Function TestFilesAreNonblocking

process_test.go:14–57

(t *testing.T)

)

func TestFilesAreNonblocking(t *testing.T) {
	pipe := func() (r, w *os.File) {
		r, w, err := os.Pipe()
		if err != nil {
			t.Fatal(err)
		}
		t.Cleanup(func() {
			r.Close()
			w.Close()
		})
		return r, w
	}

	// Set up our own blocking stdin since CI runs tests with stdin closed.
	rStdin, _ := pipe()
	rStdin.Fd()

	r, _ := pipe()
	if !isNonblock(t, r) {
		t.Fatal("Read pipe is blocking")
	}

	proc, err := newOSProcess("cat", nil, []*os.File{rStdin, os.Stdout, os.Stderr, r}, nil)
	if err != nil {
		t.Fatal(err)
	}

	if err := proc.Signal(os.Kill); err != nil {
		t.Fatal("Can't signal:", err)
	}

	var exitErr *exec.ExitError
	if err := proc.Wait(); !errors.As(err, &exitErr) {
		t.Fatalf("Wait should return an ExitError after sending os.Kill, have %T: %s", err, err)
	}

	if err := proc.Wait(); err == nil {
		t.Fatal("Waiting a second time should return an error")
	}

	if !isNonblock(t, r) {
		t.Fatal("Read pipe is blocking after newOSProcess")
	}
}

func TestArgumentsArePassedCorrectly(t *testing.T) {
	proc, err := newOSProcess("printf", []string{""}, []*os.File{os.Stdin, os.Stdout, os.Stderr}, nil)