diff options
| author | Wolfy-J <[email protected]> | 2018-06-12 20:45:24 +0300 |
|---|---|---|
| committer | Wolfy-J <[email protected]> | 2018-06-12 20:45:24 +0300 |
| commit | 99c1121d8fd31b7b61b6c22e181dc3c05a3f9f82 (patch) | |
| tree | 25e6baf4eaf4e4ebd37c2431e485dfe3f4e3ac11 /service/http/rpc.go | |
| parent | f8d8e9a55d31c6ee98b1f292e49b31b474883a4f (diff) | |
static pool logic update, better watching techniques
Diffstat (limited to 'service/http/rpc.go')
| -rw-r--r-- | service/http/rpc.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/service/http/rpc.go b/service/http/rpc.go index aa68a826..fc6aa65b 100644 --- a/service/http/rpc.go +++ b/service/http/rpc.go @@ -34,7 +34,12 @@ func (rpc *rpcServer) Reset(reset bool, r *string) error { } *r = "OK" - return rpc.svc.srv.rr.Reset() + + for _, w := range rpc.svc.rr.Workers() { + w.Kill() + } + + return nil //rpc.svc.rr.Reset() } // Workers returns list of active workers and their stats. |