You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by up...@apache.org on 2016/02/17 01:41:09 UTC
[1/3] incubator-geode git commit: Extracting common lambdas from
methods to avoid "Code to large" error [Forced Update!]
Repository: incubator-geode
Updated Branches:
refs/heads/feature/GEODE-866 58038ec1f -> 0804a1396 (forced update)
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/0804a139/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java
index bfc95c9..474231c 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java
@@ -33,6 +33,8 @@ import com.gemstone.gemfire.internal.cache.wan.WANTestBase.MyGatewayEventFilter;
import com.gemstone.gemfire.test.dunit.AsyncInvocation;
import com.gemstone.gemfire.test.dunit.IgnoredException;
import com.gemstone.gemfire.test.dunit.LogWriterUtils;
+import com.gemstone.gemfire.test.dunit.SerializableCallableIF;
+import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
import com.gemstone.gemfire.test.dunit.Wait;
public class ParallelWANPropagationDUnitTest extends WANTestBase {
@@ -85,10 +87,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//keep a larger batch to minimize number of exception occurrences in the log
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -100,19 +102,15 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 300, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm6.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm7.invoke(createPartitionedRegionRedundancy1Runnable());
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", false ));
vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", false));
@@ -120,22 +118,20 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", false ));
//make sure all the senders are running before doing any puts
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
1000 ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//verify all buckets drained on all sender nodes.
vm4.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln"));
@@ -150,6 +146,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.validateRegionSize(
getTestMethodName() + "_PR", 1000 ));
}
+
+ protected SerializableRunnableIF createCacheRunnable(Integer lnPort) {
+ return () -> WANTestBase.createCache( lnPort );
+ }
/**
* Normal happy scenario test case.
@@ -159,13 +159,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -176,31 +176,25 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm6.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm7.invoke(createPartitionedRegionRedundancy1Runnable());
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
1000 ));
@@ -215,17 +209,35 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
getTestMethodName() + "_PR", 1000 ));
}
+ protected SerializableRunnableIF createReceiverPartitionedRegionRedundancy1() {
+ return () -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 1, 100, isOffHeap() );
+ }
+
+ protected SerializableRunnableIF createPartitionedRegionRedundancy1Runnable() {
+ return () -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() );
+ }
+
+ protected SerializableRunnableIF startSenderRunnable() {
+ return () -> WANTestBase.startSender( "ln" );
+ }
+
+ protected SerializableRunnableIF waitForSenderRunnable() {
+ return () -> WANTestBase.waitForSenderRunningState( "ln" );
+ }
+
public void testParallelPropagation_ManualStart() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, false ));
@@ -236,26 +248,20 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, false ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm6.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm7.invoke(createPartitionedRegionRedundancy1Runnable());
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
1000 ));
@@ -278,13 +284,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -295,22 +301,18 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm6.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm7.invoke(createPartitionedRegionRedundancy1Runnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
1000 ));
- AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- AsyncInvocation inv2 = vm5.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- AsyncInvocation inv3 = vm6.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- AsyncInvocation inv4 = vm7.invokeAsync(() -> WANTestBase.startSender( "ln" ));
+ AsyncInvocation inv1 = vm4.invokeAsync(startSenderRunnable());
+ AsyncInvocation inv2 = vm5.invokeAsync(startSenderRunnable());
+ AsyncInvocation inv3 = vm6.invokeAsync(startSenderRunnable());
+ AsyncInvocation inv4 = vm7.invokeAsync(startSenderRunnable());
try{
inv1.join();
@@ -321,17 +323,15 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
catch(InterruptedException ie) {
fail("Caught interrupted exception");
}
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
1000 ));
@@ -353,13 +353,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -370,31 +370,25 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm6.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm7.invoke(createPartitionedRegionRedundancy1Runnable());
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
1000 ));
@@ -411,10 +405,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
(Integer) vm2.invoke(() -> WANTestBase.getRegionSize(getTestMethodName() + "_PR" ));
LogWriterUtils.getLogWriter().info("Region size on remote is: " + regionSize);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -430,24 +424,20 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
vm7.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm6.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm7.invoke(createPartitionedRegionRedundancy1Runnable());
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//------------------------------------------------------------------------------------
IgnoredException.addIgnoredException(EntryExistsException.class.getName());
@@ -472,13 +462,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -494,10 +484,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(() -> WANTestBase.createColocatedPartitionedRegions( getTestMethodName(), "ln", 1, 100, isOffHeap() ));
vm7.invoke(() -> WANTestBase.createColocatedPartitionedRegions( getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
vm2.invoke(() -> WANTestBase.createColocatedPartitionedRegions( getTestMethodName(), null, 1, 100, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createColocatedPartitionedRegions( getTestMethodName(), null, 1, 100, isOffHeap() ));
@@ -526,13 +516,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -548,10 +538,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(() -> WANTestBase.createColocatedPartitionedRegions2( getTestMethodName(), "ln", 1, 100, isOffHeap() ));
vm7.invoke(() -> WANTestBase.createColocatedPartitionedRegions2( getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
vm2.invoke(() -> WANTestBase.createColocatedPartitionedRegions2( getTestMethodName(), null, 1, 100, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createColocatedPartitionedRegions2( getTestMethodName(), null, 1, 100, isOffHeap() ));
@@ -579,13 +569,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -605,10 +595,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName(), null, 1, 100, isOffHeap() ));
@@ -616,10 +606,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
getTestMethodName(), null, 1, 100, isOffHeap() ));
//let all the senders start before doing any puts to ensure that none of the events is lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doHeavyPuts( getTestMethodName(), 150 ));
@@ -639,13 +629,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "lnSerial",
2, false, 100, 10, false, false, null, true ));
@@ -666,10 +656,8 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "lnSerial", isOffHeap() ));
@@ -720,13 +708,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
Integer tkPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( tkPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(tkPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "lnParallel1",
2, true, 100, 10, false, false, null, true ));
@@ -765,10 +753,8 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(() -> WANTestBase.startSender( "lnParallel2" ));
vm7.invoke(() -> WANTestBase.startSender( "lnParallel2" ));
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//before doing puts, make sure that the senders are started.
//this will ensure that not a single events is lost
@@ -811,13 +797,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -842,15 +828,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", "ln", 2, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
AsyncInvocation inv1 = vm7.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 5000 ));
Wait.pause(500);
@@ -882,13 +866,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false,
@@ -912,10 +896,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName(), null, 1, 100, isOffHeap() ));
@@ -924,10 +908,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
//wait for senders to be running before doing any puts. This will ensure that
//not a single events is lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 ));
@@ -941,13 +925,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -958,31 +942,25 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm6.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm7.invoke(createPartitionedRegionRedundancy1Runnable());
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doPutAll( getTestMethodName() + "_PR",
100 , 50 ));
@@ -1009,13 +987,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 100, false, false, null, true ));
@@ -1026,31 +1004,25 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 100, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm6.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm7.invoke(createPartitionedRegionRedundancy1Runnable());
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
@@ -1096,11 +1068,11 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
//vm6.invoke(() -> WANTestBase.createCache( lnPort ));
//vm7.invoke(() -> WANTestBase.createCache( lnPort ));
@@ -1113,29 +1085,25 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
//vm7.invoke(() -> WANTestBase.createSender( "ln", 2,
// true, 100, 10, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
// vm6.invoke(() -> WANTestBase.createPartitionedRegion(
// testName + "_PR", "ln", true, 1, 100, isOffHeap() ));
// vm7.invoke(() -> WANTestBase.createPartitionedRegion(
// testName + "_PR", "ln", true, 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
// vm6.invoke(() -> WANTestBase.startSender( "ln" ));
// vm7.invoke(() -> WANTestBase.startSender( "ln" ));
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ vm2.invoke(createReceiverPartitionedRegionRedundancy1());
+ vm3.invoke(createReceiverPartitionedRegionRedundancy1());
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
// vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
// vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
vm4.invoke(() -> WANTestBase.doTxPuts( getTestMethodName() + "_PR",
@@ -1155,26 +1123,24 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
@@ -1210,26 +1176,24 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRedundancy1Runnable());
+ vm5.invoke(createPartitionedRegionRedundancy1Runnable());
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
@@ -1269,17 +1233,17 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create cache and receiver on site2
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
//create cache on site1
- vm3.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm3.invoke(createCacheRunnable(lnPort));
//create sender on site1
vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
//start sender on site1
- vm3.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm3.invoke(startSenderRunnable());
//create leader (parent) PR on site1
vm3.invoke(() -> WANTestBase.createPartitionedRegion(
@@ -1309,13 +1273,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm6.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm7.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm6.invoke(createReceiverRunnable(nyPort));
+ vm7.invoke(createReceiverRunnable(nyPort));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm2.invoke(createCacheRunnable(lnPort));
+ vm3.invoke(createCacheRunnable(lnPort));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm2.invoke(() -> WANTestBase.createSender( "ln", 2, true,
100, 10, false, false, new MyGatewayEventFilter_AfterAck(), true ));
@@ -1335,10 +1299,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm5.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm2.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm2.invoke(startSenderRunnable());
+ vm3.invoke(startSenderRunnable());
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
vm6.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName(), null, 1, 100, isOffHeap() ));
@@ -1348,10 +1312,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
// wait for senders to be running before doing any puts. This will ensure
// that
// not a single events is lost
- vm2.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm3.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm2.invoke(waitForSenderRunnable());
+ vm3.invoke(waitForSenderRunnable());
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 ));
@@ -1385,5 +1349,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
assertEquals(2000, (vm2Acks + vm3Acks + vm4Acks + vm5Acks));
+ }
+
+ protected SerializableCallableIF<Integer> createReceiverRunnable(
+ Integer nyPort) {
+ return () -> WANTestBase.createReceiver( nyPort );
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/0804a139/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java
index 91234c9..d89c864 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java
@@ -28,6 +28,7 @@ import com.gemstone.gemfire.internal.cache.wan.WANTestBase;
import com.gemstone.gemfire.test.dunit.AsyncInvocation;
import com.gemstone.gemfire.test.dunit.IgnoredException;
import com.gemstone.gemfire.test.dunit.LogWriterUtils;
+import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
import com.gemstone.gemfire.test.dunit.Wait;
public class SerialWANPropogationDUnitTest extends WANTestBase {
@@ -52,10 +53,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
public void disabledtestReplicatedSerialPropagation_withoutRemoteLocator() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//keep the batch size high enough to reduce the number of exceptions in the log
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -66,22 +67,18 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( nyPort ));
- vm3.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm2.invoke(createCacheRunnable(nyPort));
+ vm3.invoke(createCacheRunnable(nyPort));
vm2.invoke(() -> WANTestBase.createReceiver2(nyPort ));
vm3.invoke(() -> WANTestBase.createReceiver2(nyPort ));
@@ -98,6 +95,15 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
getTestMethodName() + "_RR", 1000 ));
vm3.invoke(() -> WANTestBase.validateRegionSize(
getTestMethodName() + "_RR", 1000 ));
+ }
+
+ protected SerializableRunnableIF createReplicatedRegionRunnable() {
+ return () -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() );
+ }
+
+ protected SerializableRunnableIF createCacheRunnable(Integer lnPort) {
+ return () -> WANTestBase.createCache(lnPort );
}
@@ -106,10 +112,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//keep the batch size high enough to reduce the number of exceptions in the log
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -120,14 +126,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
@@ -140,8 +142,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
- vm2.invoke(() -> WANTestBase.createCache( nyPort ));
- vm3.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm2.invoke(createCacheRunnable(nyPort));
+ vm3.invoke(createCacheRunnable(nyPort));
vm2.invoke(() -> WANTestBase.createReceiver2(nyPort ));
vm3.invoke(() -> WANTestBase.createReceiver2(nyPort ));
@@ -171,10 +173,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
// reduce the batch-size so maximum number of batches will be sent
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -185,14 +187,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
@@ -208,8 +206,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// pause for some time before starting up the remote site
Wait.pause(10000);
- vm2.invoke(() -> WANTestBase.createCache( nyPort ));
- vm3.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm2.invoke(createCacheRunnable(nyPort));
+ vm3.invoke(createCacheRunnable(nyPort));
vm2.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
@@ -238,10 +236,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -256,14 +254,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -281,10 +275,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -299,14 +293,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -321,10 +311,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
(Integer) vm2.invoke(() -> WANTestBase.getRegionSize(getTestMethodName() + "_RR" ));
LogWriterUtils.getLogWriter().info("Region size on remote is: " + regionSize);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -334,14 +324,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
@@ -380,10 +366,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//senders are created on local site
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -465,10 +451,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//senders are created on local site
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -537,10 +523,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//senders are created on local site
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -623,10 +609,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
// senders are created on local site
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -734,10 +720,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
//vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//senders are created on local site. Batch size is kept to a high (170) so
//there will be less number of exceptions (occur during dispatchBatch) in the log
@@ -794,8 +780,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
// senders are created on local site. Batch size is kept to a high (170) so
// there will be less number of exceptions (occur during dispatchBatch) in
@@ -861,8 +847,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
// senders are created on local site. Batch size is kept to a high (170) so
// there will be less number of exceptions (occur during dispatchBatch) in
@@ -929,8 +915,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
// senders are created on local site. Batch size is kept to a high (170) so
// there will be less number of exceptions (occur during dispatchBatch) in
@@ -1002,8 +988,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort1 ));
// these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
// senders are created on local site. Batch size is kept to a high (170) so
// there will be less number of exceptions (occur during dispatchBatch) in
@@ -1064,11 +1050,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// these are part of remote site
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm3.invoke(createCacheRunnable(nyPort));
// these are part of local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
// senders are created on local site. Batch size is kept to a high (170) so
// there will be less number of exceptions (occur during dispatchBatch) in
@@ -1133,10 +1119,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm3.invoke(() -> WANTestBase.createReceiver( tkPort ));
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "lnSerial1",
2, false, 100, 10, false, false, null, true ));
@@ -1185,10 +1171,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1203,14 +1189,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
AsyncInvocation inv1 = vm5.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", 10000 ));
Wait.pause(2000);
@@ -1249,8 +1231,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
LogWriterUtils.getLogWriter().info("Started receivers on remote site");
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1271,10 +1253,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
LogWriterUtils.getLogWriter().info("Started senders on local site");
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
AsyncInvocation inv1 = vm5.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", 10000 ));
LogWriterUtils.getLogWriter().info("Started async puts on local site");
@@ -1334,8 +1314,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
LogWriterUtils.getLogWriter().info("Started receivers on remote site");
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1356,10 +1336,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
LogWriterUtils.getLogWriter().info("Started senders on local site");
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
AsyncInvocation inv1 = vm5.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", 10000 ));
LogWriterUtils.getLogWriter().info("Started async puts on local site");
@@ -1385,12 +1363,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// ---------------------------REBUILD vm4
// --------------------------------------
LogWriterUtils.getLogWriter().info("Rebuilding vm4....");
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
LogWriterUtils.getLogWriter().info("Rebuilt vm4");
// -----------------------------------------------------------------------------
@@ -1427,8 +1404,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1484,8 +1461,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.createReceiver( lnPort ));
vm5.invoke(() -> WANTestBase.createReceiver( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1495,14 +1472,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm2.invoke(() -> WANTestBase.createSender( "ny", 1,
false, 100, 10, false, false, null, true ));
[2/3] incubator-geode git commit: Extracting common lambdas from
methods to avoid "Code to large" error
Posted by up...@apache.org.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/0804a139/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java
index e52486f..a29a210 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java
@@ -29,6 +29,8 @@ import com.gemstone.gemfire.internal.i18n.LocalizedStrings;
import com.gemstone.gemfire.test.dunit.AsyncInvocation;
import com.gemstone.gemfire.test.dunit.IgnoredException;
import com.gemstone.gemfire.test.dunit.LogWriterUtils;
+import com.gemstone.gemfire.test.dunit.SerializableCallableIF;
+import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
WANTestBase {
@@ -84,13 +86,13 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, true, null, true ));
@@ -110,10 +112,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
vm7.invoke(() -> WANTestBase.createPersistentPartitionedRegion(
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
vm2.invoke(() -> WANTestBase.createPersistentPartitionedRegion(
getTestMethodName(), null, 1, 100, isOffHeap() ));
@@ -129,6 +131,15 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
}
+ protected SerializableCallableIF<Integer> createReceiverRunnable(
+ Integer nyPort) {
+ return () -> WANTestBase.createReceiver( nyPort );
+ }
+
+ protected SerializableRunnableIF createCacheRunnable(Integer lnPort) {
+ return () -> WANTestBase.createCache( lnPort );
+ }
+
/**
* Enable persistence for the GatewaySender but not the region
*/
@@ -136,15 +147,15 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
LogWriterUtils.getLogWriter().info("Created remote receivers");
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created local site cache");
@@ -159,22 +170,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
LogWriterUtils.getLogWriter().info("Created local site senders");
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRunnable());
+ vm5.invoke(createPartitionedRegionRunnable());
+ vm6.invoke(createPartitionedRegionRunnable());
+ vm7.invoke(createPartitionedRegionRunnable());
LogWriterUtils.getLogWriter().info("Created local site persistent PR");
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Started sender on vm4");
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Started the senders");
@@ -190,6 +197,15 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
vm3.invoke(() -> WANTestBase.validateRegionSize(
getTestMethodName(), 1000 ));
}
+
+ protected SerializableRunnableIF createPartitionedRegionRunnable() {
+ return () -> WANTestBase.createPartitionedRegion(
+ getTestMethodName(), "ln", 1, 100, isOffHeap() );
+ }
+
+ protected SerializableRunnableIF startSenderRunnable() {
+ return () -> WANTestBase.startSender( "ln" );
+ }
@@ -207,14 +223,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//create senders with disk store
String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true ));
@@ -231,32 +247,28 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), null, 1, 100, isOffHeap() ));
//create PR on local site
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRunnable());
+ vm5.invoke(createPartitionedRegionRunnable());
+ vm6.invoke(createPartitionedRegionRunnable());
+ vm7.invoke(createPartitionedRegionRunnable());
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 3000 ));
@@ -264,18 +276,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//--------------------close and rebuild local site -------------------------------------------------
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -287,14 +299,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
LogWriterUtils.getLogWriter().info("Created the senders back from the disk store.");
//create PR on local site
- AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- AsyncInvocation inv2 = vm5.invokeAsync(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- AsyncInvocation inv3 = vm6.invokeAsync(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- AsyncInvocation inv4 = vm7.invokeAsync(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
+ AsyncInvocation inv1 = vm4.invokeAsync(createPartitionedRegionRunnable());
+ AsyncInvocation inv2 = vm5.invokeAsync(createPartitionedRegionRunnable());
+ AsyncInvocation inv3 = vm6.invokeAsync(createPartitionedRegionRunnable());
+ AsyncInvocation inv4 = vm7.invokeAsync(createPartitionedRegionRunnable());
try {
inv1.join();
@@ -310,17 +318,17 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//start the senders in async mode. This will ensure that the
//node of shadow PR that went down last will come up first
- vm4.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm5.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm6.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm7.invokeAsync(() -> WANTestBase.startSender( "ln" ));
+ vm4.invokeAsync(startSenderRunnable());
+ vm5.invokeAsync(startSenderRunnable());
+ vm6.invokeAsync(startSenderRunnable());
+ vm7.invokeAsync(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("All the senders are now running...");
@@ -331,6 +339,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
vm3.invoke(() -> WANTestBase.validateRegionSize(
getTestMethodName(), 3000 ));
}
+
+ protected SerializableRunnableIF killSenderRunnable() {
+ return () -> WANTestBase.killSender();
+ }
+
+ protected SerializableRunnableIF pauseSenderRunnable() {
+ return () -> WANTestBase.pauseSender( "ln" );
+ }
+
+ protected SerializableRunnableIF waitForSenderRunnable() {
+ return () -> WANTestBase.waitForSenderRunningState( "ln" );
+ }
/**
* Enable persistence for PR and GatewaySender.
@@ -346,14 +366,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//create senders with disk store
String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true ));
@@ -380,22 +400,22 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 3000 ));
@@ -403,18 +423,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//--------------------close and rebuild local site -------------------------------------------------
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -449,17 +469,17 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//start the senders in async mode. This will ensure that the
//node of shadow PR that went down last will come up first
- vm4.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm5.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm6.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm7.invokeAsync(() -> WANTestBase.startSender( "ln" ));
+ vm4.invokeAsync(startSenderRunnable());
+ vm5.invokeAsync(startSenderRunnable());
+ vm6.invokeAsync(startSenderRunnable());
+ vm7.invokeAsync(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("All the senders are now running...");
@@ -485,10 +505,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//create senders with disk store
String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, false ));
@@ -509,22 +529,22 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 300 ));
@@ -532,18 +552,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//--------------------close and rebuild local site -------------------------------------------------
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -584,23 +604,23 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//start the senders in async mode. This will ensure that the
//node of shadow PR that went down last will come up first
- vm4.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm5.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm6.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm7.invokeAsync(() -> WANTestBase.startSender( "ln" ));
+ vm4.invokeAsync(startSenderRunnable());
+ vm5.invokeAsync(startSenderRunnable());
+ vm6.invokeAsync(startSenderRunnable());
+ vm7.invokeAsync(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("Creating the receiver.");
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create PR on remote site
LogWriterUtils.getLogWriter().info("Creating the partitioned region at receiver. ");
@@ -608,10 +628,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), null, 1, 100, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createPersistentPartitionedRegion(
getTestMethodName(), null, 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
LogWriterUtils.getLogWriter().info("Doing some extra puts. ");
//start puts in region on local site
@@ -645,14 +665,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//create senders with disk store
String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true ));
@@ -679,22 +699,22 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 3000 ));
@@ -702,18 +722,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//--------------------close and rebuild local site -------------------------------------------------
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -749,17 +769,17 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//start the senders in async mode. This will ensure that the
//node of shadow PR that went down last will come up first
- vm4.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm5.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm6.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm7.invokeAsync(() -> WANTestBase.startSender( "ln" ));
+ vm4.invokeAsync(startSenderRunnable());
+ vm5.invokeAsync(startSenderRunnable());
+ vm6.invokeAsync(startSenderRunnable());
+ vm7.invokeAsync(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("All the senders are now running...");
@@ -793,14 +813,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//create senders with disk store
String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true ));
@@ -827,22 +847,22 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPutsWithKeyAsString( getTestMethodName(), 1000 ));
@@ -850,18 +870,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//--------------------close and rebuild local site -------------------------------------------------
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -897,17 +917,17 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//start the senders in async mode. This will ensure that the
//node of shadow PR that went down last will come up first
- vm4.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm5.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm6.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm7.invokeAsync(() -> WANTestBase.startSender( "ln" ));
+ vm4.invokeAsync(startSenderRunnable());
+ vm5.invokeAsync(startSenderRunnable());
+ vm6.invokeAsync(startSenderRunnable());
+ vm7.invokeAsync(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("All the senders are now running...");
@@ -933,14 +953,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//create senders with disk store
String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true ));
@@ -967,22 +987,22 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPutsWithKeyAsString( getTestMethodName(), 1000 ));
@@ -990,18 +1010,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//--------------------close and rebuild local site -------------------------------------------------
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -1023,17 +1043,17 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//start the senders in async mode. This will ensure that the
//node of shadow PR that went down last will come up first
- vm4.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm5.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm6.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm7.invokeAsync(() -> WANTestBase.startSender( "ln" ));
+ vm4.invokeAsync(startSenderRunnable());
+ vm5.invokeAsync(startSenderRunnable());
+ vm6.invokeAsync(startSenderRunnable());
+ vm7.invokeAsync(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("All the senders are now running...");
@@ -1069,10 +1089,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
// create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
// create PR on local site
vm4.invoke(() -> WANTestBase.createPersistentPartitionedRegion( getTestMethodName(), "ln", 1, 100, isOffHeap() ));
@@ -1088,18 +1108,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
// --------------------close and rebuild local site
// -------------------------------------------------
// kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
// restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -1162,14 +1182,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//create senders with disk store
String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true ));
@@ -1196,22 +1216,22 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 ));
@@ -1219,18 +1239,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//--------------------close and rebuild local site -------------------------------------------------
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -1245,19 +1265,19 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//start the senders. NOTE that the senders are not associated with partitioned region
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Started the senders.");
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("All the senders are now running...");
@@ -1282,14 +1302,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
//create senders with disk store
String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true ));
@@ -1306,50 +1326,46 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), null, 1, 100, isOffHeap() ));
//create non persistent PR on local site
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRunnable());
+ vm5.invoke(createPartitionedRegionRunnable());
+ vm6.invoke(createPartitionedRegionRunnable());
+ vm7.invoke(createPartitionedRegionRunnable());
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 ));
LogWriterUtils.getLogWriter().info("Completed puts in the region");
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders. The local site has been brought down.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -1362,31 +1378,27 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
LogWriterUtils.getLogWriter().info("Created the senders back from the disk store.");
//create PR on local site
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
+ vm4.invoke(createPartitionedRegionRunnable());
+ vm5.invoke(createPartitionedRegionRunnable());
+ vm6.invoke(createPartitionedRegionRunnable());
+ vm7.invoke(createPartitionedRegionRunnable());
LogWriterUtils.getLogWriter().info("Created back the partitioned regions");
//start the senders
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Started the senders.");
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("All the senders are now running...");
@@ -1414,14 +1426,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -1449,22 +1461,22 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//wait for senders to become running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
//pause the senders
- vm4.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANTestBase.pauseSender( "ln" ));
+ vm4.invoke(pauseSenderRunnable());
+ vm5.invoke(pauseSenderRunnable());
+ vm6.invoke(pauseSenderRunnable());
+ vm7.invoke(pauseSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 3000 ));
@@ -1472,18 +1484,18 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
//----------------- Close and rebuild local site -------------------------------------
//kill the senders
- vm4.invoke(() -> WANTestBase.killSender());
- vm5.invoke(() -> WANTestBase.killSender());
- vm6.invoke(() -> WANTestBase.killSender());
- vm7.invoke(() -> WANTestBase.killSender());
+ vm4.invoke(killSenderRunnable());
+ vm5.invoke(killSenderRunnable());
+ vm6.invoke(killSenderRunnable());
+ vm7.invoke(killSenderRunnable());
LogWriterUtils.getLogWriter().info("Killed all the senders.");
//restart the vm
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created back the cache");
@@ -1505,20 +1517,20 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
vm7.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
//start the senders
- vm4.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm5.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm6.invokeAsync(() -> WANTestBase.startSender( "ln" ));
- vm7.invokeAsync(() -> WANTestBase.startSender( "ln" ));
+ vm4.invokeAsync(startSenderRunnable());
+ vm5.invokeAsync(startSenderRunnable());
+ vm6.invokeAsync(startSenderRunnable());
+ vm7.invokeAsync(startSenderRunnable());
LogWriterUtils.getLogWriter().info("Started the senders.");
LogWriterUtils.getLogWriter().info("Waiting for senders running.");
//wait for senders running
- vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
- vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm4.invoke(waitForSenderRunnable());
+ vm5.invoke(waitForSenderRunnable());
+ vm6.invoke(waitForSenderRunnable());
+ vm7.invoke(waitForSenderRunnable());
LogWriterUtils.getLogWriter().info("All the senders are now running...");
@@ -1569,14 +1581,14 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//create receiver on remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
//create cache in local site
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, true, null, true ));
@@ -1601,10 +1613,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
vm3.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
//start puts in region on local site
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 ));
@@ -1628,13 +1640,13 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm2.invoke(createReceiverRunnable(nyPort));
+ vm3.invoke(createReceiverRunnable(nyPort));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, true, null, true ));
@@ -1654,10 +1666,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
vm7.invoke(() -> WANTestBase.createPersistentPartitionedRegion(
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(startSenderRunnable());
+ vm5.invoke(startSenderRunnable());
+ vm6.invoke(startSenderRunnable());
+ vm7.invoke(startSenderRunnable());
vm2.invoke(() -> WANTestBase.createPersistentPartitionedRegion(
getTestMethodName(), null, 1, 100, isOffHeap() ));
@@ -1682,10 +1694,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends
vm6.invoke(ParallelWANPersistenceEnabledGatewaySenderDUnitTest.class, "setIgnoreQueue" , new Object[] { true});
vm7.invoke(ParallelWANPersistenceEnabledGatewaySenderDUnitTest.class, "setIgnoreQueue" , new Object[] { true});
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
AsyncInvocation async4 = vm4.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion(
getTestMethodName(), null, 1, 100, isOffHeap() ));
[3/3] incubator-geode git commit: Extracting common lambdas from
methods to avoid "Code to large" error
Posted by up...@apache.org.
Extracting common lambdas from methods to avoid "Code to large" error
After converting these tests to use lambdas, it appears that the large
number of lambdas are overflowing some limit of the compiler. By
extracting methods for common lambdas, the overall number of lambda
classes required is reduced for these tests.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/0804a139
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/0804a139
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/0804a139
Branch: refs/heads/feature/GEODE-866
Commit: 0804a1396588116caed281d2ce7303ec39aa8df1
Parents: 51c03a9
Author: Dan Smith <up...@apache.org>
Authored: Tue Feb 16 16:36:52 2016 -0800
Committer: Dan Smith <up...@apache.org>
Committed: Tue Feb 16 16:38:29 2016 -0800
----------------------------------------------------------------------
.../asyncqueue/AsyncEventListenerDUnitTest.java | 511 ++++++------
.../cache/wan/misc/WanValidationsDUnitTest.java | 262 +++---
...ersistenceEnabledGatewaySenderDUnitTest.java | 824 ++++++++++---------
.../ParallelWANPropagationDUnitTest.java | 639 +++++++-------
.../serial/SerialWANPropogationDUnitTest.java | 277 +++----
5 files changed, 1207 insertions(+), 1306 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/0804a139/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
index f5ed32b..fdc9ea9 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
@@ -33,6 +33,7 @@ import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem;
import com.gemstone.gemfire.internal.AvailablePortHelper;
import com.gemstone.gemfire.internal.cache.wan.AsyncEventQueueTestBase;
import com.gemstone.gemfire.test.dunit.LogWriterUtils;
+import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
import com.gemstone.gemfire.test.dunit.Wait;
public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
@@ -73,7 +74,7 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testSerialAsyncEventQueueAttributes() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 150, true, true, "testDS", true ));
@@ -84,33 +85,29 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testSerialAsyncEventQueueSize() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
+ vm4.invoke(createAsyncEventQueueRunnable());
+ vm5.invoke(createAsyncEventQueueRunnable());
+ vm6.invoke(createAsyncEventQueueRunnable());
+ vm7.invoke(createAsyncEventQueueRunnable());
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm6
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm7
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(1000);// pause at least for the batchTimeInterval
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
@@ -121,6 +118,23 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
assertEquals("Size of AsyncEventQueue is incorrect", 1000, vm4size);
assertEquals("Size of AsyncEventQueue is incorrect", 1000, vm5size);
}
+
+ protected SerializableRunnableIF pauseAsyncEventQueueRunnable() {
+ return () -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" );
+ }
+
+ protected SerializableRunnableIF createReplicatedRegionRunnable() {
+ return () -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() );
+ }
+
+ protected SerializableRunnableIF createAsyncEventQueueRunnable() {
+ return () -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ false, 100, 100, false, false, null, false );
+ }
+
+ protected SerializableRunnableIF createCacheRunnable(Integer lnPort) {
+ return () -> AsyncEventQueueTestBase.createCache( lnPort );
+ }
/**
* Added to reproduce defect #50366:
@@ -129,25 +143,25 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testConcurrentSerialAsyncEventQueueSize() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 150, true, false, null, false, 2, OrderPolicy.KEY ));
vm5.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 150, true, false, null, false, 2, OrderPolicy.KEY ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(1000);// pause at least for the batchTimeInterval
@@ -170,24 +184,20 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testReplicatedSerialAsyncEventQueue() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
+ vm4.invoke(createAsyncEventQueueRunnable());
+ vm5.invoke(createAsyncEventQueueRunnable());
+ vm6.invoke(createAsyncEventQueueRunnable());
+ vm7.invoke(createAsyncEventQueueRunnable());
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -205,10 +215,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testReplicatedSerialAsyncEventQueueWithCacheLoader() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false, "MyAsyncEventListener_CacheLoader" ));
@@ -248,10 +258,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testReplicatedSerialAsyncEventQueue_ExceptionScenario() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithCustomListener( "ln",
false, 100, 100, false, false, null, false, 1 ));
@@ -262,19 +272,19 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithCustomListener( "ln",
false, 100, 100, false, false, null, false, 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm6
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm7
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(2000);// pause at least for the batchTimeInterval
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
@@ -300,10 +310,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testReplicatedSerialAsyncEventQueueWithConflationEnabled() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false ));
@@ -314,19 +324,19 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm6
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm7
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(1000);// pause at least for the batchTimeInterval
final Map keyValues = new HashMap();
@@ -391,19 +401,15 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm6.invoke(() -> AsyncEventQueueTestBase.createCacheWithoutLocator( mPort ));
vm7.invoke(() -> AsyncEventQueueTestBase.createCacheWithoutLocator( mPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
+ vm4.invoke(createAsyncEventQueueRunnable());
+ vm5.invoke(createAsyncEventQueueRunnable());
+ vm6.invoke(createAsyncEventQueueRunnable());
+ vm7.invoke(createAsyncEventQueueRunnable());
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -426,10 +432,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testReplicatedSerialAsyncEventQueueWithPeristenceEnabled() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false ));
@@ -440,10 +446,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -466,19 +472,19 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void DISABLED_testReplicatedSerialAsyncEventQueueWithPeristenceEnabled_Restart() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
String firstDStore = (String)vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithDiskStore( "ln", false, 100,
100, true, null ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
// pause async channel and then do the puts
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -486,9 +492,9 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
// ------------------------------------------
vm4.invoke(() -> AsyncEventQueueTestBase.killSender());
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithDiskStore( "ln", false, 100, 100, true, firstDStore ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
// -----------------------------------------------------------------------------------
vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 1000 ));// primary sender
@@ -506,18 +512,18 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void DISABLED_testReplicatedSerialAsyncEventQueueWithPeristenceEnabled_Restart2() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithDiskStore( "ln", false, 100, 100, true, null ));
vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithDiskStore( "ln", false, 100, 100, true, null ));
vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithDiskStore( "ln", false, 100, 100, true, null ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> AsyncEventQueueTestBase.addCacheListenerAndCloseCache( getTestMethodName() + "_RR" ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
vm5.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR", 2000 ));
@@ -549,10 +555,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testConcurrentSerialAsyncEventQueueWithReplicatedRegion() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false, 3, OrderPolicy.KEY ));
@@ -563,10 +569,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false, 3, OrderPolicy.KEY ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -587,10 +593,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testConcurrentSerialAsyncEventQueueWithReplicatedRegion_2() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false, 3, OrderPolicy.THREAD ));
@@ -601,10 +607,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false, 3, OrderPolicy.THREAD ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invokeAsync(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
500 ));
@@ -627,10 +633,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testConcurrentSerialAsyncEventQueueWithoutOrderPolicy() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false, 3, null ));
@@ -641,10 +647,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false, 3, null ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
+ vm5.invoke(createReplicatedRegionRunnable());
+ vm6.invoke(createReplicatedRegionRunnable());
+ vm7.invoke(createReplicatedRegionRunnable());
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -663,19 +669,15 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testPartitionedSerialAsyncEventQueue() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- false, 100, 100, false, false, null, false ));
+ vm4.invoke(createAsyncEventQueueRunnable());
+ vm5.invoke(createAsyncEventQueueRunnable());
+ vm6.invoke(createAsyncEventQueueRunnable());
+ vm7.invoke(createAsyncEventQueueRunnable());
vm4.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
vm5.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
@@ -701,10 +703,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testPartitionedSerialAsyncEventQueueWithConflationEnabled() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false ));
@@ -721,13 +723,13 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm6
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm7
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(2000);
@@ -785,10 +787,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testPartitionedSerialAsyncEventQueueWithPeristenceEnabled() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, true, null, false ));
@@ -825,10 +827,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testPartitionedSerialAsyncEventQueueWithPeristenceEnabled_Restart() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
String firstDStore = (String)vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithDiskStore( "ln", false, 100,
100, true, null ));
@@ -846,7 +848,7 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
// ------------------------------------------
vm4.invoke(() -> AsyncEventQueueTestBase.killSender());
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithDiskStore( "ln", false, 100, 100, true, firstDStore ));
vm4.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
// -----------------------------------------------------------------------------------
@@ -858,10 +860,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue(
"ln", true, 100, 100, true, false, null, false ));
@@ -872,8 +874,7 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue(
"ln", true, 100, 100, true, false, null, false ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm4.invoke(createReplicatedRegionRunnable());
fail("Expected GatewaySenderConfigException where parallel async event queue can not be used with replicated region");
}
catch (Exception e) {
@@ -887,10 +888,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueue() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
true, 100, 100, false, false, null, false ));
@@ -929,10 +930,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueueWithCacheLoader() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
true, 100, 100, false, false, null, false, "MyAsyncEventListener_CacheLoader" ));
@@ -959,10 +960,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueueSize() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
true, 100, 100, false, false, null, false ));
@@ -979,13 +980,13 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm6
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm7
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(1000);// pause at least for the batchTimeInterval
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_PR",
@@ -1005,10 +1006,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testConcurrentParallelAsyncEventQueueSize() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
true, 100, 100, false, false, null, false, 2, OrderPolicy.KEY ));
@@ -1025,13 +1026,13 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm6
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm7
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(1000);// pause at least for the batchTimeInterval
vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_PR",
@@ -1047,10 +1048,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueueWithConflationEnabled() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
true, 100, 100, true, false, null, false ));
@@ -1067,13 +1068,13 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm6
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm7
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(2000);// pause for the batchTimeInterval to ensure that all the
// senders are paused
@@ -1131,10 +1132,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueueWithConflationEnabled_bug47213() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
true, 100, 100, true, false, null, false ));
@@ -1151,13 +1152,13 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
vm7.invoke(() -> AsyncEventQueueTestBase.createPRWithRedundantCopyWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm6
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm7
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(2000);// pause for the batchTimeInterval to ensure that all the
// senders are paused
@@ -1212,11 +1213,11 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueueWithOneAccessor() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(createCacheRunnable(lnPort));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm3.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
true, 100, 100, false, false, null, false ));
@@ -1258,10 +1259,10 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueueWithPersistence() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
true, 100, 100, false, true, null, false ));
@@ -1293,52 +1294,6 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
assertEquals(vm4size + vm5size + vm6size + vm7size, 256);
}
- /**
- * Below test is disabled intentionally Replicated region with Parallel Async
- * Event queue is not supported. Test is added for the same
- * testParallelAsyncEventQueueWithReplicatedRegion
- *
- * We are gone support this configuration in upcoming releases
- */
-
- public void DISABLED_DUETO_BUG51491_testReplicatedParallelAsyncEventQueue() {
- Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
-
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
-
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- true, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- true, 100, 100, false, false, null, false ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- true, 100, 100, false, false, null, false ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
- true, 100, 100, false, false, null, false ));
-
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
-
- vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
- 1000 ));
-
- vm4.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm5.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm6.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm7.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
-
- int vm4size = (Integer)vm4.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
- int vm5size = (Integer)vm5.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
- int vm6size = (Integer)vm6.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
- int vm7size = (Integer)vm7.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
-
- assertEquals(vm4size + vm5size + vm6size + vm7size, 1000);
- }
-
/**
* Test case to test possibleDuplicates. vm4 & vm5 are hosting the PR. vm5 is
* killed so the buckets hosted by it are shifted to vm4.
@@ -1346,8 +1301,8 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
@Ignore("Disabled for 52349")
public void DISABLED_testParallelAsyncEventQueueHA_Scenario1() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created the cache");
@@ -1364,9 +1319,9 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
LogWriterUtils.getLogWriter().info("Created PR with AsyncEventQueue");
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(1000);// pause for the batchTimeInterval to make sure the AsyncQueue
// is paused
@@ -1399,8 +1354,8 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueueHA_Scenario2() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created the cache");
@@ -1417,9 +1372,9 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
LogWriterUtils.getLogWriter().info("Created PR with AsyncEventQueue");
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(1000);// pause for the batchTimeInterval to make sure the AsyncQueue
// is paused
@@ -1437,7 +1392,7 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
// ----------------------------------------------------------------
// ---------------------------- start vm6 --------------------------
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm6.invoke(createCacheRunnable(lnPort));
vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithListener2( "ln", true, 100, 5, false, null ));
vm6.invoke(() -> AsyncEventQueueTestBase.createPRWithRedundantCopyWithAsyncEventQueue(
getTestMethodName() + "_PR", "ln", isOffHeap() ));
@@ -1465,8 +1420,8 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
public void testParallelAsyncEventQueueHA_Scenario3() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
LogWriterUtils.getLogWriter().info("Created the cache");
@@ -1483,9 +1438,9 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
LogWriterUtils.getLogWriter().info("Created PR with AsyncEventQueue");
vm4
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
vm5
- .invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
+ .invoke(pauseAsyncEventQueueRunnable());
Wait.pause(1000);// pause for the batchTimeInterval to make sure the AsyncQueue
// is paused
@@ -1496,7 +1451,7 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
LogWriterUtils.getLogWriter().info("Done puts");
// ---------------------------- start vm6 --------------------------
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm6.invoke(createCacheRunnable(lnPort));
vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueueWithListener2( "ln", true, 100, 5, false, null ));
vm6.invoke(() -> AsyncEventQueueTestBase.createPRWithRedundantCopyWithAsyncEventQueue(
getTestMethodName() + "_PR", "ln", isOffHeap() ));
@@ -1524,7 +1479,7 @@ public class AsyncEventListenerDUnitTest extends AsyncEventQueueTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
// create cache on node
- vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(createCacheRunnable(lnPort));
// create AsyncEventQueue on node
vm3.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln", true, 100, 10, false, false, null, true ));
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/0804a139/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java
index 88696fe..3d0c01b 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java
@@ -33,6 +33,7 @@ import com.gemstone.gemfire.internal.cache.wan.MyGatewayTransportFilter4;
import com.gemstone.gemfire.internal.cache.wan.WANTestBase;
import com.gemstone.gemfire.test.dunit.Assert;
import com.gemstone.gemfire.test.dunit.IgnoredException;
+import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
public class WanValidationsDUnitTest extends WANTestBase {
@@ -62,8 +63,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(2, lnPort));
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender("ln1", 2, false, 10, 100, false, false, null, true));
vm4.invoke(() -> WANTestBase.createSender("ln2", 2, false, 10, 100, false, false, null, true));
@@ -88,6 +89,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
}
}
+ protected SerializableRunnableIF createCacheRunnable(Integer lnPort) {
+ return () -> WANTestBase.createCache(lnPort );
+ }
+
/**
* Validate that ParallelGatewaySender can be added to Distributed region
*
@@ -106,8 +111,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln1", 2,
true, 10, 100, false, false, null, false ));
@@ -137,8 +142,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1));
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender("ln1", 2, false, 10, 100, false, false, null, true));
vm4.invoke(() -> WANTestBase.createSender("ln2", 2, false, 10, 100, false, false, null, true));
@@ -168,8 +173,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR", "ln1", isOffHeap() ));
@@ -197,8 +202,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1));
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender("ln1", 2, true, 10, 100, false, false, null, true));
vm4.invoke(() -> WANTestBase.createSender("ln2", 2, true, 10, 100, false, false, null, true));
@@ -234,7 +239,7 @@ public class WanValidationsDUnitTest extends WANTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSender("ln1_Parallel", 2, true, 10, 100, false, false, null, true));
vm1.invoke(() -> WANTestBase.createSender("ln2_Parallel", 2, true, 10, 100, false, false, null, true));
@@ -260,7 +265,7 @@ public class WanValidationsDUnitTest extends WANTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSender("ln1_Parallel", 2, true, 10, 100, false, false, null, true));
vm1.invoke(() -> WANTestBase.createSender("ln2_Parallel", 2, true, 10, 100, false, false, null, true));
@@ -294,7 +299,7 @@ public class WanValidationsDUnitTest extends WANTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSender("ln1_Parallel", 2, true, 10, 100, false, false, null, true));
vm1.invoke(() -> WANTestBase.createSender("ln2_Parallel", 2, true, 10, 100, false, false, null, true));
@@ -321,7 +326,7 @@ public class WanValidationsDUnitTest extends WANTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSender(
"ln1_Parallel", 2, true, 10, 100, false, false, null, true ));
@@ -349,7 +354,7 @@ public class WanValidationsDUnitTest extends WANTestBase {
try {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSender("ln1_Parallel", 2, true, 10, 100, false, false, null, true));
vm1.invoke(() -> WANTestBase.createSender("ln2_Parallel", 2, true, 10, 100, false, false, null, true));
@@ -378,7 +383,7 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testSerialGatewaySenderAndParallelGatewaySenderWithSameName() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations(
"ln", 2, false, 100, false, false, null, null, true, false ));
@@ -399,8 +404,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testSameRemoteDSAcrossSameSender() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations(
"ln", 2, false, 100, false, false, null, null,
@@ -425,8 +430,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testSerialSenderOnBothCache() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations(
"ln", 2, false, 100, false, false, null, null,
@@ -450,8 +455,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testParallelSenderOnBothCache(){
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2,
true, 100,false, false,
@@ -476,8 +481,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testBatchConflation() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2,
false, 100, false, false,
@@ -502,8 +507,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testisPersistentEnabled() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2,
false, 100, false, false,
@@ -524,8 +529,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testAlertThreshold() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2,
false, 100, false, false,
@@ -546,8 +551,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testManualStart() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2,
false, 100, false, false,
@@ -568,8 +573,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testGatewayEventFilters() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
ArrayList<GatewayEventFilter> eventFiletrs = new ArrayList<GatewayEventFilter>();
eventFiletrs.add(new MyGatewayEventFilter());
@@ -596,8 +601,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testGatewayEventFilters2() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
ArrayList<GatewayEventFilter> eventFiletrs = new ArrayList<GatewayEventFilter>();
eventFiletrs.add(new MyGatewayEventFilter());
@@ -625,8 +630,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testGatewayTransportFilters() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
ArrayList<GatewayTransportFilter> transportFiletrs = new ArrayList<GatewayTransportFilter>();
transportFiletrs.add(new MyGatewayTransportFilter1());
@@ -655,8 +660,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testGatewayTransportFiltersOrder() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
ArrayList<GatewayTransportFilter> transportFiletrs = new ArrayList<GatewayTransportFilter>();
transportFiletrs.add(new MyGatewayTransportFilter1());
@@ -711,8 +716,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testIsDiskSynchronous() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createSenderForValidations(
"ln", 2, false, 100, false, false, null,
@@ -761,7 +766,7 @@ public class WanValidationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
vm4.invoke(() -> WANTestBase.createReceiver( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(createCacheRunnable(lnPort));
vm5.invoke(() -> WANTestBase.createCacheServer( ));
@@ -785,8 +790,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void DISABLED_testDispatcherThreadsForParallelGatewaySender() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY ));
@@ -815,8 +820,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void DISABLED_testOrderPolicyForParallelGatewaySender() {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm1.invoke(() -> WANTestBase.createCache( lnPort ));
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm1.invoke(createCacheRunnable(lnPort));
+ vm2.invoke(createCacheRunnable(lnPort));
vm1.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY ));
@@ -840,27 +845,22 @@ public class WanValidationsDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm2.invoke(createReceiverReplicatedRegion());
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm4.invoke(createReceiverReplicatedRegion());
+ vm5.invoke(createReceiverReplicatedRegion());
+ vm6.invoke(createReceiverReplicatedRegion());
+ vm7.invoke(createReceiverReplicatedRegion());
vm4.invoke(() -> WANTestBase.addSenderThroughAttributesMutator(
getTestMethodName() + "_RR", "ln"));
@@ -885,10 +885,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testBug50434_RR_SerialAsyncEventQueue() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
@@ -899,14 +899,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm4.invoke(createReceiverReplicatedRegion());
+ vm5.invoke(createReceiverReplicatedRegion());
+ vm6.invoke(createReceiverReplicatedRegion());
+ vm7.invoke(createReceiverReplicatedRegion());
vm4.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" ));
@@ -925,33 +921,33 @@ public class WanValidationsDUnitTest extends WANTestBase {
}
}
}
+
+ protected SerializableRunnableIF createReceiverReplicatedRegion() {
+ return () -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() );
+ }
public void testBug50434_RR_Serial_Pass() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm2.invoke(createReceiverReplicatedRegion());
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm4.invoke(createReceiverReplicatedRegion());
+ vm5.invoke(createReceiverReplicatedRegion());
+ vm6.invoke(createReceiverReplicatedRegion());
+ vm7.invoke(createReceiverReplicatedRegion());
vm4.invoke(() -> WANTestBase.addSenderThroughAttributesMutator(
getTestMethodName() + "_RR", "ln"));
@@ -977,10 +973,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testBug50434_RR_SerialAsyncEventQueue_Pass() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
@@ -991,14 +987,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm4.invoke(createReceiverReplicatedRegion());
+ vm5.invoke(createReceiverReplicatedRegion());
+ vm6.invoke(createReceiverReplicatedRegion());
+ vm7.invoke(createReceiverReplicatedRegion());
vm4.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" ));
vm5.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" ));
@@ -1026,10 +1018,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_RR", null, 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1079,10 +1071,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testBug50434_PR_SerialAsyncEventQueue() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
@@ -1127,10 +1119,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1179,10 +1171,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testBug50434_PR_SerialAsyncEventQueue_Pass() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
@@ -1228,10 +1220,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 10, isOffHeap()));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -1273,10 +1265,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testBug50434_PR_ParallelAsyncEventQueue() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln",
true, 100, 100, false, false, null, false ));
@@ -1321,10 +1313,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 10, isOffHeap()));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
true, 100, 10, false, false, null, true ));
@@ -1368,10 +1360,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
public void testBug50434_PR_ParallelAsyncEventQueue_Pass() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln",
true, 100, 100, false, false, null, false ));
@@ -1424,8 +1416,8 @@ public class WanValidationsDUnitTest extends WANTestBase {
IgnoredException.addIgnoredException("could not get remote locator information");
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
try {
vm4.invoke(() -> WANTestBase.createSender( "ln1", 2,
@@ -1471,10 +1463,10 @@ public class WanValidationsDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
// ------------ START - CREATE CACHE, REGION ON LOCAL SITE ------------//
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(createCacheRunnable(lnPort));
+ vm5.invoke(createCacheRunnable(lnPort));
+ vm6.invoke(createCacheRunnable(lnPort));
+ vm7.invoke(createCacheRunnable(lnPort));
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));