Update responsible peers
This commit is contained in:
parent
2da9f84907
commit
fad981daee
@ -134,6 +134,11 @@ func BuildSyncTreeOrGetRemote(ctx context.Context, id string, deps BuildDeps) (t
|
|||||||
if err == nil {
|
if err == nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
// updating peers in case new peers arrived while we were waiting
|
||||||
|
availablePeers, err = getPeers(ctx)
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
peerIdx++
|
peerIdx++
|
||||||
select {
|
select {
|
||||||
case <-ctx.Done():
|
case <-ctx.Done():
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user