Mirror/brk
1
0
Fork 0
mirror of https://github.com/bitcoinresearchkit/brk.git synced 2026-05-19 14:24:47 -07:00
Code Issues Packages Projects Releases Wiki Activity

mempool: fix

Browse Source
This commit is contained in:
nym21
2026-05-09 13:36:06 +02:00
parent e62b0ac2a5
commit c52a076bfc
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
crates/brk_mempool/src/lib.rs
View File

@@ -24,7 +24,7 @@ use std::{
panic::{AssertUnwindSafe, catch_unwind}, panic::{AssertUnwindSafe, catch_unwind},
sync::Arc, sync::Arc,
thread, thread,
time::Duration, time::{Duration, Instant},
}; };
use brk_error::Result; use brk_error::Result;
@@ -297,11 +297,17 @@ impl Mempool {
/// confirmed-parent prevouts (typically backed by an indexer). /// confirmed-parent prevouts (typically backed by an indexer).
/// Each cycle is wrapped in `catch_unwind` so a panic doesn't /// Each cycle is wrapped in `catch_unwind` so a panic doesn't
/// freeze the snapshot; `parking_lot` locks don't poison. /// freeze the snapshot; `parking_lot` locks don't poison.
///
/// Sleep is `PERIOD - work_duration`, so a 700ms cycle followed by
/// a 200ms cycle still ticks roughly every `PERIOD`. When work
/// overruns `PERIOD`, the next cycle starts immediately.
pub fn start_with<F>(&self, resolver: F) pub fn start_with<F>(&self, resolver: F)
where where
F: Fn(&Txid, Vout) -> Option<TxOut>, F: Fn(&Txid, Vout) -> Option<TxOut>,
{ {
const PERIOD: Duration = Duration::from_secs(1);
loop { loop {
let started = Instant::now();
let outcome = catch_unwind(AssertUnwindSafe(|| { let outcome = catch_unwind(AssertUnwindSafe(|| {
if let Err(e) = self.update_with(&resolver) { if let Err(e) = self.update_with(&resolver) {
error!("update failed: {e}"); error!("update failed: {e}");
@@ -310,7 +316,9 @@ impl Mempool {
if let Err(payload) = outcome { if let Err(payload) = outcome {
error!("mempool update panicked, continuing loop: {}", panic_msg(&payload)); error!("mempool update panicked, continuing loop: {}", panic_msg(&payload));
} }
thread::sleep(Duration::from_secs(1)); if let Some(rest) = PERIOD.checked_sub(started.elapsed()) {
thread::sleep(rest);
}
} }
} }