From 7f277c9bcc12929373374c288022550398dc52b9 Mon Sep 17 00:00:00 2001 From: v2ray Date: Fri, 29 Jul 2016 12:13:20 +0200 Subject: [PATCH] prevent goroutine leak --- 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 c86fe6e6c..d2bafec98 100644 --- a/transport/internet/kcp/connection.go +++ b/transport/internet/kcp/connection.go @@ -392,6 +392,8 @@ func (this *Connection) Terminate() { log.Info("KCP|Connection: Terminating connection to ", this.RemoteAddr()) this.SetState(StateTerminated) + this.dataInputCond.Broadcast() + this.dataOutputCond.Broadcast() this.writer.Close() }