1 #![allow(unused_imports)] |
|
2 |
|
3 extern crate rand; |
|
4 extern crate mio; |
|
5 extern crate slab; |
|
6 extern crate netbuf; |
|
7 #[macro_use] |
|
8 extern crate nom; |
|
9 #[macro_use] |
|
10 extern crate log; |
|
11 extern crate env_logger; |
|
12 #[macro_use] extern crate proptest; |
|
13 |
|
14 //use std::io::*; |
|
15 //use rand::Rng; |
|
16 //use std::cmp::Ordering; |
|
17 use mio::net::*; |
|
18 use mio::*; |
|
19 |
|
20 mod utils; |
|
21 mod server; |
|
22 mod protocol; |
|
23 |
|
24 use server::network::NetworkLayer; |
|
25 |
|
26 fn main() { |
|
27 env_logger::init().unwrap(); |
|
28 |
|
29 info!("Hedgewars game server, protocol {}", utils::PROTOCOL_VERSION); |
|
30 |
|
31 let address = "0.0.0.0:46631".parse().unwrap(); |
|
32 let listener = TcpListener::bind(&address).unwrap(); |
|
33 |
|
34 let poll = Poll::new().unwrap(); |
|
35 let mut hw_network = NetworkLayer::new(listener, 1024, 512); |
|
36 hw_network.register_server(&poll).unwrap(); |
|
37 |
|
38 let mut events = Events::with_capacity(1024); |
|
39 |
|
40 loop { |
|
41 poll.poll(&mut events, None).unwrap(); |
|
42 |
|
43 for event in events.iter() { |
|
44 if event.readiness() & Ready::readable() == Ready::readable() { |
|
45 match event.token() { |
|
46 utils::SERVER => hw_network.accept_client(&poll).unwrap(), |
|
47 Token(tok) => hw_network.client_readable(&poll, tok).unwrap(), |
|
48 } |
|
49 } |
|
50 if event.readiness() & Ready::writable() == Ready::writable() { |
|
51 match event.token() { |
|
52 utils::SERVER => unreachable!(), |
|
53 Token(tok) => hw_network.client_writable(&poll, tok).unwrap(), |
|
54 } |
|
55 } |
|
56 // if event.kind().is_hup() || event.kind().is_error() { |
|
57 // match event.token() { |
|
58 // utils::SERVER => unreachable!(), |
|
59 // Token(tok) => server.client_error(&poll, tok).unwrap(), |
|
60 // } |
|
61 // } |
|
62 } |
|
63 } |
|
64 } |
|