로그 추가

This commit is contained in:
2024-08-08 11:42:49 +09:00
parent 38c5e05d4c
commit 70d3b2507c

View File

@ -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