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:
aozhiwei 2019-12-13 10:32:18 +08:00
parent d4ab89adfb
commit cd6f90eab8
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/wsproxy/gameclientmgr.cc
View File

@ -75,6 +75,7 @@ void GameClientMgr::BindTargetConn(int socket_handle, int conn_instance_id)
client->socket_handle = socket_handle;
client->conn = conn;
socket_hash_[client->socket_handle] = client;
a8::UdpLog::Instance()->Info("BindTargetConn socket_handle:%d", {socket_handle});
{
auto itr = pending_account_hash_.find(socket_handle);
if (itr != pending_account_hash_.end()) {
@ -91,6 +92,7 @@ void GameClientMgr::BindTargetConn(int socket_handle, int conn_instance_id)
cur_tick - req_tick
});
}
a8::UdpLog::Instance()->Info("BindTargetConn account_id:%s", {account_id});
RemovePendingAccount(socket_handle);
}
}
@ -100,6 +102,7 @@ void GameClientMgr::BindTargetConn(int socket_handle, int conn_instance_id)
void GameClientMgr::AddPendingAccount(const std::string& account_id, int socket_handle, long long req_tick)
{
a8::UdpLog::Instance()->Info("AddPendingAccount %s %d", {account_id, socket_handle});
auto itr = pending_account_hash_.find(socket_handle);
if (itr == pending_account_hash_.end()){
timer_list* timer = a8::Timer::Instance()->AddDeadLineTimerAndAttach(1000 * 10,
@ -122,6 +125,7 @@ void GameClientMgr::AddPendingAccount(const std::string& account_id, int socket_
void GameClientMgr::RemovePendingAccount(int socket_handle)
{
a8::UdpLog::Instance()->Info("RemovePendingAccount %d", {socket_handle});
auto itr = pending_account_hash_.find(socket_handle);
if (itr != pending_account_hash_.end()) {
a8::Timer::Instance()->DeleteTimer(std::get<2>(itr->second));