Drop mutex before calling finder.finish() to allow parallel executions (

#839) * Drop mutex before calling finder.finish() to allow parallel executions * refactor
iotaledger · Dec 16, 2021 · 6d390e5 · 6d390e5
1 parent ae9b806
commit 6d390e5
Showing 1 changed file with 12 additions and 10 deletions.
diff --git a/src/account_manager.rs b/src/account_manager.rs
@@ -419,16 +419,18 @@ impl AccountManager {
         if finder.initial_address_index == 0 {
             self.cached_migration_data.lock().await.remove(&finder.seed_hash);
         }
-        let metadata = finder
-            .finish(
-                self.cached_migration_data
-                    .lock()
-                    .await
-                    .get(&finder.seed_hash)
-                    .map(|c| c.inputs.clone())
-                    .unwrap_or_default(),
-            )
-            .await?;
+        // lock mutex in the closure, so it gets dropped before calling finder.finish(previous_inputs).await to allow
+        // parallel executions
+        let previous_inputs = {
+            self.cached_migration_data
+                .lock()
+                .await
+                .get(&finder.seed_hash)
+                .map(|c| c.inputs.clone())
+                .unwrap_or_default()
+        };
+
+        let metadata = finder.finish(previous_inputs).await?;
         self.cached_migration_data
             .lock()
             .await