We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 26b1641 commit 7a7df60Copy full SHA for 7a7df60
1 file changed
crates/batcher/src/lib.rs
@@ -1313,8 +1313,13 @@ impl Batcher {
1313
let _building_batch_mutex = self.building_batch_mutex.lock().await;
1314
1315
info!("Batch building: waiting until all the ongoing messages finish");
1316
+
1317
// acquire all the user locks to make sure all the ongoing message have been processed
- for user_mutex in self.user_proof_processing_mutexes.lock().await.values() {
1318
+ let mutexes: Vec<Arc<Mutex<()>>> = {
1319
+ let user_proofs_lock = self.user_proof_processing_mutexes.lock().await;
1320
+ user_proofs_lock.values().cloned().collect()
1321
+ };
1322
+ for user_mutex in mutexes {
1323
let _ = user_mutex.lock().await;
1324
}
1325
info!("Batch building: all user locks acquired, proceeding to build batch");
0 commit comments