WIP

Author: anton-vinogradov

modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMdcGetTest.java

@@ -17,20 +17,26 @@
 
 package org.apache.ignite.internal.processors.cache;
 
+import java.util.ArrayList;
 import java.util.Collections;
+import java.util.List;
 import java.util.UUID;
 import java.util.concurrent.ThreadLocalRandom;
 import org.apache.ignite.IgniteCache;
 import org.apache.ignite.IgniteSystemProperties;
+import org.apache.ignite.cache.CacheAtomicityMode;
 import org.apache.ignite.configuration.CacheConfiguration;
 import org.apache.ignite.configuration.IgniteConfiguration;
 import org.apache.ignite.internal.IgniteEx;
 import org.apache.ignite.internal.IgniteNodeAttributes;
 import org.apache.ignite.internal.TestRecordingCommunicationSpi;
 import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
 import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
 
 /** */
+@RunWith(Parameterized.class)
 public class CacheMdcGetTest extends GridCommonAbstractTest {
     /** */
     private static final String DC_ID_0 = "DC0";
@@ -44,6 +50,22 @@ public class CacheMdcGetTest extends GridCommonAbstractTest {
     /** */
     private static final String VAL = "val";
 
+    /** */
+    @Parameterized.Parameters(name = "atomicity={0}")
+    public static Iterable<Object[]> data() {
+        List<Object[]> res = new ArrayList<>();
+
+        for (CacheAtomicityMode mode : CacheAtomicityMode.values()) {
+            res.add(new Object[] {mode});
+        }
+
+        return res;
+    }
+
+    /** */
+    @Parameterized.Parameter()
+    public CacheAtomicityMode atomicityMode;
+
     /** {@inheritDoc} */
     @Override protected void afterTest() throws Exception {
         super.afterTest();
@@ -88,6 +110,7 @@ public void test() throws Exception {
         CacheConfiguration<Object, Object> ccfg = new CacheConfiguration<>(DEFAULT_CACHE_NAME);
 
         ccfg.setBackups(1);
+        ccfg.setAtomicityMode(atomicityMode);
 
         IgniteCache<Object, Object> cache = client.createCache(ccfg);