ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject ignite git commit: Debug test.
Date Tue, 17 May 2016 14:59:12 GMT
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 <ntikhonov@gridgain.com>
Authored: Tue May 17 17:59:06 2016 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
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.


Mime
View raw message