tyler.durden/bottom
1
0
Fork 0
mirror of https://github.com/ClementTsang/bottom.git synced 2025-07-07 05:44:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

change: add byte units to search

Browse Source
This commit is contained in:
ClementTsang 2020-05-02 19:17:24 -04:00
parent 5e874eab77
commit e12c2f5212
2 changed files with 73 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
src/app/query.rs
View File

@ -9,6 +9,8 @@ use crate::{
use std::collections::VecDeque; use std::collections::VecDeque;
const DELIMITER_LIST: [char; 5] = ['=', '>', '<', '(', ')']; const DELIMITER_LIST: [char; 5] = ['=', '>', '<', '(', ')'];
const AND_LIST: [&str; 2] = ["and", "&&"];
const OR_LIST: [&str; 2] = ["or", "||"];
/// I only separated this as otherwise, the states.rs file gets huge... and this should /// I only separated this as otherwise, the states.rs file gets huge... and this should
/// belong in another file anyways, IMO. /// belong in another file anyways, IMO.
@ -47,12 +49,12 @@ impl ProcessQuery for ProcWidgetState {
let mut rhs: Option<Box<Or>> = None; let mut rhs: Option<Box<Or>> = None;
while let Some(queue_top) = query.front() { while let Some(queue_top) = query.front() {
if queue_top.to_lowercase() == "and" { if AND_LIST.contains(&queue_top.to_lowercase().as_str()) {
query.pop_front(); query.pop_front();
rhs = Some(Box::new(process_or(query)?)); rhs = Some(Box::new(process_or(query)?));
if let Some(queue_next) = query.front() { if let Some(queue_next) = query.front() {
if queue_next.to_lowercase() == "and" { if AND_LIST.contains(&queue_next.to_lowercase().as_str()) {
// Must merge LHS and RHS // Must merge LHS and RHS
lhs = Or { lhs = Or {
lhs: Prefix { lhs: Prefix {
@ -80,12 +82,12 @@ impl ProcessQuery for ProcWidgetState {
let mut rhs: Option<Box<Prefix>> = None; let mut rhs: Option<Box<Prefix>> = None;
while let Some(queue_top) = query.front() { while let Some(queue_top) = query.front() {
if queue_top.to_lowercase() == "or" { if OR_LIST.contains(&queue_top.to_lowercase().as_str()) {
query.pop_front(); query.pop_front();
rhs = Some(Box::new(process_prefix(query)?)); rhs = Some(Box::new(process_prefix(query)?));
if let Some(queue_next) = query.front() { if let Some(queue_next) = query.front() {
if queue_next.to_lowercase() == "or" { if OR_LIST.contains(&queue_next.to_lowercase().as_str()) {
// Must merge LHS and RHS // Must merge LHS and RHS
lhs = Prefix { lhs = Prefix {
and: Some(Box::new(And { and: Some(Box::new(And {
@ -213,7 +215,65 @@ impl ProcessQuery for ProcWidgetState {
} }
if let Some(condition) = condition { if let Some(condition) = condition {
if let Some(value) = value { if let Some(read_value) = value {
// Now we want to check one last thing - is there a unit?
// If no unit, assume base.
// Furthermore, base must be PEEKED at initially, and will
// require (likely) prefix_type specific checks
// Lastly, if it *is* a unit, remember to POP!
let mut value = read_value;
match prefix_type {
PrefixType::Rps
| PrefixType::Wps
| PrefixType::TRead
| PrefixType::TWrite => {
if let Some(potential_unit) = query.front() {
match potential_unit.as_str() {
"TB" => {
value *= 1_000_000_000_000.0;
query.pop_front();
}
"TiB" => {
value *= 1_099_511_627_776.0;
query.pop_front();
}
"GB" => {
value *= 1_000_000_000.0;
query.pop_front();
}
"GiB" => {
value *= 1_073_741_824.0;
query.pop_front();
}
"MB" => {
value *= 1_000_000.0;
query.pop_front();
}
"MiB" => {
value *= 1_048_576.0;
query.pop_front();
}
"KB" => {
value *= 1000.0;
query.pop_front();
}
"KiB" => {
value *= 1024.0;
query.pop_front();
}
"B" => {
// Just gotta pop.
query.pop_front();
}
_ => {}
}
}
}
_ => {}
}
return Ok(Prefix { return Ok(Prefix {
and: None, and: None,
regex_prefix: None, regex_prefix: None,

16
src/data_conversion.rs
View File

@ -446,10 +446,10 @@ pub fn convert_process_data(
write_per_sec, write_per_sec,
total_read, total_read,
total_write, total_write,
rps_f64: converted_rps.0, rps_f64: process.read_bytes_per_sec as f64,
wps_f64: converted_wps.0, wps_f64: process.write_bytes_per_sec as f64,
tr_f64: converted_total_read.0, tr_f64: process.total_read_bytes as f64,
tw_f64: converted_total_write.0, tw_f64: process.total_write_bytes as f64,
process_states: process.process_state.to_owned(), process_states: process.process_state.to_owned(),
}); });
} }
@ -481,10 +481,10 @@ pub fn convert_process_data(
write_per_sec, write_per_sec,
total_read, total_read,
total_write, total_write,
rps_f64: converted_rps.0, rps_f64: p.read_per_sec as f64,
wps_f64: converted_wps.0, wps_f64: p.write_per_sec as f64,
tr_f64: converted_total_read.0, tr_f64: p.total_read as f64,
tw_f64: converted_total_write.0, tw_f64: p.total_write as f64,
process_states: p.process_state, process_states: p.process_state,
} }
}) })