@@ -7,7 +7,7 @@ use dashcore::{
77use dashcore_hashes:: Hash ;
88
99use crate :: chain:: checkpoints:: { mainnet_checkpoints, testnet_checkpoints, CheckpointManager } ;
10- use crate :: chain:: { ChainTip , ChainTipManager , ChainWork , ForkDetector } ;
10+ use crate :: chain:: { ChainTip , ChainTipManager , ChainWork } ;
1111use crate :: client:: ClientConfig ;
1212use crate :: error:: { SyncError , SyncResult } ;
1313use crate :: network:: NetworkManager ;
@@ -47,7 +47,6 @@ pub struct HeaderSyncManager<S: StorageManager, N: NetworkManager> {
4747 _phantom_s : std:: marker:: PhantomData < S > ,
4848 _phantom_n : std:: marker:: PhantomData < N > ,
4949 config : ClientConfig ,
50- fork_detector : ForkDetector ,
5150 tip_manager : ChainTipManager ,
5251 checkpoint_manager : CheckpointManager ,
5352 reorg_config : ReorgConfig ,
@@ -83,8 +82,6 @@ impl<S: StorageManager + Send + Sync + 'static, N: NetworkManager + Send + Sync
8382
8483 Ok ( Self {
8584 config : config. clone ( ) ,
86- fork_detector : ForkDetector :: new ( reorg_config. max_forks )
87- . map_err ( |e| SyncError :: InvalidState ( e. to_string ( ) ) ) ?,
8885 tip_manager : ChainTipManager :: new ( reorg_config. max_forks ) ,
8986 checkpoint_manager,
9087 reorg_config,
@@ -842,10 +839,6 @@ impl<S: StorageManager + Send + Sync + 'static, N: NetworkManager + Send + Sync
842839 // Reset sync state
843840 self . syncing_headers = false ;
844841 self . last_sync_progress = std:: time:: Instant :: now ( ) ;
845- // Clear any fork tracking state that shouldn't persist across restarts
846- self . fork_detector = ForkDetector :: new ( self . reorg_config . max_forks ) . map_err ( |e| {
847- SyncError :: InvalidState ( format ! ( "Failed to create fork detector: {}" , e) )
848- } ) ?;
849842 tracing:: debug!( "Reset header sync pending requests" ) ;
850843 Ok ( ( ) )
851844 }
0 commit comments