diff --git a/serversession.go b/serversession.go index 83cb6f62..e9ebc8e9 100644 --- a/serversession.go +++ b/serversession.go @@ -351,6 +351,9 @@ func (ss *ServerSession) run() { } for sc := range ss.conns { + if sc == ss.tcpConn { + sc.Close() + } sc.sessionRemove <- ss } ss.connsWG.Wait()