diff --git a/common/io/transport.go b/common/io/transport.go index 4cb045f0..503fba3e 100644 --- a/common/io/transport.go +++ b/common/io/transport.go @@ -20,6 +20,7 @@ func Pipe(reader Reader, writer Writer) error { err = writer.Write(buffer) if err != nil { log.Debug("IO: Pipe exits as ", err) + buffer.Release() return err } }