http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java
----------------------------------------------------------------------
diff --git
a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java
b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java
index d359e52..a7e17b6 100644
---
a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java
+++
b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java
@@ -46,31 +46,29 @@ public class PDXNewWanDUnitTest extends WANTestBase{
* 7> Validate whether other sites member receive this put operation.
*/
public void testWANPDX_RR_SerialSender() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 1 ));
}
/**
@@ -87,48 +85,46 @@ public class PDXNewWanDUnitTest extends WANTestBase{
* and can deserialize entries.
*/
public void testWANPDX_RemoveRomoteData() {
- 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_PDX", new Object[] { nyPort
});
+ vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort ));
- vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 1 ));
//bounce vm2
- vm2.invoke(WANTestBase.class, "closeCache");
+ vm2.invoke(() -> WANTestBase.closeCache());
- vm2.invoke(WANTestBase.class, "deletePDXDir");
+ vm2.invoke(() -> WANTestBase.deletePDXDir());
- vm2.invoke(WANTestBase.class, "createReceiver_PDX", new Object[] { nyPort
});
+ vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 2 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 2 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 2 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 2 ));
}
/**
@@ -145,34 +141,32 @@ public class PDXNewWanDUnitTest extends WANTestBase{
* 10> Make sure we flag a warning about the conflicting updates.
*/
public void testWANPDX_ConflictingData() {
- 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_PDX", new Object[] { nyPort
});
+ vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort ));
- vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 1 ));
//bounce vm3
- vm3.invoke(WANTestBase.class, "closeCache");
+ vm3.invoke(() -> WANTestBase.closeCache());
IgnoredException ex1 = IgnoredException.addIgnoredException("Trying to add
a PDXType with the same id");
IgnoredException ex2 =
IgnoredException.addIgnoredException("CacheWriterException");
@@ -182,29 +176,29 @@ public class PDXNewWanDUnitTest extends WANTestBase{
try {
//blow away vm3's PDX data
- vm3.invoke(WANTestBase.class, "deletePDXDir");
+ vm3.invoke(() -> WANTestBase.deletePDXDir());
- vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
//Define a different type from vm3
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable2", new Object[] {
getTestMethodName() + "_RR",
- 2 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable2( getTestMethodName() +
"_RR",
+ 2 ));
//Give the updates some time to make it over the WAN
Wait.pause(10000);
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 1 ));
- vm3.invoke(WANTestBase.class, "closeCache");
+ vm3.invoke(() -> WANTestBase.closeCache());
} finally {
ex1.remove();
ex2.remove();
@@ -226,108 +220,103 @@ public class PDXNewWanDUnitTest extends WANTestBase{
* 7> Validate whether other sites member receive this put operation.
*/
public void testWANPDX_RR_SerialSender3Sites() {
- 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 ));
- Integer tkPort = (Integer)vm2.invoke(WANTestBase.class,
- "createFirstRemoteLocator", new Object[] { 3, lnPort });
+ Integer tkPort = (Integer)vm2.invoke(() ->
WANTestBase.createFirstRemoteLocator( 3, lnPort ));
- vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { lnPort });
- vm4.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm5.invoke(WANTestBase.class, "createReceiver", new Object[] { tkPort });
+ vm3.invoke(() -> WANTestBase.createReceiver( lnPort ));
+ vm4.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm5.invoke(() -> WANTestBase.createReceiver( tkPort ));
//Create all of our gateway senders
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ny", 2,
- false, 100, 10, false, false, null, true });
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "tk", 3,
- false, 100, 10, false, false, null, true });
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 1,
- false, 100, 10, false, false, null, true });
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "tk", 3,
- false, 100, 10, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 1,
- false, 100, 10, false, false, null, true });
- vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ny", 2,
- false, 100, 10, false, false, null, true });
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ny,tk", isOffHeap() });
- vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln,tk", isOffHeap() });
- vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln,ny", isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createSender( "ny", 2,
+ false, 100, 10, false, false, null, true ));
+ vm3.invoke(() -> WANTestBase.createSender( "tk", 3,
+ false, 100, 10, false, false, null, true ));
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 1,
+ false, 100, 10, false, false, null, true ));
+ vm4.invoke(() -> WANTestBase.createSender( "tk", 3,
+ false, 100, 10, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ln", 1,
+ false, 100, 10, false, false, null, true ));
+ vm5.invoke(() -> WANTestBase.createSender( "ny", 2,
+ false, 100, 10, false, false, null, true ));
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ny,tk", isOffHeap() ));
+ vm4.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln,tk", isOffHeap() ));
+ vm5.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln,ny", isOffHeap() ));
//Start all of the senders
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ny" });
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "tk" });
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "tk" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ny" });
+ vm3.invoke(() -> WANTestBase.startSender( "ny" ));
+ vm3.invoke(() -> WANTestBase.startSender( "tk" ));
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(() -> WANTestBase.startSender( "tk" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm5.invoke(() -> WANTestBase.startSender( "ny" ));
//Pause ln to ny. This means the PDX type will not be dispatched
//to ny from ln
- vm3.invoke(WANTestBase.class, "pauseSender", new Object[] { "ny" });
+ vm3.invoke(() -> WANTestBase.pauseSender( "ny" ));
Wait.pause(5000);
//Do some puts that define a PDX type in ln
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 1 ));
//Make sure that tk received the update
- vm5.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 1 });
+ vm5.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 1 ));
//Make ny didn't receive the update because the sender is paused
- vm4.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 0 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 0 ));
//Now, do a put from tk. This serialized object will be distributed
//to ny from tk, using the type defined by ln.
- vm5.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 2 });
+ vm5.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 2 ));
//Verify the ny can read the object
- vm4.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 2 });
+ vm4.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 2 ));
//Wait for vm3 to receive the update (prevents a broken pipe suspect
string)
- vm3.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 2 });
+ vm3.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 2 ));
}
public void testWANPDX_RR_SerialSender_StartedLater() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 10 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 10 ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 40 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 40 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 40 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 40 ));
}
/**
@@ -342,62 +331,58 @@ public class PDXNewWanDUnitTest extends WANTestBase{
*/
public void testWANPDX_PR_SerialSender() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 1 ));
}
public void testWANPDX_PR_SerialSender_StartedLater() {
- 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_PDX", new Object[] { nyPort
});
+ vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort ));
- vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 20 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 20 ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 40 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 40 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 40 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 40 ));
}
/**
@@ -412,68 +397,64 @@ public class PDXNewWanDUnitTest extends WANTestBase{
*/
public void testWANPDX_PR_MultipleVM_SerialSender() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null,1, 5, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null,1, 5, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() });
- vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() ));
+ vm4.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 10 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 10 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 10 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 10 ));
}
public void testWANPDX_PR_MultipleVM_SerialSender_StartedLater() {
- 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_PDX", new Object[] { nyPort
});
+ vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort ));
- vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
- vm4.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
+ vm4.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 1, 5, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 1, 5, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() });
- vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() ));
+ vm4.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 10 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 10 ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm4.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 40 });
+ vm4.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 40 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 40 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 40 ));
}
/**
@@ -488,159 +469,148 @@ public class PDXNewWanDUnitTest extends WANTestBase{
*/
public void testWANPDX_PR_ParallelSender() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- true, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ true, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 1, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 1, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 1});
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 1));
}
public void testWANPDX_PR_ParallelSender_47826() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, true,
- 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2, true,
+ 100, 10, false, false, null, true ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "unsetRemoveFromQueueOnException",
- new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.unsetRemoveFromQueueOnException( "ln" ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
- getTestMethodName() + "_PR", 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable(
+ getTestMethodName() + "_PR", 1 ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 1, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 1, isOffHeap() ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 1 ));
}
public void testWANPDX_PR_ParallelSender_StartedLater() {
- 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_PDX", new Object[] { nyPort
});
+ vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort ));
- vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- true, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ true, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 10 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 10 ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 40 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 40 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 40 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 40 ));
}
public void testWANPDX_PR_MultipleVM_ParallelSender() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- true, 100, 10, false, false, null, true });
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- true, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ true, 100, 10, false, false, null, true ));
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ true, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
- vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
+ vm4.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 10 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 10 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 10 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 10 ));
}
public void testWANPDX_PR_MultipleVM_ParallelSender_StartedLater() {
- 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_PDX", new Object[] { nyPort
});
+ vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort ));
- vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
- vm4.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
+ vm4.invoke(() -> WANTestBase.createCache_PDX( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- true, 100, 10, false, false, null, true });
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- true, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ true, 100, 10, false, false, null, true ));
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ true, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
- vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
+ vm4.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 10 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 10 ));
- AsyncInvocation inv1 = vm3.invokeAsync(WANTestBase.class, "startSender",
new Object[] { "ln" });
- AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "startSender",
new Object[] { "ln" });
+ AsyncInvocation inv1 = vm3.invokeAsync(() -> WANTestBase.startSender( "ln"
));
+ AsyncInvocation inv2 = vm4.invokeAsync(() -> WANTestBase.startSender( "ln"
));
try{
inv1.join();
@@ -650,80 +620,76 @@ public class PDXNewWanDUnitTest extends WANTestBase{
fail("Caught interrupted exception");
}
- vm4.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 40 });
+ vm4.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 40 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 40 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 40 ));
}
public void testWANPDX_RR_SerialSenderWithFilter() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, new PDXGatewayEventFilter(), true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, new PDXGatewayEventFilter(), true ));
- vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", null, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- getTestMethodName() + "_RR", "ln", isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createReplicatedRegion(
+ getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_RR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_RR",
+ 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_RR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_RR", 1 ));
- vm3.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new
Object[] { 1});
+ vm3.invoke(() -> PDXNewWanDUnitTest.verifyFilterInvocation( 1));
}
public void testWANPDX_PR_MultipleVM_ParallelSenderWithFilter() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
- vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
+ vm4.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- true, 100, 10, false, false, new PDXGatewayEventFilter(), true });
- vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- true, 100, 10, false, false, new PDXGatewayEventFilter(), true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ true, 100, 10, false, false, new PDXGatewayEventFilter(), true ));
+ vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
+ true, 100, 10, false, false, new PDXGatewayEventFilter(), true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
- vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
+ vm4.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
+ vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 10 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 10 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 10 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 10 ));
- vm3.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new
Object[] { 5});
- vm4.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new
Object[] { 5});
+ vm3.invoke(() -> PDXNewWanDUnitTest.verifyFilterInvocation( 5));
+ vm4.invoke(() -> PDXNewWanDUnitTest.verifyFilterInvocation( 5));
}
@@ -732,47 +698,45 @@ public class PDXNewWanDUnitTest extends WANTestBase{
*/
public void Bug_testWANPDX_PR_SerialSender_RemoteSite_Bounce() {
- 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 ));
- vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
+ vm3.invoke(() -> WANTestBase.createCache( lnPort ));
- vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
- false, 100, 10, false, false, null, true });
+ vm3.invoke(() -> WANTestBase.createSender( "ln", 2,
+ false, 100, 10, false, false, null, true ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
+ vm3.invoke(() -> WANTestBase.startSender( "ln" ));
- vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
+ vm3.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 1 ));
- vm2.invoke(WANTestBase.class, "killSender", new Object[] {});
+ vm2.invoke(() -> WANTestBase.killSender());
- vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
- vm4.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
+ vm2.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ vm4.invoke(() -> WANTestBase.createReceiver( nyPort ));
- vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 1, 2, isOffHeap() });
- vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- getTestMethodName() + "_PR", null, 1, 2, isOffHeap() });
+ vm2.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 1, 2, isOffHeap() ));
+ vm4.invoke(() -> WANTestBase.createPartitionedRegion(
+ getTestMethodName() + "_PR", null, 1, 2, isOffHeap() ));
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
getTestMethodName() + "_PR",
- 1 });
+ vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() +
"_PR",
+ 1 ));
- vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- getTestMethodName() + "_PR", 1 });
+ vm2.invoke(() -> WANTestBase.validateRegionSize_PDX(
+ getTestMethodName() + "_PR", 1 ));
}
