From 89022245a0f7ce7f2d0eb51733288c4ce2e999f2 Mon Sep 17 00:00:00 2001 From: Elias Rohrer Date: Tue, 22 Aug 2023 14:23:08 +0200 Subject: [PATCH] f Reuse `dest_file_path` as lock key --- lightning-persister/src/fs_store.rs | 32 ++++++++++++++--------------- 1 file changed, 15 insertions(+), 17 deletions(-) diff --git a/lightning-persister/src/fs_store.rs b/lightning-persister/src/fs_store.rs index 4ef8fc598..76ec93a9a 100644 --- a/lightning-persister/src/fs_store.rs +++ b/lightning-persister/src/fs_store.rs @@ -35,7 +35,7 @@ fn path_to_windows_str>(path: T) -> Vec { pub struct FilesystemStore { data_dir: PathBuf, tmp_file_counter: AtomicUsize, - locks: Mutex>>>, + locks: Mutex>>>, } impl FilesystemStore { @@ -71,13 +71,13 @@ impl KVStore for FilesystemStore { return Err(std::io::Error::new(std::io::ErrorKind::Other, msg)); } - let mut outer_lock = self.locks.lock().unwrap(); - let lock_key = (namespace.to_string(), key.to_string()); - let inner_lock_ref = Arc::clone(&outer_lock.entry(lock_key).or_default()); - let mut dest_file_path = self.data_dir.clone(); dest_file_path.push(namespace); dest_file_path.push(key); + + let mut outer_lock = self.locks.lock().unwrap(); + let inner_lock_ref = Arc::clone(&outer_lock.entry(dest_file_path.clone()).or_default()); + FilesystemReader::new(dest_file_path, inner_lock_ref) } @@ -97,15 +97,14 @@ impl KVStore for FilesystemStore { return Err(std::io::Error::new(std::io::ErrorKind::Other, msg)); } - let mut outer_lock = self.locks.lock().unwrap(); - let lock_key = (namespace.to_string(), key.to_string()); - let inner_lock_ref = Arc::clone(&outer_lock.entry(lock_key).or_default()); - let _guard = inner_lock_ref.write().unwrap(); - let mut dest_file_path = self.data_dir.clone(); dest_file_path.push(namespace); dest_file_path.push(key); + let mut outer_lock = self.locks.lock().unwrap(); + let inner_lock_ref = Arc::clone(&outer_lock.entry(dest_file_path.clone()).or_default()); + let _guard = inner_lock_ref.write().unwrap(); + let parent_directory = dest_file_path .parent() .ok_or_else(|| { @@ -183,16 +182,15 @@ impl KVStore for FilesystemStore { return Err(std::io::Error::new(std::io::ErrorKind::Other, msg)); } - let mut outer_lock = self.locks.lock().unwrap(); - let lock_key = (namespace.to_string(), key.to_string()); - let inner_lock_ref = Arc::clone(&outer_lock.entry(lock_key.clone()).or_default()); - - let _guard = inner_lock_ref.write().unwrap(); - let mut dest_file_path = self.data_dir.clone(); dest_file_path.push(namespace); dest_file_path.push(key); + let mut outer_lock = self.locks.lock().unwrap(); + let inner_lock_ref = Arc::clone(&outer_lock.entry(dest_file_path.clone()).or_default()); + + let _guard = inner_lock_ref.write().unwrap(); + if !dest_file_path.is_file() { return Ok(()); } @@ -230,7 +228,7 @@ impl KVStore for FilesystemStore { // Note that this by itself is still leaky as lock entries will remain when more Readers/Writers are // around, but is preferable to doing nothing *or* something overly complex such as // implementing yet another RAII structure just for this pupose. - outer_lock.remove(&lock_key); + outer_lock.remove(&dest_file_path); } // Garbage collect all lock entries that are not referenced anymore. -- 2.39.5