summaryrefslogtreecommitdiff
path: root/worker_watcher.go
diff options
context:
space:
mode:
Diffstat (limited to 'worker_watcher.go')
-rwxr-xr-xworker_watcher.go3
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