From 7cc6d00a1c350eb3147ede00802d312d4be94dee Mon Sep 17 00:00:00 2001 From: Wolfy-J Date: Sun, 10 Jun 2018 21:17:54 +0300 Subject: debug is not service anymore --- static_pool.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'static_pool.go') diff --git a/static_pool.go b/static_pool.go index 9f4aab23..bb418649 100644 --- a/static_pool.go +++ b/static_pool.go @@ -55,7 +55,7 @@ func NewPool(cmd func() *exec.Cmd, factory Factory, cfg Config) (*StaticPool, er } // constant number of workers simplify logic - for i := uint64(0); i < p.cfg.NumWorkers; i++ { + for i := int64(0); i < p.cfg.NumWorkers; i++ { // to test if worker ready w, err := p.createWorker() if err != nil { @@ -143,7 +143,7 @@ func (p *StaticPool) Destroy() { // finds free worker in a given time interval or creates new if allowed. func (p *StaticPool) allocateWorker() (w *Worker, err error) { // this loop is required to skip issues with dead workers still being in a ring. - for i := uint64(0); i < p.cfg.NumWorkers; i++ { + for i := int64(0); i < p.cfg.NumWorkers; i++ { select { case w = <-p.free: if w.state.Value() == StateReady { -- cgit v1.2.3