From 557fef47917c8508e0943f5a47756bb96afc85dd Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwe@kingsome.cn>
Date: Thu, 18 Jun 2020 11:17:07 +0800
Subject: [PATCH] 1

---
 server/imserver/MSConn.cc    | 10 ++++++++++
 server/imserver/MSConn.h     |  3 +++
 server/imserver/MSConnMgr.cc | 16 ++++++++++++++++
 server/imserver/MSConnMgr.h  |  3 +++
 server/imserver/app.cc       | 10 ++++++++++
 5 files changed, 42 insertions(+)

diff --git a/server/imserver/MSConn.cc b/server/imserver/MSConn.cc
index 4234d79..09070c9 100644
--- a/server/imserver/MSConn.cc
+++ b/server/imserver/MSConn.cc
@@ -200,3 +200,13 @@ void MSConn::ReportServerInfo()
         SendMsg(msg);
     }
 }
+
+void MSConn::OnConnectSync()
+{
+
+}
+
+void MSConn::OnDisconnectSync()
+{
+
+}
diff --git a/server/imserver/MSConn.h b/server/imserver/MSConn.h
index 6164676..c975cd6 100644
--- a/server/imserver/MSConn.h
+++ b/server/imserver/MSConn.h
@@ -35,6 +35,9 @@ class MSConn
         #endif
     }
 
+    void OnConnectSync();
+    void OnDisconnectSync();
+
  private:
     void on_error(a8::AsyncTcpClient* sender, int errorId);
     void on_connect(a8::AsyncTcpClient* sender);
diff --git a/server/imserver/MSConnMgr.cc b/server/imserver/MSConnMgr.cc
index 8211305..473a292 100644
--- a/server/imserver/MSConnMgr.cc
+++ b/server/imserver/MSConnMgr.cc
@@ -44,3 +44,19 @@ void MSConnMgr::TraverseMSConn(std::function<bool (MSConn*)> func)
         }
     }
 }
+
+void MSConnMgr::__IM_MSConnConnect(a8::XParams& param)
+{
+    MSConn* conn = GetConnById(param.sender);
+    if (conn) {
+        conn->OnConnectSync();
+    }
+}
+
+void MSConnMgr::__IM_MSConnDisconnect(a8::XParams& param)
+{
+    MSConn* conn = GetConnById(param.sender);
+    if (conn) {
+        conn->OnDisconnectSync();
+    }
+}
diff --git a/server/imserver/MSConnMgr.h b/server/imserver/MSConnMgr.h
index 8f7b9d4..ed1183a 100644
--- a/server/imserver/MSConnMgr.h
+++ b/server/imserver/MSConnMgr.h
@@ -25,6 +25,9 @@ class MSConnMgr : public a8::Singleton<MSConnMgr>
     }
     void TraverseMSConn(std::function<bool (MSConn*)> func);
 
+    void __IM_MSConnConnect(a8::XParams& param);
+    void __IM_MSConnDisconnect(a8::XParams& param);
+
 private:
     MSConn* GetConnById(int instance_id);
 
diff --git a/server/imserver/app.cc b/server/imserver/app.cc
index 837098e..2be5398 100644
--- a/server/imserver/app.cc
+++ b/server/imserver/app.cc
@@ -471,6 +471,16 @@ void App::ProcessIMMsg()
                 PlayerMgr::Instance()->OnWSProxyDisconnect(pdelnode->params);
             }
             break;
+        case IM_MSConnConnect:
+            {
+                MSConnMgr::Instance()->__IM_MSConnConnect(pdelnode->params);
+            }
+            break;
+        case IM_MSConnDisconnect:
+            {
+                MSConnMgr::Instance()->__IM_MSConnDisconnect(pdelnode->params);
+            }
+            break;
             #if 0
         case IM_TargetConnConnect:
             {