ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-4705
Date Tue, 07 Mar 2017 12:34:33 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-4705-debug 8e72ddffe -> 169892f80


ignite-4705


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

Branch: refs/heads/ignite-4705-debug
Commit: 169892f80323d1bf0bc538359286e7289025d1df
Parents: 8e72ddf
Author: sboikov <sboikov@gridgain.com>
Authored: Tue Mar 7 15:34:15 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Tue Mar 7 15:34:15 2017 +0300

----------------------------------------------------------------------
 .../cache/GridCachePartitionExchangeManager.java          | 10 +++++++++-
 .../internal/processors/cache/GridCachePutAllTask.java    |  8 ++++----
 2 files changed, 13 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/169892f8/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
index e7bfdd4..eb48c2c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
@@ -1430,7 +1430,7 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
                             if (fut instanceof GridNearAtomicSingleUpdateFuture) {
                                 TestDebugLog.addEntryMessage(((GridNearAtomicSingleUpdateFuture)
fut).key(), null, "hang fut");
 
-                                TestDebugLog.printKeyMessages("test_debug.txt", ((GridNearAtomicSingleUpdateFuture)
fut).key());
+                                TestDebugLog.printKeyMessages(null, ((GridNearAtomicSingleUpdateFuture)
fut).key());
 
                                 System.exit(44);
                             }
@@ -1447,6 +1447,14 @@ public class GridCachePartitionExchangeManager<K, V> extends
GridCacheSharedMana
                         if (longRunningOpsDumpCnt < GridDhtPartitionsExchangeFuture.DUMP_PENDING_OBJECTS_THRESHOLD)
{
                             U.warn(log, "Found long running cache future [startTime=" + formatTime(fut.startTime())
+
                                 ", curTime=" + formatTime(curTime) + ", fut=" + fut + ']');
+
+                            if (fut instanceof GridNearAtomicSingleUpdateFuture) {
+                                TestDebugLog.addEntryMessage(((GridNearAtomicSingleUpdateFuture)
fut).key(), null, "hang fut");
+
+                                TestDebugLog.printKeyMessages(null, ((GridNearAtomicSingleUpdateFuture)
fut).key());
+
+                                System.exit(44);
+                            }
                         }
                         else
                             break;

http://git-wip-us.apache.org/repos/asf/ignite/blob/169892f8/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
index 5dad266..4f1455b 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java
@@ -122,11 +122,11 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>,
Void>
                             for (int i = 0; i < RETRIES; i++) {
                                 try {
                                     for (Map.Entry<Integer, Integer> e : putMap.entrySet())
{
-                                        TestDebugLog.addEntryMessage(e.getKey(), e.getValue(),
"start put");
+                                        TestDebugLog.addEntryMessage(e.getKey(), ignite.name(),
"start put");
 
                                         cache.put(e.getKey(), e.getValue());
 
-                                        TestDebugLog.addEntryMessage(e.getKey(), e.getValue(),
"end put");
+                                        TestDebugLog.addEntryMessage(e.getKey(), ignite.name(),
"end put");
                                     }
 
                                     break;
@@ -156,11 +156,11 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>,
Void>
                     for (int i = 0; i < RETRIES; i++) {
                         try {
                             for (Map.Entry<Integer, Integer> e : putMap.entrySet())
{
-                                TestDebugLog.addEntryMessage(e.getKey(), e.getValue(), "start
put");
+                                TestDebugLog.addEntryMessage(e.getKey(), ignite.name(), "start
put");
 
                                 cache.put(e.getKey(), e.getValue());
 
-                                TestDebugLog.addEntryMessage(e.getKey(), e.getValue(), "end
put");
+                                TestDebugLog.addEntryMessage(e.getKey(), ignite.name(), "end
put");
                             }
 
                             break;


Mime
View raw message