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 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 } void TraverseMSConn(std::function 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: {