diff --git a/validator/src/validator/health_check/path_check.rs b/validator/src/validator/health_check/path_check.rs index f0bc6f615e..d6f8180dc7 100644 --- a/validator/src/validator/health_check/path_check.rs +++ b/validator/src/validator/health_check/path_check.rs @@ -72,8 +72,8 @@ impl PathChecker { fn unique_path_key(path: &Vec, iteration: u8) -> Vec { std::iter::once(iteration) .chain( - path.iter() - .map(|node| node.pub_key.to_bytes().to_vec()) + path.iter() + .map(|node| node.pub_key.to_bytes().to_vec()) .flatten(), ) .collect() @@ -208,7 +208,7 @@ impl PathChecker { &self.our_destination, &delays, ) - .unwrap(); + .unwrap(); debug!("sending test packet to {}", first_node_address); match first_node_client.send(packet, first_node_address).await { @@ -227,7 +227,7 @@ impl PathChecker { .paths_status .insert(path_identifier, PathStatus::Pending) .is_some() - { + { panic!("Overwriting path checks!") } } diff --git a/validator/src/validator/health_check/score.rs b/validator/src/validator/health_check/score.rs index 2f394120e2..6f64c74647 100644 --- a/validator/src/validator/health_check/score.rs +++ b/validator/src/validator/health_check/score.rs @@ -42,9 +42,9 @@ impl NodeScore { } pub(crate) fn increase_received_packet_count(&mut self) { - self.packets_received += 1; - } + self.packets_received += 1; } +} impl std::fmt::Display for NodeScore { fn fmt(&self, f: &mut Formatter) -> Result<(), std::fmt::Error> {