change: switch from sysinfo to heim for cpu usage in macOS and Windows (#467)

Due to #404, I've just moved all CPU usage calculations over to heim.

CHANGELOG.md

@@ -65,6 +65,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 - [#425](https://github.com/ClementTsang/bottom/pull/425): Fixed a bug allowing grouped mode in tree mode if already in grouped mode.
 
+- [#467](https://github.com/ClementTsang/bottom/pull/467): Switched CPU usage data source to fix a bug on Windows where occasionally CPU usage would be stuck at 0%.
+
 ## [0.5.7] - 2021-01-30
 
 ## Bug Fixes

Cargo.toml

@@ -44,6 +44,7 @@ ctrlc = { version = "3.1.9", features = ["termination"] }
 clap = "2.33"
 dirs-next = "2.0.0"
 futures = "0.3.14"
+futures-timer = "3.0.2"
 fxhash = "0.2.1"
 indexmap = "1.6.2"
 itertools = "0.10.0"
@@ -68,13 +69,12 @@ libc = "0.2.86"
 
 [target.'cfg(target_os = "linux")'.dependencies]
 heim = { version = "0.1.0-rc.1", features = ["cpu", "disk", "memory", "net", "sensors"] }
-futures-timer = "3.0.2"
 
 [target.'cfg(target_os = "macos")'.dependencies]
-heim = { version = "0.1.0-rc.1", features = ["disk", "memory", "net"] } 
+heim = { version = "0.1.0-rc.1", features = ["cpu", "disk", "memory", "net"] } 
 
 [target.'cfg(target_os = "windows")'.dependencies]
-heim = { version = "0.1.0-rc.1", features = ["disk", "memory"] }
+heim = { version = "0.1.0-rc.1", features = ["cpu", "disk", "memory"] }
 winapi = "0.3.9"
 
 [dev-dependencies]

src/app/data_harvester.rs

@@ -80,9 +80,7 @@ pub struct DataCollector {
     pub data: Data,
     #[cfg(not(target_os = "linux"))]
     sys: System,
-    #[cfg(target_os = "linux")]
     previous_cpu_times: Vec<(cpu::PastCpuWork, cpu::PastCpuTotal)>,
-    #[cfg(target_os = "linux")]
     previous_average_cpu_time: Option<(cpu::PastCpuWork, cpu::PastCpuTotal)>,
     #[cfg(target_os = "linux")]
     pid_mapping: FxHashMap<crate::Pid, processes::PrevProcDetails>,
@@ -111,9 +109,7 @@ impl DataCollector {
             data: Data::default(),
             #[cfg(not(target_os = "linux"))]
             sys: System::new_with_specifics(sysinfo::RefreshKind::new()),
-            #[cfg(target_os = "linux")]
             previous_cpu_times: vec![],
-            #[cfg(target_os = "linux")]
             previous_average_cpu_time: None,
             #[cfg(target_os = "linux")]
             pid_mapping: FxHashMap::default(),
@@ -216,9 +212,6 @@ impl DataCollector {
     pub async fn update_data(&mut self) {
         #[cfg(not(target_os = "linux"))]
         {
-            if self.widgets_to_harvest.use_cpu {
-                self.sys.refresh_cpu();
-            }
             if self.widgets_to_harvest.use_proc {
                 self.sys.refresh_processes();
             }
@@ -235,22 +228,14 @@ impl DataCollector {
 
         // CPU
         if self.widgets_to_harvest.use_cpu {
-            #[cfg(not(target_os = "linux"))]
+            if let Ok(cpu_data) = cpu::get_cpu_data_list(
+                self.show_average_cpu,
+                &mut self.previous_cpu_times,
+                &mut self.previous_average_cpu_time,
+            )
+            .await
             {
-                self.data.cpu = Some(cpu::get_cpu_data_list(&self.sys, self.show_average_cpu));
+                self.data.cpu = Some(cpu_data);
-            }
-
-            #[cfg(target_os = "linux")]
-            {
-                if let Ok(cpu_data) = cpu::get_cpu_data_list(
-                    self.show_average_cpu,
-                    &mut self.previous_cpu_times,
-                    &mut self.previous_average_cpu_time,
-                )
-                .await
-                {
-                    self.data.cpu = Some(cpu_data);
-                }
             }
 
             #[cfg(target_family = "unix")]

src/app/data_harvester/cpu.rs

@@ -10,56 +10,40 @@ pub type CpuHarvest = Vec<CpuData>;
 pub type PastCpuWork = f64;
 pub type PastCpuTotal = f64;
 
-#[cfg(not(target_os = "linux"))]
-use sysinfo::{ProcessorExt, System, SystemExt};
-
-#[cfg(not(target_os = "linux"))]
-pub fn get_cpu_data_list(sys: &System, show_average_cpu: bool) -> CpuHarvest {
-    let cpu_data = sys.get_processors();
-    let avg_cpu_usage = sys.get_global_processor_info().get_cpu_usage();
-    let mut cpu_vec = vec![];
-
-    if show_average_cpu {
-        cpu_vec.push(CpuData {
-            cpu_prefix: "AVG".to_string(),
-            cpu_count: None,
-            cpu_usage: avg_cpu_usage as f64,
-        });
-    }
-
-    for (itx, cpu) in cpu_data.iter().enumerate() {
-        cpu_vec.push(CpuData {
-            cpu_prefix: "CPU".to_string(),
-            cpu_count: Some(itx),
-            cpu_usage: f64::from(cpu.get_cpu_usage()),
-        });
-    }
-
-    cpu_vec
-}
-
-#[cfg(target_os = "linux")]
 pub async fn get_cpu_data_list(
     show_average_cpu: bool, previous_cpu_times: &mut Vec<(PastCpuWork, PastCpuTotal)>,
     previous_average_cpu_time: &mut Option<(PastCpuWork, PastCpuTotal)>,
 ) -> crate::error::Result<CpuHarvest> {
     use futures::StreamExt;
+    #[cfg(target_os = "linux")]
     use heim::cpu::os::linux::CpuTimeExt;
     use std::collections::VecDeque;
 
     fn convert_cpu_times(cpu_time: &heim::cpu::CpuTime) -> (f64, f64) {
-        let working_time: f64 = (cpu_time.user()
+        #[cfg(not(target_os = "linux"))]
-            + cpu_time.nice()
+        {
-            + cpu_time.system()
+            let working_time: f64 =
-            + cpu_time.irq()
+                (cpu_time.user() + cpu_time.system()).get::<heim::units::time::second>();
-            + cpu_time.soft_irq()
+            (
-            + cpu_time.steal())
+                working_time,
-        .get::<heim::units::time::second>();
+                working_time + cpu_time.idle().get::<heim::units::time::second>(),
-        (
+            )
-            working_time,
+        }
-            working_time
+        #[cfg(target_os = "linux")]
-                + (cpu_time.idle() + cpu_time.io_wait()).get::<heim::units::time::second>(),
+        {
-        )
+            let working_time: f64 = (cpu_time.user()
+                + cpu_time.nice()
+                + cpu_time.system()
+                + cpu_time.irq()
+                + cpu_time.soft_irq()
+                + cpu_time.steal())
+            .get::<heim::units::time::second>();
+            (
+                working_time,
+                working_time
+                    + (cpu_time.idle() + cpu_time.io_wait()).get::<heim::units::time::second>(),
+            )
+        }
     }
 
     fn calculate_cpu_usage_percentage(