You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by up...@apache.org on 2016/02/16 23:11:40 UTC
[20/56] [abbrv] incubator-geode git commit: Automatically converting
calls of vm.invoke to lambdas
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java
index c6123be..000ddf0 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java
@@ -49,106 +49,100 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
* @throws Exception
*/
public void testReplicatedSerialPropagation_withoutRemoteSite() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
- vm4.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
+ vm4.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache(lnPort ));
//keep the batch size high enough to reduce the number of exceptions in the log
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 400, false, false, null, true, 4, OrderPolicy.KEY });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 400, false, false, null, true, 4, OrderPolicy.KEY });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 400, false, false, null, true, 4, OrderPolicy.KEY ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 400, false, false, null, true, 4, OrderPolicy.KEY ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
- vm2.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createCache( nyPort ));
+ vm3.invoke(() -> WANTestBase.createCache( nyPort ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm2.invoke(WANTestBase.class, "createReceiver2",
- new Object[] {nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver2",
- new Object[] {nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver2(nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver2(nyPort ));
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
public void testReplicatedSerialPropagation() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
-
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
-
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
-
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
+
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
@@ -156,95 +150,93 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
IgnoredException.addIgnoredException("Broken pipe");
IgnoredException.addIgnoredException("Connection reset");
IgnoredException.addIgnoredException("Unexpected IOException");
- 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,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
+
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
+
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
//---------close local site and build again-----------------------------------------
- vm4.invoke(WANTestBase.class, "killSender", new Object[] { });
- vm5.invoke(WANTestBase.class, "killSender", new Object[] { });
- vm6.invoke(WANTestBase.class, "killSender", new Object[] { });
- vm7.invoke(WANTestBase.class, "killSender", new Object[] { });
+ vm4.invoke(() -> WANTestBase.killSender( ));
+ vm5.invoke(() -> WANTestBase.killSender( ));
+ vm6.invoke(() -> WANTestBase.killSender( ));
+ vm7.invoke(() -> WANTestBase.killSender( ));
Integer regionSize =
- (Integer) vm2.invoke(WANTestBase.class, "getRegionSize", new Object[] {getTestMethodName() + "_RR" });
+ (Integer) vm2.invoke(() -> WANTestBase.getRegionSize(getTestMethodName() + "_RR" ));
LogWriterUtils.getLogWriter().info("Region size on remote is: " + regionSize);
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
-
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
+ 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,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] { "ln", true });
- vm5.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] { "ln", true });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
+ vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
+ vm5.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" ));
IgnoredException.addIgnoredException(EntryExistsException.class.getName());
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
//----------------------------------------------------------------------------------
//verify remote site receives all the events
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
/**
@@ -255,69 +247,67 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
* @throws Exception
*/
public void testReplicatedSerialPropagationWithLocalRegionDestroy() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//these are part of remote site
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
//senders are created on local site
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 20, false, false, null, true, 3, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 20, false, false, null, true ,3, OrderPolicy.THREAD});
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 20, false, false, null, true, 3, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 20, false, false, null, true ,3, OrderPolicy.THREAD));
//create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
//create another RR (RR_2) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
//create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
//create another RR (RR_2) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
//do puts in RR_2 in main thread
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_2", 500 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_2", 500 ));
//destroy RR_2 after above puts are complete
- vm4.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_2"});
+ vm4.invoke(() -> WANTestBase.destroyRegion( getTestMethodName() + "_RR_2"));
try {
inv1.join();
@@ -327,11 +317,11 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
}
//sleep for some time to let all the events propagate to remote site
Thread.sleep(20);
- //vm4.invoke(WANTestBase.class, "verifyQueueSize", new Object[] { "ln", 0 });
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_2", 500 });
+ //vm4.invoke(() -> WANTestBase.verifyQueueSize( "ln", 0 ));
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_2", 500 ));
}
/**
@@ -342,54 +332,52 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
* @throws Exception
*/
public void testReplicatedSerialPropagationWithRemoteRegionDestroy() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//these are part of remote site
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
//senders are created on local site
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 500, false, false, null, true, 5, OrderPolicy.KEY });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 500, false, false, null, true, 5, OrderPolicy.KEY });
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 500, false, false, null, true, 5, OrderPolicy.KEY ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 500, false, false, null, true, 5, OrderPolicy.KEY ));
//create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
//create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 10000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 10000 ));
//destroy RR_1 in remote site
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_1"});
+ vm2.invoke(() -> WANTestBase.destroyRegion( getTestMethodName() + "_RR_1"));
try {
inv1.join();
@@ -399,13 +387,13 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
}
//verify that all is well in local site. All the events should be present in local region
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 10000 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 10000 ));
//assuming some events might have been dispatched before the remote region was destroyed,
//sender's region queue will have events less than 1000 but the queue will not be empty.
//NOTE: this much verification might be sufficient in DUnit. Hydra will take care of
//more in depth validations.
- vm4.invoke(WANTestBase.class, "verifyRegionQueueNotEmptyForConcurrentSender", new Object[] {"ln" });
+ vm4.invoke(() -> WANTestBase.verifyRegionQueueNotEmptyForConcurrentSender("ln" ));
}
/**
@@ -416,74 +404,72 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
* @throws Exception
*/
public void testReplicatedSerialPropagationWithRemoteRegionDestroy2() throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
//these are part of remote site
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
//these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
//senders are created on local site
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 200, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 200, false, false, null, true, 5, OrderPolicy.THREAD });
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 200, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 200, false, false, null, true, 5, OrderPolicy.THREAD ));
//create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
//create another RR (RR_2) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
//start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
//create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
//create another RR (RR_2) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
//destroy RR_2 on remote site in the middle
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_2"});
+ vm2.invoke(() -> WANTestBase.destroyRegion( getTestMethodName() + "_RR_2"));
//expected exceptions in the logs
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
//start puts in RR_2 in another thread
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_2", 1000 });
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_2", 1000 ));
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
try {
inv1.join();
@@ -493,87 +479,81 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
}
//though region RR_2 is destroyed, RR_1 should still get all the events put in it
//in local site
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 1000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 1000 ));
}
public void testReplicatedSerialPropagationWithRemoteRegionDestroy3()
throws Exception {
- Integer lnPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstLocatorWithDSId", new Object[] { 1 });
- Integer nyPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
// these are part of remote site
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
// these are part of local site
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache( lnPort ));
// senders are created on local site
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 200, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 200, false, false, null, true, 5, OrderPolicy.THREAD });
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 200, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 200, false, false, null, true, 5, OrderPolicy.THREAD ));
// create one RR (RR_1) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", null, isOffHeap() ));
// create another RR (RR_2) on remote site
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", null, isOffHeap() ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException",
- new Object[] { "ln", true });
- vm5.invoke(WANTestBase.class, "setRemoveFromQueueOnException",
- new Object[] { "ln", true });
+ vm4.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
+ vm5.invoke(() -> WANTestBase.setRemoveFromQueueOnException( "ln", true ));
// start the senders on local site
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
// create one RR (RR_1) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_1", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
// create another RR (RR_2) on local site
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR_2", "ln", isOffHeap() });
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
// start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
// start puts in RR_2 in another thread
- AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR_2", 1000 });
+ AsyncInvocation inv2 = vm4.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR_2", 1000 ));
// destroy RR_2 on remote site in the middle
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName()
- + "_RR_2" });
+ vm2.invoke(() -> WANTestBase.destroyRegion( getTestMethodName()
+ + "_RR_2" ));
try {
inv1.join();
@@ -586,8 +566,8 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
// in it
// in local site
try {
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR_1", 1000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR_1", 1000 ));
} finally {
System.setProperty(
"gemfire.GatewaySender.REMOVE_FROM_QUEUE_ON_EXCEPTION", "False");
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java
index 63ab79e..c534b66 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java
@@ -46,153 +46,145 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
public void testSerialReplicatedWanWithOverflow() {
- 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 ));
//keep the maxQueueMemory low enough to trigger eviction
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 50, 5, false, false, null, true, 5, OrderPolicy.KEY });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 50, 5, false, false, null, true, 5, OrderPolicy.KEY });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "doHeavyPuts", new Object[] {
- getTestMethodName() + "_RR", 150 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 150 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 150 });
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 50, 5, false, false, null, true, 5, OrderPolicy.KEY ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 50, 5, false, false, null, true, 5, OrderPolicy.KEY ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.doHeavyPuts(
+ getTestMethodName() + "_RR", 150 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 150 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 150 ));
}
public void Bug46921_testSerialReplicatedWanWithPersistence() {
- 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,
- false, 100, 10, false, true, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, true, null, true, 5, OrderPolicy.THREAD });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
+
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+
+ vm4.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, true, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, true, null, true, 5, OrderPolicy.THREAD ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
public void testReplicatedSerialPropagationToTwoWanSites() throws Exception {
Integer lnPort = createFirstLocatorWithDSId(1);
- Integer nyPort = (Integer)vm0.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 2, lnPort });
- Integer tkPort = (Integer)vm1.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 3, lnPort });
-
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { tkPort });
-
- vm4.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm6.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
- vm7.invoke(WANTestBase.class, "createCache", new Object[] {lnPort });
-
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "lnSerial1",
- 2, false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "lnSerial1",
- 2, false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
-
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "lnSerial2",
- 3, false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "lnSerial2",
- 3, false, 100, 10, false, false, null, true, 5 , OrderPolicy.THREAD});
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial1" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial1" });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial2" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial2" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ Integer nyPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer tkPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, lnPort ));
+
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( tkPort ));
+
+ vm4.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "lnSerial1",
+ 2, false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "lnSerial1",
+ 2, false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "lnSerial2",
+ 3, false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "lnSerial2",
+ 3, false, 100, 10, false, false, null, true, 5 , OrderPolicy.THREAD));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "lnSerial1" ));
+ vm5.invoke(() -> WANTestBase.startSender( "lnSerial1" ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "lnSerial2" ));
+ vm5.invoke(() -> WANTestBase.startSender( "lnSerial2" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
public void testReplicatedSerialPropagationHA() throws Exception {
@@ -200,287 +192,274 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
IgnoredException.addIgnoredException("Connection reset");
IgnoredException.addIgnoredException("Unexpected IOException");
- 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,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
-
- AsyncInvocation inv1 = vm5.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { getTestMethodName() + "_RR", 10000 });
+ 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,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+
+ AsyncInvocation inv1 = vm5.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", 10000 ));
Wait.pause(2000);
- AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "killSender");
+ AsyncInvocation inv2 = vm4.invokeAsync(() -> WANTestBase.killSender());
inv1.join();
inv2.join();
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 10000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 10000 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 10000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 10000 ));
}
public void testReplicatedSerialPropagationWithConflation() 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,
- false, 100, 1000, true, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 1000, true, false, null, true, 5, OrderPolicy.THREAD });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
+
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+
+ vm4.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 1000, true, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 1000, true, false, null, true, 5, OrderPolicy.THREAD ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
public void testReplicatedSerialPropagationWithParallelThreads()
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,
- false, 100, 10, false, false, null, true, 4, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 4, OrderPolicy.THREAD });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "doMultiThreadedPuts", new Object[] {
- getTestMethodName() + "_RR", 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000 });
+ Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1));
+ Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(2,lnPort ));
+
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm3.invoke(() -> WANTestBase.createReceiver( nyPort ));
+
+ vm4.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm6.invoke(() -> WANTestBase.createCache(lnPort ));
+ vm7.invoke(() -> WANTestBase.createCache(lnPort ));
+
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 4, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 4, OrderPolicy.THREAD ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.doMultiThreadedPuts(
+ getTestMethodName() + "_RR", 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000 ));
}
public void testSerialPropogationWithFilter() 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 ));
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
false, 100, 10, false, false,
- new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
+ new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
false, 100, 10, false, false,
- new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD });
+ new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD ));
- 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() ));
- 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" ));
- 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(), 800 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName(), 800 ));
}
public void testReplicatedSerialPropagationWithFilter() 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 ));
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
false, 100, 10, false, false,
- new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
+ new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
false, 100, 10, false, false,
- new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD });
-
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName(), null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName(), null, isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
-
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName(), "ln", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName(), "ln", isOffHeap() });
- vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName(), "ln", isOffHeap() });
- vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName(), "ln", isOffHeap() });
-
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 });
-
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName(), 800 });
- vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName(), 800 });
+ new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD ));
+
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName(), null, isOffHeap() ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName(), null, isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName(), "ln", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName(), "ln", isOffHeap() ));
+ vm6.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName(), "ln", isOffHeap() ));
+ vm7.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName(), "ln", isOffHeap() ));
+
+ vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 ));
+
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName(), 800 ));
+ vm3.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName(), 800 ));
}
public void testNormalRegionSerialPropagation() 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 });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm5.invoke(() -> WANTestBase.createCache( lnPort ));
- vm4.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
- vm5.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
+ vm4.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
+ vm5.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2,
+ false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
Wait.pause(500);
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(WANTestBase.class, "createNormalRegion", new Object[] {
- getTestMethodName() + "_RR", "ln" });
- vm5.invoke(WANTestBase.class, "createNormalRegion", new Object[] {
- getTestMethodName() + "_RR", "ln" });
+ vm4.invoke(() -> WANTestBase.createNormalRegion(
+ getTestMethodName() + "_RR", "ln" ));
+ vm5.invoke(() -> WANTestBase.createNormalRegion(
+ getTestMethodName() + "_RR", "ln" ));
- vm5.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
- 1000 });
+ vm5.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
+ 1000 ));
- vm4.invoke(WANTestBase.class, "checkQueueStats", new Object[] { "ln", 0,
- 0, 0, 0});
+ vm4.invoke(() -> WANTestBase.checkQueueStats( "ln", 0,
+ 0, 0, 0));
- vm5.invoke(WANTestBase.class, "checkQueueStats", new Object[] { "ln", 0,
- 1000, 0, 0 });
+ vm5.invoke(() -> WANTestBase.checkQueueStats( "ln", 0,
+ 1000, 0, 0 ));
- vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 1000});
+ vm5.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 1000));
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 0});
+ vm4.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 0));
- vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- getTestMethodName() + "_RR", 0 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize(
+ getTestMethodName() + "_RR", 0 ));
- vm2.invoke(WANTestBase.class, "checkGatewayReceiverStats", new Object[] {0, 0, 0});
+ vm2.invoke(() -> WANTestBase.checkGatewayReceiverStats(0, 0, 0));
}