diff --git a/transport/internet/kcp/receiving.go b/transport/internet/kcp/receiving.go index 8320a976..18dfaa15 100644 --- a/transport/internet/kcp/receiving.go +++ b/transport/internet/kcp/receiving.go @@ -274,9 +274,6 @@ func (this *ReceivingWorker) DumpWindow() { } func (this *ReceivingWorker) Read(b []byte) (int, error) { - this.Lock() - defer this.Unlock() - return this.queue.Read(b) }