Mirror/brk
1
0
Fork 0
mirror of https://github.com/bitcoinresearchkit/brk.git synced 2026-05-11 22:51:16 -07:00
Code Issues Packages Projects Releases Wiki Activity

computer: perf

Browse Source
This commit is contained in:
nym21
2025-07-12 16:17:29 +02:00
parent b24a29895f
commit 1e71e2d68f
1 changed files with 23 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
crates/brk_computer/src/vecs/stateful/utxo_cohorts.rs
View File

@@ -1340,33 +1340,36 @@ impl Vecs {
let prev_timestamp = chain_state.last().unwrap().timestamp; let prev_timestamp = chain_state.last().unwrap().timestamp;
self.age_range let mut vecs = self
.age_range
.as_mut_vec() .as_mut_vec()
.into_iter() .into_iter()
.map(|(filter, v)| (filter, &mut v.state)) .map(|(filter, v)| (filter, &mut v.state))
.for_each(|(filter, state)| { .collect::<Vec<_>>();
let _ = chain_state
.iter()
.try_for_each(|block_state| -> ControlFlow<()> {
let prev_days_old =
prev_timestamp.difference_in_days_between(block_state.timestamp);
let days_old = timestamp.difference_in_days_between(block_state.timestamp);
if prev_days_old == days_old { let _ = chain_state
return ControlFlow::Continue(()); .iter()
} .try_for_each(|block_state| -> ControlFlow<()> {
let prev_days_old =
prev_timestamp.difference_in_days_between(block_state.timestamp);
let days_old = timestamp.difference_in_days_between(block_state.timestamp);
let is = filter.contains(days_old); if prev_days_old == days_old {
let was = filter.contains(prev_days_old); return ControlFlow::Continue(());
}
if is && !was { vecs.iter_mut().for_each(|(filter, state)| {
state.increment(&block_state.supply, block_state.price); let is = filter.contains(days_old);
} else if was && !is { let was = filter.contains(prev_days_old);
state.decrement(&block_state.supply, block_state.price);
}
ControlFlow::Continue(()) if is && !was {
}); state.increment(&block_state.supply, block_state.price);
} else if was && !is {
state.decrement(&block_state.supply, block_state.price);
}
});
ControlFlow::Continue(())
}); });
} }