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:44 UTC
[08/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/concurrent/ConcurrentWANPropogation_1_DUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java
index 2044c75..1248417 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_1_DUnitTest.java
@@ -71,27 +71,27 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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() });
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
vm2.invoke(WANTestBase.class, "createCache", new Object[] { nyPort });
vm3.invoke(WANTestBase.class, "createCache", 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, "createReceiver2",
new Object[] {nyPort });
@@ -99,11 +99,11 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
new Object[] {nyPort });
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
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 });
}
public void testReplicatedSerialPropagation() throws Exception {
@@ -126,29 +126,29 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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, "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 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
}
@@ -175,23 +175,23 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
//---------close local site and build again-----------------------------------------
@@ -201,7 +201,7 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "killSender", new Object[] { });
Integer regionSize =
- (Integer) vm2.invoke(WANTestBase.class, "getRegionSize", new Object[] {testName + "_RR" });
+ (Integer) vm2.invoke(WANTestBase.class, "getRegionSize", new Object[] {getTestMethodName() + "_RR" });
LogWriterSupport.getLogWriter().info("Region size on remote is: " + regionSize);
vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort });
@@ -218,13 +218,13 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
vm5.invoke(WANTestBase.class, "setRemoveFromQueueOnException", new Object[] { "ln", 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" });
@@ -236,15 +236,15 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
//----------------------------------------------------------------------------------
//verify remote site receives all the events
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 });
}
/**
@@ -278,15 +278,15 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
//create one RR (RR_1) on remote site
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", null, isOffHeap() });
+ getTestMethodName() + "_RR_1", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", null, isOffHeap() });
+ getTestMethodName() + "_RR_1", null, isOffHeap() });
//create another RR (RR_2) on remote site
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", null, isOffHeap() });
+ getTestMethodName() + "_RR_2", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", null, isOffHeap() });
+ getTestMethodName() + "_RR_2", null, isOffHeap() });
//start the senders on local site
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -294,30 +294,30 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
//create one RR (RR_1) on local site
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
//create another RR (RR_2) on local site
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { testName + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 1000 });
//do puts in RR_2 in main thread
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR_2", 500 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_2", 500 });
//destroy RR_2 after above puts are complete
- vm4.invoke(WANTestBase.class, "destroyRegion", new Object[] { testName + "_RR_2"});
+ vm4.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_2"});
try {
inv1.join();
@@ -329,9 +329,9 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
Thread.sleep(20);
//vm4.invoke(WANTestBase.class, "verifyQueueSize", new Object[] { "ln", 0 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR_1", 1000 });
+ getTestMethodName() + "_RR_1", 1000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR_2", 500 });
+ getTestMethodName() + "_RR_2", 500 });
}
/**
@@ -365,9 +365,9 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
//create one RR (RR_1) on remote site
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", null, isOffHeap() });
+ getTestMethodName() + "_RR_1", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", null, isOffHeap() });
+ getTestMethodName() + "_RR_1", null, isOffHeap() });
//start the senders on local site
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -375,21 +375,21 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
//create one RR (RR_1) on local site
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { testName + "_RR_1", 10000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 10000 });
//destroy RR_1 in remote site
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { testName + "_RR_1"});
+ vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_1"});
try {
inv1.join();
@@ -400,7 +400,7 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
//verify that all is well in local site. All the events should be present in local region
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR_1", 10000 });
+ getTestMethodName() + "_RR_1", 10000 });
//assuming some events might have been dispatched before the remote region was destroyed,
//sender's region queue will have events less than 1000 but the queue will not be empty.
//NOTE: this much verification might be sufficient in DUnit. Hydra will take care of
@@ -439,15 +439,15 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
//create one RR (RR_1) on remote site
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", null, isOffHeap() });
+ getTestMethodName() + "_RR_1", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", null, isOffHeap() });
+ getTestMethodName() + "_RR_1", null, isOffHeap() });
//create another RR (RR_2) on remote site
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", null, isOffHeap() });
+ getTestMethodName() + "_RR_2", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", null, isOffHeap() });
+ getTestMethodName() + "_RR_2", null, isOffHeap() });
//start the senders on local site
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -455,35 +455,35 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
//create one RR (RR_1) on local site
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
//create another RR (RR_2) on local site
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
//destroy RR_2 on remote site in the middle
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { testName + "_RR_2"});
+ vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName() + "_RR_2"});
//expected exceptions in the logs
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
//start puts in RR_2 in another thread
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR_2", 1000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_2", 1000 });
//start puts in RR_1 in another thread
- AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { testName + "_RR_1", 1000 });
+ AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR_1", 1000 });
try {
inv1.join();
@@ -494,7 +494,7 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
//though region RR_2 is destroyed, RR_1 should still get all the events put in it
//in local site
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR_1", 1000 });
+ getTestMethodName() + "_RR_1", 1000 });
}
@@ -522,15 +522,15 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
// create one RR (RR_1) on remote site
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", null, isOffHeap() });
+ getTestMethodName() + "_RR_1", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", null, isOffHeap() });
+ getTestMethodName() + "_RR_1", null, isOffHeap() });
// create another RR (RR_2) on remote site
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", null, isOffHeap() });
+ getTestMethodName() + "_RR_2", null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", null, isOffHeap() });
+ getTestMethodName() + "_RR_2", null, isOffHeap() });
// start the senders on local site
vm4.invoke(WANTestBase.class, "setRemoveFromQueueOnException",
@@ -544,35 +544,35 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
// create one RR (RR_1) on local site
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_1", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_1", "ln", isOffHeap() });
// create another RR (RR_2) on local site
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR_2", "ln", isOffHeap() });
+ getTestMethodName() + "_RR_2", "ln", isOffHeap() });
IgnoredException.addIgnoredException(BatchException70.class.getName());
IgnoredException.addIgnoredException(ServerOperationException.class.getName());
// start puts in RR_1 in another thread
AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { testName + "_RR_1", 1000 });
+ new Object[] { getTestMethodName() + "_RR_1", 1000 });
// start puts in RR_2 in another thread
AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { testName + "_RR_2", 1000 });
+ new Object[] { getTestMethodName() + "_RR_2", 1000 });
// destroy RR_2 on remote site in the middle
- vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { testName
+ vm2.invoke(WANTestBase.class, "destroyRegion", new Object[] { getTestMethodName()
+ "_RR_2" });
try {
@@ -587,7 +587,7 @@ public class ConcurrentWANPropogation_1_DUnitTest extends WANTestBase {
// in local site
try {
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR_1", 1000 });
+ getTestMethodName() + "_RR_1", 1000 });
} finally {
System.setProperty(
"gemfire.GatewaySender.REMOVE_FROM_QUEUE_ON_EXCEPTION", "False");
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java
index dda86ce..63ab79e 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentWANPropogation_2_DUnitTest.java
@@ -68,29 +68,29 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
false, 50, 5, false, false, null, true, 5, OrderPolicy.KEY });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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, "doHeavyPuts", new Object[] {
- testName + "_RR", 150 });
+ getTestMethodName() + "_RR", 150 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 150 });
+ getTestMethodName() + "_RR", 150 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 150 });
+ getTestMethodName() + "_RR", 150 });
}
public void Bug46921_testSerialReplicatedWanWithPersistence() {
@@ -114,29 +114,29 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
false, 100, 10, false, true, null, true, 5, OrderPolicy.THREAD });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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, "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 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
}
@@ -167,9 +167,9 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
3, false, 100, 10, false, false, null, true, 5 , OrderPolicy.THREAD});
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial1" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial1" });
@@ -178,21 +178,21 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "lnSerial2" });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
+ getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
+ getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
+ getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
+ getTestMethodName() + "_RR", "lnSerial1,lnSerial2", isOffHeap() });
- 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 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
}
public void testReplicatedSerialPropagationHA() throws Exception {
@@ -219,24 +219,24 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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() });
AsyncInvocation inv1 = vm5.invokeAsync(WANTestBase.class, "doPuts",
- new Object[] { testName + "_RR", 10000 });
+ new Object[] { getTestMethodName() + "_RR", 10000 });
Wait.pause(2000);
AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "killSender");
@@ -244,9 +244,9 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
inv2.join();
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 });
}
public void testReplicatedSerialPropagationWithConflation() throws Exception {
@@ -270,29 +270,29 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
false, 100, 1000, true, false, null, true, 5, OrderPolicy.THREAD });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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, "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 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
}
public void testReplicatedSerialPropagationWithParallelThreads()
@@ -317,29 +317,29 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
false, 100, 10, false, false, null, true, 4, OrderPolicy.THREAD });
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() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
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, "doMultiThreadedPuts", new Object[] {
- testName + "_RR", 1000 });
+ getTestMethodName() + "_RR", 1000 });
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 });
}
public void testSerialPropogationWithFilter() throws Exception {
@@ -365,26 +365,26 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD });
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" });
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() });
- 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 });
}
public void testReplicatedSerialPropagationWithFilter() throws Exception {
@@ -410,28 +410,28 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
new MyGatewayEventFilter(), true, 5, OrderPolicy.THREAD });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName, null, isOffHeap() });
+ getTestMethodName(), null, isOffHeap() });
vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName, null, isOffHeap() });
+ getTestMethodName(), null, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName, "ln", isOffHeap() });
+ getTestMethodName(), "ln", isOffHeap() });
vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName, "ln", isOffHeap() });
+ getTestMethodName(), "ln", isOffHeap() });
vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName, "ln", isOffHeap() });
+ getTestMethodName(), "ln", isOffHeap() });
vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName, "ln", isOffHeap() });
+ getTestMethodName(), "ln", 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 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName, 800 });
+ getTestMethodName(), 800 });
}
public void testNormalRegionSerialPropagation() throws Exception {
@@ -451,18 +451,18 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
false, 100, 10, false, false, null, true, 5, OrderPolicy.THREAD });
vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] {
- testName + "_RR", null, isOffHeap() });
+ getTestMethodName() + "_RR", null, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
Wait.pause(500);
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm4.invoke(WANTestBase.class, "createNormalRegion", new Object[] {
- testName + "_RR", "ln" });
+ getTestMethodName() + "_RR", "ln" });
vm5.invoke(WANTestBase.class, "createNormalRegion", new Object[] {
- testName + "_RR", "ln" });
+ getTestMethodName() + "_RR", "ln" });
- vm5.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_RR",
+ vm5.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR",
1000 });
vm4.invoke(WANTestBase.class, "checkQueueStats", new Object[] { "ln", 0,
@@ -472,13 +472,13 @@ public class ConcurrentWANPropogation_2_DUnitTest extends WANTestBase {
1000, 0, 0 });
vm5.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 1000});
+ getTestMethodName() + "_RR", 1000});
vm4.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 0});
+ getTestMethodName() + "_RR", 0});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_RR", 0 });
+ getTestMethodName() + "_RR", 0 });
vm2.invoke(WANTestBase.class, "checkGatewayReceiverStats", new Object[] {0, 0, 0});
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/disttx/DistTXWANDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/disttx/DistTXWANDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/disttx/DistTXWANDUnitTest.java
index 3d868c9..b5d15fe 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/disttx/DistTXWANDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/disttx/DistTXWANDUnitTest.java
@@ -73,27 +73,27 @@ public class DistTXWANDUnitTest extends WANTestBase {
false, 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" });
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, "doDistTXPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doDistTXPuts", new Object[] { getTestMethodName() + "_PR",
50 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 50 });
+ getTestMethodName() + "_PR", 50 });
}
public void testPartitionedSerialPropagation_SenderNotSameAsCoordinator() throws Exception {
@@ -118,27 +118,27 @@ public class DistTXWANDUnitTest extends WANTestBase {
false, 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" });
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() });
- vm6.invoke(WANTestBase.class, "doDistTXPuts", new Object[] { testName + "_PR",
+ vm6.invoke(WANTestBase.class, "doDistTXPuts", new Object[] { getTestMethodName() + "_PR",
50 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 50 });
+ getTestMethodName() + "_PR", 50 });
}
@@ -166,13 +166,13 @@ public class DistTXWANDUnitTest 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" });
@@ -180,9 +180,9 @@ public class DistTXWANDUnitTest 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
@@ -191,7 +191,7 @@ public class DistTXWANDUnitTest extends WANTestBase {
vm6.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
vm7.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
- vm4.invoke(WANTestBase.class, "doDistTXPuts", new Object[] { testName + "_PR",
+ vm4.invoke(WANTestBase.class, "doDistTXPuts", new Object[] { getTestMethodName() + "_PR",
5 });
//verify all buckets drained on all sender nodes.
@@ -201,7 +201,7 @@ public class DistTXWANDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR", 5 });
+ getTestMethodName() + "_PR", 5 });
}
public void testDummy() {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0552f26/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelGatewaySenderDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelGatewaySenderDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelGatewaySenderDUnitTest.java
index ac19679..1cd6846 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelGatewaySenderDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelGatewaySenderDUnitTest.java
@@ -52,10 +52,10 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2,
true, 100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
try {
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
fail("Expected IllegateStateException : cannot have the same parallel gateway sender");
}
catch (Exception e) {
@@ -102,22 +102,22 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
true, 100, 10, false, false, null, true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -125,13 +125,13 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", null, 1, 100, isOffHeap() });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", 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
vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
@@ -139,9 +139,9 @@ public class CommonParallelGatewaySenderDUnitTest 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 + "_PR1",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR1",
1000 });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR2",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR2",
1000 });
//verify all buckets drained on all sender nodes.
@@ -151,9 +151,9 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
vm7.invoke(CommonParallelGatewaySenderDUnitTest.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR1", 1000 });
+ getTestMethodName() + "_PR1", 1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR2", 1000 });
+ getTestMethodName() + "_PR2", 1000 });
}
/**
@@ -190,22 +190,22 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
true, 100, 10, false, true, null, true });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", "ln", 1, 100, isOffHeap() });
vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
@@ -213,13 +213,13 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR1", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR1", null, 1, 100, isOffHeap() });
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName + "_PR2", null, 1, 100, isOffHeap() });
+ getTestMethodName() + "_PR2", 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
vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" });
@@ -227,9 +227,9 @@ public class CommonParallelGatewaySenderDUnitTest 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 + "_PR1",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR1",
1000 });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName + "_PR2",
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR2",
1000 });
//verify all buckets drained on all sender nodes.
@@ -239,9 +239,9 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
vm7.invoke(CommonParallelGatewaySenderDUnitTest.class, "validateParallelSenderQueueAllBucketsDrained", new Object[] {"ln"});
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR1", 1000 });
+ getTestMethodName() + "_PR1", 1000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName + "_PR2", 1000 });
+ getTestMethodName() + "_PR2", 1000 });
}
@@ -291,35 +291,35 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
//create PR on remote site
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", null, 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", null, 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", null, 1, 100, isOffHeap() });
//create PR on remote site
vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", null, 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", null, 1, 100, isOffHeap() });
vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", null, 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", null, 1, 100, isOffHeap() });
//create PR on local site
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", "ln", 1, 100, isOffHeap() });
//create PR on local site
vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", "ln", 1, 100, isOffHeap() });
vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", "ln", 1, 100, isOffHeap() });
vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", "ln", 1, 100, isOffHeap() });
vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", "ln", 1, 100, isOffHeap() });
//start the senders on local site
@@ -341,8 +341,8 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
vm7.invoke(WANTestBase.class, "pauseSender", new Object[] { "ln" });
//start puts in region on local site
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName+"PR1", 3000 });
- vm4.invoke(WANTestBase.class, "doPuts", new Object[] { testName+"PR2", 5000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName()+"PR1", 3000 });
+ vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName()+"PR2", 5000 });
LogWriterSupport.getLogWriter().info("Completed puts in the region");
//--------------------close and rebuild local site -------------------------------------------------
@@ -375,13 +375,13 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
LogWriterSupport.getLogWriter().info("Created the senders back from the disk store.");
//create PR on local site
AsyncInvocation inv1 = vm4.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", "ln", 1, 100, isOffHeap() });
AsyncInvocation inv2 = vm5.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", "ln", 1, 100, isOffHeap() });
AsyncInvocation inv3 = vm6.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", "ln", 1, 100, isOffHeap() });
AsyncInvocation inv4 = vm7.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR1", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR1", "ln", 1, 100, isOffHeap() });
try {
inv1.join();
@@ -394,13 +394,13 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
}
inv1 = vm4.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", "ln", 1, 100, isOffHeap() });
inv2 = vm5.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", "ln", 1, 100, isOffHeap() });
inv3 = vm6.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", "ln", 1, 100, isOffHeap() });
inv4 = vm7.invokeAsync(WANTestBase.class, "createPartitionedRegion", new Object[] {
- testName+"PR2", "ln", 1, 100, isOffHeap() });
+ getTestMethodName()+"PR2", "ln", 1, 100, isOffHeap() });
try {
inv1.join();
@@ -433,14 +433,14 @@ public class CommonParallelGatewaySenderDUnitTest extends WANTestBase {
//----------------------------------------------------------------------------------------------------
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName+"PR1", 3000 });
+ getTestMethodName()+"PR1", 3000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName+"PR1", 3000 });
+ getTestMethodName()+"PR1", 3000 });
vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName+"PR2", 5000 });
+ getTestMethodName()+"PR2", 5000 });
vm3.invoke(WANTestBase.class, "validateRegionSize", new Object[] {
- testName+"PR2", 5000 });
+ getTestMethodName()+"PR2", 5000 });
}
public static void validateParallelSenderQueueAllBucketsDrained(final String senderId) {