From 468a556ebb505073de4a5676cbbd3fca1ab0853f Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Wed, 6 Dec 2023 17:48:50 +0000 Subject: [PATCH] more spans --- pageserver/src/tenant/block_io.rs | 1 + pageserver/src/tenant/layer_map.rs | 1 + pageserver/src/tenant/storage_layer/layer.rs | 1 + pageserver/src/tenant/timeline.rs | 2 ++ 4 files changed, 5 insertions(+) diff --git a/pageserver/src/tenant/block_io.rs b/pageserver/src/tenant/block_io.rs index 0617017528..e2e027e564 100644 --- a/pageserver/src/tenant/block_io.rs +++ b/pageserver/src/tenant/block_io.rs @@ -141,6 +141,7 @@ impl<'a> BlockCursor<'a> { /// access to the contents of the page. (For the page cache, the /// lease object represents a lock on the buffer.) #[inline(always)] + #[tracing::instrument(skip_all, level = tracing::Level::DEBUG)] pub async fn read_blk( &self, blknum: u32, diff --git a/pageserver/src/tenant/layer_map.rs b/pageserver/src/tenant/layer_map.rs index 9b6225501f..b33bb62ff5 100644 --- a/pageserver/src/tenant/layer_map.rs +++ b/pageserver/src/tenant/layer_map.rs @@ -181,6 +181,7 @@ impl LayerMap { /// NOTE: This only searches the 'historic' layers, *not* the /// 'open' and 'frozen' layers! /// + #[tracing::instrument(level = tracing::Level::DEBUG, skip_all)] pub fn search(&self, key: Key, end_lsn: Lsn) -> Option { let version = self.historic.get().unwrap().get_version(end_lsn.0 - 1)?; let latest_delta = version.delta_coverage.query(key.to_i128()); diff --git a/pageserver/src/tenant/storage_layer/layer.rs b/pageserver/src/tenant/storage_layer/layer.rs index 112128ead8..690183a3ed 100644 --- a/pageserver/src/tenant/storage_layer/layer.rs +++ b/pageserver/src/tenant/storage_layer/layer.rs @@ -234,6 +234,7 @@ impl Layer { /// # Cancellation-Safety /// /// This method is cancellation-safe. + #[tracing::instrument(level = tracing::Level::DEBUG, skip_all)] pub(crate) async fn get_value_reconstruct_data( &self, key: Key, diff --git a/pageserver/src/tenant/timeline.rs b/pageserver/src/tenant/timeline.rs index 81dbc04793..2ae5465308 100644 --- a/pageserver/src/tenant/timeline.rs +++ b/pageserver/src/tenant/timeline.rs @@ -498,6 +498,7 @@ impl Timeline { /// # Cancel-Safety /// /// This method is cancellation-safe. + #[instrument(skip_all, fields(%key, %lsn), level = tracing::Level::DEBUG)] pub async fn get( &self, key: Key, @@ -2198,6 +2199,7 @@ impl Timeline { /// # Cancel-Safety /// /// This method is cancellation-safe. + #[instrument(level = tracing::Level::DEBUG, skip_all)] async fn get_reconstruct_data( &self, key: Key,