http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java ---------------------------------------------------------------------- diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java index 1ed4d1b..ed48b15 100644 --- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java +++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_1_DUnitTest.java @@ -42,111 +42,107 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes } public void testParallelGatewaySenderWithoutStarting() { - 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, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 6, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 6, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 6, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 6, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); - - vm4.invoke(WANTestBase.class, "verifySenderStoppedState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "verifySenderStoppedState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "verifySenderStoppedState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "verifySenderStoppedState", new Object[] { "ln" }); - - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {getTestMethodName() + "_PR", 0 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {getTestMethodName() + "_PR", 0 }); + 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.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 6, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 6, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 6, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 6, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); + + vm4.invoke(() -> WANTestBase.verifySenderStoppedState( "ln" )); + vm5.invoke(() -> WANTestBase.verifySenderStoppedState( "ln" )); + vm6.invoke(() -> WANTestBase.verifySenderStoppedState( "ln" )); + vm7.invoke(() -> WANTestBase.verifySenderStoppedState( "ln" )); + + vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_PR", 0 )); + vm3.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_PR", 0 )); } /** * Defect 44323 (ParallelGatewaySender should not be started on Accessor node) */ public void testParallelGatewaySenderStartOnAccessorNode() { - 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, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegionAsAccessor", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100 }); - vm7.invoke(WANTestBase.class, "createPartitionedRegionAsAccessor", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100 }); - - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, 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.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegionAsAccessor( + getTestMethodName() + "_PR", "ln", 1, 100 )); + vm7.invoke(() -> WANTestBase.createPartitionedRegionAsAccessor( + getTestMethodName() + "_PR", "ln", 1, 100 )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); //start the senders - 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.pause(2000); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); - vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm5.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); + vm4.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm5.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {getTestMethodName() + "_PR", 1000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {getTestMethodName() + "_PR", 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_PR", 1000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_PR", 1000 )); } @@ -155,67 +151,65 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes * @throws Exception */ public void testParallelPropagationSenderPause() 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, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "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, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, 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.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); //make sure all the senders are running before doing any puts - 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" )); //FIRST RUN: now, the senders are started. So, start the puts - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 100 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 100 )); //now, pause all of 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" )); Wait.pause(2000); //SECOND RUN: keep one thread doing puts to the region - vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); //verify region size remains on remote vm and is restricted below a specified limit (i.e. number of puts in the first run) - vm2.invoke(WANTestBase.class, "validateRegionSizeRemainsSame", new Object[] {getTestMethodName() + "_PR", 100 }); + vm2.invoke(() -> WANTestBase.validateRegionSizeRemainsSame(getTestMethodName() + "_PR", 100 )); } /** @@ -223,80 +217,78 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes * @throws Exception */ public void testParallelPropagationSenderResume() 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, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 8, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 8, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 8, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 8, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "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, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, 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.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 8, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 8, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 8, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 8, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); //make sure all the senders are running before doing any puts - 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" )); //now, the senders are started. So, start the puts - vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); //now, pause all of 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" )); //sleep for a second or two Wait.pause(2000); //resume the senders - 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" )); Wait.pause(2000); - vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm5.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm6.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); + vm4.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm5.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm6.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm7.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); //find the region size on remote vm - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {getTestMethodName() + "_PR", 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_PR", 1000 )); } @@ -308,59 +300,57 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes * @throws Exception */ public void testParallelPropagationSenderResumeNegativeScenario() 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 }); - - vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, 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 )); + + vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, 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" )); //wait till the senders are running - 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" )); //start the puts - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 100 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 100 )); //let the queue drain completely - vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln", 0 }); + vm4.invoke(() -> WANTestBase.validateQueueContents( "ln", 0 )); //stop the senders - vm4.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.stopSender( "ln" )); + vm5.invoke(() -> WANTestBase.stopSender( "ln" )); //now, try to resume a stopped sender - vm4.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.resumeSender( "ln" )); + vm5.invoke(() -> WANTestBase.resumeSender( "ln" )); //do more puts - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); //validate region size on remote vm to contain only the events put in local site //before the senders are stopped. - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {getTestMethodName() + "_PR", 100 }); + vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_PR", 100 )); } /** @@ -368,142 +358,138 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes * @throws Exception */ public void testParallelPropagationSenderStop() 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, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 3, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 3, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 3, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 3, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "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, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, 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.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 3, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 3, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 3, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 3, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); //make sure all the senders are running before doing any puts - 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" )); //FIRST RUN: now, the senders are started. So, do some of the puts - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 100 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 100 )); //now, stop all of the senders - vm4.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.stopSender( "ln" )); + vm5.invoke(() -> WANTestBase.stopSender( "ln" )); + vm6.invoke(() -> WANTestBase.stopSender( "ln" )); + vm7.invoke(() -> WANTestBase.stopSender( "ln" )); //SECOND RUN: keep one thread doing puts - vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); //verify region size remains on remote vm and is restricted below a specified limit (number of puts in the first run) - vm2.invoke(WANTestBase.class, "validateRegionSizeRemainsSame", new Object[] {getTestMethodName() + "_PR", 100 }); + vm2.invoke(() -> WANTestBase.validateRegionSizeRemainsSame(getTestMethodName() + "_PR", 100 )); } /** * Normal scenario in which a sender is stopped and then started again. */ public void testParallelPropagationSenderStartAfterStop() throws Throwable { - 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, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "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, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, 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.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); //make sure all the senders are running before doing any puts - 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" )); //FIRST RUN: now, the senders are started. So, do some of the puts - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 200 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 200 )); //now, stop all of the senders - vm4.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.stopSender( "ln" )); + vm5.invoke(() -> WANTestBase.stopSender( "ln" )); + vm6.invoke(() -> WANTestBase.stopSender( "ln" )); + vm7.invoke(() -> WANTestBase.stopSender( "ln" )); Wait.pause(2000); //SECOND RUN: do some of the puts after the senders are stopped - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); //Region size on remote site should remain same and below the number of puts done in the FIRST RUN - vm2.invoke(WANTestBase.class, "validateRegionSizeRemainsSame", new Object[] {getTestMethodName() + "_PR", 200 }); + vm2.invoke(() -> WANTestBase.validateRegionSizeRemainsSame(getTestMethodName() + "_PR", 200 )); //start the senders again - AsyncInvocation vm4start = vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - AsyncInvocation vm5start = vm5.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - AsyncInvocation vm6start = vm6.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - AsyncInvocation vm7start = vm7.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); + AsyncInvocation vm4start = vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); + AsyncInvocation vm5start = vm5.invokeAsync(() -> WANTestBase.startSender( "ln" )); + AsyncInvocation vm6start = vm6.invokeAsync(() -> WANTestBase.startSender( "ln" )); + AsyncInvocation vm7start = vm7.invokeAsync(() -> WANTestBase.startSender( "ln" )); int START_TIMEOUT = 30000; vm4start.getResult(START_TIMEOUT); vm5start.getResult(START_TIMEOUT); @@ -511,25 +497,25 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes vm7start.getResult(START_TIMEOUT); //Region size on remote site should remain same and below the number of puts done in the FIRST RUN - vm2.invoke(WANTestBase.class, "validateRegionSizeRemainsSame", new Object[] {getTestMethodName() + "_PR", 200 }); + vm2.invoke(() -> WANTestBase.validateRegionSizeRemainsSame(getTestMethodName() + "_PR", 200 )); //SECOND RUN: do some more puts - AsyncInvocation async = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + AsyncInvocation async = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); async.join(); //verify all the buckets on all the sender nodes are drained - vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm5.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm6.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); + vm4.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm5.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm6.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm7.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); //verify the events propagate to remote site - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {getTestMethodName() + "_PR", 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_PR", 1000 )); - vm4.invoke(WANTestBase.class, "validateQueueSizeStat", new Object[] { "ln", 0 }); - vm5.invoke(WANTestBase.class, "validateQueueSizeStat", new Object[] { "ln", 0 }); - vm6.invoke(WANTestBase.class, "validateQueueSizeStat", new Object[] { "ln", 0 }); - vm7.invoke(WANTestBase.class, "validateQueueSizeStat", new Object[] { "ln", 0 }); + vm4.invoke(() -> WANTestBase.validateQueueSizeStat( "ln", 0 )); + vm5.invoke(() -> WANTestBase.validateQueueSizeStat( "ln", 0 )); + vm6.invoke(() -> WANTestBase.validateQueueSizeStat( "ln", 0 )); + vm7.invoke(() -> WANTestBase.validateQueueSizeStat( "ln", 0 )); } /** @@ -539,86 +525,84 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes * @throws Exception */ public void Bug47553_testParallelPropagationSenderStartAfterStop_Scenario2() 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, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "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, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, 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.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 7, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); //make sure all the senders are running before doing any puts - 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 started"); //FIRST RUN: now, the senders are started. So, do some of the puts - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 200 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 200 )); LogWriterUtils.getLogWriter().info("Done few puts"); //now, stop all of the senders - vm4.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.stopSender( "ln" )); + vm5.invoke(() -> WANTestBase.stopSender( "ln" )); + vm6.invoke(() -> WANTestBase.stopSender( "ln" )); + vm7.invoke(() -> WANTestBase.stopSender( "ln" )); LogWriterUtils.getLogWriter().info("All the senders are stopped"); Wait.pause(2000); //SECOND RUN: do some of the puts after the senders are stopped - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); LogWriterUtils.getLogWriter().info("Done some more puts in second run"); //Region size on remote site should remain same and below the number of puts done in the FIRST RUN - vm2.invoke(WANTestBase.class, "validateRegionSizeRemainsSame", new Object[] {getTestMethodName() + "_PR", 200 }); + vm2.invoke(() -> WANTestBase.validateRegionSizeRemainsSame(getTestMethodName() + "_PR", 200 )); //SECOND RUN: start async puts on region - AsyncInvocation async = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 5000 }); + AsyncInvocation async = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 5000 )); LogWriterUtils.getLogWriter().info("Started high number of puts by async thread"); LogWriterUtils.getLogWriter().info("Starting the senders at the same time"); //when puts are happening by another thread, start the senders - 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("All the senders are started"); @@ -627,13 +611,13 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes Wait.pause(2000); //verify all the buckets on all the sender nodes are drained - vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm5.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm6.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); + vm4.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm5.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm6.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm7.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); //verify that the queue size ultimately becomes zero. That means all the events propagate to remote site. - vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln", 0 }); + vm4.invoke(() -> WANTestBase.validateQueueContents( "ln", 0 )); } /** @@ -641,76 +625,74 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes * @throws Exception */ public void testParallelPropagationSenderStartAfterStopOnAccessorNode() throws Throwable { - 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, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegionAsAccessor", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100}); - vm7.invoke(WANTestBase.class, "createPartitionedRegionAsAccessor", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100}); - - 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, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, 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.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegionAsAccessor( + getTestMethodName() + "_PR", "ln", 1, 100)); + vm7.invoke(() -> WANTestBase.createPartitionedRegionAsAccessor( + getTestMethodName() + "_PR", "ln", 1, 100)); + + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); + + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); //make sure all the senders are not running on accessor nodes and running on non-accessor nodes - 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" )); - vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm6.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); + vm7.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); //FIRST RUN: now, the senders are started. So, do some of the puts - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 200 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 200 )); //now, stop all of the senders - vm4.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "stopSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.stopSender( "ln" )); + vm5.invoke(() -> WANTestBase.stopSender( "ln" )); + vm6.invoke(() -> WANTestBase.stopSender( "ln" )); + vm7.invoke(() -> WANTestBase.stopSender( "ln" )); Wait.pause(2000); //SECOND RUN: do some of the puts after the senders are stopped - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); //Region size on remote site should remain same and below the number of puts done in the FIRST RUN - vm2.invoke(WANTestBase.class, "validateRegionSizeRemainsSame", new Object[] {getTestMethodName() + "_PR", 200 }); + vm2.invoke(() -> WANTestBase.validateRegionSizeRemainsSame(getTestMethodName() + "_PR", 200 )); //start the senders again - AsyncInvocation vm4start = vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - AsyncInvocation vm5start = vm5.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - AsyncInvocation vm6start = vm6.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - AsyncInvocation vm7start = vm7.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); + AsyncInvocation vm4start = vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); + AsyncInvocation vm5start = vm5.invokeAsync(() -> WANTestBase.startSender( "ln" )); + AsyncInvocation vm6start = vm6.invokeAsync(() -> WANTestBase.startSender( "ln" )); + AsyncInvocation vm7start = vm7.invokeAsync(() -> WANTestBase.startSender( "ln" )); int START_TIMEOUT = 30000; vm4start.getResult(START_TIMEOUT); vm5start.getResult(START_TIMEOUT); @@ -718,19 +700,19 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes vm7start.getResult(START_TIMEOUT); //Region size on remote site should remain same and below the number of puts done in the FIRST RUN - vm2.invoke(WANTestBase.class, "validateRegionSizeRemainsSame", new Object[] {getTestMethodName() + "_PR", 200 }); + vm2.invoke(() -> WANTestBase.validateRegionSizeRemainsSame(getTestMethodName() + "_PR", 200 )); //SECOND RUN: do some more puts - AsyncInvocation async = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + AsyncInvocation async = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); async.join(); Wait.pause(5000); //verify all buckets drained only on non-accessor nodes. - vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm5.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); + vm4.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm5.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); //verify the events propagate to remote site - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {getTestMethodName() + "_PR", 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_PR", 1000 )); } @@ -739,96 +721,93 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes * is tested */ public void testStartPauseResumeParallelGatewaySender() 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 )); - 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 )); - 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 cache on local site"); - vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); - vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); - vm6.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); - vm7.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); + vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); + vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); + vm6.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); + vm7.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); LogWriterUtils.getLogWriter().info("Created senders on local site"); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() )); LogWriterUtils.getLogWriter().info("Created PRs on local site"); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); LogWriterUtils.getLogWriter().info("Created PRs on remote site"); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); LogWriterUtils.getLogWriter().info("Done 1000 puts on local site"); //Since puts are already done on userPR, it will have the buckets created. //During sender start, it will wait until those buckets are created for shadowPR as well. //Start the senders in async threads, so colocation of shadowPR will be complete and //missing buckets will be created in PRHARedundancyProvider.createMissingBuckets(). - 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" )); - 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("Started senders on local site"); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 5000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 5000 )); LogWriterUtils.getLogWriter().info("Done 5000 puts on local site"); - 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" )); LogWriterUtils.getLogWriter().info("Paused senders on local site"); - vm4.invoke(WANTestBase.class, "verifySenderPausedState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "verifySenderPausedState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "verifySenderPausedState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "verifySenderPausedState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.verifySenderPausedState( "ln" )); + vm5.invoke(() -> WANTestBase.verifySenderPausedState( "ln" )); + vm6.invoke(() -> WANTestBase.verifySenderPausedState( "ln" )); + vm7.invoke(() -> WANTestBase.verifySenderPausedState( "ln" )); - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", - new Object[] { getTestMethodName() + "_PR", 1000 }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 )); LogWriterUtils.getLogWriter().info("Started 1000 async puts on local site"); - 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("Resumed senders on local site"); - vm4.invoke(WANTestBase.class, "verifySenderResumedState", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "verifySenderResumedState", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "verifySenderResumedState", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "verifySenderResumedState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.verifySenderResumedState( "ln" )); + vm5.invoke(() -> WANTestBase.verifySenderResumedState( "ln" )); + vm6.invoke(() -> WANTestBase.verifySenderResumedState( "ln" )); + vm7.invoke(() -> WANTestBase.verifySenderResumedState( "ln" )); try { inv1.join(); @@ -838,14 +817,14 @@ public class ConcurrentParallelGatewaySenderOperation_1_DUnitTest extends WANTes } //verify all buckets drained on all sender nodes. - vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm5.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm6.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"}); - - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName() + "_PR", 5000 }); - vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName() + "_PR", 5000 }); + vm4.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm5.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm6.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + vm7.invoke(() -> WANTestBase.validateParallelSenderQueueAllBucketsDrained("ln")); + + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName() + "_PR", 5000 )); + vm3.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName() + "_PR", 5000 )); } }
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_2_DUnitTest.java ---------------------------------------------------------------------- diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_2_DUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_2_DUnitTest.java index 4e74822..a387e29 100644 --- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_2_DUnitTest.java +++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderOperation_2_DUnitTest.java @@ -125,8 +125,7 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes vm4.invoke(() -> resumeSender("ln")); - AsyncInvocation putAsync = vm4.invokeAsync(WANTestBase.class, - "doPutsFrom", new Object[] { getTestMethodName() + "_PR", 10, 101 }); + AsyncInvocation putAsync = vm4.invokeAsync(() -> WANTestBase.doPutsFrom( getTestMethodName() + "_PR", 10, 101 )); try { putAsync.join(); } catch (InterruptedException e) { @@ -172,16 +171,14 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes createReceiverAndDoPutsInPausedSender(nyPort); - vm4.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "resumeSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.resumeSender( "ln" )); + vm5.invoke(() -> WANTestBase.resumeSender( "ln" )); + vm6.invoke(() -> WANTestBase.resumeSender( "ln" )); Wait.pause(200); - AsyncInvocation localDestroyAsync = vm4.invokeAsync(WANTestBase.class, - "destroyRegion", new Object[] { getTestMethodName() + "_PR" }); + AsyncInvocation localDestroyAsync = vm4.invokeAsync(() -> WANTestBase.destroyRegion( getTestMethodName() + "_PR" )); - AsyncInvocation closeAsync = vm4.invokeAsync(WANTestBase.class, - "closeCache"); + AsyncInvocation closeAsync = vm4.invokeAsync(() -> WANTestBase.closeCache()); try { localDestroyAsync.join(); closeAsync.join(); @@ -209,11 +206,8 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes createReceiverAndDoPutsInPausedSender(nyPort); - AsyncInvocation putAsync = vm4.invokeAsync(WANTestBase.class, - "doPutsFrom", new Object[] { getTestMethodName() + "_PR", 10, 2000 }); - AsyncInvocation localDestroyAsync = vm4.invokeAsync( - ConcurrentParallelGatewaySenderOperation_2_DUnitTest.class, - "closeRegion", new Object[] { getTestMethodName() + "_PR" }); + AsyncInvocation putAsync = vm4.invokeAsync(() -> WANTestBase.doPutsFrom( getTestMethodName() + "_PR", 10, 2000 )); + AsyncInvocation localDestroyAsync = vm4.invokeAsync(() -> ConcurrentParallelGatewaySenderOperation_2_DUnitTest.closeRegion( getTestMethodName() + "_PR" )); try { putAsync.join(); localDestroyAsync.join(); @@ -295,8 +289,7 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes String regionName = getTestMethodName() + "_PR"; vm2.invoke(() -> createPartitionedRegion(regionName, null, 1, 10, isOffHeap())); - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", - new Object[] { regionName, 10 }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( regionName, 10 )); Wait.pause(1000); vm5.invoke(() -> localDestroyRegion(regionName)); @@ -335,17 +328,15 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes createAndStartTwoSenders(vm5, lnPort, 4); String regionName = getTestMethodName() + "_PR"; - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - regionName, null, 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - regionName, null, 1, 100, isOffHeap() }); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + regionName, null, 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + regionName, null, 1, 100, isOffHeap() )); - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", - new Object[] { regionName, 10 }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( regionName, 10 )); Wait.pause(1000); - vm5.invoke(WANTestBase.class, "localDestroyRegion", - new Object[] { regionName }); + vm5.invoke(() -> WANTestBase.localDestroyRegion( regionName )); try { inv1.join(); @@ -356,11 +347,11 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes validateRegionSizes(regionName, 10, vm4, vm6, vm7); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - regionName, "ln1,ln2", 1, 100, isOffHeap() }); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + regionName, "ln1,ln2", 1, 100, isOffHeap() )); - vm4.invoke(WANTestBase.class, "doPutsFrom", new Object[] { - regionName, 10, 20 }); + vm4.invoke(() -> WANTestBase.doPutsFrom( + regionName, 10, 20 )); validateRegionSizes(regionName, 20, vm4, vm6, vm7); } finally { @@ -384,8 +375,7 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes vm2.invoke(() -> createCustomerOrderShipmentPartitionedRegion(null, null, 1, 100, isOffHeap())); - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, - "putcolocatedPartitionedRegion", new Object[] { 10 }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.putcolocatedPartitionedRegion( 10 )); Wait.pause(1000); try { @@ -412,7 +402,7 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes Integer lnPort = locatorPorts[0]; Integer nyPort = locatorPorts[1]; - vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver( nyPort )); try { createAndStartSenderWithCustomerOrderShipmentRegion(vm4, lnPort, 6, true); @@ -420,17 +410,14 @@ public class ConcurrentParallelGatewaySenderOperation_2_DUnitTest extends WANTes LogWriterUtils.getLogWriter().info("Created PRs on local site"); - vm2.invoke(WANTestBase.class, - "createCustomerOrderShipmentPartitionedRegion", new Object[] { null, - null, 1, 100, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createCustomerOrderShipmentPartitionedRegion( null, + null, 1, 100, isOffHeap() )); - AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, - "putcolocatedPartitionedRegion", new Object[] { 2000 }); + AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.putcolocatedPartitionedRegion( 2000 )); Wait.pause(1000); try { - vm5.invoke(WANTestBase.class, "destroyRegion", - new Object[] { customerRegionName }); + vm5.invoke(() -> WANTestBase.destroyRegion( customerRegionName )); } catch (Exception ex) { assertTrue(ex.getCause() instanceof IllegalStateException); return;
