Skip to content

M
mybee
Commit f2944470 authored by acud's avatar acud Committed by GitHub
Browse files
Options

refactor: puller always send cancel ruid (#1888)

parent 85b36366
Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 2 deletions
pkg/puller/puller.go
View file @ f2944470
...@@ -354,7 +354,6 @@ func (p *Puller) histSyncWorker(ctx context.Context, peer swarm.Address, bin uin ...@@ -354,7 +354,6 @@ func (p *Puller) histSyncWorker(ctx context.Context, peer swarm.Address, bin uin
} }
if ruid == 0 { if ruid == 0 {
p.metrics.HistWorkerErrCounter.Inc() p.metrics.HistWorkerErrCounter.Inc()
return
} }
if err := p.syncer.CancelRuid(ctx, peer, ruid); err != nil && logMore { if err := p.syncer.CancelRuid(ctx, peer, ruid); err != nil && logMore {
p.logger.Debugf("histSyncWorker cancel ruid: %v", err) p.logger.Debugf("histSyncWorker cancel ruid: %v", err)
...@@ -401,7 +400,6 @@ func (p *Puller) liveSyncWorker(ctx context.Context, peer swarm.Address, bin uin ...@@ -401,7 +400,6 @@ func (p *Puller) liveSyncWorker(ctx context.Context, peer swarm.Address, bin uin
} }
if ruid == 0 { if ruid == 0 {
p.metrics.LiveWorkerErrCounter.Inc() p.metrics.LiveWorkerErrCounter.Inc()
return
} }
if err := p.syncer.CancelRuid(ctx, peer, ruid); err != nil && logMore { if err := p.syncer.CancelRuid(ctx, peer, ruid); err != nil && logMore {
p.logger.Debugf("histSyncWorker cancel ruid: %v", err) p.logger.Debugf("histSyncWorker cancel ruid: %v", err)
......
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