diff options
author | Valery Piashchynski <[email protected]> | 2021-02-02 19:17:03 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2021-02-02 19:17:03 +0300 |
commit | 2bdf7fafa73cabf7cf63657a6b58f2a423ae0fcd (patch) | |
tree | fe5efc14a18f78218816a2bc7a2e19ee95642714 /pkg/pool/supervisor_pool.go | |
parent | 68becf8c58daec426f94513cf444061c199194d7 (diff) |
Move worker states out of internal
Diffstat (limited to 'pkg/pool/supervisor_pool.go')
-rwxr-xr-x | pkg/pool/supervisor_pool.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/pkg/pool/supervisor_pool.go b/pkg/pool/supervisor_pool.go index 2597b352..3347ecd4 100755 --- a/pkg/pool/supervisor_pool.go +++ b/pkg/pool/supervisor_pool.go @@ -6,9 +6,9 @@ import ( "time" "github.com/spiral/errors" - "github.com/spiral/roadrunner/v2/internal" "github.com/spiral/roadrunner/v2/pkg/events" "github.com/spiral/roadrunner/v2/pkg/payload" + "github.com/spiral/roadrunner/v2/pkg/states" "github.com/spiral/roadrunner/v2/pkg/worker" "github.com/spiral/roadrunner/v2/tools" ) @@ -144,7 +144,7 @@ func (sp *supervised) control() { workers := sp.pool.Workers() for i := 0; i < len(workers); i++ { - if workers[i].State().Value() == internal.StateInvalid { + if workers[i].State().Value() == states.StateInvalid { continue } @@ -177,7 +177,7 @@ func (sp *supervised) control() { // firs we check maxWorker idle if sp.cfg.IdleTTL != 0 { // then check for the worker state - if workers[i].State().Value() != internal.StateReady { + if workers[i].State().Value() != states.StateReady { continue } |