diff options
author | Aram Drevekenin <aram@poor.dev> | 2019-09-16 21:16:42 +0200 |
---|---|---|
committer | Aram Drevekenin <aram@poor.dev> | 2019-09-16 21:16:42 +0200 |
commit | e3ec9d22f0063d9ce83f87b49fd5dd90d57a9950 (patch) | |
tree | ec6c89abdb959a6d8c46863deb04c9e67311ddca /src/os | |
parent | 97aa07dfb8b3ab7840b15d4bfb278bb9f1b3c9ae (diff) |
style(all): rustfmt
Diffstat (limited to 'src/os')
-rw-r--r-- | src/os/linux.rs | 32 |
1 files changed, 18 insertions, 14 deletions
diff --git a/src/os/linux.rs b/src/os/linux.rs index 4023322..925ef69 100644 --- a/src/os/linux.rs +++ b/src/os/linux.rs @@ -1,11 +1,11 @@ -use ::std::io::stdin; -use ::pnet::datalink::{self, NetworkInterface}; -use ::pnet::datalink::DataLinkReceiver; +use ::netstat::{get_sockets_info, AddressFamilyFlags, ProtocolFlags, SocketInfo}; use ::pnet::datalink::Channel::Ethernet; -use ::termion::event::Event; -use ::termion::input::{TermRead}; -use ::netstat::{SocketInfo, AddressFamilyFlags, ProtocolFlags, get_sockets_info}; +use ::pnet::datalink::DataLinkReceiver; +use ::pnet::datalink::{self, NetworkInterface}; use ::procfs::Process; +use ::std::io::stdin; +use ::termion::event::Event; +use ::termion::input::TermRead; pub struct KeyboardEvents; @@ -14,33 +14,37 @@ impl Iterator for KeyboardEvents { fn next(&mut self) -> Option<Event> { match stdin().events().next() { Some(Ok(ev)) => Some(ev), - _ => None + _ => None, } } } -pub fn get_datalink_channel (interface: &NetworkInterface) -> Box<DataLinkReceiver> { +pub fn get_datalink_channel(interface: &NetworkInterface) -> Box<DataLinkReceiver> { match datalink::channel(interface, Default::default()) { Ok(Ethernet(_tx, rx)) => rx, Ok(_) => panic!("Unhandled channel type"), - Err(e) => panic!("An error occurred when creating the datalink channel: {}", e) + Err(e) => panic!( + "An error occurred when creating the datalink channel: {}", + e + ), } } -pub fn get_interface (interface_name: &str) -> Option<NetworkInterface> { - datalink::interfaces().into_iter() +pub fn get_interface(interface_name: &str) -> Option<NetworkInterface> { + datalink::interfaces() + .into_iter() .filter(|iface| iface.name == interface_name) .next() } -pub fn get_process_name (id: i32) -> Option<String> { +pub fn get_process_name(id: i32) -> Option<String> { match Process::new(id) { Ok(process) => Some(process.stat.comm), - Err(_) => None + Err(_) => None, } } -pub fn get_open_sockets () -> Vec<SocketInfo> { +pub fn get_open_sockets() -> Vec<SocketInfo> { let af_flags = AddressFamilyFlags::IPV4; let proto_flags = ProtocolFlags::TCP | ProtocolFlags::UDP; get_sockets_info(af_flags, proto_flags).unwrap_or_default() |