Skip to content

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

puller: exit on nextInterval error (#414)

parent 4bae1a0e
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 5 deletions
pkg/puller/puller.go
View file @ 0bc0be56
...@@ -385,11 +385,7 @@ func (p *Puller) histSyncWorker(ctx context.Context, peer swarm.Address, bin uin ...@@ -385,11 +385,7 @@ func (p *Puller) histSyncWorker(ctx context.Context, peer swarm.Address, bin uin
s, _, _, err := p.nextPeerInterval(peer, bin) s, _, _, err := p.nextPeerInterval(peer, bin)
if err != nil { if err != nil {
p.logger.Debugf("histSyncWorker nextPeerInterval: %v", err) p.logger.Debugf("histSyncWorker nextPeerInterval: %v", err)
// wait and retry? this is a local error return
// maybe just quit the peer entirely.
// not sure how to do this
<-time.After(30 * time.Second)
continue
} }
if s > cur { if s > cur {
if logMore { if logMore {
......
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