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 distributed lookahead

Browse Source
This commit is contained in:
Tan Chee Keong
2025-03-16 21:27:07 +08:00
parent 0c360c893e
commit 50ec5f17a1
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1137,8 +1137,17 @@ async fn fill_in_selection_proofs<T: SlotClock + 'static, E: EthSpec>(
let lookahead_slot = current_slot + selection_lookahead; let lookahead_slot = current_slot + selection_lookahead;
let mut relevant_duties = duties_by_slot.split_off(&lookahead_slot); let relevant_duties = if duties_service.distributed {
std::mem::swap(&mut relevant_duties, &mut duties_by_slot); if let Some(duties) = duties_by_slot.remove(&lookahead_slot) {
BTreeMap::from([(lookahead_slot, duties)])
} else {
BTreeMap::new()
}
} else {
let mut duties = duties_by_slot.split_off(&lookahead_slot);
std::mem::swap(&mut duties, &mut duties_by_slot);
duties
};
let batch_size = relevant_duties.values().map(Vec::len).sum::<usize>(); let batch_size = relevant_duties.values().map(Vec::len).sum::<usize>();