go/sqlite3
1
0
Fork 0
mirror of https://github.com/ncruces/go-sqlite3.git synced 2026-01-12 05:59:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Synchronize IPC test.

Browse Source
This commit is contained in:
Nuno Cruces
2023-02-13 15:16:58 +00:00
parent 831817a737
commit 22b702fcda
1 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
tests/parallel_test.go
View File

@@ -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) {