From 72fe0230ee1806f7ac4f35bdca4002d15202b35e Mon Sep 17 00:00:00 2001 From: Nils Andreas Svee Date: Wed, 22 Apr 2026 21:45:11 +0700 Subject: [PATCH] style: Apply general code formatting and import reordering --- src/main.rs | 12 ++++++++++-- src/metrics.rs | 4 ++-- src/pinger.rs | 2 +- 3 files changed, 13 insertions(+), 5 deletions(-) diff --git a/src/main.rs b/src/main.rs index 92fa1f6..231cdae 100644 --- a/src/main.rs +++ b/src/main.rs @@ -134,7 +134,11 @@ fn main() -> anyhow::Result<()> { name: "starting", reason: "", reflector: None, - tags: if config.dry_run { &[("dry_run", "true")] } else { &[] }, + tags: if config.dry_run { + &[("dry_run", "true")] + } else { + &[] + }, }); let (mut ping_listener, mut ping_sender) = match config.measurement_type { @@ -331,7 +335,11 @@ fn main() -> anyhow::Result<()> { "Restoring base shaper rates (D/L): {} / {}", config.download_base_kbits, config.upload_base_kbits ); - let _ = Netlink::set_qdisc_rate(down_qdisc, config.download_base_kbits as u64, config.dry_run); + let _ = Netlink::set_qdisc_rate( + down_qdisc, + config.download_base_kbits as u64, + config.dry_run, + ); let _ = Netlink::set_qdisc_rate(up_qdisc, config.upload_base_kbits as u64, config.dry_run); result diff --git a/src/metrics.rs b/src/metrics.rs index 18ecd4b..2ca2a05 100644 --- a/src/metrics.rs +++ b/src/metrics.rs @@ -1,13 +1,13 @@ +use crate::Config; use crate::config::{MeasurementType, ObservabilityProtocol}; use crate::time::Time; -use crate::Config; use log::{error, info, warn}; use rustix::time::ClockId; use std::fmt::Write; use std::net::{IpAddr, TcpStream, UdpSocket}; +use std::sync::Arc; use std::sync::atomic::{AtomicU32, Ordering}; use std::sync::mpsc::{Receiver, RecvTimeoutError, SyncSender}; -use std::sync::Arc; use std::time::Duration; const MAX_RECONNECT_BACKOFF: u64 = 60; diff --git a/src/pinger.rs b/src/pinger.rs index c015a75..0ee960a 100644 --- a/src/pinger.rs +++ b/src/pinger.rs @@ -1,5 +1,5 @@ -use crate::SHUTDOWN; use crate::MeasurementType; +use crate::SHUTDOWN; use crate::metrics::{Metric, MetricsSender}; use crate::util::RwLockExt; use icmp_socket2::socket::IcmpSocket;