ayo/gocommon
8
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

base: ayo:ca5632031c868dfaee4504047b27fe3fbdac4392
Branches Tags
ayo:master ayo:ds-live ayo:ds ayo:new_conn ayo:kd-live
..
compare: ayo:86fac6bbc07204c4ebe5fa0e7ac9e018531a9504
Branches Tags
ayo:master ayo:ds-live ayo:ds ayo:new_conn ayo:kd-live

2 Commits
ca5632031c ... 86fac6bbc0

Author SHA1 Message Date
mountain
86fac6bbc0 Merge branch 'master' of https://repositories.action2quare.com/ayo/gocommon 2024-08-08 11:42:52 +09:00
mountain
70d3b2507c 로그 추가 2024-08-08 11:42:49 +09:00
1 changed files with 3 additions and 0 deletions
Expand all files Collapse all files

3
wshandler/wshandler.go
View File

@ -586,9 +586,11 @@ func upgrade_core(ws *WebsocketHandler, conn *Conn, accid primitive.ObjectID, al
ws.connWaitGroup.Done() ws.connWaitGroup.Done()
}() }()
logger.Println("wshandler connected :", accid)
for { for {
messageType, r, err := c.innerConn.NextReader() messageType, r, err := c.innerConn.NextReader()
if err != nil { if err != nil {
logger.Println("wshandler NextReader err :", messageType, err)
if ce, ok := err.(*websocket.CloseError); ok { if ce, ok := err.(*websocket.CloseError); ok {
c.closeMessage = ce.Text 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) ws.Call(newconn.sender, string(cmd), r)
} }
} }
logger.Println("wshandler disconnected :", accid, c.closeMessage)
c.Conn = nil c.Conn = nil
if c.closeMessage != ForceShutdownCloseMessage { if c.closeMessage != ForceShutdownCloseMessage {
ws.connInOutChan <- c ws.connInOutChan <- c