ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [1/5] incubator-ignite git commit: # sprint-1 Added test for IGNITE-114.
Date Thu, 22 Jan 2015 10:27:01 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-53 e8de0fce2 -> 5aa877be8


# sprint-1 Added test for IGNITE-114.


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

Branch: refs/heads/ignite-53
Commit: 3c948bee10681971ba0c74d61a4f98fde822ba56
Parents: e466b24
Author: sboikov <semen.boikov@inria.fr>
Authored: Wed Jan 21 20:46:00 2015 +0300
Committer: sboikov <semen.boikov@inria.fr>
Committed: Wed Jan 21 20:46:00 2015 +0300

----------------------------------------------------------------------
 .../cache/IgniteCacheInvokeReadThroughTest.java | 121 +++++++++++++++++++
 .../bamboo/GridDataGridTestSuite.java           |   3 +
 2 files changed, 124 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3c948bee/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeReadThroughTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeReadThroughTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeReadThroughTest.java
new file mode 100644
index 0000000..4bdc029
--- /dev/null
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheInvokeReadThroughTest.java
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.processors.cache;
+
+import org.apache.ignite.*;
+import org.gridgain.grid.cache.*;
+import org.gridgain.grid.cache.store.*;
+
+import javax.cache.processor.*;
+
+import static org.gridgain.grid.cache.GridCacheAtomicityMode.*;
+import static org.gridgain.grid.cache.GridCacheDistributionMode.*;
+import static org.gridgain.grid.cache.GridCacheMode.*;
+
+/**
+ *
+ */
+public class IgniteCacheInvokeReadThroughTest extends IgniteCacheAbstractTest {
+    /** */
+    private static volatile boolean failed;
+
+    /** {@inheritDoc} */
+    @Override protected int gridCount() {
+        return 3;
+    }
+
+    /** {@inheritDoc} */
+    @Override protected GridCacheMode cacheMode() {
+        return PARTITIONED;
+    }
+
+    /** {@inheritDoc} */
+    @Override protected GridCacheAtomicityMode atomicityMode() {
+        return TRANSACTIONAL;
+    }
+
+    /** {@inheritDoc} */
+    @Override protected GridCacheDistributionMode distributionMode() {
+        return PARTITIONED_ONLY;
+    }
+
+    /** {@inheritDoc} */
+    @Override protected GridCacheStore<?, ?> cacheStore() {
+        return new TestStore();
+    }
+
+    /** {@inheritDoc} */
+    @Override protected void beforeTestsStarted() throws Exception {
+        super.beforeTestsStarted();
+
+        failed = false;
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testInvokeReadThrough() throws Exception {
+        IgniteCache<Integer, Integer> cache = jcache(0);
+
+        checkReadThrough(cache, primaryKey(cache));
+
+        checkReadThrough(cache, backupKey(cache));
+
+        checkReadThrough(cache, nearKey(cache));
+    }
+
+    /**
+     * @param cache Cache.
+     * @param key Key.
+     */
+    private void checkReadThrough(IgniteCache<Integer, Integer> cache, Integer key)
{
+        log.info("Test [key=" + key + ']');
+
+        storeMap.put(key, key);
+
+        Object ret = cache.invoke(key, new EntryProcessor<Integer, Integer, Object>()
{
+            @Override public Object process(MutableEntry<Integer, Integer> entry, Object...
args) {
+                if (!entry.exists()) {
+                    failed = true;
+
+                    fail();
+                }
+
+                Integer val = entry.getValue();
+
+                if (!val.equals(entry.getKey())) {
+                    failed = true;
+
+                    assertEquals(val, entry.getKey());
+                }
+
+                entry.setValue(val + 1);
+
+                return val;
+            }
+        });
+
+        assertEquals(key, ret);
+
+        for (int i = 0; i < gridCount(); i++)
+            assertEquals("Unexpected value for node: " + i, key + 1, jcache(i).get(key));
+
+        assertFalse(failed);
+    }
+}
+

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3c948bee/modules/core/src/test/java/org/gridgain/testsuites/bamboo/GridDataGridTestSuite.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/testsuites/bamboo/GridDataGridTestSuite.java
b/modules/core/src/test/java/org/gridgain/testsuites/bamboo/GridDataGridTestSuite.java
index 32d0d05..51da16f 100644
--- a/modules/core/src/test/java/org/gridgain/testsuites/bamboo/GridDataGridTestSuite.java
+++ b/modules/core/src/test/java/org/gridgain/testsuites/bamboo/GridDataGridTestSuite.java
@@ -335,6 +335,9 @@ public class GridDataGridTestSuite extends TestSuite {
         suite.addTestSuite(GridCacheMultinodeUpdateAtomicSelfTest.class);
         suite.addTestSuite(GridCacheMultinodeUpdateAtomicNearEnabledSelfTest.class);
 
+        // TODO: IGNITE-114.
+        // suite.addTestSuite(IgniteCacheInvokeReadThroughTest.class);
+
         return suite;
     }
 }


Mime
View raw message