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 <[email protected]> Authored: Tue May 17 17:43:36 2016 +0300 Committer: nikolay_tikhonov <[email protected]> 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; }
