diff options
| author | David Göransson <david.goransson@mullvad.net> | 2024-11-26 15:18:17 +0100 |
|---|---|---|
| committer | David Göransson <david.goransson@mullvad.net> | 2024-11-27 09:00:19 +0100 |
| commit | da2de465a3b415a00337c81195a254eb7cec4055 (patch) | |
| tree | b187d728b4b36d5befa0c1b9a8603f3f8c50ec62 | |
| parent | b09b15fac44ede49ff2b90b4970b9cf3733a0945 (diff) | |
| download | mullvadvpn-da2de465a3b415a00337c81195a254eb7cec4055.tar.xz mullvadvpn-da2de465a3b415a00337c81195a254eb7cec4055.zip | |
Fix formatting
| -rw-r--r-- | mullvad-daemon/src/lib.rs | 2 | ||||
| -rw-r--r-- | talpid-core/src/tunnel/mod.rs | 42 | ||||
| -rw-r--r-- | talpid-core/src/tunnel_state_machine/connecting_state.rs | 12 |
3 files changed, 23 insertions, 33 deletions
diff --git a/mullvad-daemon/src/lib.rs b/mullvad-daemon/src/lib.rs index 4c0be97bb6..79f08e8a0f 100644 --- a/mullvad-daemon/src/lib.rs +++ b/mullvad-daemon/src/lib.rs @@ -1439,7 +1439,7 @@ impl Daemon { #[cfg(target_os = "android")] match event { AccessMethodEvent::New { setting, .. } => { - // On android mullvad-api invokes protect on a socket to send requests + // On android mullvad-api invokes protect on a socket to send requests // outside the tunnel let notifier = self.management_interface.notifier().clone(); tokio::spawn(async move { diff --git a/talpid-core/src/tunnel/mod.rs b/talpid-core/src/tunnel/mod.rs index c36e660aff..a75f725099 100644 --- a/talpid-core/src/tunnel/mod.rs +++ b/talpid-core/src/tunnel/mod.rs @@ -4,9 +4,9 @@ use futures::channel::oneshot; use std::path; #[cfg(not(target_os = "android"))] use talpid_routing::RouteManagerHandle; -pub use talpid_tunnel::{TunnelArgs, TunnelEvent, TunnelMetadata}; #[cfg(target_os = "android")] use talpid_tunnel::tun_provider; +pub use talpid_tunnel::{TunnelArgs, TunnelEvent, TunnelMetadata}; #[cfg(not(target_os = "android"))] use talpid_types::net::openvpn as openvpn_types; use talpid_types::net::{wireguard as wireguard_types, TunnelParameters}; @@ -53,40 +53,30 @@ impl Into<ErrorStateCause> for Error { Error::EnableIpv6Error => ErrorStateCause::Ipv6Unavailable, #[cfg(target_os = "android")] - Error::WireguardTunnelMonitoringError( - talpid_wireguard::Error::TunnelError( - talpid_wireguard::TunnelError::SetupTunnelDevice( - tun_provider::Error::OtherLegacyAlwaysOnVpn, - ), + Error::WireguardTunnelMonitoringError(talpid_wireguard::Error::TunnelError( + talpid_wireguard::TunnelError::SetupTunnelDevice( + tun_provider::Error::OtherLegacyAlwaysOnVpn, ), - ) => ErrorStateCause::OtherLegacyAlwaysOnVpn, + )) => ErrorStateCause::OtherLegacyAlwaysOnVpn, #[cfg(target_os = "android")] - Error::WireguardTunnelMonitoringError( - talpid_wireguard::Error::TunnelError( - talpid_wireguard::TunnelError::SetupTunnelDevice( - tun_provider::Error::OtherAlwaysOnApp { app_name }, - ), + Error::WireguardTunnelMonitoringError(talpid_wireguard::Error::TunnelError( + talpid_wireguard::TunnelError::SetupTunnelDevice( + tun_provider::Error::OtherAlwaysOnApp { app_name }, ), - ) => ErrorStateCause::OtherAlwaysOnApp { app_name }, + )) => ErrorStateCause::OtherAlwaysOnApp { app_name }, #[cfg(target_os = "android")] - Error::WireguardTunnelMonitoringError( - talpid_wireguard::Error::TunnelError( - talpid_wireguard::TunnelError::SetupTunnelDevice( - tun_provider::Error::NotPrepared, - ), - ), - ) => ErrorStateCause::NotPrepared, + Error::WireguardTunnelMonitoringError(talpid_wireguard::Error::TunnelError( + talpid_wireguard::TunnelError::SetupTunnelDevice(tun_provider::Error::NotPrepared), + )) => ErrorStateCause::NotPrepared, #[cfg(target_os = "android")] - Error::WireguardTunnelMonitoringError( - talpid_wireguard::Error::TunnelError( - talpid_wireguard::TunnelError::SetupTunnelDevice( - tun_provider::Error::InvalidDnsServers(addresses), - ), + Error::WireguardTunnelMonitoringError(talpid_wireguard::Error::TunnelError( + talpid_wireguard::TunnelError::SetupTunnelDevice( + tun_provider::Error::InvalidDnsServers(addresses), ), - ) => ErrorStateCause::InvalidDnsServers(addresses), + )) => ErrorStateCause::InvalidDnsServers(addresses), #[cfg(target_os = "windows")] error => match error.get_tunnel_device_error() { Some(error) => ErrorStateCause::CreateTunnelDevice { diff --git a/talpid-core/src/tunnel_state_machine/connecting_state.rs b/talpid-core/src/tunnel_state_machine/connecting_state.rs index c616d6c205..7387d51c03 100644 --- a/talpid-core/src/tunnel_state_machine/connecting_state.rs +++ b/talpid-core/src/tunnel_state_machine/connecting_state.rs @@ -215,7 +215,7 @@ impl ConnectingState { ) -> Self { let (event_tx, event_rx) = mpsc::unbounded(); let on_tunnel_event = - move |event| -> std::pin::Pin<Box<dyn std::future::Future<Output=()> + Send>> { + move |event| -> std::pin::Pin<Box<dyn std::future::Future<Output = ()> + Send>> { let (tx, rx) = oneshot::channel(); let _ = event_tx.unbounded_send((event, tx)); Box::pin(async move { @@ -304,14 +304,14 @@ impl ConnectingState { None } error @ tunnel::Error::WireguardTunnelMonitoringError(..) - if !should_retry(&error, retry_attempt) => - { - log::error!( + if !should_retry(&error, retry_attempt) => + { + log::error!( "{}", error.display_chain_with_msg("Tunnel has stopped unexpectedly") ); - Some(ErrorStateCause::StartTunnelError) - } + Some(ErrorStateCause::StartTunnelError) + } error => { log::warn!( "{}", |
