Function _waitMapVersionSync

devtools/tutils/node.go:738–789

(baseParams api.BaseParams, ctx *Ctx, timeout time.Time, smap *cluster.Smap, prevVersion int64,
	idsToIgnore cos.StringSet)

}

func _waitMapVersionSync(baseParams api.BaseParams, ctx *Ctx, timeout time.Time, smap *cluster.Smap, prevVersion int64,
	idsToIgnore cos.StringSet) error {
	var (
		prevSid string
		orig    = idsToIgnore.Clone()
	)
	for {
		sid, _, exists := _nextNode(smap, idsToIgnore)
		if !exists {
			break
		}
		if sid == prevSid {
			time.Sleep(time.Second)
		}
		daemonSmap, err := api.GetNodeClusterMap(baseParams, sid)
		if err != nil && !cos.IsRetriableConnErr(err) &&
			!cmn.IsStatusServiceUnavailable(err) && !cmn.IsStatusBadGateway(err) /* retry as well */ {
			return err
		}
		if err == nil && daemonSmap.Version > prevVersion {
			idsToIgnore.Add(sid)
			if daemonSmap.Version > smap.Version {
				*smap = *daemonSmap
			}
			if daemonSmap.Version > prevVersion+1 {
				// update Smap to a newer version and restart waiting
				if prevVersion < 0 {
					ctx.Log("%s (from node %s)\n", daemonSmap.StringEx(), sid)
				} else {
					ctx.Log("Updating Smap v%d to %s (from node %s)\n", prevVersion, daemonSmap.StringEx(), sid)
				}
				*smap = *daemonSmap
				prevVersion = smap.Version - 1
				idsToIgnore = orig.Clone()
				idsToIgnore.Add(sid)
			}
			continue
		}
		if time.Now().After(timeout) {
			return fmt.Errorf("timed out waiting for node %s to sync Smap > v%d", sid, prevVersion)
		}
		if daemonSmap != nil {
			if snode := daemonSmap.GetNode(sid); snode != nil {
				ctx.Log("Waiting for %s(%s) to sync Smap > v%d\n", snode.StringEx(), daemonSmap, prevVersion)
			} else {
				ctx.Log("Waiting for node %s(%s) to sync Smap > v%d\n", sid, daemonSmap, prevVersion)
			}
		}
		prevSid = sid
	}
	return nil
}

// Quick remove node from SMap
func _removeNodeFromSmap(ctx *Ctx, proxyURL, sid string, timeout time.Duration) error {