Skip to content

Commit

Permalink
[nspcc-dev#1052] Tidy INFO logs
Browse files Browse the repository at this point in the history
Signed-off-by: Alex Vanin <alexey@nspcc.ru>
  • Loading branch information
alexvanin authored and aprasolova committed Mar 5, 2022
1 parent 6140f4b commit 77b6960
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 7 deletions.
4 changes: 2 additions & 2 deletions pkg/morph/event/listener.go
Original file line number Diff line number Diff line change
Expand Up @@ -431,7 +431,7 @@ func (l listener) SetNotificationParser(pi NotificationParserInfo) {
l.notificationParsers[pi.scriptHashWithType] = pi.parser()
}

log.Info("registered new event parser")
log.Debug("registered new event parser")
}

// RegisterNotificationHandler registers the handler for particular notification event of contract.
Expand Down Expand Up @@ -468,7 +468,7 @@ func (l listener) RegisterNotificationHandler(hi NotificationHandlerInfo) {
)
l.mtx.Unlock()

log.Info("registered new event handler")
log.Debug("registered new event handler")
}

// EnableNotarySupport enables notary request listening. Passed hash is
Expand Down
4 changes: 2 additions & 2 deletions pkg/services/policer/check.go
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ func (p *Policer) processNodes(ctx context.Context, addr *object.Address, nodes
if strings.Contains(err.Error(), headsvc.ErrNotFound.Error()) {
continue
} else {
log.Error("could not receive object header",
log.Debug("could not receive object header",
zap.String("error", err.Error()),
)

Expand All @@ -114,7 +114,7 @@ func (p *Policer) processNodes(ctx context.Context, addr *object.Address, nodes
}

if shortage > 0 {
log.Info("shortage of object copies detected",
log.Debug("shortage of object copies detected",
zap.Uint32("shortage", shortage),
)

Expand Down
9 changes: 6 additions & 3 deletions pkg/services/replicator/process.go
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ func (p *Replicator) Run(ctx context.Context) {
// HandleTask executes replication task inside invoking goroutine.
func (p *Replicator) HandleTask(ctx context.Context, task *Task) {
defer func() {
p.log.Info("finish work",
p.log.Debug("finish work",
zap.Uint32("amount of unfinished replicas", task.quantity),
)
}()
Expand All @@ -67,7 +67,10 @@ func (p *Replicator) HandleTask(ctx context.Context, task *Task) {
default:
}

log := p.log.With(zap.String("node", hex.EncodeToString(task.nodes[i].PublicKey())))
log := p.log.With(
zap.String("node", hex.EncodeToString(task.nodes[i].PublicKey())),
zap.Stringer("object", task.addr),
)

callCtx, cancel := context.WithTimeout(ctx, p.putTimeout)

Expand All @@ -80,7 +83,7 @@ func (p *Replicator) HandleTask(ctx context.Context, task *Task) {
zap.String("error", err.Error()),
)
} else {
log.Info("object successfully replicated")
log.Debug("object successfully replicated")

task.quantity--
}
Expand Down

0 comments on commit 77b6960

Please sign in to comment.