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

src/server/state.rs: update to tokio alpha.2 

Signed-off-by: Wolfgang Bumiller <w.bumiller@proxmox.com>
This commit is contained in:
Wolfgang Bumiller 2019-09-02 13:04:44 +02:00
parent aadcf7c621
commit b30415d244
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/server/state.rs
View File

@ -4,8 +4,7 @@ use std::sync::Mutex;
use futures::*; use futures::*;
// FIXME: with the next bump `Signal::new` becomes a freestanding function `signal()` use tokio_net::signal::unix::{signal, SignalKind};
use tokio_net::signal::unix::{Signal, SignalKind};
use crate::tools::{self, BroadcastData}; use crate::tools::{self, BroadcastData};
@ -36,7 +35,7 @@ lazy_static! {
pub fn server_state_init() -> Result<(), Error> { pub fn server_state_init() -> Result<(), Error> {
let stream = Signal::new(SignalKind::interrupt())?; let stream = signal(SignalKind::interrupt())?;
let future = stream.for_each(|_| { let future = stream.for_each(|_| {
println!("got shutdown request (SIGINT)"); println!("got shutdown request (SIGINT)");
@ -50,7 +49,7 @@ pub fn server_state_init() -> Result<(), Error> {
tokio::spawn(task.map(|_| ())); tokio::spawn(task.map(|_| ()));
let stream = Signal::new(SignalKind::hangup())?; let stream = signal(SignalKind::hangup())?;
let future = stream.for_each(|_| { let future = stream.for_each(|_| {
println!("got reload request (SIGHUP)"); println!("got reload request (SIGHUP)");