Function TestReload100Pods

integration/restart_linux_test.go:84–126

(t *testing.T)

}

func TestReload100Pods(t *testing.T) {
	workDir := t.TempDir()

	currentReleaseCtrdDefaultConfig(t, workDir)

	ctrd := newCtrdProc(t, *containerdBin, workDir, []string{})

	logPath := ctrd.logPath()
	t.Cleanup(func() {
		if t.Failed() {
			dumpFileContent(t, logPath)
		}

		t.Log("Ensure there is no leaky state dir after test")
		assert.NoError(t, os.Remove(filepath.Join(workDir, "state", "io.containerd.runtime.v2.task", "k8s.io")))
	})
	require.NoError(t, ctrd.isReady())

	podCtxs := []*podTCtx{}
	defer func() {
		for _, p := range podCtxs {
			p.stop(true)
		}
		assert.NoError(t, ctrd.kill(syscall.SIGTERM))
		assert.NoError(t, ctrd.wait(5*time.Minute))
	}()

	for i := range 100 {
		podCtx := newPodTCtx(t,
			ctrd.criRuntimeService(t),
			fmt.Sprintf("test-restart-%d", i),
			"sandbox",
			WithHostNetwork)

		podCtxs = append(podCtxs, podCtx)
	}

	assert.NoError(t, ctrd.kill(syscall.SIGTERM))
	assert.NoError(t, ctrd.wait(5*time.Minute))

	ctrd = newCtrdProc(t, *containerdBin, workDir, []string{})
	require.NoError(t, ctrd.isReady())
}