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 03:21:47 +00:00
parent 8e0bdaca4f
commit 27b2cac699
3 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/wsproxy/GCListener.cc
View File

@ -228,3 +228,8 @@ long long GCListener::GetSentBytesNum()
{ {
return tcp_listener_->sent_bytes_num; return tcp_listener_->sent_bytes_num;
} }
void GCListener::ProcUdpPacket(a8::UdpPacket* pkt)
{
}

3
server/wsproxy/GCListener.h
View File

@ -5,6 +5,7 @@ namespace a8
{ {
class TcpListener; class TcpListener;
class UdpListener; class UdpListener;
struct UdpPacket;
} }
class KcpSession; class KcpSession;
@ -36,6 +37,8 @@ class GCListener : public a8::Singleton<GCListener>
long long GetSendNodeNum(); long long GetSendNodeNum();
long long GetSentBytesNum(); long long GetSentBytesNum();
void ProcUdpPacket(a8::UdpPacket* pkt);
private: private:
a8::TcpListener *tcp_listener_ = nullptr; a8::TcpListener *tcp_listener_ = nullptr;

1
server/wsproxy/app.cc
View File

@ -574,6 +574,7 @@ void App::DispatchUdpMsg()
while (udp_work_node_) { while (udp_work_node_) {
UdpMsgNode *pdelnode = udp_work_node_; UdpMsgNode *pdelnode = udp_work_node_;
GCListener::Instance()->ProcUdpPacket(pdelnode->pkt);
udp_work_node_ = pdelnode->next; udp_work_node_ = pdelnode->next;
udp_working_msgnode_size_--; udp_working_msgnode_size_--;
if (a8::XGetTickCount() - starttick > 200) { if (a8::XGetTickCount() - starttick > 200) {