fix: config to disable piece doctor

node/builder.go

@@ -551,7 +551,7 @@ func ConfigBoost(cfg *config.Boost) Option {
 		Override(new(*server.GraphsyncUnpaidRetrieval), modules.RetrievalGraphsync(cfg.LotusDealmaking.SimultaneousTransfersForStorage, cfg.LotusDealmaking.SimultaneousTransfersForStoragePerClient, cfg.LotusDealmaking.SimultaneousTransfersForRetrieval)),
 		Override(new(dtypes.StagingGraphsync), From(new(*server.GraphsyncUnpaidRetrieval))),
 		Override(new(dtypes.ProviderPieceStore), modules.NewProviderPieceStore),
-		Override(StartPieceDoctorKey, modules.NewPieceDoctor),
+		Override(StartPieceDoctorKey, modules.NewPieceDoctor(cfg)),
 
 		// Lotus Markets (retrieval deps)
 		Override(new(sealer.PieceProvider), sealer.NewPieceProvider),

node/config/def.go

@@ -95,6 +95,7 @@ func DefaultBoost() *Boost {
 			EmbeddedServicePort:   8042,
 			ServiceApiInfo:        "",
 			ServiceRPCTimeout:     Duration(15 * time.Minute),
+			EnablePieceDoctor:     true,
 		},
 
 		ContractDeals: ContractDealsConfig{

node/config/types.go

@@ -430,6 +430,8 @@ type LocalIndexDirectoryConfig struct {
 	ServiceApiInfo string
 	// The RPC timeout when making requests to the boostd-data service
 	ServiceRPCTimeout Duration
+	// PieceDoctor runs a continuous background process to check each piece in LID for retrievability
+	EnablePieceDoctor bool
 }
 
 type LocalIndexDirectoryLeveldbConfig struct {

node/modules/piecedirectory.go

@@ -163,20 +163,25 @@ func NewPieceStore(pm *piecedirectory.PieceDirectory, maddr address.Address) pie
 	return &boostPieceStoreWrapper{piecedirectory: pm, maddr: maddr}
 }
 
-func NewPieceDoctor(lc fx.Lifecycle, maddr lotus_dtypes.MinerAddress, store *bdclient.Store, ssm *sectorstatemgr.SectorStateMgr, fullnodeApi api.FullNode) *piecedirectory.Doctor {
-	doc := piecedirectory.NewDoctor(address.Address(maddr), store, ssm, fullnodeApi)
-	docctx, cancel := context.WithCancel(context.Background())
-	lc.Append(fx.Hook{
-		OnStart: func(ctx context.Context) error {
-			go doc.Run(docctx)
-			return nil
-		},
-		OnStop: func(ctx context.Context) error {
-			cancel()
-			return nil
-		},
-	})
-	return doc
+func NewPieceDoctor(cfg *config.Boost) func(lc fx.Lifecycle, maddr lotus_dtypes.MinerAddress, store *bdclient.Store, ssm *sectorstatemgr.SectorStateMgr, fullnodeApi api.FullNode) *piecedirectory.Doctor {
+	return func(lc fx.Lifecycle, maddr lotus_dtypes.MinerAddress, store *bdclient.Store, ssm *sectorstatemgr.SectorStateMgr, fullnodeApi api.FullNode) *piecedirectory.Doctor {
+		if !cfg.LocalIndexDirectory.EnablePieceDoctor {
+			return &piecedirectory.Doctor{}
+		}
+		doc := piecedirectory.NewDoctor(address.Address(maddr), store, ssm, fullnodeApi)
+		docctx, cancel := context.WithCancel(context.Background())
+		lc.Append(fx.Hook{
+			OnStart: func(ctx context.Context) error {
+				go doc.Run(docctx)
+				return nil
+			},
+			OnStop: func(ctx context.Context) error {
+				cancel()
+				return nil
+			},
+		})
+		return doc
+	}
 }
 
 type boostPieceStoreWrapper struct {