Function TestOOMEventMonitor

integration/oom_linux_test.go:35–139

(t *testing.T)

)

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

	rawCfg := fmt.Sprintf(`
version = 3

[plugins.'io.containerd.cri.v1.runtime'.containerd.runtimes.runc]
  runtime_type = "io.containerd.runc.v2"
  runtime_path = "%s/containerd-shim-runc-v2"
`, *buildDir)

	err := os.WriteFile(
		filepath.Join(workDir, "config.toml"),
		[]byte(rawCfg),
		0600,
	)
	require.NoError(t, err, "failed to create config")

	ctrd := newCtrdProc(t, filepath.Join(*buildDir, "containerd"), workDir, []string{})

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

	var busyboxImage = images.Get(images.BusyBox)
	pullImagesByCRI(t, ctrd.criImageService(t), busyboxImage)

	n := 8
	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))
	}()

	t.Logf("Creating %d pod sandboxes", n)
	for i := range n {
		podCtx := newPodTCtx(t,
			ctrd.criRuntimeService(t),
			fmt.Sprintf("test-oom-event-%d", i),
			"sandbox",
			WithHostNetwork)
		podCtxs = append(podCtxs, podCtx)
	}

	for round := range 10 {
		if t.Failed() {
			break
		}