asonix/pict-rs
1
1
Fork 1
Code Issues 2 Pull requests 3 Actions Projects Releases 133 Wiki Activity

Remove 'armed' from NotificationEntryInner by only creating them when needed
All checks were successful
/ check (aarch64-unknown-linux-musl) (push) Successful in 1m53s
Details
/ check (armv7-unknown-linux-musleabihf) (push) Successful in 1m54s
Details
/ check (x86_64-unknown-linux-musl) (push) Successful in 1m49s
Details
/ clippy (push) Successful in 1m21s
Details
/ tests (push) Successful in 1m50s
Details

Browse source
This commit is contained in:
asonix 2024-04-03 13:22:34 -05:00
parent cef9a68307
commit d97cfe2a64
1 changed files with 27 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

56
src/repo/notification_map.rs
View file

@ -1,10 +1,7 @@
use dashmap::DashMap;
use dashmap::{mapref::entry::Entry, DashMap};
use std::{
future::Future,
sync::{
atomic::{AtomicBool, Ordering},
Arc, Weak,
},
sync::{Arc, Weak},
time::Duration,
};
use tokio::sync::Notify;
@ -26,7 +23,6 @@ struct NotificationEntryInner {
key: Arc<str>,
map: Map,
notify: Notify,
armed: AtomicBool,
}
impl NotificationMap {
@ -37,30 +33,34 @@ impl NotificationMap {
}
pub(super) fn register_interest(&self, key: Arc<str>) -> NotificationEntry {
let new_entry = Arc::new(NotificationEntryInner {
key: key.clone(),
map: self.map.clone(),
notify: crate::sync::bare_notify(),
armed: AtomicBool::new(false),
});
match self.map.entry(key.clone()) {
Entry::Occupied(mut occupied) => {
if let Some(inner) = occupied.get().upgrade() {
NotificationEntry { inner }
} else {
let inner = Arc::new(NotificationEntryInner {
key,
map: self.map.clone(),
notify: crate::sync::bare_notify(),
});
let mut key_entry = self
.map
.entry(key)
.or_insert_with(|| Arc::downgrade(&new_entry));
occupied.insert(Arc::downgrade(&inner));
let upgraded_entry = key_entry.value().upgrade();
NotificationEntry { inner }
}
}
Entry::Vacant(vacant) => {
let inner = Arc::new(NotificationEntryInner {
key,
map: self.map.clone(),
notify: crate::sync::bare_notify(),
});
let inner = if let Some(entry) = upgraded_entry {
entry
} else {
*key_entry.value_mut() = Arc::downgrade(&new_entry);
new_entry
};
vacant.insert(Arc::downgrade(&inner));
inner.armed.store(true, Ordering::Release);
NotificationEntry { inner }
NotificationEntry { inner }
}
}
}
pub(super) fn notify(&self, key: &str) {
@ -87,8 +87,6 @@ impl Default for NotificationMap {
impl Drop for NotificationEntryInner {
fn drop(&mut self) {
if self.armed.load(Ordering::Acquire) {
self.map.remove(&self.key);
}
self.map.remove(&self.key);
}
}