(
&mut self,
max_per_socket: usize,
max_frame_bytes: usize,
)
| 267 | } |
| 268 | |
| 269 | pub fn poll_frame_events( |
| 270 | &mut self, |
| 271 | max_per_socket: usize, |
| 272 | max_frame_bytes: usize, |
| 273 | ) -> Vec<NetworkEvent> { |
| 274 | let mut events = Vec::new(); |
| 275 | self.poll_accepts(max_per_socket, &mut events); |
| 276 | self.poll_websocket_accepts(max_per_socket, &mut events); |
| 277 | self.poll_tcp_frames(max_per_socket, max_frame_bytes, &mut events); |
| 278 | self.poll_udp_packets(max_per_socket, max_frame_bytes, &mut events); |
| 279 | self.poll_websocket_messages(max_per_socket, max_frame_bytes, &mut events); |
| 280 | events |
| 281 | } |
| 282 | |
| 283 | fn poll_accepts(&mut self, max_per_socket: usize, events: &mut Vec<NetworkEvent>) { |
| 284 | for host_index in 0..self.tcp_hosts.len() { |
nothing calls this directly
no test coverage detected