diff --git a/common/net/connection.go b/common/net/connection.go index a035803f..0540ce99 100644 --- a/common/net/connection.go +++ b/common/net/connection.go @@ -117,6 +117,7 @@ func (c *connection) Write(b []byte) (int, error) { func (c *connection) WriteMultiBuffer(mb buf.MultiBuffer) error { if c.done.Done() { + buf.ReleaseMulti(mb) return io.ErrClosedPipe }