diff options
| author | Wolfy-J <[email protected]> | 2019-12-23 14:43:47 +0300 |
|---|---|---|
| committer | Wolfy-J <[email protected]> | 2019-12-23 14:43:47 +0300 |
| commit | c7b0a4a81827284f7565c56aa476eea34fb6382f (patch) | |
| tree | ee30e93169c37fb058fbe55af6b3f954eabd9646 /service/limit/controller.go | |
| parent | 7f694966730f6dac09d0d0ea3bf51276b8e4dfe4 (diff) | |
- test fixes
Diffstat (limited to 'service/limit/controller.go')
| -rw-r--r-- | service/limit/controller.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/service/limit/controller.go b/service/limit/controller.go index c11f4b91..24a158f7 100644 --- a/service/limit/controller.go +++ b/service/limit/controller.go @@ -66,7 +66,12 @@ func (c *controller) control(p roadrunner.Pool) { // make sure worker still on initial request if p.Remove(w, err) && w.State().NumExecs() == eID { - go w.Kill() + go func() { + err := w.Kill() + if err != nil { + fmt.Printf("error killing worker with PID number: %d, created: %s", w.Pid, w.Created) + } + }() c.report(EventExecTTL, w, err) } } |