Lower error level

This commit is contained in:
Carl 2020-03-15 19:57:29 -07:00 committed by Michael Vines
parent 5a93a4c466
commit 9411fc00b8
2 changed files with 22 additions and 5 deletions

View File

@ -629,11 +629,19 @@ impl ReplayStage {
// errors related to the slot being purged // errors related to the slot being purged
let slot = bank.slot(); let slot = bank.slot();
warn!("Fatal replay error in slot: {}, err: {:?}", slot, err); warn!("Fatal replay error in slot: {}, err: {:?}", slot, err);
datapoint_error!( if err.is_severity_error() {
"replay-stage-mark_dead_slot", datapoint_error!(
("error", format!("error: {:?}", err), String), "replay-stage-mark_dead_slot",
("slot", slot, i64) ("error", format!("error: {:?}", err), String),
); ("slot", slot, i64)
);
} else {
datapoint_info!(
"replay-stage-mark_dead_slot",
("error", format!("error: {:?}", err), String),
("slot", slot, i64)
);
}
bank_progress.is_dead = true; bank_progress.is_dead = true;
blockstore blockstore
.set_dead_slot(slot) .set_dead_slot(slot)

View File

@ -260,6 +260,15 @@ pub enum BlockstoreProcessorError {
InvalidHardFork(Slot), InvalidHardFork(Slot),
} }
impl BlockstoreProcessorError {
pub fn is_severity_error(&self) -> bool {
match self {
BlockstoreProcessorError::InvalidBlock(BlockError::InvalidTickCount) => false,
_ => true,
}
}
}
/// Callback for accessing bank state while processing the blockstore /// Callback for accessing bank state while processing the blockstore
pub type ProcessCallback = Arc<dyn Fn(&Bank) -> () + Sync + Send>; pub type ProcessCallback = Arc<dyn Fn(&Bank) -> () + Sync + Send>;