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-24 09:47:53 +00:00
parent 09aad454d6
commit 2a4941c0b1
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/wsproxy/downstreammgr.cc
View File

@ -77,9 +77,9 @@ std::weak_ptr<DownStream> DownStreamMgr::GetDownStream(int sockhandle)
return itr != socket_hash_.end() ? itr->second : nullptr; return itr != socket_hash_.end() ? itr->second : nullptr;
} }
void DownStreamMgr::BindUpStream(int socket_handle, int conn_instance_id) void DownStreamMgr::BindUpStream(int socket_handle, int instance_id)
{ {
std::weak_ptr<UpStream> up_wp = UpStreamMgr::Instance()->GetUpStreamById(conn_instance_id); std::weak_ptr<UpStream> up_wp = UpStreamMgr::Instance()->GetUpStreamById(instance_id);
if (!up_wp.expired()) { if (!up_wp.expired()) {
auto down_wp = GetDownStream(socket_handle); auto down_wp = GetDownStream(socket_handle);
if (auto down = down_wp.lock(); !down_wp.expired()) { if (auto down = down_wp.lock(); !down_wp.expired()) {

2
server/wsproxy/downstreammgr.h
View File

@ -18,7 +18,7 @@ class DownStreamMgr : public a8::Singleton<DownStreamMgr>
void OnUpStreamDisconnect(int instance_id); void OnUpStreamDisconnect(int instance_id);
void OnUpStreamConnect(int instance_id); void OnUpStreamConnect(int instance_id);
std::weak_ptr<DownStream> GetDownStream(int sockhande); std::weak_ptr<DownStream> GetDownStream(int sockhande);
void BindUpStream(int socket_handle, int conn_instance_id); void BindUpStream(int socket_handle, int instance_id);
void AddPendingAccount(const std::string& account_id, int socket_handle, long long req_tick); void AddPendingAccount(const std::string& account_id, int socket_handle, long long req_tick);
private: private: