From c766021d5fae623f66698cfd67420f978ba682ed Mon Sep 17 00:00:00 2001 From: Conrad Ludgate Date: Mon, 29 Jul 2024 16:12:44 +0100 Subject: [PATCH] fix fair queue --- pageserver/src/tenant/throttle.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pageserver/src/tenant/throttle.rs b/pageserver/src/tenant/throttle.rs index ce4fa49ac8..220458757d 100644 --- a/pageserver/src/tenant/throttle.rs +++ b/pageserver/src/tenant/throttle.rs @@ -112,7 +112,11 @@ where bucket_width, }, state: Mutex::new(LeakyBucketState::new(end)), - queue: fair.then(Notify::new), + queue: fair.then(|| { + let queue = Notify::new(); + queue.notify_one(); + queue + }), }; Inner {