mirror of
https://github.com/sigp/lighthouse.git
synced 2026-06-10 01:26:44 +00:00
@@ -6,7 +6,7 @@ use std::{
|
|||||||
|
|
||||||
use beacon_chain::{BeaconChain, BeaconChainTypes};
|
use beacon_chain::{BeaconChain, BeaconChainTypes};
|
||||||
use lighthouse_network::{
|
use lighthouse_network::{
|
||||||
NetworkGlobals, PeerId,
|
NetworkGlobals, PeerAction, PeerId,
|
||||||
service::api_types::{CustodyBackFillBatchRequestId, CustodyBackfillBatchId},
|
service::api_types::{CustodyBackFillBatchRequestId, CustodyBackfillBatchId},
|
||||||
types::CustodyBackFillState,
|
types::CustodyBackFillState,
|
||||||
};
|
};
|
||||||
@@ -601,13 +601,21 @@ impl<T: BeaconChainTypes> CustodyBackFillSync<T> {
|
|||||||
exceeded_retries: _,
|
exceeded_retries: _,
|
||||||
} = coupling_error
|
} = coupling_error
|
||||||
{
|
{
|
||||||
let unique_faulty_peers: HashSet<PeerId> =
|
let mut failed_peers = HashSet::new();
|
||||||
faulty_peers.iter().map(|(_, peer)| *peer).collect();
|
for (column_index, faulty_peer) in faulty_peers {
|
||||||
for faulty_peer in unique_faulty_peers {
|
|
||||||
debug!(
|
debug!(
|
||||||
?error,
|
?error,
|
||||||
|
?column_index,
|
||||||
?faulty_peer,
|
?faulty_peer,
|
||||||
"Custody backfill sync: peer failed to serve columns (not penalizing)"
|
"Custody backfill sync: peer failed to serve column"
|
||||||
|
);
|
||||||
|
failed_peers.insert(faulty_peer);
|
||||||
|
}
|
||||||
|
for peer in failed_peers {
|
||||||
|
network.report_peer(
|
||||||
|
peer,
|
||||||
|
PeerAction::LowToleranceError,
|
||||||
|
"Peer failed to serve column",
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user