You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ja...@apache.org on 2016/04/01 19:32:10 UTC
[2/7] incubator-geode git commit: GEODE-1062: Refactor of WANTestBase
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/65d7a6f1/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java
index ed6dc29..6899101 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java
@@ -69,7 +69,8 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- createReceivers(nyPort);
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
createSenderCaches(lnPort);
@@ -115,11 +116,6 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createCache( lnPort ));
}
- protected void createReceivers(Integer nyPort) {
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
- }
-
protected void createSenderVM5() {
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, true, null, true ));
@@ -135,7 +131,8 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- createReceivers(nyPort);
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
createSenderCaches(lnPort);
@@ -149,7 +146,7 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
10 ));
- startSenders();
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
100 ));
@@ -190,7 +187,8 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- createReceivers(nyPort);
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
createSenderCaches(lnPort);
@@ -204,7 +202,7 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
20 ));
- startSenders();
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
20 ));
@@ -270,16 +268,12 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
vm5.invoke(() -> WANTestBase.validateQueueSizeStat( "ln", 0 ));
}
- protected void startSenders() {
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- }
-
public void testStopOneSerialGatewaySenderBothPrimary() throws Throwable {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- createReceivers(nyPort);
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
createSenderCaches(lnPort);
@@ -290,7 +284,7 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
createSenderRegions();
- startSenders();
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
100 ));
@@ -331,7 +325,8 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- createReceivers(nyPort);
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
createSenderCaches(lnPort);
@@ -342,7 +337,7 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
createSenderRegions();
- startSenders();
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
10 ));
@@ -366,11 +361,12 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4);
createSenderVM4();
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -428,9 +424,11 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.stopSender( "ln" ));
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+
LogWriterUtils.getLogWriter().info("Completed puts in the region");
vm2.invoke(() -> WANTestBase.validateRegionSize(
getTestMethodName() + "_RR", 100 ));
@@ -454,7 +452,8 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- createReceivers(nyPort);
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
createSenderCaches(lnPort);
@@ -465,7 +464,7 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
createSenderRegions();
- startSenders();
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
10 ));
@@ -491,7 +490,8 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- createReceivers(nyPort);
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
createSenderCaches(lnPort);
@@ -502,7 +502,7 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
createSenderRegions();
- startSenders();
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
10 ));
@@ -526,7 +526,8 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- createReceivers(nyPort);
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
createSenderCaches(lnPort);
@@ -537,7 +538,7 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase {
createSenderRegions();
- startSenders();
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
10 ));
@@ -556,19 +557,17 @@ public class SerialGatewaySenderOperationsDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, true, null, true ));
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, true, null, true ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
SerializableRunnable check = new SerializableRunnable("assert no cache servers") {
public void run() {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/65d7a6f1/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java
index c4ceb21..d77fdcf 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java
@@ -80,8 +80,7 @@ public class SerialGatewaySenderQueueDUnitTest extends WANTestBase{
vm5.invoke(() -> WANTestBase.createSenderWithMultipleDispatchers( "ln", 2,
false, 100, 10, false, false, null, true, 1, OrderPolicy.KEY ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -148,8 +147,9 @@ public class SerialGatewaySenderQueueDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
+
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
@@ -158,11 +158,8 @@ public class SerialGatewaySenderQueueDUnitTest extends WANTestBase{
vm2.invoke(() -> WANTestBase.addListenerOnRegion(getTestMethodName() + "_PR"));
vm3.invoke(() -> WANTestBase.addListenerOnRegion(getTestMethodName() + "_PR"));
-
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSenderWithMultipleDispatchers( "ln", 2,
false, 100, 10, false, false, null, true, 1, OrderPolicy.KEY ));
@@ -178,8 +175,7 @@ public class SerialGatewaySenderQueueDUnitTest extends WANTestBase{
vm7.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.addQueueListener( "ln", false));
vm5.invoke(() -> WANTestBase.addQueueListener( "ln", false));
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/65d7a6f1/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java
index 4fac57f..9a818e0 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java
@@ -43,13 +43,10 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, true, null, true ));
@@ -61,8 +58,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -92,13 +88,10 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -108,8 +101,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends
vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR", null, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR", "ln", isOffHeap() ));
vm5.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -135,13 +127,10 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, true, null, true ));
@@ -151,8 +140,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends
vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR", null, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR", "ln", isOffHeap() ));
vm5.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -177,13 +165,10 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
String firstDStore = (String)vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, false,
100, 10, false, true, null, null, true ));
@@ -198,8 +183,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -277,13 +261,10 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
String firstDStore = (String)vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, false,
100, 10, false, true, null, null, true ));
@@ -298,8 +279,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -370,13 +350,10 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2, false,
100, 10, false, false, null, true ));
@@ -388,8 +365,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -473,13 +449,10 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
String firstDStore = (String)vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, false,
100, 10, false, true, null, null, true ));
@@ -494,8 +467,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/65d7a6f1/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java
index b1fb8d9..8cc50de 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropagationLoopBackDUnitTest.java
@@ -36,6 +36,8 @@ public class SerialWANPropagationLoopBackDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
+ vm2.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm3.invoke(() -> WANTestBase.createCache( nyPort ));
vm2.invoke(() -> WANTestBase.createReceiver( lnPort ));
vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
@@ -125,13 +127,14 @@ public class SerialWANPropagationLoopBackDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
Integer tkPort = (Integer)vm2.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, lnPort ));
-
+ createCacheInVMs(lnPort, vm3, vm6);
+ createCacheInVMs(nyPort, vm4, vm7);
+ createCacheInVMs(tkPort, vm5);
+
vm3.invoke(() -> WANTestBase.createReceiver( lnPort ));
vm4.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm5.invoke(() -> WANTestBase.createReceiver( tkPort ));
-
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( nyPort ));
+
// using vm5 for sender in ds 3. cache is already created.
vm6.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -230,13 +233,14 @@ public class SerialWANPropagationLoopBackDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
Integer tkPort = (Integer)vm2.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, lnPort ));
-
+ createCacheInVMs(lnPort, vm3, vm6);
+ createCacheInVMs(nyPort, vm4, vm7);
+ createCacheInVMs(tkPort, vm5);
+
vm3.invoke(() -> WANTestBase.createReceiver( lnPort ));
vm4.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm5.invoke(() -> WANTestBase.createReceiver( tkPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( nyPort ));
// using vm5 for sender in ds 3. cache is already created.
vm6.invoke(() -> WANTestBase.createSender( "ln1", 2,
@@ -373,7 +377,9 @@ public class SerialWANPropagationLoopBackDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
Integer tkPort = (Integer)vm2.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, lnPort ));
-
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm5.invoke(() -> WANTestBase.createCache( tkPort ));
vm3.invoke(() -> WANTestBase.createReceiver( lnPort ));
vm4.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm5.invoke(() -> WANTestBase.createReceiver( tkPort ));
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/65d7a6f1/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java
index a272eeb..55f1ac1 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationDUnitTest.java
@@ -53,10 +53,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
public void disabledtestReplicatedSerialPropagation_withoutRemoteLocator() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
//keep the batch size high enough to reduce the number of exceptions in the log
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -64,25 +61,23 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
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(createCacheRunnable(nyPort));
- vm3.invoke(createCacheRunnable(nyPort));
-
+ createCacheInVMs(nyPort, vm2, vm3);
+
vm2.invoke(() -> WANTestBase.createReceiver2(nyPort ));
vm3.invoke(() -> WANTestBase.createReceiver2(nyPort ));
-
+
vm2.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
@@ -102,20 +97,13 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
getTestMethodName() + "_RR", "ln", isOffHeap() );
}
- protected SerializableRunnableIF createCacheRunnable(Integer lnPort) {
- return () -> WANTestBase.createCache(lnPort );
- }
-
public void testReplicatedSerialPropagation_withoutRemoteSite() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
//keep the batch size high enough to reduce the number of exceptions in the log
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -123,8 +111,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(createReplicatedRegionRunnable());
vm5.invoke(createReplicatedRegionRunnable());
@@ -133,25 +120,21 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
-
- vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
- "ln", false ));
- vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
- "ln", false ));
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
-
- vm2.invoke(createCacheRunnable(nyPort));
- vm3.invoke(createCacheRunnable(nyPort));
-
- vm2.invoke(() -> WANTestBase.createReceiver2(nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver2(nyPort ));
-
+
+ createCacheInVMs(nyPort, vm2, vm3);
+
vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ getTestMethodName() + "_RR", null, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm2.invoke(() -> WANTestBase.createReceiver2(nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver2(nyPort ));
+
+ Thread.sleep(5000);
vm4.invoke(() -> WANTestBase.validateRegionSize(
getTestMethodName() + "_RR", 1000 ));
@@ -173,10 +156,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
// reduce the batch-size so maximum number of batches will be sent
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -184,8 +164,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 5, false, false, null, true ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(createReplicatedRegionRunnable());
vm5.invoke(createReplicatedRegionRunnable());
@@ -195,10 +174,6 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
IgnoredException.addIgnoredException(IOException.class.getName());
- vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
- "ln", false ));
- vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
- "ln", false ));
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
10000 ));
@@ -206,8 +181,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// pause for some time before starting up the remote site
Wait.pause(10000);
- vm2.invoke(createCacheRunnable(nyPort));
- vm3.invoke(createCacheRunnable(nyPort));
+ createCacheInVMs(nyPort, vm2, vm3);
vm2.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
@@ -233,13 +207,10 @@ public class SerialWANPropogationDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -251,8 +222,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(createReplicatedRegionRunnable());
vm5.invoke(createReplicatedRegionRunnable());
@@ -272,13 +242,10 @@ public class SerialWANPropogationDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -290,8 +257,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(createReplicatedRegionRunnable());
vm5.invoke(createReplicatedRegionRunnable());
@@ -310,28 +276,21 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer regionSize =
(Integer) vm2.invoke(() -> WANTestBase.getRegionSize(getTestMethodName() + "_RR" ));
LogWriterUtils.getLogWriter().info("Region size on remote is: " + regionSize);
-
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
-
- vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
- vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
vm4.invoke(createReplicatedRegionRunnable());
vm5.invoke(createReplicatedRegionRunnable());
vm6.invoke(createReplicatedRegionRunnable());
vm7.invoke(createReplicatedRegionRunnable());
-
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
-
+
+ startSenderInVMs("ln", vm4, vm5);
+
vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
@@ -362,14 +321,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//these are part of remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
//these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
//senders are created on local site
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -390,8 +346,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
getTestMethodName() + "_RR_2", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
//create one RR (RR_1) on local site
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
@@ -447,14 +402,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//these are part of remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
//these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
//senders are created on local site
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -469,8 +421,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
getTestMethodName() + "_RR_1", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
//create one RR (RR_1) on local site
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
@@ -519,14 +470,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//these are part of remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
//these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
//senders are created on local site
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -547,8 +495,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
getTestMethodName() + "_RR_2", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
//create one RR (RR_1) on local site
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
@@ -594,25 +541,17 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
getTestMethodName() + "_RR_1", 1000 ));
}
-
- /**
- * In this test the system property gemfire.GatewaySender.REMOVE_FROM_QUEUE_ON_EXCEPTION is set to true.
- * This will ensure that other events which did not cause BatchException can reach remote site.
- */
+
public void testReplicatedSerialPropagationWithRemoteRegionDestroy3()
throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
// these are part of remote site
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
-
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
// these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
// senders are created on local site
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
@@ -633,12 +572,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
getTestMethodName() + "_RR_2", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
- vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
-
- // start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
// create one RR (RR_1) on local site
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
@@ -716,14 +650,12 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//these are part of remote site
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
//vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
//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
@@ -739,8 +671,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// testName + "_RR_1", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
//create one RR (RR_1) on local site
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
@@ -777,11 +708,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer) vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
// these are part of remote site
+ vm2.invoke(() -> WANTestBase.createCache( nyPort ));
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5);
// 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
@@ -800,8 +731,6 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
- "ln", false ));
// start puts in RR_1 in another thread
AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
@@ -827,10 +756,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmpty",
// new Object[] { "ln" });
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
-
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
0 ));
@@ -844,11 +773,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer) vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
// these are part of remote site
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5);
// 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
@@ -862,15 +791,12 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR_1", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
// create one RR (RR_1) on local site
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
- "ln", false ));
// start puts in RR_1 in another thread
AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
@@ -893,9 +819,9 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty( "ln" ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
-
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
0 ));
@@ -912,11 +838,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer) vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
// these are part of remote site
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5);
// 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
@@ -934,9 +860,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// create one RR (RR_1) on local site
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
- "ln", false ));
+
// start puts in RR_1 in another thread
AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
// close cache in remote site. This will automatically kill the remote
@@ -964,10 +888,12 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm1.invoke(() -> WANTestBase.bringBackLocatorOnOldPort(
2, lnPort, nyPort ));
- vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
- getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
0 ));
@@ -985,11 +911,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort2 = (Integer) vm3.invoke(() -> WANTestBase.createSecondRemoteLocator( 2, nyPort1, lnPort ));
// these are part of remote site
+ createCacheInVMs(nyPort1, vm2);
vm2.invoke(() -> WANTestBase.createReceiver( nyPort1 ));
// these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5);
// 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
@@ -1008,8 +934,6 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
- "ln", false ));
// start puts in RR_1 in another thread
AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
// close cache in remote site. This will automatically kill the remote
@@ -1032,10 +956,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty( "ln" ));
+ createCacheInVMs(nyPort2, vm6);
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
vm6.invoke(() -> WANTestBase.createReceiver( nyPort2 ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR_1", null, isOffHeap() ));
vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
0 ));
@@ -1049,12 +974,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer) vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
// these are part of remote site
+ createCacheInVMs(nyPort, vm2, vm3);
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm3.invoke(createCacheRunnable(nyPort));
// these are part of local site
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5);
// 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
@@ -1098,9 +1022,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty( "ln" ));
- vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm3);
vm3.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
0 ));
@@ -1116,13 +1041,12 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer nyPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
Integer tkPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, lnPort ));
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(tkPort, vm3);
vm3.invoke(() -> WANTestBase.createReceiver( tkPort ));
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "lnSerial1",
2, false, 100, 10, false, false, null, true ));
@@ -1139,11 +1063,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "lnSerial1" ));
- vm5.invoke(() -> WANTestBase.startSender( "lnSerial1" ));
-
- vm4.invoke(() -> WANTestBase.startSender( "lnSerial2" ));
- vm5.invoke(() -> WANTestBase.startSender( "lnSerial2" ));
+ startSenderInVMs("lnSerial1", vm4, vm5);
+ startSenderInVMs("lnSerial2", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() ));
@@ -1168,13 +1089,10 @@ public class SerialWANPropogationDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1186,8 +1104,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(createReplicatedRegionRunnable());
vm5.invoke(createReplicatedRegionRunnable());
@@ -1224,15 +1141,12 @@ public class SerialWANPropogationDUnitTest 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 ));
- vm6.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm7.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm2, vm3, vm6, vm7);
+ createReceiverInVMs(nyPort, vm2, vm3, vm6, vm7);
LogWriterUtils.getLogWriter().info("Started receivers on remote site");
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
+ WANTestBase.createCacheInVMs(lnPort, vm4, vm5);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1248,8 +1162,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
LogWriterUtils.getLogWriter().info("Started senders on local site");
@@ -1307,15 +1220,12 @@ public class SerialWANPropogationDUnitTest 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 ));
- vm6.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm7.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ createCacheInVMs(nyPort, vm2, vm3, vm6, vm7);
+ createReceiverInVMs(nyPort, vm2, vm3, vm6, vm7);
LogWriterUtils.getLogWriter().info("Started receivers on remote site");
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1331,8 +1241,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm7.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
LogWriterUtils.getLogWriter().info("Started senders on local site");
@@ -1363,7 +1272,7 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// ---------------------------REBUILD vm4
// --------------------------------------
LogWriterUtils.getLogWriter().info("Rebuilding vm4....");
- vm4.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
@@ -1402,10 +1311,10 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm4.invoke(createCacheRunnable(lnPort));
- vm5.invoke(createCacheRunnable(lnPort));
+ createCacheInVMs(lnPort, vm4, vm5);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -1416,7 +1325,6 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
getTestMethodName() + "_RR", null, isOffHeap() ));
vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- Wait.pause(500);
vm5.invoke(() -> WANTestBase.startSender( "ln" ));
vm4.invoke(() -> WANTestBase.createNormalRegion(
@@ -1455,23 +1363,21 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
public void testReplicatedSerialPropagationWithRemoteSenderConfiguredButNotStarted() {
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 ));
-
- vm4.invoke(() -> WANTestBase.createReceiver( lnPort ));
- vm5.invoke(() -> WANTestBase.createReceiver( lnPort ));
- vm6.invoke(createCacheRunnable(lnPort));
- vm7.invoke(createCacheRunnable(lnPort));
-
+
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
+
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
+ createReceiverInVMs(lnPort, vm4, vm5);
+
+
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
-
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
-
+
+ startSenderInVMs("ln", vm4, vm5);
+
vm4.invoke(createReplicatedRegionRunnable());
vm5.invoke(createReplicatedRegionRunnable());
vm6.invoke(createReplicatedRegionRunnable());
@@ -1489,10 +1395,9 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
-
- vm2.invoke(() -> WANTestBase.startSender( "ny" ));
- vm3.invoke(() -> WANTestBase.startSender( "ny" ));
-
+
+ startSenderInVMs("ny", vm2, vm3);
+
vm2.invoke(() -> WANTestBase.validateRegionSize(
getTestMethodName() + "_RR", 1000 ));
vm3.invoke(() -> WANTestBase.validateRegionSize(
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/65d7a6f1/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java
index 126e737..b6d0ee4 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java
@@ -37,13 +37,10 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -80,13 +77,10 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -103,8 +97,7 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest extends WANTestBase
vm3.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -140,13 +133,10 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "lnSerial",
2, false, 100, 10, false, false, null, true ));
@@ -201,13 +191,10 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "lnSerial1",
2, false, 100, 10, false, false, null, true ));
@@ -247,11 +234,9 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest extends WANTestBase
vm7.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", "lnSerial2", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "lnSerial1" ));
- vm5.invoke(() -> WANTestBase.startSender( "lnSerial1" ));
+ startSenderInVMs("lnSerial1", vm4, vm5);
- vm5.invoke(() -> WANTestBase.startSender( "lnSerial2" ));
- vm6.invoke(() -> WANTestBase.startSender( "lnSerial2" ));
+ startSenderInVMs("lnSerial2", vm5, vm6);
vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
@@ -270,13 +255,12 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest extends WANTestBase
Integer nyPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstRemoteLocator(2, lnPort ));
Integer tkPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(3,lnPort ));
+ createCacheInVMs(nyPort, vm2);
vm2.invoke(() -> WANTestBase.createReceiver(nyPort ));
+ createCacheInVMs(tkPort, vm3);
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 ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "lnSerial1",
2, false, 100, 10, false, false, null, true ));
@@ -293,11 +277,8 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest extends WANTestBase
vm3.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "lnSerial1" ));
- vm5.invoke(() -> WANTestBase.startSender( "lnSerial1" ));
-
- vm4.invoke(() -> WANTestBase.startSender( "lnSerial2" ));
- vm5.invoke(() -> WANTestBase.startSender( "lnSerial2" ));
+ startSenderInVMs("lnSerial1", vm4, vm5);
+ startSenderInVMs("lnSerial2", vm4, vm5);
vm4.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", "lnSerial1,lnSerial2", 1, 100, isOffHeap() ));
@@ -325,13 +306,10 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -347,9 +325,8 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest extends WANTestBase
vm7.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
-
+ startSenderInVMs("ln", vm4, vm5);
+
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createPartitionedRegion(
@@ -379,13 +356,8 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest 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 ));
-
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -401,13 +373,13 @@ public class SerialWANPropogation_PartitionedRegionDUnitTest extends WANTestBase
vm7.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
vm3.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
+ createReceiverInVMs(nyPort, vm2, vm3);
vm4.invoke(() -> WANTestBase.doMultiThreadedPuts(
getTestMethodName() + "_PR", 1000 ));
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/65d7a6f1/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java
index 5846e75..6658be5 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java
@@ -33,13 +33,10 @@ public class SerialWANPropogationsFeatureDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -51,8 +48,7 @@ public class SerialWANPropogationsFeatureDUnitTest extends WANTestBase{
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -77,13 +73,10 @@ public class SerialWANPropogationsFeatureDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, true, null, true ));
@@ -95,8 +88,7 @@ public class SerialWANPropogationsFeatureDUnitTest extends WANTestBase{
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -122,13 +114,10 @@ public class SerialWANPropogationsFeatureDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 1000, true, false, null, true ));
@@ -140,8 +129,7 @@ public class SerialWANPropogationsFeatureDUnitTest extends WANTestBase{
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -167,13 +155,10 @@ public class SerialWANPropogationsFeatureDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm6.invoke(() -> WANTestBase.createCache( lnPort ));
- vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false, null, true ));
@@ -185,8 +170,7 @@ public class SerialWANPropogationsFeatureDUnitTest extends WANTestBase{
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
@@ -211,13 +195,10 @@ public class SerialWANPropogationsFeatureDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false,
@@ -235,8 +216,7 @@ public class SerialWANPropogationsFeatureDUnitTest extends WANTestBase{
vm7.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm2.invoke(() -> WANTestBase.createPartitionedRegion(
getTestMethodName(), null, 1, 100, isOffHeap() ));
@@ -254,13 +234,10 @@ public class SerialWANPropogationsFeatureDUnitTest 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 ));
+ createCacheInVMs(nyPort, vm2, vm3);
+ createReceiverInVMs(nyPort, vm2, vm3);
- vm4.invoke(() -> WANTestBase.createCache(lnPort ));
- vm5.invoke(() -> WANTestBase.createCache(lnPort ));
- vm6.invoke(() -> WANTestBase.createCache(lnPort ));
- vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+ createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
false, 100, 10, false, false,
@@ -274,8 +251,7 @@ public class SerialWANPropogationsFeatureDUnitTest extends WANTestBase{
vm3.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName(), null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm4.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName(), "ln", isOffHeap() ));
@@ -299,14 +275,10 @@ public class SerialWANPropogationsFeatureDUnitTest 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 ));
-
- vm2.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ createCacheInVMs(nyPort, vm6, vm7);
+ createReceiverInVMs(nyPort, vm6, vm7);
+ createCacheInVMs(lnPort, vm2, vm3, vm4, vm5);
vm4.invoke(() -> WANTestBase.createSender( "ln", 2, false, 100, 10, false, false,
new MyGatewayEventFilter_AfterAck(), true ));
vm5.invoke(() -> WANTestBase.createSender( "ln", 2, false, 100, 10, false, false,
@@ -317,8 +289,7 @@ public class SerialWANPropogationsFeatureDUnitTest extends WANTestBase{
vm7.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName(), null, isOffHeap() ));
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ startSenderInVMs("ln", vm4, vm5);
vm2.invoke(() -> WANTestBase.createReplicatedRegion(
getTestMethodName(), "ln", isOffHeap() ));