sheepy-clone: rust/hedgewars-server/src/main.rs@38e66519e585 (annotated)

14797 38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	1	#![feature(self_struct_ctor)]
13124 1e39b8749072 separated the server logic from all the async io mess. alfadur parents: 12858 diff changeset	2	#![allow(unused_imports)]
13426 d1368c776a4f Enable all lints from the rust-2018-idioms suite. marmistrz parents: 13419 diff changeset	3	#![deny(bare_trait_objects)]
13124 1e39b8749072 separated the server logic from all the async io mess. alfadur parents: 12858 diff changeset	4
14797 38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	5	extern crate getopts;
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	6	use getopts::Options;
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	7	use std::env;
14462 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	8	use log::*;
12858 a9d105dc5c95 Improve this code a bit more unc0rr parents: 12857 diff changeset	9	use mio::net::*;
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	10	use mio::*;
858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	11
14462 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	12	mod protocol;
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	13	mod server;
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	14	mod utils;
858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	15
13671 09f4a30e50cc Rust 2018 conversion alfadur parents: 13534 diff changeset	16	use crate::server::network::NetworkLayer;
13419 28b314ad566d handle edge polling properly alfadur parents: 13124 diff changeset	17	use std::time::Duration;
13124 1e39b8749072 separated the server logic from all the async io mess. alfadur parents: 12858 diff changeset	18
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	19	fn main() {
13802 c5edfcfac68b Bump dependencies alfadur parents: 13801 diff changeset	20	env_logger::init();
12142 193dfdcb0620 - Use logging facilities instead of plain println! unc0rr parents: 12138 diff changeset	21
14797 38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	22	let args: Vec<String> = env::args().collect();
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	23	let mut opts = Options::new();
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	24
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	25	opts.optopt("p", "port", "port - defaults to 46631", "PORT");
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	26	opts.optflag("h", "help", "help");
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	27	let matches = match opts.parse(&args[1..]) {
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	28	Ok(m) => { m }
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	29	Err(f) => { panic!(f.to_string()) }
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	30	};
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	31	if matches.opt_present("h") {
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	32	println!("-p/--port - defaults to 46631");
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	33	return;
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	34	}
14788 b3adc030104b implement server vars alfadur parents: 14784 diff changeset	35	info!("Hedgewars game server, protocol {}", utils::SERVER_VERSION);
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	36
14797 38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	37	let address;
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	38	if matches.opt_present("p") {
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	39	match matches.opt_str("p") {
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	40	Some(x) => address = format!("0.0.0.0:{}", x).parse().unwrap(),
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	41	None => address = "0.0.0.0:46631".parse().unwrap(),
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	42	}
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	43	}
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	44	else {
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	45	address = "0.0.0.0:46631".parse().unwrap();
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	46	}
38e66519e585 ugly hacked in argument for port to remove unc0rr's excuse nemo parents: 14788 diff changeset	47
12131 4348997e502b Refactor code to add more structure to it unc0rr parents: 12130 diff changeset	48	let listener = TcpListener::bind(&address).unwrap();
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	49
858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	50	let poll = Poll::new().unwrap();
13124 1e39b8749072 separated the server logic from all the async io mess. alfadur parents: 12858 diff changeset	51	let mut hw_network = NetworkLayer::new(listener, 1024, 512);
1e39b8749072 separated the server logic from all the async io mess. alfadur parents: 12858 diff changeset	52	hw_network.register_server(&poll).unwrap();
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	53
858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	54	let mut events = Events::with_capacity(1024);
858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	55
858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	56	loop {
13419 28b314ad566d handle edge polling properly alfadur parents: 13124 diff changeset	57	let timeout = if hw_network.has_pending_operations() {
28b314ad566d handle edge polling properly alfadur parents: 13124 diff changeset	58	Some(Duration::from_millis(1))
28b314ad566d handle edge polling properly alfadur parents: 13124 diff changeset	59	} else {
28b314ad566d handle edge polling properly alfadur parents: 13124 diff changeset	60	None
28b314ad566d handle edge polling properly alfadur parents: 13124 diff changeset	61	};
28b314ad566d handle edge polling properly alfadur parents: 13124 diff changeset	62	poll.poll(&mut events, timeout).unwrap();
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	63
858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	64	for event in events.iter() {
12858 a9d105dc5c95 Improve this code a bit more unc0rr parents: 12857 diff changeset	65	if event.readiness() & Ready::readable() == Ready::readable() {
12132 36ac9c075d0d - Use netbuf buffers for client connection stream unc0rr parents: 12131 diff changeset	66	match event.token() {
14784 f43ab2bd76ae add a thread for internal server IO and implement account checking with it alfadur parents: 14696 diff changeset	67	utils::SERVER_TOKEN => hw_network.accept_client(&poll).unwrap(),
f43ab2bd76ae add a thread for internal server IO and implement account checking with it alfadur parents: 14696 diff changeset	68	#[cfg(feature = "official-server")]
f43ab2bd76ae add a thread for internal server IO and implement account checking with it alfadur parents: 14696 diff changeset	69	utils::IO_TOKEN => hw_network.handle_io_result(),
13124 1e39b8749072 separated the server logic from all the async io mess. alfadur parents: 12858 diff changeset	70	Token(tok) => hw_network.client_readable(&poll, tok).unwrap(),
12132 36ac9c075d0d - Use netbuf buffers for client connection stream unc0rr parents: 12131 diff changeset	71	}
36ac9c075d0d - Use netbuf buffers for client connection stream unc0rr parents: 12131 diff changeset	72	}
12858 a9d105dc5c95 Improve this code a bit more unc0rr parents: 12857 diff changeset	73	if event.readiness() & Ready::writable() == Ready::writable() {
12132 36ac9c075d0d - Use netbuf buffers for client connection stream unc0rr parents: 12131 diff changeset	74	match event.token() {
14784 f43ab2bd76ae add a thread for internal server IO and implement account checking with it alfadur parents: 14696 diff changeset	75	utils::SERVER_TOKEN => unreachable!(),
f43ab2bd76ae add a thread for internal server IO and implement account checking with it alfadur parents: 14696 diff changeset	76	utils::IO_TOKEN => unreachable!(),
13124 1e39b8749072 separated the server logic from all the async io mess. alfadur parents: 12858 diff changeset	77	Token(tok) => hw_network.client_writable(&poll, tok).unwrap(),
12132 36ac9c075d0d - Use netbuf buffers for client connection stream unc0rr parents: 12131 diff changeset	78	}
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	79	}
14462 98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	80	// if event.kind().is_hup() \|\| event.kind().is_error() {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	81	// match event.token() {
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	82	// utils::SERVER => unreachable!(),
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	83	// Token(tok) => server.client_error(&poll, tok).unwrap(),
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	84	// }
98ef2913ec73 Apply rustfmt to all files unc0rr parents: 14420 diff changeset	85	// }
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	86	}
13419 28b314ad566d handle edge polling properly alfadur parents: 13124 diff changeset	87	hw_network.on_idle(&poll).unwrap();
12130 858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	88	}
858bf4d04c54 Start server implementation in rust unc0rr parents: diff changeset	89	}

author	nemo
	Fri, 12 Apr 2019 11:41:35 -0400
changeset 14797	38e66519e585
parent 14788	b3adc030104b
child 14798	9de13d9a6312
permissions	-rw-r--r--