rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-07-07 14:10:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "experiment: what if we make Handle !Send so it can't be held across await points"

Browse Source 
This reverts commit b44070d0c7.
This commit is contained in:
Christian Schwarz
2025-01-14 13:32:12 +01:00
parent b44070d0c7
commit b95365b45d
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pageserver/src/tenant/timeline/handle.rs
View File

@@ -173,7 +173,6 @@ pub(crate) struct ShardTimelineId {
pub(crate) struct Handle<T: Types> {
timeline: Arc<T::Timeline>,
inner: tokio::sync::OwnedMutexGuard<HandleInner>,
_dont_hold_across_await_points: std::marker::PhantomData<*const u8>,
}
pub(crate) struct WeakHandle<T: Types> {
timeline: Arc<T::Timeline>,
@@ -401,7 +400,6 @@ impl<T: Types> Cache<T> {
Ok(Handle {
timeline,
inner: handle_locked,
_dont_hold_across_await_points: Default::default(),
})
}
Err(e) => Err(GetError::TenantManager(e)),
@@ -423,7 +421,6 @@ impl<T: Types> WeakHandle<T> {
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<T: Types> Deref for Handle<T> {
}
impl<T: Types> Handle<T> {
pub(crate) fn timeline(&self) -> &T::Timeline {
&self.timeline
}
pub(crate) fn downgrade(&self) -> WeakHandle<T> {
WeakHandle {
timeline: Arc::clone(&self.timeline),