You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2018/02/26 10:02:59 UTC
ignite git commit: ignite-2.3 Fixed Web Console regression.
Repository: ignite
Updated Branches:
refs/heads/ignite-2.3-web-console [created] 619759889
ignite-2.3 Fixed Web Console regression.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/61975988
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/61975988
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/61975988
Branch: refs/heads/ignite-2.3-web-console
Commit: 619759889b17e3d702dcab791cb59583bb7f26b6
Parents: c0a5229
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Mon Feb 26 17:02:39 2018 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Mon Feb 26 17:02:39 2018 +0700
----------------------------------------------------------------------
modules/web-console/frontend/app/utils/SimpleWorkerPool.js | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/61975988/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 d8ed28b..495a4d2 100644
--- a/modules/web-console/frontend/app/utils/SimpleWorkerPool.js
+++ b/modules/web-console/frontend/app/utils/SimpleWorkerPool.js
@@ -19,6 +19,7 @@ import {Observable} from 'rxjs/Observable';
import {Subject} from 'rxjs/Subject';
import 'rxjs/add/observable/race';
import 'rxjs/add/operator/filter';
+import 'rxjs/add/operator/map';
import 'rxjs/add/operator/pluck';
import 'rxjs/add/operator/take';
import 'rxjs/add/operator/toPromise';
@@ -64,7 +65,7 @@ export default class SimpleWorkerPool {
}
_getNextWorker() {
- return this._workers.find((w) => !w.tid);
+ return this._workers.find((w) => _.isNil(w.tid));
}
_getNextTask() {
@@ -105,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();