1
This commit is contained in:
parent
a35add02b6
commit
22cc01609a
@ -243,4 +243,12 @@ std::shared_ptr<KcpSession> GCListener::GetKcpSessionBySocketHandle(int socket_h
|
|||||||
void GCListener::ProcUdpPacket(a8::UdpPacket* pkt)
|
void GCListener::ProcUdpPacket(a8::UdpPacket* pkt)
|
||||||
{
|
{
|
||||||
long long key = pkt->GetRemoteKey();
|
long long key = pkt->GetRemoteKey();
|
||||||
|
auto session = GetKcpSessionByRemoteKey(key);
|
||||||
|
if (!session) {
|
||||||
|
++kcp_socket_handle_;
|
||||||
|
session = std::make_shared<KcpSession>();
|
||||||
|
session->Init(pkt);
|
||||||
|
kcp_session_addr_hash_[key] = session;
|
||||||
|
}
|
||||||
|
session->OnRecvPacket(pkt);
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user