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:
azw 2023-04-13 23:08:47 +00:00
parent 7adbdd97bc
commit a3a0ad5979
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/wsproxy/mastermgr.cc
View File

@ -25,6 +25,8 @@ public:
f8::MsgHdr* hdr_copy = nullptr; f8::MsgHdr* hdr_copy = nullptr;
f8::TimerWp timer_wp; f8::TimerWp timer_wp;
long long req_tick = 0; long long req_tick = 0;
UpStream* conn = nullptr;
}; };
void MasterMgr::Init() void MasterMgr::Init()
@ -61,16 +63,19 @@ void MasterMgr::_SS_MS_ResponseTargetServer(f8::MsgHdr& hdr, const ss::SS_MS_Res
msg.port() msg.port()
); );
if (conn) { if (conn) {
RemoveRequest(req->socket_handle);
conn->ForwardClientMsgEx(req->hdr_copy); conn->ForwardClientMsgEx(req->hdr_copy);
req->conn = conn;
req->hdr_copy = nullptr;
RemoveRequest(req->socket_handle);
return; return;
} else { } else {
abort(); abort();
} }
} } else {
RemoveRequest(req->socket_handle); RemoveRequest(req->socket_handle);
} }
} }
}
std::shared_ptr<Master> MasterMgr::GetConnById(int instance_id) std::shared_ptr<Master> MasterMgr::GetConnById(int instance_id)
{ {