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 06:59:55 +00:00
parent 4dbd7177d6
commit 5a051c97cc
4 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/wsproxy/app.cc
View File

@ -444,7 +444,7 @@ void App::ProcessClientMsg(f8::MsgHdr& hdr)
return;
}
} else {
GameClient* client = GameClientMgr::Instance()->GetGameClientBySocket(hdr.socket_handle);
Client* client = GameClientMgr::Instance()->GetGameClientBySocket(hdr.socket_handle);
if (client) {
conn = client->conn;
}

2
server/wsproxy/client.h
View File

@ -1,7 +1,7 @@
#pragma once
class TargetConn;
class GameClient
class Client
{
public:
int socket_handle = a8::INVALID_SOCKET_HANDLE;

6
server/wsproxy/gameclientmgr.cc
View File

@ -67,7 +67,7 @@ void GameClientMgr::OnTargetServerConnect(a8::XParams& param)
}
#endif
GameClient* GameClientMgr::GetGameClientBySocket(int sockhandle)
Client* GameClientMgr::GetGameClientBySocket(int sockhandle)
{
auto itr = socket_hash_.find(sockhandle);
return itr != socket_hash_.end() ? itr->second : nullptr;
@ -77,11 +77,11 @@ void GameClientMgr::BindTargetConn(int socket_handle, int conn_instance_id)
{
TargetConn* conn = TargetConnMgr::Instance()->GetConnById(conn_instance_id);
if (conn) {
GameClient* client = GetGameClientBySocket(socket_handle);
Client* client = GetGameClientBySocket(socket_handle);
if (client) {
client->conn = conn;
} else {
client = new GameClient();
client = new Client();
client->socket_handle = socket_handle;
client->conn = conn;
socket_hash_[client->socket_handle] = client;

6
server/wsproxy/gameclientmgr.h
View File

@ -2,7 +2,7 @@
#include <f8/timer.h>
class GameClient;
class Client;
class GameClientMgr : public a8::Singleton<GameClientMgr>
{
private:
@ -19,7 +19,7 @@ class GameClientMgr : public a8::Singleton<GameClientMgr>
void OnTargetServerDisconnect(a8::XParams& param);
void OnTargetServerConnect(a8::XParams& param);
#endif
GameClient* GetGameClientBySocket(int sockhande);
Client* GetGameClientBySocket(int sockhande);
void BindTargetConn(int socket_handle, int conn_instance_id);
void AddPendingAccount(const std::string& account_id, int socket_handle, long long req_tick);
@ -29,7 +29,7 @@ private:
private:
a8::Attacher timer_attacher_;
std::map<int, GameClient*> socket_hash_;
std::map<int, Client*> socket_hash_;
#if 0
std::map<int, std::tuple<std::string, long long, timer_list*>> pending_account_hash_;
#endif