diff options
| author | Valery Piashchynski <[email protected]> | 2020-12-15 14:28:30 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2020-12-15 14:28:30 +0300 |
| commit | 21b51367e27f5a1b166459a115e4655d07a5d832 (patch) | |
| tree | c3257a2ac38f0688e78ca2c9eeb160fb7a84c55d /static_pool.go | |
| parent | 08f073f3bdc1288db68235c098c3a2109c6e7667 (diff) | |
| parent | d39a0735fe21d21c5aae20c4780458433a42250a (diff) | |
Merge branch '2.0' into plugin/reloader
# Conflicts:
# go.mod
# sync_worker.go
Diffstat (limited to 'static_pool.go')
| -rwxr-xr-x | static_pool.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/static_pool.go b/static_pool.go index b626a499..fbb2e5e8 100755 --- a/static_pool.go +++ b/static_pool.go @@ -162,7 +162,8 @@ func (sp *StaticPool) Exec(p Payload) (Payload, error) { } // worker want's to be terminated - if rsp.Body == nil && rsp.Context != nil && string(rsp.Context) == StopRequest { + // TODO careful with string(rsp.Context) + if len(rsp.Body) == 0 && string(rsp.Context) == StopRequest { sw.State().Set(StateInvalid) err = sw.Stop(bCtx) if err != nil { |