diff --git a/cmd/neofs-node/object.go b/cmd/neofs-node/object.go index b6b98c5c..60017c9a 100644 --- a/cmd/neofs-node/object.go +++ b/cmd/neofs-node/object.go @@ -328,6 +328,7 @@ func initObjectService(c *cfg) { rangehashsvc.WithHeadService(sHead), rangehashsvc.WithRangeService(sRange), rangehashsvc.WithWorkerPool(c.cfgObject.pool.rngHash), + rangehashsvc.WithLogger(c.log), ) sRangeHashV2 := rangehashsvcV2.NewService( diff --git a/pkg/services/object/rangehash/service.go b/pkg/services/object/rangehash/service.go index a40dbb8e..3268ab13 100644 --- a/pkg/services/object/rangehash/service.go +++ b/pkg/services/object/rangehash/service.go @@ -17,7 +17,9 @@ import ( rangesvc "github.com/nspcc-dev/neofs-node/pkg/services/object/range" objutil "github.com/nspcc-dev/neofs-node/pkg/services/object/util" "github.com/nspcc-dev/neofs-node/pkg/util" + "github.com/nspcc-dev/neofs-node/pkg/util/logger" "github.com/pkg/errors" + "go.uber.org/zap" ) type Service struct { @@ -44,11 +46,14 @@ type cfg struct { rangeSvc *rangesvc.Service clientCache *cache.ClientCache + + log *logger.Logger } func defaultCfg() *cfg { return &cfg{ workerPool: new(util.SyncWorkerPool), + log: zap.L(), } } @@ -273,3 +278,9 @@ func WithClientCache(v *cache.ClientCache) Option { c.clientCache = v } } + +func WithLogger(l *logger.Logger) Option { + return func(c *cfg) { + c.log = l + } +}