diff -r 6e8b807bda4b -r ba39a1d396c0 gameServer2/src/main.rs --- a/gameServer2/src/main.rs Sun Jun 10 18:56:51 2018 +0200 +++ b/gameServer2/src/main.rs Sun Jun 10 19:12:26 2018 +0200 @@ -1,3 +1,5 @@ +#![allow(unused_imports)] + extern crate rand; extern crate mio; extern crate slab; @@ -7,17 +9,20 @@ #[macro_use] extern crate log; extern crate env_logger; +#[macro_use] extern crate proptest; //use std::io::*; //use rand::Rng; //use std::cmp::Ordering; -use mio::tcp::*; +use mio::net::*; use mio::*; mod utils; mod server; mod protocol; +use server::network::NetworkLayer; + fn main() { env_logger::init().unwrap(); @@ -25,10 +30,10 @@ let address = "0.0.0.0:46631".parse().unwrap(); let listener = TcpListener::bind(&address).unwrap(); - let mut server = server::server::HWServer::new(listener, 1024, 512); let poll = Poll::new().unwrap(); - server.register(&poll).unwrap(); + let mut hw_network = NetworkLayer::new(listener, 1024, 512); + hw_network.register_server(&poll).unwrap(); let mut events = Events::with_capacity(1024); @@ -36,24 +41,24 @@ poll.poll(&mut events, None).unwrap(); for event in events.iter() { - if event.kind().is_readable() { + if event.readiness() & Ready::readable() == Ready::readable() { match event.token() { - utils::SERVER => server.accept(&poll).unwrap(), - tok => server.client_readable(&poll, tok).unwrap(), + utils::SERVER => hw_network.accept_client(&poll).unwrap(), + Token(tok) => hw_network.client_readable(&poll, tok).unwrap(), } } - if event.kind().is_writable() { + if event.readiness() & Ready::writable() == Ready::writable() { match event.token() { utils::SERVER => unreachable!(), - tok => server.client_writable(&poll, tok).unwrap(), + Token(tok) => hw_network.client_writable(&poll, tok).unwrap(), } } - if event.kind().is_hup() || event.kind().is_error() { - match event.token() { - utils::SERVER => unreachable!(), - tok => server.client_error(&poll, tok).unwrap(), - } - } +// if event.kind().is_hup() || event.kind().is_error() { +// match event.token() { +// utils::SERVER => unreachable!(), +// Token(tok) => server.client_error(&poll, tok).unwrap(), +// } +// } } } }