server_common/wsproxy
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
azw 2023-04-09 09:22:43 +00:00
parent 06cd9f5018
commit 179d04da21
2 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server/wsproxy/downstreammgr.cc
View File

@ -54,12 +54,11 @@ void DownStreamMgr::OnClientDisconnect(int socket_handle)
#endif #endif
} }
#if 0 void DownStreamMgr::OnUpStreamDisconnect(int instance_id)
void DownStreamMgr::OnTargetServerDisconnect(a8::XParams& param)
{ {
std::list<GameClient*> delete_client; std::list<std::shared_ptr<DownStream>> delete_client;
for (auto& pair : socket_hash_) { for (auto& pair : socket_hash_) {
if (pair.second->conn && pair.second->conn->instance_id == param.sender.GetInt()) { if (pair.second->conn && pair.second->conn->instance_id == instance_id) {
delete_client.push_back(pair.second); delete_client.push_back(pair.second);
} }
} }
@ -67,17 +66,13 @@ void DownStreamMgr::OnTargetServerDisconnect(a8::XParams& param)
RemovePendingAccount(client->socket_handle); RemovePendingAccount(client->socket_handle);
GCListener::Instance()->ForceCloseClient(client->socket_handle); GCListener::Instance()->ForceCloseClient(client->socket_handle);
socket_hash_.erase(client->socket_handle); socket_hash_.erase(client->socket_handle);
delete client;
} }
} }
#endif
#if 0 void DownStreamMgr::OnUpStreamConnect(int instance_id)
void DownStreamMgr::OnTargetServerConnect(a8::XParams& param)
{ {
} }
#endif
std::weak_ptr<DownStream> DownStreamMgr::GetGameClientBySocket(int sockhandle) std::weak_ptr<DownStream> DownStreamMgr::GetGameClientBySocket(int sockhandle)
{ {

6
server/wsproxy/downstreammgr.h
View File

@ -15,10 +15,8 @@ class DownStreamMgr : public a8::Singleton<DownStreamMgr>
void Init(); void Init();
void UnInit(); void UnInit();
#if 0 void OnUpStreamDisconnect(int instance_id);
void OnTargetServerDisconnect(a8::XParams& param); void OnUpStreamConnect(int instance_id);
void OnTargetServerConnect(a8::XParams& param);
#endif
std::weak_ptr<DownStream> GetGameClientBySocket(int sockhande); std::weak_ptr<DownStream> GetGameClientBySocket(int sockhande);
void BindUpStream(int socket_handle, int conn_instance_id); void BindUpStream(int socket_handle, int conn_instance_id);
void AddPendingAccount(const std::string& account_id, int socket_handle, long long req_tick); void AddPendingAccount(const std::string& account_id, int socket_handle, long long req_tick);