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

1

Browse Source
This commit is contained in:
aozhiwei 2020-05-03 22:28:17 +08:00
parent 8c26eae458
commit 4185df5829
3 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/imserver/app.cc
View File

@ -396,6 +396,14 @@ void App::ProcessWSProxyMsg(f8::MsgHdr& hdr)
ProcessNetMsg(handler, WSListener::Instance(), hdr); ProcessNetMsg(handler, WSListener::Instance(), hdr);
} }
break; break;
case HID_Player:
{
Player* hum = PlayerMgr::Instance()->GetPlayerBySocket(hdr.socket_handle);
if (hum) {
ProcessNetMsg(handler, hum, hdr);
}
}
break;
case HID_PlayerMgr: case HID_PlayerMgr:
{ {
ProcessNetMsg(handler, PlayerMgr::Instance(), hdr); ProcessNetMsg(handler, PlayerMgr::Instance(), hdr);

6
server/imserver/playermgr.cc
View File

@ -38,6 +38,12 @@ Player* PlayerMgr::GetPlayerBySocket(int socket)
return itr != socket_hash_.end() ? itr->second : nullptr; return itr != socket_hash_.end() ? itr->second : nullptr;
} }
Player* PlayerMgr::GetPlayerByAccountId(const std::string& account_id)
{
auto itr = accountid_hash_.find(account_id);
return itr != accountid_hash_.end() ? itr->second : nullptr;
}
void PlayerMgr::OnClientDisconnect(a8::XParams& param) void PlayerMgr::OnClientDisconnect(a8::XParams& param)
{ {
int gg_socket = param.sender; int gg_socket = param.sender;

4
server/imserver/playermgr.h
View File

@ -27,9 +27,11 @@ class PlayerMgr : public a8::Singleton<PlayerMgr>
void _SS_WSP_SocketDisconnect(f8::MsgHdr& hdr, const ss::SS_WSP_SocketDisconnect& msg); void _SS_WSP_SocketDisconnect(f8::MsgHdr& hdr, const ss::SS_WSP_SocketDisconnect& msg);
void _CMLogin(f8::MsgHdr& hdr, const cs::CMLogin& msg); void _CMLogin(f8::MsgHdr& hdr, const cs::CMLogin& msg);
Player* GetPlayerBySocket(int socket);
Player* GetPlayerByAccountId(const std::string& account_id);
private: private:
int OnlineNum(); int OnlineNum();
Player* GetPlayerBySocket(int socket);
void OnClientDisconnect(a8::XParams& param); void OnClientDisconnect(a8::XParams& param);
void RemovePlayerBySocket(int socket_handle); void RemovePlayerBySocket(int socket_handle);