[geode] branch feature/GEODE-4647 updated: GEODE-4647: fix a test case

[zhouxj]

This is an automated email from the ASF dual-hosted git repository.

zhouxj pushed a commit to branch feature/GEODE-4647
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-4647 by this 
push:
     new 4f580b2  GEODE-4647: fix a test case
4f580b2 is described below

commit 4f580b27ac38bab4215c6f2afc61a7870274834f
Author: zhouxh <gz...@pivotal.io>
AuthorDate: Fri Mar 16 15:11:22 2018 -0700

    GEODE-4647: fix a test case
---
 .../cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java         | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
 
b/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
index aa1db53..442ef9f 100644
--- 
a/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
+++ 
b/geode-core/src/test/java/org/apache/geode/internal/cache/wan/asyncqueue/AsyncEventListenerDUnitTest.java
@@ -1521,8 +1521,8 @@ public class AsyncEventListenerDUnitTest extends 
AsyncEventQueueTestBase {
     LogWriterUtils.getLogWriter().info("Primary buckets on vm2: " + 
primaryBucketsvm2);
 
     // before shutdown vm2, both vm1 and vm2 should have 40 events in primary 
queue
-    vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
40, 80, 80, 0));
-    vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
40, 80, 80, 0));
+    vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
40, 40, 80, 80, 0));
+    vm2.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
40, 40, 80, 80, 0));
 
     // ---------------------------- Kill vm2 --------------------------
     vm2.invoke(() -> AsyncEventQueueTestBase.killSender());
@@ -1549,8 +1549,8 @@ public class AsyncEventListenerDUnitTest extends 
AsyncEventQueueTestBase {
         .info("After shutdown vm2, started vm3, Primary buckets on vm1: " + 
primaryBucketsvm1);
 
     // vm1.invoke(()->AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
80, 80, 80, 0));
-    vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
40, 80, 80, 0));
-    vm3.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
40, 0, 0, 0));
+    vm1.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
40, 40, 80, 80, 0));
+    vm3.invoke(() -> AsyncEventQueueTestBase.checkAsyncEventQueueStats("ln", 
40, 40, 0, 0, 0));
 
     vm3.invoke(() -> AsyncEventQueueTestBase.resumeAsyncEventQueue("ln"));
     vm1.invoke(() -> AsyncEventQueueTestBase.resumeAsyncEventQueue("ln"));

-- 
To stop receiving notification emails like this one, please contact
zho...@apache.org.