Fix testsv2.5.0-alpha.1

Signed-off-by: Valery Piashchynski <[email protected]>

2 files changed, 35 insertions, 35 deletions

diff --git a/transport/socket/socket_factory_spawn_test.go b/transport/socket/socket_factory_spawn_test.go
index aa5b811c..363a3510 100644
--- a/transport/socket/socket_factory_spawn_test.go
+++ b/transport/socket/socket_factory_spawn_test.go
@@ -28,7 +28,7 @@ func Test_Tcp_Start2(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorker(cmd)
 	assert.NoError(t, err)
@@ -51,7 +51,7 @@ func Test_Tcp_StartCloseFactory2(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 	f := NewSocketServer(ls, time.Minute)
 	defer func() {
@@ -84,7 +84,7 @@ func Test_Tcp_StartError2(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "pipes")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "pipes")
 	err = cmd.Start()
 	if err != nil {
 		t.Errorf("error executing the command: error %v", err)
@@ -108,7 +108,7 @@ func Test_Tcp_Failboot2(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/failboot.php")
+	cmd := exec.Command("php", "../../tests/failboot.php")
 
 	finish := make(chan struct{}, 10)
 	listener := func(event interface{}) {
@@ -140,7 +140,7 @@ func Test_Tcp_Invalid2(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/invalid.php")
+	cmd := exec.Command("php", "../../tests/invalid.php")
 
 	w, err := NewSocketServer(ls, time.Second*1).SpawnWorker(cmd)
 	assert.Error(t, err)
@@ -160,7 +160,7 @@ func Test_Tcp_Broken2(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "broken", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "broken", "tcp")
 
 	finish := make(chan struct{}, 10)
 	listener := func(event interface{}) {
@@ -214,7 +214,7 @@ func Test_Tcp_Echo2(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 	w, _ := NewSocketServer(ls, time.Minute).SpawnWorker(cmd)
 	go func() {
@@ -247,7 +247,7 @@ func Test_Unix_Start2(t *testing.T) {
 		assert.NoError(t, err)
 	}()
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "unix")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "unix")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorker(cmd)
 	assert.NoError(t, err)
@@ -271,7 +271,7 @@ func Test_Unix_Failboot2(t *testing.T) {
 		assert.NoError(t, err)
 	}()
 
-	cmd := exec.Command("php", "../../../tests/failboot.php")
+	cmd := exec.Command("php", "../../tests/failboot.php")
 
 	finish := make(chan struct{}, 10)
 	listener := func(event interface{}) {
@@ -298,7 +298,7 @@ func Test_Unix_Timeout2(t *testing.T) {
 		assert.NoError(t, err)
 	}()
 
-	cmd := exec.Command("php", "../../../tests/slow-client.php", "echo", "unix", "200", "0")
+	cmd := exec.Command("php", "../../tests/slow-client.php", "echo", "unix", "200", "0")
 
 	w, err := NewSocketServer(ls, time.Millisecond*100).SpawnWorker(cmd)
 	assert.Nil(t, w)
@@ -314,7 +314,7 @@ func Test_Unix_Invalid2(t *testing.T) {
 		assert.NoError(t, err)
 	}()
 
-	cmd := exec.Command("php", "../../../tests/invalid.php")
+	cmd := exec.Command("php", "../../tests/invalid.php")
 
 	w, err := NewSocketServer(ls, time.Second*10).SpawnWorker(cmd)
 	assert.Error(t, err)
@@ -329,7 +329,7 @@ func Test_Unix_Broken2(t *testing.T) {
 		assert.NoError(t, errC)
 	}()
 
-	cmd := exec.Command("php", "../../../tests/client.php", "broken", "unix")
+	cmd := exec.Command("php", "../../tests/client.php", "broken", "unix")
 
 	finish := make(chan struct{}, 10)
 	listener := func(event interface{}) {
@@ -378,7 +378,7 @@ func Test_Unix_Echo2(t *testing.T) {
 		assert.NoError(t, err)
 	}()
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "unix")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "unix")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorker(cmd)
 	if err != nil {
@@ -416,7 +416,7 @@ func Benchmark_Tcp_SpawnWorker_Stop2(b *testing.B) {
 
 	f := NewSocketServer(ls, time.Minute)
 	for n := 0; n < b.N; n++ {
-		cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+		cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 		w, err := f.SpawnWorker(cmd)
 		if err != nil {
@@ -441,7 +441,7 @@ func Benchmark_Tcp_Worker_ExecEcho2(b *testing.B) {
 		assert.NoError(b, err)
 	}()
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorker(cmd)
 	if err != nil {
@@ -481,7 +481,7 @@ func Benchmark_Unix_SpawnWorker_Stop2(b *testing.B) {
 
 	f := NewSocketServer(ls, time.Minute)
 	for n := 0; n < b.N; n++ {
-		cmd := exec.Command("php", "../../../tests/client.php", "echo", "unix")
+		cmd := exec.Command("php", "../../tests/client.php", "echo", "unix")
 
 		w, err := f.SpawnWorker(cmd)
 		if err != nil {
@@ -510,7 +510,7 @@ func Benchmark_Unix_Worker_ExecEcho2(b *testing.B) {
 		b.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "unix")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "unix")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorker(cmd)
 	if err != nil {
diff --git a/transport/socket/socket_factory_test.go b/transport/socket/socket_factory_test.go
index 36abecf9..879dba8e 100755
--- a/transport/socket/socket_factory_test.go
+++ b/transport/socket/socket_factory_test.go
@@ -31,7 +31,7 @@ func Test_Tcp_Start(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorkerWithTimeout(ctx, cmd)
 	assert.NoError(t, err)
@@ -56,7 +56,7 @@ func Test_Tcp_StartCloseFactory(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 	f := NewSocketServer(ls, time.Minute)
 	defer func() {
@@ -93,7 +93,7 @@ func Test_Tcp_StartError(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "pipes")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "pipes")
 	err = cmd.Start()
 	if err != nil {
 		t.Errorf("error executing the command: error %v", err)
@@ -122,7 +122,7 @@ func Test_Tcp_Failboot(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/failboot.php")
+	cmd := exec.Command("php", "../../tests/failboot.php")
 
 	finish := make(chan struct{}, 10)
 	listener := func(event interface{}) {
@@ -156,7 +156,7 @@ func Test_Tcp_Timeout(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/slow-client.php", "echo", "tcp", "200", "0")
+	cmd := exec.Command("php", "../../tests/slow-client.php", "echo", "tcp", "200", "0")
 
 	w, err := NewSocketServer(ls, time.Millisecond*1).SpawnWorkerWithTimeout(ctx, cmd)
 	assert.Nil(t, w)
@@ -179,7 +179,7 @@ func Test_Tcp_Invalid(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/invalid.php")
+	cmd := exec.Command("php", "../../tests/invalid.php")
 
 	w, err := NewSocketServer(ls, time.Second*1).SpawnWorkerWithTimeout(ctx, cmd)
 	assert.Error(t, err)
@@ -201,7 +201,7 @@ func Test_Tcp_Broken(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "broken", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "broken", "tcp")
 
 	finish := make(chan struct{}, 10)
 	listener := func(event interface{}) {
@@ -257,7 +257,7 @@ func Test_Tcp_Echo(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 	w, _ := NewSocketServer(ls, time.Minute).SpawnWorkerWithTimeout(ctx, cmd)
 	go func() {
@@ -296,7 +296,7 @@ func Test_Unix_Start(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "unix")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "unix")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorkerWithTimeout(ctx, cmd)
 	assert.NoError(t, err)
@@ -326,7 +326,7 @@ func Test_Unix_Failboot(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/failboot.php")
+	cmd := exec.Command("php", "../../tests/failboot.php")
 
 	finish := make(chan struct{}, 10)
 	listener := func(event interface{}) {
@@ -359,7 +359,7 @@ func Test_Unix_Timeout(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/slow-client.php", "echo", "unix", "200", "0")
+	cmd := exec.Command("php", "../../tests/slow-client.php", "echo", "unix", "200", "0")
 
 	w, err := NewSocketServer(ls, time.Millisecond*100).SpawnWorkerWithTimeout(ctx, cmd)
 	assert.Nil(t, w)
@@ -381,7 +381,7 @@ func Test_Unix_Invalid(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/invalid.php")
+	cmd := exec.Command("php", "../../tests/invalid.php")
 
 	w, err := NewSocketServer(ls, time.Second*10).SpawnWorkerWithTimeout(ctx, cmd)
 	assert.Error(t, err)
@@ -402,7 +402,7 @@ func Test_Unix_Broken(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "broken", "unix")
+	cmd := exec.Command("php", "../../tests/client.php", "broken", "unix")
 
 	block := make(chan struct{}, 10)
 	listener := func(event interface{}) {
@@ -459,7 +459,7 @@ func Test_Unix_Echo(t *testing.T) {
 		t.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "unix")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "unix")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorkerWithTimeout(ctx, cmd)
 	if err != nil {
@@ -503,7 +503,7 @@ func Benchmark_Tcp_SpawnWorker_Stop(b *testing.B) {
 
 	f := NewSocketServer(ls, time.Minute)
 	for n := 0; n < b.N; n++ {
-		cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+		cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 		w, err := f.SpawnWorkerWithTimeout(ctx, cmd)
 		if err != nil {
@@ -534,7 +534,7 @@ func Benchmark_Tcp_Worker_ExecEcho(b *testing.B) {
 		b.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "tcp")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "tcp")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorkerWithTimeout(ctx, cmd)
 	if err != nil {
@@ -572,7 +572,7 @@ func Benchmark_Unix_SpawnWorker_Stop(b *testing.B) {
 
 	f := NewSocketServer(ls, time.Minute)
 	for n := 0; n < b.N; n++ {
-		cmd := exec.Command("php", "../../../tests/client.php", "echo", "unix")
+		cmd := exec.Command("php", "../../tests/client.php", "echo", "unix")
 
 		w, err := f.SpawnWorkerWithTimeout(ctx, cmd)
 		if err != nil {
@@ -599,7 +599,7 @@ func Benchmark_Unix_Worker_ExecEcho(b *testing.B) {
 		b.Skip("socket is busy")
 	}
 
-	cmd := exec.Command("php", "../../../tests/client.php", "echo", "unix")
+	cmd := exec.Command("php", "../../tests/client.php", "echo", "unix")
 
 	w, err := NewSocketServer(ls, time.Minute).SpawnWorkerWithTimeout(ctx, cmd)
 	if err != nil {