Update responsible peers
This commit is contained in:
parent
086b99ede2
commit
47297d8988
@ -129,6 +129,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