diff options
| -rw-r--r-- | service/rpc/config_test.go | 4 | ||||
| -rw-r--r-- | socket_factory_test.go | 8 | ||||
| -rw-r--r-- | static_pool_test.go | 4 | ||||
| -rw-r--r-- | worker_test.go | 2 |
4 files changed, 9 insertions, 9 deletions
diff --git a/service/rpc/config_test.go b/service/rpc/config_test.go index b335be19..6a2138d2 100644 --- a/service/rpc/config_test.go +++ b/service/rpc/config_test.go @@ -85,7 +85,7 @@ func Test_Config_ErrorMethod(t *testing.T) { func TestConfig_Dialer(t *testing.T) { cfg := &Config{Listen: "tcp://:18001"} - ln, err := cfg.Listener() + ln, _ := cfg.Listener() defer ln.Close() conn, err := cfg.Dialer() @@ -104,7 +104,7 @@ func TestConfig_DialerUnix(t *testing.T) { cfg := &Config{Listen: "unix://rpc.sock"} - ln, err := cfg.Listener() + ln, _ := cfg.Listener() defer ln.Close() conn, err := cfg.Dialer() diff --git a/socket_factory_test.go b/socket_factory_test.go index 00d0e93c..56d9313e 100644 --- a/socket_factory_test.go +++ b/socket_factory_test.go @@ -140,7 +140,7 @@ func Test_Tcp_Broken(t *testing.T) { cmd := exec.Command("php", "tests/client.php", "broken", "tcp") - w, err := NewSocketFactory(ls, time.Minute).SpawnWorker(cmd) + w, _ := NewSocketFactory(ls, time.Minute).SpawnWorker(cmd) go func() { err := w.Wait() @@ -167,7 +167,7 @@ func Test_Tcp_Echo(t *testing.T) { cmd := exec.Command("php", "tests/client.php", "echo", "tcp") - w, err := NewSocketFactory(ls, time.Minute).SpawnWorker(cmd) + w, _ := NewSocketFactory(ls, time.Minute).SpawnWorker(cmd) go func() { assert.NoError(t, w.Wait()) }() @@ -281,7 +281,7 @@ func Test_Unix_Broken(t *testing.T) { cmd := exec.Command("php", "tests/client.php", "broken", "unix") - w, err := NewSocketFactory(ls, time.Minute).SpawnWorker(cmd) + w, _ := NewSocketFactory(ls, time.Minute).SpawnWorker(cmd) go func() { err := w.Wait() @@ -310,7 +310,7 @@ func Test_Unix_Echo(t *testing.T) { cmd := exec.Command("php", "tests/client.php", "echo", "unix") - w, err := NewSocketFactory(ls, time.Minute).SpawnWorker(cmd) + w, _ := NewSocketFactory(ls, time.Minute).SpawnWorker(cmd) go func() { assert.NoError(t, w.Wait()) }() diff --git a/static_pool_test.go b/static_pool_test.go index 1e4906a5..a78fcf11 100644 --- a/static_pool_test.go +++ b/static_pool_test.go @@ -252,7 +252,7 @@ func Test_StaticPool_Replace_Worker(t *testing.T) { var lastPID string lastPID = strconv.Itoa(*p.Workers()[0].Pid) - res, err := p.Exec(&Payload{Body: []byte("hello")}) + res, _ := p.Exec(&Payload{Body: []byte("hello")}) assert.Equal(t, lastPID, string(res.Body)) for i := 0; i < 10; i++ { @@ -287,7 +287,7 @@ func Test_StaticPool_Stop_Worker(t *testing.T) { var lastPID string lastPID = strconv.Itoa(*p.Workers()[0].Pid) - res, err := p.Exec(&Payload{Body: []byte("hello")}) + res, _ := p.Exec(&Payload{Body: []byte("hello")}) assert.Equal(t, lastPID, string(res.Body)) for i := 0; i < 10; i++ { diff --git a/worker_test.go b/worker_test.go index b3a3fc46..c357b6e0 100644 --- a/worker_test.go +++ b/worker_test.go @@ -132,7 +132,7 @@ func Test_Echo_Slow(t *testing.T) { func Test_Broken(t *testing.T) { cmd := exec.Command("php", "tests/client.php", "broken", "pipes") - w, err := NewPipeFactory().SpawnWorker(cmd) + w, _ := NewPipeFactory().SpawnWorker(cmd) go func() { err := w.Wait() assert.Error(t, err) |