mirror of
https://github.com/sigp/lighthouse.git
synced 2026-05-30 04:37:13 +00:00
Merge branch 'unstable' of https://github.com/sigp/lighthouse into data-column-reprocess-queue
This commit is contained in:
@@ -593,7 +593,7 @@ impl<T: BeaconChainTypes> CustodyBackFillSync<T> {
|
||||
Err(err) => {
|
||||
debug!(batch_epoch = %batch_id, error = ?err, "Batch download failed");
|
||||
|
||||
// If there are any coupling errors, penalize the appropriate peers
|
||||
// If there are any coupling errors, penalize the appropriate peers.
|
||||
if let RpcResponseError::BlockComponentCouplingError(coupling_error) = err
|
||||
&& let CouplingError::DataColumnPeerFailure {
|
||||
error,
|
||||
@@ -601,15 +601,19 @@ impl<T: BeaconChainTypes> CustodyBackFillSync<T> {
|
||||
exceeded_retries: _,
|
||||
} = coupling_error
|
||||
{
|
||||
let mut failed_peers = HashSet::new();
|
||||
for (column_index, faulty_peer) in faulty_peers {
|
||||
debug!(
|
||||
?error,
|
||||
?column_index,
|
||||
?faulty_peer,
|
||||
"Custody backfill sync penalizing peer"
|
||||
"Custody backfill sync: peer failed to serve column"
|
||||
);
|
||||
failed_peers.insert(faulty_peer);
|
||||
}
|
||||
for peer in failed_peers {
|
||||
network.report_peer(
|
||||
faulty_peer,
|
||||
peer,
|
||||
PeerAction::LowToleranceError,
|
||||
"Peer failed to serve column",
|
||||
);
|
||||
|
||||
@@ -378,10 +378,11 @@ where
|
||||
.data
|
||||
.slot
|
||||
.epoch(E::slots_per_epoch());
|
||||
let fork = spec.fork_at_epoch(epoch);
|
||||
let domain = spec.get_domain(
|
||||
epoch,
|
||||
Domain::PTCAttester,
|
||||
&state.fork(),
|
||||
&fork,
|
||||
state.genesis_validators_root(),
|
||||
);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user