nik/liana
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bitcoin: looper: avoid large sleeps when bitcoind is syncing

Browse Source 
Sleeping for 30 whole seconds impedes the shutdown check. Sleep only .5s
but still only do poll bitcoind one every 30s when it's syncing.
This commit is contained in:
Antoine Poinsot 2023-08-22 15:41:26 +02:00
parent bdeaf93ec8
commit 0d5041ca4a
No known key found for this signature in database
GPG Key ID: E13FC145CD3F4304
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/bitcoin/poller/looper.rs
View File

@ -306,6 +306,16 @@ fn maybe_initialize_tip(bit: &impl BitcoinInterface, db: &impl DatabaseInterface
}
}
fn sync_poll_interval() -> time::Duration {
// TODO: be smarter, like in revaultd, but more generic too.
#[cfg(not(test))]
{
time::Duration::from_secs(30)
}
#[cfg(test)]
time::Duration::from_secs(0)
}
/// Main event loop. Repeatedly polls the Bitcoin interface until told to stop through the
/// `shutdown` atomic.
pub fn looper(
@ -329,7 +339,15 @@ pub fn looper(
let now = time::Instant::now();
if let Some(last_poll) = last_poll {
if now.duration_since(last_poll) < poll_interval {
let time_since_poll = now.duration_since(last_poll);
let poll_interval = if synced {
poll_interval
} else {
// Until we are synced we poll less often to avoid harassing bitcoind and impeding
// the sync. As a function since it's mocked for the tests.
sync_poll_interval()
};
if time_since_poll < poll_interval {
thread::sleep(time::Duration::from_millis(500));
continue;
}
@ -345,10 +363,6 @@ pub fn looper(
);
synced = sync_progress == 1.0;
if !synced {
// Avoid harassing bitcoind..
// TODO: be smarter, like in revaultd, but more generic too.
#[cfg(not(test))]
thread::sleep(time::Duration::from_secs(30));
continue;
}
}