@@ -93,14 +93,14 @@ func (c *Conn) WriteComBinlogDumpGTID(serverID uint32, binlogFilename string, bi
9393 4 + // data-size
9494 len (sidBlock ) // data
9595 data , pos := c .startEphemeralPacketWithHeader (length )
96- pos = writeByte (data , pos , ComBinlogDumpGTID ) // nolint
97- pos = writeUint16 (data , pos , flags ) // nolint
98- pos = writeUint32 (data , pos , serverID ) // nolint
99- pos = writeUint32 (data , pos , uint32 (len (binlogFilename ))) // nolint
100- pos = writeEOFString (data , pos , binlogFilename ) // nolint
101- pos = writeUint64 (data , pos , binlogPos ) // nolint
102- pos = writeUint32 (data , pos , uint32 (len (sidBlock ))) // nolint
103- pos += copy (data [pos :], sidBlock ) // nolint
96+ pos = writeByte (data , pos , ComBinlogDumpGTID )
97+ pos = writeUint16 (data , pos , flags )
98+ pos = writeUint32 (data , pos , serverID )
99+ pos = writeUint32 (data , pos , uint32 (len (binlogFilename )))
100+ pos = writeEOFString (data , pos , binlogFilename )
101+ pos = writeUint64 (data , pos , binlogPos )
102+ pos = writeUint32 (data , pos , uint32 (len (sidBlock )))
103+ pos += copy (data [pos :], sidBlock ) // nolint
104104 if err := c .writeEphemeralPacket (); err != nil {
105105 return sqlerror .NewSQLErrorf (sqlerror .CRServerGone , sqlerror .SSUnknownSQLState , "%v" , err )
106106 }
0 commit comments