Function targetRejoin

ais/tests/multiproxy_test.go:481–515

targetRejoin kills a random selected target, wait for it to rejoin and verifies it

(t *testing.T)

// targetRejoin kills a random selected target, wait for it to rejoin and verifies it
func targetRejoin(t *testing.T) {
	var (
		id       string
		node     *cluster.Snode
		proxyURL = tutils.RandomProxyURL(t)
	)

	smap := tutils.GetClusterMap(t, proxyURL)
	tlog.Logf("targets: %d, proxies: %d\n", smap.CountActiveTargets(), smap.CountActiveProxies())

	node, _ = smap.GetRandTarget()
	id = node.ID()

	cmd, err := tutils.KillNode(node)
	tassert.CheckFatal(t, err)
	smap, err = tutils.WaitForClusterState(proxyURL, "synchronize on 'target crashed'",
		smap.Version, smap.CountActiveProxies(), smap.CountActiveTargets()-1)
	tassert.CheckFatal(t, err)

	if _, ok := smap.Tmap[id]; ok {
		t.Fatalf("Killed target was not removed from the Smap: %v", id)
	}

	err = tutils.RestoreNode(cmd, false, "target")
	tassert.CheckFatal(t, err)

	smap, err = tutils.WaitForClusterState(proxyURL, "synchronize on 'target rejoined'",
		smap.Version, smap.CountActiveProxies(), smap.CountActiveTargets()+1)
	tassert.CheckFatal(t, err)

	if _, ok := smap.Tmap[id]; !ok {
		t.Fatalf("Restarted target %s did not rejoin the cluster", id)
	}
	tutils.WaitForRebalAndResil(t, tutils.BaseAPIParams(proxyURL))
}

// crashAndFastRestore kills the primary and restores it before a new leader is elected
func crashAndFastRestore(t *testing.T) {