@ -496,10 +496,14 @@ impl ReplayStage {
|
|||||||
bank_forks: &RwLock<BankForks>,
|
bank_forks: &RwLock<BankForks>,
|
||||||
) {
|
) {
|
||||||
error!("purging slot {}", duplicate_slot);
|
error!("purging slot {}", duplicate_slot);
|
||||||
let empty = HashSet::new();
|
let slot_descendants = descendants.get(&duplicate_slot);
|
||||||
let slot_descendants = descendants.get(&duplicate_slot).unwrap_or(&empty);
|
if slot_descendants.is_none() {
|
||||||
|
// Root has already moved past this slot, no need to purge it
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
for d in slot_descendants
|
for d in slot_descendants
|
||||||
|
.unwrap()
|
||||||
.iter()
|
.iter()
|
||||||
.chain(std::iter::once(&duplicate_slot))
|
.chain(std::iter::once(&duplicate_slot))
|
||||||
{
|
{
|
||||||
|
Reference in New Issue
Block a user