Fix message cleaner & saver potential deadlock (#901)

iggy-rs · Apr 14, 2024 · ea50337 · ea50337
1 parent 6e7cabe
commit ea50337
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/server/Cargo.toml b/server/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "server"
-version = "0.2.18"
+version = "0.2.19"
 edition = "2021"
 build = "src/build.rs"
 

diff --git a/server/src/channels/commands/clean_messages.rs b/server/src/channels/commands/clean_messages.rs
@@ -65,7 +65,7 @@ impl MessagesCleaner {
 impl ServerCommand<CleanMessagesCommand> for CleanMessagesExecutor {
     async fn execute(&mut self, system: &SharedSystem, _command: CleanMessagesCommand) {
         let now = IggyTimestamp::now().to_micros();
-        let system = system.write();
+        let system = system.read();
         let streams = system.get_streams();
         for stream in streams {
             let topics = stream.get_topics();