diff --git a/wshandler/wshandler.go b/wshandler/wshandler.go index 2e56fe1..78029b3 100644 --- a/wshandler/wshandler.go +++ b/wshandler/wshandler.go @@ -586,9 +586,11 @@ func upgrade_core(ws *WebsocketHandler, conn *Conn, accid primitive.ObjectID, al ws.connWaitGroup.Done() }() + logger.Println("wshandler connected :", accid) for { messageType, r, err := c.innerConn.NextReader() if err != nil { + logger.Println("wshandler NextReader err :", messageType, err) if ce, ok := err.(*websocket.CloseError); ok { c.closeMessage = ce.Text } @@ -610,6 +612,7 @@ func upgrade_core(ws *WebsocketHandler, conn *Conn, accid primitive.ObjectID, al ws.Call(newconn.sender, string(cmd), r) } } + logger.Println("wshandler disconnected :", accid, c.closeMessage) c.Conn = nil if c.closeMessage != ForceShutdownCloseMessage { ws.connInOutChan <- c