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

잘못된 호출 수정

Browse Source
This commit is contained in:
mountain
2024-02-13 15:06:46 +09:00
parent d8156a96ee
commit bef684b3fe
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
wshandler/wshandler.go
View File

@ -297,7 +297,7 @@ func (ws *WebsocketHandler) mainLoop(ctx context.Context) {
defer func() { defer func() {
for _, conn := range entireConns { for _, conn := range entireConns {
ws.Call(conn.sender, ClientDisconnected, nil) ws.ClientDisconnected(conn)
conn.Close() conn.Close()
} }
}() }()
@ -459,11 +459,9 @@ func (ws *WebsocketHandler) mainLoop(ctx context.Context) {
case c := <-ws.connInOutChan: case c := <-ws.connInOutChan:
if c.Conn == nil { if c.Conn == nil {
delete(entireConns, c.sender.Accid.Hex()) delete(entireConns, c.sender.Accid.Hex())
logger.Println("ClientDisconnected :", c.sender.Alias)
go ws.ClientDisconnected(c) go ws.ClientDisconnected(c)
} else { } else {
entireConns[c.sender.Accid.Hex()] = c entireConns[c.sender.Accid.Hex()] = c
logger.Println("ClientConnected :", c.sender.Alias)
go ws.ClientConnected(c) go ws.ClientConnected(c)
} }