Function TestFindXrayProcessesMultiple

backend/xray/process_unix_test.go:16–48

(t *testing.T)

)

func TestFindXrayProcessesMultiple(t *testing.T) {
	exe := resolveXrayBinary(t)

	const instanceCount = 5
	children := make([]struct {
		pid    int
		waitCh <-chan error
	}, 0, instanceCount)

	for i := 0; i < instanceCount; i++ {
		pid, waitCh := startXrayProcess(t, exe)
		children = append(children, struct {
			pid    int
			waitCh <-chan error
		}{pid: pid, waitCh: waitCh})
	}

	waitForProcesses(exe, children, t)

	for _, c := range children {
		if err := killProcessTree(c.pid); err != nil {
			t.Fatalf("killProcessTree(%d) error: %v", c.pid, err)
		}
	}

	for _, c := range children {
		select {
		case <-c.waitCh:
		case <-time.After(5 * time.Second):
			t.Fatalf("xray process %d did not exit after kill", c.pid)
		}
	}
}

func keys(m map[int]struct{}) []int {
	out := make([]int, 0, len(m))