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-17 02:57:52 +00:00
parent f0e3d861fb
commit 47c546ece5
1 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
server/wsproxy/GCListener.cc
View File

@ -158,18 +158,7 @@ static void GSUdpListeneron_error(a8::UdpListener*, int errorid)
static void GSUdpListeneron_recv_packet(a8::UdpListener*, a8::UdpPacket* pkt) static void GSUdpListeneron_recv_packet(a8::UdpListener*, a8::UdpPacket* pkt)
{ {
std::shared_ptr<KcpSession> session; App::Instance()->AddUdpMsg(pkt);
GCListener::Instance()->kcp_session_mutex_->lock();
auto itr = GCListener::Instance()->kcp_session_addr_hash_.find(pkt->GetRemoteKey());
if (itr == GCListener::Instance()->kcp_session_addr_hash_.end()) {
session = std::make_shared<KcpSession>();
GCListener::Instance()->kcp_session_addr_hash_[pkt->GetRemoteKey()] = session;
session->Init(pkt);
} else {
session = itr->second;
}
GCListener::Instance()->kcp_session_mutex_->unlock();
session->OnRecvPacket(pkt);
} }
void GCListener::Init() void GCListener::Init()