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-25 07:00:25 +00:00
parent 86a709acbf
commit 9f7276a776
5 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/wsproxy/GCListener.cc
View File

@ -193,3 +193,8 @@ bool GCListener::GetWebSocketUrl(int socket_handle, std::string& url, std::strin
return false; return false;
} }
} }
int GCListener::GetSocketCount()
{
return tcp_listener_->GetClientSocketCount();
}

1
server/wsproxy/GCListener.h
View File

@ -40,6 +40,7 @@ class GCListener : public a8::Singleton<GCListener>
long long GetSendNodeNum(); long long GetSendNodeNum();
long long GetSentBytesNum(); long long GetSentBytesNum();
bool GetWebSocketUrl(int socket_handle, std::string& url, std::string& query_str); bool GetWebSocketUrl(int socket_handle, std::string& url, std::string& query_str);
int GetSocketCount();
private: private:
a8::TcpListener *tcp_listener_ = nullptr; a8::TcpListener *tcp_listener_ = nullptr;

6
server/wsproxy/app.cc
View File

@ -55,10 +55,10 @@ const char* const PROJ_LOG_FILENAME_FMT = "log_$pid_%Y%m%d.log";
static void SavePerfLog() 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", "max_join_time:%d tcp_count:%d udp_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,
@ -69,6 +69,8 @@ static void SavePerfLog()
App::Instance()->GetPerf().read_count, App::Instance()->GetPerf().read_count,
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(),
LongSessionMgr::Instance()->GetLongSessionCount()
}); });
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/longsessionmgr.cc
View File

@ -126,3 +126,8 @@ void LongSessionMgr::DelSession(int socket_handle)
} }
socket_handle_hash_.erase(socket_handle); socket_handle_hash_.erase(socket_handle);
} }
int LongSessionMgr::GetLongSessionCount()
{
return socket_handle_hash_.size();
}

1
server/wsproxy/longsessionmgr.h
View File

@ -31,6 +31,7 @@ class LongSessionMgr : public a8::Singleton<LongSessionMgr>
std::shared_ptr<LongSession> GetSession(int socket_handle); std::shared_ptr<LongSession> GetSession(int socket_handle);
std::shared_ptr<a8::UdpListener> GetUdpListener() { return udp_listener_; } std::shared_ptr<a8::UdpListener> GetUdpListener() { return udp_listener_; }
void DelSession(int socket_handle); void DelSession(int socket_handle);
int GetLongSessionCount();
private: private:
std::shared_ptr<a8::UdpListener> udp_listener_; std::shared_ptr<a8::UdpListener> udp_listener_;