diff --git a/aggligator-util/src/transport/tcp.rs b/aggligator-util/src/transport/tcp.rs index 05aa4f6..fd84906 100644 --- a/aggligator-util/src/transport/tcp.rs +++ b/aggligator-util/src/transport/tcp.rs @@ -390,7 +390,9 @@ impl AcceptingTransport for TcpAcceptor { // Find local interface. let Some(interface) = local_interface_for_ip(local.ip())? else { - tracing::warn!("Interface for incoming connection from {remote} to {local} not found, rejecting."); + tracing::warn!( + "Interface for incoming connection from {remote} to {local} not found, rejecting." + ); continue; }; diff --git a/aggligator/src/agg/task.rs b/aggligator/src/agg/task.rs index 1d7e31d..b9de01b 100644 --- a/aggligator/src/agg/task.rs +++ b/aggligator/src/agg/task.rs @@ -1412,7 +1412,7 @@ where // Extract message and link used for sending. let mut status = packet.status.borrow_mut(); - let SentReliableStatus::ResendQueued {msg: reliable_msg} = &*status else { + let SentReliableStatus::ResendQueued { msg: reliable_msg } = &*status else { unreachable!("message was not queued for resending") }; @@ -1815,7 +1815,7 @@ where /// Sends statistics data. fn send_stats(&mut self) { - let Some (interval) = self.cfg.stats_intervals.iter().min() else { return }; + let Some(interval) = self.cfg.stats_intervals.iter().min() else { return }; if self.stats_last_sent.elapsed() >= *interval { self.stats_last_sent = Instant::now(); diff --git a/aggligator/src/connect.rs b/aggligator/src/connect.rs index 0239a52..0909651 100644 --- a/aggligator/src/connect.rs +++ b/aggligator/src/connect.rs @@ -423,9 +423,12 @@ where server_id, connection_id: encrypted_conn_id, existing_connection, - user_data: remote_user_data, cfg + user_data: remote_user_data, + cfg, } = LinkMsg::recv(&mut rx).await? - else { return Err::<_, IncomingError>(protocol_err!("expected Connect message").into()) }; + else { + return Err::<_, IncomingError>(protocol_err!("expected Connect message").into()); + }; let shared_secret = server_secret.diffie_hellman(&client_public_key); let conn_id = encrypted_conn_id.decrypt(&shared_secret); diff --git a/aggligator/src/control.rs b/aggligator/src/control.rs index 74d7cc8..5b9ab60 100644 --- a/aggligator/src/control.rs +++ b/aggligator/src/control.rs @@ -308,9 +308,11 @@ where public_key: server_public_key, server_id, cfg, - user_data: remote_user_data + user_data: remote_user_data, } = LinkMsg::recv(&mut rx).await? - else { return Err::<_, AddLinkError>(protocol_err!("expected Welcome message").into()) }; + else { + return Err::<_, AddLinkError>(protocol_err!("expected Welcome message").into()); + }; let shared_secret = client_secret.diffie_hellman(&server_public_key);