Function _removeNodeFromSmap

devtools/tutils/node.go:792–817

Quick remove node from SMap

(ctx *Ctx, proxyURL, sid string, timeout time.Duration)

// Quick remove node from SMap
func _removeNodeFromSmap(ctx *Ctx, proxyURL, sid string, timeout time.Duration) error {
	var (
		baseParams = api.BaseParams{Client: ctx.Client, URL: proxyURL, Token: LoggedUserToken}
		smap, err  = api.GetClusterMap(baseParams)
		node       = smap.GetNode(sid)
	)
	if err != nil {
		return fmt.Errorf("api.GetClusterMap failed, err: %v", err)
	}
	if node != nil && smap.IsPrimary(node) {
		return fmt.Errorf("unregistering primary proxy is not allowed")
	}
	tlog.Logf("Remove %s from %s\n", node.StringEx(), smap)

	err = api.RemoveNodeFromSmap(baseParams, sid)
	if err != nil {
		return err
	}

	// If node does not exist in cluster we should not wait for map version
	// sync because update will not be scheduled.
	if node != nil {
		return _waitMapVersionSync(baseParams, ctx, time.Now().Add(timeout), smap, smap.Version, cos.NewStringSet(node.ID()))
	}
	return nil
}