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 <ivasilin...@gridgain.com> Authored: Fri Jun 5 18:58:33 2015 +0300 Committer: ivasilinets <ivasilin...@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) {
