summaryrefslogtreecommitdiff
path: root/pkg/pool
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-08-09 17:10:07 +0300
committerValery Piashchynski <[email protected]>2021-08-09 17:10:07 +0300
commitfba3d927b62f8963f0c291da2739061e726df32e (patch)
tree37fd54198f1b4939c0b78435c22817ca0c5facd9 /pkg/pool
parent606e2170ccac5a13a11198aaf54e4219a83291ab (diff)
Update goridge to v3.2.0, update all frames operations.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/pool')
-rwxr-xr-xpkg/pool/static_pool.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/pkg/pool/static_pool.go b/pkg/pool/static_pool.go
index 1cd0a8fa..051e7a8a 100755
--- a/pkg/pool/static_pool.go
+++ b/pkg/pool/static_pool.go
@@ -253,6 +253,7 @@ func defaultErrEncoder(sp *StaticPool) ErrorEncoder {
case errors.Is(errors.SoftJob, err):
if sp.cfg.MaxJobs != 0 && w.State().NumExecs() >= sp.cfg.MaxJobs {
+ // TODO suspicious logic, redesign
err = sp.ww.Allocate()
if err != nil {
sp.events.Push(events.PoolEvent{Event: events.EventWorkerConstruct, Payload: errors.E(op, err)})