Remove goto
This commit is contained in:
parent
5c884afcf1
commit
6eda884686
@ -75,16 +75,14 @@ func (t treeRemoteGetter) treeRequestLoop(ctx context.Context, retryTimeout time
|
|||||||
if retryTimeout == 0 {
|
if retryTimeout == 0 {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
goto Wait
|
} else {
|
||||||
|
peerIdx = peerIdx % len(availablePeers)
|
||||||
|
msg, err = t.treeRequest(ctx, availablePeers[peerIdx])
|
||||||
|
if err == nil || retryTimeout == 0 {
|
||||||
|
return msg, err
|
||||||
|
}
|
||||||
|
peerIdx++
|
||||||
}
|
}
|
||||||
|
|
||||||
peerIdx = peerIdx % len(availablePeers)
|
|
||||||
msg, err = t.treeRequest(ctx, availablePeers[peerIdx])
|
|
||||||
if err == nil || retryTimeout == 0 {
|
|
||||||
return msg, err
|
|
||||||
}
|
|
||||||
peerIdx++
|
|
||||||
Wait:
|
|
||||||
select {
|
select {
|
||||||
case <-time.After(newRequestTimeout):
|
case <-time.After(newRequestTimeout):
|
||||||
break
|
break
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user