From 0bddb3b70201403566944eaaeb98069702fd1e96 Mon Sep 17 00:00:00 2001 From: Luis Felipe Dominguez Vega Date: Thu, 6 Aug 2020 00:51:52 -0400 Subject: [PATCH] Fixing some linter errors --- src/main.rs | 9 ++------- src/redis.rs | 2 +- src/task.rs | 28 ++++++++++++++-------------- src/utils.rs | 4 ++-- 4 files changed, 19 insertions(+), 24 deletions(-) diff --git a/src/main.rs b/src/main.rs index 5cf552b..8d9b763 100644 --- a/src/main.rs +++ b/src/main.rs @@ -52,14 +52,9 @@ async fn main() { let config_reader = global_config::SETTINGS.read().unwrap(); loop { - redis::get_redis_hosts(ping_thread_log.clone()) + redis::get_redis_hosts(&ping_thread_log) .map(|hosts| { - task::do_ping_task( - ping_thread_log.clone(), - &mut historical_hosts, - hosts, - hostname.clone(), - ); + task::do_ping(&ping_thread_log, &mut historical_hosts, hosts, &hostname); }) .unwrap_or_default(); diff --git a/src/redis.rs b/src/redis.rs index 91f172e..a657e0e 100644 --- a/src/redis.rs +++ b/src/redis.rs @@ -13,7 +13,7 @@ impl PartialEq for Host { } } -pub fn get_redis_hosts(ping_thread_log: Logger) -> Result, ()> { +pub fn get_redis_hosts(ping_thread_log: &Logger) -> Result, ()> { let redis_host = crate::global_config::SETTINGS .read() .unwrap() diff --git a/src/task.rs b/src/task.rs index 02395ac..3b7ec9f 100644 --- a/src/task.rs +++ b/src/task.rs @@ -4,13 +4,13 @@ use fastping_rs::Pinger; use slog::Logger; use std::collections::HashMap; -pub fn do_ping_task( - ping_thread_log: Logger, +pub fn do_ping( + ping_thread_log: &Logger, historical_hosts: &mut HashMap, hosts: Vec, - hostname: String, + hostname: &str, ) { - let local_inet_address = crate::utils::ifaddrs(ping_thread_log.clone()); + let local_inet_address = crate::utils::ifaddrs(ping_thread_log); let config_reader = crate::global_config::SETTINGS.read().unwrap(); @@ -42,16 +42,16 @@ pub fn do_ping_task( for deleted_host in deleted_hosts { crate::prom::PING_LATENCY_HISTOGRAM - .remove_label_values(&[&deleted_host.0[..], &deleted_host.1[..], &hostname[..]]) + .remove_label_values(&[&deleted_host.0[..], &deleted_host.1[..], hostname]) .unwrap_or_default(); crate::prom::PING_ERROR_COUNT - .remove_label_values(&[&deleted_host.0[..], &deleted_host.1[..], &hostname[..]]) + .remove_label_values(&[&deleted_host.0[..], &deleted_host.1[..], hostname]) .unwrap_or_default(); crate::prom::PING_LAST - .remove_label_values(&[&deleted_host.0[..], &deleted_host.1[..], &hostname[..]]) + .remove_label_values(&[&deleted_host.0[..], &deleted_host.1[..], hostname]) .unwrap_or_default(); crate::prom::HOST_UP - .remove_label_values(&[&deleted_host.0[..], &deleted_host.1[..], &hostname[..]]) + .remove_label_values(&[&deleted_host.0[..], &deleted_host.1[..], hostname]) .unwrap_or_default(); } @@ -99,21 +99,21 @@ pub fn do_ping_task( .with_label_values(&[ &addr_str[..], &historical_hosts[&addr_str][..], - &hostname[..], + hostname, ]) .inc(); crate::prom::PING_LAST .remove_label_values(&[ &addr_str[..], &historical_hosts[&addr_str][..], - &hostname[..], + hostname, ]) .unwrap_or_default(); crate::prom::HOST_UP .with_label_values(&[ &addr_str[..], &historical_hosts[&addr_str][..], - &hostname[..], + hostname, ]) .set(0.0); warn!(ping_thread_log, "No response from host"; "host" => addr_str); @@ -126,21 +126,21 @@ pub fn do_ping_task( .with_label_values(&[ &addr_str[..], &historical_hosts[&addr_str][..], - &hostname[..], + hostname, ]) .observe(millis as f64); crate::prom::PING_LAST .with_label_values(&[ &addr_str[..], &historical_hosts[&addr_str][..], - &hostname[..], + hostname, ]) .set(millis as f64); crate::prom::HOST_UP .with_label_values(&[ &addr_str[..], &historical_hosts[&addr_str][..], - &hostname[..], + hostname, ]) .set(1.0); diff --git a/src/utils.rs b/src/utils.rs index 4f40a6c..f6a4573 100644 --- a/src/utils.rs +++ b/src/utils.rs @@ -3,7 +3,7 @@ use nix::sys::socket::SockAddr::Inet; use nix::unistd::gethostname; use slog::Logger; -pub fn ifaddrs(ping_thread_log: Logger) -> Vec { +pub fn ifaddrs(ping_thread_log: &Logger) -> Vec { let mut local_inet_address = vec![]; for ifaddr in getifaddrs().unwrap() { @@ -28,7 +28,7 @@ pub fn ifaddrs(ping_thread_log: Logger) -> Vec { } pub fn host_name() -> String { - let mut buf = [0u8; 128]; + let mut buf = [0_u8; 128]; let hostname_cstr = gethostname(&mut buf).expect("Failed getting hostname"); let hostname = hostname_cstr.to_str().expect("Hostname wasn't valid UTF-8");