diff --git a/server/wsproxy/app.cc b/server/wsproxy/app.cc index 8da030e..99f1593 100644 --- a/server/wsproxy/app.cc +++ b/server/wsproxy/app.cc @@ -450,7 +450,10 @@ void App::ProcessTargetServerMsg(f8::MsgHdr& hdr) DownStreamMgr::Instance()->BindUpStream(hdr.socket_handle, hdr.ip_saddr); GCListener::Instance()->MarkClient(hdr.socket_handle, true); } - GCListener::Instance()->ForwardUpStreamMsg(hdr); + auto down = DownStreamMgr::Instance()->GetDownStream(hdr.socket_handle); + if (!down.expired()) { + down.lock()->ForwardUpStreamMsg(hdr); + } } void App::InitLog()