diff --git a/src/rpc/system.rs b/src/rpc/system.rs index 0a68babc..0adbaa01 100644 --- a/src/rpc/system.rs +++ b/src/rpc/system.rs @@ -225,7 +225,7 @@ pub fn gen_node_key(metadata_dir: &Path) -> Result { use std::os::unix::fs::PermissionsExt; let mut perm = f.metadata()?.permissions(); perm.set_mode(0o600); - std::fs::set_permissions(key_file.as_path(), perm)?; + std::fs::set_permissions(key_file.as_path(), perm)?; } #[cfg(windows)] @@ -813,7 +813,7 @@ impl NodeStatus { } } - #[cfg(not(windows))] + #[cfg(not(windows))] fn update_disk_usage(&mut self, meta_dir: &Path, data_dir: &DataDirEnum) { use nix::sys::statvfs::statvfs; @@ -876,10 +876,10 @@ impl NodeStatus { }; } - #[cfg(windows)] + #[cfg(windows)] fn update_disk_usage(&mut self, _meta_dir: &Path, _data_dir: &DataDirEnum) { - // TODO(mediocregopher): update disk usage on windows, only used for metrics - } + // TODO(mediocregopher): update disk usage on windows, only used for metrics + } } /// Obtain the list of currently available IP addresses on all non-loopback @@ -894,7 +894,7 @@ fn get_default_ip(filter_ipnet: Option) -> Option { #[cfg(not(windows))] { - pnet_datalink::interfaces() + pnet_datalink::interfaces() .into_iter() // filter down and loopback interfaces .filter(|i| i.is_up() && !i.is_loopback()) @@ -902,7 +902,8 @@ fn get_default_ip(filter_ipnet: Option) -> Option { .flat_map(|e| e.ips) // optionally, filter to be inside filter_ipnet .find(|ipn| { - filter_ipnet.is_some_and(|ipnet| ipnet.contains(&ipn.ip())) || filter_ipnet.is_none() + filter_ipnet.is_some_and(|ipnet| ipnet.contains(&ipn.ip())) + || filter_ipnet.is_none() }) .map(|ipn| ipn.ip()) } diff --git a/src/web/web_server.rs b/src/web/web_server.rs index 8d1d7d09..50eb78f2 100644 --- a/src/web/web_server.rs +++ b/src/web/web_server.rs @@ -18,10 +18,10 @@ use opentelemetry::{ use crate::error::*; -use garage_api_common::generic_server::server_loop; use garage_api_common::cors::{ add_cors_headers, find_matching_cors_rule, handle_options_for_bucket, }; +use garage_api_common::generic_server::server_loop; use garage_api_common::helpers::*; use garage_api_s3::error::{ CommonErrorDerivative, Error as ApiError, OkOrBadRequest, OkOrInternalError, @@ -103,10 +103,10 @@ impl WebServer { #[cfg(not(windows))] UnixOrTCPSocketAddress::UnixSocket(ref path) => { + use garage_api_common::generic_server::UnixListenerOn; use std::fs::{self, Permissions}; use std::os::unix::prelude::PermissionsExt; use tokio::net::UnixListener; - use garage_api_common::generic_server::UnixListenerOn; if path.exists() { fs::remove_file(path)?