tyler/proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

src/bin/proxmox-backup-api.rs: switch to async

Browse Source 
Signed-off-by: Wolfgang Bumiller <w.bumiller@proxmox.com>
This commit is contained in:
Wolfgang Bumiller 2019-08-28 16:11:01 +02:00
parent e235c8f719
commit e76ac3a499
1 changed files with 28 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
src/bin/proxmox-backup-api.rs
View File

@ -1,3 +1,9 @@
use failure::*;
use futures::*;
use lazy_static::lazy_static;
use proxmox::tools::try_block;
//use proxmox_backup::tools; //use proxmox_backup::tools;
use proxmox_backup::api_schema::router::*; use proxmox_backup::api_schema::router::*;
use proxmox_backup::api_schema::config::*; use proxmox_backup::api_schema::config::*;
@ -7,24 +13,15 @@ use proxmox_backup::tools::daemon;
use proxmox_backup::auth_helpers::*; use proxmox_backup::auth_helpers::*;
use proxmox_backup::config; use proxmox_backup::config;
use failure::*; #[tokio::main]
use lazy_static::lazy_static; async fn main() {
use proxmox::tools::try_block; if let Err(err) = run().await {
use futures::*;
use futures::future::Future;
use hyper;
fn main() {
if let Err(err) = run() {
eprintln!("Error: {}", err); eprintln!("Error: {}", err);
std::process::exit(-1); std::process::exit(-1);
} }
} }
fn run() -> Result<(), Error> { async fn run() -> Result<(), Error> {
if let Err(err) = syslog::init( if let Err(err) = syslog::init(
syslog::Facility::LOG_DAEMON, syslog::Facility::LOG_DAEMON,
log::LevelFilter::Info, log::LevelFilter::Info,
@ -58,36 +55,34 @@ fn run() -> Result<(), Error> {
// http server future: // http server future:
let server = daemon::create_daemon( let server = daemon::create_daemon(
([127,0,0,1], 82).into(), ([127,0,0,1], 82).into(),
|listener| { move |listener| {
Ok(hyper::Server::builder(listener.incoming()) Ok(hyper::Server::builder(listener.incoming())
.serve(rest_server) .serve(rest_server)
.with_graceful_shutdown(server::shutdown_future()) .with_graceful_shutdown(server::shutdown_future())
.map_err(|e| eprintln!("server error: {}", e)) .map(|e| {
if let Err(e) = e {
eprintln!("server error: {}", e);
}
})
) )
}, },
)?; )?;
daemon::systemd_notify(daemon::SystemdNotify::Ready)?; daemon::systemd_notify(daemon::SystemdNotify::Ready)?;
tokio::run(lazy(|| { let init_result: Result<(), Error> = try_block!({
server::create_task_control_socket()?;
let init_result: Result<(), Error> = try_block!({ server::server_state_init()?;
server::create_task_control_socket()?;
server::server_state_init()?;
Ok(())
});
if let Err(err) = init_result {
eprintln!("unable to start daemon - {}", err);
} else {
tokio::spawn(server.then(|_| {
log::info!("done - exit server");
Ok(())
}));
}
Ok(()) Ok(())
})); });
if let Err(err) = init_result {
bail!("unable to start daemon - {}", err);
}
server.await;
log::info!("done - exit server");
Ok(()) Ok(())
} }