gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-05-07 16:55:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add duration of computation offset

Browse Source
This commit is contained in:
Tan Chee Keong
2025-04-11 12:03:54 +08:00
parent 76125fa0fa
commit ea13f74c06
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
validator_client/validator_services/src/duties_service.rs
View File

@@ -127,7 +127,8 @@ pub struct SubscriptionSlots {
} }
struct SelectionProofConfig { struct SelectionProofConfig {
look_ahead: u64, lookahead_slot: u64,
computation_offset: Duration, // The seconds to compute the selection proof before a slot
selections_endpoint: bool, selections_endpoint: bool,
parallel_sign: bool, parallel_sign: bool,
} }
@@ -990,11 +991,13 @@ async fn poll_beacon_attesters_for_epoch<T: SlotClock + 'static, E: EthSpec>(
let subservice = duties_service.clone(); let subservice = duties_service.clone();
let config = SelectionProofConfig { let config = SelectionProofConfig {
look_ahead: if duties_service.distributed { lookahead_slot: if duties_service.distributed {
SELECTION_PROOF_SLOT_LOOKAHEAD_DVT SELECTION_PROOF_SLOT_LOOKAHEAD_DVT
} else { } else {
SELECTION_PROOF_SLOT_LOOKAHEAD SELECTION_PROOF_SLOT_LOOKAHEAD
}, },
computation_offset: duties_service.slot_clock.slot_duration()
/ SELECTION_PROOF_SCHEDULE_DENOM,
selections_endpoint: duties_service.distributed, selections_endpoint: duties_service.distributed,
parallel_sign: duties_service.distributed, parallel_sign: duties_service.distributed,
}; };
@@ -1108,17 +1111,16 @@ async fn fill_in_selection_proofs<T: SlotClock + 'static, E: EthSpec>(
// At halfway through each slot when nothing else is likely to be getting signed, sign a batch // At halfway through each slot when nothing else is likely to be getting signed, sign a batch
// of selection proofs and insert them into the duties service `attesters` map. // of selection proofs and insert them into the duties service `attesters` map.
let slot_clock = &duties_service.slot_clock; let slot_clock = &duties_service.slot_clock;
let slot_offset = duties_service.slot_clock.slot_duration() / SELECTION_PROOF_SCHEDULE_DENOM;
while !duties_by_slot.is_empty() { while !duties_by_slot.is_empty() {
if let Some(duration) = slot_clock.duration_to_next_slot() { if let Some(duration) = slot_clock.duration_to_next_slot() {
sleep(duration.saturating_sub(slot_offset)).await; sleep(duration.saturating_sub(config.computation_offset)).await;
let Some(current_slot) = slot_clock.now() else { let Some(current_slot) = slot_clock.now() else {
continue; continue;
}; };
let selection_lookahead = config.look_ahead; let selection_lookahead = config.lookahead_slot;
let lookahead_slot = current_slot + selection_lookahead; let lookahead_slot = current_slot + selection_lookahead;