diff options
Diffstat (limited to 'worker_watcher.go')
-rwxr-xr-x | worker_watcher.go | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/worker_watcher.go b/worker_watcher.go index f9b3d372..f8fb67a9 100755 --- a/worker_watcher.go +++ b/worker_watcher.go @@ -228,7 +228,6 @@ func (ww *workerWatcher) GetFreeWorker(ctx context.Context) (WorkerBase, error) if w == nil { continue } - //ww.ReduceWorkersCount() return w, nil case <-ctx.Done(): return nil, errors.E(op, errors.NoFreeWorkers, errors.Str("no free workers in the stack, timeout exceed")) @@ -236,7 +235,6 @@ func (ww *workerWatcher) GetFreeWorker(ctx context.Context) (WorkerBase, error) } } - //ww.ReduceWorkersCount() return w, nil } @@ -278,7 +276,6 @@ func (ww *workerWatcher) RemoveWorker(wb WorkerBase) error { wb.State().Set(StateRemove) return nil - } // O(1) operation |