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:36:42 +08:00
parent ff48ed0a67
commit adeaac6e1d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/wsproxy/app.cc
View File

@ -450,9 +450,9 @@ void App::ProcessTargetServerMsg(f8::MsgHdr& hdr)
DownStreamMgr::Instance()->BindUpStream(hdr.socket_handle, hdr.ip_saddr);
GCListener::Instance()->MarkClient(hdr.socket_handle, true);
}
auto down = DownStreamMgr::Instance()->GetDownStream(hdr.socket_handle);
if (!down.expired()) {
down.lock()->ForwardUpStreamMsg(hdr);
auto down_wp = DownStreamMgr::Instance()->GetDownStream(hdr.socket_handle);
if (!down_wp.expired()) {
down_wp.lock()->ForwardUpStreamMsg(hdr);
}
}