diff --git a/transport/internet/kcp/listener.go b/transport/internet/kcp/listener.go index 1a173d7c..494468cf 100644 --- a/transport/internet/kcp/listener.go +++ b/transport/internet/kcp/listener.go @@ -121,6 +121,9 @@ func (this *Listener) Close() error { this.running = false close(this.awaitingConns) + for _, conn := range this.sessions { + go conn.Terminate() + } this.hub.Close() return nil