Rasmus Rosengren
3 years ago
parent
4ac84a774b
commit
dba83eb64a
GPG Key ID:
A13BC7BC4F81CF5F
@ -0,0 +1,34 @@ |
|||||||
|
use systemstat::Platform; |
||||||
|
|
||||||
|
use crate::Block; |
||||||
|
|
||||||
|
pub struct CpuBlock { |
||||||
|
pub id: usize, |
||||||
|
} |
||||||
|
|
||||||
|
impl Block for CpuBlock { |
||||||
|
fn id(&self) -> usize { |
||||||
|
self.id |
||||||
|
} |
||||||
|
|
||||||
|
fn name(&self) -> &str { |
||||||
|
"cpu" |
||||||
|
} |
||||||
|
|
||||||
|
fn run( |
||||||
|
&mut self, |
||||||
|
_event_r: flume::Receiver<crate::protocol::i3bar_event::I3BarEvent>, |
||||||
|
update_s: flume::Sender<(usize, String)>, |
||||||
|
) { |
||||||
|
let sys = systemstat::System::new(); |
||||||
|
loop { |
||||||
|
let cpu = sys.cpu_load_aggregate().unwrap(); |
||||||
|
std::thread::sleep(std::time::Duration::from_millis(1000)); |
||||||
|
let cpu = cpu.done().unwrap(); |
||||||
|
let load_percentage = 100.0 * cpu.user; |
||||||
|
update_s |
||||||
|
.send((self.id, format!(" Cpu: {:.2}% ", load_percentage))) |
||||||
|
.unwrap(); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,35 @@ |
|||||||
|
use systemstat::Platform; |
||||||
|
|
||||||
|
use crate::Block; |
||||||
|
|
||||||
|
pub struct MemoryBlock { |
||||||
|
pub id: usize, |
||||||
|
} |
||||||
|
|
||||||
|
impl Block for MemoryBlock { |
||||||
|
fn id(&self) -> usize { |
||||||
|
self.id |
||||||
|
} |
||||||
|
|
||||||
|
fn name(&self) -> &str { |
||||||
|
"memory" |
||||||
|
} |
||||||
|
|
||||||
|
fn run( |
||||||
|
&mut self, |
||||||
|
_event_r: flume::Receiver<crate::protocol::i3bar_event::I3BarEvent>, |
||||||
|
update_s: flume::Sender<(usize, String)>, |
||||||
|
) { |
||||||
|
let sys = systemstat::System::new(); |
||||||
|
loop { |
||||||
|
let mem = sys.memory().unwrap(); |
||||||
|
let bytes_used = systemstat::saturating_sub_bytes(mem.total, mem.free).as_u64(); |
||||||
|
let bytes_total = mem.total.as_u64(); |
||||||
|
let mem_percentage = 100.0 * bytes_used as f64 / bytes_total as f64; |
||||||
|
update_s |
||||||
|
.send((self.id, format!(" Mem: {:.2}% ", mem_percentage))) |
||||||
|
.unwrap(); |
||||||
|
std::thread::sleep(std::time::Duration::from_millis(1000)); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
pub mod cpu; |
||||||
|
pub mod memory; |
||||||
|
pub mod time; |
||||||
@ -0,0 +1,32 @@ |
|||||||
|
use chrono::Timelike; |
||||||
|
|
||||||
|
use crate::Block; |
||||||
|
|
||||||
|
pub struct TimeBlock { |
||||||
|
pub id: usize, |
||||||
|
} |
||||||
|
|
||||||
|
impl Block for TimeBlock { |
||||||
|
fn id(&self) -> usize { |
||||||
|
self.id |
||||||
|
} |
||||||
|
|
||||||
|
fn name(&self) -> &str { |
||||||
|
"time" |
||||||
|
} |
||||||
|
|
||||||
|
fn run( |
||||||
|
&mut self, |
||||||
|
_event_r: flume::Receiver<crate::protocol::i3bar_event::I3BarEvent>, |
||||||
|
update_s: flume::Sender<(usize, String)>, |
||||||
|
) { |
||||||
|
loop { |
||||||
|
let now = chrono::Local::now(); |
||||||
|
let time_string = now.format(" %a %d/%m %R ").to_string(); |
||||||
|
update_s.send((self.id, time_string)).unwrap(); |
||||||
|
|
||||||
|
let second = now.second() as u64; |
||||||
|
std::thread::sleep(std::time::Duration::from_secs(60 - second)); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,15 @@ |
|||||||
|
use std::io::Write; |
||||||
|
|
||||||
|
pub fn _debug<'s, S1, S2>(loc: S1, content: S2) |
||||||
|
where |
||||||
|
S1: AsRef<str>, |
||||||
|
S2: AsRef<str>, |
||||||
|
{ |
||||||
|
let mut file = std::fs::OpenOptions::new() |
||||||
|
.append(true) |
||||||
|
.create(true) |
||||||
|
.open("/home/rosen/dev/i3status-simple/debug.log") |
||||||
|
.unwrap(); |
||||||
|
file.write_all(format!("[{:?}]: {:?}\n", loc.as_ref(), content.as_ref()).as_bytes()) |
||||||
|
.unwrap(); |
||||||
|
} |
||||||
Loading…
Reference in new issue