server_common/a8
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-15 01:57:39 +00:00
parent 50341c6846
commit dd650c0bca
2 changed files with 21 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
a8/udplistener.cc
View File

@ -106,8 +106,10 @@ namespace a8
0, 0,
(struct sockaddr*)&destAddr, (struct sockaddr*)&destAddr,
(socklen_t*)&addrLen); (socklen_t*)&addrLen);
if(ret > 0){ if(ret > 0) {
#if 0
master->OnSocketRead(recv_buf, ret); master->OnSocketRead(recv_buf, ret);
#endif
} }
} }
} }
@ -126,10 +128,6 @@ namespace a8
impl_ = nullptr; impl_ = nullptr;
} }
void UdpListener::OnSocketRead(char*, unsigned int)
{
}
void UdpListener::Open() void UdpListener::Open()
{ {
if (!IsActive()) { if (!IsActive()) {
@ -149,4 +147,14 @@ namespace a8
return impl_->IsActive(); return impl_->IsActive();
} }
void UdpListener::SendUdpPacket(UdpPacket* pkt)
{
}
void UdpListener::OnRecvUdpPacket(UdpPacket* pkt)
{
}
} }

9
a8/udplistener.h
View File

@ -2,6 +2,12 @@
namespace a8 namespace a8
{ {
struct UdpPacket
{
char* buf = nullptr;
int buf_len = 0;
sockaddr_in remote_addr;
};
struct UdpListenerImpl; struct UdpListenerImpl;
class UdpListener class UdpListener
@ -15,10 +21,11 @@ namespace a8
UdpListener(); UdpListener();
~UdpListener(); ~UdpListener();
virtual void OnSocketRead(char*, unsigned int);
void Open(); void Open();
void Close(); void Close();
bool IsActive(); bool IsActive();
virtual void SendUdpPacket(UdpPacket* pkt);
virtual void OnRecvUdpPacket(UdpPacket* pkt);
private: private:
a8::UdpListenerImpl* impl_ = nullptr; a8::UdpListenerImpl* impl_ = nullptr;