diff --git a/transport/internet/kcp/connection.go b/transport/internet/kcp/connection.go index 092f9b0e..991ca878 100644 --- a/transport/internet/kcp/connection.go +++ b/transport/internet/kcp/connection.go @@ -359,7 +359,7 @@ func (this *Connection) updateTask() { func (this *Connection) FetchInputFrom(conn io.Reader) { go func() { - payload := alloc.NewBuffer() + payload := alloc.NewLocalBuffer(2048) defer payload.Release() for { payload.Reset()