summaryrefslogtreecommitdiff
path: root/pkg/transport/socket/socket_factory_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/transport/socket/socket_factory_test.go')
-rwxr-xr-xpkg/transport/socket/socket_factory_test.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/pkg/transport/socket/socket_factory_test.go b/pkg/transport/socket/socket_factory_test.go
index 4abcd5d9..c13a897b 100755
--- a/pkg/transport/socket/socket_factory_test.go
+++ b/pkg/transport/socket/socket_factory_test.go
@@ -120,7 +120,7 @@ func Test_Tcp_Failboot(t *testing.T) {
cmd := exec.Command("php", "../../../tests/failboot.php")
- finish := make(chan struct{}, 1)
+ finish := make(chan struct{}, 10)
listener := func(event interface{}) {
if ev, ok := event.(events.WorkerEvent); ok {
if ev.Event == events.EventWorkerStderr {
@@ -199,7 +199,7 @@ func Test_Tcp_Broken(t *testing.T) {
cmd := exec.Command("php", "../../../tests/client.php", "broken", "tcp")
- finish := make(chan struct{}, 1)
+ finish := make(chan struct{}, 10)
listener := func(event interface{}) {
if ev, ok := event.(events.WorkerEvent); ok {
if ev.Event == events.EventWorkerStderr {
@@ -325,7 +325,7 @@ func Test_Unix_Failboot(t *testing.T) {
cmd := exec.Command("php", "../../../tests/failboot.php")
- finish := make(chan struct{}, 1)
+ finish := make(chan struct{}, 10)
listener := func(event interface{}) {
if ev, ok := event.(events.WorkerEvent); ok {
if ev.Event == events.EventWorkerStderr {