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-746-debug
Date Wed, 15 Apr 2015 08:34:39 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-746-debug b23535191 -> d63ded410


# ignite-746-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/d63ded41
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d63ded41
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d63ded41

Branch: refs/heads/ignite-746-debug
Commit: d63ded41003cd3a40f330fbec9bf9adee6aeaab4
Parents: b235351
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Apr 15 11:34:30 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Apr 15 11:34:30 2015 +0300

----------------------------------------------------------------------
 .../distributed/dht/atomic/GridDhtAtomicCache.java |  4 ++++
 ...acheAtomicInvalidPartitionHandlingSelfTest.java | 17 +++++++++++++++++
 2 files changed, 21 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d63ded41/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
index 96c9783..8c5e1a9 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
@@ -224,12 +224,16 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K,
V> {
                 }
             });
         }
+
+        ctx.io().addDisconnectListener(disconnectLsnr);
     }
 
     /** {@inheritDoc} */
     @Override public void stop() {
         for (DeferredResponseBuffer buf : pendingResponses.values())
             buf.finish();
+
+        ctx.io().removeDisconnectListener(disconnectLsnr);
     }
 
     /**

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d63ded41/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridCacheAtomicInvalidPartitionHandlingSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridCacheAtomicInvalidPartitionHandlingSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridCacheAtomicInvalidPartitionHandlingSelfTest.java
index bda3e6a..22cd609 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridCacheAtomicInvalidPartitionHandlingSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridCacheAtomicInvalidPartitionHandlingSelfTest.java
@@ -299,6 +299,23 @@ public class GridCacheAtomicInvalidPartitionHandlingSelfTest extends
GridCommonA
                             // No-op.
                         }
                         catch (IgniteException e) {
+                            if (e.hasCause(CacheAtomicUpdateTimeoutCheckedException.class))
{
+                                TestDebugLog.addMessage("atomic update timeout, put: " +
put);
+
+                            /*
+                            if (upd != null) {
+                                for (Object key0 : upd.keySet())
+                                    TestDebugLog.printKeyMessages(false, key0);
+                            }
+                            else
+                                TestDebugLog.printKeyMessages(false, key);
+                                */
+
+                                TestDebugLog.printMessages(false);
+
+                                System.exit(22);
+                            }
+
                             if (!e.hasCause(CachePartialUpdateCheckedException.class))
                                 throw e;
                         }


Mime
View raw message