From 22b702fcda89d7f83693e137ebb925553577d376 Mon Sep 17 00:00:00 2001
From: Nuno Cruces <ncruces@users.noreply.github.com>
Date: Mon, 13 Feb 2023 15:16:58 +0000
Subject: [PATCH] Synchronize IPC test.

---
 tests/parallel_test.go | 20 ++++++++++++++++----
 1 file changed, 16 insertions(+), 4 deletions(-)

diff --git a/tests/parallel_test.go b/tests/parallel_test.go
index 347cf80..1c4a4c9 100644
--- a/tests/parallel_test.go
+++ b/tests/parallel_test.go
@@ -1,6 +1,7 @@
 package tests
 
 import (
+	"io"
 	"os"
 	"os/exec"
 	"path/filepath"
@@ -13,7 +14,7 @@ import (
 )
 
 func TestParallel(t *testing.T) {
-	testParallel(t, t.TempDir(), 50)
+	testParallel(t, t.TempDir(), 100)
 }
 
 func TestMultiProcess(t *testing.T) {
@@ -23,12 +24,23 @@ func TestMultiProcess(t *testing.T) {
 
 	dir := t.TempDir()
 	t.Setenv("TestParallel_dir", dir)
-	cmd := exec.Command("go", "test", "-run", "TestChildProcess")
+	cmd := exec.Command("go", "test", "-v", "-run", "TestChildProcess")
+	cmd.Stderr = os.Stderr
+	out, err := cmd.StdoutPipe()
+	if err != nil {
+		t.Fatal(err)
+	}
 	if err := cmd.Start(); err != nil {
 		t.Fatal(err)
 	}
 
-	testParallel(t, dir, 500)
+	var buf [3]byte
+	// Wait for child to start.
+	if _, err := io.ReadFull(out, buf[:]); err != nil || string(buf[:]) != "===" {
+		t.Fatal(err)
+	}
+
+	testParallel(t, dir, 1000)
 	cmd.Wait()
 }
 
@@ -38,7 +50,7 @@ func TestChildProcess(t *testing.T) {
 		return
 	}
 
-	testParallel(t, dir, 500)
+	testParallel(t, dir, 1000)
 }
 
 func testParallel(t *testing.T, dir string, n int) {