(
&mut self,
max_per_socket: usize,
max_bytes: usize,
events: &mut Vec<NetworkEvent>,
)
| 379 | err, |
| 380 | )); |
| 381 | break; |
| 382 | } |
| 383 | } |
| 384 | } |
| 385 | } |
| 386 | } |
| 387 | |
| 388 | fn poll_udp_packets( |
| 389 | &mut self, |
| 390 | max_per_socket: usize, |
| 391 | max_bytes: usize, |
| 392 | events: &mut Vec<NetworkEvent>, |
| 393 | ) { |
| 394 | for i in 0..self.udp_endpoints.len() { |
| 395 | let Some(endpoint) = self.udp_endpoints[i].as_ref() else { |
| 396 | continue; |
| 397 | }; |
| 398 | let id = UdpEndpointId(i as u32); |
| 399 | for _ in 0..max_per_socket { |
| 400 | match endpoint.poll_event(max_bytes) { |
| 401 | Ok(Some(event)) => events.push(NetworkEvent { |
| 402 | source: NetSource::UdpEndpoint(id), |
| 403 | event, |
| 404 | }), |
| 405 | Ok(None) => break, |
| 406 | Err(err) => { |
| 407 | events.push(net_error_event(NetSource::UdpEndpoint(id), "udp_recv", err)); |
| 408 | break; |
| 409 | } |
no test coverage detected