From 0fbc42ebcbb138d35e98a2c2538a66aa9672824f Mon Sep 17 00:00:00 2001 From: "qiheng.zhou" Date: Tue, 4 Feb 2025 14:23:34 +0800 Subject: [PATCH] reuse write buffer --- pkg/remote/trans/gonet/bytebuffer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/remote/trans/gonet/bytebuffer.go b/pkg/remote/trans/gonet/bytebuffer.go index bf5457168e..37a0e33a6b 100644 --- a/pkg/remote/trans/gonet/bytebuffer.go +++ b/pkg/remote/trans/gonet/bytebuffer.go @@ -66,7 +66,7 @@ func NewBufferReader(ir io.Reader) remote.ByteBuffer { // NewBufferWriter creates a new remote.ByteBuffer using the given netpoll.ZeroCopyWriter. func NewBufferWriter(iw io.Writer) remote.ByteBuffer { rw := rwPool.Get().(*bufferReadWriter) - rw.writer = netpoll.NewWriter(iw) + rw.writer = netpoll.NewWriterReuseBuffer(iw) rw.ioWriter = iw rw.status = remote.BitWritable return rw