author | sheepluva |
Wed, 16 May 2018 18:09:13 +0200 | |
branch | ui-scaling |
changeset 13389 | 24b531dcebe7 |
parent 13119 | 1e39b8749072 |
child 13414 | 28b314ad566d |
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)] |
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
2 |
|
12125 | 3 |
extern crate rand; |
4 |
extern crate mio; |
|
12126 | 5 |
extern crate slab; |
12127 | 6 |
extern crate netbuf; |
12133 | 7 |
#[macro_use] |
8 |
extern crate nom; |
|
12137
193dfdcb0620
- Use logging facilities instead of plain println!
unc0rr
parents:
12133
diff
changeset
|
9 |
#[macro_use] |
193dfdcb0620
- Use logging facilities instead of plain println!
unc0rr
parents:
12133
diff
changeset
|
10 |
extern crate log; |
193dfdcb0620
- Use logging facilities instead of plain println!
unc0rr
parents:
12133
diff
changeset
|
11 |
extern crate env_logger; |
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
12 |
#[macro_use] extern crate proptest; |
12125 | 13 |
|
12126 | 14 |
//use std::io::*; |
12125 | 15 |
//use rand::Rng; |
16 |
//use std::cmp::Ordering; |
|
12853 | 17 |
use mio::net::*; |
12125 | 18 |
use mio::*; |
19 |
||
20 |
mod utils; |
|
12126 | 21 |
mod server; |
12129 | 22 |
mod protocol; |
12125 | 23 |
|
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
24 |
use server::network::NetworkLayer; |
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
25 |
|
12125 | 26 |
fn main() { |
12137
193dfdcb0620
- Use logging facilities instead of plain println!
unc0rr
parents:
12133
diff
changeset
|
27 |
env_logger::init().unwrap(); |
193dfdcb0620
- Use logging facilities instead of plain println!
unc0rr
parents:
12133
diff
changeset
|
28 |
|
193dfdcb0620
- Use logging facilities instead of plain println!
unc0rr
parents:
12133
diff
changeset
|
29 |
info!("Hedgewars game server, protocol {}", utils::PROTOCOL_VERSION); |
12125 | 30 |
|
31 |
let address = "0.0.0.0:46631".parse().unwrap(); |
|
12126 | 32 |
let listener = TcpListener::bind(&address).unwrap(); |
12125 | 33 |
|
34 |
let poll = Poll::new().unwrap(); |
|
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
35 |
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
|
36 |
hw_network.register_server(&poll).unwrap(); |
12125 | 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() { |
|
12853 | 44 |
if event.readiness() & Ready::readable() == Ready::readable() { |
12127 | 45 |
match event.token() { |
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
46 |
utils::SERVER => hw_network.accept_client(&poll).unwrap(), |
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
47 |
Token(tok) => hw_network.client_readable(&poll, tok).unwrap(), |
12127 | 48 |
} |
49 |
} |
|
12853 | 50 |
if event.readiness() & Ready::writable() == Ready::writable() { |
12127 | 51 |
match event.token() { |
52 |
utils::SERVER => unreachable!(), |
|
13119
1e39b8749072
separated the server logic from all the async io mess.
alfadur
parents:
12853
diff
changeset
|
53 |
Token(tok) => hw_network.client_writable(&poll, tok).unwrap(), |
12127 | 54 |
} |
12125 | 55 |
} |
12853 | 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 |
// } |
|
12125 | 62 |
} |
63 |
} |
|
64 |
} |