Repository: ignite Updated Branches: refs/heads/ignite-test 08b2a7220 -> ac6c4c8b8
Debug test. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ac6c4c8b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ac6c4c8b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ac6c4c8b Branch: refs/heads/ignite-test Commit: ac6c4c8b8c5d2965bbc79ae2129be04c6fafae76 Parents: 08b2a72 Author: nikolay_tikhonov <[email protected]> Authored: Tue May 17 17:59:06 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Tue May 17 17:59:06 2016 +0300 ---------------------------------------------------------------------- ...acheContinuousQueryRandomOperationsTest.java | 844 +++++++++---------- 1 file changed, 422 insertions(+), 422 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ac6c4c8b/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 75ff9f3..27816ac 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.
