We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 979db7d commit d287c69Copy full SHA for d287c69
src/conn/pool/waitlist.rs
@@ -57,16 +57,12 @@ impl Waitlist {
57
}
58
59
60
- /// Returns `true` if removed.
61
- pub(crate) fn remove(&mut self, id: QueueId) -> bool {
62
- let is_removed = self.queue.remove(&id).is_some();
63
- if is_removed {
+ pub(crate) fn remove(&mut self, id: QueueId) {
+ if self.queue.remove(&id).is_some() {
64
self.metrics
65
.active_wait_requests
66
.fetch_sub(1, atomic::Ordering::Relaxed);
67
68
-
69
- is_removed
70
71
72
pub(crate) fn peek_id(&mut self) -> Option<QueueId> {
0 commit comments