diff --git a/pageserver/client/src/page_service.rs b/pageserver/client/src/page_service.rs index 38f137852d..5d3783bed0 100644 --- a/pageserver/client/src/page_service.rs +++ b/pageserver/client/src/page_service.rs @@ -1,4 +1,3 @@ -use std::pin::Pin; use futures::{ stream::{SplitSink, SplitStream}, diff --git a/pageserver/src/tenant/storage_layer.rs b/pageserver/src/tenant/storage_layer.rs index add35b0ad5..77bef5976e 100644 --- a/pageserver/src/tenant/storage_layer.rs +++ b/pageserver/src/tenant/storage_layer.rs @@ -249,7 +249,7 @@ impl IoConcurrency { trace!(task_id, "spawning"); tokio::spawn(async move { trace!("start"); - scopeguard::defer!({ trace!("end") }); + scopeguard::defer!{ trace!("end") }; type IosRx = tokio::sync::mpsc::UnboundedReceiver; type BarrierReqRx = tokio::sync::mpsc::UnboundedReceiver>; @@ -426,7 +426,7 @@ impl IoConcurrency { let io_num = IO_NUM.fetch_add(1, std::sync::atomic::Ordering::Relaxed); let fut = async move { trace!("start"); - scopeguard::defer!({ trace!("end") }); + scopeguard::defer!(trace!("end")); fut.await } .instrument(tracing::trace_span!("spawned_io", %io_num)); diff --git a/pageserver/src/virtual_file/io_engine.rs b/pageserver/src/virtual_file/io_engine.rs index 50c400d20f..7a77817b18 100644 --- a/pageserver/src/virtual_file/io_engine.rs +++ b/pageserver/src/virtual_file/io_engine.rs @@ -15,7 +15,6 @@ pub(super) mod tokio_epoll_uring_ext; use tokio_epoll_uring::IoBuf; use tracing::Instrument; -use crate::log_if_slow; pub(crate) use super::api::IoEngineKind; #[derive(Clone, Copy)] @@ -112,7 +111,6 @@ pub(crate) fn get() -> IoEngine { use std::{ os::unix::prelude::FileExt, sync::atomic::{AtomicU8, Ordering}, - time::Duration, }; use super::{