mirror of
https://github.com/sigp/lighthouse.git
synced 2026-05-07 00:42:42 +00:00
change to slot
This commit is contained in:
@@ -672,13 +672,13 @@ pub async fn fill_in_aggregation_proofs<T: SlotClock + 'static, E: EthSpec>(
|
|||||||
"Selection proof in result variable"
|
"Selection proof in result variable"
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
result.map(|proof| (duty.validator_index, proof_slot, subnet_id, proof))
|
result.map(|proof| (duty.validator_index, slot, subnet_id, proof))
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
while let Some(result) = futures_unordered.next().await {
|
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 sync_map = duties_service.sync_duties.committees.read();
|
||||||
let Some(committee_duties) = sync_map.get(&sync_committee_period) else {
|
let Some(committee_duties) = sync_map.get(&sync_committee_period) else {
|
||||||
debug!("period" = sync_committee_period, "Missing sync duties");
|
debug!("period" = sync_committee_period, "Missing sync duties");
|
||||||
@@ -693,7 +693,7 @@ pub async fn fill_in_aggregation_proofs<T: SlotClock + 'static, E: EthSpec>(
|
|||||||
if let Some(Some(duty)) = validators.get(&validator_index) {
|
if let Some(Some(duty)) = validators.get(&validator_index) {
|
||||||
debug!(
|
debug!(
|
||||||
validator_index,
|
validator_index,
|
||||||
"slot" = %proof_slot,
|
"slot" = %slot,
|
||||||
"subcommittee_index" = *subnet_id,
|
"subcommittee_index" = *subnet_id,
|
||||||
// log full selection proof for debugging
|
// log full selection proof for debugging
|
||||||
"full selection proof" = ?proof,
|
"full selection proof" = ?proof,
|
||||||
|
|||||||
Reference in New Issue
Block a user