Skip to content

Commit

Permalink
cr
Browse files Browse the repository at this point in the history
  • Loading branch information
Arqu committed Jul 22, 2024
1 parent bcb4b2a commit 851f3c6
Showing 1 changed file with 26 additions and 26 deletions.
52 changes: 26 additions & 26 deletions iroh-metrics/src/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -82,38 +82,38 @@ async fn dump_metrics(
) -> Result<()> {
let core = Core::get().ok_or_else(|| anyhow!("metrics disabled"))?;
let m = core.encode();
if let Err(e) = m {
error!("Failed to encode metrics: {e:#}");
} else {
let m = m.unwrap();
let m = parse_prometheus_metrics(&m)?;
let time_since_start = start.elapsed().as_millis() as f64;

// take the keys from m and sort them
let mut keys: Vec<&String> = m.keys().collect();
keys.sort();

let mut metrics = String::new();
if write_header {
metrics.push_str("time");
match m {
Err(e) => error!("Failed to encode metrics: {e:#}"),
Ok(m) => {
let m = parse_prometheus_metrics(&m)?;
let time_since_start = start.elapsed().as_millis() as f64;

// take the keys from m and sort them
let mut keys: Vec<&String> = m.keys().collect();
keys.sort();

let mut metrics = String::new();
if write_header {
metrics.push_str("time");
for key in keys.iter() {
metrics.push(',');
metrics.push_str(key);
}
metrics.push('\n');
}

metrics.push_str(&format!("{}", time_since_start));
for key in keys.iter() {
let value = m[*key];
let formatted_value = format!("{:.3}", value);
metrics.push(',');
metrics.push_str(key);
metrics.push_str(&formatted_value);
}
metrics.push('\n');
}

metrics.push_str(&format!("{}", time_since_start));
for key in keys.iter() {
let value = m[*key];
let formatted_value = format!("{:.3}", value);
metrics.push(',');
metrics.push_str(&formatted_value);
file.write_all(metrics.as_bytes()).await?;
file.flush().await?;
}
metrics.push('\n');

file.write_all(metrics.as_bytes()).await?;
file.flush().await?;
}
Ok(())
}

0 comments on commit 851f3c6

Please sign in to comment.