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 2023-04-23 16:55:36 +08:00
parent 7f42fbcd94
commit a26e6547cf
5 changed files with 5 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/wsproxy/kcpsession.cc
View File

@ -49,9 +49,8 @@ void KcpSession::UnInit()
} }
} }
void KcpSession::Update() void KcpSession::Update(long long tick)
{ {
long long tick = a8::XGetTickCount();
ikcp_update(kcp_, tick - init_tick_); ikcp_update(kcp_, tick - init_tick_);
UpdateInput(); UpdateInput();
} }

3
server/wsproxy/kcpsession.h
View File

@ -11,7 +11,8 @@ public:
void Init(a8::UdpListener* udp_listener, int socket_handle, a8::UdpPacket* pkt); void Init(a8::UdpListener* udp_listener, int socket_handle, a8::UdpPacket* pkt);
void UnInit(); void UnInit();
void Update(); void Update(long long tick);
void SendClientMsg(char* buf, int buf_len); void SendClientMsg(char* buf, int buf_len);
void OnRecvPacket(a8::UdpPacket* pkt); void OnRecvPacket(a8::UdpPacket* pkt);
const sockaddr_in& GetAddr() const { return remote_addr_; } const sockaddr_in& GetAddr() const { return remote_addr_; }

12
server/wsproxy/longsession.cc
View File

@ -15,15 +15,5 @@ void LongSession::UnInit()
void LongSession::Update(long long tick) void LongSession::Update(long long tick)
{ {
GetKcpSession()->Update(tick);
}
int LongSession::GetSocketHandle()
{
return kcp_session_->GetSocketHandle();
}
long long LongSession::GetSecretKey()
{
return kcp_session_->GetSecretKey();
} }

2
server/wsproxy/longsession.h
View File

@ -10,8 +10,6 @@ class LongSession
void UnInit(); void UnInit();
void Update(long long tick); void Update(long long tick);
int GetSocketHandle();
long long GetSecretKey();
std::shared_ptr<KcpSession> GetKcpSession() { return kcp_session_; } std::shared_ptr<KcpSession> GetKcpSession() { return kcp_session_; }
private: private:

2
server/wsproxy/longsessionmgr.cc
View File

@ -55,7 +55,7 @@ void LongSessionMgr::ProcUdpPacket(a8::UdpPacket* pkt)
int socket_handle = 0; int socket_handle = 0;
long long secret_key = 0; long long secret_key = 0;
auto session = GetSession(socket_handle); auto session = GetSession(socket_handle);
if (session && secret_key == session->GetSecretKey()) { if (session && secret_key == session->GetKcpSession()->GetSecretKey()) {
session->GetKcpSession()->OnRecvPacket(pkt); session->GetKcpSession()->OnRecvPacket(pkt);
} }
} }