You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2018/12/11 08:28:58 UTC
[11/51] [partial] ignite git commit: IGNITE-10175 migrate core
modules tests from Junit 3 to 4 - Fixes #5562.
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureSerializationTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureSerializationTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureSerializationTest.java
index 2b7d3a4..84970d0 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureSerializationTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/closure/GridClosureSerializationTest.java
@@ -31,10 +31,14 @@ import org.apache.ignite.lang.IgniteCallable;
import org.apache.ignite.resources.JobContextResource;
import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
* Tests handling of job result serialization error.
*/
+@RunWith(JUnit4.class)
public class GridClosureSerializationTest extends GridCommonAbstractTest {
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(final String igniteInstanceName) throws Exception {
@@ -57,6 +61,7 @@ public class GridClosureSerializationTest extends GridCommonAbstractTest {
* @throws Exception If failed.
*/
@SuppressWarnings({"Convert2Lambda"})
+ @Test
public void testSerializationFailure() throws Exception {
final IgniteEx ignite0 = grid(0);
final IgniteEx ignite1 = grid(1);
@@ -78,6 +83,7 @@ public class GridClosureSerializationTest extends GridCommonAbstractTest {
* @throws Exception If failed.
*/
@SuppressWarnings({"Convert2Lambda"})
+ @Test
public void testExceptionSerializationFailure() throws Exception {
final IgniteEx ignite0 = grid(0);
final IgniteEx ignite1 = grid(1);
@@ -99,6 +105,7 @@ public class GridClosureSerializationTest extends GridCommonAbstractTest {
* @throws Exception If failed.
*/
@SuppressWarnings({"Convert2Lambda"})
+ @Test
public void testAttributesSerializationFailure() throws Exception {
final IgniteEx ignite0 = grid(0);
final IgniteEx ignite1 = grid(1);
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridAddressResolverSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridAddressResolverSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridAddressResolverSelfTest.java
index 2b706d5..d29f062 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridAddressResolverSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridAddressResolverSelfTest.java
@@ -30,11 +30,15 @@ import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.apache.ignite.testframework.junits.common.GridCommonTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
* Address Resolver test.
*/
@GridCommonTest(group = "Kernal Self")
+@RunWith(JUnit4.class)
public class GridAddressResolverSelfTest extends GridCommonAbstractTest {
/** */
private final InetSocketAddress addr0 = new InetSocketAddress("test0.com", 5000);
@@ -76,6 +80,7 @@ public class GridAddressResolverSelfTest extends GridCommonAbstractTest {
}
/** */
+ @Test
public void test() throws Exception {
startGrid(0);
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridUpdateNotifierSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridUpdateNotifierSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridUpdateNotifierSelfTest.java
index 58c41b5..c73dd27 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridUpdateNotifierSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/GridUpdateNotifierSelfTest.java
@@ -24,12 +24,16 @@ import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgniteProductVersion;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.apache.ignite.testframework.junits.common.GridCommonTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
import org.mockito.Mockito;
/**
* Update notifier test.
*/
@GridCommonTest(group = "Kernal Self")
+@RunWith(JUnit4.class)
public class GridUpdateNotifierSelfTest extends GridCommonAbstractTest {
/** */
private String updateStatusParams;
@@ -64,6 +68,7 @@ public class GridUpdateNotifierSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNotifier() throws Exception {
String nodeVer = IgniteProperties.get("ignite.version");
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/GridComputeJobExecutionErrorToLogManualTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/GridComputeJobExecutionErrorToLogManualTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/GridComputeJobExecutionErrorToLogManualTest.java
index dc24156..5afb0e2 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/GridComputeJobExecutionErrorToLogManualTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/GridComputeJobExecutionErrorToLogManualTest.java
@@ -26,10 +26,14 @@ import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
* Manual test to reproduce IGNITE-4053
*/
+@RunWith(JUnit4.class)
public class GridComputeJobExecutionErrorToLogManualTest extends GridCommonAbstractTest {
/** */
private static final TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
@@ -58,6 +62,7 @@ public class GridComputeJobExecutionErrorToLogManualTest extends GridCommonAbstr
/**
* @throws Exception If fails.
*/
+ @Test
public void testRuntimeException() throws Exception {
Ignite ignite = grid(0);
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java
index d1fbb34..3e6736e 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeConfigVariationsFullApiTest.java
@@ -50,11 +50,15 @@ import org.apache.ignite.lang.IgniteRunnable;
import org.apache.ignite.testframework.junits.IgniteConfigVariationsAbstractTest;
import org.jetbrains.annotations.Nullable;
import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
* Full API compute test.
*/
@SuppressWarnings("unchecked")
+@RunWith(JUnit4.class)
public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariationsAbstractTest {
/** Max job count. */
private static final int MAX_JOB_COUNT = 10;
@@ -177,6 +181,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testExecuteTaskClass() throws Exception {
runTest(jobFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -201,6 +206,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testExecuteTaskClassAsync() throws Exception {
runTest(jobFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -225,6 +231,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testExecuteTask() throws Exception {
runTest(jobFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -248,6 +255,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testExecuteTaskAsync() throws Exception {
runTest(jobFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -271,6 +279,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testBroadcastClosure() throws Exception {
runTest(closureFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -294,6 +303,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testBroadcastClosureAsync() throws Exception {
runTest(closureFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -317,6 +327,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testBroadcastCallable() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -346,6 +357,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testBroadcastCallableAsync() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -375,6 +387,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testBroadcastRunnable() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -389,6 +402,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testBroadcastRunnableAsync() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -405,6 +419,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testRun() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -427,6 +442,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testRunAsync() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -453,6 +469,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testApplyAsync() throws Exception {
runTest(closureFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -480,6 +497,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testApply() throws Exception {
runTest(closureFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -499,6 +517,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testApplyForCollection() throws Exception {
runTest(closureFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -524,6 +543,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testApplyForCollectionAsync() throws Exception {
runTest(closureFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -550,6 +570,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testApplyForCollectionWithReducer() throws Exception {
runTest(closureFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -585,6 +606,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testApplyForCollectionWithReducerAsync() throws Exception {
runTest(closureFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -620,6 +642,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testCallAsync() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -648,6 +671,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testCall() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -668,6 +692,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testCallCollection() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -690,6 +715,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testCallCollectionAsync() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -712,6 +738,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testCallCollectionWithReducer() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -746,6 +773,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testCallCollectionWithReducerAsync() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -780,6 +808,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testAffinityCall() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -806,6 +835,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testAffinityCallAsync() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -834,6 +864,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultiCacheAffinityCall() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -861,6 +892,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultiCacheAffinityCallAsync() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -890,6 +922,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultiCacheByPartIdAffinityCall() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -917,6 +950,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultiCacheByPartIdAffinityCallAsync() throws Exception {
runTest(callableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -946,6 +980,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testAffinityRun() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -965,6 +1000,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testAffinityRunAsync() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -986,6 +1022,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultiCacheAffinityRun() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -1006,6 +1043,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultiCacheAffinityRunAsync() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -1028,6 +1066,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultiCacheByPartIdAffinityRun() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -1048,6 +1087,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultiCacheByPartIdAffinityRunAsync() throws Exception {
runTest(runnableFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -1070,6 +1110,7 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
/**
* @throws Exception If failed.
*/
+ @Test
public void testDeployExecuteByName() throws Exception {
runTest(jobFactories, new ComputeTest() {
@Override public void test(Factory factory, Ignite ignite) throws Exception {
@@ -1127,7 +1168,8 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
* @param ignite Ignite instance to use.
* @throws Exception If failed.
*/
- public void test(Factory factory, Ignite ignite) throws Exception;
+ @Test
+ public void test(Factory factory, Ignite ignite) throws Exception;
}
/**
@@ -2469,4 +2511,4 @@ public class IgniteComputeConfigVariationsFullApiTest extends IgniteConfigVariat
out.writeObject(eVal);
}
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorConfigurationSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorConfigurationSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorConfigurationSelfTest.java
index 2277100..b35b625 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorConfigurationSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorConfigurationSelfTest.java
@@ -25,10 +25,14 @@ import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
* Tests custom executor configuration.
*/
+@RunWith(JUnit4.class)
public class IgniteComputeCustomExecutorConfigurationSelfTest extends GridCommonAbstractTest {
/** */
private static final TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
@@ -49,6 +53,7 @@ public class IgniteComputeCustomExecutorConfigurationSelfTest extends GridCommon
/**
* @throws Exception If failed.
*/
+ @Test
public void testConfigurations() throws Exception {
try {
checkStartWithInvalidConfiguration(getConfiguration("node0")
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorSelfTest.java
index 18c52c0..b59fdcf 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/IgniteComputeCustomExecutorSelfTest.java
@@ -36,12 +36,16 @@ import org.apache.ignite.lang.IgniteReducer;
import org.apache.ignite.lang.IgniteRunnable;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.jetbrains.annotations.Nullable;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
* Tests custom executor named pools.
*
* https://issues.apache.org/jira/browse/IGNITE-4699
*/
+@RunWith(JUnit4.class)
public class IgniteComputeCustomExecutorSelfTest extends GridCommonAbstractTest {
/** */
private static final int GRID_CNT = 2;
@@ -96,6 +100,7 @@ public class IgniteComputeCustomExecutorSelfTest extends GridCommonAbstractTest
/**
* @throws Exception If fails.
*/
+ @Test
public void testInvalidCustomExecutor() throws Exception {
grid(0).compute().withExecutor("invalid").broadcast(new IgniteRunnable() {
@Override public void run() {
@@ -107,6 +112,7 @@ public class IgniteComputeCustomExecutorSelfTest extends GridCommonAbstractTest
/**
* @throws Exception If fails.
*/
+ @Test
public void testAllComputeApiByCustomExecutor() throws Exception {
IgniteCompute comp = grid(0).compute().withExecutor(EXEC_NAME0);
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/PublicThreadpoolStarvationTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/PublicThreadpoolStarvationTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/PublicThreadpoolStarvationTest.java
index dd9e0d5..c99b55a 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/PublicThreadpoolStarvationTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/compute/PublicThreadpoolStarvationTest.java
@@ -25,6 +25,9 @@ import org.apache.ignite.internal.binary.BinaryMarshaller;
import org.apache.ignite.internal.processors.cache.GridCacheAbstractSelfTest;
import org.apache.ignite.lang.IgniteRunnable;
import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
import static org.apache.ignite.cache.CacheAtomicityMode.ATOMIC;
import static org.apache.ignite.cache.CacheMode.PARTITIONED;
@@ -33,6 +36,7 @@ import static org.apache.ignite.cache.CacheMode.PARTITIONED;
* Test to validate https://issues.apache.org/jira/browse/IGNITE-4239
* Jobs hang when a lot of jobs calculate cache.
*/
+@RunWith(JUnit4.class)
public class PublicThreadpoolStarvationTest extends GridCacheAbstractSelfTest {
/** Cache size. */
private static final int CACHE_SIZE = 10;
@@ -113,6 +117,7 @@ public class PublicThreadpoolStarvationTest extends GridCacheAbstractSelfTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testCacheSizeOnPublicThreadpoolStarvation() throws Exception {
grid(0).compute().run(new IgniteRunnable() {
@Override public void run() {
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
index d2d895e..e5800bf 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java
@@ -53,6 +53,9 @@ import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static java.util.concurrent.TimeUnit.SECONDS;
@@ -67,6 +70,7 @@ import static org.apache.ignite.internal.processors.continuous.GridContinuousPro
/**
* Event consume test.
*/
+@RunWith(JUnit4.class)
public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/** */
private static final String PRJ_PRED_CLS_NAME = "org.apache.ignite.tests.p2p.GridEventConsumeProjectionPredicate";
@@ -174,6 +178,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testApi() throws Exception {
try {
grid(0).events().stopRemoteListen(null);
@@ -251,6 +256,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testApiAsyncOld() throws Exception {
IgniteEvents evtAsync = grid(0).events().withAsync();
@@ -341,6 +347,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testApiAsync() throws Exception {
IgniteEvents evt = grid(0).events();
@@ -420,6 +427,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testAllEvents() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -460,6 +468,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testEventsByType() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -501,6 +510,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testEventsByFilter() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -545,6 +555,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testEventsByTypeAndFilter() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -591,6 +602,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testRemoteProjection() throws Exception {
final Collection<UUID> nodeIds = new ConcurrentSkipListSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -632,6 +644,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testProjectionWithLocalNode() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -673,6 +686,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testLocalNodeOnly() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -716,6 +730,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testStopByCallback() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -757,6 +772,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testStopRemoteListen() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -807,6 +823,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testStopLocalListenByCallback() throws Exception {
final AtomicInteger cnt = new AtomicInteger();
final CountDownLatch latch = new CountDownLatch(1);
@@ -842,6 +859,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNodeJoin() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -893,6 +911,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNodeJoinWithProjection() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -947,6 +966,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
*
* @throws Exception If failed.
*/
+ @Test
public void testNodeJoinWithP2P() throws Exception {
fail("https://issues.apache.org/jira/browse/IGNITE-585");
@@ -995,6 +1015,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testResources() throws Exception {
final Collection<UUID> nodeIds = new HashSet<>();
final AtomicInteger cnt = new AtomicInteger();
@@ -1049,6 +1070,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMasterNodeLeave() throws Exception {
final CountDownLatch latch = new CountDownLatch(GRID_CNT);
@@ -1088,6 +1110,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMasterNodeLeaveNoAutoUnsubscribe() throws Exception {
Ignite g = startGrid("anotherGrid");
@@ -1145,6 +1168,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultithreadedWithNodeRestart() throws Exception {
final AtomicBoolean stop = new AtomicBoolean();
final BlockingQueue<IgniteBiTuple<Integer, UUID>> queue = new LinkedBlockingQueue<>();
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridMessageListenSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridMessageListenSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridMessageListenSelfTest.java
index c0cd5f2..7fd5eab 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridMessageListenSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridMessageListenSelfTest.java
@@ -40,12 +40,16 @@ import org.apache.ignite.resources.IgniteInstanceResource;
import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.jetbrains.annotations.Nullable;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
import static java.util.concurrent.TimeUnit.SECONDS;
/**
* Message listen test.
*/
+@RunWith(JUnit4.class)
public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/** */
private static final int GRID_CNT = 3;
@@ -143,6 +147,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNullTopic() throws Exception {
latch = new CountDownLatch(MSG_CNT * GRID_CNT);
@@ -163,6 +168,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNonNullTopic() throws Exception {
latch = new CountDownLatch(MSG_CNT * GRID_CNT);
@@ -183,6 +189,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testStopListen() throws Exception {
latch = new CountDownLatch(GRID_CNT);
@@ -208,6 +215,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testProjection() throws Exception {
latch = new CountDownLatch(MSG_CNT * (GRID_CNT - 1));
@@ -227,6 +235,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNodeJoin() throws Exception {
latch = new CountDownLatch(MSG_CNT * (GRID_CNT + 1));
@@ -259,6 +268,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNodeJoinWithProjection() throws Exception {
latch = new CountDownLatch(MSG_CNT * GRID_CNT);
@@ -298,6 +308,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNullTopicWithDeployment() throws Exception {
Class<?> cls = getExternalClassLoader().loadClass(LSNR_CLS_NAME);
@@ -317,6 +328,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNonNullTopicWithDeployment() throws Exception {
ClassLoader ldr = getExternalClassLoader();
@@ -341,6 +353,7 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testListenActor() throws Exception {
latch = new CountDownLatch(MSG_CNT * (GRID_CNT + 1));
@@ -494,4 +507,4 @@ public class GridMessageListenSelfTest extends GridCommonAbstractTest {
latch.countDown();
}
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/IgniteNoCustomEventsOnNodeStart.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/IgniteNoCustomEventsOnNodeStart.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/IgniteNoCustomEventsOnNodeStart.java
index dc151a6..0e6f736 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/IgniteNoCustomEventsOnNodeStart.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/IgniteNoCustomEventsOnNodeStart.java
@@ -25,10 +25,14 @@ import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
* Sanity test to verify there are no unnecessary messages on node start.
*/
+@RunWith(JUnit4.class)
public class IgniteNoCustomEventsOnNodeStart extends GridCommonAbstractTest {
/** */
private static final TcpDiscoveryIpFinder IP_FINDER = new TcpDiscoveryVmIpFinder(true);
@@ -56,6 +60,7 @@ public class IgniteNoCustomEventsOnNodeStart extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testNoCustomEventsOnStart() throws Exception {
failed = false;
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/BPlusTreeSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/BPlusTreeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/BPlusTreeSelfTest.java
index ae9aff8..57a9715 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/BPlusTreeSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/BPlusTreeSelfTest.java
@@ -77,6 +77,9 @@ import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.jetbrains.annotations.Nullable;
import org.jsr166.ConcurrentLinkedHashMap;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
import static org.apache.ignite.internal.pagemem.PageIdUtils.effectivePageId;
import static org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree.rnd;
@@ -86,6 +89,7 @@ import static org.apache.ignite.internal.util.IgniteTree.OperationType.REMOVE;
/**
*/
+@RunWith(JUnit4.class)
public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/** */
private static final short LONG_INNER_IO = 30000;
@@ -216,6 +220,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testFind() throws IgniteCheckedException {
TestTree tree = createTestTree(true);
TreeMap<Long, Long> map = new TreeMap<>();
@@ -234,6 +239,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testRetries() throws IgniteCheckedException {
TestTree tree = createTestTree(true);
@@ -254,6 +260,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testIsEmpty() throws Exception {
TestTree tree = createTestTree(true);
@@ -277,6 +284,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testFindWithClosure() throws IgniteCheckedException {
TestTree tree = createTestTree(true);
TreeMap<Long, Long> map = new TreeMap<>();
@@ -339,6 +347,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_1_20_mm_1() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 20;
@@ -351,6 +360,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_1_20_mm_0() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 20;
@@ -363,6 +373,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_1_20_pm_1() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 20;
@@ -375,6 +386,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_1_20_pm_0() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 20;
@@ -387,6 +399,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_1_20_pp_1() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 20;
@@ -399,6 +412,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_1_20_pp_0() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 20;
@@ -411,6 +425,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_1_20_mp_1() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 20;
@@ -423,6 +438,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_1_20_mp_0() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 20;
@@ -436,6 +452,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_2_40_mm_1() throws IgniteCheckedException {
MAX_PER_PAGE = 2;
CNT = 40;
@@ -448,6 +465,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_2_40_mm_0() throws IgniteCheckedException {
MAX_PER_PAGE = 2;
CNT = 40;
@@ -460,6 +478,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_2_40_pm_1() throws IgniteCheckedException {
MAX_PER_PAGE = 2;
CNT = 40;
@@ -472,6 +491,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_2_40_pm_0() throws IgniteCheckedException {
MAX_PER_PAGE = 2;
CNT = 40;
@@ -484,6 +504,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_2_40_pp_1() throws IgniteCheckedException {
MAX_PER_PAGE = 2;
CNT = 40;
@@ -496,6 +517,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_2_40_pp_0() throws IgniteCheckedException {
MAX_PER_PAGE = 2;
CNT = 40;
@@ -508,6 +530,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_2_40_mp_1() throws IgniteCheckedException {
MAX_PER_PAGE = 2;
CNT = 40;
@@ -520,6 +543,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_2_40_mp_0() throws IgniteCheckedException {
MAX_PER_PAGE = 2;
CNT = 40;
@@ -533,6 +557,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_3_60_mm_1() throws IgniteCheckedException {
MAX_PER_PAGE = 3;
CNT = 60;
@@ -545,6 +570,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_3_60_mm_0() throws IgniteCheckedException {
MAX_PER_PAGE = 3;
CNT = 60;
@@ -557,6 +583,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_3_60_pm_1() throws IgniteCheckedException {
MAX_PER_PAGE = 3;
CNT = 60;
@@ -569,6 +596,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_3_60_pm_0() throws IgniteCheckedException {
MAX_PER_PAGE = 3;
CNT = 60;
@@ -581,6 +609,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_3_60_pp_1() throws IgniteCheckedException {
MAX_PER_PAGE = 3;
CNT = 60;
@@ -593,6 +622,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_3_60_pp_0() throws IgniteCheckedException {
MAX_PER_PAGE = 3;
CNT = 60;
@@ -605,6 +635,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_3_60_mp_1() throws IgniteCheckedException {
MAX_PER_PAGE = 3;
CNT = 60;
@@ -617,6 +648,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testPutRemove_3_60_mp_0() throws IgniteCheckedException {
MAX_PER_PAGE = 3;
CNT = 60;
@@ -733,6 +765,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testRandomInvoke_1_30_1() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 30;
@@ -743,6 +776,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testRandomInvoke_1_30_0() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 30;
@@ -854,6 +888,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testRandomPutRemove_1_30_0() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 30;
@@ -864,6 +899,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testRandomPutRemove_1_30_1() throws IgniteCheckedException {
MAX_PER_PAGE = 1;
CNT = 30;
@@ -874,6 +910,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassiveRemove3_false() throws Exception {
MAX_PER_PAGE = 3;
@@ -883,6 +920,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassiveRemove3_true() throws Exception {
MAX_PER_PAGE = 3;
@@ -892,6 +930,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassiveRemove2_false() throws Exception {
MAX_PER_PAGE = 2;
@@ -901,6 +940,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassiveRemove2_true() throws Exception {
MAX_PER_PAGE = 2;
@@ -910,6 +950,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassiveRemove1_false() throws Exception {
MAX_PER_PAGE = 1;
@@ -919,6 +960,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassiveRemove1_true() throws Exception {
MAX_PER_PAGE = 1;
@@ -993,6 +1035,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassivePut1_true() throws Exception {
MAX_PER_PAGE = 1;
@@ -1002,6 +1045,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassivePut1_false() throws Exception {
MAX_PER_PAGE = 1;
@@ -1011,12 +1055,14 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassivePut2_true() throws Exception {
MAX_PER_PAGE = 2;
doTestMassivePut(true);
}
+ @Test
public void testMassivePut2_false() throws Exception {
MAX_PER_PAGE = 2;
@@ -1026,12 +1072,14 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMassivePut3_true() throws Exception {
MAX_PER_PAGE = 3;
doTestMassivePut(true);
}
+ @Test
public void testMassivePut3_false() throws Exception {
MAX_PER_PAGE = 3;
@@ -1164,6 +1212,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testEmptyCursors() throws IgniteCheckedException {
MAX_PER_PAGE = 5;
@@ -1194,6 +1243,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testCursorConcurrentMerge() throws IgniteCheckedException {
MAX_PER_PAGE = 5;
@@ -1269,6 +1319,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
*
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testSizeForPutRmvSequential() throws IgniteCheckedException {
MAX_PER_PAGE = 5;
@@ -1358,6 +1409,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
*
* @throws Exception If failed.
*/
+ @Test
public void testSizeForRandomPutRmvMultithreaded_5_4() throws Exception {
MAX_PER_PAGE = 5;
CNT = 10_000;
@@ -1365,6 +1417,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
doTestSizeForRandomPutRmvMultithreaded(4);
}
+ @Test
public void testSizeForRandomPutRmvMultithreaded_3_256() throws Exception {
MAX_PER_PAGE = 3;
CNT = 10_000;
@@ -1481,6 +1534,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
*
* @see #doTestSizeForRandomPutRmvMultithreadedAsync doTestSizeForRandomPutRmvMultithreadedAsync() for details.
*/
+ @Test
public void testSizeForRandomPutRmvMultithreadedAsync_16() throws Exception {
doTestSizeForRandomPutRmvMultithreadedAsync(16);
}
@@ -1491,6 +1545,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
*
* @see #doTestSizeForRandomPutRmvMultithreadedAsync doTestSizeForRandomPutRmvMultithreadedAsync() for details.
*/
+ @Test
public void testSizeForRandomPutRmvMultithreadedAsync_3() throws Exception {
doTestSizeForRandomPutRmvMultithreadedAsync(3);
}
@@ -1660,6 +1715,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
*
* @throws Exception if test failed
*/
+ @Test
public void testPutSizeLivelock() throws Exception {
MAX_PER_PAGE = 5;
CNT = 800;
@@ -1792,6 +1848,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
*
* @throws Exception If failed.
*/
+ @Test
public void testPutRmvSizeSinglePageContention() throws Exception {
MAX_PER_PAGE = 10;
CNT = 20_000;
@@ -1913,6 +1970,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
*
* @throws Exception If failed.
*/
+ @Test
public void testPutRmvFindSizeMultithreaded() throws Exception {
MAX_PER_PAGE = 5;
CNT = 60_000;
@@ -2050,6 +2108,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testTestRandomPutRemoveMultithreaded_1_30_0() throws Exception {
MAX_PER_PAGE = 1;
CNT = 30;
@@ -2060,6 +2119,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testTestRandomPutRemoveMultithreaded_1_30_1() throws Exception {
MAX_PER_PAGE = 1;
CNT = 30;
@@ -2070,6 +2130,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testTestRandomPutRemoveMultithreaded_2_50_0() throws Exception {
MAX_PER_PAGE = 2;
CNT = 50;
@@ -2080,6 +2141,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testTestRandomPutRemoveMultithreaded_2_50_1() throws Exception {
MAX_PER_PAGE = 2;
CNT = 50;
@@ -2090,6 +2152,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testTestRandomPutRemoveMultithreaded_3_70_0() throws Exception {
MAX_PER_PAGE = 3;
CNT = 70;
@@ -2100,6 +2163,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testTestRandomPutRemoveMultithreaded_3_70_1() throws Exception {
MAX_PER_PAGE = 3;
CNT = 70;
@@ -2110,6 +2174,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws IgniteCheckedException If failed.
*/
+ @Test
public void testFindFirstAndLast() throws IgniteCheckedException {
MAX_PER_PAGE = 5;
@@ -2136,6 +2201,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testIterate() throws Exception {
MAX_PER_PAGE = 5;
@@ -2166,6 +2232,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testIterateConcurrentPutRemove() throws Exception {
iterateConcurrentPutRemove();
}
@@ -2173,6 +2240,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testIterateConcurrentPutRemove_1() throws Exception {
fail("https://issues.apache.org/jira/browse/IGNITE-7265");
@@ -2184,6 +2252,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testIterateConcurrentPutRemove_5() throws Exception {
MAX_PER_PAGE = 5;
@@ -2193,6 +2262,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testIteratePutRemove_10() throws Exception {
MAX_PER_PAGE = 10;
@@ -2338,6 +2408,7 @@ public class BPlusTreeSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testConcurrentGrowDegenerateTreeAndConcurrentRemove() throws Exception {
//calculate tree size when split happens
final TestTree t = createTestTree(true);
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/CacheFreeListImplSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/CacheFreeListImplSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/CacheFreeListImplSelfTest.java
index 74f80df..2f78c56 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/CacheFreeListImplSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/CacheFreeListImplSelfTest.java
@@ -52,10 +52,14 @@ import org.apache.ignite.plugin.extensions.communication.MessageWriter;
import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
import org.jetbrains.annotations.Nullable;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
*
*/
+@RunWith(JUnit4.class)
public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/** */
private static final int CPUS = Runtime.getRuntime().availableProcessors();
@@ -79,6 +83,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteSingleThreaded_1024() throws Exception {
checkInsertDeleteSingleThreaded(1024);
}
@@ -86,6 +91,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteSingleThreaded_2048() throws Exception {
checkInsertDeleteSingleThreaded(2048);
}
@@ -93,6 +99,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteSingleThreaded_4096() throws Exception {
checkInsertDeleteSingleThreaded(4096);
}
@@ -100,6 +107,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteSingleThreaded_8192() throws Exception {
checkInsertDeleteSingleThreaded(8192);
}
@@ -107,6 +115,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteSingleThreaded_16384() throws Exception {
checkInsertDeleteSingleThreaded(16384);
}
@@ -114,6 +123,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteMultiThreaded_1024() throws Exception {
checkInsertDeleteMultiThreaded(1024);
}
@@ -121,6 +131,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteMultiThreaded_2048() throws Exception {
checkInsertDeleteMultiThreaded(2048);
}
@@ -128,6 +139,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteMultiThreaded_4096() throws Exception {
checkInsertDeleteMultiThreaded(4096);
}
@@ -135,6 +147,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteMultiThreaded_8192() throws Exception {
checkInsertDeleteMultiThreaded(8192);
}
@@ -142,6 +155,7 @@ public class CacheFreeListImplSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testInsertDeleteMultiThreaded_16384() throws Exception {
checkInsertDeleteMultiThreaded(16384);
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/DataRegionMetricsSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/DataRegionMetricsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/DataRegionMetricsSelfTest.java
index 122f50e..a62b891 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/DataRegionMetricsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/DataRegionMetricsSelfTest.java
@@ -23,12 +23,16 @@ import org.apache.ignite.configuration.DataRegionConfiguration;
import org.apache.ignite.internal.processors.cache.persistence.DataRegionMetricsImpl;
import org.apache.ignite.internal.processors.cache.ratemetrics.HitRateMetrics;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
import static java.lang.Thread.sleep;
/**
*
*/
+@RunWith(JUnit4.class)
public class DataRegionMetricsSelfTest extends GridCommonAbstractTest {
/** */
private DataRegionMetricsImpl memMetrics;
@@ -61,6 +65,7 @@ public class DataRegionMetricsSelfTest extends GridCommonAbstractTest {
* Test for allocationRate metric in single-threaded mode.
* @throws Exception if any happens during test.
*/
+ @Test
public void testAllocationRateSingleThreaded() throws Exception {
threadsCnt = 1;
memMetrics.rateTimeInterval(RATE_TIME_INTERVAL_2);
@@ -84,6 +89,7 @@ public class DataRegionMetricsSelfTest extends GridCommonAbstractTest {
* Test for allocationRate metric in multi-threaded mode with short silent period in the middle of the test.
* @throws Exception if any happens during test.
*/
+ @Test
public void testAllocationRateMultiThreaded() throws Exception {
threadsCnt = 4;
memMetrics.rateTimeInterval(RATE_TIME_INTERVAL_1);
@@ -123,6 +129,7 @@ public class DataRegionMetricsSelfTest extends GridCommonAbstractTest {
* Test verifies that allocationRate calculation algorithm survives setting new values to rateTimeInterval parameter.
* @throws Exception if any happens during test.
*/
+ @Test
public void testAllocationRateTimeIntervalConcurrentChange() throws Exception {
threadsCnt = 5;
memMetrics.rateTimeInterval(RATE_TIME_INTERVAL_1);
@@ -153,6 +160,7 @@ public class DataRegionMetricsSelfTest extends GridCommonAbstractTest {
*
* @throws Exception if any happens during test.
*/
+ @Test
public void testAllocationRateSubintervalsConcurrentChange() throws Exception {
threadsCnt = 5;
memMetrics.rateTimeInterval(RATE_TIME_INTERVAL_1);
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbDynamicCacheSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbDynamicCacheSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbDynamicCacheSelfTest.java
index 126ed5f..3d8b5aa 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbDynamicCacheSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbDynamicCacheSelfTest.java
@@ -30,10 +30,14 @@ import org.apache.ignite.configuration.DataStorageConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
*
*/
+@RunWith(JUnit4.class)
public class IgniteDbDynamicCacheSelfTest extends GridCommonAbstractTest {
/** {@inheritDoc} */
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
@@ -79,6 +83,7 @@ public class IgniteDbDynamicCacheSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testCreate() throws Exception {
int iterations = 200;
@@ -112,6 +117,7 @@ public class IgniteDbDynamicCacheSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testMultipleDynamicCaches() throws Exception {
int caches = 10;
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbMemoryLeakAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbMemoryLeakAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbMemoryLeakAbstractTest.java
index 81b5515..9047609 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbMemoryLeakAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbMemoryLeakAbstractTest.java
@@ -26,12 +26,16 @@ import org.apache.ignite.configuration.DataStorageConfiguration;
import org.apache.ignite.internal.IgniteEx;
import org.apache.ignite.internal.processors.cache.IgniteCacheProxy;
import org.apache.ignite.internal.processors.cache.persistence.DataStructure;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
import static org.apache.ignite.IgniteSystemProperties.getInteger;
/**
* Base class for memory leaks tests.
*/
+@RunWith(JUnit4.class)
public abstract class IgniteDbMemoryLeakAbstractTest extends IgniteDbAbstractTest {
/** */
private static final int CONCURRENCY_LEVEL = 16;
@@ -173,6 +177,7 @@ public abstract class IgniteDbMemoryLeakAbstractTest extends IgniteDbAbstractTes
/**
* @throws Exception If failed.
*/
+ @Test
public void testMemoryLeak() throws Exception {
final IgniteEx ignite = grid(0);
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetAbstractTest.java
index f170280..9b370bd 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetAbstractTest.java
@@ -46,10 +46,14 @@ import org.apache.ignite.internal.util.typedef.X;
import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.GridTestUtils.SF;
import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
*
*/
+@RunWith(JUnit4.class)
public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/** */
private static final int KEYS_COUNT = 20_000;
@@ -78,6 +82,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
*
*/
+ @Test
public void testGradualRandomPutAllRemoveAll() throws Exception {
IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -138,6 +143,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
*
*/
+ @Test
public void testRandomRemove() throws Exception {
IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -177,6 +183,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
*/
+ @Test
public void testRandomPut() throws Exception {
IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -205,6 +212,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testPutGetSimple() throws Exception {
IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -229,6 +237,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testPutGetLarge() throws Exception {
IgniteCache<Integer, byte[]> cache = cache(DEFAULT_CACHE_NAME);
@@ -271,6 +280,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testPutGetLargeKeys() throws Exception {
IgniteCache<LargeDbKey, Integer> cache = ignite(0).cache(DEFAULT_CACHE_NAME);
@@ -319,6 +329,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testPutGetOverwrite() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -347,6 +358,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testOverwriteNormalSizeAfterSmallerSize() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -371,6 +383,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testPutDoesNotTriggerRead() throws Exception {
IgniteEx ig = grid(0);
@@ -382,6 +395,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testPutGetMultipleObjects() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -455,6 +469,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testSizeClear() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -491,6 +506,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testBounds() throws Exception {
IgniteEx ig = ig();
@@ -549,6 +565,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testMultithreadedPut() throws Exception {
IgniteEx ig = ig();
@@ -613,6 +630,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testPutGetRandomUniqueMultipleObjects() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -680,6 +698,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testPutPrimaryUniqueSecondaryDuplicates() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -724,6 +743,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testPutGetRandomNonUniqueMultipleObjects() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -770,6 +790,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testPutGetRemoveMultipleForward() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -814,6 +835,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testRandomPutGetRemove() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -861,6 +883,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
assertEquals(map.get(key), cache.get(key));
}
+ @Test
public void testPutGetRemoveMultipleBackward() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -905,6 +928,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testIndexOverwrite() throws Exception {
final IgniteCache<Integer, DbValue> cache = cache(DEFAULT_CACHE_NAME);
@@ -948,6 +972,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testObjectKey() throws Exception {
IgniteEx ig = ig();
@@ -993,6 +1018,7 @@ public abstract class IgniteDbPutGetAbstractTest extends IgniteDbAbstractTest {
/**
* @throws Exception If failed.
*/
+ @Test
public void testIterators() throws Exception {
IgniteEx ignite = ig();
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetWithCacheStoreTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetWithCacheStoreTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetWithCacheStoreTest.java
index 8cca7f4..0701514 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetWithCacheStoreTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbPutGetWithCacheStoreTest.java
@@ -32,6 +32,9 @@ import org.apache.ignite.configuration.IgniteReflectionFactory;
import org.apache.ignite.configuration.WALMode;
import org.apache.ignite.internal.IgniteEx;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
import static org.apache.ignite.cache.CacheAtomicityMode.ATOMIC;
import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL;
@@ -39,6 +42,7 @@ import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL;
/**
*
*/
+@RunWith(JUnit4.class)
public class IgniteDbPutGetWithCacheStoreTest extends GridCommonAbstractTest {
/** */
private static Map<Object, Object> storeMap = new ConcurrentHashMap<>();
@@ -93,6 +97,7 @@ public class IgniteDbPutGetWithCacheStoreTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testWriteThrough() throws Exception {
checkWriteThrough(ATOMIC);
checkWriteThrough(TRANSACTIONAL);
@@ -101,6 +106,7 @@ public class IgniteDbPutGetWithCacheStoreTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testReadThrough() throws Exception {
checkReadThrough(ATOMIC);
checkReadThrough(TRANSACTIONAL);
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodeTinyPutGetTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodeTinyPutGetTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodeTinyPutGetTest.java
index 345eb86..14b5b53 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodeTinyPutGetTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IgniteDbSingleNodeTinyPutGetTest.java
@@ -19,10 +19,14 @@ package org.apache.ignite.internal.processors.database;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.internal.IgniteEx;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
* Test for
*/
+@RunWith(JUnit4.class)
public class IgniteDbSingleNodeTinyPutGetTest extends IgniteDbSingleNodePutGetTest {
/** {@inheritDoc} */
@Override protected boolean isLargePage() {
@@ -30,6 +34,7 @@ public class IgniteDbSingleNodeTinyPutGetTest extends IgniteDbSingleNodePutGetTe
}
/** */
+ @Test
public void testPutGetTiny() {
IgniteEx ig = grid(0);
@@ -43,106 +48,127 @@ public class IgniteDbSingleNodeTinyPutGetTest extends IgniteDbSingleNodePutGetTe
}
/** {@inheritDoc} */
+ @Test
@Override public void testGradualRandomPutAllRemoveAll() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testRandomRemove() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testRandomPut() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutGetSimple() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutGetLarge() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutGetOverwrite() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testOverwriteNormalSizeAfterSmallerSize() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutDoesNotTriggerRead() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutGetMultipleObjects() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testSizeClear() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testBounds() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testMultithreadedPut() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutGetRandomUniqueMultipleObjects() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutPrimaryUniqueSecondaryDuplicates() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutGetRandomNonUniqueMultipleObjects() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutGetRemoveMultipleForward() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testRandomPutGetRemove() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testPutGetRemoveMultipleBackward() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testIndexOverwrite() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testObjectKey() {
// No-op
}
/** {@inheritDoc} */
+ @Test
@Override public void testIterators() {
// No-op
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0544d46/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IndexStorageSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IndexStorageSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IndexStorageSelfTest.java
index de2161a..78c83b6 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IndexStorageSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/database/IndexStorageSelfTest.java
@@ -35,10 +35,14 @@ import org.apache.ignite.internal.processors.cache.persistence.DataRegionMetrics
import org.apache.ignite.internal.processors.cache.persistence.RootPage;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
/**
*
*/
+@RunWith(JUnit4.class)
public class IndexStorageSelfTest extends GridCommonAbstractTest {
/** Make sure page is small enough to trigger multiple pages in a linked list. */
private static final int PAGE_SIZE = 1024;
@@ -57,6 +61,7 @@ public class IndexStorageSelfTest extends GridCommonAbstractTest {
/**
* @throws Exception if failed.
*/
+ @Test
public void testMetaIndexAllocation() throws Exception {
metaAllocation();
}