diff --git a/transport/pipe/impl.go b/transport/pipe/impl.go
index 4fee384dd..b795aa749 100644
--- a/transport/pipe/impl.go
+++ b/transport/pipe/impl.go
@@ -6,6 +6,7 @@ import (
 	"sync"
 	"time"
 
+	"v2ray.com/core/common"
 	"v2ray.com/core/common/buf"
 	"v2ray.com/core/common/signal"
 	"v2ray.com/core/common/signal/done"
@@ -106,6 +107,7 @@ func (p *pipe) writeMultiBufferInternal(mb buf.MultiBuffer) error {
 	defer p.Unlock()
 
 	if err := p.getState(false); err != nil {
+		mb.Release()
 		return err
 	}
 
@@ -142,7 +144,7 @@ func (p *pipe) Close() error {
 	}
 
 	p.state = closed
-	p.done.Close()
+	common.Must(p.done.Close())
 	return nil
 }
 
@@ -161,5 +163,5 @@ func (p *pipe) CloseError() {
 		p.data = nil
 	}
 
-	p.done.Close()
+	common.Must(p.done.Close())
 }