server_common/wsproxy
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-03-24 15:07:58 +08:00
parent 8873d2efac
commit ec94b9525a
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/wsproxy/app.cc
View File

@ -262,6 +262,9 @@ void App::ProcessTargetServerMsg(f8::MsgHdr* hdr)
if (hdr->msgid == ss::_SS_CMLogin || hdr->msgid == ss::_SS_CMReconnect) { if (hdr->msgid == ss::_SS_CMLogin || hdr->msgid == ss::_SS_CMReconnect) {
DownStreamMgr::Instance()->BindUpStream(hdr->socket_handle, hdr->ip_saddr); DownStreamMgr::Instance()->BindUpStream(hdr->socket_handle, hdr->ip_saddr);
GCListener::Instance()->MarkClient(hdr->socket_handle, true); GCListener::Instance()->MarkClient(hdr->socket_handle, true);
}
if (hdr->msgid == ss::_SS_HttpTunnelResponse) {
} }
auto down_wp = DownStreamMgr::Instance()->GetDownStream(hdr->socket_handle); auto down_wp = DownStreamMgr::Instance()->GetDownStream(hdr->socket_handle);
if (!down_wp.expired()) { if (!down_wp.expired()) {

1
server/wsproxy/mastermgr.cc
View File

@ -309,7 +309,6 @@ void MasterMgr::AddHttpTunnelRequest(int socket_handle, std::shared_ptr<f8::Json
{ {
if (a8::TIMER_EXEC_EVENT == event) { if (a8::TIMER_EXEC_EVENT == event) {
MasterMgr::Instance()->RemoveHttpTunnelRequest(req->socket_handle); MasterMgr::Instance()->RemoveHttpTunnelRequest(req->socket_handle);
} else if (ALLOC_TARGET_SERVER_SUCCESS_TIMER_EVENT == event) {
} }
} }
); );