Compare commits
2 Commits
ca5632031c
...
86fac6bbc0
| Author | SHA1 | Date | |
|---|---|---|---|
| 86fac6bbc0 | |||
| 70d3b2507c |
@ -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
|
||||
|
||||
Reference in New Issue
Block a user