Skip to content

Commit ac3e2c7

Browse files
fix missing KeyChanFunc
1 parent 8c63c46 commit ac3e2c7

File tree

2 files changed

+9
-2
lines changed

2 files changed

+9
-2
lines changed

core/node/groups.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -368,7 +368,7 @@ func Online(bcfg *BuildCfg, cfg *config.Config, userResourceOverrides rcmgr.Part
368368
cfg.Routing.AcceleratedDHTClient.WithDefault(config.DefaultAcceleratedDHTClient),
369369
int(cfg.Provider.WorkerCount.WithDefault(config.DefaultProviderWorkerCount)),
370370
),
371-
Reprovider(cfg),
371+
Reprovider(isProviderEnabled, cfg),
372372
)
373373
}
374374

core/node/reprovider.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,14 @@ func (r *NoopReprovider) StopProviding(...mh.Multihash)
2929
func (r *NoopReprovider) InstantProvide(context.Context, ...mh.Multihash) error { return nil }
3030
func (r *NoopReprovider) ForceProvide(context.Context, ...mh.Multihash) error { return nil }
3131

32-
func Reprovider(cfg *config.Config) fx.Option {
32+
func Reprovider(reprovide bool, cfg *config.Config) fx.Option {
33+
if !reprovide {
34+
return fx.Options(
35+
fx.Provide(func() reprovider.Reprovider {
36+
return &NoopReprovider{}
37+
}))
38+
}
39+
3340
mhStore := fx.Provide(func(keyProvider provider.KeyChanFunc, repo repo.Repo) (*rds.MHStore, error) {
3441
return rds.NewMHStore(context.Background(), repo.Datastore(),
3542
rds.WithPrefixLen(10),

0 commit comments

Comments
 (0)