You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2018/10/23 15:01:32 UTC
[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.
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;
+ }
+}