diff --git a/wshandler/wshandler.go b/wshandler/wshandler.go index d9d9d21..ec832ad 100644 --- a/wshandler/wshandler.go +++ b/wshandler/wshandler.go @@ -297,7 +297,7 @@ func (ws *WebsocketHandler) mainLoop(ctx context.Context) { defer func() { for _, conn := range entireConns { - ws.Call(conn.sender, ClientDisconnected, nil) + ws.ClientDisconnected(conn) conn.Close() } }() @@ -459,11 +459,9 @@ func (ws *WebsocketHandler) mainLoop(ctx context.Context) { case c := <-ws.connInOutChan: if c.Conn == nil { delete(entireConns, c.sender.Accid.Hex()) - logger.Println("ClientDisconnected :", c.sender.Alias) go ws.ClientDisconnected(c) } else { entireConns[c.sender.Accid.Hex()] = c - logger.Println("ClientConnected :", c.sender.Alias) go ws.ClientConnected(c) }