diff options
| author | Trinity Pointard <trinity.pointard@gmail.com> | 2021-04-23 22:41:24 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-05-03 22:11:42 +0200 |
| commit | 6644df6b969df3f7ff0516ab7acd9b600dff0a54 (patch) | |
| tree | 2f86f6af2b12986da9cf1b0f412658f0eccb956e /src/garage/server.rs | |
| parent | f8ae8fc4beba57f1fb391f6fc9f38e6ab59406a9 (diff) | |
| download | garage-6644df6b969df3f7ff0516ab7acd9b600dff0a54.tar.gz garage-6644df6b969df3f7ff0516ab7acd9b600dff0a54.zip | |
fix clippy warnings on garage
Diffstat (limited to 'src/garage/server.rs')
| -rw-r--r-- | src/garage/server.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/garage/server.rs b/src/garage/server.rs index 3004d3d2..36f7de5c 100644 --- a/src/garage/server.rs +++ b/src/garage/server.rs @@ -25,7 +25,7 @@ async fn shutdown_signal(send_cancel: watch::Sender<bool>) -> Result<(), Error> Ok(()) } -async fn wait_from(mut chan: watch::Receiver<bool>) -> () { +async fn wait_from(mut chan: watch::Receiver<bool>) { while !*chan.borrow() { if chan.changed().await.is_err() { return; @@ -48,7 +48,7 @@ pub async fn run_server(config_file: PathBuf) -> Result<(), Error> { .expect("Unable to open sled DB"); info!("Initialize RPC server..."); - let mut rpc_server = RpcServer::new(config.rpc_bind_addr.clone(), config.rpc_tls.clone()); + let mut rpc_server = RpcServer::new(config.rpc_bind_addr, config.rpc_tls.clone()); info!("Initializing background runner..."); let (send_cancel, watch_cancel) = watch::channel(false); @@ -71,9 +71,9 @@ pub async fn run_server(config_file: PathBuf) -> Result<(), Error> { let web_server = run_web_server(garage, wait_from(watch_cancel.clone())); futures::try_join!( - bootstrap.map(|rv| { + bootstrap.map(|()| { info!("Bootstrap done"); - Ok(rv) + Ok(()) }), run_rpc_server.map(|rv| { info!("RPC server exited"); |