author | alfadur |
Thu, 25 Oct 2018 04:55:27 +0300 | |
changeset 13960 | 0e2fd51c4a52 |
parent 13805 | 0463a4221327 |
permissions | -rw-r--r-- |
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
1 |
#![allow(unused_imports)] |
13421
d1368c776a4f
Enable all lints from the rust-2018-idioms suite.
marmistrz
parents:
13414
diff
changeset
|
2 |
#![deny(bare_trait_objects)] |
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
3 |
|
12126 | 4 |
//use std::io::*; |
12125 | 5 |
//use rand::Rng; |
6 |
//use std::cmp::Ordering; |
|
12853 | 7 |
use mio::net::*; |
12125 | 8 |
use mio::*; |
13805 | 9 |
use log::*; |
12125 | 10 |
|
11 |
mod utils; |
|
12126 | 12 |
mod server; |
12129 | 13 |
mod protocol; |
12125 | 14 |
|
13666 | 15 |
use crate::server::network::NetworkLayer; |
13414 | 16 |
use std::time::Duration; |
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
17 |
|
12125 | 18 |
fn main() { |
13797 | 19 |
env_logger::init(); |
12137
193dfdcb0620
- Use logging facilities instead of plain println!
unc0rr
parents:
12133
diff
changeset
|
20 |
|
193dfdcb0620
- Use logging facilities instead of plain println!
unc0rr
parents:
12133
diff
changeset
|
21 |
info!("Hedgewars game server, protocol {}", utils::PROTOCOL_VERSION); |
12125 | 22 |
|
23 |
let address = "0.0.0.0:46631".parse().unwrap(); |
|
12126 | 24 |
let listener = TcpListener::bind(&address).unwrap(); |
12125 | 25 |
|
26 |
let poll = Poll::new().unwrap(); |
|
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
27 |
let mut hw_network = NetworkLayer::new(listener, 1024, 512); |
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
28 |
hw_network.register_server(&poll).unwrap(); |
12125 | 29 |
|
30 |
let mut events = Events::with_capacity(1024); |
|
31 |
||
32 |
loop { |
|
13414 | 33 |
let timeout = if hw_network.has_pending_operations() { |
34 |
Some(Duration::from_millis(1)) |
|
35 |
} else { |
|
36 |
None |
|
37 |
}; |
|
38 |
poll.poll(&mut events, timeout).unwrap(); |
|
12125 | 39 |
|
40 |
for event in events.iter() { |
|
12853 | 41 |
if event.readiness() & Ready::readable() == Ready::readable() { |
12127 | 42 |
match event.token() { |
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
43 |
utils::SERVER => hw_network.accept_client(&poll).unwrap(), |
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
44 |
Token(tok) => hw_network.client_readable(&poll, tok).unwrap(), |
12127 | 45 |
} |
46 |
} |
|
12853 | 47 |
if event.readiness() & Ready::writable() == Ready::writable() { |
12127 | 48 |
match event.token() { |
49 |
utils::SERVER => unreachable!(), |
|
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
50 |
Token(tok) => hw_network.client_writable(&poll, tok).unwrap(), |
12127 | 51 |
} |
12125 | 52 |
} |
12853 | 53 |
// if event.kind().is_hup() || event.kind().is_error() { |
54 |
// match event.token() { |
|
55 |
// utils::SERVER => unreachable!(), |
|
56 |
// Token(tok) => server.client_error(&poll, tok).unwrap(), |
|
57 |
// } |
|
58 |
// } |
|
12125 | 59 |
} |
13414 | 60 |
hw_network.on_idle(&poll).unwrap(); |
12125 | 61 |
} |
62 |
} |