From 89838e46bf26347b547f63e330a010adf118a9b9 Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Fri, 7 Feb 2025 02:30:15 +0100 Subject: [PATCH] just not instrumented, validate that again, should be equivalent with f9528ec9801f3c5ee897987b2d8725d2ef819b47 --- pageserver/src/page_service.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/pageserver/src/page_service.rs b/pageserver/src/page_service.rs index e577b4221d..dc0bbb3afb 100644 --- a/pageserver/src/page_service.rs +++ b/pageserver/src/page_service.rs @@ -1076,6 +1076,13 @@ impl PageServerHandler { // what we want to do let flush_fut = pgb_writer.flush(); + // metric for how long flushing takes + let flush_fut = match flushing_timer { + Some(flushing_timer) => { + futures::future::Either::Left(flushing_timer.measure(flush_fut)) + } + None => futures::future::Either::Right(flush_fut), + }; // do it while respecting cancellation let _: () = async move { tokio::select! {