gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-05-30 20:57:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

inclusion_list_due_bps

Browse Source
This commit is contained in:
Eitan Seri-Levi
2026-04-30 15:36:06 +02:00
parent 81102d5943
commit afdb61326e
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
validator_client/validator_services/src/inclusion_list_service.rs
View File

@@ -150,11 +150,14 @@ impl<S: ValidatorStore + 'static, T: SlotClock + 'static> InclusionListService<S
let executor = self.executor.clone(); let executor = self.executor.clone();
let chain_spec = spec.clone(); let chain_spec = spec.clone();
let il_due_fraction = spec.inclusion_list_due_bps as u32;
let interval_fut = async move { let interval_fut = async move {
loop { loop {
if let Some(duration_to_next_slot) = self.slot_clock.duration_to_next_slot() { if let Some(duration_to_next_slot) = self.slot_clock.duration_to_next_slot() {
// 3/4 of the way into the slot // Wait until the start of the next slot, then sleep to
sleep(duration_to_next_slot + (slot_duration * 3 / 4)).await; // inclusion_list_due_bps fraction into that slot.
let il_offset = slot_duration * il_due_fraction / 10000;
sleep(duration_to_next_slot + il_offset).await;
if let Err(e) = self.spawn_inclusion_list_task(slot_duration, &chain_spec) { if let Err(e) = self.spawn_inclusion_list_task(slot_duration, &chain_spec) {
crit!( crit!(
error = ?e, error = ?e,