diff --git a/server/wsproxy/app.cc b/server/wsproxy/app.cc index 7d5f93b..a88b4e8 100644 --- a/server/wsproxy/app.cc +++ b/server/wsproxy/app.cc @@ -11,6 +11,7 @@ #include #include +#include #include "app.h" #include "GCListener.h" @@ -103,6 +104,7 @@ bool App::Init(int argc, char* argv[]) srand(time(nullptr)); InitLog(); + f8::MsgQueue::Instance()->Init(); HandlerMgr::Instance()->Init(); f8::Timer::Instance()->Init(); JsonDataMgr::Instance()->Init(); @@ -163,6 +165,7 @@ void App::UnInit() DownStreamMgr::Instance()->UnInit(); JsonDataMgr::Instance()->UnInit(); f8::Timer::Instance()->UnInit(); + f8::MsgQueue::Instance()->UnInit(); HandlerMgr::Instance()->UnInit(); UnInitLog(); @@ -229,6 +232,7 @@ void App::AddSocketMsg(SocketFrom_e sockfrom, void App::QuickExecute() { + f8::MsgQueue::Instance()->Update(); DispatchMsg(); f8::Timer::Instance()->Update(); }