Function main

server/src/main.rs:221–593

()

}

fn main() {
    env_logger::init();

    let config = Configuration::from_args(std::env::args());
    let timely_config: timely::Configuration = config.clone().into();
    let server_config: server::Configuration = config.clone().into();

    timely::execute(timely_config, move |worker| {
        // Initialize server state (no networking).
        let mut server = Server::<T, Token>::new_at(server_config.clone(), worker.timer());

        if server_config.enable_logging {
            #[cfg(feature = "real-time")]
            server.enable_logging(worker).unwrap();
        }

        // The server might specify a sequence of requests for
        // setting-up built-in arrangements. We serialize those here
        // and pre-load the sequencer with them, such that they will
        // flow through the regular request handling.
        let builtins = Server::<T, Token>::builtins();
        let preload_command = Command {
            owner: worker.index(),
            client: SYSTEM.0,
            requests: builtins,
        };

        // Setup serializing command stream between all workers.
        let mut sequencer: Sequencer<Command> =
            Sequencer::preloaded(worker, Instant::now(), VecDeque::from(vec![preload_command]));

        // Kickoff ticking, if configured. We only want to issue ticks
        // from a single worker, to avoid redundant ticking.
        if worker.index() == 0 && server_config.tick.is_some() {
            sequencer.push(Command {
                owner: 0,
                client: SYSTEM.0,
                requests: vec![Request::Tick],
            });
        }

        // Set up I/O event loop.
        let mut io = {
            use std::net::{IpAddr, Ipv4Addr, SocketAddr};

            // let addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), config.port);
            let addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::new(0,0,0,0)), config.port);

            IO::new(addr)
        };

        info!(
            "[W{}] running with config {:?}, {} peers",
            worker.index(),
            config,
            worker.peers(),
        );