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/05/17 14:44:06 UTC
ignite git commit: Debug test.
Repository: ignite
Updated Branches:
refs/heads/ignite-test [created] 08b2a7220
Debug test.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/08b2a722
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/08b2a722
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/08b2a722
Branch: refs/heads/ignite-test
Commit: 08b2a72205bfeaeba1122e0250cadfc904967212
Parents: a606f59
Author: nikolay_tikhonov <nt...@gridgain.com>
Authored: Tue May 17 17:43:36 2016 +0300
Committer: nikolay_tikhonov <nt...@gridgain.com>
Committed: Tue May 17 17:43:36 2016 +0300
----------------------------------------------------------------------
...acheContinuousQueryRandomOperationsTest.java | 1258 +++++++++---------
.../IgniteCacheQuerySelfTestSuite3.java | 79 +-
2 files changed, 673 insertions(+), 664 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/08b2a722/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
index a6c33bb..75ff9f3 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
@@ -143,337 +143,337 @@ public class CacheContinuousQueryRandomOperationsTest extends GridCommonAbstract
super.afterTestsStopped();
}
-
- /**
- * @throws Exception If failed.
- */
- public void testFilterAndFactoryProvided() throws Exception {
- final CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- grid(0).createCache(ccfg);
-
- try {
- final ContinuousQuery qry = new ContinuousQuery();
-
- qry.setRemoteFilterFactory(new Factory<CacheEntryEventFilter>() {
- @Override public CacheEntryEventFilter create() {
- return null;
- }
- });
-
- qry.setRemoteFilter(new CacheEntryEventSerializableFilter() {
- @Override public boolean evaluate(CacheEntryEvent event) throws CacheEntryListenerException {
- return false;
- }
- });
-
- qry.setLocalListener(new CacheEntryUpdatedListener() {
- @Override public void onUpdated(Iterable iterable) throws CacheEntryListenerException {
- // No-op.
- }
- });
-
- GridTestUtils.assertThrows(log, new Callable<Object>() {
- @Override public Object call() throws Exception {
- return grid(0).cache(ccfg.getName()).query(qry);
- }
- }, IgniteException.class, null);
-
- }
- finally {
- grid(0).destroyCache(ccfg.getName());
- }
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomic() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicReplicated() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicReplicatedAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicReplicatedClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicOffheapValues() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- OFFHEAP_VALUES,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicOffheapValuesAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- OFFHEAP_VALUES,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicOffheapValuesClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- OFFHEAP_VALUES,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicOffheapTiered() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- OFFHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicOffheapTieredAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- OFFHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicOffheapTieredClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- OFFHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicNoBackups() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicNoBackupsAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testAtomicNoBackupsClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTx() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxExplicit() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveAtomicWithoutBackup() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveAtomicWithoutBackupWithStore() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveAtomic() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveAtomicWithStore() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- ATOMIC,
- ONHEAP_TIERED,
- true);
-
- doTestNotModifyOperation(ccfg);
- }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testFilterAndFactoryProvided() throws Exception {
+// final CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// grid(0).createCache(ccfg);
+//
+// try {
+// final ContinuousQuery qry = new ContinuousQuery();
+//
+// qry.setRemoteFilterFactory(new Factory<CacheEntryEventFilter>() {
+// @Override public CacheEntryEventFilter create() {
+// return null;
+// }
+// });
+//
+// qry.setRemoteFilter(new CacheEntryEventSerializableFilter() {
+// @Override public boolean evaluate(CacheEntryEvent event) throws CacheEntryListenerException {
+// return false;
+// }
+// });
+//
+// qry.setLocalListener(new CacheEntryUpdatedListener() {
+// @Override public void onUpdated(Iterable iterable) throws CacheEntryListenerException {
+// // No-op.
+// }
+// });
+//
+// GridTestUtils.assertThrows(log, new Callable<Object>() {
+// @Override public Object call() throws Exception {
+// return grid(0).cache(ccfg.getName()).query(qry);
+// }
+// }, IgniteException.class, null);
+//
+// }
+// finally {
+// grid(0).destroyCache(ccfg.getName());
+// }
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomic() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicReplicated() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicReplicatedAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicReplicatedClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicOffheapValues() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// OFFHEAP_VALUES,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicOffheapValuesAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// OFFHEAP_VALUES,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicOffheapValuesClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// OFFHEAP_VALUES,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicOffheapTiered() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// OFFHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicOffheapTieredAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// OFFHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicOffheapTieredClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// OFFHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicNoBackups() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicNoBackupsAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testAtomicNoBackupsClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTx() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxExplicit() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveAtomicWithoutBackup() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveAtomicWithoutBackupWithStore() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveAtomic() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveAtomicWithStore() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// ATOMIC,
+// ONHEAP_TIERED,
+// true);
+//
+// doTestNotModifyOperation(ccfg);
+// }
/**
* @throws Exception If failed.
@@ -487,97 +487,97 @@ public class CacheContinuousQueryRandomOperationsTest extends GridCommonAbstract
doTestNotModifyOperation(ccfg);
}
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveAtomicOffheapWithStore() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- ATOMIC,
- OFFHEAP_TIERED,
- true);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveTx() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveTxWithStore() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveReplicatedTx() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveReplicatedTxWithStore() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveReplicatedAtomic() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- false);
-
- doTestNotModifyOperation(ccfg);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testDoubleRemoveReplicatedAtomicWithStore() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- ATOMIC,
- ONHEAP_TIERED,
- true);
-
- doTestNotModifyOperation(ccfg);
- }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveAtomicOffheapWithStore() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// ATOMIC,
+// OFFHEAP_TIERED,
+// true);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveTx() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveTxWithStore() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveReplicatedTx() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveReplicatedTxWithStore() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveReplicatedAtomic() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestNotModifyOperation(ccfg);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testDoubleRemoveReplicatedAtomicWithStore() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// ATOMIC,
+// ONHEAP_TIERED,
+// true);
+//
+// doTestNotModifyOperation(ccfg);
+// }
/**
* @throws Exception If failed.
@@ -848,213 +848,213 @@ public class CacheContinuousQueryRandomOperationsTest extends GridCommonAbstract
assertEquals(event.getOldValue(), oldVal);
}
- /**
- * @throws Exception If failed.
- */
- public void testTxClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxClientExplicit() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxReplicated() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxReplicatedClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
- 0,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxOffheapValues() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- OFFHEAP_VALUES,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxOffheapValuesAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- OFFHEAP_VALUES,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxOffheapValuesExplicit() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- OFFHEAP_VALUES,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxOffheapValuesClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- OFFHEAP_VALUES,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxOffheapTiered() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- OFFHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxOffheapTieredAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- OFFHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxOffheapTieredClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- OFFHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxOffheapTieredClientExplicit() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 1,
- TRANSACTIONAL,
- OFFHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxNoBackups() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxNoBackupsAllNodes() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, ALL);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxNoBackupsExplicit() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, SERVER);
- }
-
- /**
- * @throws Exception If failed.
- */
- public void testTxNoBackupsClient() throws Exception {
- CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
- 0,
- TRANSACTIONAL,
- ONHEAP_TIERED,
- false);
-
- doTestContinuousQuery(ccfg, CLIENT);
- }
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxClientExplicit() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxReplicated() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxReplicatedClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+// 0,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxOffheapValues() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// OFFHEAP_VALUES,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxOffheapValuesAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// OFFHEAP_VALUES,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxOffheapValuesExplicit() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// OFFHEAP_VALUES,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxOffheapValuesClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// OFFHEAP_VALUES,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxOffheapTiered() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// OFFHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxOffheapTieredAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// OFFHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxOffheapTieredClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// OFFHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxOffheapTieredClientExplicit() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 1,
+// TRANSACTIONAL,
+// OFFHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxNoBackups() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxNoBackupsAllNodes() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, ALL);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxNoBackupsExplicit() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, SERVER);
+// }
+//
+// /**
+// * @throws Exception If failed.
+// */
+// public void testTxNoBackupsClient() throws Exception {
+// CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+// 0,
+// TRANSACTIONAL,
+// ONHEAP_TIERED,
+// false);
+//
+// doTestContinuousQuery(ccfg, CLIENT);
+// }
/**
* @param ccfg Cache configuration.
http://git-wip-us.apache.org/repos/asf/ignite/blob/08b2a722/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
index e0e81b7..92b4a8d 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
@@ -67,42 +67,51 @@ public class IgniteCacheQuerySelfTestSuite3 extends TestSuite {
TestSuite suite = new TestSuite("Ignite Cache Queries Test Suite 3");
// Continuous queries.
- suite.addTestSuite(GridCacheContinuousQueryLocalSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryLocalAtomicSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryReplicatedSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryReplicatedAtomicSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryReplicatedP2PDisabledSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryPartitionedSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryPartitionedOnlySelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryPartitionedP2PDisabledSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryTxSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryTxOffheapTieredTest.class);
- suite.addTestSuite(GridCacheContinuousQueryTxOffheapValuesTest.class);
- suite.addTestSuite(GridCacheContinuousQueryAtomicSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryAtomicNearEnabledSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryAtomicP2PDisabledSelfTest.class);
- suite.addTestSuite(GridCacheContinuousQueryAtomicOffheapTieredTest.class);
- suite.addTestSuite(GridCacheContinuousQueryAtomicOffheapValuesTest.class);
- suite.addTestSuite(GridCacheContinuousQueryReplicatedTxOneNodeTest.class);
- suite.addTestSuite(GridCacheContinuousQueryReplicatedAtomicOneNodeTest.class);
- suite.addTestSuite(GridCacheContinuousQueryPartitionTxOneNodeTest.class);
- suite.addTestSuite(GridCacheContinuousQueryPartitionAtomicOneNodeTest.class);
- suite.addTestSuite(IgniteCacheContinuousQueryClientTest.class);
- suite.addTestSuite(IgniteCacheContinuousQueryClientReconnectTest.class);
- suite.addTestSuite(IgniteCacheContinuousQueryClientTxReconnectTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryLocalSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryLocalAtomicSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryReplicatedSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryReplicatedAtomicSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryReplicatedP2PDisabledSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryPartitionedSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryPartitionedOnlySelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryPartitionedP2PDisabledSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryTxSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryTxOffheapTieredTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryTxOffheapValuesTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryAtomicSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryAtomicNearEnabledSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryAtomicP2PDisabledSelfTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryAtomicOffheapTieredTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryAtomicOffheapValuesTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryReplicatedTxOneNodeTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryReplicatedAtomicOneNodeTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryPartitionTxOneNodeTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryPartitionAtomicOneNodeTest.class);
+// suite.addTestSuite(IgniteCacheContinuousQueryClientTest.class);
+// suite.addTestSuite(IgniteCacheContinuousQueryClientReconnectTest.class);
+// suite.addTestSuite(IgniteCacheContinuousQueryClientTxReconnectTest.class);
suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
- suite.addTestSuite(CacheContinuousQueryRandomOperationsTwoNodesTest.class);
- suite.addTestSuite(GridCacheContinuousQueryConcurrentTest.class);
- suite.addTestSuite(CacheContinuousQueryAsyncFilterListenerTest.class);
- suite.addTestSuite(CacheContinuousQueryFactoryFilterRandomOperationTest.class);
- suite.addTestSuite(CacheContinuousQueryFactoryAsyncFilterRandomOperationTest.class);
- suite.addTestSuite(CacheContinuousQueryOrderingEventTest.class);
- suite.addTestSuite(CacheContinuousQueryOperationFromCallbackTest.class);
- suite.addTestSuite(CacheContinuousQueryOperationP2PTest.class);
- suite.addTestSuite(CacheContinuousBatchAckTest.class);
- suite.addTestSuite(CacheContinuousBatchForceServerModeAckTest.class);
- suite.addTestSuite(CacheContinuousQueryExecuteInPrimaryTest.class);
- suite.addTestSuite(CacheContinuousQueryLostPartitionTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+ suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+// suite.addTestSuite(CacheContinuousQueryRandomOperationsTwoNodesTest.class);
+// suite.addTestSuite(GridCacheContinuousQueryConcurrentTest.class);
+// suite.addTestSuite(CacheContinuousQueryAsyncFilterListenerTest.class);
+// suite.addTestSuite(CacheContinuousQueryFactoryFilterRandomOperationTest.class);
+// suite.addTestSuite(CacheContinuousQueryFactoryAsyncFilterRandomOperationTest.class);
+// suite.addTestSuite(CacheContinuousQueryOrderingEventTest.class);
+// suite.addTestSuite(CacheContinuousQueryOperationFromCallbackTest.class);
+// suite.addTestSuite(CacheContinuousQueryOperationP2PTest.class);
+// suite.addTestSuite(CacheContinuousBatchAckTest.class);
+// suite.addTestSuite(CacheContinuousBatchForceServerModeAckTest.class);
+// suite.addTestSuite(CacheContinuousQueryExecuteInPrimaryTest.class);
+// suite.addTestSuite(CacheContinuousQueryLostPartitionTest.class);
return suite;
}