Function TestForkReapExitCodes

agent/reaper/reaper_test.go:128–165

nolint:tparallel // Subtests must be sequential, each starts its own reaper.

(t *testing.T)

//nolint:tparallel // Subtests must be sequential, each starts its own reaper.
func TestForkReapExitCodes(t *testing.T) {
	t.Parallel()
	if testutil.InCI() {
		t.Skip("Detected CI, skipping reaper tests")
	}
	if !runSubprocess(t) {
		return
	}

	tests := []struct {
		name         string
		command      string
		expectedCode int
	}{
		{"exit 0", "exit 0", 0},
		{"exit 1", "exit 1", 1},
		{"exit 42", "exit 42", 42},
		{"exit 255", "exit 255", 255},
		{"SIGKILL", "kill -9 $$", 128 + 9},
		{"SIGTERM", "kill -15 $$", 128 + 15},
	}

	//nolint:paralleltest // Subtests must be sequential, each starts its own reaper.
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			var reapLock sync.RWMutex
			opts := append([]reaper.Option{
				reaper.WithExecArgs("/bin/sh", "-c", tt.command),
				reaper.WithReapLock(&reapLock),
			}, withDone(t)...)
			reapLock.RLock()
			exitCode, err := reaper.ForkReap(opts...)
			reapLock.RUnlock()
			require.NoError(t, err)
			require.Equal(t, tt.expectedCode, exitCode, "exit code mismatch for %q", tt.command)
		})
	}
}

// TestReapInterrupt verifies that ForkReap forwards caught signals
// to the child process. The test sends SIGINT to its own process