From 2160224b7ef21e3319a93d057165712aabe8cbe2 Mon Sep 17 00:00:00 2001 From: main Date: Tue, 31 Mar 2026 13:07:12 -0400 Subject: Exterminate inert consult slop --- crates/phone-opus/src/mcp/telemetry.rs | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) (limited to 'crates/phone-opus/src/mcp/telemetry.rs') diff --git a/crates/phone-opus/src/mcp/telemetry.rs b/crates/phone-opus/src/mcp/telemetry.rs index 8df0009..5b91d78 100644 --- a/crates/phone-opus/src/mcp/telemetry.rs +++ b/crates/phone-opus/src/mcp/telemetry.rs @@ -84,11 +84,7 @@ impl ServerTelemetry { self.totals.success_count += 1; let entry = self.methods.entry(operation.to_owned()).or_default(); entry.success_count += 1; - entry.total_latency_ms = entry - .total_latency_ms - .saturating_add(u128::from(latency_ms)); - entry.max_latency_ms = entry.max_latency_ms.max(latency_ms); - entry.last_latency_ms = Some(latency_ms); + record_latency_sample(entry, latency_ms); entry.last_error = None; } @@ -123,11 +119,7 @@ impl ServerTelemetry { } else { entry.response_error_count += 1; } - entry.total_latency_ms = entry - .total_latency_ms - .saturating_add(u128::from(latency_ms)); - entry.max_latency_ms = entry.max_latency_ms.max(latency_ms); - entry.last_latency_ms = Some(latency_ms); + record_latency_sample(entry, latency_ms); entry.last_error = Some(fault.message().to_owned()); } @@ -211,6 +203,14 @@ impl ServerTelemetry { } } +fn record_latency_sample(stats: &mut MethodStats, latency_ms: u64) { + stats.total_latency_ms = stats + .total_latency_ms + .saturating_add(u128::from(latency_ms)); + stats.max_latency_ms = stats.max_latency_ms.max(latency_ms); + stats.last_latency_ms = Some(latency_ms); +} + fn average_latency_ms(stats: &MethodStats) -> u64 { if stats.request_count == 0 { return 0; -- cgit v1.2.3