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 4CECA17B08 for ; Mon, 1 Jun 2015 11:45:12 +0000 (UTC) Received: (qmail 61883 invoked by uid 500); 1 Jun 2015 11:45:12 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 61845 invoked by uid 500); 1 Jun 2015 11:45: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 61830 invoked by uid 99); 1 Jun 2015 11:45:12 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 01 Jun 2015 11:45:12 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id BF2341A4202 for ; Mon, 1 Jun 2015 11:45:11 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.771 X-Spam-Level: * X-Spam-Status: No, score=1.771 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, T_RP_MATCHES_RCVD=-0.01, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id RkRm44odwFPt for ; Mon, 1 Jun 2015 11:45:10 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with SMTP id 19FB747C36 for ; Mon, 1 Jun 2015 11:44:56 +0000 (UTC) Received: (qmail 60829 invoked by uid 99); 1 Jun 2015 11:44:54 -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; Mon, 01 Jun 2015 11:44:54 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 6F2CFE0513; Mon, 1 Jun 2015 11:44:54 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sevdokimov@apache.org To: commits@ignite.incubator.apache.org Date: Mon, 01 Jun 2015 11:45:31 -0000 Message-Id: <292d9315a6244963a82c95fd311de280@git.apache.org> In-Reply-To: <79a37b0eafb644bc9db80065f03fc61a@git.apache.org> References: <79a37b0eafb644bc9db80065f03fc61a@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [39/53] [abbrv] incubator-ignite git commit: # ignite-709 # ignite-709 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/07b6cb59 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/07b6cb59 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/07b6cb59 Branch: refs/heads/ignite-sprint-5 Commit: 07b6cb598ddb8f6c8ca76245ffbe6c434e08f870 Parents: 2c3ce15 Author: sboikov Authored: Fri May 29 11:26:45 2015 +0300 Committer: sboikov Committed: Fri May 29 11:34:51 2015 +0300 ---------------------------------------------------------------------- .../dht/preloader/GridDhtPartitionMap.java | 2 +- ...niteCacheClientNodeChangingTopologyTest.java | 6 ++ .../junits/common/GridCommonAbstractTest.java | 61 +++++++++++++++++--- 3 files changed, 60 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/07b6cb59/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionMap.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionMap.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionMap.java index facf7e3..faa6cf6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionMap.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionMap.java @@ -237,7 +237,7 @@ public class GridDhtPartitionMap implements Comparable, Ext * @return Full string representation. */ public String toFullString() { - return S.toString(GridDhtPartitionMap.class, this, "size", size(), "map", super.toString()); + return S.toString(GridDhtPartitionMap.class, this, "size", size(), "map", map.toString()); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/07b6cb59/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheClientNodeChangingTopologyTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheClientNodeChangingTopologyTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheClientNodeChangingTopologyTest.java index 47c1d7e..922e618 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheClientNodeChangingTopologyTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheClientNodeChangingTopologyTest.java @@ -1556,6 +1556,9 @@ public class IgniteCacheClientNodeChangingTopologyTest extends GridCommonAbstrac catch (TimeoutException e) { log.error("Failed to wait for update."); + for (Ignite ignite : G.allGrids()) + dumpCacheDebugInfo(ignite); + U.dumpThreads(log); CyclicBarrier barrier0 = updateBarrier; @@ -1593,6 +1596,9 @@ public class IgniteCacheClientNodeChangingTopologyTest extends GridCommonAbstrac catch (TimeoutException e) { log.error("Failed to wait for update."); + for (Ignite ignite : G.allGrids()) + dumpCacheDebugInfo(ignite); + U.dumpThreads(log); CyclicBarrier barrier0 = updateBarrier; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/07b6cb59/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java index 1f4c7b6..cded7fa 100644 --- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java @@ -31,6 +31,7 @@ import org.apache.ignite.internal.processors.cache.distributed.dht.*; import org.apache.ignite.internal.processors.cache.distributed.dht.colocated.*; import org.apache.ignite.internal.processors.cache.distributed.near.*; import org.apache.ignite.internal.processors.cache.local.*; +import org.apache.ignite.internal.processors.cache.transactions.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; import org.apache.ignite.lang.*; @@ -383,19 +384,31 @@ public abstract class GridCommonAbstractTest extends GridAbstractTest { int actual = owners.size(); if (affNodes.size() != owners.size() || !affNodes.containsAll(owners)) { - LT.warn(log(), null, "Waiting for topology map update [grid=" + g.name() + - ", cache=" + cfg.getName() + ", p=" + p + ", nodes=" + exp + ", owners=" + actual + - ", affNodes=" + affNodes + ", owners=" + owners + - ", locNode=" + g.cluster().localNode().id() + ']'); + LT.warn(log(), null, "Waiting for topology map update [" + + "grid=" + g.name() + + ", cache=" + cfg.getName() + + ", cacheId=" + dht.context().cacheId() + + ", p=" + p + + ", affNodesCnt=" + exp + + ", ownersCnt=" + actual + + ", affNodes=" + affNodes + + ", owners=" + owners + + ", locNode=" + g.cluster().localNode() + ']'); if (i == 0) start = System.currentTimeMillis(); if (System.currentTimeMillis() - start > 30_000) - throw new IgniteException("Timeout of waiting for topology map update [grid=" - + g.name() + ", p=" + p + ", nodes=" + exp + ", owners=" + actual + - ", affNodes=" + affNodes + ", owners=" + owners + ", locNode=" - + g.cluster().localNode().id() + ']'); + throw new IgniteException("Timeout of waiting for topology map update [" + + "grid=" + g.name() + + ", cache=" + cfg.getName() + + ", cacheId=" + dht.context().cacheId() + + ", p=" + p + + ", affNodesCnt=" + exp + + ", ownersCnt=" + actual + + ", affNodes=" + affNodes + + ", owners=" + owners + + ", locNode=" + g.cluster().localNode() + ']'); Thread.sleep(200); // Busy wait. @@ -415,6 +428,38 @@ public abstract class GridCommonAbstractTest extends GridAbstractTest { } /** + * @param ignite Node. + */ + public void dumpCacheDebugInfo(Ignite ignite) { + GridKernalContext ctx = ((IgniteKernal)ignite).context(); + + log.error("Cache information update [node=" + ignite.name() + + ", client=" + ignite.configuration().isClientMode() + ']'); + + GridCacheSharedContext cctx = ctx.cache().context(); + + log.error("Pending transactions:"); + + for (IgniteInternalTx tx : cctx.tm().activeTransactions()) + log.error(">>> " + tx); + + log.error("Pending explicit locks:"); + + for (GridCacheExplicitLockSpan lockSpan : cctx.mvcc().activeExplicitLocks()) + log.error(">>> " + lockSpan); + + log.error("Pending cache futures:"); + + for (GridCacheFuture fut : cctx.mvcc().activeFutures()) + log.error(">>> " + fut); + + log.error("Pending atomic cache futures:"); + + for (GridCacheFuture fut : cctx.mvcc().atomicFutures()) + log.error(">>> " + fut); + } + + /** * @param cache Cache. * @return Affinity. */