ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: # ignite-157-debug
Date Tue, 28 Apr 2015 07:38:07 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-157-debug d43074e70 -> 344fcbf85


# ignite-157-debug


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

Branch: refs/heads/ignite-157-debug
Commit: 344fcbf85c1a5c6eb96edbd0e75b249542c5845c
Parents: d43074e
Author: sboikov <sboikov@gridgain.com>
Authored: Tue Apr 28 10:37:58 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Tue Apr 28 10:37:58 2015 +0300

----------------------------------------------------------------------
 .../GridDhtPartitionsExchangeFuture.java        | 40 +++++++++++---------
 1 file changed, 23 insertions(+), 17 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/344fcbf8/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
index e6d9d54..6c2169e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
@@ -679,38 +679,44 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT
         return false; // TODO ignite-23;
     }
 
+    private static int cnt = 0;
+
     /**
      *
      */
     private void dumpPendingObjects() {
-        U.warn(log, "Failed to wait for partition release future. Dumping pending objects
that might be the cause: " +
-            cctx.localNodeId());
+        synchronized (GridDhtPartitionsExchangeFuture.class) {
+            U.warn(log, "Failed to wait for partition release future. Dumping pending objects
that might be the cause: " +
+                cctx.localNodeId());
 
-        U.warn(log, "Pending transactions:");
+            U.warn(log, "Pending transactions:");
 
-        for (IgniteInternalTx tx : cctx.tm().activeTransactions())
-            U.warn(log, ">>> " + tx);
+            for (IgniteInternalTx tx : cctx.tm().activeTransactions())
+                U.warn(log, ">>> " + tx);
 
-        U.warn(log, "Pending explicit locks:");
+            U.warn(log, "Pending explicit locks:");
 
-        for (GridCacheExplicitLockSpan lockSpan : cctx.mvcc().activeExplicitLocks())
-            U.warn(log, ">>> " + lockSpan);
+            for (GridCacheExplicitLockSpan lockSpan : cctx.mvcc().activeExplicitLocks())
+                U.warn(log, ">>> " + lockSpan);
 
-        U.warn(log, "Pending cache futures:");
+            U.warn(log, "Pending cache futures:");
 
-        for (GridCacheFuture<?> fut : cctx.mvcc().activeFutures())
-            U.warn(log, ">>> " + fut);
+            for (GridCacheFuture<?> fut : cctx.mvcc().activeFutures())
+                U.warn(log, ">>> " + fut);
 
-        U.warn(log, "Pending atomic cache futures:");
+            U.warn(log, "Pending atomic cache futures:");
 
-        for (GridCacheFuture<?> fut : cctx.mvcc().atomicFutures())
-            U.warn(log, ">>> " + fut);
+            for (GridCacheFuture<?> fut : cctx.mvcc().atomicFutures())
+                U.warn(log, ">>> " + fut);
 
-        TestDebugLog.addMessage("Release timeout");
+            TestDebugLog.addMessage("Release timeout");
 
-        TestDebugLog.printMessages(false);
+            if (++cnt > 3) {
+                TestDebugLog.printMessages(false);
 
-        System.exit(1);
+                System.exit(1);
+            }
+        }
     }
 
     /**


Mime
View raw message