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/05/04 22:57:26 UTC
[26/63] [abbrv] incubator-geode git commit: GEODE-1262: Removed
VM5-VM7 in AsyncEventQueueTestBase
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/ecbbf766/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventQueueStatsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventQueueStatsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventQueueStatsDUnitTest.java
index cd11ae9..8972595 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventQueueStatsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/asyncqueue/AsyncEventQueueStatsDUnitTest.java
@@ -37,37 +37,37 @@ public class AsyncEventQueueStatsDUnitTest extends AsyncEventQueueTestBase {
public void testReplicatedSerialPropagation() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm2.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm3.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
+ vm1.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 1000 ));// primary sender
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 1000 ));// primary sender
Wait.pause(2000);//give some time for system to become stable
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
"ln", 0, 1000, 1000, 1000 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln", 10 ));
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln", 10 ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
"ln", 0, 1000, 0, 0 ));
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln", 0 ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln", 0 ));
}
/**
@@ -76,53 +76,53 @@ public class AsyncEventQueueStatsDUnitTest extends AsyncEventQueueTestBase {
public void testAsyncStatsTwoListeners() throws Exception {
Integer lnPort = createFirstLocatorWithDSId(1);
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln1",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln1",
false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln1",
+ vm2.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln1",
false, 100, 100, false, false, null, false ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln1",
+ vm3.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln1",
false, 100, 100, false, false, null, false ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln1",
+ vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln1",
false, 100, 100, false, false, null, false ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln2",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln2",
false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln2",
+ vm2.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln2",
false, 100, 100, false, false, null, false ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln2",
+ vm3.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln2",
false, 100, 100, false, false, null, false ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln2",
+ vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln2",
false, 100, 100, false, false, null, false ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() ));
vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() ));
- vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
+ vm1.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
1000 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln1", 1000 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln2", 1000 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln1", 1000 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln2", 1000 ));
Wait.pause(2000);//give some time for system to become stable
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
"ln1", 0, 1000, 1000, 1000 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln1", 10 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln1", 10 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
"ln2", 0, 1000, 1000, 1000 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln2", 10 ));
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln2", 10 ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
"ln1", 0, 1000, 0, 0 ));
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln1", 0 ));
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln1", 0 ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
"ln2", 0, 1000, 0, 0 ));
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln2", 0 ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueBatchStats( "ln2", 0 ));
}
/**
@@ -131,28 +131,28 @@ public class AsyncEventQueueStatsDUnitTest extends AsyncEventQueueTestBase {
public void testReplicatedSerialPropagationHA() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache(lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm2.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm1.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm2.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm3.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR", "ln", isOffHeap() ));
- AsyncInvocation inv1 = vm5.invokeAsync(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR", 10000 ));
+ AsyncInvocation inv1 = vm2.invokeAsync(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR", 10000 ));
Wait.pause(2000);
- AsyncInvocation inv2 = vm4.invokeAsync(() -> AsyncEventQueueTestBase.killAsyncEventQueue( "ln" ));
+ AsyncInvocation inv2 = vm1.invokeAsync(() -> AsyncEventQueueTestBase.killAsyncEventQueue( "ln" ));
Boolean isKilled = Boolean.FALSE;
try {
isKilled = (Boolean)inv2.getResult();
@@ -162,13 +162,13 @@ public class AsyncEventQueueStatsDUnitTest extends AsyncEventQueueTestBase {
}
AsyncInvocation inv3 = null;
if(!isKilled){
- inv3 = vm5.invokeAsync(() -> AsyncEventQueueTestBase.killSender( "ln" ));
+ inv3 = vm2.invokeAsync(() -> AsyncEventQueueTestBase.killSender( "ln" ));
inv3.join();
}
inv1.join();
inv2.join();
Wait.pause(2000);//give some time for system to become stable
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats_Failover("ln", 10000));
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats_Failover("ln", 10000));
}
/**
@@ -177,52 +177,52 @@ public class AsyncEventQueueStatsDUnitTest extends AsyncEventQueueTestBase {
public void testReplicatedSerialPropagationUNPorcessedEvents() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm2.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, false, false, null, false ));
//create one RR (RR_1) on local site
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm1.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm2.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm3.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR_1", "ln", isOffHeap() ));
//create another RR (RR_2) on local site
- vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm1.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm2.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm3.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
+ vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue(
getTestMethodName() + "_RR_2", "ln", isOffHeap() ));
//start puts in RR_1 in another thread
- vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR_1", 1000 ));
//do puts in RR_2 in main thread
- vm4.invoke(() -> AsyncEventQueueTestBase.doPutsFrom( getTestMethodName() + "_RR_2", 1000, 1500 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.doPutsFrom( getTestMethodName() + "_RR_2", 1000, 1500 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 1500 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 1500 ));
Wait.pause(2000);//give some time for system to become stable
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln",
0, 1500, 1500, 1500));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueUnprocessedStats("ln", 0));
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueUnprocessedStats("ln", 0));
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln",
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln",
0, 1500, 0, 0));
- vm5.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueUnprocessedStats("ln", 1500));
+ vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueUnprocessedStats("ln", 1500));
}
/**
@@ -231,20 +231,20 @@ public class AsyncEventQueueStatsDUnitTest extends AsyncEventQueueTestBase {
public void testSerialPropagationConflation() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
false, 100, 100, true, false, null, false ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm4
+ vm1
.invoke(() -> AsyncEventQueueTestBase.pauseAsyncEventQueue( "ln" ));
//pause at least for the batchTimeInterval to make sure that the AsyncEventQueue is actually paused
Wait.pause(2000);
@@ -255,8 +255,8 @@ public class AsyncEventQueueStatsDUnitTest extends AsyncEventQueueTestBase {
keyValues.put(i, i);
}
- vm4.invoke(() -> AsyncEventQueueTestBase.putGivenKeyValue( getTestMethodName() + "_RR", keyValues ));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueSize( "ln", keyValues.size() ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.putGivenKeyValue( getTestMethodName() + "_RR", keyValues ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueSize( "ln", keyValues.size() ));
for(int i=0;i<500;i++) {
updateKeyValues.put(i, i+"_updated");
@@ -264,22 +264,22 @@ public class AsyncEventQueueStatsDUnitTest extends AsyncEventQueueTestBase {
// Put the update events and check the queue size.
// There should be no conflation with the previous create events.
- vm4.invoke(() -> AsyncEventQueueTestBase.putGivenKeyValue( getTestMethodName() + "_RR", updateKeyValues ));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueSize( "ln", keyValues.size() + updateKeyValues.size() ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.putGivenKeyValue( getTestMethodName() + "_RR", updateKeyValues ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueSize( "ln", keyValues.size() + updateKeyValues.size() ));
// Put the update events again and check the queue size.
// There should be conflation with the previous update events.
- vm4.invoke(() -> AsyncEventQueueTestBase.putGivenKeyValue( getTestMethodName() + "_RR", updateKeyValues ));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueSize( "ln", keyValues.size() + updateKeyValues.size() ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.putGivenKeyValue( getTestMethodName() + "_RR", updateKeyValues ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueSize( "ln", keyValues.size() + updateKeyValues.size() ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.resumeAsyncEventQueue( "ln" ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 1000 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.resumeAsyncEventQueue( "ln" ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 1000 ));
Wait.pause(2000);// give some time for system to become stable
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats(
"ln", 0, 2000, 2000, 1000 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueConflatedStats( "ln", 500 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueConflatedStats( "ln", 500 ));
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/ecbbf766/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentAsyncEventQueueDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentAsyncEventQueueDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentAsyncEventQueueDUnitTest.java
index ff11577..3e52393 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentAsyncEventQueueDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/concurrent/ConcurrentAsyncEventQueueDUnitTest.java
@@ -36,35 +36,35 @@ public class ConcurrentAsyncEventQueueDUnitTest extends AsyncEventQueueTestBase
public void testConcurrentSerialAsyncEventQueueAttributes() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 150, true, true, "testDS", true, 5, OrderPolicy.THREAD ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateConcurrentAsyncEventQueueAttributes( "ln", 100, 150, AsyncEventQueueFactoryImpl.DEFAULT_BATCH_TIME_INTERVAL, true, "testDS", true, true, 5, OrderPolicy.THREAD ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateConcurrentAsyncEventQueueAttributes( "ln", 100, 150, AsyncEventQueueFactoryImpl.DEFAULT_BATCH_TIME_INTERVAL, true, "testDS", true, true, 5, OrderPolicy.THREAD ));
}
public void testConcurrentParallelAsyncEventQueueAttributesOrderPolicyKey() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
true, 100, 150, true, true, "testDS", true, 5, OrderPolicy.KEY ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateConcurrentAsyncEventQueueAttributes( "ln", 100, 150, AsyncEventQueueFactoryImpl.DEFAULT_BATCH_TIME_INTERVAL, true, "testDS", true, true, 5, OrderPolicy.KEY ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateConcurrentAsyncEventQueueAttributes( "ln", 100, 150, AsyncEventQueueFactoryImpl.DEFAULT_BATCH_TIME_INTERVAL, true, "testDS", true, true, 5, OrderPolicy.KEY ));
}
public void testConcurrentParallelAsyncEventQueueAttributesOrderPolicyPartition() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
true, 100, 150, true, true, "testDS", true, 5, OrderPolicy.PARTITION ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateConcurrentAsyncEventQueueAttributes( "ln", 100, 150, AsyncEventQueueFactoryImpl.DEFAULT_BATCH_TIME_INTERVAL, true, "testDS", true, true, 5, OrderPolicy.PARTITION ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateConcurrentAsyncEventQueueAttributes( "ln", 100, 150, AsyncEventQueueFactoryImpl.DEFAULT_BATCH_TIME_INTERVAL, true, "testDS", true, true, 5, OrderPolicy.PARTITION ));
}
/**
@@ -79,37 +79,37 @@ public class ConcurrentAsyncEventQueueDUnitTest extends AsyncEventQueueTestBase
public void testReplicatedSerialAsyncEventQueueWithMultipleDispatcherThreadsOrderPolicyKey() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 10, true, false, null, false, 3, OrderPolicy.KEY ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm2.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 10, true, false, null, false, 3, OrderPolicy.KEY ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm3.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 10, true, false, null, false, 3, OrderPolicy.KEY ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 10, true, false, null, false, 3, OrderPolicy.KEY ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
+ vm1.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
100 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
vm4.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm5.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm6.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm7.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 100 ));// primary sender
- vm5.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
- vm6.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
- vm7.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 100 ));// primary sender
+ vm2.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
+ vm3.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
+ vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
}
/**
@@ -124,30 +124,30 @@ public class ConcurrentAsyncEventQueueDUnitTest extends AsyncEventQueueTestBase
public void testReplicatedSerialAsyncEventQueueWithMultipleDispatcherThreadsOrderPolicyThread() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 10, true, false, null, false, 3, OrderPolicy.THREAD ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm2.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 10, true, false, null, false, 3, OrderPolicy.THREAD ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm3.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 10, true, false, null, false, 3, OrderPolicy.THREAD ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
false, 100, 10, true, false, null, false, 3, OrderPolicy.THREAD ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
vm4.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createReplicatedRegionWithAsyncEventQueue( getTestMethodName() + "_RR", "ln", isOffHeap() ));
- AsyncInvocation inv1 = vm4.invokeAsync(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
+ AsyncInvocation inv1 = vm1.invokeAsync(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_RR",
50 ));
- AsyncInvocation inv2 = vm4.invokeAsync(() -> AsyncEventQueueTestBase.doNextPuts( getTestMethodName() + "_RR",
+ AsyncInvocation inv2 = vm1.invokeAsync(() -> AsyncEventQueueTestBase.doNextPuts( getTestMethodName() + "_RR",
50, 100 ));
- AsyncInvocation inv3 = vm4.invokeAsync(() -> AsyncEventQueueTestBase.doNextPuts( getTestMethodName() + "_RR",
+ AsyncInvocation inv3 = vm1.invokeAsync(() -> AsyncEventQueueTestBase.doNextPuts( getTestMethodName() + "_RR",
100, 150 ));
try {
@@ -160,15 +160,15 @@ public class ConcurrentAsyncEventQueueDUnitTest extends AsyncEventQueueTestBase
ie);
}
+ vm1.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
vm4.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm5.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm6.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm7.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
-
- vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 150 ));// primary sender
- vm5.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
- vm6.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
- vm7.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
+
+ vm1.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 150 ));// primary sender
+ vm2.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
+ vm3.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
+ vm4.invoke(() -> AsyncEventQueueTestBase.validateAsyncEventListener( "ln", 0 ));// secondary
}
/**
@@ -183,39 +183,39 @@ public class ConcurrentAsyncEventQueueDUnitTest extends AsyncEventQueueTestBase
public void testPartitionedParallelAsyncEventQueueWithMultipleDispatcherThreadsOrderPolicyKey() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
true, 100, 10, true, false, null, false, 3, OrderPolicy.KEY ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm2.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
true, 100, 10, true, false, null, false, 3, OrderPolicy.KEY ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm3.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
true, 100, 10, true, false, null, false, 3, OrderPolicy.KEY ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
+ vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln",
true, 100, 10, true, false, null, false, 3, OrderPolicy.KEY ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
vm4.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
- vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_PR",
+ vm1.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_PR",
100 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
vm4.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm5.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm6.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm7.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ int vm1size = (Integer)vm1.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln"));
+ int vm2size = (Integer)vm2.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln"));
+ int vm3size = (Integer)vm3.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln"));
int vm4size = (Integer)vm4.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln"));
- int vm5size = (Integer)vm5.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln"));
- int vm6size = (Integer)vm6.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln"));
- int vm7size = (Integer)vm7.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln"));
- assertEquals(vm4size + vm5size + vm6size + vm7size, 100);
+ assertEquals(vm1size + vm2size + vm3size + vm4size, 100);
}
@@ -232,38 +232,38 @@ public class ConcurrentAsyncEventQueueDUnitTest extends AsyncEventQueueTestBase
public void testPartitionedParallelAsyncEventQueueWithMultipleDispatcherThreadsOrderPolicyPartition() {
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln", true, 100, 10, true, false, null, false, 3,
+ vm1.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln", true, 100, 10, true, false, null, false, 3,
OrderPolicy.PARTITION ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln", true, 100, 10, true, false, null, false, 3,
+ vm2.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln", true, 100, 10, true, false, null, false, 3,
OrderPolicy.PARTITION ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln", true, 100, 10, true, false, null, false, 3,
+ vm3.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln", true, 100, 10, true, false, null, false, 3,
OrderPolicy.PARTITION ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln", true, 100, 10, true, false, null, false, 3,
+ vm4.invoke(() -> AsyncEventQueueTestBase.createConcurrentAsyncEventQueue( "ln", true, 100, 10, true, false, null, false, 3,
OrderPolicy.PARTITION ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
vm4.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
- vm5.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
- vm6.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
- vm7.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR", "ln", isOffHeap() ));
- vm4.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_PR",
+ vm1.invoke(() -> AsyncEventQueueTestBase.doPuts( getTestMethodName() + "_PR",
100 ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ vm2.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ vm3.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
vm4.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm5.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm6.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
- vm7.invoke(() -> AsyncEventQueueTestBase.waitForAsyncQueueToGetEmpty( "ln" ));
+ int vm1size = (Integer)vm1.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
+ int vm2size = (Integer)vm2.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
+ int vm3size = (Integer)vm3.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
int vm4size = (Integer)vm4.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
- int vm5size = (Integer)vm5.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
- int vm6size = (Integer)vm6.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
- int vm7size = (Integer)vm7.invoke(() -> AsyncEventQueueTestBase.getAsyncEventListenerMapSize( "ln" ));
- assertEquals(100, vm4size + vm5size + vm6size + vm7size);
+ assertEquals(100, vm1size + vm2size + vm3size + vm4size);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/ecbbf766/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelAsyncEventQueueDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelAsyncEventQueueDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelAsyncEventQueueDUnitTest.java
index 2741760..8a88d43 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelAsyncEventQueueDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/CommonParallelAsyncEventQueueDUnitTest.java
@@ -34,12 +34,12 @@ public class CommonParallelAsyncEventQueueDUnitTest extends AsyncEventQueueTestB
public void testSameSenderWithNonColocatedRegions() throws Exception {
IgnoredException.addIgnoredException("cannot have the same parallel async");
Integer lnPort = (Integer)vm0.invoke(() -> AsyncEventQueueTestBase.createFirstLocatorWithDSId( 1 ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
+ vm1.invoke(() -> AsyncEventQueueTestBase.createCache( lnPort ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createAsyncEventQueue( "ln",
true, 100, 100, false, false, null, false ));
- vm4.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR1", "ln", isOffHeap() ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR1", "ln", isOffHeap() ));
try {
- vm4.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR2", "ln", isOffHeap() ));
+ vm1.invoke(() -> AsyncEventQueueTestBase.createPartitionedRegionWithAsyncEventQueue( getTestMethodName() + "_PR2", "ln", isOffHeap() ));
fail("Expected IllegateStateException : cannot have the same parallel gateway sender");
}
catch (Exception e) {