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:40 UTC
[04/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/parallel/ParallelWANPropagationDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java
index 2dcfe25..7ea17d6 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java
@@ -55,7 +55,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
createCache(lnPort);
createSender("ln", 2, true, 100, 300, false, false,
null, true);
- createPartitionedRegion(testName + "_PR", "ln", 1, 100, isOffHeap());
+ createPartitionedRegion(getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap());
Set<GatewaySender> senders = cache.getGatewaySenders();
GatewaySender sender = null;
@@ -105,13 +105,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 300, false, false, null, true });
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, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -129,7 +129,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
@@ -137,9 +137,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort });
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() });
//verify all buckets drained on all sender nodes.
vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
@@ -152,7 +152,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
// started before creating partition region it is quite possible that the
// region may loose some of the events. This needs to be handled by the code
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
}
/**
@@ -183,13 +183,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
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, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -197,9 +197,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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() });
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
@@ -208,7 +208,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
//verify all buckets drained on all sender nodes.
@@ -218,7 +218,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
}
public void testParallelPropagation_ManualStart() throws Exception {
@@ -245,18 +245,18 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, false });
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() });
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() });
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
@@ -265,7 +265,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
//verify all buckets drained on all sender nodes.
@@ -275,7 +275,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
}
/**
@@ -306,15 +306,15 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
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, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -332,9 +332,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
fail("Caught interrupted exception");
}
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() });
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
@@ -343,11 +343,11 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
}
/**
@@ -383,13 +383,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
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, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -397,9 +397,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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() });
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
@@ -408,10 +408,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
//-------------------Close and rebuild local site ---------------------------------
vm4.invoke(WANTestBase.class, "killSender", new Object[] {});
@@ -420,7 +420,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "killSender", new Object[] {});
Integer regionSize =
- (Integer) vm2.invoke(WANTestBase.class, "getRegionSize", new Object[] {testName + "_PR" });
+ (Integer) vm2.invoke(WANTestBase.class, "getRegionSize", new Object[] {getTestMethodName() + "_PR" });
LogWriterSupport.getLogWriter().info("Region size on remote is: " + regionSize);
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -443,13 +443,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] { "ln", true });
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, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -466,7 +466,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR", 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 });
//verify all buckets drained on all sender nodes.
vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
@@ -475,9 +475,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
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 });
}
public void testParallelColocatedPropagation() throws Exception {
@@ -504,13 +504,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createColocatedPartitionedRegions",
- new Object[] { testName, "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createColocatedPartitionedRegions",
- new Object[] { testName, "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createColocatedPartitionedRegions",
- new Object[] { testName, "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createColocatedPartitionedRegions",
- new Object[] { testName, "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -518,11 +518,11 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createColocatedPartitionedRegions",
- new Object[] { testName, null, 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createColocatedPartitionedRegions",
- new Object[] { testName, null, 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), null, 1, 100, isOffHeap() });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName, 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 });
//verify all buckets drained on all sender nodes.
vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
@@ -531,7 +531,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 1000 });
+ getTestMethodName(), 1000 });
}
/**
* Create colocated partitioned regions.
@@ -566,13 +566,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createColocatedPartitionedRegions2",
- new Object[] { testName, "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createColocatedPartitionedRegions2",
- new Object[] { testName, "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createColocatedPartitionedRegions2",
- new Object[] { testName, "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createColocatedPartitionedRegions2",
- new Object[] { testName, "ln", 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -580,13 +580,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createColocatedPartitionedRegions2",
- new Object[] { testName, null, 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createColocatedPartitionedRegions2",
- new Object[] { testName, null, 1, 100, isOffHeap() });
+ new Object[] { getTestMethodName(), null, 1, 100, isOffHeap() });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName, 1000 });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName+"_child1", 1000 });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName+"_child2", 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName()+"_child1", 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName()+"_child2", 1000 });
//verify all buckets drained on all sender nodes.
vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
@@ -595,11 +595,11 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 1000 });
+ getTestMethodName(), 1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName+"_child1", 0 });
+ getTestMethodName()+"_child1", 0 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName+"_child2", 0 });
+ getTestMethodName()+"_child2", 0 });
}
@@ -627,13 +627,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -641,9 +641,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
//let all the senders start before doing any puts to ensure that none of the events is lost
vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
@@ -651,7 +651,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doHeavyPuts", new Object[] { testName, 150 });
+ vm4.invoke(WANTestBase.class, "doHeavyPuts", new Object[] { getTestMethodName(), 150 });
//verify all buckets drained on all sender nodes.
vm4.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
@@ -660,7 +660,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 150 });
+ getTestMethodName(), 150 });
}
public void testSerialReplicatedAndParallePartitionedPropagation()
@@ -694,32 +694,32 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
2, true, 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", 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, "createReplicatedRegion", new Object[] {
- testName + "_RR", "lnSerial", isOffHeap() });
+ getTestMethodName() + "_RR", "lnSerial", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "lnSerial", isOffHeap() });
+ getTestMethodName() + "_RR", "lnSerial", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "lnSerial", isOffHeap() });
+ getTestMethodName() + "_RR", "lnSerial", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "lnSerial", isOffHeap() });
+ getTestMethodName() + "_RR", "lnSerial", isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "lnParallel", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "lnParallel", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "lnParallel", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "lnParallel", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "lnParallel", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "lnParallel", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "lnParallel", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "lnParallel", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial" });
@@ -729,9 +729,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "startSender", new Object[] { "lnParallel" });
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "lnParallel" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
- vm5.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm5.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
//verify all buckets drained on all sender nodes.
@@ -741,9 +741,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"lnParallel"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
}
public void testPartitionedParallelPropagationToTwoWanSites()
@@ -781,13 +781,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
3, true, 100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "lnParallel1,lnParallel2", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "lnParallel1,lnParallel2", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "lnParallel1,lnParallel2", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "lnParallel1,lnParallel2", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "lnParallel1,lnParallel2", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "lnParallel1,lnParallel2", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "lnParallel1,lnParallel2", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "lnParallel1,lnParallel2", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "lnParallel1" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "lnParallel1" });
@@ -800,9 +800,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "lnParallel2" });
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() });
//before doing puts, make sure that the senders are started.
//this will ensure that not a single events is lost
@@ -817,7 +817,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "lnParallel2" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
//verify all buckets drained on all sender nodes.
@@ -833,9 +833,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"lnParallel2"});
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 });
}
public void testPartitionedParallelPropagationHA() throws Exception {
@@ -870,13 +870,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] { "ln", true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 2, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 2, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 2, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 2, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 2, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 2, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 2, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 2, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -884,16 +884,16 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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() });
AsyncInvocation inv1 = vm7.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { testName + "_PR", 5000 });
+ new Object[] { getTestMethodName() + "_PR", 5000 });
Wait.pause(500);
AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "killSender");
AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { testName + "_PR", 10000 });
+ new Object[] { getTestMethodName() + "_PR", 10000 });
Wait.pause(1500);
AsyncInvocation inv4 = vm5.invokeAsync(WANTestBase.class, "killSender");
inv1.join();
@@ -902,18 +902,18 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
inv4.join();
vm6.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 10000 });
+ getTestMethodName() + "_PR", 10000 });
vm7.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 10000 });
+ getTestMethodName() + "_PR", 10000 });
//verify all buckets drained on the sender nodes that up and running.
vm6.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
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 });
}
public void testParallelPropagationWithFilter() throws Exception {
@@ -944,13 +944,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
new MyGatewayEventFilter(), true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -958,9 +958,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
//wait for senders to be running before doing any puts. This will ensure that
//not a single events is lost
@@ -969,10 +969,10 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName, 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 800 });
+ getTestMethodName(), 800 });
}
@@ -1001,13 +1001,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
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, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -1015,9 +1015,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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() });
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
@@ -1026,7 +1026,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPutAll", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPutAll", new Object[] { getTestMethodName() + "_PR",
100 , 50 });
//verify all buckets drained on all sender nodes.
@@ -1036,7 +1036,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 5000 });
+ getTestMethodName() + "_PR", 5000 });
}
@@ -1071,13 +1071,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 100, false, false, null, true });
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, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -1085,9 +1085,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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() });
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
@@ -1103,8 +1103,8 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
Wait.pause(2000);
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR", 1000 });
- vm4.invoke(WANTestBase.class, "doDestroys", new Object[] { testName + "_PR", 500 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 1000 });
+ vm4.invoke(WANTestBase.class, "doDestroys", new Object[] { getTestMethodName() + "_PR", 500 });
vm4.invoke(WANTestBase.class, "validateParallelSenderQueueBucketSize", new Object[] { "ln", 15 });
@@ -1126,9 +1126,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 500 });
+ getTestMethodName() + "_PR", 500 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 500 });
+ getTestMethodName() + "_PR", 500 });
}
@@ -1160,9 +1160,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
// true, 100, 10, false, false, null, true });
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", true, 1, 100, isOffHeap() });
// vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
@@ -1174,9 +1174,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
// vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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() });
//before doing any puts, let the senders be running in order to ensure that
//not a single event will be lost
@@ -1184,7 +1184,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm5.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
// vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
// vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doTxPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doTxPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
//verify all buckets drained on all sender nodes.
@@ -1194,7 +1194,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
// vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 3 });
+ getTestMethodName() + "_PR", 3 });
}
public void disable_testParallelGatewaySenderQueueLocalSize() {
@@ -1214,9 +1214,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -1237,7 +1237,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
// vm5.invoke(WANTestBase.class, "waitForSenderPausedState", new Object[] { "ln" });
Wait.pause(1000);
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
10 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln", 10 });
@@ -1271,9 +1271,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -1294,7 +1294,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
// vm5.invoke(WANTestBase.class, "waitForSenderPausedState", new Object[] { "ln" });
Wait.pause(1000);
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
10 });
vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln", 10 });
@@ -1335,26 +1335,26 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
//create leader (parent) PR on site1
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "PARENT_PR", null, 0, 100, isOffHeap() });
+ getTestMethodName() + "PARENT_PR", null, 0, 100, isOffHeap() });
String parentRegionFullPath =
- (String) vm3.invoke(WANTestBase.class, "getRegionFullPath", new Object[] { testName + "PARENT_PR"});
+ (String) vm3.invoke(WANTestBase.class, "getRegionFullPath", new Object[] { getTestMethodName() + "PARENT_PR"});
//create colocated (child) PR on site1
vm3.invoke(WANTestBase.class, "createColocatedPartitionedRegion", new Object[] {
- testName + "CHILD_PR", "ln", 0, 100, parentRegionFullPath });
+ getTestMethodName() + "CHILD_PR", "ln", 0, 100, parentRegionFullPath });
//create leader and colocated PR on site2
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "PARENT_PR", null, 0, 100, isOffHeap() });
+ getTestMethodName() + "PARENT_PR", null, 0, 100, isOffHeap() });
vm2.invoke(WANTestBase.class, "createColocatedPartitionedRegion", new Object[] {
- testName + "CHILD_PR", null, 0, 100, parentRegionFullPath });
+ getTestMethodName() + "CHILD_PR", null, 0, 100, parentRegionFullPath });
//do puts in colocated (child) PR on site1
- vm3.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "CHILD_PR", 1000 });
+ vm3.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "CHILD_PR", 1000 });
//verify the puts reach site2
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "CHILD_PR", 1000 });
+ getTestMethodName() + "CHILD_PR", 1000 });
}
public void testParallelPropagationWithFilter_AfterAck() throws Exception {
@@ -1381,13 +1381,13 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
100, 10, false, false, new MyGatewayEventFilter_AfterAck(), true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 1, 100, isOffHeap() });
+ getTestMethodName(), "ln", 1, 100, isOffHeap() });
vm2.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -1395,9 +1395,9 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
// wait for senders to be running before doing any puts. This will ensure
// that
@@ -1411,7 +1411,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
vm5.invoke(WANTestBase.class, "waitForSenderRunningState",
new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName, 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 });
vm2.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln",
0 });
@@ -1423,18 +1423,18 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase {
0 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 1000 });
+ getTestMethodName(), 1000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 1000 });
+ getTestMethodName(), 1000 });
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 1000 });
+ getTestMethodName(), 1000 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 1000 });
+ getTestMethodName(), 1000 });
vm6.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 1000 });
+ getTestMethodName(), 1000 });
vm7.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 1000 });
+ getTestMethodName(), 1000 });
Integer vm2Acks = (Integer)vm2.invoke(WANTestBase.class,
"validateAfterAck", new Object[] { "ln"});
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationLoopBackDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationLoopBackDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationLoopBackDUnitTest.java
index 05d43dc..dff14b1 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationLoopBackDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationLoopBackDUnitTest.java
@@ -75,19 +75,19 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//create PR on site1
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
//create PR on site2
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ny", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ny", 0, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ny", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ny", 0, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ny", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ny", 0, 100, isOffHeap() });
//start sender on site1
vm2.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -113,10 +113,10 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
Wait.pause(1000);
//Do 100 puts on site1
- vm2.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm2.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
100 });
//do next 100 puts on site2
- vm3.invoke(WANTestBase.class, "doPutsFrom", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPutsFrom", new Object[] { getTestMethodName() + "_PR",
100, 200 });
//verify queue size on both sites
vm2.invoke(WANTestBase.class, "verifyQueueSize", new Object[] { "ln", 100 });
@@ -134,7 +134,7 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//validate events reached site2 from site1
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
//on site2, verify queue size again
//this ensures that loopback is not happening since the queue size is same as before
@@ -150,9 +150,9 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//validate region size on both the sites
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
}
/**
@@ -194,17 +194,17 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//create PR on the 3 sites
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ny", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ny", 0, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ny", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ny", 0, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "tk", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "tk", 0, 100, isOffHeap() });
//start senders on all the sites
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -225,11 +225,11 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
Wait.pause(1000);
//do puts on site1
- vm3.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
100 });
//do more puts on site3
- vm5.invoke(WANTestBase.class, "doPutsFrom", new Object[] { testName + "_PR",
+ vm5.invoke(WANTestBase.class, "doPutsFrom", new Object[] { getTestMethodName() + "_PR",
100, 200 });
//verify queue size on site1 and site3
@@ -242,9 +242,9 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//validate region size on site2 (should have 100) and site3 (should have 200)
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 100 });
+ getTestMethodName() + "_PR", 100 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
//verify queue size remains same on site3 which means event loopback did not happen
//this means events coming from site1 are not enqueued back into the sender
@@ -255,11 +255,11 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//validate region size
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
}
/**
@@ -315,17 +315,17 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//create PR
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln1,ln2", 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", "ln1,ln2", 0, 1, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln1,ln2", 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", "ln1,ln2", 0, 1, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ny1,ny2", 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", "ny1,ny2", 0, 1, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ny1,ny2", 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", "ny1,ny2", 0, 1, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "tk1,tk2", 0, 1, isOffHeap() });
+ getTestMethodName() + "_PR", "tk1,tk2", 0, 1, isOffHeap() });
//start all the senders
vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln1" });
@@ -359,7 +359,7 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
Wait.pause(1000);
//do puts on site1
- vm3.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm3.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
100 });
//verify queue size on site1 and site3
@@ -372,7 +372,7 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//validate region size on site2
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 100 });
+ getTestMethodName() + "_PR", 100 });
//verify queue size on site2 (sender 2 to 1)
//should remain at 0 as the events from site1 should not go back to site1
@@ -383,7 +383,7 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
vm4.invoke(WANTestBase.class, "verifyQueueSize", new Object[] { "ny2", 0 });
//do more puts on site3
- vm5.invoke(WANTestBase.class, "doPutsFrom", new Object[] { testName + "_PR",
+ vm5.invoke(WANTestBase.class, "doPutsFrom", new Object[] { getTestMethodName() + "_PR",
100, 200 });
//resume sender (from site3 to site2) on site3
@@ -391,7 +391,7 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//validate region size on site2
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
//verify queue size on site2 (sender 2 to 3)
//should remain at 0 as the events from site3 should not go back to site3
@@ -414,11 +414,11 @@ public class ParallelWANPropagationLoopBackDUnitTest extends WANTestBase {
//validate region size on all sites
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 200 });
+ getTestMethodName() + "_PR", 200 });
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
index 54c6bc7..79e5574 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
@@ -62,13 +62,13 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
true, 100, 10, true, false, null, true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -83,9 +83,9 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
Wait.pause(2000);
@@ -95,7 +95,7 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
keyValues.put(i, i);
}
- vm4.invoke(WANTestBase.class, "putGivenKeyValue", new Object[] { testName, keyValues });
+ vm4.invoke(WANTestBase.class, "putGivenKeyValue", new Object[] { getTestMethodName(), keyValues });
vm4.invoke(WANTestBase.class, "checkQueueSize", new Object[] { "ln", keyValues.size() });
@@ -141,27 +141,27 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
ArrayList<Integer> v4List = (ArrayList<Integer>)vm4.invoke(
@@ -206,27 +206,27 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 3, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 3, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 3, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 3, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 3, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 3, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 3, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 3, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 1000 });
+ getTestMethodName() + "_PR", 1000 });
ArrayList<Integer> v4List = (ArrayList<Integer>)vm4.invoke(
WANTestBase.class, "getSenderStats", new Object[] { "ln", 0 });
@@ -266,25 +266,25 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
3, true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln1,ln2", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln1,ln2", 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln1" });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln2" });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR",
1000 });
Wait.pause(10000);
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 });
ArrayList<Integer> v4Sender1List = (ArrayList<Integer>)vm4.invoke(
WANTestBase.class, "getSenderStats", new Object[] { "ln1", 0 });
@@ -333,16 +333,16 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 3, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 3, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 3, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 3, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 3, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 3, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 3, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 3, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -350,14 +350,14 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
AsyncInvocation inv1 = vm5.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { testName + "_PR", 10000 });
+ new Object[] { getTestMethodName() + "_PR", 10000 });
Wait.pause(2000);
AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "killSender");
inv1.join();
inv2.join();
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 10000 });
+ getTestMethodName() + "_PR", 10000 });
ArrayList<Integer> v5List = (ArrayList<Integer>)vm5.invoke(
WANTestBase.class, "getSenderStats", new Object[] { "ln", 0});
@@ -413,19 +413,19 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
true, 100, 10, false, false, null, true });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", null, 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", null, 0, 100, isOffHeap() });
vm2.invoke(WANTestBase.class, "addCacheListenerAndDestroyRegion", new Object[] {
- testName + "_PR"});
+ getTestMethodName() + "_PR"});
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR", "ln", 0, 100, isOffHeap() });
+ getTestMethodName() + "_PR", "ln", 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -433,11 +433,11 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
//start puts in RR_1 in another thread
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR", 20000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", 20000 });
//verify that all is well in local site. All the events should be present in local region
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 20000 });
+ getTestMethodName() + "_PR", 20000 });
ArrayList<Integer> v4List = (ArrayList<Integer>)vm5.invoke(
WANTestBase.class, "getSenderStats", new Object[] { "ln", -1});
@@ -481,13 +481,13 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
new MyGatewayEventFilter(), true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -495,12 +495,12 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName, 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName(), 1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 800 });
+ getTestMethodName(), 800 });
ArrayList<Integer> v4List = (ArrayList<Integer>)vm4.invoke(
WANTestBase.class, "getSenderStats", new Object[] { "ln", 0 });
@@ -545,13 +545,13 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
true, 100, 10, true, false, null, true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, "ln", 0, 100, isOffHeap() });
+ getTestMethodName(), "ln", 0, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -566,7 +566,7 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName, null, 1, 100, isOffHeap() });
+ getTestMethodName(), null, 1, 100, isOffHeap() });
Wait.pause(2000);
@@ -576,24 +576,24 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
keyValues.put(i, i);
}
- vm4.invoke(WANTestBase.class, "putGivenKeyValue", new Object[] { testName, keyValues });
+ vm4.invoke(WANTestBase.class, "putGivenKeyValue", new Object[] { getTestMethodName(), keyValues });
vm4.invoke(WANTestBase.class, "checkQueueSize", new Object[] { "ln", keyValues.size() });
for(int i=0;i<500;i++) {
updateKeyValues.put(i, i+"_updated");
}
- vm4.invoke(WANTestBase.class, "putGivenKeyValue", new Object[] { testName, updateKeyValues });
+ vm4.invoke(WANTestBase.class, "putGivenKeyValue", new Object[] { getTestMethodName(), updateKeyValues });
vm4.invoke(WANTestBase.class, "checkQueueSize", new Object[] { "ln", keyValues.size() + updateKeyValues.size() /*creates aren't conflated*/ });
// Do the puts again. Since these are updates, the previous updates will be conflated.
- vm4.invoke(WANTestBase.class, "putGivenKeyValue", new Object[] { testName, updateKeyValues });
+ vm4.invoke(WANTestBase.class, "putGivenKeyValue", new Object[] { getTestMethodName(), updateKeyValues });
vm4.invoke(WANTestBase.class, "checkQueueSize", new Object[] { "ln", keyValues.size() + updateKeyValues.size() /*creates aren't conflated*/ });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 0 });
+ getTestMethodName(), 0 });
vm2.invoke(WANTestBase.class, "checkGatewayReceiverStats", new Object[] {0, 0, 0});
@@ -604,10 +604,10 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{
keyValues.putAll(updateKeyValues);
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, keyValues.size() });
+ getTestMethodName(), keyValues.size() });
vm2.invoke(WANTestBase.class, "validateRegionContents", new Object[] {
- testName, keyValues });
+ getTestMethodName(), keyValues });
vm2.invoke(WANTestBase.class, "checkGatewayReceiverStats", new Object[] {0, 1500, 1000});