Browse Source

release buffer in error case

Darien Raymond 6 years ago
parent
commit
8d09d74224
1 changed files with 1 additions and 0 deletions
  1. 1 0
      common/net/connection.go

+ 1 - 0
common/net/connection.go

@@ -117,6 +117,7 @@ func (c *connection) Write(b []byte) (int, error) {
 
 
 func (c *connection) WriteMultiBuffer(mb buf.MultiBuffer) error {
 func (c *connection) WriteMultiBuffer(mb buf.MultiBuffer) error {
 	if c.done.Done() {
 	if c.done.Done() {
+		buf.ReleaseMulti(mb)
 		return io.ErrClosedPipe
 		return io.ErrClosedPipe
 	}
 	}