From b95365b45d4778e5d85a2eda3d6e1509558a7a3c Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Tue, 14 Jan 2025 13:32:12 +0100 Subject: [PATCH] Revert "experiment: what if we make Handle !Send so it can't be held across await points" This reverts commit b44070d0c78552c75dcd119e5599ad54a08c8468. --- pageserver/src/tenant/timeline/handle.rs | 6 ------ 1 file changed, 6 deletions(-) diff --git a/pageserver/src/tenant/timeline/handle.rs b/pageserver/src/tenant/timeline/handle.rs index 278bbdb863..7ef237734f 100644 --- a/pageserver/src/tenant/timeline/handle.rs +++ b/pageserver/src/tenant/timeline/handle.rs @@ -173,7 +173,6 @@ pub(crate) struct ShardTimelineId { pub(crate) struct Handle { timeline: Arc, inner: tokio::sync::OwnedMutexGuard, - _dont_hold_across_await_points: std::marker::PhantomData<*const u8>, } pub(crate) struct WeakHandle { timeline: Arc, @@ -401,7 +400,6 @@ impl Cache { Ok(Handle { timeline, inner: handle_locked, - _dont_hold_across_await_points: Default::default(), }) } Err(e) => Err(GetError::TenantManager(e)), @@ -423,7 +421,6 @@ impl WeakHandle { HandleInner::KeepingTimelineGateOpen { .. } => Ok(Handle { timeline: Arc::clone(&self.timeline), inner: lock_guard, - _dont_hold_across_await_points: Default::default(), }), HandleInner::ShutDown => Err(HandleUpgradeError::ShutDown), } @@ -442,9 +439,6 @@ impl Deref for Handle { } impl Handle { - pub(crate) fn timeline(&self) -> &T::Timeline { - &self.timeline - } pub(crate) fn downgrade(&self) -> WeakHandle { WeakHandle { timeline: Arc::clone(&self.timeline),