summaryrefslogtreecommitdiff
path: root/static_pool.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-06-10 21:17:54 +0300
committerWolfy-J <[email protected]>2018-06-10 21:17:54 +0300
commit7cc6d00a1c350eb3147ede00802d312d4be94dee (patch)
treeac1391c831d4366b477e61b57e095a1dfeafbbb7 /static_pool.go
parente9203e05a7f3278a8080d0f69e6640e5d3d1042d (diff)
debug is not service anymore
Diffstat (limited to 'static_pool.go')
-rw-r--r--static_pool.go4
1 files changed, 2 insertions, 2 deletions
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 {