Remove unnecessary mutex lock and drop in pipeline serialization (#1744)

eclipse-zenoh · Jan 29, 2025 · 6f7c089 · 6f7c089
1 parent 9ba08eb
commit 6f7c089
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/io/zenoh-transport/src/common/pipeline.rs b/io/zenoh-transport/src/common/pipeline.rs
@@ -276,7 +276,6 @@ impl StageIn {
                                 break batch;
                             }
                             None => {
-                                drop(c_guard);
                                 // Wait for an available batch until deadline
                                 if !deadline.wait(&self.s_ref)? {
                                     // Still no available batch.
@@ -288,7 +287,6 @@ impl StageIn {
                                     );
                                     return Ok(false);
                                 }
-                                c_guard = self.mutex.current();
                             }
                         },
                     }
@@ -441,11 +439,9 @@ impl StageIn {
                                 break batch;
                             }
                             None => {
-                                drop(c_guard);
                                 if !self.s_ref.wait() {
                                     return false;
                                 }
-                                c_guard = self.mutex.current();
                             }
                         },
                     }