fix/flushBuf: defer reset buf.

ClickHouse · Sep 19, 2024 · 181c5a5 · 181c5a5
1 parent a64f2cd
commit 181c5a5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client.go b/client.go
@@ -255,6 +255,7 @@ func (c *Client) packet(ctx context.Context) (proto.ServerCode, error) {
 }
 
 func (c *Client) flushBuf(ctx context.Context, b *proto.Buffer) error {
+	defer b.Reset()
 	if err := ctx.Err(); err != nil {
 		return errors.Wrap(err, "context")
 	}
@@ -279,7 +280,6 @@ func (c *Client) flushBuf(ctx context.Context, b *proto.Buffer) error {
 	if ce := c.lg.Check(zap.DebugLevel, "Flush"); ce != nil {
 		ce.Write(zap.Int("bytes", n))
 	}
-	b.Reset()
 	return nil
 }