TakeV/dxx-rebirth
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Factor out net_udp_listen read loop

Browse source
This commit is contained in:
Kp 2016-04-23 17:59:47 +00:00
parent 271146e84f
commit 11cf93a299
1 changed files with 17 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
similar/main/net_udp.cpp
View file

@ -4645,40 +4645,25 @@ void net_udp_flush()
net_udp_flush(UDP_Socket[1]); net_udp_flush(UDP_Socket[1]);
} }
static void net_udp_listen(RAIIsocket &sock)
{
if (!sock)
return;
struct _sockaddr sender_addr;
std::array<uint8_t, UPID_MAX_SIZE> packet;
for (;;)
{
const int size = udp_receive_packet(sock, packet.data(), packet.size(), &sender_addr);
if (!(size > 0))
break;
net_udp_process_packet(packet.data(), sender_addr, size);
}
}
void net_udp_listen() void net_udp_listen()
{ {
int size; range_for (auto &s, UDP_Socket)
ubyte packet[UPID_MAX_SIZE]; net_udp_listen(s);
struct _sockaddr sender_addr;
if (UDP_Socket[0])
{
size = udp_receive_packet(UDP_Socket[0], packet, UPID_MAX_SIZE, &sender_addr );
while ( size > 0 ) {
net_udp_process_packet( packet, sender_addr, size );
size = udp_receive_packet(UDP_Socket[0], packet, UPID_MAX_SIZE, &sender_addr );
}
}
if (UDP_Socket[1])
{
size = udp_receive_packet(UDP_Socket[1], packet, UPID_MAX_SIZE, &sender_addr );
while ( size > 0 ) {
net_udp_process_packet( packet, sender_addr, size );
size = udp_receive_packet(UDP_Socket[1], packet, UPID_MAX_SIZE, &sender_addr );
}
}
#ifdef USE_TRACKER
if (UDP_Socket[2])
{
size = udp_receive_packet(UDP_Socket[2], packet, UPID_MAX_SIZE, &sender_addr );
while ( size > 0 ) {
net_udp_process_packet( packet, sender_addr, size );
size = udp_receive_packet(UDP_Socket[2], packet, UPID_MAX_SIZE, &sender_addr );
}
}
#endif
} }
void net_udp_send_data(const ubyte * ptr, int len, int priority ) void net_udp_send_data(const ubyte * ptr, int len, int priority )