fix?: use block_in_place for block_on

fedimint · Jan 18, 2024 · 28b0361 · 28b0361
1 parent 5a4df7a
commit 28b0361
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/fedimint-server/src/atomic_broadcast/backup.rs b/fedimint-server/src/atomic_broadcast/backup.rs
@@ -60,15 +60,17 @@ impl std::io::Write for UnitSaver {
     }
 
     fn flush(&mut self) -> std::io::Result<()> {
-        futures::executor::block_on(async {
-            let mut dbtx = self.db.begin_transaction().await;
+        tokio::task::block_in_place(|| {
+            futures::executor::block_on(async {
+                let mut dbtx = self.db.begin_transaction().await;
 
-            dbtx.insert_new_entry(&AlephUnitsKey(self.units_index), &self.buffer)
-                .await;
+                dbtx.insert_new_entry(&AlephUnitsKey(self.units_index), &self.buffer)
+                    .await;
 
-            dbtx.commit_tx_result()
-                .await
-                .expect("This is the only place where we write to this key");
+                dbtx.commit_tx_result()
+                    .await
+                    .expect("This is the only place where we write to this key");
+            })
         });
 
         self.buffer.clear();