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 2023-04-24 10:35:53 +08:00
parent b5c367d954
commit ff48ed0a67
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/wsproxy/app.cc
View File

@ -450,7 +450,10 @@ void App::ProcessTargetServerMsg(f8::MsgHdr& hdr)
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);
} }
GCListener::Instance()->ForwardUpStreamMsg(hdr); auto down = DownStreamMgr::Instance()->GetDownStream(hdr.socket_handle);
if (!down.expired()) {
down.lock()->ForwardUpStreamMsg(hdr);
}
} }
void App::InitLog() void App::InitLog()