Function TestWindowsHostProcess

integration/windows_hostprocess_test.go:48–99

Tests to verify the Windows HostProcess

(t *testing.T)

// Tests to verify the Windows HostProcess
func TestWindowsHostProcess(t *testing.T) {
	pauseImage := images.Get(images.Pause)
	EnsureImageExists(t, pauseImage)

	t.Run("run as Local Service", func(t *testing.T) {
		runHostProcess(t, false, pauseImage, defaultAction, hpcContainerOpt, localServiceUsername, defaultCommand)
	})
	t.Run("run as Local System", func(t *testing.T) {
		runHostProcess(t, false, pauseImage, defaultAction, hpcContainerOpt, localSystemUsername, defaultCommand)
	})
	t.Run("run as unacceptable user", func(t *testing.T) {
		runHostProcess(t, true, pauseImage, defaultAction, hpcContainerOpt, WithWindowsUsername("Guest"), defaultCommand)
	})
	t.Run("run command on host", func(t *testing.T) {
		cmd := WithCommand("Powershell", "/c", "Get-Command containerd.exe")
		runHostProcess(t, false, pauseImage, defaultAction, hpcContainerOpt, localServiceUsername, cmd)
	})
	t.Run("run withHostNetwork", func(t *testing.T) {
		hostname, err := os.Hostname()
		require.NoError(t, err)
		cmd := WithCommand("Powershell", "/c", fmt.Sprintf("if ($env:COMPUTERNAME -ne %s) { exit -1 }", hostname))
		runHostProcess(t, false, pauseImage, defaultAction, hpcContainerOpt, localServiceUsername, cmd)
	})
	t.Run("run with a different os.version image", func(t *testing.T) {
		image := "docker.io/e2eteam/busybox:1.29-windows-amd64-1909"
		EnsureImageExists(t, image)
		runHostProcess(t, false, image, defaultAction, hpcContainerOpt, localServiceUsername, defaultCommand)
	})
	t.Run("run and check stats", func(t *testing.T) {
		var stats = func(t *testing.T, containerID string, containerConfig *v1.ContainerConfig) {
			t.Logf("Fetch stats for container")
			var (
				s   *runtime.ContainerStats
				err error
			)
			require.NoError(t, Eventually(func() (bool, error) {
				s, err = runtimeService.ContainerStats(containerID)
				if err != nil {
					return false, err
				}
				if s.GetWritableLayer().GetUsedBytes().GetValue() != 0 {
					return true, nil
				}
				return false, nil
			}, time.Second, 30*time.Second))

			t.Logf("Verify stats received for container %q", containerConfig)
			testStats(t, s, containerConfig)
		}
		runHostProcess(t, false, pauseImage, stats, hpcContainerOpt, localServiceUsername, defaultCommand, WithTestAnnotations(), WithTestLabels())
	})
}

func runHostProcess(t *testing.T, expectErr bool, image string, action hpcAction, opts ...ContainerOpts) {
	t.Logf("Create a pod config and run sandbox container")