From 2a04819582c64071c46c765df8a71691cc230994 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Fri, 20 Oct 2017 23:30:14 +0200 Subject: [PATCH] fix data race in kcp connection --- transport/internet/kcp/receiving.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/transport/internet/kcp/receiving.go b/transport/internet/kcp/receiving.go index 7c10dad57..5024628be 100644 --- a/transport/internet/kcp/receiving.go +++ b/transport/internet/kcp/receiving.go @@ -256,7 +256,7 @@ func (v *ReceivingWorker) Write(seg Segment) error { ackSeg.Conv = v.conn.conv ackSeg.ReceivingNext = v.nextNumber ackSeg.ReceivingWindow = v.nextNumber + v.windowSize - if v.conn.state == StateReadyToClose { + if v.conn.State() == StateReadyToClose { ackSeg.Option = SegmentOptionClose } return v.conn.output.Write(ackSeg)