Compare commits

...

2 Commits

Author SHA1 Message Date
Christian Schwarz
0cd4e120da disable flush time measurement 2025-02-05 14:48:49 +01:00
Christian Schwarz
f9528ec980 see if it's the instrument() 2025-02-05 14:16:40 +01:00

View File

@@ -1077,12 +1077,12 @@ 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),
};
// 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! {
@@ -1099,7 +1099,7 @@ impl PageServerHandler {
Ok(())
}
// and log the info! line inside the request span
.instrument(span.clone())
// .instrument(span.clone())
.await?;
}
Ok(())