server/game2006go
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-03-21 11:41:40 +08:00
parent 65ebd56c28
commit 19df707e84
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/imserver_new/listener/wsplistener.go
View File

@ -18,8 +18,8 @@ import (
type WSPListener struct {
ss.MsgHandlerImpl
listener net.Listener
ch chan *f5.MsgHdr
msgList q5.ListHead
ch chan *f5.MsgHdr
msgList q5.ListHead
}
func (this *WSPListener) init() {
@ -39,9 +39,12 @@ func (this *WSPListener) unInit() {
}
func (this *WSPListener) SS_ping(hdr *f5.MsgHdr, msg *ss.SS_Ping) {
rspMsg := ss.SS_Pong{}
this.sendProxyMsg(hdr.Conn, 0, &rspMsg)
}
func (this *WSPListener) SS_WSP_SocketDisconnect(hdr *f5.MsgHdr, msg *ss.SS_WSP_SocketDisconnect) {
GetPlayerMgr().OnSocketClose(hdr.GetSocket())
}
func (this *WSPListener) accept() {

4
server/imserver_new/player/playermgr.go
View File

@ -55,7 +55,7 @@ func (this *playerMgr) init() {
}
}
for socket, _ := range deletedPlayers {
this.onSocketClose(socket)
this.OnSocketClose(socket)
}
})
@ -276,7 +276,7 @@ func (this *playerMgr) CMReconnect(hdr *f5.MsgHdr, msg *cs.CMReconnect) {
GetWspListener().SendProxyMsg(hdr.Conn, hdr.SocketHandle, rspMsg)
}
func (this *playerMgr) onSocketClose(conn f5.WspCliConn) {
func (this *playerMgr) OnSocketClose(conn f5.WspCliConn) {
hum := this.internalGetPlayerBySocket(conn)
if hum == nil {
return