// +build !windows package rawexec import ( "context" "os" "regexp" "runtime" "strconv" "syscall" "testing" "fmt" "io/ioutil" "path/filepath" "strings" "time" "github.com/hashicorp/nomad/helper/testtask" "github.com/hashicorp/nomad/helper/uuid" basePlug "github.com/hashicorp/nomad/plugins/base" "github.com/hashicorp/nomad/plugins/drivers" dtestutil "github.com/hashicorp/nomad/plugins/drivers/testutils" "github.com/hashicorp/nomad/testutil" "github.com/stretchr/testify/require" "golang.org/x/sys/unix" ) func TestRawExecDriver_User(t *testing.T) { t.Parallel() if runtime.GOOS != "linux" { t.Skip("Linux only test") } require := require.New(t) d := newEnabledRawExecDriver(t) harness := dtestutil.NewDriverHarness(t, d) task := &drivers.TaskConfig{ ID: uuid.Generate(), Name: "sleep", User: "alice", } cleanup := harness.MkAllocDir(task, false) defer cleanup() tc := &TaskConfig{ Command: testtask.Path(), Args: []string{"sleep", "45s"}, } require.NoError(task.EncodeConcreteDriverConfig(&tc)) testtask.SetTaskConfigEnv(task) _, _, err := harness.StartTask(task) require.Error(err) msg := "unknown user alice" require.Contains(err.Error(), msg) } func TestRawExecDriver_Signal(t *testing.T) { t.Parallel() if runtime.GOOS != "linux" { t.Skip("Linux only test") } require := require.New(t) d := newEnabledRawExecDriver(t) harness := dtestutil.NewDriverHarness(t, d) task := &drivers.TaskConfig{ ID: uuid.Generate(), Name: "signal", } cleanup := harness.MkAllocDir(task, true) defer cleanup() tc := &TaskConfig{ Command: "/bin/bash", Args: []string{"test.sh"}, } require.NoError(task.EncodeConcreteDriverConfig(&tc)) testtask.SetTaskConfigEnv(task) testFile := filepath.Join(task.TaskDir().Dir, "test.sh") testData := []byte(` at_term() { echo 'Terminated.' exit 3 } trap at_term USR1 while true; do sleep 1 done `) require.NoError(ioutil.WriteFile(testFile, testData, 0777)) _, _, err := harness.StartTask(task) require.NoError(err) go func() { time.Sleep(100 * time.Millisecond) require.NoError(harness.SignalTask(task.ID, "SIGUSR1")) }() // Task should terminate quickly waitCh, err := harness.WaitTask(context.Background(), task.ID) require.NoError(err) select { case res := <-waitCh: require.False(res.Successful()) require.Equal(3, res.ExitCode) case <-time.After(time.Duration(testutil.TestMultiplier()*6) * time.Second): require.Fail("WaitTask timeout") } // Check the log file to see it exited because of the signal outputFile := filepath.Join(task.TaskDir().LogDir, "signal.stdout.0") exp := "Terminated." testutil.WaitForResult(func() (bool, error) { act, err := ioutil.ReadFile(outputFile) if err != nil { return false, fmt.Errorf("Couldn't read expected output: %v", err) } if strings.TrimSpace(string(act)) != exp { t.Logf("Read from %v", outputFile) return false, fmt.Errorf("Command outputted %v; want %v", act, exp) } return true, nil }, func(err error) { require.NoError(err) }) } func TestRawExecDriver_StartWaitStop(t *testing.T) { t.Parallel() require := require.New(t) d := newEnabledRawExecDriver(t) harness := dtestutil.NewDriverHarness(t, d) defer harness.Kill() // Disable cgroups so test works without root config := &Config{NoCgroups: true, Enabled: true} var data []byte require.NoError(basePlug.MsgPackEncode(&data, config)) bconfig := &basePlug.Config{PluginConfig: data} require.NoError(harness.SetConfig(bconfig)) task := &drivers.TaskConfig{ ID: uuid.Generate(), Name: "test", } taskConfig := map[string]interface{}{} taskConfig["command"] = testtask.Path() taskConfig["args"] = []string{"sleep", "100s"} require.NoError(task.EncodeConcreteDriverConfig(&taskConfig)) cleanup := harness.MkAllocDir(task, false) defer cleanup() handle, _, err := harness.StartTask(task) require.NoError(err) ch, err := harness.WaitTask(context.Background(), handle.Config.ID) require.NoError(err) require.NoError(harness.WaitUntilStarted(task.ID, 1*time.Second)) go func() { harness.StopTask(task.ID, 2*time.Second, "SIGINT") }() select { case result := <-ch: require.Equal(int(unix.SIGINT), result.Signal) case <-time.After(10 * time.Second): require.Fail("timeout waiting for task to shutdown") } // Ensure that the task is marked as dead, but account // for WaitTask() closing channel before internal state is updated testutil.WaitForResult(func() (bool, error) { status, err := harness.InspectTask(task.ID) if err != nil { return false, fmt.Errorf("inspecting task failed: %v", err) } if status.State != drivers.TaskStateExited { return false, fmt.Errorf("task hasn't exited yet; status: %v", status.State) } return true, nil }, func(err error) { require.NoError(err) }) require.NoError(harness.DestroyTask(task.ID, true)) } // TestRawExecDriver_DestroyKillsAll asserts that when TaskDestroy is called all // task processes are cleaned up. func TestRawExecDriver_DestroyKillsAll(t *testing.T) { t.Parallel() // This only works reliably with cgroup PID tracking, happens in linux only if runtime.GOOS != "linux" { t.Skip("Linux only test") } require := require.New(t) d := newEnabledRawExecDriver(t) harness := dtestutil.NewDriverHarness(t, d) defer harness.Kill() task := &drivers.TaskConfig{ ID: uuid.Generate(), Name: "test", } cleanup := harness.MkAllocDir(task, true) defer cleanup() taskConfig := map[string]interface{}{} taskConfig["command"] = "/bin/sh" taskConfig["args"] = []string{"-c", fmt.Sprintf(`sleep 3600 & echo "SLEEP_PID=$!"`)} require.NoError(task.EncodeConcreteDriverConfig(&taskConfig)) handle, _, err := harness.StartTask(task) require.NoError(err) defer harness.DestroyTask(task.ID, true) ch, err := harness.WaitTask(context.Background(), handle.Config.ID) require.NoError(err) select { case result := <-ch: require.True(result.Successful(), "command failed: %#v", result) case <-time.After(10 * time.Second): require.Fail("timeout waiting for task to shutdown") } sleepPid := 0 // Ensure that the task is marked as dead, but account // for WaitTask() closing channel before internal state is updated testutil.WaitForResult(func() (bool, error) { stdout, err := ioutil.ReadFile(filepath.Join(task.TaskDir().LogDir, "test.stdout.0")) if err != nil { return false, fmt.Errorf("failed to output pid file: %v", err) } pidMatch := regexp.MustCompile(`SLEEP_PID=(\d+)`).FindStringSubmatch(string(stdout)) if len(pidMatch) != 2 { return false, fmt.Errorf("failed to find pid in %s", string(stdout)) } pid, err := strconv.Atoi(pidMatch[1]) if err != nil { return false, fmt.Errorf("pid parts aren't int: %s", pidMatch[1]) } sleepPid = pid return true, nil }, func(err error) { require.NoError(err) }) // isProcessRunning returns an error if process is not running isProcessRunning := func(pid int) error { process, err := os.FindProcess(pid) if err != nil { return fmt.Errorf("failed to find process: %s", err) } err = process.Signal(syscall.Signal(0)) if err != nil { return fmt.Errorf("failed to signal process: %s", err) } return nil } require.NoError(isProcessRunning(sleepPid)) require.NoError(harness.DestroyTask(task.ID, true)) testutil.WaitForResult(func() (bool, error) { err := isProcessRunning(sleepPid) if err == nil { return false, fmt.Errorf("child process is still running") } if !strings.Contains(err.Error(), "failed to signal process") { return false, fmt.Errorf("unexpected error: %v", err) } return true, nil }, func(err error) { require.NoError(err) }) } func TestRawExec_ExecTaskStreaming(t *testing.T) { t.Parallel() if runtime.GOOS == "darwin" { t.Skip("skip running exec tasks on darwin as darwin has restrictions on starting tty shells") } require := require.New(t) d := newEnabledRawExecDriver(t) harness := dtestutil.NewDriverHarness(t, d) defer harness.Kill() task := &drivers.TaskConfig{ ID: uuid.Generate(), Name: "sleep", } cleanup := harness.MkAllocDir(task, false) defer cleanup() tc := &TaskConfig{ Command: testtask.Path(), Args: []string{"sleep", "9000s"}, } require.NoError(task.EncodeConcreteDriverConfig(&tc)) testtask.SetTaskConfigEnv(task) _, _, err := harness.StartTask(task) require.NoError(err) defer d.DestroyTask(task.ID, true) dtestutil.ExecTaskStreamingConformanceTests(t, harness, task.ID) }