From 239c1839c385c36cf55a842f7dac12809d333295 Mon Sep 17 00:00:00 2001 From: Tan Chee Keong Date: Mon, 21 Apr 2025 17:11:06 +0800 Subject: [PATCH] proof_slot --- validator_client/validator_services/src/sync.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/validator_client/validator_services/src/sync.rs b/validator_client/validator_services/src/sync.rs index bf9c70b6ce..f626c08eef 100644 --- a/validator_client/validator_services/src/sync.rs +++ b/validator_client/validator_services/src/sync.rs @@ -672,13 +672,13 @@ pub async fn fill_in_aggregation_proofs( "Selection proof in result variable" ); } - result.map(|proof| (duty.validator_index, slot, subnet_id, proof)) + result.map(|proof| (duty.validator_index, proof_slot, subnet_id, proof)) }); } } while let Some(result) = futures_unordered.next().await { - if let Some((validator_index, slot, subnet_id, proof)) = result { + if let Some((validator_index, proof_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"); @@ -693,7 +693,7 @@ pub async fn fill_in_aggregation_proofs( if let Some(Some(duty)) = validators.get(&validator_index) { debug!( validator_index, - "slot" = %slot, + "slot" = %proof_slot, "subcommittee_index" = *subnet_id, // log full selection proof for debugging "full selection proof" = ?proof, @@ -704,7 +704,7 @@ pub async fn fill_in_aggregation_proofs( duty.aggregation_duties .proofs .write() - .insert((slot, subnet_id), proof); + .insert((proof_slot, subnet_id), proof); } } Ok(false) => {} // Not an aggregator