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/19 19:36:43 UTC
[06/63] [abbrv] incubator-geode git commit: Automatically converting
calls of vm.invoke to lambdas
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/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 56e8d82..91234c9 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
@@ -50,122 +50,114 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// this test is disabled due to a high rate of failure in unit test runs
// see ticket #52190
public void disabledtestReplicatedSerialPropagation_withoutRemoteLocator() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
+ vm4.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache(lnPort ));
//keep the batch size high enough to reduce the number of exceptions in the log
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 400, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 400, false, false, null, true });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 400, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 400, false, false, null, true ));
+
+ 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(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm2.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm3.invoke(() -> WANTestBase.createCache( nyPort ));
- vm2.invoke(WANTestBase.class, "createReceiver2",
- new Object[] {nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver2",
- new Object[] {nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver2(nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver2(nyPort ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
public void testReplicatedSerialPropagation_withoutRemoteSite() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm4.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
+ vm4.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache(lnPort ));
//keep the batch size high enough to reduce the number of exceptions in the log
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 400, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 400, false, false, null, true });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 400, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 400, false, false, null, true ));
+
+ 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() ));
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] {
- "ln", false });
- vm5.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] {
- "ln", false });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
+ "ln", false ));
+ vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
+ "ln", false ));
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
- vm2.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm3.invoke(() -> WANTestBase.createCache( nyPort ));
- vm2.invoke(WANTestBase.class, "createReceiver2",
- new Object[] {nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver2",
- new Object[] {nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver2(nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver2(nyPort ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
/**
@@ -175,207 +167,201 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
*/
public void testReplicatedSerialPropagationWithoutRemoteSite_defect46595()
throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
// reduce the batch-size so maximum number of batches will be sent
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 5, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 5, false, false, null, true });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 5, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 5, false, false, null, true ));
+
+ 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() ));
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
IgnoredException.addIgnoredException(IOException.class.getName());
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] {
- "ln", false });
- vm5.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] {
- "ln", false });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
+ "ln", false ));
+ vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
+ "ln", false ));
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 10000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 10000 ));
// pause for some time before starting up the remote site
Wait.pause(10000);
- vm2.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm3.invoke(() -> WANTestBase.createCache( nyPort ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm2.invoke(WANTestBase.class, "createReceiver2", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver2", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver2( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver2( nyPort ));
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 10000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 10000 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 10000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 10000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 10000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 10000 ));
}
public void testReplicatedSerialPropagation() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
-
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
-
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
-
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ 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 ));
+
+ 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 ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ 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(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
public void testReplicatedSerialPropagationWithLocalSiteClosedAndRebuilt() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
-
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
-
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
-
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ 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 ));
+
+ 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 ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ 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(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
//---------close local site and build again-----------------------------------------
- vm4.invoke(WANTestBase.class, "killSender", new Object[] { });
- vm5.invoke(WANTestBase.class, "killSender", new Object[] { });
- vm6.invoke(WANTestBase.class, "killSender", new Object[] { });
- vm7.invoke(WANTestBase.class, "killSender", new Object[] { });
+ vm4.invoke(() -> WANTestBase.killSender( ));
+ vm5.invoke(() -> WANTestBase.killSender( ));
+ vm6.invoke(() -> WANTestBase.killSender( ));
+ vm7.invoke(() -> WANTestBase.killSender( ));
Integer regionSize =
- (Integer) vm2.invoke(WANTestBase.class, "getRegionSize", new Object[] {getTestMethodName() + "_RR" });
+ (Integer) vm2.invoke(() -> WANTestBase.getRegionSize(getTestMethodName() + "_RR" ));
LogWriterUtils.getLogWriter().info("Region size on remote is: " + regionSize);
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
-
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+
+ 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.class, "setRemoveFromQueueOnException", new Object[] { "ln", true });
- vm5.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] { "ln", true });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
+ vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ 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(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
IgnoredException.addIgnoredException(EntryExistsException.class.getName());
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
//----------------------------------------------------------------------------------
//verify remote site receives all the events
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
/**
@@ -386,69 +372,67 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
* @throws Exception
*/
public void testReplicatedSerialPropagationWithLocalRegionDestroy() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
//senders are created on local site
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 20, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 20, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 20, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 20, false, false, null, true ));
//create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
//create another RR (RR_2) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
//create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
//create another RR (RR_2) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
//do puts in RR_2 in main thread
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_2", 500 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_2", 500 ));
//destroy RR_2 after above puts are complete
- vm4.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_2"});
+ vm4.invoke(() -> WANTestBase.destroyRegion( getTestMethodName() + "_RR_2"));
try {
inv1.join();
@@ -458,11 +442,11 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
}
//sleep for some time to let all the events propagate to remote site
Thread.sleep(20);
- //vm4.invoke(WANTestBase.class, "verifyQueueSize", new Object[] { "ln", 0 });
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_2", 500 });
+ //vm4.invoke(() -> WANTestBase.verifyQueueSize( "ln", 0 ));
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_2", 500 ));
}
/**
@@ -473,54 +457,52 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
* @throws Exception
*/
public void testReplicatedSerialPropagationWithRemoteRegionDestroy() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
//senders are created on local site
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 500, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 500, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 500, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 500, false, false, null, true ));
//create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
//create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
//destroy RR_1 in remote site
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_1"});
+ vm2.invoke(() -> WANTestBase.destroyRegion( getTestMethodName() + "_RR_1"));
try {
inv1.join();
@@ -530,13 +512,13 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
}
//verify that all is well in local site. All the events should be present in local region
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 1000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 1000 ));
//assuming some events might have been dispatched before the remote region was destroyed,
//sender's region queue will have events less than 1000 but the queue will not be empty.
//NOTE: this much verification might be sufficient in DUnit. Hydra will take care of
//more in depth validations.
- vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmpty", new Object[] {"ln" });
+ vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty("ln" ));
}
/**
@@ -547,74 +529,72 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
* @throws Exception
*/
public void testReplicatedSerialPropagationWithRemoteRegionDestroy2() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
//senders are created on local site
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 200, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 200, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 200, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 200, false, false, null, true ));
//create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
//create another RR (RR_2) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
//create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
//create another RR (RR_2) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
//destroy RR_2 on remote site in the middle
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_2"});
+ vm2.invoke(() -> WANTestBase.destroyRegion( getTestMethodName() + "_RR_2"));
//expected exceptions in the logs
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
//start puts in RR_2 in another thread
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_2", 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_2", 1000 ));
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
try {
inv1.join();
@@ -624,8 +604,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
}
//though region RR_2 is destroyed, RR_1 should still get all the events put in it
//in local site
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 1000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 1000 ));
}
@@ -635,79 +615,75 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
*/
public void testReplicatedSerialPropagationWithRemoteRegionDestroy3()
throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
// senders are created on local site
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 200, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 200, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 200, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 200, false, false, null, true ));
// create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
// create another RR (RR_2) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] { "ln", true });
- vm5.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] { "ln", true });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
+ vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
// create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
// create another RR (RR_2) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
// start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
// start puts in RR_2 in another thread
- AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_2", 1000 });
+ AsyncInvocation inv2 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_2", 1000 ));
// destroy RR_2 on remote site in the middle
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName()
- + "_RR_2" });
+ vm2.invoke(() -> WANTestBase.destroyRegion( getTestMethodName()
+ + "_RR_2" ));
try {
inv1.join();
@@ -720,8 +696,8 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
// in it
// in local site
try {
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 1000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 1000 ));
} finally {
System.setProperty(
"gemfire.GatewaySender.REMOVE_FROM_QUEUE_ON_EXCEPTION", "False");
@@ -750,53 +726,51 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
* @throws Exception
*/
public void testReplicatedSerialPropagationWithRemoteReceiverStopped() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
- //vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ //vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( 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
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, false, null, true ));
//create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- //vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- // testName + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ //vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ // testName + "_RR_1", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
//create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 500 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 500 ));
//close cache in remote site. This will automatically kill the remote receivers.
- vm2.invoke(WANTestBase.class, "closeCache");
- //vm3.invoke(WANTestBase.class, "closeCache");
+ vm2.invoke(() -> WANTestBase.closeCache());
+ //vm3.invoke(() -> WANTestBase.closeCache());
try {
inv1.join();
@@ -806,53 +780,50 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
}
//verify that all is well in local site
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 500 });
- vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmpty", new Object[] {"ln" });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 500 ));
+ vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty("ln" ));
}
public void testReplicatedSerialPropagationWithRemoteReceiverRestarted()
throws Exception {
- Integer lnPort = (Integer) vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer) vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( 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
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, false, null, true ));
// create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
// create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] {
- "ln", false });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
+ "ln", false ));
// start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 8000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
// close cache in remote site. This will automatically kill the remote
// receivers.
Wait.pause(2000);
- vm2.invoke(WANTestBase.class, "closeCache");
- // vm3.invoke(WANTestBase.class, "closeCache");
+ vm2.invoke(() -> WANTestBase.closeCache());
+ // vm3.invoke(() -> WANTestBase.closeCache());
try {
inv1.join();
@@ -861,73 +832,67 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
fail();
}
- vm4.invoke(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
// verify that all is well in local site
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 8000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 8000 ));
// vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmpty",
// new Object[] { "ln" });
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
- vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln",
- 0 });
+ vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
+ 0 ));
- vm2.invoke(WANTestBase.class, "checkMinimumGatewayReceiverStats",
- new Object[] { 1, 1 });
+ vm2.invoke(() -> WANTestBase.checkMinimumGatewayReceiverStats( 1, 1 ));
}
public void testReplicatedSerialPropagationWithRemoteReceiverRestarted_SenderReceiverPersistent()
throws Exception {
- Integer lnPort = (Integer) vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer) vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( 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
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, true, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, true, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, true, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, true, null, true ));
// create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createPersistentReplicatedRegion",
- new Object[] { getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR_1", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
// create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] {
- "ln", false });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
+ "ln", false ));
// start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 8000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
// close cache in remote site. This will automatically kill the remote
// receivers.
Wait.pause(2000);
- vm2.invoke(WANTestBase.class, "closeCache");
- // vm3.invoke(WANTestBase.class, "closeCache");
+ vm2.invoke(() -> WANTestBase.closeCache());
+ // vm3.invoke(() -> WANTestBase.closeCache());
try {
inv1.join();
@@ -937,69 +902,63 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
}
// verify that all is well in local site
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 8000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 8000 ));
- vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmpty",
- new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty( "ln" ));
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm2.invoke(WANTestBase.class, "createPersistentReplicatedRegion",
- new Object[] { getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion( getTestMethodName() + "_RR_1", null, isOffHeap() ));
- vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln",
- 0 });
+ vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
+ 0 ));
- vm2.invoke(WANTestBase.class, "checkMinimumGatewayReceiverStats",
- new Object[] { 1, 1 });
+ vm2.invoke(() -> WANTestBase.checkMinimumGatewayReceiverStats( 1, 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 8000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 8000 ));
}
public void testReplicatedSerialPropagationWithRemoteSiteBouncedBack_ReceiverPersistent()
throws Exception {
- Integer lnPort = (Integer) vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer) vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( 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
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, false, null, true ));
// create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createPersistentReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
// create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] {
- "ln", false });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
+ "ln", false ));
// start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 8000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
// close cache in remote site. This will automatically kill the remote
// receivers.
Wait.pause(2000);
- vm1.invoke(WANTestBase.class, "shutdownLocator");
- vm2.invoke(WANTestBase.class, "closeCache");
- // vm3.invoke(WANTestBase.class, "closeCache");
+ vm1.invoke(() -> WANTestBase.shutdownLocator());
+ vm2.invoke(() -> WANTestBase.closeCache());
+ // vm3.invoke(() -> WANTestBase.closeCache());
try {
inv1.join();
@@ -1008,78 +967,71 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
fail();
}
// Do some extra puts after cache close so that some events are in the queue.
- vm4.invoke(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
// verify that all is well in local site
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 8000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 8000 ));
- vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmpty",
- new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty( "ln" ));
- vm1.invoke(WANTestBase.class, "bringBackLocatorOnOldPort", new Object[] {
- 2, lnPort, nyPort });
+ vm1.invoke(() -> WANTestBase.bringBackLocatorOnOldPort(
+ 2, lnPort, nyPort ));
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm2.invoke(WANTestBase.class, "createPersistentReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
- vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln",
- 0 });
+ vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
+ 0 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 8000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 8000 ));
- vm2.invoke(WANTestBase.class, "checkMinimumGatewayReceiverStats",
- new Object[] { 1, 1 });
+ vm2.invoke(() -> WANTestBase.checkMinimumGatewayReceiverStats( 1, 1 ));
}
public void testReplicatedSerialPropagationWithRemoteSiteBouncedBackWithMultipleRemoteLocators()
throws Exception {
- Integer lnPort = (Integer) vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort1 = (Integer) vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
- Integer nyPort2 = (Integer) vm3.invoke(WANTestBase.class,
- "createSecondRemoteLocator", new Object[] { 2, nyPort1, lnPort });
+ Integer lnPort = (Integer) vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort1 = (Integer) vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort2 = (Integer) vm3.invoke(() -> WANTestBase.createSecondRemoteLocator( 2, nyPort1, lnPort ));
// these are part of remote site
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort1 });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort1 ));
// these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( 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
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, false, null, true ));
// create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
// create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] {
- "ln", false });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException(
+ "ln", false ));
// start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 8000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
// close cache in remote site. This will automatically kill the remote
// receivers.
Wait.pause(2000);
- vm1.invoke(WANTestBase.class, "shutdownLocator");
- vm2.invoke(WANTestBase.class, "closeCache");
- // vm3.invoke(WANTestBase.class, "closeCache");
+ vm1.invoke(() -> WANTestBase.shutdownLocator());
+ vm2.invoke(() -> WANTestBase.closeCache());
+ // vm3.invoke(() -> WANTestBase.closeCache());
try {
inv1.join();
@@ -1087,71 +1039,65 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
e.printStackTrace();
fail();
}
- vm4.invoke(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
// verify that all is well in local site
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 8000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 8000 ));
- vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmpty",
- new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty( "ln" ));
- vm6.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort2 });
+ vm6.invoke(() -> WANTestBase.createReceiver( nyPort2 ));
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
- vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln",
- 0 });
+ vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
+ 0 ));
- vm6.invoke(WANTestBase.class, "checkMinimumGatewayReceiverStats",
- new Object[] { 1, 1 });
+ vm6.invoke(() -> WANTestBase.checkMinimumGatewayReceiverStats( 1, 1 ));
}
public void testReplicatedSerialPropagationWithRemoteReceiverRestartedOnOtherNode()
throws Exception {
- Integer lnPort = (Integer) vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer) vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ 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.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createCache( nyPort ));
// these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( 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
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 350, false, false, null, true });
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 350, false, false, null, true ));
// create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createPersistentReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createPersistentReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
// create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
// start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 8000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 8000 ));
// close cache in remote site. This will automatically kill the remote
// receivers.
- vm2.invoke(WANTestBase.class, "closeCache");
- vm3.invoke(WANTestBase.class, "closeCache");
+ vm2.invoke(() -> WANTestBase.closeCache());
+ vm3.invoke(() -> WANTestBase.closeCache());
try {
inv1.join();
@@ -1161,129 +1107,122 @@ public class SerialWANPropogationDUnitTest extends WANTestBase {
}
// verify that all is well in local site
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 8000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 8000 ));
- vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmpty",
- new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmpty( "ln" ));
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createPersistentReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createPersistentReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
- vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln",
- 0 });
+ vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
+ 0 ));
- vm3.invoke(WANTestBase.class, "checkMinimumGatewayReceiverStats",
- new Object[] { 1, 1 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 8000 });
+ vm3.invoke(() -> WANTestBase.checkMinimumGatewayReceiverStats( 1, 1 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 8000 ));
}
public void testReplicatedSerialPropagationToTwoWanSites() throws Exception {
Integer lnPort = createFirstLocatorWithDSId(1);
- Integer nyPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
- Integer tkPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 3, lnPort });
-
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { tkPort });
-
- vm4.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
-
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "lnSerial1",
- 2, false, 100, 10, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "lnSerial1",
- 2, false, 100, 10, false, false, null, true });
-
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "lnSerial2",
- 3, false, 100, 10, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "lnSerial2",
- 3, false, 100, 10, false, false, null, true });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
-
<TRUNCATED>