ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [2/2] incubator-ignite git commit: ignite-648: find by ID
Date Tue, 14 Apr 2015 13:31:51 GMT
ignite-648: find by ID


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/92cde7fe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/92cde7fe
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/92cde7fe

Branch: refs/heads/ignite-648
Commit: 92cde7fe12129c429a6fd2d1b4e319bef9b1b551
Parents: 9af5a00
Author: Artem Shutak <ashutak@gridgain.com>
Authored: Tue Apr 14 16:31:45 2015 +0300
Committer: Artem Shutak <ashutak@gridgain.com>
Committed: Tue Apr 14 16:31:45 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/cache/multijvm/IgniteNodeRunner.java    | 3 +--
 .../internal/processors/cache/multijvm/IgniteProcessProxy.java  | 5 ++---
 2 files changed, 3 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/92cde7fe/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteNodeRunner.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteNodeRunner.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteNodeRunner.java
index 5bd531e..e69f9bc 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteNodeRunner.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteNodeRunner.java
@@ -71,8 +71,7 @@ public class IgniteNodeRunner {
     public static IgniteConfiguration configuration(String[] args) {
         IgniteConfiguration cfg = new IgniteConfiguration();
 
-        // TODO uncomment
-//        cfg.setNodeId(UUID.fromString(args[0]));
+        cfg.setNodeId((args != null && args.length >= 1) ? UUID.fromString(args[0])
: null);
         //-------
         TcpDiscoverySpi disco = new TcpDiscoverySpi();
 

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/92cde7fe/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteProcessProxy.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteProcessProxy.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteProcessProxy.java
index fe22484..a38ebd1 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteProcessProxy.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/IgniteProcessProxy.java
@@ -132,9 +132,8 @@ public class IgniteProcessProxy implements IgniteEx {
         // TODO cfg.
         try(Ignite ignite = Ignition.start(IgniteNodeRunner.configuration(null))) {
             // TODO
-//            ClusterGroup grp = ignite.cluster().forNodeId(id);
-            ClusterGroup grp = ignite.cluster().forRemotes();
-            
+            ClusterGroup grp = ignite.cluster().forNodeId(id);
+
             return ignite.compute(grp).apply(new C1<Set<String>, IgniteClusterEx>()
{
                 @Override public IgniteClusterEx apply(Set<String> objects) {
                     X.println(">>>>> Cluster 1");


Mime
View raw message