From 9f7276a776fb350b585545c9f5108901cedc3899 Mon Sep 17 00:00:00 2001
From: azw <vcl_delphi@126.com>
Date: Tue, 25 Apr 2023 07:00:25 +0000
Subject: [PATCH] 1

---
 server/wsproxy/GCListener.cc     | 5 +++++
 server/wsproxy/GCListener.h      | 1 +
 server/wsproxy/app.cc            | 6 ++++--
 server/wsproxy/longsessionmgr.cc | 5 +++++
 server/wsproxy/longsessionmgr.h  | 1 +
 5 files changed, 16 insertions(+), 2 deletions(-)

diff --git a/server/wsproxy/GCListener.cc b/server/wsproxy/GCListener.cc
index d3c3220..0fe6f27 100644
--- a/server/wsproxy/GCListener.cc
+++ b/server/wsproxy/GCListener.cc
@@ -193,3 +193,8 @@ bool GCListener::GetWebSocketUrl(int socket_handle, std::string& url, std::strin
         return false;
     }
 }
+
+int GCListener::GetSocketCount()
+{
+    return tcp_listener_->GetClientSocketCount();
+}
diff --git a/server/wsproxy/GCListener.h b/server/wsproxy/GCListener.h
index 4aa30d5..dd3bfd7 100644
--- a/server/wsproxy/GCListener.h
+++ b/server/wsproxy/GCListener.h
@@ -40,6 +40,7 @@ class GCListener : public a8::Singleton<GCListener>
     long long GetSendNodeNum();
     long long GetSentBytesNum();
     bool GetWebSocketUrl(int socket_handle, std::string& url, std::string& query_str);
+    int GetSocketCount();
 
 private:
     a8::TcpListener *tcp_listener_ = nullptr;
diff --git a/server/wsproxy/app.cc b/server/wsproxy/app.cc
index 3c99376..6b47615 100644
--- a/server/wsproxy/app.cc
+++ b/server/wsproxy/app.cc
@@ -55,10 +55,10 @@ const char* const PROJ_LOG_FILENAME_FMT = "log_$pid_%Y%m%d.log";
 
 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 "
                                  "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_timer_idle,
@@ -69,6 +69,8 @@ static void SavePerfLog()
                                      App::Instance()->GetPerf().read_count,
                                      App::Instance()->GetPerf().max_login_time,
                                      App::Instance()->GetPerf().max_join_time,
+                                     GCListener::Instance()->GetSocketCount(),
+                                     LongSessionMgr::Instance()->GetLongSessionCount()
                                   });
     if (App::Instance()->HasFlag(2)) {
         a8::XPrintf("mainloop_time:%d netmsg_time:%d send_node_num:%d sent_bytes_num:%d\n",
diff --git a/server/wsproxy/longsessionmgr.cc b/server/wsproxy/longsessionmgr.cc
index 3915a67..405c2a5 100644
--- a/server/wsproxy/longsessionmgr.cc
+++ b/server/wsproxy/longsessionmgr.cc
@@ -126,3 +126,8 @@ void LongSessionMgr::DelSession(int socket_handle)
     }
     socket_handle_hash_.erase(socket_handle);
 }
+
+int LongSessionMgr::GetLongSessionCount()
+{
+    return socket_handle_hash_.size();
+}
diff --git a/server/wsproxy/longsessionmgr.h b/server/wsproxy/longsessionmgr.h
index 0be1d50..4595195 100644
--- a/server/wsproxy/longsessionmgr.h
+++ b/server/wsproxy/longsessionmgr.h
@@ -31,6 +31,7 @@ class LongSessionMgr : public a8::Singleton<LongSessionMgr>
     std::shared_ptr<LongSession> GetSession(int socket_handle);
     std::shared_ptr<a8::UdpListener> GetUdpListener() { return udp_listener_; }
     void DelSession(int socket_handle);
+    int GetLongSessionCount();
 
 private:
     std::shared_ptr<a8::UdpListener> udp_listener_;