diff options
author | Clement Tsang <34804052+ClementTsang@users.noreply.github.com> | 2020-04-01 20:31:43 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-04-01 20:31:43 -0400 |
commit | 0b1d84fdf590bf8cacc5d0f94b67f63daa9b768a (patch) | |
tree | d2ff261148f9ef21f2e860af43f795df911c5c79 /src/data_conversion.rs | |
parent | c1a19f960fc1b348dd4465fe9a4d698bed229c77 (diff) |
Add modularity to widget placement and inclusion (#95)
Diffstat (limited to 'src/data_conversion.rs')
-rw-r--r-- | src/data_conversion.rs | 54 |
1 files changed, 25 insertions, 29 deletions
diff --git a/src/data_conversion.rs b/src/data_conversion.rs index 93473a2a..8feca30a 100644 --- a/src/data_conversion.rs +++ b/src/data_conversion.rs @@ -103,7 +103,7 @@ pub fn convert_disk_row(current_data: &data_farmer::DataCollection) -> Vec<Vec<S } pub fn convert_cpu_data_points( - current_data: &data_farmer::DataCollection, display_time: u64, is_frozen: bool, + current_data: &data_farmer::DataCollection, is_frozen: bool, ) -> Vec<ConvertedCpuData> { let mut cpu_data_vector: Vec<ConvertedCpuData> = Vec::new(); let current_time = if is_frozen { @@ -117,8 +117,7 @@ pub fn convert_cpu_data_points( }; for (time, data) in ¤t_data.timed_data_vec { - let time_from_start: f64 = - (display_time as f64 - current_time.duration_since(*time).as_millis() as f64).floor(); + let time_from_start: f64 = (current_time.duration_since(*time).as_millis() as f64).floor(); for (itx, cpu) in data.cpu_data.iter().enumerate() { // Check if the vector exists yet @@ -133,15 +132,15 @@ pub fn convert_cpu_data_points( //Insert joiner points for &(joiner_offset, joiner_val) in &cpu.1 { - let offset_time = time_from_start - joiner_offset as f64; + let offset_time = time_from_start + joiner_offset as f64; cpu_data_vector[itx_offset] .cpu_data - .push((offset_time, joiner_val)); + .push((-offset_time, joiner_val)); } cpu_data_vector[itx_offset] .cpu_data - .push((time_from_start, cpu.0)); + .push((-time_from_start, cpu.0)); } if *time == current_time { @@ -153,7 +152,7 @@ pub fn convert_cpu_data_points( } pub fn convert_mem_data_points( - current_data: &data_farmer::DataCollection, display_time: u64, is_frozen: bool, + current_data: &data_farmer::DataCollection, is_frozen: bool, ) -> Vec<Point> { let mut result: Vec<Point> = Vec::new(); let current_time = if is_frozen { @@ -167,16 +166,15 @@ pub fn convert_mem_data_points( }; for (time, data) in ¤t_data.timed_data_vec { - let time_from_start: f64 = - (display_time as f64 - current_time.duration_since(*time).as_millis() as f64).floor(); + let time_from_start: f64 = (current_time.duration_since(*time).as_millis() as f64).floor(); //Insert joiner points for &(joiner_offset, joiner_val) in &data.mem_data.1 { - let offset_time = time_from_start - joiner_offset as f64; - result.push((offset_time, joiner_val)); + let offset_time = time_from_start + joiner_offset as f64; + result.push((-offset_time, joiner_val)); } - result.push((time_from_start, data.mem_data.0)); + result.push((-time_from_start, data.mem_data.0)); if *time == current_time { break; @@ -187,7 +185,7 @@ pub fn convert_mem_data_points( } pub fn convert_swap_data_points( - current_data: &data_farmer::DataCollection, display_time: u64, is_frozen: bool, + current_data: &data_farmer::DataCollection, is_frozen: bool, ) -> Vec<Point> { let mut result: Vec<Point> = Vec::new(); let current_time = if is_frozen { @@ -201,16 +199,15 @@ pub fn convert_swap_data_points( }; for (time, data) in ¤t_data.timed_data_vec { - let time_from_start: f64 = - (display_time as f64 - current_time.duration_since(*time).as_millis() as f64).floor(); + let time_from_start: f64 = (current_time.duration_since(*time).as_millis() as f64).floor(); //Insert joiner points for &(joiner_offset, joiner_val) in &data.swap_data.1 { - let offset_time = time_from_start - joiner_offset as f64; - result.push((offset_time, joiner_val)); + let offset_time = time_from_start + joiner_offset as f64; + result.push((-offset_time, joiner_val)); } - result.push((time_from_start, data.swap_data.0)); + result.push((-time_from_start, data.swap_data.0)); if *time == current_time { break; @@ -257,7 +254,7 @@ pub fn convert_mem_labels(current_data: &data_farmer::DataCollection) -> (String } pub fn get_rx_tx_data_points( - current_data: &data_farmer::DataCollection, display_time: u64, is_frozen: bool, + current_data: &data_farmer::DataCollection, is_frozen: bool, ) -> (Vec<Point>, Vec<Point>) { let mut rx: Vec<Point> = Vec::new(); let mut tx: Vec<Point> = Vec::new(); @@ -274,22 +271,21 @@ pub fn get_rx_tx_data_points( // TODO: [REFACTOR] Can we use collect on this, CPU, and MEM? for (time, data) in ¤t_data.timed_data_vec { - let time_from_start: f64 = - (display_time as f64 - current_time.duration_since(*time).as_millis() as f64).floor(); + let time_from_start: f64 = (current_time.duration_since(*time).as_millis() as f64).floor(); //Insert joiner points for &(joiner_offset, joiner_val) in &data.rx_data.1 { - let offset_time = time_from_start - joiner_offset as f64; - rx.push((offset_time, joiner_val)); + let offset_time = time_from_start + joiner_offset as f64; + rx.push((-offset_time, joiner_val)); } for &(joiner_offset, joiner_val) in &data.tx_data.1 { - let offset_time = time_from_start - joiner_offset as f64; - tx.push((offset_time, joiner_val)); + let offset_time = time_from_start + joiner_offset as f64; + tx.push((-offset_time, joiner_val)); } - rx.push((time_from_start, data.rx_data.0)); - tx.push((time_from_start, data.tx_data.0)); + rx.push((-time_from_start, data.rx_data.0)); + tx.push((-time_from_start, data.tx_data.0)); if *time == current_time { break; @@ -300,9 +296,9 @@ pub fn get_rx_tx_data_points( } pub fn convert_network_data_points( - current_data: &data_farmer::DataCollection, display_time: u64, is_frozen: bool, + current_data: &data_farmer::DataCollection, is_frozen: bool, ) -> ConvertedNetworkData { - let (rx, tx) = get_rx_tx_data_points(current_data, display_time, is_frozen); + let (rx, tx) = get_rx_tx_data_points(current_data, is_frozen); let total_rx_converted_result: (f64, String); let rx_converted_result: (f64, String); |