http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java ---------------------------------------------------------------------- diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java index 01f665c..e52486f 100644 --- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java +++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java @@ -47,10 +47,8 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends public void testPartitionedRegionWithGatewaySenderPersistenceEnabled() throws IOException { try { - 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 )); createCache(lnPort); GatewaySenderFactory fact = cache.createGatewaySenderFactory(); fact.setPersistenceEnabled(true); @@ -83,53 +81,51 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends * site receives all the events. */ public void testPersistentPartitionedRegionWithGatewaySenderPersistenceEnabled() { - 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, - true, 100, 10, false, true, null, true }); - vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, true, null, true }); - vm6.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, true, null, true }); - vm7.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, true, null, true }); - - vm4.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - - vm2.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 }); - - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 1000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 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, + true, 100, 10, false, true, null, true )); + vm5.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, true, null, true )); + vm6.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, true, null, true )); + vm7.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, true, null, true )); + + vm4.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); + + vm2.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 )); + + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 1000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 1000 )); } @@ -137,64 +133,62 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends * Enable persistence for the GatewaySender but not the region */ public void testPartitionedRegionWithPersistentGatewaySender() { - 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 )); - 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 )); LogWriterUtils.getLogWriter().info("Created remote receivers"); - 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 )); LogWriterUtils.getLogWriter().info("Created local site cache"); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, true, null, true }); - vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, true, null, true }); - vm6.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, true, null, true }); - vm7.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, true, null, true }); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, true, null, true )); + vm5.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, true, null, true )); + vm6.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, true, null, true )); + vm7.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, true, null, true )); LogWriterUtils.getLogWriter().info("Created local site senders"); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); LogWriterUtils.getLogWriter().info("Created local site persistent PR"); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Started sender on vm4"); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Started the senders"); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 )); - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 1000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 1000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 1000 )); } @@ -208,109 +202,99 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends */ public void testPRWithGatewaySenderPersistenceEnabled_Restart() { //create locator on local site - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); //create locator on remote site - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); //create receiver on 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 )); //create cache in 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 )); //create senders with disk store - String diskStore1 = (String) vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore2 = (String) vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore3 = (String) vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore4 = (String) vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); + String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore2 = (String) vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore3 = (String) vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore4 = (String) vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); LogWriterUtils.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4); //create PR on remote site - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); //create PR on local site - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); //start the senders on local site - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); //wait for senders to become running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); //pause the senders - vm4.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm5.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm6.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm7.invoke(() -> WANTestBase.pauseSender( "ln" )); //start puts in region on local site - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 3000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 3000 )); LogWriterUtils.getLogWriter().info("Completed puts in the region"); //--------------------close and rebuild local site ------------------------------------------------- //kill the senders - 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()); LogWriterUtils.getLogWriter().info("Killed all the senders."); //restart the vm - 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 )); LogWriterUtils.getLogWriter().info("Created back the cache"); //create senders with disk store - vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore1, true }); - vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore2, true }); - vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore3, true }); - vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore4, true }); + vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore1, true )); + vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore2, true )); + vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore3, true )); + vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore4, true )); LogWriterUtils.getLogWriter().info("Created the senders back from the disk store."); //create PR on local site - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv2 = vm5.invokeAsync(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv3 = vm6.invokeAsync(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv4 = vm7.invokeAsync(() -> WANTestBase.createPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); try { inv1.join(); @@ -326,26 +310,26 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends //start the senders in async mode. This will ensure that the //node of shadow PR that went down last will come up first - vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm5.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm6.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm7.invokeAsync(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Waiting for senders running."); //wait for senders running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); LogWriterUtils.getLogWriter().info("All the senders are now running..."); //---------------------------------------------------------------------------------------------------- - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 3000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 3000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 3000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 3000 )); } /** @@ -357,109 +341,99 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends */ public void testPersistentPRWithGatewaySenderPersistenceEnabled_Restart() { //create locator on local site - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); //create locator on remote site - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); //create receiver on 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 )); //create cache in 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 )); //create senders with disk store - String diskStore1 = (String) vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore2 = (String) vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore3 = (String) vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore4 = (String) vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); + String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore2 = (String) vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore3 = (String) vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore4 = (String) vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); LogWriterUtils.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4); //create PR on remote site - vm2.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); //create PR on local site - vm4.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); //start the senders on local site - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); //wait for senders to become running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); //pause the senders - vm4.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm5.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm6.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm7.invoke(() -> WANTestBase.pauseSender( "ln" )); //start puts in region on local site - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 3000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 3000 )); LogWriterUtils.getLogWriter().info("Completed puts in the region"); //--------------------close and rebuild local site ------------------------------------------------- //kill the senders - 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()); LogWriterUtils.getLogWriter().info("Killed all the senders."); //restart the vm - 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 )); LogWriterUtils.getLogWriter().info("Created back the cache"); //create senders with disk store - vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore1, true }); - vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore2, true }); - vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore3, true }); - vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore4, true }); + vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore1, true )); + vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore2, true )); + vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore3, true )); + vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore4, true )); LogWriterUtils.getLogWriter().info("Created the senders back from the disk store."); //create PR on local site - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv2 = vm5.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv3 = vm6.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv4 = vm7.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); try { inv1.join(); @@ -475,26 +449,26 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends //start the senders in async mode. This will ensure that the //node of shadow PR that went down last will come up first - vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm5.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm6.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm7.invokeAsync(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Waiting for senders running."); //wait for senders running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); LogWriterUtils.getLogWriter().info("All the senders are now running..."); //---------------------------------------------------------------------------------------------------- - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 3000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 3000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 3000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 3000 )); } /** @@ -506,100 +480,90 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends */ public void testPersistentPRWithGatewaySenderPersistenceEnabled_Restart2() { //create locator on local site - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); //create locator on remote site - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); //create cache in 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 )); //create senders with disk store - String diskStore1 = (String) vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, false }); - String diskStore2 = (String) vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, false }); - String diskStore3 = (String) vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, false }); - String diskStore4 = (String) vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, false }); + String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, false )); + String diskStore2 = (String) vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, false )); + String diskStore3 = (String) vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, false )); + String diskStore4 = (String) vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, false )); LogWriterUtils.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4); //create PR on local site - vm4.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); //start the senders on local site - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); //wait for senders to become running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); //pause the senders - vm4.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm5.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm6.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm7.invoke(() -> WANTestBase.pauseSender( "ln" )); //start puts in region on local site - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 300 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 300 )); LogWriterUtils.getLogWriter().info("Completed puts in the region"); //--------------------close and rebuild local site ------------------------------------------------- //kill the senders - 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()); LogWriterUtils.getLogWriter().info("Killed all the senders."); //restart the vm - 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 )); LogWriterUtils.getLogWriter().info("Created back the cache"); //create senders with disk store - vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore1, true }); - vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore2, true }); - vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore3, true }); - vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore4, true }); + vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore1, true )); + vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore2, true )); + vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore3, true )); + vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore4, true )); LogWriterUtils.getLogWriter().info("Created the senders back from the disk store."); //create PR on local site - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv2 = vm5.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv3 = vm6.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv4 = vm7.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); try { inv1.join(); @@ -613,56 +577,56 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends LogWriterUtils.getLogWriter().info("Created back the partitioned regions"); - vm4.invoke(WANTestBase.class, "unsetRemoveFromQueueOnException", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "unsetRemoveFromQueueOnException", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "unsetRemoveFromQueueOnException", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "unsetRemoveFromQueueOnException", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.unsetRemoveFromQueueOnException( "ln" )); + vm5.invoke(() -> WANTestBase.unsetRemoveFromQueueOnException( "ln" )); + vm6.invoke(() -> WANTestBase.unsetRemoveFromQueueOnException( "ln" )); + vm7.invoke(() -> WANTestBase.unsetRemoveFromQueueOnException( "ln" )); //start the senders in async mode. This will ensure that the //node of shadow PR that went down last will come up first - vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm5.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm6.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm7.invokeAsync(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Waiting for senders running."); //wait for senders running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); LogWriterUtils.getLogWriter().info("Creating the receiver."); //create receiver on 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 )); //create PR on remote site LogWriterUtils.getLogWriter().info("Creating the partitioned region at receiver. "); - vm2.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm4.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); + vm2.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm4.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm5.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm6.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm7.invoke(() -> WANTestBase.pauseSender( "ln" )); LogWriterUtils.getLogWriter().info("Doing some extra puts. "); //start puts in region on local site - vm4.invoke(WANTestBase.class, "doPutsAfter300", new Object[] { getTestMethodName(), 1000 }); + vm4.invoke(() -> WANTestBase.doPutsAfter300( getTestMethodName(), 1000 )); //---------------------------------------------------------------------------------------------------- - vm4.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.resumeSender( "ln" )); + vm5.invoke(() -> WANTestBase.resumeSender( "ln" )); + vm6.invoke(() -> WANTestBase.resumeSender( "ln" )); + vm7.invoke(() -> WANTestBase.resumeSender( "ln" )); LogWriterUtils.getLogWriter().info("Validating the region size at the receiver end. "); - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 1000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 1000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 1000 )); } @@ -676,110 +640,100 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends */ public void testPersistentPRWithGatewaySenderPersistenceEnabled_Restart_Scenario2() { //create locator on local site - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); //create locator on remote site - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); //create receiver on 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 )); //create cache in 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 )); //create senders with disk store - String diskStore1 = (String) vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore2 = (String) vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore3 = (String) vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore4 = (String) vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); + String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore2 = (String) vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore3 = (String) vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore4 = (String) vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); LogWriterUtils.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4); //create PR on remote site - vm2.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); //create PR on local site - vm4.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); //start the senders on local site - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); //wait for senders to become running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); //pause the senders - vm4.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm5.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm6.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm7.invoke(() -> WANTestBase.pauseSender( "ln" )); //start puts in region on local site - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 3000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 3000 )); LogWriterUtils.getLogWriter().info("Completed puts in the region"); //--------------------close and rebuild local site ------------------------------------------------- //kill the senders - 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()); LogWriterUtils.getLogWriter().info("Killed all the senders."); //restart the vm - 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 )); LogWriterUtils.getLogWriter().info("Created back the cache"); //create senders with disk store - vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore1, true }); - vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore2, true }); - vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore3, true }); - vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore4, true }); + vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore1, true )); + vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore2, true )); + vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore3, true )); + vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore4, true )); LogWriterUtils.getLogWriter().info("Created the senders back from the disk store."); //create PR on local site - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv2 = vm5.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv3 = vm6.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv4 = vm7.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); try { inv1.join(); @@ -795,34 +749,34 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends //start the senders in async mode. This will ensure that the //node of shadow PR that went down last will come up first - vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm5.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm6.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm7.invokeAsync(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Waiting for senders running."); //wait for senders running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); LogWriterUtils.getLogWriter().info("All the senders are now running..."); //---------------------------------------------------------------------------------------------------- //Dispatcher should be dispatching now. Do some more puts through async thread - AsyncInvocation async1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 }); + AsyncInvocation async1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName(), 1000 )); try { async1.join(); } catch (InterruptedException e) { e.printStackTrace(); } - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 3000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 3000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 3000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 3000 )); } /** @@ -834,110 +788,100 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends */ public void testPersistentPRWithPersistentGatewaySender_Restart_Bug44275() { //create locator on local site - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); //create locator on remote site - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); //create receiver on 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 )); //create cache in 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 )); //create senders with disk store - String diskStore1 = (String) vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore2 = (String) vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore3 = (String) vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore4 = (String) vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); + String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore2 = (String) vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore3 = (String) vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore4 = (String) vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); LogWriterUtils.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4); //create PR on remote site - vm2.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); //create PR on local site - vm4.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); //start the senders on local site - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); //wait for senders to become running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); //pause the senders - vm4.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm5.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm6.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm7.invoke(() -> WANTestBase.pauseSender( "ln" )); //start puts in region on local site - vm4.invoke(WANTestBase.class, "doPutsWithKeyAsString", new Object[] { getTestMethodName(), 1000 }); + vm4.invoke(() -> WANTestBase.doPutsWithKeyAsString( getTestMethodName(), 1000 )); LogWriterUtils.getLogWriter().info("Completed puts in the region"); //--------------------close and rebuild local site ------------------------------------------------- //kill the senders - 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()); LogWriterUtils.getLogWriter().info("Killed all the senders."); //restart the vm - 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 )); LogWriterUtils.getLogWriter().info("Created back the cache"); //create senders with disk store - vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore1, true }); - vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore2, true }); - vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore3, true }); - vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore4, true }); + vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore1, true )); + vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore2, true )); + vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore3, true )); + vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore4, true )); LogWriterUtils.getLogWriter().info("Created the senders back from the disk store."); //create PR on local site - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv2 = vm5.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv3 = vm6.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + AsyncInvocation inv4 = vm7.invokeAsync(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); try { inv1.join(); @@ -953,26 +897,26 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends //start the senders in async mode. This will ensure that the //node of shadow PR that went down last will come up first - vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm5.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm6.invokeAsync(() -> WANTestBase.startSender( "ln" )); + vm7.invokeAsync(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Waiting for senders running."); //wait for senders running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); LogWriterUtils.getLogWriter().info("All the senders are now running..."); //---------------------------------------------------------------------------------------------------- - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 1000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName(), 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 1000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName(), 1000 )); } /** @@ -984,197 +928,178 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends */ public void testPersistentPRWithPersistentGatewaySender_Restart_DoOps() { //create locator on local site - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); //create locator on remote site - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); //create receiver on 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 )); //create cache in 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 )); //create senders with disk store - String diskStore1 = (String) vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore2 = (String) vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore3 = (String) vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); - String diskStore4 = (String) vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, null, true }); + String diskStore1 = (String) vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore2 = (String) vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore3 = (String) vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); + String diskStore4 = (String) vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, null, true )); LogWriterUtils.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4); //create PR on remote site - vm2.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), null, 1, 100, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), null, 1, 100, isOffHeap() )); //create PR on local site - vm4.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPersistentPartitionedRegion", new Object[] { - getTestMethodName(), "ln", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPersistentPartitionedRegion( + getTestMethodName(), "ln", 1, 100, isOffHeap() )); //start the senders on local site - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); //wait for senders to become running - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); //pause the senders - vm4.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm5.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm6.invoke(() -> WANTestBase.pauseSender( "ln" )); + vm7.invoke(() -> WANTestBase.pauseSender( "ln" )); //start puts in region on local site - vm4.invoke(WANTestBase.class, "doPutsWithKeyAsString", new Object[] { getTestMethodName(), 1000 }); + vm4.invoke(() -> WANTestBase.doPutsWithKeyAsString( getTestMethodName(), 1000 )); LogWriterUtils.getLogWriter().info("Completed puts in the region"); //--------------------close and rebuild local site ------------------------------------------------- //kill the senders - 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()); LogWriterUtils.getLogWriter().info("Killed all the senders."); //restart the vm - 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 )); LogWriterUtils.getLogWriter().info("Created back the cache"); //create senders with disk store - vm4.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore1, true }); - vm5.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore2, true }); - vm6.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore3, true }); - vm7.invoke(WANTestBase.class, "createSenderWithDiskStore", - new Object[] { "ln", 2, true, 100, 10, false, true, null, diskStore4, true }); + vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore1, true )); + vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore2, true )); + vm6.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore3, true )); + vm7.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, true, 100, 10, false, true, null, diskStore4, true )); LogWriterUtils.getLogWriter().info("Created the senders back from the disk store."); // create PR on local site - vm4.invoke(WANTestBase.class, "createPersistentPartitionedRegion", - new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPersistentPartitionedRegion", - new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPersistentPartitionedRegion", - new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap
<TRUNCATED>