1

server/imserver/MSConn.cc

@@ -200,3 +200,13 @@ void MSConn::ReportServerInfo()
         SendMsg(msg);
     }
 }
+
+void MSConn::OnConnectSync()
+{
+
+}
+
+void MSConn::OnDisconnectSync()
+{
+
+}

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);

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();
+    }
+}

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);
 

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:
             {