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 2015/06/05 17:58:39 UTC
incubator-ignite git commit: #nodejs: ignition start parameter is
list of hosts with ports
Repository: incubator-ignite
Updated Branches:
refs/heads/nodejs 16b29b7c4 -> f8d2261df
#nodejs: ignition start parameter is list of hosts with ports
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/f8d2261d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/f8d2261d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/f8d2261d
Branch: refs/heads/nodejs
Commit: f8d2261df96641a222ef473c54e1ecdf2ea6a7e4
Parents: 16b29b7
Author: ivasilinets <iv...@gridgain.com>
Authored: Fri Jun 5 18:58:33 2015 +0300
Committer: ivasilinets <iv...@gridgain.com>
Committed: Fri Jun 5 18:58:33 2015 +0300
----------------------------------------------------------------------
modules/nodejs/src/main/nodejs/ignition.js | 12 ++++++------
modules/nodejs/src/test/nodejs/test_ignition.js | 2 +-
modules/nodejs/src/test/nodejs/test_ignition_fail.js | 2 +-
3 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f8d2261d/modules/nodejs/src/main/nodejs/ignition.js
----------------------------------------------------------------------
diff --git a/modules/nodejs/src/main/nodejs/ignition.js b/modules/nodejs/src/main/nodejs/ignition.js
index 5e36da2..b771f75 100644
--- a/modules/nodejs/src/main/nodejs/ignition.js
+++ b/modules/nodejs/src/main/nodejs/ignition.js
@@ -17,15 +17,15 @@ function Ignition() {
/**
* Open connection with server node
*
- * @param {number} port Port
- * @param {string[]} hosts List of nodes hosts
+ * @param {string[]} address List of nodes hosts with ports
* @param {Ignition~onStart} callback Called on finish
*/
-Ignition.start = function(port, hosts, callback) {
+Ignition.start = function(address, callback) {
var Server = require("./server").Server;
- var numConn = hosts.length;
- for (var host of hosts) {
- var server = new Server(host, port);
+ var numConn = address.length;
+ for (var addr of address) {
+ var params = addr.split(":");
+ var server = new Server(params[0], params[1]);
server.checkConnection(onConnect.bind(null, server));
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f8d2261d/modules/nodejs/src/test/nodejs/test_ignition.js
----------------------------------------------------------------------
diff --git a/modules/nodejs/src/test/nodejs/test_ignition.js b/modules/nodejs/src/test/nodejs/test_ignition.js
index df7e240..c441b01 100644
--- a/modules/nodejs/src/test/nodejs/test_ignition.js
+++ b/modules/nodejs/src/test/nodejs/test_ignition.js
@@ -1,7 +1,7 @@
var TestUtils = require("./test_utils").TestUtils;
var Ignition = require(TestUtils.scriptPath() + "ignition").Ignition;
-Ignition.start(9090, ['127.0.0.0', '127.0.0.1'], onConnect);
+Ignition.start(['127.0.0.0:9090', '127.0.0.1:9090'], onConnect);
function onConnect(error, server) {
if (error) {
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f8d2261d/modules/nodejs/src/test/nodejs/test_ignition_fail.js
----------------------------------------------------------------------
diff --git a/modules/nodejs/src/test/nodejs/test_ignition_fail.js b/modules/nodejs/src/test/nodejs/test_ignition_fail.js
index e50d08f..2259592 100644
--- a/modules/nodejs/src/test/nodejs/test_ignition_fail.js
+++ b/modules/nodejs/src/test/nodejs/test_ignition_fail.js
@@ -1,7 +1,7 @@
var TestUtils = require("./test_utils").TestUtils;
var Ignition = require(TestUtils.scriptPath() + "ignition").Ignition;
-Ignition.start(9091, ['127.0.0.0', '127.0.0.1'], onConnect);
+Ignition.start(['127.0.0.0:9091', '127.0.0.1:9092'], onConnect);
function onConnect(error, server) {
if (error) {