Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id F3AD617A97 for ; Tue, 14 Apr 2015 13:32:12 +0000 (UTC) Received: (qmail 11051 invoked by uid 500); 14 Apr 2015 13:32:12 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 11008 invoked by uid 500); 14 Apr 2015 13:32:12 -0000 Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.incubator.apache.org Delivered-To: mailing list commits@ignite.incubator.apache.org Received: (qmail 10996 invoked by uid 99); 14 Apr 2015 13:32:12 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Apr 2015 13:32:12 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Tue, 14 Apr 2015 13:32:10 +0000 Received: (qmail 10572 invoked by uid 99); 14 Apr 2015 13:31:51 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Apr 2015 13:31:51 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C26D6E0063; Tue, 14 Apr 2015 13:31:50 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.incubator.apache.org Date: Tue, 14 Apr 2015 13:31:51 -0000 Message-Id: <82407b95ee794bb0bf09114e6f350e3d@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [2/2] incubator-ignite git commit: ignite-648: find by ID X-Virus-Checked: Checked by ClamAV on apache.org 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 Authored: Tue Apr 14 16:31:45 2015 +0300 Committer: Artem Shutak 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, IgniteClusterEx>() { @Override public IgniteClusterEx apply(Set objects) { X.println(">>>>> Cluster 1");