diff --git a/server/wsproxy/app.cc b/server/wsproxy/app.cc index 85e7b86..dd6a0d1 100644 --- a/server/wsproxy/app.cc +++ b/server/wsproxy/app.cc @@ -262,6 +262,9 @@ void App::ProcessTargetServerMsg(f8::MsgHdr* hdr) if (hdr->msgid == ss::_SS_CMLogin || hdr->msgid == ss::_SS_CMReconnect) { DownStreamMgr::Instance()->BindUpStream(hdr->socket_handle, hdr->ip_saddr); GCListener::Instance()->MarkClient(hdr->socket_handle, true); + } + if (hdr->msgid == ss::_SS_HttpTunnelResponse) { + } auto down_wp = DownStreamMgr::Instance()->GetDownStream(hdr->socket_handle); if (!down_wp.expired()) { diff --git a/server/wsproxy/mastermgr.cc b/server/wsproxy/mastermgr.cc index d9b7a2b..4988576 100644 --- a/server/wsproxy/mastermgr.cc +++ b/server/wsproxy/mastermgr.cc @@ -309,7 +309,6 @@ void MasterMgr::AddHttpTunnelRequest(int socket_handle, std::shared_ptrRemoveHttpTunnelRequest(req->socket_handle); - } else if (ALLOC_TARGET_SERVER_SUCCESS_TIMER_EVENT == event) { } } );