IGNITE-6926) Web console: Fixed SimpleWorkerPool next worker selection logic.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/50b384bf Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/50b384bf Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/50b384bf Branch: refs/heads/ignite-zk Commit: 50b384bfa2a68289326fbee093f52c9b5193b7ff Parents: 63b628d Author: Alexey Kuznetsov <akuznet...@apache.org> Authored: Thu Nov 16 10:12:24 2017 +0700 Committer: Alexey Kuznetsov <akuznet...@apache.org> Committed: Thu Nov 16 10:12:24 2017 +0700 ---------------------------------------------------------------------- modules/web-console/frontend/app/utils/SimpleWorkerPool.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/50b384bf/modules/web-console/frontend/app/utils/SimpleWorkerPool.js ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/utils/SimpleWorkerPool.js b/modules/web-console/frontend/app/utils/SimpleWorkerPool.js index b76dc52..495a4d2 100644 --- a/modules/web-console/frontend/app/utils/SimpleWorkerPool.js +++ b/modules/web-console/frontend/app/utils/SimpleWorkerPool.js @@ -65,7 +65,7 @@ export default class SimpleWorkerPool { } _getNextWorker() { - return this._workers.find((w) => !w.tid); + return this._workers.find((w) => _.isNil(w.tid)); } _getNextTask() { @@ -106,7 +106,7 @@ export default class SimpleWorkerPool { this._tasks.push({tid, data}); if (this.__dbg) - console.log(`Pool: [name=${this._name}, queue=${this._tasks.length}]`); + console.log(`Pool: [name=${this._name}, tid=${tid}, queue=${this._tasks.length}]`); this._run();
