release read buffer

ppzqh · Feb 4, 2025 · 1a3e677 · 1a3e677
1 parent 28d0fc1
commit 1a3e677
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/remote/trans/gonet/trans_server.go b/pkg/remote/trans/gonet/trans_server.go
@@ -92,7 +92,7 @@ func (ts *transServer) BootstrapServer(ln net.Listener) (err error) {
 			defer func() {
 				transRecover(ctx, conn, "OnRead")
 			}()
-			bc := newBufioConn(conn)
+			bc := conn //newBufioConn(conn)
 			ctx, err = ts.transHdlr.OnActive(ctx, bc)
 			if err != nil {
 				klog.CtxErrorf(ctx, "KITEX: OnActive error=%s", err)
@@ -166,7 +166,7 @@ type bufioConn struct {
 func newBufioConn(c net.Conn) *bufioConn {
 	return &bufioConn{
 		conn: c,
-		r:    netpoll.NewReader(c),
+		r:    netpoll.NewReaderReuseBuffer(c),
 	}
 }