f Drop lock before notify_one()

Author: tnull

src/event.rs

@@ -151,10 +151,11 @@ impl<K: KVStorePersister> LdkLiteEventQueue<K> {
 		Self { queue, notifier, persister }
 	}
 	pub(crate) fn add_event(&self, event: LdkLiteEvent) -> Result<(), Error> {
-		let mut locked_queue = self.queue.lock().unwrap();
-		locked_queue.0.push_back(event);
-
-		self.persister.persist(EVENTS_PERSISTENCE_KEY, &*locked_queue)?;
+		{
+			let mut locked_queue = self.queue.lock().unwrap();
+			locked_queue.0.push_back(event);
+			self.persister.persist(EVENTS_PERSISTENCE_KEY, &*locked_queue)?;
+		}
 
 		self.notifier.notify_one();
 		Ok(())
@@ -169,9 +170,11 @@ impl<K: KVStorePersister> LdkLiteEventQueue<K> {
 	}
 
 	pub(crate) fn event_handled(&self) -> Result<(), Error> {
-		let mut locked_queue = self.queue.lock().unwrap();
-		locked_queue.0.pop_front();
-		self.persister.persist(EVENTS_PERSISTENCE_KEY, &*locked_queue)?;
+		{
+			let mut locked_queue = self.queue.lock().unwrap();
+			locked_queue.0.pop_front();
+			self.persister.persist(EVENTS_PERSISTENCE_KEY, &*locked_queue)?;
+		}
 		self.notifier.notify_one();
 		Ok(())
 	}