validator: ignore too old tower error (#35229)

* validator: ignore too old tower error * Update core/src/replay_stage.rs Co-authored-by: Ashwin Sekar <[email protected]> * remove redundant references --------- Co-authored-by: Ashwin Sekar <[email protected]>
solana-labs · Feb 21, 2024 · 531793b · 531793b
1 parent a97f26e
commit 531793b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/core/src/consensus.rs b/core/src/consensus.rs
@@ -1533,6 +1533,9 @@ impl TowerError {
             false
         }
     }
+    pub fn is_too_old(&self) -> bool {
+        matches!(self, TowerError::TooOldTower(_, _))
+    }
 }
 
 #[derive(Debug)]

diff --git a/core/src/replay_stage.rs b/core/src/replay_stage.rs
@@ -1171,6 +1171,13 @@ impl ReplayStage {
                         node_pubkey,
                         vote_account,
                     )
+                } else if err.is_too_old() {
+                    warn!("Failed to load tower, too old for {}: {}. Creating a new tower from bankforks.", node_pubkey, err);
+                    Tower::new_from_bankforks(
+                        &bank_forks.read().unwrap(),
+                        node_pubkey,
+                        vote_account,
+                    )
                 } else {
                     error!("Failed to load tower for {}: {}", node_pubkey, err);
                     std::process::exit(1);
-Original file line number
+Diff line change
@@ Expand Up / @@ -1533,6 +1533,9 @@ impl TowerError { @@
                 false
             }
         }
+        pub fn is_too_old(&self) -> bool {
+            matches!(self, TowerError::TooOldTower(_, _))
+        }
     }
     #[derive(Debug)]
@@ Expand Down @@