diff options
| author | Linus Färnstrand <linus@mullvad.net> | 2018-12-13 17:32:24 +0100 |
|---|---|---|
| committer | Linus Färnstrand <linus@mullvad.net> | 2018-12-13 17:36:07 +0100 |
| commit | ffd272313cdfc77a79876050170272ab36fe932d (patch) | |
| tree | 4036176402e0f1d306d57a2860074699cbf4f319 /talpid-core/src | |
| parent | e175aaa139da8010fd3ae85bfc10dc7d98d50acc (diff) | |
| download | mullvadvpn-ffd272313cdfc77a79876050170272ab36fe932d.tar.xz mullvadvpn-ffd272313cdfc77a79876050170272ab36fe932d.zip | |
Activate the merge_imports rustfmt feature
Diffstat (limited to 'talpid-core/src')
26 files changed, 169 insertions, 137 deletions
diff --git a/talpid-core/src/logging.rs b/talpid-core/src/logging.rs index 512f86c9a6..9f63c70a33 100644 --- a/talpid-core/src/logging.rs +++ b/talpid-core/src/logging.rs @@ -1,5 +1,4 @@ -use std::path::Path; -use std::{fs, io}; +use std::{fs, io, path::Path}; error_chain! {} diff --git a/talpid-core/src/mktemp.rs b/talpid-core/src/mktemp.rs index 5e72044809..b5b5ec0719 100644 --- a/talpid-core/src/mktemp.rs +++ b/talpid-core/src/mktemp.rs @@ -1,7 +1,7 @@ -use std::env; -use std::fs; -use std::io; -use std::path::{Path, PathBuf}; +use std::{ + env, fs, io, + path::{Path, PathBuf}, +}; use uuid::Uuid; diff --git a/talpid-core/src/mpsc.rs b/talpid-core/src/mpsc.rs index c8e5b7449d..fd8814ab74 100644 --- a/talpid-core/src/mpsc.rs +++ b/talpid-core/src/mpsc.rs @@ -1,5 +1,4 @@ -use std::marker::PhantomData; -use std::sync::mpsc; +use std::{marker::PhantomData, sync::mpsc}; /// Abstraction over an `mpsc::Sender` that first converts the value to another type before sending. #[derive(Debug, Clone)] @@ -33,8 +32,7 @@ where #[cfg(test)] mod tests { use super::*; - use std::sync::mpsc; - use std::thread; + use std::{sync::mpsc, thread}; #[derive(Debug, Eq, PartialEq)] enum Inner { diff --git a/talpid-core/src/network_interface.rs b/talpid-core/src/network_interface.rs index 0bdc23072e..761fcbf794 100644 --- a/talpid-core/src/network_interface.rs +++ b/talpid-core/src/network_interface.rs @@ -1,6 +1,8 @@ use nix::fcntl; -use std::net::IpAddr; -use std::os::unix::io::{AsRawFd, IntoRawFd, RawFd}; +use std::{ + net::IpAddr, + os::unix::io::{AsRawFd, IntoRawFd, RawFd}, +}; use tun::{platform, Configuration, Device}; error_chain! { diff --git a/talpid-core/src/offline/linux.rs b/talpid-core/src/offline/linux.rs index 68792f39bb..cf0daca86a 100644 --- a/talpid-core/src/offline/linux.rs +++ b/talpid-core/src/offline/linux.rs @@ -2,18 +2,19 @@ extern crate iproute2; extern crate netlink_socket; extern crate rtnetlink; -use std::collections::BTreeSet; -use std::thread; +use std::{collections::BTreeSet, thread}; use error_chain::ChainedError; use futures::{future::Either, sync::mpsc::UnboundedSender, Future, Stream}; use log::{error, trace, warn}; -use self::iproute2::Link; -use self::netlink_socket::{Protocol, SocketAddr, TokioSocket}; -use self::rtnetlink::{ - LinkFlags, LinkHeader, LinkLayerType, LinkMessage, NetlinkCodec, NetlinkFramed, NetlinkMessage, - RtnlMessage, +use self::{ + iproute2::Link, + netlink_socket::{Protocol, SocketAddr, TokioSocket}, + rtnetlink::{ + LinkFlags, LinkHeader, LinkLayerType, LinkMessage, NetlinkCodec, NetlinkFramed, + NetlinkMessage, RtnlMessage, + }, }; use tunnel_state_machine::TunnelCommand; diff --git a/talpid-core/src/offline/windows.rs b/talpid-core/src/offline/windows.rs index eb8fe9a5b8..e5dbbaaed2 100644 --- a/talpid-core/src/offline/windows.rs +++ b/talpid-core/src/offline/windows.rs @@ -8,28 +8,35 @@ extern crate winapi; -use self::winapi::shared::basetsd::LONG_PTR; -use self::winapi::shared::minwindef::{DWORD, LPARAM, LRESULT, UINT, WPARAM}; -use self::winapi::shared::windef::HWND; -use self::winapi::um::handleapi::CloseHandle; -use self::winapi::um::libloaderapi::GetModuleHandleW; -use self::winapi::um::processthreadsapi::GetThreadId; -use self::winapi::um::synchapi::WaitForSingleObject; -use self::winapi::um::winbase::INFINITE; -use self::winapi::um::winuser::{ - CreateWindowExW, DefWindowProcW, DestroyWindow, DispatchMessageW, GetMessageW, - GetWindowLongPtrW, PostQuitMessage, PostThreadMessageW, SetWindowLongPtrW, GWLP_USERDATA, - GWLP_WNDPROC, PBT_APMRESUMEAUTOMATIC, PBT_APMSUSPEND, WM_DESTROY, WM_POWERBROADCAST, WM_USER, +use self::winapi::{ + shared::{ + basetsd::LONG_PTR, + minwindef::{DWORD, LPARAM, LRESULT, UINT, WPARAM}, + windef::HWND, + }, + um::{ + handleapi::CloseHandle, + libloaderapi::GetModuleHandleW, + processthreadsapi::GetThreadId, + synchapi::WaitForSingleObject, + winbase::INFINITE, + winuser::{ + CreateWindowExW, DefWindowProcW, DestroyWindow, DispatchMessageW, GetMessageW, + GetWindowLongPtrW, PostQuitMessage, PostThreadMessageW, SetWindowLongPtrW, + GWLP_USERDATA, GWLP_WNDPROC, PBT_APMRESUMEAUTOMATIC, PBT_APMSUSPEND, WM_DESTROY, + WM_POWERBROADCAST, WM_USER, + }, + }, }; use futures::sync::mpsc::UnboundedSender; use log::debug; -use std::ffi::c_void; -use std::mem::zeroed; -use std::os::windows::io::IntoRawHandle; -use std::os::windows::io::RawHandle; -use std::ptr; -use std::thread; -use std::time::Duration; +use std::{ + ffi::c_void, + mem::zeroed, + os::windows::io::{IntoRawHandle, RawHandle}, + ptr, thread, + time::Duration, +}; use tunnel_state_machine::TunnelCommand; const CLASS_NAME: &[u8] = b"S\0T\0A\0T\0I\0C\0\0\0"; diff --git a/talpid-core/src/process/openvpn.rs b/talpid-core/src/process/openvpn.rs index c524277290..8197784f0b 100644 --- a/talpid-core/src/process/openvpn.rs +++ b/talpid-core/src/process/openvpn.rs @@ -2,10 +2,12 @@ use duct; extern crate os_pipe; use super::stoppable_process::StoppableProcess; -use std::ffi::{OsStr, OsString}; -use std::fmt; -use std::path::{Path, PathBuf}; -use std::sync::Mutex; +use std::{ + ffi::{OsStr, OsString}, + fmt, + path::{Path, PathBuf}, + sync::Mutex, +}; use self::os_pipe::{pipe, PipeWriter}; use atty; @@ -378,8 +380,7 @@ impl StoppableProcess for OpenVpnProcHandle { #[cfg(test)] mod tests { use super::OpenVpnCommand; - use std::ffi::OsString; - use std::net::Ipv4Addr; + use std::{ffi::OsString, net::Ipv4Addr}; use talpid_types::net::{Endpoint, TransportProtocol}; #[test] diff --git a/talpid-core/src/process/stoppable_process.rs b/talpid-core/src/process/stoppable_process.rs index bcbd71973d..6de7eb104d 100644 --- a/talpid-core/src/process/stoppable_process.rs +++ b/talpid-core/src/process/stoppable_process.rs @@ -1,7 +1,8 @@ use log::{debug, trace, warn}; -use std::io; -use std::thread; -use std::time::{Duration, Instant}; +use std::{ + io, thread, + time::{Duration, Instant}, +}; static POLL_INTERVAL_MS: Duration = Duration::from_millis(50); diff --git a/talpid-core/src/routing/linux.rs b/talpid-core/src/routing/linux.rs index e45c469c57..da256a849f 100644 --- a/talpid-core/src/routing/linux.rs +++ b/talpid-core/src/routing/linux.rs @@ -1,8 +1,7 @@ use super::{NetNode, RequiredRoutes}; use super::subprocess::{Exec, RunExpr}; -use std::collections::HashSet; -use std::net::IpAddr; +use std::{collections::HashSet, net::IpAddr}; error_chain! { diff --git a/talpid-core/src/routing/macos.rs b/talpid-core/src/routing/macos.rs index 6928084273..582c453439 100644 --- a/talpid-core/src/routing/macos.rs +++ b/talpid-core/src/routing/macos.rs @@ -1,8 +1,7 @@ use super::{NetNode, RequiredRoutes, Route}; use super::subprocess::{Exec, RunExpr}; -use std::collections::HashSet; -use std::net::IpAddr; +use std::{collections::HashSet, net::IpAddr}; error_chain! { errors { diff --git a/talpid-core/src/security/linux/dns/mod.rs b/talpid-core/src/security/linux/dns/mod.rs index e9756b56b2..7266e7263b 100644 --- a/talpid-core/src/security/linux/dns/mod.rs +++ b/talpid-core/src/security/linux/dns/mod.rs @@ -7,10 +7,10 @@ mod systemd_resolved; use std::{env, fmt, net::IpAddr, path::Path}; -use self::network_manager::NetworkManager; -use self::resolvconf::Resolvconf; -use self::static_resolv_conf::StaticResolvConf; -use self::systemd_resolved::SystemdResolved; +use self::{ + network_manager::NetworkManager, resolvconf::Resolvconf, static_resolv_conf::StaticResolvConf, + systemd_resolved::SystemdResolved, +}; const RESOLV_CONF_PATH: &str = "/etc/resolv.conf"; diff --git a/talpid-core/src/security/linux/dns/network_manager.rs b/talpid-core/src/security/linux/dns/network_manager.rs index bc87685399..118be6e62d 100644 --- a/talpid-core/src/security/linux/dns/network_manager.rs +++ b/talpid-core/src/security/linux/dns/network_manager.rs @@ -1,15 +1,18 @@ extern crate dbus; -use std::collections::HashMap; -use std::net::IpAddr; +use std::{collections::HashMap, net::IpAddr}; -use self::dbus::arg::{RefArg, Variant}; -use self::dbus::stdintf::*; -use self::dbus::BusType; +use self::dbus::{ + arg::{RefArg, Variant}, + stdintf::*, + BusType, +}; -use std::fs::File; -use std::io::{BufRead, BufReader}; -use std::path::Path; +use std::{ + fs::File, + io::{BufRead, BufReader}, + path::Path, +}; use error_chain::ChainedError; diff --git a/talpid-core/src/security/linux/dns/static_resolv_conf.rs b/talpid-core/src/security/linux/dns/static_resolv_conf.rs index 37d20c49f1..e8534d3f8d 100644 --- a/talpid-core/src/security/linux/dns/static_resolv_conf.rs +++ b/talpid-core/src/security/linux/dns/static_resolv_conf.rs @@ -1,12 +1,17 @@ extern crate notify; -use std::net::IpAddr; -use std::sync::{mpsc, Arc, Mutex, MutexGuard}; -use std::{fs, io, thread}; +use std::{ + fs, io, + net::IpAddr, + sync::{mpsc, Arc, Mutex, MutexGuard}, + thread, +}; use self::notify::{RecommendedWatcher, RecursiveMode, Watcher}; -use super::resolv_conf::{Config, ScopedIp}; -use super::RESOLV_CONF_PATH; +use super::{ + resolv_conf::{Config, ScopedIp}, + RESOLV_CONF_PATH, +}; use error_chain::ChainedError; const RESOLV_CONF_BACKUP_PATH: &str = "/etc/resolv.conf.mullvadbackup"; diff --git a/talpid-core/src/security/linux/dns/systemd_resolved.rs b/talpid-core/src/security/linux/dns/systemd_resolved.rs index ae68206473..3d6cd19fd3 100644 --- a/talpid-core/src/security/linux/dns/systemd_resolved.rs +++ b/talpid-core/src/security/linux/dns/systemd_resolved.rs @@ -9,12 +9,12 @@ use std::{ path::Path, }; -use self::dbus::arg::RefArg; -use self::dbus::stdintf::*; -use self::dbus::{BusType, Interface, Member, Message, MessageItem, MessageItemArray, Signature}; +use self::dbus::{ + arg::RefArg, stdintf::*, BusType, Interface, Member, Message, MessageItem, MessageItemArray, + Signature, +}; -use super::super::iface_index; -use super::{resolv_conf, RESOLV_CONF_PATH}; +use super::{super::iface_index, resolv_conf, RESOLV_CONF_PATH}; error_chain! { diff --git a/talpid-core/src/security/mod.rs b/talpid-core/src/security/mod.rs index d057fb8336..ff59c0507e 100644 --- a/talpid-core/src/security/mod.rs +++ b/talpid-core/src/security/mod.rs @@ -2,11 +2,9 @@ use ipnetwork::{IpNetwork, Ipv4Network, Ipv6Network}; #[cfg(unix)] use lazy_static::lazy_static; -use std::fmt; -use std::net::IpAddr; #[cfg(unix)] use std::net::{Ipv4Addr, Ipv6Addr}; -use std::path::Path; +use std::{fmt, net::IpAddr, path::Path}; use talpid_types::net::Endpoint; diff --git a/talpid-core/src/security/windows/dns.rs b/talpid-core/src/security/windows/dns.rs index 8023d07b03..efe7dd9c73 100644 --- a/talpid-core/src/security/windows/dns.rs +++ b/talpid-core/src/security/windows/dns.rs @@ -1,10 +1,11 @@ use log::{debug, error, info, trace, warn}; -use std::borrow::Borrow; -use std::net::IpAddr; -use std::os::raw::{c_char, c_void}; -use std::path::Path; -use std::ptr; -use std::slice; +use std::{ + borrow::Borrow, + net::IpAddr, + os::raw::{c_char, c_void}, + path::Path, + ptr, slice, +}; use error_chain::ChainedError; use widestring::WideCString; diff --git a/talpid-core/src/security/windows/mod.rs b/talpid-core/src/security/windows/mod.rs index 35dd57a1de..e2930b92fc 100644 --- a/talpid-core/src/security/windows/mod.rs +++ b/talpid-core/src/security/windows/mod.rs @@ -1,5 +1,4 @@ -use std::net::IpAddr; -use std::ptr; +use std::{net::IpAddr, ptr}; use log::{debug, error, trace}; use talpid_types::net::Endpoint; diff --git a/talpid-core/src/security/windows/system_state.rs b/talpid-core/src/security/windows/system_state.rs index cdc36f4e36..55948340d7 100644 --- a/talpid-core/src/security/windows/system_state.rs +++ b/talpid-core/src/security/windows/system_state.rs @@ -1,9 +1,11 @@ //! A writer for a blob that would persistently store the system state. Useful //! for when the application of a secuirty policy proves to be persistent across //! reboots -use std::fs::{self, File}; -use std::io::{self, Write}; -use std::path::Path; +use std::{ + fs::{self, File}, + io::{self, Write}, + path::Path, +}; /// This struct is responsible for saving a binary blob to disk. The binary blob is intended to /// store system state that should be resotred when the security policy is reset. diff --git a/talpid-core/src/tunnel/mod.rs b/talpid-core/src/tunnel/mod.rs index fbf5a06f9d..078f23cf16 100644 --- a/talpid-core/src/tunnel/mod.rs +++ b/talpid-core/src/tunnel/mod.rs @@ -1,12 +1,14 @@ use crate::{mktemp, process::openvpn::OpenVpnCommand}; -use std::collections::HashMap; -use std::ffi::OsString; -use std::fs; -use std::io::{self, Write}; -use std::net::Ipv4Addr; -use std::path::{Path, PathBuf}; -use std::result::Result as StdResult; +use std::{ + collections::HashMap, + ffi::OsString, + fs, + io::{self, Write}, + net::Ipv4Addr, + path::{Path, PathBuf}, + result::Result as StdResult, +}; #[cfg(target_os = "linux")] use failure::ResultExt as FailureResultExt; @@ -362,8 +364,7 @@ impl CloseHandle { fn is_ipv6_enabled_in_os() -> bool { #[cfg(windows)] { - use winreg::enums::*; - use winreg::RegKey; + use winreg::{enums::*, RegKey}; const IPV6_DISABLED_ON_TUNNELS_MASK: u32 = 0x01; diff --git a/talpid-core/src/tunnel/openvpn.rs b/talpid-core/src/tunnel/openvpn.rs index dd7af9e5a2..fd2437f2e6 100644 --- a/talpid-core/src/tunnel/openvpn.rs +++ b/talpid-core/src/tunnel/openvpn.rs @@ -2,14 +2,18 @@ use crate::process::{ openvpn::{OpenVpnCommand, OpenVpnProcHandle}, stoppable_process::StoppableProcess, }; -use std::collections::HashMap; -use std::io; -use std::path::Path; -use std::process::ExitStatus; -use std::sync::atomic::{AtomicBool, Ordering}; -use std::sync::{mpsc, Arc}; -use std::thread; -use std::time::Duration; +use std::{ + collections::HashMap, + io, + path::Path, + process::ExitStatus, + sync::{ + atomic::{AtomicBool, Ordering}, + mpsc, Arc, + }, + thread, + time::Duration, +}; use talpid_ipc; diff --git a/talpid-core/src/tunnel_state_machine/blocked_state.rs b/talpid-core/src/tunnel_state_machine/blocked_state.rs index 14b72a20f8..d392318c6a 100644 --- a/talpid-core/src/tunnel_state_machine/blocked_state.rs +++ b/talpid-core/src/tunnel_state_machine/blocked_state.rs @@ -1,6 +1,5 @@ use error_chain::ChainedError; -use futures::sync::mpsc; -use futures::Stream; +use futures::{sync::mpsc, Stream}; use talpid_types::tunnel::BlockReason; use super::{ diff --git a/talpid-core/src/tunnel_state_machine/connected_state.rs b/talpid-core/src/tunnel_state_machine/connected_state.rs index 35d8a4f7c2..961889d6c2 100644 --- a/talpid-core/src/tunnel_state_machine/connected_state.rs +++ b/talpid-core/src/tunnel_state_machine/connected_state.rs @@ -1,8 +1,12 @@ use error_chain::ChainedError; -use futures::sync::{mpsc, oneshot}; -use futures::{Async, Future, Stream}; -use talpid_types::net::{Endpoint, OpenVpnProxySettings, TransportProtocol}; -use talpid_types::tunnel::BlockReason; +use futures::{ + sync::{mpsc, oneshot}, + Async, Future, Stream, +}; +use talpid_types::{ + net::{Endpoint, OpenVpnProxySettings, TransportProtocol}, + tunnel::BlockReason, +}; use super::{ AfterDisconnect, ConnectingState, DisconnectingState, EventConsequence, Result, ResultExt, diff --git a/talpid-core/src/tunnel_state_machine/connecting_state.rs b/talpid-core/src/tunnel_state_machine/connecting_state.rs index e4d81dd51e..20fdb249ff 100644 --- a/talpid-core/src/tunnel_state_machine/connecting_state.rs +++ b/talpid-core/src/tunnel_state_machine/connecting_state.rs @@ -1,16 +1,20 @@ -use std::ffi::OsString; -use std::path::{Path, PathBuf}; -use std::thread; -use std::time::{Duration, Instant}; +use std::{ + ffi::OsString, + path::{Path, PathBuf}, + thread, + time::{Duration, Instant}, +}; use error_chain::ChainedError; -use futures::sync::{mpsc, oneshot}; -use futures::{Async, Future, Stream}; +use futures::{ + sync::{mpsc, oneshot}, + Async, Future, Stream, +}; use log::{debug, error, info, trace, warn}; -use talpid_types::net::{ - Endpoint, OpenVpnProxySettings, TransportProtocol, TunnelEndpoint, TunnelEndpointData, +use talpid_types::{ + net::{Endpoint, OpenVpnProxySettings, TransportProtocol, TunnelEndpoint, TunnelEndpointData}, + tunnel::BlockReason, }; -use talpid_types::tunnel::BlockReason; use super::{ AfterDisconnect, BlockedState, ConnectedState, ConnectedStateBootstrap, DisconnectingState, diff --git a/talpid-core/src/tunnel_state_machine/disconnected_state.rs b/talpid-core/src/tunnel_state_machine/disconnected_state.rs index 6c57e287a1..0634c75da4 100644 --- a/talpid-core/src/tunnel_state_machine/disconnected_state.rs +++ b/talpid-core/src/tunnel_state_machine/disconnected_state.rs @@ -4,8 +4,7 @@ use super::{ }; use crate::security::SecurityPolicy; use error_chain::ChainedError; -use futures::sync::mpsc; -use futures::Stream; +use futures::{sync::mpsc, Stream}; /// No tunnel is running. pub struct DisconnectedState; diff --git a/talpid-core/src/tunnel_state_machine/disconnecting_state.rs b/talpid-core/src/tunnel_state_machine/disconnecting_state.rs index 928880f274..ec8be8cfe1 100644 --- a/talpid-core/src/tunnel_state_machine/disconnecting_state.rs +++ b/talpid-core/src/tunnel_state_machine/disconnecting_state.rs @@ -1,8 +1,10 @@ use std::thread; use error_chain::ChainedError; -use futures::sync::{mpsc, oneshot}; -use futures::{Async, Future, Stream}; +use futures::{ + sync::{mpsc, oneshot}, + Async, Future, Stream, +}; use talpid_types::tunnel::{ActionAfterDisconnect, BlockReason}; use super::{ diff --git a/talpid-core/src/tunnel_state_machine/mod.rs b/talpid-core/src/tunnel_state_machine/mod.rs index dcb4ada26c..53d58060d3 100644 --- a/talpid-core/src/tunnel_state_machine/mod.rs +++ b/talpid-core/src/tunnel_state_machine/mod.rs @@ -7,23 +7,28 @@ mod connecting_state; mod disconnected_state; mod disconnecting_state; -use std::path::{Path, PathBuf}; -use std::sync::mpsc as sync_mpsc; -use std::thread; +use std::{ + path::{Path, PathBuf}, + sync::mpsc as sync_mpsc, + thread, +}; use error_chain::ChainedError; -use futures::sync::mpsc; -use futures::{Async, Future, Poll, Stream}; +use futures::{sync::mpsc, Async, Future, Poll, Stream}; use tokio_core::reactor::Core; -use talpid_types::net::{TunnelEndpoint, TunnelOptions}; -use talpid_types::tunnel::{BlockReason, TunnelStateTransition}; +use talpid_types::{ + net::{TunnelEndpoint, TunnelOptions}, + tunnel::{BlockReason, TunnelStateTransition}, +}; -use self::blocked_state::BlockedState; -use self::connected_state::{ConnectedState, ConnectedStateBootstrap}; -use self::connecting_state::ConnectingState; -use self::disconnected_state::DisconnectedState; -use self::disconnecting_state::{AfterDisconnect, DisconnectingState}; +use self::{ + blocked_state::BlockedState, + connected_state::{ConnectedState, ConnectedStateBootstrap}, + connecting_state::ConnectingState, + disconnected_state::DisconnectedState, + disconnecting_state::{AfterDisconnect, DisconnectingState}, +}; use crate::{ mpsc::IntoSender, offline, @@ -249,8 +254,7 @@ enum TunnelStateMachineAction { impl<T: TunnelState> From<EventConsequence<T>> for TunnelStateMachineAction { fn from(event_consequence: EventConsequence<T>) -> Self { - use self::EventConsequence::*; - use self::TunnelStateMachineAction::*; + use self::{EventConsequence::*, TunnelStateMachineAction::*}; match event_consequence { NewState((state_wrapper, transition)) => { |
