From 70d3b2507cf5d0fffa7c26969ec2ee7204908414 Mon Sep 17 00:00:00 2001 From: mountain Date: Thu, 8 Aug 2024 11:42:49 +0900 Subject: [PATCH] =?UTF-8?q?=EB=A1=9C=EA=B7=B8=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- wshandler/wshandler.go | 3 +++ 1 file changed, 3 insertions(+) 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