diff --git a/pkg/services/object/head/distributed.go b/pkg/services/object/head/distributed.go index 7922490f..dbff3eaa 100644 --- a/pkg/services/object/head/distributed.go +++ b/pkg/services/object/head/distributed.go @@ -125,7 +125,9 @@ loop: h.w.write(head) }); err != nil { wg.Done() - // TODO: log error + + svcutil.LogWorkerPoolError(h.log, "HEAD", err) + break loop } } diff --git a/pkg/services/object/put/distributed.go b/pkg/services/object/put/distributed.go index c53401fe..f20885e1 100644 --- a/pkg/services/object/put/distributed.go +++ b/pkg/services/object/put/distributed.go @@ -103,7 +103,9 @@ loop: traverser.SubmitSuccess() }); err != nil { wg.Done() - // TODO: log error + + svcutil.LogWorkerPoolError(t.log, "PUT", err) + break loop } } diff --git a/pkg/services/object/range/streamer.go b/pkg/services/object/range/streamer.go index 02b202d6..1d557877 100644 --- a/pkg/services/object/range/streamer.go +++ b/pkg/services/object/range/streamer.go @@ -205,7 +205,9 @@ loop: nextRange.SetOffset(nextRange.GetOffset() + uw) }); err != nil { wg.Done() - // TODO: log error + + svcutil.LogWorkerPoolError(p.log, "RANGE", err) + break loop } diff --git a/pkg/services/object/rangehash/distributed.go b/pkg/services/object/rangehash/distributed.go index f74eac57..e4171680 100644 --- a/pkg/services/object/rangehash/distributed.go +++ b/pkg/services/object/rangehash/distributed.go @@ -125,7 +125,9 @@ loop: } }); err != nil { wg.Done() - // TODO: log error + + svcutil.LogWorkerPoolError(h.log, "RANGEHASH", err) + break loop } } diff --git a/pkg/services/object/search/streamer.go b/pkg/services/object/search/streamer.go index fb3d288e..7be5bdee 100644 --- a/pkg/services/object/search/streamer.go +++ b/pkg/services/object/search/streamer.go @@ -8,7 +8,7 @@ import ( "github.com/nspcc-dev/neofs-api-go/pkg/object" "github.com/nspcc-dev/neofs-node/pkg/core/netmap" "github.com/nspcc-dev/neofs-node/pkg/network" - "github.com/nspcc-dev/neofs-node/pkg/services/object/util" + svcutil "github.com/nspcc-dev/neofs-node/pkg/services/object/util" "github.com/nspcc-dev/neofs-node/pkg/services/object_manager/placement" "github.com/pkg/errors" ) @@ -113,7 +113,7 @@ func (p *Streamer) preparePrm(prm *Prm) error { traverseOpts = append(traverseOpts, placement.SuccessAfter(1)) // use local-only placement builder - builder = util.NewLocalPlacement(builder, p.localAddrSrc) + builder = svcutil.NewLocalPlacement(builder, p.localAddrSrc) } // set placement builder @@ -169,11 +169,13 @@ loop: } if err := streamer.stream(p.ctx, p.ch); err != nil { - util.LogServiceError(p.log, "SEARCH", addr, err) + svcutil.LogServiceError(p.log, "SEARCH", addr, err) } }); err != nil { wg.Done() - // TODO: log error + + svcutil.LogWorkerPoolError(p.log, "SEARCH", err) + break loop } } diff --git a/pkg/services/object/util/log.go b/pkg/services/object/util/log.go index 1ea5bbbc..e01503b3 100644 --- a/pkg/services/object/util/log.go +++ b/pkg/services/object/util/log.go @@ -14,3 +14,11 @@ func LogServiceError(l *logger.Logger, req string, node *network.Address, err er zap.String("error", err.Error()), ) } + +// LogWorkerPoolError writes debug error message of object worker pool to provided logger. +func LogWorkerPoolError(l *logger.Logger, req string, err error) { + l.Debug("could not push task to worker pool", + zap.String("request", req), + zap.String("error", err.Error()), + ) +}