You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/11/21 12:10:12 UTC
[18/47] ignite git commit: IGNITE-6926) Web console: Fixed
SimpleWorkerPool next worker selection logic.
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 <ak...@apache.org>
Authored: Thu Nov 16 10:12:24 2017 +0700
Committer: Alexey Kuznetsov <ak...@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();