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-26 06:58:30 +00:00
parent a4e1fbd27e
commit 9fb8c7c51a
3 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/wsproxy/app.cc
View File

@ -58,7 +58,7 @@ static void SavePerfLog()
f8::UdpLog::Instance()->Info("max_run_delay_time:%d max_timer_idle:%d " f8::UdpLog::Instance()->Info("max_run_delay_time:%d max_timer_idle:%d "
"in_data_size:%d out_data_size:%d msgnode_size:%d udp_msgnode_size:%d " "in_data_size:%d out_data_size:%d msgnode_size:%d udp_msgnode_size:%d "
"read_count:%d max_login_time:%d " "read_count:%d max_login_time:%d "
"max_join_time:%d tcp_count:%d udp_count:%d", "max_join_time:%d tcp_count:%d udp_count:%d down_stream_count:%d",
{ {
App::Instance()->GetPerf().max_run_delay_time, App::Instance()->GetPerf().max_run_delay_time,
App::Instance()->GetPerf().max_timer_idle, App::Instance()->GetPerf().max_timer_idle,
@ -70,7 +70,8 @@ static void SavePerfLog()
App::Instance()->GetPerf().max_login_time, App::Instance()->GetPerf().max_login_time,
App::Instance()->GetPerf().max_join_time, App::Instance()->GetPerf().max_join_time,
GCListener::Instance()->GetSocketCount(), GCListener::Instance()->GetSocketCount(),
LongSessionMgr::Instance()->GetLongSessionCount() LongSessionMgr::Instance()->GetLongSessionCount(),
DownStreamMgr::Instance()->GetDownStreamCount()
}); });
if (App::Instance()->HasFlag(2)) { if (App::Instance()->HasFlag(2)) {
a8::XPrintf("mainloop_time:%d netmsg_time:%d send_node_num:%d sent_bytes_num:%d\n", a8::XPrintf("mainloop_time:%d netmsg_time:%d send_node_num:%d sent_bytes_num:%d\n",

5
server/wsproxy/downstreammgr.cc
View File

@ -152,3 +152,8 @@ void DownStreamMgr::RemovePendingAccount(int socket_handle)
pending_account_hash_.erase(itr); pending_account_hash_.erase(itr);
} }
} }
int DownStreamMgr::GetDownStreamCount()
{
return socket_hash_.size();
}

1
server/wsproxy/downstreammgr.h
View File

@ -20,6 +20,7 @@ class DownStreamMgr : public a8::Singleton<DownStreamMgr>
std::weak_ptr<DownStream> GetDownStream(int sockhande); std::weak_ptr<DownStream> GetDownStream(int sockhande);
void BindUpStream(int socket_handle, int instance_id); void BindUpStream(int socket_handle, int 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);
int GetDownStreamCount();
private: private: