diff --git a/crates/api-grub/src/monitoring.rs b/crates/api-grub/src/monitoring.rs index 063e445..7ec406c 100644 --- a/crates/api-grub/src/monitoring.rs +++ b/crates/api-grub/src/monitoring.rs @@ -61,10 +61,6 @@ pub async fn get_metrics_from_monitoring(duration: usize, delay: usize) -> anyho warn!("Session dropped, creating new ..."); break 'inner; } - // if let Err(_) = a.get_measure_info(vec.clone()).await { - // warn!("Session dropped, creating new ..."); - // break 'inner; - // } tokio::time::sleep(tokio::time::Duration::from_secs(delay as u64)).await } } diff --git a/crates/integr-structs/src/api.rs b/crates/integr-structs/src/api.rs index 02f1170..e7984f5 100644 --- a/crates/integr-structs/src/api.rs +++ b/crates/integr-structs/src/api.rs @@ -376,7 +376,7 @@ pub mod enode_monitoring { impl Default for Query { fn default() -> Self { Self { - id : vec!["/measures/device$18".to_owned()], + id : vec!["/measures/device$18".to_owned(), "/measures/device$19".to_owned()], data : Data::default(), post_query : "links".to_owned(), enable_actions : false, @@ -476,14 +476,9 @@ pub mod enode_monitoring { pub fn get_chunk_size(total_measures: usize) -> usize { match total_measures { - 0..=144 => total_measures, - 145..=288 => total_measures / 4, - 289..=432 => total_measures / 5, - 433..=576 => total_measures / 6, - 577..=720 => total_measures / 7, - 721..=864 => total_measures / 8, - 865..=1008 => total_measures / 9, - _ => total_measures / 10, + 0..=432 => total_measures, + 433..=1008 => total_measures / 2, + _ => total_measures / 4, } }