Function do_main

redis-server/src/main.rs:269–315

()

}

async fn do_main() {
    debug!("Starting");
    let Config {
        cache_size,
        cache_path,
        bind_addr,
        durable_fs,
    } = Config::from_args();

    let addr = match net::SocketAddr::from_str(&bind_addr) {
        Ok(a) => a,
        Err(e) => {
            error!(
                "Could not parse redis server address {} -> {:?}",
                bind_addr, e
            );
            return;
        }
    };

    let (shutdown_tx, shutdown_rx) = oneshot::channel();

    let mut handle = tokio::spawn(async move {
        run_server(cache_size, cache_path, durable_fs, addr, shutdown_rx).await;
    });

    tokio::select! {
        Some(()) = async move {
            let sigterm = tokio::signal::unix::SignalKind::terminate();
            tokio::signal::unix::signal(sigterm).unwrap().recv().await
        } => {}
        Ok(()) = tokio::signal::ctrl_c() => {
        }
        _ = &mut handle => {
            warn!("Server has unexpectedly stopped!");
            return;
        }
    }

    info!("Starting shutdown process ...");
    shutdown_tx
        .send(())
        .expect("Could not send shutdown signal!");
    // Ignore if there is an error from the handler on return.
    let _ = handle.await;
    info!("Server has stopped!");
}

#[tokio::main]
async fn main() {