You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by nt...@apache.org on 2016/03/29 11:29:02 UTC
[8/8] ignite git commit: IGNITE-2004 Added tests.
IGNITE-2004 Added tests.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2586dbb6
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2586dbb6
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2586dbb6
Branch: refs/heads/ignite-2630
Commit: 2586dbb69ed4d742edf8e43280df21a579e7a6cd
Parents: 440354d
Author: nikolay_tikhonov <nt...@gridgain.com>
Authored: Tue Mar 29 12:28:34 2016 +0300
Committer: nikolay_tikhonov <nt...@gridgain.com>
Committed: Tue Mar 29 12:28:34 2016 +0300
----------------------------------------------------------------------
...torPartitionCounterRandomOperationsTest.java | 85 +++++++++++++++++++-
1 file changed, 83 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2586dbb6/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheInterceptorPartitionCounterRandomOperationsTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheInterceptorPartitionCounterRandomOperationsTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheInterceptorPartitionCounterRandomOperationsTest.java
index eaae7c5..d034af0 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheInterceptorPartitionCounterRandomOperationsTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheInterceptorPartitionCounterRandomOperationsTest.java
@@ -145,6 +145,7 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
new BlockingArrayQueue<Cache.Entry<QueryTestKey, QueryTestValue>>());
}
}
+
/**
* @throws Exception If failed.
*/
@@ -161,6 +162,19 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
/**
* @throws Exception If failed.
*/
+ public void testAtomicWithStore() throws Exception {
+ CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+ 1,
+ ATOMIC,
+ ONHEAP_TIERED,
+ true);
+
+ doTestPartitionCounterOperation(ccfg);
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
public void testAtomicReplicated() throws Exception {
CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
0,
@@ -174,6 +188,19 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
/**
* @throws Exception If failed.
*/
+ public void testAtomicReplicatedWithStore() throws Exception {
+ CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+ 0,
+ ATOMIC,
+ ONHEAP_TIERED,
+ true);
+
+ doTestPartitionCounterOperation(ccfg);
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
public void testAtomicOffheapValues() throws Exception {
CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
1,
@@ -187,6 +214,19 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
/**
* @throws Exception If failed.
*/
+ public void testAtomicOffheapValuesWithStore() throws Exception {
+ CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+ 1,
+ ATOMIC,
+ OFFHEAP_VALUES,
+ true);
+
+ doTestPartitionCounterOperation(ccfg);
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
public void testAtomicOffheapTiered() throws Exception {
CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
1,
@@ -226,6 +266,19 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
/**
* @throws Exception If failed.
*/
+ public void testTxWithStore() throws Exception {
+ CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+ 1,
+ TRANSACTIONAL,
+ ONHEAP_TIERED,
+ true);
+
+ doTestPartitionCounterOperation(ccfg);
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
public void testTxExplicit() throws Exception {
CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
1,
@@ -252,6 +305,19 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
/**
* @throws Exception If failed.
*/
+ public void testTxReplicatedWithStore() throws Exception {
+ CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+ 0,
+ TRANSACTIONAL,
+ ONHEAP_TIERED,
+ true);
+
+ doTestPartitionCounterOperation(ccfg);
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
public void testTxOffheapValues() throws Exception {
CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
1,
@@ -317,6 +383,19 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
/**
* @throws Exception If failed.
*/
+ public void testTxNoBackupsWithStore() throws Exception {
+ CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+ 0,
+ TRANSACTIONAL,
+ ONHEAP_TIERED,
+ true);
+
+ doTestPartitionCounterOperation(ccfg);
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
public void testTxNoBackupsExplicit() throws Exception {
CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
0,
@@ -372,7 +451,7 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
Map<Integer, Long> partCntr,
IgniteCache<Object, Object> cache)
throws Exception {
- Object key = new QueryTestKey(rnd.nextInt(1));
+ Object key = new QueryTestKey(rnd.nextInt(KEYS));
Object newVal = value(rnd);
Object oldVal = expData.get(key);
@@ -616,7 +695,9 @@ public class CacheInterceptorPartitionCounterRandomOperationsTest extends GridCo
boolean rmv
) {
Collection<ClusterNode> nodes =
- Collections.singletonList(affinity(cache).mapKeyToPrimaryAndBackups(key).iterator().next());
+ cache.getConfiguration(CacheConfiguration.class).getAtomicityMode() == TRANSACTIONAL ?
+ affinity(cache).mapKeyToPrimaryAndBackups(key) :
+ Collections.singletonList(affinity(cache).mapKeyToPrimaryAndBackups(key).iterator().next());
List<BlockingQueue<Cache.Entry<QueryTestKey, QueryTestValue>>> queues = new ArrayList<>();