diff --git a/client.go b/client.go index c785fbd..7a14082 100644 --- a/client.go +++ b/client.go @@ -1015,7 +1015,6 @@ func (c *HostClient) acquireWriter(conn net.Conn) *bufio.Writer { } func (c *HostClient) releaseWriter(bw *bufio.Writer) { - bw.Reset(nil) c.writerPool.Put(bw) } @@ -1034,7 +1033,6 @@ func (c *HostClient) acquireReader(conn net.Conn) *bufio.Reader { } func (c *HostClient) releaseReader(br *bufio.Reader) { - br.Reset(nil) c.readerPool.Put(br) } diff --git a/compress.go b/compress.go index d9f28b3..18e2d8d 100644 --- a/compress.go +++ b/compress.go @@ -89,7 +89,6 @@ func acquireGzipWriter(w io.Writer, level int) *gzipWriter { func releaseGzipWriter(zw *gzipWriter) { zw.Close() - zw.Reset(nil) zw.p.Put(zw) } @@ -133,7 +132,6 @@ func acquireFlateWriter(w io.Writer, level int) *flateWriter { func releaseFlateWriter(zw *flateWriter) { zw.Close() - zw.Reset(nil) zw.p.Put(zw) } diff --git a/server.go b/server.go index 93e3c5d..24cb233 100644 --- a/server.go +++ b/server.go @@ -1407,7 +1407,6 @@ func acquireReader(ctx *RequestCtx) *bufio.Reader { } func releaseReader(s *Server, r *bufio.Reader) { - r.Reset(nil) s.readerPool.Put(r) } @@ -1426,7 +1425,6 @@ func acquireWriter(ctx *RequestCtx) *bufio.Writer { } func releaseWriter(s *Server, w *bufio.Writer) { - w.Reset(nil) s.writerPool.Put(w) } diff --git a/stream.go b/stream.go index 2d9723a..377ff46 100644 --- a/stream.go +++ b/stream.go @@ -26,12 +26,11 @@ func NewStreamReader(sw StreamWriter) io.Reader { pr, pw := io.Pipe() var bw *bufio.Writer - bwv := streamWriterBufPool.Get() - if bwv == nil { + v := streamWriterBufPool.Get() + if v == nil { bw = bufio.NewWriter(pw) - bwv = bw } else { - bw = bwv.(*bufio.Writer) + bw = v.(*bufio.Writer) bw.Reset(pw) } @@ -46,8 +45,7 @@ func NewStreamReader(sw StreamWriter) io.Reader { bw.Flush() pw.Close() - bw.Reset(nil) - streamWriterBufPool.Put(bwv) + streamWriterBufPool.Put(bw) }() return pr