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 2112D17C90 for ; Fri, 10 Apr 2015 20:05:55 +0000 (UTC) Received: (qmail 60598 invoked by uid 500); 10 Apr 2015 20:05:51 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 60568 invoked by uid 500); 10 Apr 2015 20:05:51 -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 60559 invoked by uid 99); 10 Apr 2015 20:05:51 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 10 Apr 2015 20:05:51 +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; Fri, 10 Apr 2015 20:05:50 +0000 Received: (qmail 60528 invoked by uid 99); 10 Apr 2015 20:05:30 -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; Fri, 10 Apr 2015 20:05:30 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D4231E03C2; Fri, 10 Apr 2015 20:05:29 +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 Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: incubator-ignite git commit: ignite-724 Cluster doesn't start with daemon node and cache metrics enabled Date: Fri, 10 Apr 2015 20:05:29 +0000 (UTC) X-Virus-Checked: Checked by ClamAV on apache.org Repository: incubator-ignite Updated Branches: refs/heads/ignite-sprint-3 c3210d803 -> 7bb7586b2 ignite-724 Cluster doesn't start with daemon node and cache metrics enabled Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7bb7586b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7bb7586b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7bb7586b Branch: refs/heads/ignite-sprint-3 Commit: 7bb7586b202ee2c6dec8db85e86d6f0c5d94025a Parents: c3210d8 Author: Andrey Gura Authored: Fri Apr 10 22:30:19 2015 +0300 Committer: Andrey Gura Committed: Fri Apr 10 22:55:25 2015 +0300 ---------------------------------------------------------------------- .../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 1 - .../discovery/tcp/internal/TcpDiscoveryNode.java | 12 +++++++----- .../CacheMetricsForClusterGroupSelfTest.java | 18 +++++++++++++++++- 3 files changed, 24 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7bb7586b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java index 4b43fec..6cf6de8 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java @@ -4330,7 +4330,6 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements TcpDiscov { assert nodeId != null; assert metrics != null; - assert cacheMetrics != null; TcpDiscoveryNode node = ring.node(nodeId); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7bb7586b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java index f5c1edb..bb8f051 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java @@ -128,8 +128,11 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Cluste * @param metricsProvider Metrics provider. * @param ver Version. */ - public TcpDiscoveryNode(UUID id, Collection addrs, Collection hostNames, int discPort, - DiscoveryMetricsProvider metricsProvider, IgniteProductVersion ver) { + public TcpDiscoveryNode(UUID id, + Collection addrs, + Collection hostNames, int discPort, + DiscoveryMetricsProvider metricsProvider, IgniteProductVersion ver) + { assert id != null; assert !F.isEmpty(addrs); assert metricsProvider != null; @@ -145,6 +148,7 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Cluste consistentId = U.consistentId(addrs, discPort); metrics = metricsProvider.metrics(); + cacheMetrics = metricsProvider.cacheMetrics(); sockAddrs = U.toSocketAddresses(this, discPort); } @@ -248,9 +252,7 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Cluste * @param cacheMetrics Cache metrics. */ public void setCacheMetrics(Map cacheMetrics) { - assert cacheMetrics != null; - - this.cacheMetrics = cacheMetrics; + this.cacheMetrics = cacheMetrics != null ? cacheMetrics : Collections.emptyMap(); } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7bb7586b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsForClusterGroupSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsForClusterGroupSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsForClusterGroupSelfTest.java index 19d7aab..1ba24e3 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsForClusterGroupSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsForClusterGroupSelfTest.java @@ -56,9 +56,25 @@ public class CacheMetricsForClusterGroupSelfTest extends GridCommonAbstractTest /** Cache 2. */ private IgniteCache cache2; + /** Daemon grid. */ + private boolean daemon; + + /** {@inheritDoc} */ + @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception { + IgniteConfiguration cfg = super.getConfiguration(gridName); + + cfg.setDaemon(daemon); + + return cfg; + } + /** {@inheritDoc} */ @Override protected void beforeTestsStarted() throws Exception { startGrids(GRID_CNT); + + daemon = true; + + startGrid(GRID_CNT); } /** {@inheritDoc} */ @@ -150,7 +166,7 @@ public class CacheMetricsForClusterGroupSelfTest extends GridCommonAbstractTest * Wait for {@link EventType#EVT_NODE_METRICS_UPDATED} event will be receieved. */ private void awaitMetricsUpdate() throws InterruptedException { - final CountDownLatch latch = new CountDownLatch(GRID_CNT * 2); + final CountDownLatch latch = new CountDownLatch((GRID_CNT + 1) * 2); IgnitePredicate lsnr = new IgnitePredicate() { @Override public boolean apply(Event ignore) {