You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2016/02/03 03:32:43 UTC
[07/15] incubator-geode git commit: Refactor dunit
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/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 413b74c..d359e52 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
@@ -59,18 +59,18 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
1 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 1 });
+ getTestMethodName() + "_RR", 1 });
}
/**
@@ -100,18 +100,18 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
1 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 1 });
+ getTestMethodName() + "_RR", 1 });
//bounce vm2
@@ -122,13 +122,13 @@ public class PDXNewWanDUnitTest extends WANTestBase{
vm2.invoke(WANTestBase.class, "createReceiver_PDX", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
2 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 2 });
+ getTestMethodName() + "_RR", 2 });
}
/**
@@ -158,18 +158,18 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
1 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 1 });
+ getTestMethodName() + "_RR", 1 });
//bounce vm3
vm3.invoke(WANTestBase.class, "closeCache");
@@ -192,17 +192,17 @@ public class PDXNewWanDUnitTest extends WANTestBase{
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
//Define a different type from vm3
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable2", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable2", new Object[] { 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[] {
- testName + "_RR", 1 });
+ getTestMethodName() + "_RR", 1 });
vm3.invoke(WANTestBase.class, "closeCache");
} finally {
@@ -253,11 +253,11 @@ public class PDXNewWanDUnitTest extends WANTestBase{
vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ny", 2,
false, 100, 10, false, false, null, true });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ny,tk", isOffHeap() });
+ getTestMethodName() + "_RR", "ny,tk", isOffHeap() });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln,tk", isOffHeap() });
+ getTestMethodName() + "_RR", "ln,tk", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln,ny", isOffHeap() });
+ getTestMethodName() + "_RR", "ln,ny", isOffHeap() });
//Start all of the senders
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ny" });
@@ -274,29 +274,29 @@ public class PDXNewWanDUnitTest extends WANTestBase{
Wait.pause(5000);
//Do some puts that define a PDX type in ln
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
1 });
//Make sure that tk received the update
vm5.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 1 });
+ getTestMethodName() + "_RR", 1 });
//Make ny didn't receive the update because the sender is paused
vm4.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 0 });
+ 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[] { testName + "_RR",
+ vm5.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
2 });
//Verify the ny can read the object
vm4.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 2 });
+ getTestMethodName() + "_RR", 2 });
//Wait for vm3 to receive the update (prevents a broken pipe suspect string)
vm3.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 2 });
+ getTestMethodName() + "_RR", 2 });
}
public void testWANPDX_RR_SerialSender_StartedLater() {
@@ -313,21 +313,21 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
10 });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
40 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 40 });
+ getTestMethodName() + "_RR", 40 });
}
/**
@@ -355,18 +355,18 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
1 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 1 });
+ getTestMethodName() + "_PR", 1 });
}
public void testWANPDX_PR_SerialSender_StartedLater() {
@@ -383,21 +383,21 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
20 });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
40 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 40 });
+ getTestMethodName() + "_PR", 40 });
}
/**
@@ -426,20 +426,20 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null,1, 5, isOffHeap() });
+ getTestMethodName() + "_PR", null,1, 5, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 1, 5, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 1, 5, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
10 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 10 });
+ getTestMethodName() + "_PR", 10 });
}
public void testWANPDX_PR_MultipleVM_SerialSender_StartedLater() {
@@ -457,23 +457,23 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 1, 5, isOffHeap() });
+ getTestMethodName() + "_PR", null, 1, 5, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 1, 5, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 1, 5, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
10 });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
40 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 40 });
+ getTestMethodName() + "_PR", 40 });
}
/**
@@ -501,18 +501,18 @@ public class PDXNewWanDUnitTest extends WANTestBase{
true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 1, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
1 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 1});
+ getTestMethodName() + "_PR", 1});
}
public void testWANPDX_PR_ParallelSender_47826() {
@@ -529,7 +529,7 @@ public class PDXNewWanDUnitTest extends WANTestBase{
100, 10, false, false, null, true });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() });
vm3.invoke(WANTestBase.class, "unsetRemoveFromQueueOnException",
new Object[] { "ln" });
@@ -537,13 +537,13 @@ public class PDXNewWanDUnitTest extends WANTestBase{
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] {
- testName + "_PR", 1 });
+ getTestMethodName() + "_PR", 1 });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 1, isOffHeap() });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 1 });
+ getTestMethodName() + "_PR", 1 });
}
public void testWANPDX_PR_ParallelSender_StartedLater() {
@@ -560,21 +560,21 @@ public class PDXNewWanDUnitTest extends WANTestBase{
true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
10 });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
40 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 40 });
+ getTestMethodName() + "_PR", 40 });
}
@@ -595,21 +595,21 @@ public class PDXNewWanDUnitTest extends WANTestBase{
true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ 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.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
10 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 10 });
+ getTestMethodName() + "_PR", 10 });
}
public void testWANPDX_PR_MultipleVM_ParallelSender_StartedLater() {
@@ -629,14 +629,14 @@ public class PDXNewWanDUnitTest extends WANTestBase{
true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
10 });
AsyncInvocation inv1 = vm3.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -650,11 +650,11 @@ public class PDXNewWanDUnitTest extends WANTestBase{
fail("Caught interrupted exception");
}
- vm4.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
40 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 40 });
+ getTestMethodName() + "_PR", 40 });
}
@@ -672,18 +672,18 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, new PDXGatewayEventFilter(), true });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_RR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR",
1 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_RR", 1 });
+ getTestMethodName() + "_RR", 1 });
vm3.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new Object[] { 1});
}
@@ -706,21 +706,21 @@ public class PDXNewWanDUnitTest extends WANTestBase{
true, 100, 10, false, false, new PDXGatewayEventFilter(), true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ 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.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
10 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 10 });
+ getTestMethodName() + "_PR", 10 });
vm3.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new Object[] { 5});
vm4.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new Object[] { 5});
@@ -745,18 +745,18 @@ public class PDXNewWanDUnitTest extends WANTestBase{
false, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 2, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 2, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
1 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 1 });
+ getTestMethodName() + "_PR", 1 });
vm2.invoke(WANTestBase.class, "killSender", new Object[] {});
@@ -764,15 +764,15 @@ public class PDXNewWanDUnitTest extends WANTestBase{
vm4.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 1, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 1, 2, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 1, 2, isOffHeap() });
+ getTestMethodName() + "_PR", null, 1, 2, isOffHeap() });
- vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR",
1 });
vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] {
- testName + "_PR", 1 });
+ getTestMethodName() + "_PR", 1 });
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPersistenceDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPersistenceDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPersistenceDUnitTest.java
index 2bb728f..4d52811 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPersistenceDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPersistenceDUnitTest.java
@@ -57,9 +57,9 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
//create cache in local site
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -80,13 +80,13 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
LogWriterSupport.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4);
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -104,7 +104,7 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" });
//start puts in region on local site
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR", 3000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", 3000 });
LogWriterSupport.getLogWriter().info("Completed puts in the region");
//--------------------close and rebuild local site -------------------------------------------------
@@ -145,13 +145,13 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
//create PR on local site
AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
try {
inv1.join();
inv2.join();
@@ -179,18 +179,18 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
LogWriterSupport.getLogWriter().info("All the senders are now running...");
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
//----------------------------------------------------------------------------------------------------
- vm4.invoke(WANTestBase.class, "doNextPuts", new Object[] { testName + "_RR", 3000, 10000 });
+ vm4.invoke(WANTestBase.class, "doNextPuts", new Object[] { getTestMethodName() + "_RR", 3000, 10000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
}
@@ -214,9 +214,9 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
//create cache in local site
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -237,16 +237,16 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
LogWriterSupport.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4);
vm4.invoke(WANTestBase.class,
- "createReplicatedRegion", new Object[] { testName + "_RR", "ln",
+ "createReplicatedRegion", new Object[] { getTestMethodName() + "_RR", "ln",
Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm5.invoke(WANTestBase.class,
- "createReplicatedRegion", new Object[] { testName + "_RR", "ln",
+ "createReplicatedRegion", new Object[] { getTestMethodName() + "_RR", "ln",
Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm6.invoke(WANTestBase.class,
- "createReplicatedRegion", new Object[] { testName + "_RR", "ln",
+ "createReplicatedRegion", new Object[] { getTestMethodName() + "_RR", "ln",
Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm7.invoke(WANTestBase.class,
- "createReplicatedRegion", new Object[] { testName + "_RR", "ln",
+ "createReplicatedRegion", new Object[] { getTestMethodName() + "_RR", "ln",
Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -265,7 +265,7 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" });
//start puts in region on local site
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR", 3000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", 3000 });
LogWriterSupport.getLogWriter().info("Completed puts in the region");
//--------------------close and rebuild local site -------------------------------------------------
@@ -304,13 +304,13 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
//create PR on local site
AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
try {
inv1.join();
@@ -341,28 +341,28 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
//----------------------------------------------------------------------------------------------------
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm6.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm7.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
/* exp1 = addExpectedException(CacheClosedException.class.getName());
try {
*/ vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm4.invoke(WANTestBase.class, "doNextPuts", new Object[] {
- testName + "_RR", 3000, 10000 });
+ getTestMethodName() + "_RR", 3000, 10000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
/* }
finally {
exp1.remove();
@@ -389,14 +389,14 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 1, 100, isOffHeap() });
//create cache in local site
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -417,26 +417,26 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
LogWriterSupport.getLogWriter().info("The DS are: " + diskStore1 + "," + diskStore2 + "," + diskStore3 + "," + diskStore4);
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPersistentPartitionedRegion",
- new Object[] { testName + "_PR", "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPersistentPartitionedRegion",
- new Object[] { testName + "_PR", "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPersistentPartitionedRegion",
- new Object[] { testName + "_PR", "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPersistentPartitionedRegion",
- new Object[] { testName + "_PR", "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -454,8 +454,8 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" });
//start puts in region on local site
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR", 3000 });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR", 3000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", 3000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 3000 });
LogWriterSupport.getLogWriter().info("Completed puts in the region");
//--------------------close and rebuild local site -------------------------------------------------
@@ -496,13 +496,13 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
//create PR on local site
AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK, DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
try {
inv1.join();
@@ -515,16 +515,16 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
}
inv1 = vm4.invokeAsync(WANTestBase.class,
- "createPersistentPartitionedRegion", new Object[] { testName + "_PR", "ln", 1,
+ "createPersistentPartitionedRegion", new Object[] { getTestMethodName() + "_PR", "ln", 1,
100, isOffHeap() });
inv2 = vm5.invokeAsync(WANTestBase.class,
- "createPersistentPartitionedRegion", new Object[] { testName + "_PR", "ln", 1,
+ "createPersistentPartitionedRegion", new Object[] { getTestMethodName() + "_PR", "ln", 1,
100, isOffHeap() });
inv3 = vm6.invokeAsync(WANTestBase.class,
- "createPersistentPartitionedRegion", new Object[] { testName + "_PR", "ln", 1,
+ "createPersistentPartitionedRegion", new Object[] { getTestMethodName() + "_PR", "ln", 1,
100, isOffHeap() });
inv4 = vm7.invokeAsync(WANTestBase.class,
- "createPersistentPartitionedRegion", new Object[] { testName + "_PR", "ln", 1,
+ "createPersistentPartitionedRegion", new Object[] { getTestMethodName() + "_PR", "ln", 1,
100, isOffHeap() });
try {
@@ -557,47 +557,47 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
//----------------------------------------------------------------------------------------------------
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm6.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm7.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 3000 });
+ getTestMethodName() + "_PR", 3000 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 3000 });
+ getTestMethodName() + "_PR", 3000 });
vm6.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 3000 });
+ getTestMethodName() + "_PR", 3000 });
vm7.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 3000 });
+ getTestMethodName() + "_PR", 3000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 3000 });
+ getTestMethodName() + "_RR", 3000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 3000 });
+ getTestMethodName() + "_PR", 3000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 3000 });
+ getTestMethodName() + "_PR", 3000 });
- vm4.invoke(WANTestBase.class, "doNextPuts", new Object[] { testName + "_RR", 3000, 10000 });
- vm4.invoke(WANTestBase.class, "doNextPuts", new Object[] { testName + "_PR", 3000, 10000 });
+ vm4.invoke(WANTestBase.class, "doNextPuts", new Object[] { getTestMethodName() + "_RR", 3000, 10000 });
+ vm4.invoke(WANTestBase.class, "doNextPuts", new Object[] { getTestMethodName() + "_PR", 3000, 10000 });
/* exp1 = addExpectedException(CacheClosedException.class.getName());
try {*/
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 10000 });
+ getTestMethodName() + "_PR", 10000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 10000 });
+ getTestMethodName() + "_PR", 10000 });
/* }
finally {
exp1.remove();
@@ -647,16 +647,16 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
+ diskStore4);
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -665,9 +665,9 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "waitForSenderRunningState",
new Object[] { "ln" });
@@ -682,13 +682,13 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
{
AsyncInvocation inv1 = vm7.invokeAsync(
ReplicatedRegion_ParallelWANPropogationDUnitTest.class, "doPuts0",
- new Object[] { testName + "_RR", 10000 });
+ new Object[] { getTestMethodName() + "_RR", 10000 });
pauseWaitCriteria(1000);
AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "killSender");
pauseWaitCriteria(2000);
AsyncInvocation inv3 = vm6.invokeAsync(
ReplicatedRegion_ParallelWANPropogationDUnitTest.class, "doPuts1",
- new Object[] { testName + "_RR", 10000 });
+ new Object[] { getTestMethodName() + "_RR", 10000 });
pauseWaitCriteria(1500);
AsyncInvocation inv4 = vm5.invokeAsync(WANTestBase.class, "killSender");
try {
@@ -716,15 +716,15 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class,
"createReplicatedRegion",
- new Object[] { testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ new Object[] { getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class,
"createReplicatedRegion",
- new Object[] { testName + "_RR", "ln", Scope.DISTRIBUTED_ACK,
+ new Object[] { getTestMethodName() + "_RR", "ln", Scope.DISTRIBUTED_ACK,
DataPolicy.PERSISTENT_REPLICATE, isOffHeap() });
AsyncInvocation inv3 = vm6.invokeAsync(
ReplicatedRegion_ParallelWANPropogationDUnitTest.class, "doPuts2",
- new Object[] { testName + "_RR", 15000 });
+ new Object[] { getTestMethodName() + "_RR", 15000 });
try {
inv1.join();
inv2.join();
@@ -748,6 +748,6 @@ public class ReplicatedRegion_ParallelWANPersistenceDUnitTest extends WANTestBas
"validateParallelSenderQueueAllBucketsDrained", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 15000 });
+ getTestMethodName() + "_RR", 15000 });
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPropogationDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPropogationDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPropogationDUnitTest.java
index b8740b1..18b1109 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPropogationDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/ReplicatedRegion_ParallelWANPropogationDUnitTest.java
@@ -71,12 +71,12 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln1", 2,
true, 10, 100, false, false, null, true });
@@ -143,9 +143,9 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
*/ vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln1", 2,
true, 10, 100, false, false, null, false });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm4.invoke(WANTestBase.class, "doPuts", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] {
"ln1", 1000 });
@@ -181,7 +181,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
/* ExpectedException exp1 = addExpectedException(GatewaySenderException.class
.getName(), vm4);
ExpectedException exp2 = addExpectedException(InterruptedException.class
@@ -190,7 +190,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln1", 2,
true, 10, 100, false, false, null, false });
vm4.invoke(WANTestBase.class, "doPuts", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] {
"ln1", 1000 });
/* }
@@ -221,7 +221,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
/* ExpectedException exp1 = addExpectedException(GatewaySenderException.class
.getName(), vm4);
@@ -233,10 +233,10 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln1" });
vm4.invoke(WANTestBase.class, "doPuts", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] {
"ln1", 10000 });
/* }
@@ -269,9 +269,9 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
/* ExpectedException exp1 = addExpectedException(
GatewaySenderException.class.getName());
@@ -289,12 +289,12 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln1" });
vm4.invoke(WANTestBase.class, "doPuts", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] {
"ln1", 1000 });
@@ -356,29 +356,29 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln1", 2,
true, 10, 100, false, false, null, true});
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln1"});
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000});
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000});
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln1",
0 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000});
+ getTestMethodName() + "_RR", 1000});
}
catch (Exception e) {
Assert.fail("Unexpected exception", e);
@@ -401,15 +401,15 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln1", 2,
true, 10, 100, false, false, null, true});
@@ -419,12 +419,12 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln1"});
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln1"});
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln1",
@@ -433,7 +433,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
0 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
}
catch (Exception e) {
Assert.fail("Unexpected exception", e);
@@ -456,15 +456,15 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", Scope.DISTRIBUTED_ACK, DataPolicy.EMPTY, isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", Scope.DISTRIBUTED_ACK, DataPolicy.EMPTY, isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", Scope.DISTRIBUTED_ACK, DataPolicy.REPLICATE, isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", Scope.DISTRIBUTED_ACK, DataPolicy.REPLICATE, isOffHeap() });
vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln1", 2,
true, 10, 100, false, false, null, true});
@@ -474,12 +474,12 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln1"});
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln1"});
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
// vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
// 1000 });
- vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln1",
@@ -488,7 +488,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
0 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
}
catch (Exception e) {
Assert.fail("Unexpected exception", e);
@@ -513,14 +513,14 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -528,22 +528,22 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
true, 10, 100, false, false, null, true });
@@ -568,14 +568,14 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "waitForSenderRunningState",
new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm5.invoke(WANTestBase.class, "doNextPuts", new Object[] { testName + "_PR",
+ vm5.invoke(WANTestBase.class, "doNextPuts", new Object[] { getTestMethodName() + "_PR",
1000, 2000 });
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_PR",
1000 });
- vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln",
@@ -587,13 +587,13 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
.getName());
try {*/
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
/* }
finally {
exp1.remove();
@@ -620,7 +620,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -637,24 +637,24 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
true, 10, 100, false, false, null, false });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln1", isOffHeap() });
+ getTestMethodName() + "_RR", "ln1", isOffHeap() });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm6.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm6.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm7.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm7.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
@@ -671,7 +671,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
.getName());
try {*/
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
/* }
finally {
exp1.remove();
@@ -715,13 +715,13 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
true, 100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -729,9 +729,9 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
// before doing any puts, let the senders be running in order to ensure
// that
@@ -745,10 +745,10 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "waitForSenderRunningState",
new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
/* ExpectedException exp1 = addExpectedException(CacheClosedException.class
.getName());
@@ -777,13 +777,13 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
true, 100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -801,7 +801,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
// ------------------------------------------------------------------------------------
vm4.invoke(WANTestBase.class, "doNextPuts", new Object[] {
- testName + "_RR", 1000, 2000 });
+ getTestMethodName() + "_RR", 1000, 2000 });
// verify all buckets drained on all sender nodes.
vm4.invoke(WANTestBase.class,
@@ -816,9 +816,9 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
/* exp1 = addExpectedException(CacheClosedException.class.getName());
try {*/
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 2000 });
+ getTestMethodName() + "_RR", 2000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 2000 });
+ getTestMethodName() + "_RR", 2000 });
/* }
finally {
exp1.remove();
@@ -846,16 +846,16 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
vm4.invoke(WANTestBase.class,
- "createReplicatedRegion", new Object[] { testName + "_RR", "ln1",
+ "createReplicatedRegion", new Object[] { getTestMethodName() + "_RR", "ln1",
Scope.DISTRIBUTED_NO_ACK, DataPolicy.REPLICATE, isOffHeap() });
vm5.invoke(WANTestBase.class,
- "createReplicatedRegion", new Object[] { testName + "_RR", "ln1",
+ "createReplicatedRegion", new Object[] { getTestMethodName() + "_RR", "ln1",
Scope.DISTRIBUTED_NO_ACK, DataPolicy.REPLICATE, isOffHeap() });
vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln1", 2,
@@ -866,12 +866,12 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln1"});
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln1"});
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { testName + "_RR",
+ vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] { getTestMethodName() + "_RR",
1000 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln1",
@@ -880,7 +880,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
0 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
}
catch (Exception e) {
Assert.fail("Unexpected exception", e);
@@ -913,17 +913,17 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "waitForSenderRunningState",
new Object[] { "ln" });
@@ -937,7 +937,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
try {*/
AsyncInvocation inv1 = vm4.invokeAsync(
ReplicatedRegion_ParallelWANPropogationDUnitTest.class, "doPuts0", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
Wait.pause(1000);
AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "killSender");
try {
@@ -965,7 +965,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
LogWriterSupport.getLogWriter().info("The size of the queue is in vm4 " + size);
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
}
/**Below test is disabled intentionally
@@ -1000,13 +1000,13 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -1014,9 +1014,9 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm4.invoke(WANTestBase.class, "waitForSenderRunningState",
new Object[] { "ln" });
@@ -1033,13 +1033,13 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
try */{
AsyncInvocation inv1 = vm7.invokeAsync(
ReplicatedRegion_ParallelWANPropogationDUnitTest.class, "doPuts0", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
pauseWaitCriteria(1000);
AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "killSender");
pauseWaitCriteria(2000);
AsyncInvocation inv3 = vm6.invokeAsync(
ReplicatedRegion_ParallelWANPropogationDUnitTest.class, "doPuts1", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
pauseWaitCriteria(1500);
AsyncInvocation inv4 = vm5.invokeAsync(WANTestBase.class, "killSender");
try {
@@ -1062,7 +1062,7 @@ public class ReplicatedRegion_ParallelWANPropogationDUnitTest extends WANTestBas
"validateParallelSenderQueueAllBucketsDrained", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 10000 });
+ getTestMethodName() + "_RR", 10000 });
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/SenderWithTransportFilterDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/SenderWithTransportFilterDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/SenderWithTransportFilterDUnitTest.java
index 3fdc672..af6c1e3 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/SenderWithTransportFilterDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/SenderWithTransportFilterDUnitTest.java
@@ -65,7 +65,7 @@ public class SenderWithTransportFilterDUnitTest extends WANTestBase {
vm2.invoke(SenderWithTransportFilterDUnitTest.class,
"createReceiverWithTransportFilters", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -74,15 +74,15 @@ public class SenderWithTransportFilterDUnitTest extends WANTestBase {
1, false, false, true });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "ln", isOffHeap() });
+ getTestMethodName() + "_RR", "ln", isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "doPuts",
- new Object[] { testName + "_RR", 100 });
+ new Object[] { getTestMethodName() + "_RR", 100 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 100 });
+ getTestMethodName() + "_RR", 100 });
}
public void testParallelSenderWithTansportFilter() {
@@ -95,7 +95,7 @@ public class SenderWithTransportFilterDUnitTest extends WANTestBase {
vm2.invoke(SenderWithTransportFilterDUnitTest.class,
"createReceiverWithTransportFilters", new Object[] { nyPort });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 10, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 10, isOffHeap() });
vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -104,19 +104,19 @@ public class SenderWithTransportFilterDUnitTest extends WANTestBase {
1, false, false, true });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 10, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 10, isOffHeap() });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "doPuts",
- new Object[] { testName + "_PR", 100 });
+ new Object[] { getTestMethodName() + "_PR", 100 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 100 });
+ getTestMethodName() + "_PR", 100 });
}
public static int createReceiverWithTransportFilters(int locPort) {
- WANTestBase test = new WANTestBase(testName);
+ WANTestBase test = new WANTestBase(getTestMethodName());
Properties props = new Properties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + locPort