From ae52e325a243af58d3bf36686dec0e8b40d85894 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Sun, 11 Feb 2018 02:08:20 +0100 Subject: [PATCH] send ack more frequently too --- transport/internet/kcp/connection.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/transport/internet/kcp/connection.go b/transport/internet/kcp/connection.go index c7f40642..fd039605 100644 --- a/transport/internet/kcp/connection.go +++ b/transport/internet/kcp/connection.go @@ -258,6 +258,7 @@ func (c *Connection) ReadMultiBuffer() (buf.MultiBuffer, error) { } mb := c.receivingWorker.ReadMultiBuffer() if !mb.IsEmpty() { + c.dataUpdater.WakeUp() return mb, nil } @@ -307,6 +308,7 @@ func (c *Connection) Read(b []byte) (int, error) { } nBytes := c.receivingWorker.Read(b) if nBytes > 0 { + c.dataUpdater.WakeUp() return nBytes, nil }