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

tidy up sync.rs

Browse Source
This commit is contained in:
Tan Chee Keong
2025-04-01 16:06:14 +08:00
parent 101f24c440
commit d222ce8a5c
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -137,6 +137,7 @@ async fn make_selection_proof<T: SlotClock + 'static, E: EthSpec>(
let beacon_committee_selection = BeaconCommitteeSelection { let beacon_committee_selection = BeaconCommitteeSelection {
validator_index: duty.validator_index, validator_index: duty.validator_index,
slot: duty.slot, slot: duty.slot,
// In distributed mode, this is partial selection proof
selection_proof: validator_store selection_proof: validator_store
.produce_selection_proof(duty.pubkey, duty.slot) .produce_selection_proof(duty.pubkey, duty.slot)
.await .await
@@ -153,7 +154,7 @@ async fn make_selection_proof<T: SlotClock + 'static, E: EthSpec>(
"validator_index" = duty.validator_index, "validator_index" = duty.validator_index,
"slot" = %duty.slot, "slot" = %duty.slot,
"partial selection proof" = ?beacon_committee_selection.selection_proof, "partial selection proof" = ?beacon_committee_selection.selection_proof,
"Sending beacon committee selection to middleware" "Sending selection to middleware"
); );
async move { async move {
beacon_node beacon_node
@@ -173,7 +174,7 @@ async fn make_selection_proof<T: SlotClock + 'static, E: EthSpec>(
"validator_index" = response_data.validator_index, "validator_index" = response_data.validator_index,
"slot" = %response_data.slot, "slot" = %response_data.slot,
"full selection proof" = ?response_data.selection_proof, "full selection proof" = ?response_data.selection_proof,
"Received beacon committee selection from middleware" "Received selection from middleware"
); );
SelectionProof::from(response_data.selection_proof.clone()) SelectionProof::from(response_data.selection_proof.clone())
} else { } else {
@@ -1105,6 +1106,7 @@ 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 relevant_duties = if duties_service.distributed { let relevant_duties = if duties_service.distributed {
// Remove old slot duties and only keep current duties
duties_by_slot duties_by_slot
.remove(&lookahead_slot) .remove(&lookahead_slot)
.map(|duties| BTreeMap::from([(lookahead_slot, duties)])) .map(|duties| BTreeMap::from([(lookahead_slot, duties)]))
@@ -1127,7 +1129,7 @@ async fn fill_in_selection_proofs<T: SlotClock + 'static, E: EthSpec>(
); );
// In distributed case, we want to send all partial selection proofs to the middleware to determine aggregation duties, // In distributed case, we want to send all partial selection proofs to the middleware to determine aggregation duties,
// as the middleware will need to have a threshold of partial selection proof to be able to return the full selection proof // as the middleware will need to have a threshold of partial selection proofs to be able to return the full selection proof
// Thus, sign selection proofs in parallel in distributed case; Otherwise, sign them serially in non-distributed (normal) case // Thus, sign selection proofs in parallel in distributed case; Otherwise, sign them serially in non-distributed (normal) case
let duty_and_proof_results = if duties_service.distributed { let duty_and_proof_results = if duties_service.distributed {
futures::future::join_all(relevant_duties.into_values().flatten().map( futures::future::join_all(relevant_duties.into_values().flatten().map(