diff --git a/server/wsproxy/upstream.cc b/server/wsproxy/upstream.cc index aee615d..efae6a5 100644 --- a/server/wsproxy/upstream.cc +++ b/server/wsproxy/upstream.cc @@ -6,6 +6,7 @@ #include #include +#include #include "ss_proto.pb.h" #include "ss_msgid.pb.h" @@ -165,12 +166,16 @@ void UpStream::on_connect(a8::TcpClient* sender) sender->remote_address, sender->remote_port }); - #if 0 - App::Instance()->AddIMMsg(IM_UpStreamConnect, - a8::XParams() - .SetSender(instance_id) - ); - #endif + f8::MsgQueue::Instance()->PostMsg + ( + IM_UpStreamConnect, + a8::Args + ( + { + instance_id + } + ) + ); } void UpStream::on_disconnect(a8::TcpClient* sender) @@ -183,12 +188,16 @@ void UpStream::on_disconnect(a8::TcpClient* sender) sender->remote_address, sender->remote_port }); - #if 0 - App::Instance()->AddIMMsg(IM_UpStreamDisconnect, - a8::XParams() - .SetSender(instance_id) - ); - #endif + f8::MsgQueue::Instance()->PostMsg + ( + IM_UpStreamDisconnect, + a8::Args + ( + { + instance_id + } + ) + ); } void UpStream::on_socketread(a8::TcpClient* sender, char* buf, unsigned int len)