@@ -151,7 +151,6 @@ impl GlobalStateEvaluator {
151
151
burn_block_height : * burn_block_height,
152
152
current_miner : current_miner. into ( ) ,
153
153
active_signer_protocol_version,
154
- tx_replay_state : false ,
155
154
tx_replay_set : None ,
156
155
} ;
157
156
let entry = state_views
@@ -249,9 +248,6 @@ pub struct SignerStateMachine {
249
248
pub current_miner : MinerState ,
250
249
/// The active signing protocol version
251
250
pub active_signer_protocol_version : u64 ,
252
- /// Whether or not we're in a tx replay state
253
- /// TODO: just a placeholder for now
254
- pub tx_replay_state : bool ,
255
251
/// Transaction replay set
256
252
pub tx_replay_set : Option < Vec < StacksTransaction > > ,
257
253
}
@@ -392,7 +388,6 @@ impl LocalStateMachine {
392
388
burn_block_height : 0 ,
393
389
current_miner : MinerState :: NoValidMiner ,
394
390
active_signer_protocol_version : SUPPORTED_SIGNER_PROTOCOL_VERSION ,
395
- tx_replay_state : false ,
396
391
tx_replay_set : None ,
397
392
}
398
393
}
@@ -689,18 +684,6 @@ impl LocalStateMachine {
689
684
proposal_config : & ProposalEvalConfig ,
690
685
mut expected_burn_block : Option < NewBurnBlock > ,
691
686
) -> Result < ( ) , SignerChainstateError > {
692
- // TODO: test only, remove
693
- match expected_burn_block. clone ( ) {
694
- Some ( expected_burn_block) => {
695
- if expected_burn_block. burn_block_height > 230 {
696
- info ! (
697
- "---- bitcoin_block_arrival {} {} ----" ,
698
- expected_burn_block. burn_block_height, expected_burn_block. consensus_hash
699
- ) ;
700
- }
701
- }
702
- None => { }
703
- }
704
687
// set self to uninitialized so that if this function errors,
705
688
// self is left as uninitialized.
706
689
let prior_state = std:: mem:: replace ( self , Self :: Uninitialized ) ;
@@ -733,7 +716,6 @@ impl LocalStateMachine {
733
716
let peer_info = client. get_peer_info ( ) ?;
734
717
let next_burn_block_height = peer_info. burn_block_height ;
735
718
let next_burn_block_hash = peer_info. pox_consensus ;
736
- let mut fork_detected = prior_state_machine. tx_replay_state ;
737
719
let mut tx_replay_set = prior_state_machine. tx_replay_set . clone ( ) ;
738
720
739
721
if let Some ( expected_burn_block) = expected_burn_block {
@@ -758,8 +740,7 @@ impl LocalStateMachine {
758
740
// TODO: handle fork while still in replay
759
741
&& tx_replay_set. is_none ( )
760
742
{
761
- fork_detected = true ;
762
- info ! ( "---- Signer State: Possible fork! ----" ;
743
+ info ! ( "Signer State: fork detected" ;
763
744
"expected_burn_block.height" => expected_burn_block. burn_block_height,
764
745
"expected_burn_block.hash" => %expected_burn_block. consensus_hash,
765
746
"next_burn_block_height" => next_burn_block_height,
@@ -851,7 +832,6 @@ impl LocalStateMachine {
851
832
burn_block_height : next_burn_block_height,
852
833
current_miner : miner_state,
853
834
active_signer_protocol_version : prior_state_machine. active_signer_protocol_version ,
854
- tx_replay_state : fork_detected,
855
835
tx_replay_set,
856
836
} ) ;
857
837
@@ -897,7 +877,6 @@ impl LocalStateMachine {
897
877
burn_block_height : * burn_block_height,
898
878
current_miner : current_miner. into ( ) ,
899
879
active_signer_protocol_version,
900
- tx_replay_state : false ,
901
880
tx_replay_set : None ,
902
881
} ) ;
903
882
// Because we updated our active signer protocol version, update local_update so its included in the subsequent evaluations
@@ -931,7 +910,6 @@ impl LocalStateMachine {
931
910
burn_block_height,
932
911
current_miner : ( & new_miner) . into ( ) ,
933
912
active_signer_protocol_version,
934
- tx_replay_state : false ,
935
913
tx_replay_set : None ,
936
914
} ) ;
937
915
}
0 commit comments