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

Add more logging

Browse Source
This commit is contained in:
Tan Chee Keong
2025-04-18 14:14:06 +08:00
parent f2725ce0cc
commit 23fefa338a
2 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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, slot, subnet_id, proof)) result.map(|proof| (duty.validator_index, proof_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, 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 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" = %slot, "slot" = %proof_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,

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

@@ -380,11 +380,20 @@ impl<T: SlotClock + 'static, E: EthSpec> SyncCommitteeService<T, E> {
aggregator_index, aggregator_index,
aggregator_pk, aggregator_pk,
contribution.clone(), contribution.clone(),
selection_proof, selection_proof.clone(),
) )
.await .await
{ {
Ok(signed_contribution) => Some(signed_contribution), Ok(signed_contribution) => {
debug!(
validator_index = aggregator_index,
%slot,
subcommittee_index = %subnet_id,
full_selection_proof = ?selection_proof,
"Produced sync contribution and proof"
);
Some(signed_contribution)
}
Err(ValidatorStoreError::UnknownPubkey(pubkey)) => { Err(ValidatorStoreError::UnknownPubkey(pubkey)) => {
// A pubkey can be missing when a validator was recently // A pubkey can be missing when a validator was recently
// removed via the API. // removed via the API.