Skip to content

Commit 09fb4ac

Browse files
committed
Add ommitted block_in_place
1 parent 873fdc5 commit 09fb4ac

File tree

1 file changed

+18
-15
lines changed

1 file changed

+18
-15
lines changed

src/lib.rs

Lines changed: 18 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -307,22 +307,25 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
307307
// Block to ensure we update our fee rate cache once on startup
308308
let wallet = Arc::clone(&self.wallet);
309309
let sync_logger = Arc::clone(&self.logger);
310-
runtime.block_on(async move {
311-
let now = Instant::now();
312-
match wallet.update_fee_estimates().await {
313-
Ok(()) => {
314-
log_info!(
315-
sync_logger,
316-
"Initial fee rate cache update finished in {}ms.",
317-
now.elapsed().as_millis()
318-
);
319-
Ok(())
320-
}
321-
Err(e) => {
322-
log_error!(sync_logger, "Initial fee rate cache update failed: {}", e,);
323-
Err(e)
310+
let runtime_ref = &runtime;
311+
tokio::task::block_in_place(move || {
312+
runtime_ref.block_on(async move {
313+
let now = Instant::now();
314+
match wallet.update_fee_estimates().await {
315+
Ok(()) => {
316+
log_info!(
317+
sync_logger,
318+
"Initial fee rate cache update finished in {}ms.",
319+
now.elapsed().as_millis()
320+
);
321+
Ok(())
322+
}
323+
Err(e) => {
324+
log_error!(sync_logger, "Initial fee rate cache update failed: {}", e,);
325+
Err(e)
326+
}
324327
}
325-
}
328+
})
326329
})?;
327330

328331
// Setup wallet sync

0 commit comments

Comments
 (0)