diff --git a/cmd/neofs-ir/defaults.go b/cmd/neofs-ir/defaults.go index 31805b02b..3ef4c204d 100644 --- a/cmd/neofs-ir/defaults.go +++ b/cmd/neofs-ir/defaults.go @@ -83,4 +83,7 @@ func defaultConfiguration(cfg *viper.Viper) { cfg.SetDefault("workers.neofs", "10") cfg.SetDefault("workers.container", "10") cfg.SetDefault("workers.alphabet", "10") + + cfg.SetDefault("netmap_cleaner.enabled", false) + cfg.SetDefault("netmap_cleaner.threshold", 3) } diff --git a/pkg/innerring/innerring.go b/pkg/innerring/innerring.go index bfa1dfa52..85179ccb8 100644 --- a/pkg/innerring/innerring.go +++ b/pkg/innerring/innerring.go @@ -173,13 +173,15 @@ func New(ctx context.Context, log *zap.Logger, cfg *viper.Viper) (*Server, error // create netmap processor netmapProcessor, err := netmap.New(&netmap.Params{ - Log: log, - PoolSize: cfg.GetInt("workers.netmap"), - NetmapContract: server.contracts.netmap, - EpochTimer: server.localTimers, - MorphClient: server.morphClient, - EpochState: server, - ActiveState: server, + Log: log, + PoolSize: cfg.GetInt("workers.netmap"), + NetmapContract: server.contracts.netmap, + EpochTimer: server.localTimers, + MorphClient: server.morphClient, + EpochState: server, + ActiveState: server, + CleanupEnabled: cfg.GetBool("netmap_cleaner.enabled"), + CleanupThreshold: cfg.GetUint64("netmap_cleaner.threshold"), }) if err != nil { return nil, err