summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorDavid Göransson <david.goransson@mullvad.net>2024-11-26 15:18:17 +0100
committerDavid Göransson <david.goransson@mullvad.net>2024-11-27 09:00:19 +0100
commitda2de465a3b415a00337c81195a254eb7cec4055 (patch)
treeb187d728b4b36d5befa0c1b9a8603f3f8c50ec62
parentb09b15fac44ede49ff2b90b4970b9cf3733a0945 (diff)
downloadmullvadvpn-da2de465a3b415a00337c81195a254eb7cec4055.tar.xz
mullvadvpn-da2de465a3b415a00337c81195a254eb7cec4055.zip
Fix formatting
-rw-r--r--mullvad-daemon/src/lib.rs2
-rw-r--r--talpid-core/src/tunnel/mod.rs42
-rw-r--r--talpid-core/src/tunnel_state_machine/connecting_state.rs12
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!(
"{}",