style: reformat thread builder calls in main.rs
Standardize the formatting of thread spawning for the receiver and sender to improve code consistency and readability.
This commit is contained in:
1 file changed
+8
-8
+8
-8
@@ -127,8 +127,9 @@ fn main() -> anyhow::Result<()> {
|
|||||||
|
|
||||||
let err_tx = error_tx.clone();
|
let err_tx = error_tx.clone();
|
||||||
let reflector_peers_lock_clone = reflector_peers_lock.clone();
|
let reflector_peers_lock_clone = reflector_peers_lock.clone();
|
||||||
thread::Builder::new().name("receiver".to_string()).spawn(
|
thread::Builder::new()
|
||||||
move || {
|
.name("receiver".to_string())
|
||||||
|
.spawn(move || {
|
||||||
if let Err(e) = pinger_receiver.listen(
|
if let Err(e) = pinger_receiver.listen(
|
||||||
id,
|
id,
|
||||||
config.measurement_type,
|
config.measurement_type,
|
||||||
@@ -137,8 +138,7 @@ fn main() -> anyhow::Result<()> {
|
|||||||
) {
|
) {
|
||||||
let _ = err_tx.send(e);
|
let _ = err_tx.send(e);
|
||||||
}
|
}
|
||||||
},
|
})?;
|
||||||
)?;
|
|
||||||
|
|
||||||
let err_tx = error_tx.clone();
|
let err_tx = error_tx.clone();
|
||||||
thread::Builder::new()
|
thread::Builder::new()
|
||||||
@@ -151,8 +151,9 @@ fn main() -> anyhow::Result<()> {
|
|||||||
|
|
||||||
let err_tx = error_tx.clone();
|
let err_tx = error_tx.clone();
|
||||||
let reflector_peers_lock_clone = reflector_peers_lock.clone();
|
let reflector_peers_lock_clone = reflector_peers_lock.clone();
|
||||||
thread::Builder::new().name("sender".to_string()).spawn(
|
thread::Builder::new()
|
||||||
move || {
|
.name("sender".to_string())
|
||||||
|
.spawn(move || {
|
||||||
if let Err(e) = pinger_sender.send(
|
if let Err(e) = pinger_sender.send(
|
||||||
id,
|
id,
|
||||||
config.measurement_type,
|
config.measurement_type,
|
||||||
@@ -161,8 +162,7 @@ fn main() -> anyhow::Result<()> {
|
|||||||
) {
|
) {
|
||||||
let _ = err_tx.send(e);
|
let _ = err_tx.send(e);
|
||||||
}
|
}
|
||||||
},
|
})?;
|
||||||
)?;
|
|
||||||
|
|
||||||
if reflector_pool_size > config.num_reflectors as usize {
|
if reflector_pool_size > config.num_reflectors as usize {
|
||||||
let reflector_selector = ReflectorSelector {
|
let reflector_selector = ReflectorSelector {
|
||||||
|
|||||||
Reference in new issue
Block a user