Function targetMapVersionMismatch

ais/tests/multiproxy_test.go:624–650

targetMapVersionMismatch updates map version of a few targets, kill the primary proxy wait for the new leader to come online

(getNum func(int) int, t *testing.T, proxyURL string)

// targetMapVersionMismatch updates map version of a few targets, kill the primary proxy
// wait for the new leader to come online
func targetMapVersionMismatch(getNum func(int) int, t *testing.T, proxyURL string) {
	smap := tutils.GetClusterMap(t, proxyURL)
	tlog.Logf("targets: %d, proxies: %d\n", smap.CountActiveTargets(), smap.CountActiveProxies())

	smap.Version++
	jsonMap, err := jsoniter.Marshal(smap)
	tassert.CheckFatal(t, err)

	n := getNum(smap.CountActiveTargets() + smap.CountActiveProxies() - 1)
	for _, v := range smap.Tmap {
		if n == 0 {
			break
		}
		baseParams := tutils.BaseAPIParams(v.URL(cmn.NetPublic))
		baseParams.Method = http.MethodPut
		reqParams := &api.ReqParams{
			BaseParams: baseParams,
			Path:       apc.URLPathDae.Join(apc.SyncSmap),
			Body:       jsonMap,
			Header:     http.Header{cos.HdrContentType: []string{cos.ContentJSON}},
		}
		err = reqParams.DoHTTPRequest()
		tassert.CheckFatal(t, err)
		n--
	}
	killRestorePrimary(t, proxyURL, false, nil)
}

// concurrentPutGetDel does put/get/del sequence against all proxies concurrently
func concurrentPutGetDel(t *testing.T) {