diff options
-rw-r--r-- | run.go | 7 |
1 files changed, 7 insertions, 0 deletions
@@ -88,8 +88,15 @@ func runFunc() { for cc := range clts { go func(cc *ClientConn) { + sc := cc.server() + cc.Kick("Proxy shutting down.") <-cc.Closed() + + if sc != nil { + <-sc.Closed() + } + wg.Done() }(cc) } |