diff options
author | Wolfy-J <[email protected]> | 2018-06-23 17:23:38 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-06-23 17:23:38 +0300 |
commit | acc6cee9e7faa5da0574723272c076cf1b77ce3f (patch) | |
tree | 009b9f7ab8e717d255c8dc08c42b3c8207667b08 /service/http | |
parent | 01744322290cdaa554e49a573aa5bf46f9463ee2 (diff) |
properly close
Diffstat (limited to 'service/http')
-rw-r--r-- | service/http/rpc_test.go | 58 |
1 files changed, 0 insertions, 58 deletions
diff --git a/service/http/rpc_test.go b/service/http/rpc_test.go index 12bdb8d8..de7ed0c3 100644 --- a/service/http/rpc_test.go +++ b/service/http/rpc_test.go @@ -124,64 +124,6 @@ func Test_RPC_Unix(t *testing.T) { assert.NotEqual(t, res, res2) } -func Test_RPC_Unix_2(t *testing.T) { - if runtime.GOOS == "windows" { - t.Skip("not supported on " + runtime.GOOS) - } - - logger, _ := test.NewNullLogger() - logger.SetLevel(logrus.DebugLevel) - - c := service.NewContainer(logger) - c.Register(rpc.ID, &rpc.Service{}) - c.Register(ID, &Service{}) - - assert.NoError(t, c.Init(&testCfg{ - rpcCfg: `{"enable":true, "listen":"unix://` + tmpDir() + `/rpc.unix"}`, - httpCfg: `{ - "enable": true, - "address": ":6029", - "maxRequest": 1024, - "uploads": { - "dir": ` + tmpDir() + `, - "forbid": [] - }, - "workers":{ - "command": "php ../../php-src/tests/http/client.php pid pipes", - "relay": "pipes", - "pool": { - "numWorkers": 1, - "allocateTimeout": 10000000, - "destroyTimeout": 10000000 - } - } - }`})) - - s, _ := c.Get(ID) - ss := s.(*Service) - - s2, _ := c.Get(rpc.ID) - rs := s2.(*rpc.Service) - - go func() { c.Serve() }() - time.Sleep(time.Millisecond * 100) - defer c.Stop() - - res, _, _ := get("http://localhost:6029") - assert.Equal(t, strconv.Itoa(*ss.rr.Workers()[0].Pid), res) - - cl, err := rs.Client() - assert.NoError(t, err) - - r := "" - assert.NoError(t, cl.Call("http.Reset", true, &r)) - assert.Equal(t, "OK", r) - - res2, _, _ := get("http://localhost:6029") - assert.Equal(t, strconv.Itoa(*ss.rr.Workers()[0].Pid), res2) - assert.NotEqual(t, res, res2) -} - func Test_Workers(t *testing.T) { logger, _ := test.NewNullLogger() logger.SetLevel(logrus.DebugLevel) |