summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorClementTsang <cjhtsang@uwaterloo.ca>2020-02-10 19:44:26 -0500
committerClementTsang <cjhtsang@uwaterloo.ca>2020-02-10 19:44:26 -0500
commita7025aca4a25b597b2ae766f9cdc3ff39d815f38 (patch)
tree2dfd5ce513a92d797278008e3e51419864471581 /src
parentf21c06f8ed19f57208b3fb1fa1e55238a5a1a9ef (diff)
More clippy fixing.
Diffstat (limited to 'src')
-rw-r--r--src/app/data_farmer.rs32
-rw-r--r--src/app/data_harvester.rs6
-rw-r--r--src/app/data_harvester/network.rs8
-rw-r--r--src/app/data_harvester/processes.rs10
-rw-r--r--src/main.rs1
5 files changed, 28 insertions, 29 deletions
diff --git a/src/app/data_farmer.rs b/src/app/data_farmer.rs
index e02d715a..298bf543 100644
--- a/src/app/data_farmer.rs
+++ b/src/app/data_farmer.rs
@@ -97,19 +97,19 @@ impl DataCollection {
let mut new_entry = TimedData::default();
// Network
- self.eat_network(&harvested_data, &harvested_time, &mut new_entry);
+ self.eat_network(&harvested_data, harvested_time, &mut new_entry);
// Memory and Swap
- self.eat_memory_and_swap(&harvested_data, &harvested_time, &mut new_entry);
+ self.eat_memory_and_swap(&harvested_data, harvested_time, &mut new_entry);
// CPU
- self.eat_cpu(&harvested_data, &harvested_time, &mut new_entry);
+ self.eat_cpu(&harvested_data, harvested_time, &mut new_entry);
// Temp
self.eat_temp(&harvested_data);
// Disks
- self.eat_disks(&harvested_data, &harvested_time);
+ self.eat_disks(&harvested_data, harvested_time);
// Processes
self.eat_proc(&harvested_data);
@@ -120,14 +120,14 @@ impl DataCollection {
}
fn eat_memory_and_swap(
- &mut self, harvested_data: &Data, harvested_time: &Instant, new_entry: &mut TimedData,
+ &mut self, harvested_data: &Data, harvested_time: Instant, new_entry: &mut TimedData,
) {
// Memory
let mem_percent = harvested_data.memory.mem_used_in_mb as f64
/ harvested_data.memory.mem_total_in_mb as f64
* 100.0;
let mem_joining_pts = if let Some((time, last_pt)) = self.timed_data_vec.last() {
- generate_joining_points(&time, last_pt.mem_data.0, &harvested_time, mem_percent)
+ generate_joining_points(*time, last_pt.mem_data.0, harvested_time, mem_percent)
} else {
Vec::new()
};
@@ -140,7 +140,7 @@ impl DataCollection {
/ harvested_data.swap.mem_total_in_mb as f64
* 100.0;
let swap_joining_pt = if let Some((time, last_pt)) = self.timed_data_vec.last() {
- generate_joining_points(&time, last_pt.swap_data.0, &harvested_time, swap_percent)
+ generate_joining_points(*time, last_pt.swap_data.0, harvested_time, swap_percent)
} else {
Vec::new()
};
@@ -154,7 +154,7 @@ impl DataCollection {
}
fn eat_network(
- &mut self, harvested_data: &Data, harvested_time: &Instant, new_entry: &mut TimedData,
+ &mut self, harvested_data: &Data, harvested_time: Instant, new_entry: &mut TimedData,
) {
// RX
let logged_rx_val = if harvested_data.network.rx as f64 > 0.0 {
@@ -164,7 +164,7 @@ impl DataCollection {
};
let rx_joining_pts = if let Some((time, last_pt)) = self.timed_data_vec.last() {
- generate_joining_points(&time, last_pt.rx_data.0, &harvested_time, logged_rx_val)
+ generate_joining_points(*time, last_pt.rx_data.0, harvested_time, logged_rx_val)
} else {
Vec::new()
};
@@ -179,7 +179,7 @@ impl DataCollection {
};
let tx_joining_pts = if let Some((time, last_pt)) = self.timed_data_vec.last() {
- generate_joining_points(&time, last_pt.tx_data.0, &harvested_time, logged_tx_val)
+ generate_joining_points(*time, last_pt.tx_data.0, harvested_time, logged_tx_val)
} else {
Vec::new()
};
@@ -191,7 +191,7 @@ impl DataCollection {
}
fn eat_cpu(
- &mut self, harvested_data: &Data, harvested_time: &Instant, new_entry: &mut TimedData,
+ &mut self, harvested_data: &Data, harvested_time: Instant, new_entry: &mut TimedData,
) {
// Note this only pre-calculates the data points - the names will be
// within the local copy of cpu_harvest. Since it's all sequential
@@ -199,9 +199,9 @@ impl DataCollection {
for (itx, cpu) in harvested_data.cpu.iter().enumerate() {
let cpu_joining_pts = if let Some((time, last_pt)) = self.timed_data_vec.last() {
generate_joining_points(
- &time,
+ *time,
last_pt.cpu_data[itx].0,
- &harvested_time,
+ harvested_time,
cpu.cpu_usage,
)
} else {
@@ -220,7 +220,7 @@ impl DataCollection {
self.temp_harvest = harvested_data.temperature_sensors.clone();
}
- fn eat_disks(&mut self, harvested_data: &Data, harvested_time: &Instant) {
+ fn eat_disks(&mut self, harvested_data: &Data, harvested_time: Instant) {
// TODO: [PO] To implement
let time_since_last_harvest = harvested_time
@@ -262,12 +262,12 @@ impl DataCollection {
}
pub fn generate_joining_points(
- start_x: &Instant, start_y: f64, end_x: &Instant, end_y: f64,
+ start_x: Instant, start_y: f64, end_x: Instant, end_y: f64,
) -> Vec<(TimeOffset, Value)> {
let mut points: Vec<(TimeOffset, Value)> = Vec::new();
// Convert time floats first:
- let tmp_time_diff = (*end_x).duration_since(*start_x).as_millis() as f64;
+ let tmp_time_diff = (end_x).duration_since(start_x).as_millis() as f64;
let time_difference = if tmp_time_diff == 0.0 {
0.001
} else {
diff --git a/src/app/data_harvester.rs b/src/app/data_harvester.rs
index ae276703..db478038 100644
--- a/src/app/data_harvester.rs
+++ b/src/app/data_harvester.rs
@@ -118,10 +118,10 @@ impl DataState {
// Network
self.data.network = network::get_network_data(
&self.sys,
- &self.data.last_collection_time,
+ self.data.last_collection_time,
&mut self.data.network.total_rx,
&mut self.data.network.total_tx,
- &current_instant,
+ current_instant,
)
.await;
@@ -160,7 +160,7 @@ impl DataState {
&mut self.prev_pid_stats,
self.use_current_cpu_total,
self.mem_total_kb,
- &current_instant,
+ current_instant,
),
&mut self.data.list_of_processes,
);
diff --git a/src/app/data_harvester/network.rs b/src/app/data_harvester/network.rs
index ad06368f..b4d32c29 100644
--- a/src/app/data_harvester/network.rs
+++ b/src/app/data_harvester/network.rs
@@ -20,8 +20,8 @@ impl NetworkHarvest {
}
pub async fn get_network_data(
- sys: &System, prev_net_access_time: &Instant, prev_net_rx: &mut u64, prev_net_tx: &mut u64,
- curr_time: &Instant,
+ sys: &System, prev_net_access_time: Instant, prev_net_rx: &mut u64, prev_net_tx: &mut u64,
+ curr_time: Instant,
) -> NetworkHarvest {
let mut io_data = net::io_counters();
let mut total_rx: u64 = 0;
@@ -42,9 +42,7 @@ pub async fn get_network_data(
}
}
- let elapsed_time = curr_time
- .duration_since(*prev_net_access_time)
- .as_secs_f64();
+ let elapsed_time = curr_time.duration_since(prev_net_access_time).as_secs_f64();
let rx = ((total_rx - *prev_net_rx) as f64 / elapsed_time) as u64;
let tx = ((total_tx - *prev_net_tx) as f64 / elapsed_time) as u64;
diff --git a/src/app/data_harvester/processes.rs b/src/app/data_harvester/processes.rs
index 0092c768..582d8632 100644
--- a/src/app/data_harvester/processes.rs
+++ b/src/app/data_harvester/processes.rs
@@ -119,13 +119,13 @@ fn linux_cpu_usage<S: core::hash::BuildHasher>(
pid: u32, cpu_usage: f64, cpu_percentage: f64,
prev_pid_stats: &HashMap<String, (f64, Instant), S>,
new_pid_stats: &mut HashMap<String, (f64, Instant), S>, use_current_cpu_total: bool,
- curr_time: &Instant,
+ curr_time: Instant,
) -> std::io::Result<f64> {
// Based heavily on https://stackoverflow.com/a/23376195 and https://stackoverflow.com/a/1424556
let before_proc_val: f64 = if prev_pid_stats.contains_key(&pid.to_string()) {
prev_pid_stats
.get(&pid.to_string())
- .unwrap_or(&(0_f64, *curr_time))
+ .unwrap_or(&(0_f64, curr_time))
.0
} else {
0_f64
@@ -141,7 +141,7 @@ fn linux_cpu_usage<S: core::hash::BuildHasher>(
(after_proc_val - before_proc_val) / cpu_usage * 100_f64
);*/
- new_pid_stats.insert(pid.to_string(), (after_proc_val, *curr_time));
+ new_pid_stats.insert(pid.to_string(), (after_proc_val, curr_time));
if use_current_cpu_total {
Ok((after_proc_val - before_proc_val) / cpu_usage * 100_f64)
} else {
@@ -153,7 +153,7 @@ fn convert_ps<S: core::hash::BuildHasher>(
process: &str, cpu_usage: f64, cpu_percentage: f64,
prev_pid_stats: &HashMap<String, (f64, Instant), S>,
new_pid_stats: &mut HashMap<String, (f64, Instant), S>, use_current_cpu_total: bool,
- curr_time: &Instant,
+ curr_time: Instant,
) -> std::io::Result<ProcessHarvest> {
if process.trim().to_string().is_empty() {
return Ok(ProcessHarvest {
@@ -195,7 +195,7 @@ fn convert_ps<S: core::hash::BuildHasher>(
pub fn get_sorted_processes_list(
sys: &System, prev_idle: &mut f64, prev_non_idle: &mut f64,
prev_pid_stats: &mut HashMap<String, (f64, Instant), RandomState>, use_current_cpu_total: bool,
- mem_total_kb: u64, curr_time: &Instant,
+ mem_total_kb: u64, curr_time: Instant,
) -> crate::utils::error::Result<Vec<ProcessHarvest>> {
let mut process_vector: Vec<ProcessHarvest> = Vec::new();
diff --git a/src/main.rs b/src/main.rs
index 8405ba7c..11b5bcfd 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -116,6 +116,7 @@ fn get_matches() -> clap::ArgMatches<'static> {
.get_matches()
}
+#[allow(deprecated)]
fn main() -> error::Result<()> {
create_logger()?;
let matches = get_matches();