ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [04/50] [abbrv] incubator-ignite git commit: #ignite-333: add tests.
Date Mon, 16 Mar 2015 03:39:56 GMT
#ignite-333: add tests.


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

Branch: refs/heads/ignite-368
Commit: 6da0acf010234660a9ab16896548688cd2566fbf
Parents: 13f15f6
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Thu Mar 12 17:18:44 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Thu Mar 12 17:18:44 2015 +0300

----------------------------------------------------------------------
 .../cache/GridCacheAbstractFullApiSelfTest.java | 163 +++++++++++++++++++
 1 file changed, 163 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6da0acf0/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
index f25229d..0479d9b 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java
@@ -4093,4 +4093,167 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract
             ccfg.getAtomicWriteOrderMode() == CacheAtomicWriteOrderMode.CLOCK)
             U.sleep(100);
     }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testLocalClearKey() throws Exception {
+        testLocalClearKey(false, Arrays.asList("key25"));
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testLocalClearKeyAsync() throws Exception {
+        testLocalClearKey(true, Arrays.asList("key25"));
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testLocalClearKeys() throws Exception {
+        testLocalClearKey(false, Arrays.asList("key25", "key100", "key150"));
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testLocalClearKeysAsync() throws Exception {
+        testLocalClearKey(true, Arrays.asList("key25", "key100", "key150"));
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testLocalClear() throws Exception {
+        testLocalClearKey(false, null);
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testLocalClearAsync() throws Exception {
+        testLocalClearKey(true, null);
+    }
+
+    /**
+     * @param async If {@code true} uses async method.
+     * @throws Exception If failed.
+     */
+    protected void testLocalClearKey(boolean async, Collection<String> keysToRemove)
throws Exception {
+        // Save entries only on their primary nodes. If we didn't do so, clearLocally() will
not remove all entries
+        // because some of them were blocked due to having readers.
+        for (int i = 0; i < 500; ++i) {
+            Ignite g = primaryIgnite("key" + i);
+
+            g.jcache(null).put("key" + i, "value" + i);
+        }
+
+        if (async) {
+            IgniteCache<String, Integer> asyncCache = jcache().withAsync();
+
+            if (keysToRemove == null)
+                asyncCache.localClear();
+            else if (keysToRemove.size() == 1)
+                asyncCache.localClear(F.first(keysToRemove));
+            else
+                asyncCache.localClearAll(new HashSet(keysToRemove));
+
+            asyncCache.future().get();
+        }
+        else {
+            if (keysToRemove == null)
+                jcache().localClear();
+            else if (keysToRemove.size() == 1)
+                jcache().localClear(F.first(keysToRemove));
+            else
+                jcache().localClearAll(new HashSet(keysToRemove));
+        }
+
+        for (int i = 0; i < 500; ++i) {
+            String key = "key" + i;
+
+            boolean found = false;
+
+            for (int j = 0; j < gridCount(); j++)
+                if (jcache(j).localPeek(key) != null)
+                    found = true;
+
+            if (keysToRemove == null || keysToRemove.contains(key))
+                assertFalse("Found removed key " + key, found);
+            else
+                assertTrue("Not found key " + key, found);
+        }
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testGlobalClearKey() throws Exception {
+        testGlobalClearKey(false, Arrays.asList("key25"));
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testGlobalClearKeyAsync() throws Exception {
+        testGlobalClearKey(true, Arrays.asList("key25"));
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testGlobalClearKeys() throws Exception {
+        testGlobalClearKey(false, Arrays.asList("key25", "key100", "key150"));
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testGlobalClearKeysAsync() throws Exception {
+        testGlobalClearKey(true, Arrays.asList("key25", "key100", "key150"));
+    }
+
+    /**
+     * @param async If {@code true} uses async method.
+     * @throws Exception If failed.
+     */
+    protected void testGlobalClearKey(boolean async, Collection<String> keysToRemove)
throws Exception {
+        // Save entries only on their primary nodes. If we didn't do so, clearLocally() will
not remove all entries
+        // because some of them were blocked due to having readers.
+        for (int i = 0; i < 500; ++i)
+            grid(0).jcache(null).put("key" + i, "value" + i);
+
+        if (async) {
+            IgniteCache<String, Integer> asyncCache = jcache().withAsync();
+
+            if (keysToRemove.size() == 1)
+                asyncCache.clear(F.first(keysToRemove));
+            else
+                asyncCache.clearAll(new HashSet(keysToRemove));
+
+            asyncCache.future().get();
+        }
+        else {
+            if (keysToRemove.size() == 1)
+                jcache().clear(F.first(keysToRemove));
+            else
+                jcache().clearAll(new HashSet(keysToRemove));
+        }
+
+        for (int i = 0; i < 500; ++i) {
+            String key = "key" + i;
+
+            boolean found = false;
+
+            for (int j = 0; j < gridCount(); j++)
+                if (jcache(j).localPeek(key) != null)
+                    found = true;
+
+            if (!keysToRemove.contains(key))
+                assertTrue("Not found key " + key, found);
+            else
+                assertFalse("Found removed key " + key, found);
+        }
+    }
 }


Mime
View raw message