16 |
19 |
17 mod utils; |
20 mod utils; |
18 mod server; |
21 mod server; |
19 mod protocol; |
22 mod protocol; |
20 |
23 |
|
24 use server::network::NetworkLayer; |
|
25 |
21 fn main() { |
26 fn main() { |
22 env_logger::init().unwrap(); |
27 env_logger::init().unwrap(); |
23 |
28 |
24 info!("Hedgewars game server, protocol {}", utils::PROTOCOL_VERSION); |
29 info!("Hedgewars game server, protocol {}", utils::PROTOCOL_VERSION); |
25 |
30 |
26 let address = "0.0.0.0:46631".parse().unwrap(); |
31 let address = "0.0.0.0:46631".parse().unwrap(); |
27 let listener = TcpListener::bind(&address).unwrap(); |
32 let listener = TcpListener::bind(&address).unwrap(); |
28 let mut server = server::server::HWServer::new(listener, 1024, 512); |
|
29 |
33 |
30 let poll = Poll::new().unwrap(); |
34 let poll = Poll::new().unwrap(); |
31 server.register(&poll).unwrap(); |
35 let mut hw_network = NetworkLayer::new(listener, 1024, 512); |
|
36 hw_network.register_server(&poll).unwrap(); |
32 |
37 |
33 let mut events = Events::with_capacity(1024); |
38 let mut events = Events::with_capacity(1024); |
34 |
39 |
35 loop { |
40 loop { |
36 poll.poll(&mut events, None).unwrap(); |
41 poll.poll(&mut events, None).unwrap(); |
37 |
42 |
38 for event in events.iter() { |
43 for event in events.iter() { |
39 if event.readiness() & Ready::readable() == Ready::readable() { |
44 if event.readiness() & Ready::readable() == Ready::readable() { |
40 match event.token() { |
45 match event.token() { |
41 utils::SERVER => server.accept(&poll).unwrap(), |
46 utils::SERVER => hw_network.accept_client(&poll).unwrap(), |
42 Token(tok) => server.client_readable(&poll, tok).unwrap(), |
47 Token(tok) => hw_network.client_readable(&poll, tok).unwrap(), |
43 } |
48 } |
44 } |
49 } |
45 if event.readiness() & Ready::writable() == Ready::writable() { |
50 if event.readiness() & Ready::writable() == Ready::writable() { |
46 match event.token() { |
51 match event.token() { |
47 utils::SERVER => unreachable!(), |
52 utils::SERVER => unreachable!(), |
48 Token(tok) => server.client_writable(&poll, tok).unwrap(), |
53 Token(tok) => hw_network.client_writable(&poll, tok).unwrap(), |
49 } |
54 } |
50 } |
55 } |
51 // if event.kind().is_hup() || event.kind().is_error() { |
56 // if event.kind().is_hup() || event.kind().is_error() { |
52 // match event.token() { |
57 // match event.token() { |
53 // utils::SERVER => unreachable!(), |
58 // utils::SERVER => unreachable!(), |