hyung-hwan/hodu
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fired CONN_UPDATED from receive_from_stream

Browse Source
This commit is contained in:
hyung-hwan 2025-03-18 23:45:00 +09:00
parent 5fa6cd466b
commit 9865914436
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server.go
View File

@ -889,6 +889,19 @@ func (cts *ServerConn) receive_from_stream(wg *sync.WaitGroup) {
cts.S.cts_map_by_token[x.Conn.Token] = cts cts.S.cts_map_by_token[x.Conn.Token] = cts
cts.S.cts_mtx.Unlock() cts.S.cts_mtx.Unlock()
cts.S.log.Write(cts.Sid, LOG_INFO, "client(%d) %s - token set to '%s'", cts.Id, cts.RemoteAddr, x.Conn.Token) cts.S.log.Write(cts.Sid, LOG_INFO, "client(%d) %s - token set to '%s'", cts.Id, cts.RemoteAddr, x.Conn.Token)
cts.S.bulletin.Enqueue(
&ServerEvent{
Kind: SERVER_EVENT_CONN_UPDATED,
Data: &ServerEventConnAdded{
Conn: cts.Id,
ServerAddr: cts.LocalAddr.String(),
ClientAddr: cts.RemoteAddr.String(),
ClientToken: cts.ClientToken.Get(),
CreatedMilli: cts.Created.UnixMilli(),
},
},
)
} }
} }
} }