38 poll.poll(&mut events, timeout).unwrap(); |
38 poll.poll(&mut events, timeout).unwrap(); |
39 |
39 |
40 for event in events.iter() { |
40 for event in events.iter() { |
41 if event.readiness() & Ready::readable() == Ready::readable() { |
41 if event.readiness() & Ready::readable() == Ready::readable() { |
42 match event.token() { |
42 match event.token() { |
43 utils::SERVER => hw_network.accept_client(&poll).unwrap(), |
43 utils::SERVER_TOKEN => hw_network.accept_client(&poll).unwrap(), |
|
44 #[cfg(feature = "official-server")] |
|
45 utils::IO_TOKEN => hw_network.handle_io_result(), |
44 Token(tok) => hw_network.client_readable(&poll, tok).unwrap(), |
46 Token(tok) => hw_network.client_readable(&poll, tok).unwrap(), |
45 } |
47 } |
46 } |
48 } |
47 if event.readiness() & Ready::writable() == Ready::writable() { |
49 if event.readiness() & Ready::writable() == Ready::writable() { |
48 match event.token() { |
50 match event.token() { |
49 utils::SERVER => unreachable!(), |
51 utils::SERVER_TOKEN => unreachable!(), |
|
52 utils::IO_TOKEN => unreachable!(), |
50 Token(tok) => hw_network.client_writable(&poll, tok).unwrap(), |
53 Token(tok) => hw_network.client_writable(&poll, tok).unwrap(), |
51 } |
54 } |
52 } |
55 } |
53 // if event.kind().is_hup() || event.kind().is_error() { |
56 // if event.kind().is_hup() || event.kind().is_error() { |
54 // match event.token() { |
57 // match event.token() { |