summaryrefslogtreecommitdiffstats
path: root/src/os
diff options
context:
space:
mode:
authorAram Drevekenin <aram@poor.dev>2019-09-16 21:16:42 +0200
committerAram Drevekenin <aram@poor.dev>2019-09-16 21:16:42 +0200
commite3ec9d22f0063d9ce83f87b49fd5dd90d57a9950 (patch)
treeec6c89abdb959a6d8c46863deb04c9e67311ddca /src/os
parent97aa07dfb8b3ab7840b15d4bfb278bb9f1b3c9ae (diff)
style(all): rustfmt
Diffstat (limited to 'src/os')
-rw-r--r--src/os/linux.rs32
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()