We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 32c05e8 commit ab13cd9Copy full SHA for ab13cd9
les/retrieve.go
@@ -212,11 +212,18 @@ func (r *sentReq) stateRequesting() reqStateFn {
212
// no need to go to stopped state because waiting() already returned false
213
return nil
214
}
215
- case rpSoftTimeout, rpDeliveredInvalid:
+ case rpSoftTimeout:
216
// last request timed out, try asking a new peer
217
go r.tryRequest()
218
r.lastReqQueued = true
219
return r.stateRequesting
220
+ case rpDeliveredInvalid:
221
+ // if it was the last sent request (set to nil by update) then start a new one
222
+ if !r.lastReqQueued && r.lastReqSentTo == nil {
223
+ go r.tryRequest()
224
+ r.lastReqQueued = true
225
+ }
226
+ return r.stateRequesting
227
case rpDeliveredValid:
228
r.stop(nil)
229
return r.stateStopped
0 commit comments