summaryrefslogtreecommitdiff
path: root/static_pool.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-12-15 13:31:40 +0300
committerGitHub <[email protected]>2020-12-15 13:31:40 +0300
commitb44d272312389691920e42e5295395bef0d3b769 (patch)
tree1c826999423e59db5b7dab1184725e22468ecfbd /static_pool.go
parent673da74925dee5c62064d3304289ae81cb499217 (diff)
parent7b0a6720c21056ed4b922eb5b1b8a91a44dc3638 (diff)
Merge pull request #447 from spiral/feature/goridge3
Feature/goridge3
Diffstat (limited to 'static_pool.go')
-rwxr-xr-xstatic_pool.go3
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 {