From 1dcd9afe59664f8f3af3c21f8bc7e0f756d663cc Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Fri, 8 Sep 2023 14:27:29 +0800 Subject: [PATCH] 1 --- server/hallserver/listener/handlermgr.go | 2 +- server/hallserver/listener/wsplistener.go | 7 +++---- server/hallserver/player/player.go | 1 - server/hallserver/player/playermgr.go | 4 ++++ 4 files changed, 8 insertions(+), 6 deletions(-) diff --git a/server/hallserver/listener/handlermgr.go b/server/hallserver/listener/handlermgr.go index 9d493151..d7de2c51 100644 --- a/server/hallserver/listener/handlermgr.go +++ b/server/hallserver/listener/handlermgr.go @@ -12,8 +12,8 @@ type HandlerMgr struct { func (this *HandlerMgr) Init() { ss.RegHandlerId(int(ss.SSMessageIdE__SS_Ping), constant.WSP_LISTENER_HANDLER_ID) - ss.RegHandlerId(int(ss.SSMessageIdE__SS_WSP_SocketDisconnect), constant.WSP_LISTENER_HANDLER_ID) + ss.RegHandlerId(int(ss.SSMessageIdE__SS_WSP_SocketDisconnect), constant.PLAYER_MGR_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMPing), constant.PLAYER_MGR_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMLogin), constant.PLAYER_MGR_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMReconnect), constant.PLAYER_MGR_HANDLER_ID) diff --git a/server/hallserver/listener/wsplistener.go b/server/hallserver/listener/wsplistener.go index e393f830..a9bc0c2c 100644 --- a/server/hallserver/listener/wsplistener.go +++ b/server/hallserver/listener/wsplistener.go @@ -27,7 +27,7 @@ func (this *WSPListener) Init() { listener, err := net.Listen("tcp", "0.0.0.0:"+ q5.ToString(mt.Table.HallCluster.GetListenPort())) if err != nil { - + panic(err) } else { this.listener = listener go this.parseNetPkt() @@ -39,9 +39,8 @@ func (this *WSPListener) UnInit() { } func (this *WSPListener) SS_ping(hdr *f5.MsgHdr, msg *ss.SS_Ping) { -} - -func (this *WSPListener) SS_WSP_SocketDisconnect(hdr *f5.MsgHdr, msg *ss.SS_WSP_SocketDisconnect) { + rspMsg := ss.SS_Pong{} + this.SendProxyMsg(hdr.Conn, 0, &rspMsg) } func (this *WSPListener) accept() { diff --git a/server/hallserver/player/player.go b/server/hallserver/player/player.go index 9f7bdbb4..f34d31a3 100644 --- a/server/hallserver/player/player.go +++ b/server/hallserver/player/player.go @@ -28,7 +28,6 @@ func (this *player) GetRoom() *common.Room { return this.room } - func (this *player) init(req *pendingLoginRequest){ this.socket = req.hdr.GetSocket() this.accountId = req.msg.GetAccountId() diff --git a/server/hallserver/player/playermgr.go b/server/hallserver/player/playermgr.go index f0fc7cf4..5e27cf94 100644 --- a/server/hallserver/player/playermgr.go +++ b/server/hallserver/player/playermgr.go @@ -2,6 +2,7 @@ package player import ( "cs" + "ss" "encoding/json" "f5" "fmt" @@ -223,3 +224,6 @@ func (this *playerMgr) genSeqId() *int64 { reqId := this.currReqId return &reqId } + +func (this *playerMgr) SS_WSP_SocketDisconnect(hdr *f5.MsgHdr, msg *ss.SS_WSP_SocketDisconnect) { +}