From 88c9947285df8d042a4059e995546200d4bcf90a Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Tue, 6 Dec 2016 11:27:58 +0100 Subject: [PATCH] simplify chain writing --- common/io/chain_writer.go | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) diff --git a/common/io/chain_writer.go b/common/io/chain_writer.go index 79d20acb..70b751c5 100644 --- a/common/io/chain_writer.go +++ b/common/io/chain_writer.go @@ -29,16 +29,10 @@ func (v *ChainWriter) Write(payload []byte) (int, error) { size := len(payload) for size > 0 { buffer := alloc.NewBuffer() - if size > alloc.BufferSize { - buffer.Append(payload[:alloc.BufferSize]) - size -= alloc.BufferSize - payload = payload[alloc.BufferSize:] - bytesWritten += alloc.BufferSize - } else { - buffer.Append(payload) - bytesWritten += size - size = 0 - } + nBytes, _ := buffer.Write(payload) + size -= nBytes + payload = payload[nBytes:] + bytesWritten += nBytes err := v.writer.Write(buffer) if err != nil { return bytesWritten, err