From 9ee9af9e027855311a36187260bf6640fef5e77e Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Sun, 29 Jul 2018 03:23:59 +0200 Subject: [PATCH] fix mb copy again --- transport/internet/kcp/connection.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/transport/internet/kcp/connection.go b/transport/internet/kcp/connection.go index 1987b1ea..460aa2a4 100644 --- a/transport/internet/kcp/connection.go +++ b/transport/internet/kcp/connection.go @@ -392,21 +392,21 @@ func (c *Connection) WriteMultiBuffer(mb buf.MultiBuffer) error { } }() + mbPtr := &mb + for { for { if c == nil || c.State() != StateActive { return io.ErrClosedPipe } - mbPtr := &mb - if !c.sendingWorker.Push(func(bb []byte) (int, error) { return mbPtr.Read(bb[:c.mss]) }) { break } updatePending = true - if mb.IsEmpty() { + if mbPtr.IsEmpty() { return nil } }