gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-03-20 13:24:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Try to fix

Browse Source
This commit is contained in:
Tan Chee Keong
2025-04-18 10:43:44 +08:00
parent efa14b08e4
commit 24b125f851
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -561,7 +561,7 @@ pub async fn make_sync_selection_proof<T: SlotClock + 'static, E: EthSpec>(
"slot" = %proof_slot,
"subcommittee_index" = *subnet_id,
"partial selection proof" = ?Signature::from(selection_proof.clone()),
"Created sync selection proof"
"Sending sync selection to middleware"
);
let sync_committee_selection = SyncCommitteeSelection {
@@ -588,7 +588,6 @@ pub async fn make_sync_selection_proof<T: SlotClock + 'static, E: EthSpec>(
match middleware_response {
Ok(response) => {
// Process each middleware response
let response_data = &response.data[0];
// The selection proof from middleware response will be a full selection proof
debug!(
@@ -664,14 +663,14 @@ pub async fn fill_in_aggregation_proofs<T: SlotClock + 'static, E: EthSpec>(
)
.await;
result.map(|proof| (duty.validator_index, proof_slot, subnet_id, proof))
result.map(|proof| (duty.validator_index, slot, subnet_id, proof))
});
}
}
let mut successful_results = Vec::new();
// let mut successful_results = Vec::new();
while let Some(result) = futures_unordered.next().await {
if let Some((validator_index, proof_slot, subnet_id, proof)) = result {
if let Some((validator_index, slot, subnet_id, proof)) = result {
let sync_map = duties_service.sync_duties.committees.read();
let Some(committee_duties) = sync_map.get(&sync_committee_period) else {
debug!("period" = sync_committee_period, "Missing sync duties");
@@ -686,7 +685,7 @@ pub async fn fill_in_aggregation_proofs<T: SlotClock + 'static, E: EthSpec>(
if let Some(Some(duty)) = validators.get(&validator_index) {
debug!(
validator_index,
"slot" = %proof_slot,
"slot" = %slot,
"subcommittee_index" = *subnet_id,
// log full selection proof for debugging
"full selection proof" = ?proof,
@@ -698,7 +697,7 @@ pub async fn fill_in_aggregation_proofs<T: SlotClock + 'static, E: EthSpec>(
.proofs
.write()
.insert((slot, subnet_id), proof);
successful_results.push(validator_index);
//successful_results.push(validator_index);
}
}
Ok(false) => {} // Not an aggregator