aboutsummaryrefslogtreecommitdiffstats
path: root/les/retrieve.go
diff options
context:
space:
mode:
Diffstat (limited to 'les/retrieve.go')
-rw-r--r--les/retrieve.go9
1 files changed, 8 insertions, 1 deletions
diff --git a/les/retrieve.go b/les/retrieve.go
index c3d788813..d77cfea74 100644
--- a/les/retrieve.go
+++ b/les/retrieve.go
@@ -212,11 +212,18 @@ func (r *sentReq) stateRequesting() reqStateFn {
// no need to go to stopped state because waiting() already returned false
return nil
}
- case rpSoftTimeout, rpDeliveredInvalid:
+ case rpSoftTimeout:
// last request timed out, try asking a new peer
go r.tryRequest()
r.lastReqQueued = true
return r.stateRequesting
+ case rpDeliveredInvalid:
+ // if it was the last sent request (set to nil by update) then start a new one
+ if !r.lastReqQueued && r.lastReqSentTo == nil {
+ go r.tryRequest()
+ r.lastReqQueued = true
+ }
+ return r.stateRequesting
case rpDeliveredValid:
r.stop(nil)
return r.stateStopped