ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [28/50] [abbrv] ignite git commit: IGNITE-9694 Add tests to check that reading queries are not blocked on exchange events that don't change data visibility - Fixes #4926.
Date Tue, 23 Oct 2018 15:01:32 GMT
http://git-wip-us.apache.org/repos/asf/ignite/blob/3fae41b1/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheBlockOnCreateDestoryIndexTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheBlockOnCreateDestoryIndexTest.java
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheBlockOnCreateDestoryIndexTest.java
new file mode 100644
index 0000000..469ec93
--- /dev/null
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheBlockOnCreateDestoryIndexTest.java
@@ -0,0 +1,480 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.processors.cache.distributed;
+
+import java.lang.annotation.Annotation;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.UUID;
+import org.apache.ignite.IgniteCache;
+import org.apache.ignite.cache.query.SqlFieldsQuery;
+import org.apache.ignite.configuration.CacheConfiguration;
+import org.apache.ignite.internal.IgniteEx;
+import org.apache.ignite.internal.processors.cache.distributed.CacheBlockOnReadAbstractTest.Params;
+import org.apache.ignite.internal.processors.query.schema.message.SchemaOperationStatusMessage;
+import org.apache.ignite.internal.util.typedef.T3;
+import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+
+import static org.apache.ignite.cache.CacheAtomicityMode.ATOMIC;
+import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL;
+import static org.apache.ignite.cache.CacheMode.PARTITIONED;
+import static org.apache.ignite.cache.CacheMode.REPLICATED;
+
+/**
+ *
+ */
+public class CacheBlockOnCreateDestoryIndexTest extends GridCommonAbstractTest {
+    /** */
+    private final List<? extends CacheBlockOnReadAbstractTest> tests = Arrays.asList(
+        new CacheBlockOnSingleGetTest() {
+            /** {@inheritDoc} */
+            @Nullable @Override protected <A extends Annotation> A currentTestAnnotation(Class<A>
annotationCls) {
+                return CacheBlockOnCreateDestoryIndexTest.this.currentTestAnnotation(annotationCls);
+            }
+        },
+        new CacheBlockOnGetAllTest() {
+            /** {@inheritDoc} */
+            @Nullable @Override protected <A extends Annotation> A currentTestAnnotation(Class<A>
annotationCls) {
+                return CacheBlockOnCreateDestoryIndexTest.this.currentTestAnnotation(annotationCls);
+            }
+        },
+        new CacheBlockOnScanTest() {
+            /** {@inheritDoc} */
+            @Nullable @Override protected <A extends Annotation> A currentTestAnnotation(Class<A>
annotationCls) {
+                return CacheBlockOnCreateDestoryIndexTest.this.currentTestAnnotation(annotationCls);
+            }
+        },
+        new CacheBlockOnSqlQueryTest() {
+            /** {@inheritDoc} */
+            @Nullable @Override protected <A extends Annotation> A currentTestAnnotation(Class<A>
annotationCls) {
+                return CacheBlockOnCreateDestoryIndexTest.this.currentTestAnnotation(annotationCls);
+            }
+        }
+    );
+
+    /** {@inheritDoc} */
+    @Override protected void beforeTest() throws Exception {
+        currentTest().beforeTest();
+    }
+
+    /** {@inheritDoc} */
+    @Override protected void afterTest() throws Exception {
+        currentTest().afterTest();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(0)
+    @Params(atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    public void testCreateIndexAtomicPartitionedGet() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(0)
+    @Params(atomicityMode = ATOMIC, cacheMode = REPLICATED)
+    public void testCreateIndexAtomicReplicatedGet() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(0)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    public void testCreateIndexTransactionalPartitionedGet() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(0)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = REPLICATED)
+    public void testCreateIndexTransactionalReplicatedGet() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(1)
+    @Params(atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    public void testCreateIndexAtomicPartitionedGetAll() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(1)
+    @Params(atomicityMode = ATOMIC, cacheMode = REPLICATED)
+    public void testCreateIndexAtomicReplicatedGetAll() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(1)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    public void testCreateIndexTransactionalPartitionedGetAll() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(1)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = REPLICATED)
+    public void testCreateIndexTransactionalReplicatedGetAll() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(2)
+    @Params(atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    public void testCreateIndexAtomicPartitionedScan() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(2)
+    @Params(atomicityMode = ATOMIC, cacheMode = REPLICATED)
+    public void testCreateIndexAtomicReplicatedScan() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(2)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    public void testCreateIndexTransactionalPartitionedScan() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(2)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = REPLICATED)
+    public void testCreateIndexTransactionalReplicatedScan() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(3)
+    @Params(atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    public void testCreateIndexAtomicPartitionedSqlQuery() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(3)
+    @Params(atomicityMode = ATOMIC, cacheMode = REPLICATED)
+    public void testCreateIndexAtomicReplicatedSqlQuery() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(3)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    public void testCreateIndexTransactionalPartitionedSqlQuery() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(3)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = REPLICATED)
+    public void testCreateIndexTransactionalReplicatedSqlQuery() throws Exception {
+        doTestCreateIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(0)
+    @Params(atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    public void testDestroyIndexAtomicPartitionedGet() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(0)
+    @Params(atomicityMode = ATOMIC, cacheMode = REPLICATED)
+    public void testDestroyIndexAtomicReplicatedGet() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(0)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    public void testDestroyIndexTransactionalPartitionedGet() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(0)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = REPLICATED)
+    public void testDestroyIndexTransactionalReplicatedGet() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(1)
+    @Params(atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    public void testDestroyIndexAtomicPartitionedGetAll() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(1)
+    @Params(atomicityMode = ATOMIC, cacheMode = REPLICATED)
+    public void testDestroyIndexAtomicReplicatedGetAll() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(1)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    public void testDestroyIndexTransactionalPartitionedGetAll() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(1)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = REPLICATED)
+    public void testDestroyIndexTransactionalReplicatedGetAll() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(2)
+    @Params(atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    public void testDestroyIndexAtomicPartitionedScan() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(2)
+    @Params(atomicityMode = ATOMIC, cacheMode = REPLICATED)
+    public void testDestroyIndexAtomicReplicatedScan() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(2)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    public void testDestroyIndexTransactionalPartitionedScan() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(2)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = REPLICATED)
+    public void testDestroyIndexTransactionalReplicatedScan() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(3)
+    @Params(atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    public void testDestroyIndexAtomicPartitionedSqlQuery() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(3)
+    @Params(atomicityMode = ATOMIC, cacheMode = REPLICATED)
+    public void testDestroyIndexAtomicReplicatedSqlQuery() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(3)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    public void testDestroyIndexTransactionalPartitionedSqlQuery() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    @TestIndex(3)
+    @Params(atomicityMode = TRANSACTIONAL, cacheMode = REPLICATED)
+    public void testDestroyIndexTransactionalReplicatedSqlQuery() throws Exception {
+        doTestDestroyIndex();
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    private void doTestCreateIndex() throws Exception {
+        IgniteEx ignite = currentTest().baseline().get(0);
+
+        List<T3<String, String, String>> caches = createCaches(ignite);
+
+        currentTest().doTest(
+            msg -> msg instanceof SchemaOperationStatusMessage,
+            () -> createIndex(ignite, caches.remove(caches.size() - 1))
+        );
+    }
+
+    /**
+     * @throws Exception If failed.
+     */
+    private void doTestDestroyIndex() throws Exception {
+        IgniteEx ignite = currentTest().baseline().get(0);
+
+        List<T3<String, String, String>> caches = createCaches(ignite);
+
+        for (T3<String, String, String> pair : caches)
+            createIndex(ignite, pair);
+
+        currentTest().doTest(
+            msg -> msg instanceof SchemaOperationStatusMessage,
+            () -> destroyIndex(ignite, caches.remove(caches.size() - 1))
+        );
+    }
+
+    /**
+     * @param ignite Ignite instance.
+     * @return 3 pairs {@code {cacheName, tableName, indexName}} for further sql operations.
+     */
+    @NotNull private List<T3<String, String, String>> createCaches(IgniteEx ignite)
{
+        List<T3<String, String, String>> caches = new ArrayList<>();
+
+        for (int i = 0; i < 3; i++) {
+            String tblName = "TABLE_" + UUID.randomUUID().toString().replace('-', '_');
+
+            String cacheName = "CACHE_" + tblName;
+
+            CacheConfiguration<?, ?> ccfg = new CacheConfiguration<>(cacheName).setSqlSchema("PUBLIC");
+
+            IgniteCache<?, ?> cache = ignite.createCache(ccfg);
+
+            String createTblQryStr = String.format(
+                "CREATE TABLE %s (id LONG, name VARCHAR, city_id LONG, PRIMARY KEY (id, city_id))
" +
+                    "WITH \"backups=1, affinityKey=city_id\"",
+                tblName
+            );
+
+            cache.query(new SqlFieldsQuery(createTblQryStr)).getAll();
+
+            String idxName = "IDX_" + tblName;
+
+            caches.add(new T3<>(cacheName, tblName, idxName));
+        }
+
+        return caches;
+    }
+
+    /**
+     *
+     */
+    private void createIndex(IgniteEx ignite, T3<String, String, String> pair) {
+        IgniteCache<?, ?> cache = ignite.getOrCreateCache(pair.get1());
+
+        String createIdxQryStr = String.format("CREATE INDEX %S on %s (city_id)", pair.get3(),
pair.get2());
+
+        cache.query(new SqlFieldsQuery(createIdxQryStr)).getAll();
+    }
+
+    /**
+     *
+     */
+    private void destroyIndex(IgniteEx ignite, T3<String, String, String> pair) {
+        IgniteCache<?, ?> cache = ignite.getOrCreateCache(pair.get1());
+
+        String createIdxQryStr = String.format("DROP INDEX %s", pair.get3());
+
+        cache.query(new SqlFieldsQuery(createIdxQryStr)).getAll();
+    }
+
+    /**
+     *
+     */
+    @Target(ElementType.METHOD)
+    @Retention(RetentionPolicy.RUNTIME)
+    protected @interface TestIndex {
+        /**
+         * Index in {@link CacheBlockOnCreateDestoryIndexTest#tests} list.
+         */
+        int value();
+    }
+
+    /**
+     * Index in {@link CacheBlockOnCreateDestoryIndexTest#tests} list.
+     *
+     * @see TestIndex#value()
+     */
+    private CacheBlockOnReadAbstractTest currentTest() {
+        return tests.get(currentTestAnnotation(TestIndex.class).value());
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/3fae41b1/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheBlockOnSqlQueryTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheBlockOnSqlQueryTest.java
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheBlockOnSqlQueryTest.java
new file mode 100644
index 0000000..f1d96ea
--- /dev/null
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheBlockOnSqlQueryTest.java
@@ -0,0 +1,131 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.processors.cache.distributed;
+
+import java.util.Random;
+import org.apache.ignite.cache.query.SqlQuery;
+import org.apache.ignite.cache.query.annotations.QuerySqlField;
+import org.apache.ignite.configuration.CacheConfiguration;
+import org.jetbrains.annotations.NotNull;
+
+import static org.apache.ignite.cache.CacheAtomicityMode.ATOMIC;
+import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL;
+import static org.apache.ignite.cache.CacheMode.PARTITIONED;
+
+/**
+ *
+ */
+public class CacheBlockOnSqlQueryTest extends CacheBlockOnReadAbstractTest {
+
+    /** {@inheritDoc} */
+    @Override @NotNull protected CacheReadBackgroundOperation<?, ?> getReadOperation()
{
+        return new CacheReadBackgroundOperation<Integer, TestingEntity>() {
+            /** Random. */
+            private Random random = new Random();
+
+            /** {@inheritDoc} */
+            @Override protected CacheConfiguration<Integer, TestingEntity> createCacheConfiguration()
{
+                return super.createCacheConfiguration().setIndexedTypes(Integer.class, TestingEntity.class);
+            }
+
+            /** {@inheritDoc} */
+            @Override protected Integer createKey(int idx) {
+                return idx;
+            }
+
+            /** {@inheritDoc} */
+            @Override protected TestingEntity createValue(int idx) {
+                return new TestingEntity(idx, idx);
+            }
+
+            /** {@inheritDoc} */
+            @Override public void doRead() {
+                int idx = random.nextInt(entriesCount());
+
+                cache().query(
+                    new SqlQuery<>(TestingEntity.class, "val >= ? and val < ?")
+                        .setArgs(idx, idx + 500)
+                ).getAll();
+            }
+        };
+    }
+
+    /**
+     *
+     */
+    public static class TestingEntity {
+        /** Id. */
+        @QuerySqlField(index = true)
+        public Integer id;
+
+        /** Value. */
+        @QuerySqlField(index = true)
+        public double val;
+
+        /**
+         * Default constructor.
+         */
+        public TestingEntity() {
+        }
+
+        /**
+         * @param id Id.
+         * @param val Value.
+         */
+        public TestingEntity(Integer id, double val) {
+            this.id = id;
+            this.val = val;
+        }
+    }
+
+    /** {@inheritDoc} */
+    @Params(baseline = 1, atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    @Override public void testStartServerAtomicPartitioned() {
+        fail("https://issues.apache.org/jira/browse/IGNITE-9916");
+    }
+
+    /** {@inheritDoc} */
+    @Params(baseline = 1, atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    @Override public void testStartServerTransactionalPartitioned() {
+        fail("https://issues.apache.org/jira/browse/IGNITE-9916");
+    }
+
+    /** {@inheritDoc} */
+    @Params(baseline = 1, atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    @Override public void testStopServerAtomicPartitioned() {
+        fail("https://issues.apache.org/jira/browse/IGNITE-9916");
+    }
+
+    /** {@inheritDoc} */
+    @Params(baseline = 1, atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    @Override public void testStopServerTransactionalPartitioned() {
+        fail("https://issues.apache.org/jira/browse/IGNITE-9916");
+    }
+
+    /** {@inheritDoc} */
+    @Params(baseline = 1, atomicityMode = ATOMIC, cacheMode = PARTITIONED)
+    @Override public void testStopBaselineAtomicPartitioned() {
+        fail("https://issues.apache.org/jira/browse/IGNITE-9916");
+    }
+
+    /** {@inheritDoc} */
+    @Params(baseline = 1, atomicityMode = TRANSACTIONAL, cacheMode = PARTITIONED)
+    @Override public void testStopBaselineTransactionalPartitioned() {
+        fail("https://issues.apache.org/jira/browse/IGNITE-9916");
+    }
+}

http://git-wip-us.apache.org/repos/asf/ignite/blob/3fae41b1/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheBlockExchangeOnSqlReadOperationsTestSuite.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheBlockExchangeOnSqlReadOperationsTestSuite.java
b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheBlockExchangeOnSqlReadOperationsTestSuite.java
new file mode 100644
index 0000000..3be640b
--- /dev/null
+++ b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheBlockExchangeOnSqlReadOperationsTestSuite.java
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.testsuites;
+
+import junit.framework.TestSuite;
+import org.apache.ignite.internal.processors.cache.distributed.CacheBlockOnCreateDestoryIndexTest;
+import org.apache.ignite.internal.processors.cache.distributed.CacheBlockOnSqlQueryTest;
+
+/**
+ * Test suite for cache queries.
+ */
+public class IgniteCacheBlockExchangeOnSqlReadOperationsTestSuite extends TestSuite {
+    /**
+     * @return Test suite.
+     */
+    public static TestSuite suite() {
+        TestSuite suite = new TestSuite("Do Not Block Read Operations Test Suite");
+
+        suite.addTestSuite(CacheBlockOnSqlQueryTest.class);
+        suite.addTestSuite(CacheBlockOnCreateDestoryIndexTest.class);
+
+        return suite;
+    }
+}


Mime
View raw message