style: Apply general code formatting and import reordering
This commit is contained in:
3 files changed
+13
-5
No files matched your search
+10
-2
@@ -134,7 +134,11 @@ fn main() -> anyhow::Result<()> {
|
|||||||
name: "starting",
|
name: "starting",
|
||||||
reason: "",
|
reason: "",
|
||||||
reflector: None,
|
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 {
|
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): {} / {}",
|
"Restoring base shaper rates (D/L): {} / {}",
|
||||||
config.download_base_kbits, config.upload_base_kbits
|
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);
|
let _ = Netlink::set_qdisc_rate(up_qdisc, config.upload_base_kbits as u64, config.dry_run);
|
||||||
|
|
||||||
result
|
result
|
||||||
|
|||||||
+2
-2
@@ -1,13 +1,13 @@
|
|||||||
|
use crate::Config;
|
||||||
use crate::config::{MeasurementType, ObservabilityProtocol};
|
use crate::config::{MeasurementType, ObservabilityProtocol};
|
||||||
use crate::time::Time;
|
use crate::time::Time;
|
||||||
use crate::Config;
|
|
||||||
use log::{error, info, warn};
|
use log::{error, info, warn};
|
||||||
use rustix::time::ClockId;
|
use rustix::time::ClockId;
|
||||||
use std::fmt::Write;
|
use std::fmt::Write;
|
||||||
use std::net::{IpAddr, TcpStream, UdpSocket};
|
use std::net::{IpAddr, TcpStream, UdpSocket};
|
||||||
|
use std::sync::Arc;
|
||||||
use std::sync::atomic::{AtomicU32, Ordering};
|
use std::sync::atomic::{AtomicU32, Ordering};
|
||||||
use std::sync::mpsc::{Receiver, RecvTimeoutError, SyncSender};
|
use std::sync::mpsc::{Receiver, RecvTimeoutError, SyncSender};
|
||||||
use std::sync::Arc;
|
|
||||||
use std::time::Duration;
|
use std::time::Duration;
|
||||||
|
|
||||||
const MAX_RECONNECT_BACKOFF: u64 = 60;
|
const MAX_RECONNECT_BACKOFF: u64 = 60;
|
||||||
|
|||||||
+1
-1
@@ -1,5 +1,5 @@
|
|||||||
use crate::SHUTDOWN;
|
|
||||||
use crate::MeasurementType;
|
use crate::MeasurementType;
|
||||||
|
use crate::SHUTDOWN;
|
||||||
use crate::metrics::{Metric, MetricsSender};
|
use crate::metrics::{Metric, MetricsSender};
|
||||||
use crate::util::RwLockExt;
|
use crate::util::RwLockExt;
|
||||||
use icmp_socket2::socket::IcmpSocket;
|
use icmp_socket2::socket::IcmpSocket;
|
||||||
|
|||||||
Reference in new issue
Block a user