ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [07/48] incubator-ignite git commit: # ignite-43
Date Wed, 21 Jan 2015 11:52:59 GMT
# ignite-43


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

Branch: refs/heads/ignite-65
Commit: 2f5d4d8a4a76a41f04d642594197df915459ef8d
Parents: 48dd7fb
Author: sboikov <sboikov@gridgain.com>
Authored: Tue Jan 13 12:47:33 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Tue Jan 13 12:47:33 2015 +0300

----------------------------------------------------------------------
 .../cache/IgniteCacheEntryListenerAbstractTest.java  | 15 +++++++++++++++
 1 file changed, 15 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2f5d4d8a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java
index b35e1a8..f63ab9d 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java
@@ -12,6 +12,8 @@ package org.apache.ignite.internal.processors.cache;
 import org.apache.ignite.*;
 import org.apache.ignite.lang.*;
 import org.gridgain.grid.cache.*;
+import org.gridgain.grid.kernal.*;
+import org.gridgain.grid.kernal.processors.continuous.*;
 import org.gridgain.grid.util.lang.*;
 import org.gridgain.grid.util.typedef.internal.*;
 import org.gridgain.testframework.*;
@@ -61,6 +63,19 @@ public abstract class IgniteCacheEntryListenerAbstractTest extends IgniteCacheAb
         return cfg;
     }
 
+    /** {@inheritDoc} */
+    @Override protected void afterTest() throws Exception {
+        super.afterTest();
+
+        for (int i = 0; i < gridCount(); i++) {
+            GridContinuousProcessor proc = ((GridKernal)grid(i)).context().continuous();
+
+            ConcurrentMap<?, ?> syncMsgFuts = GridTestUtils.getFieldValue(proc, "syncMsgFuts");
+
+            assertEquals(0, syncMsgFuts.size());
+        }
+    }
+
     /**
      * @throws Exception If failed.
      */


Mime
View raw message