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 19:25:36 +08:00
parent 0ede4b54fe
commit 0ad1989d8e
3 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/wsproxy/app.cc
View File

@ -264,7 +264,12 @@ void App::ProcessTargetServerMsg(f8::MsgHdr* hdr)
GCListener::Instance()->MarkClient(hdr->socket_handle, true); GCListener::Instance()->MarkClient(hdr->socket_handle, true);
} }
if (hdr->msgid == ss::_SS_HttpTunnelResponse) { if (hdr->msgid == ss::_SS_HttpTunnelResponse) {
ss::SS_HttpTunnelResponse msg;
bool ok = msg.ParseFromArray(hdr->buf + hdr->offset, hdr->buflen - hdr->offset);
if (ok) {
MasterMgr::Instance()->_SS_HttpTunnelResponse(hdr, msg);
}
return;
} }
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()) {

5
server/wsproxy/mastermgr.cc
View File

@ -135,6 +135,11 @@ void MasterMgr::_SS_MS_HttpTunnelResponse(f8::MsgHdr* hdr, const ss::SS_MS_HttpT
} }
} }
void MasterMgr::_SS_HttpTunnelResponse(f8::MsgHdr* hdr, const ss::SS_HttpTunnelResponse& msg)
{
}
std::shared_ptr<Master> MasterMgr::GetConnById(int instance_id) std::shared_ptr<Master> MasterMgr::GetConnById(int instance_id)
{ {
auto itr = mastersvr_hash_.find(instance_id); auto itr = mastersvr_hash_.find(instance_id);

2
server/wsproxy/mastermgr.h
View File

@ -9,6 +9,7 @@ namespace ss
{ {
class SS_MS_ResponseTargetServer; class SS_MS_ResponseTargetServer;
class SS_MS_HttpTunnelResponse; class SS_MS_HttpTunnelResponse;
class SS_HttpTunnelResponse;
} }
struct HttpTunnelRequest; struct HttpTunnelRequest;
@ -30,6 +31,7 @@ class MasterMgr : public a8::Singleton<MasterMgr>
void _SS_MS_ResponseTargetServer(f8::MsgHdr* hdr, const ss::SS_MS_ResponseTargetServer& msg); void _SS_MS_ResponseTargetServer(f8::MsgHdr* hdr, const ss::SS_MS_ResponseTargetServer& msg);
void _SS_MS_HttpTunnelResponse(f8::MsgHdr* hdr, const ss::SS_MS_HttpTunnelResponse& msg); void _SS_MS_HttpTunnelResponse(f8::MsgHdr* hdr, const ss::SS_MS_HttpTunnelResponse& msg);
void _SS_HttpTunnelResponse(f8::MsgHdr* hdr, const ss::SS_HttpTunnelResponse& msg);
void RequestTargetServer(f8::MsgHdr* hdr, void RequestTargetServer(f8::MsgHdr* hdr,
const std::string& team_id, const std::string& team_id,
const std::string& account_id, const std::string& account_id,