Commit 48b7d216 authored by Janoš Guljaš's avatar Janoš Guljaš Committed by GitHub

reduce some of very frequent pusher log messages (#299)

parent 4b268c92
...@@ -6,6 +6,7 @@ package pusher ...@@ -6,6 +6,7 @@ package pusher
import ( import (
"context" "context"
"errors"
"time" "time"
"github.com/ethersphere/bee/pkg/logging" "github.com/ethersphere/bee/pkg/logging"
...@@ -96,7 +97,9 @@ func (s *Service) chunksWorker() { ...@@ -96,7 +97,9 @@ func (s *Service) chunksWorker() {
// for now ignoring the receipt and checking only for error // for now ignoring the receipt and checking only for error
_, err = s.pushSyncer.PushChunkToClosest(ctx, ch) _, err = s.pushSyncer.PushChunkToClosest(ctx, ch)
if err != nil { if err != nil {
s.logger.Errorf("pusher: error while sending chunk or receiving receipt: %v", err) if !errors.Is(err, topology.ErrNotFound) {
s.logger.Errorf("pusher: error while sending chunk or receiving receipt: %v", err)
}
continue continue
} }
...@@ -138,7 +141,9 @@ func (s *Service) setChunkAsSynced(ctx context.Context, addr swarm.Address) { ...@@ -138,7 +141,9 @@ func (s *Service) setChunkAsSynced(ctx context.Context, addr swarm.Address) {
s.metrics.TotalChunksSynced.Inc() s.metrics.TotalChunksSynced.Inc()
ta, err := s.tag.GetByAddress(addr) ta, err := s.tag.GetByAddress(addr)
if err != nil { if err != nil {
s.logger.Debugf("pusher: get tag by address %s: %v", addr, err) if !errors.Is(err, tags.TagNotFoundErr) {
s.logger.Debugf("pusher: get tag by address %s: %v", addr, err)
}
// return // until bzz api implements tags dont retunrn here // return // until bzz api implements tags dont retunrn here
} else { } else {
// update the tags only if we get it // update the tags only if we get it
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment