diff --git a/server/wsproxy/upstreammgr.cc b/server/wsproxy/upstreammgr.cc index a1634b1..fd492fa 100644 --- a/server/wsproxy/upstreammgr.cc +++ b/server/wsproxy/upstreammgr.cc @@ -4,6 +4,7 @@ #include "upstreammgr.h" #include "upstream.h" +#include "downstreammgr.h" void UpStreamMgr::Init() { @@ -23,6 +24,8 @@ void UpStreamMgr::Init() IM_UpStreamDisconnect, [this] (const a8::Args& args) { + int instance_id = args.Get(0); + DownStreamMgr::Instance()->OnUpStreamDisconnect(instance_id); }); }