diff --git a/a8/udplistener.cc b/a8/udplistener.cc index 5e8df4a..7d5252a 100644 --- a/a8/udplistener.cc +++ b/a8/udplistener.cc @@ -106,8 +106,10 @@ namespace a8 0, (struct sockaddr*)&destAddr, (socklen_t*)&addrLen); - if(ret > 0){ + if(ret > 0) { + #if 0 master->OnSocketRead(recv_buf, ret); + #endif } } } @@ -126,10 +128,6 @@ namespace a8 impl_ = nullptr; } - void UdpListener::OnSocketRead(char*, unsigned int) - { - } - void UdpListener::Open() { if (!IsActive()) { @@ -149,4 +147,14 @@ namespace a8 return impl_->IsActive(); } + void UdpListener::SendUdpPacket(UdpPacket* pkt) + { + + } + + void UdpListener::OnRecvUdpPacket(UdpPacket* pkt) + { + + } + } diff --git a/a8/udplistener.h b/a8/udplistener.h index 509d25e..5f3ec28 100644 --- a/a8/udplistener.h +++ b/a8/udplistener.h @@ -2,6 +2,12 @@ namespace a8 { + struct UdpPacket + { + char* buf = nullptr; + int buf_len = 0; + sockaddr_in remote_addr; + }; struct UdpListenerImpl; class UdpListener @@ -15,10 +21,11 @@ namespace a8 UdpListener(); ~UdpListener(); - virtual void OnSocketRead(char*, unsigned int); void Open(); void Close(); bool IsActive(); + virtual void SendUdpPacket(UdpPacket* pkt); + virtual void OnRecvUdpPacket(UdpPacket* pkt); private: a8::UdpListenerImpl* impl_ = nullptr;