#![allow(unused_imports)]
#![deny(bare_trait_objects)]
use log::*;
use mio::net::*;
use mio::*;
mod protocol;
mod server;
mod utils;
use crate::server::network::NetworkLayer;
use std::time::Duration;
fn main() {
env_logger::init();
info!("Hedgewars game server, protocol {}", utils::SERVER_VERSION);
let address = "0.0.0.0:46631".parse().unwrap();
let listener = TcpListener::bind(&address).unwrap();
let poll = Poll::new().unwrap();
let mut hw_network = NetworkLayer::new(listener, 1024, 512);
hw_network.register_server(&poll).unwrap();
let mut events = Events::with_capacity(1024);
loop {
let timeout = if hw_network.has_pending_operations() {
Some(Duration::from_millis(1))
} else {
None
};
poll.poll(&mut events, timeout).unwrap();
for event in events.iter() {
if event.readiness() & Ready::readable() == Ready::readable() {
match event.token() {
utils::SERVER_TOKEN => hw_network.accept_client(&poll).unwrap(),
#[cfg(feature = "official-server")]
utils::IO_TOKEN => hw_network.handle_io_result(),
Token(tok) => hw_network.client_readable(&poll, tok).unwrap(),
}
}
if event.readiness() & Ready::writable() == Ready::writable() {
match event.token() {
utils::SERVER_TOKEN => unreachable!(),
utils::IO_TOKEN => unreachable!(),
Token(tok) => hw_network.client_writable(&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(),
// }
// }
}
hw_network.on_idle(&poll).unwrap();
}
}