This repository was archived by the owner on Jan 22, 2025. It is now read-only.
File tree 2 files changed +7
-8
lines changed
2 files changed +7
-8
lines changed Original file line number Diff line number Diff line change @@ -2786,7 +2786,6 @@ impl ReplayStage {
2786
2786
match replay_result {
2787
2787
Ok ( replay_tx_count) => tx_count += replay_tx_count,
2788
2788
Err ( err) => {
2789
- // Error means the slot needs to be marked as dead
2790
2789
Self :: mark_dead_slot (
2791
2790
blockstore,
2792
2791
bank,
@@ -2802,8 +2801,7 @@ impl ReplayStage {
2802
2801
ancestor_hashes_replay_update_sender,
2803
2802
purge_repair_slot_counter,
2804
2803
) ;
2805
- // If the bank was corrupted, don't try to run the below logic to check if the
2806
- // bank is completed
2804
+ // don't try to run the below logic to check if the bank is completed
2807
2805
continue ;
2808
2806
}
2809
2807
}
Original file line number Diff line number Diff line change @@ -812,6 +812,12 @@ impl Validator {
812
812
config. block_verification_method, config. block_production_method
813
813
) ;
814
814
815
+ let ( replay_vote_sender, replay_vote_receiver) = unbounded ( ) ;
816
+
817
+ // block min prioritization fee cache should be readable by RPC, and writable by validator
818
+ // (by both replay stage and banking stage)
819
+ let prioritization_fee_cache = Arc :: new ( PrioritizationFeeCache :: default ( ) ) ;
820
+
815
821
let leader_schedule_cache = Arc :: new ( leader_schedule_cache) ;
816
822
let entry_notification_sender = entry_notifier_service
817
823
. as_ref ( )
@@ -939,10 +945,6 @@ impl Validator {
939
945
) ) ,
940
946
} ;
941
947
942
- // block min prioritization fee cache should be readable by RPC, and writable by validator
943
- // (by both replay stage and banking stage)
944
- let prioritization_fee_cache = Arc :: new ( PrioritizationFeeCache :: default ( ) ) ;
945
-
946
948
let rpc_override_health_check =
947
949
Arc :: new ( AtomicBool :: new ( config. rpc_config . disable_health_check ) ) ;
948
950
let (
@@ -1229,7 +1231,6 @@ impl Validator {
1229
1231
} ;
1230
1232
let last_vote = tower. last_vote ( ) ;
1231
1233
1232
- let ( replay_vote_sender, replay_vote_receiver) = unbounded ( ) ;
1233
1234
let tvu = Tvu :: new (
1234
1235
vote_account,
1235
1236
authorized_voter_keypairs,
You can’t perform that action at this time.
0 commit comments