[geode] branch develop updated: GEODE-3919: Changed test to wait for the appropriate queue size since conflation is async

[bo...@apache.org]

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

boglesby pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/develop by this push:
     new fd907a0  GEODE-3919: Changed test to wait for the appropriate queue size since conflation is async
fd907a0 is described below

commit fd907a00ae1c5b42affbb9db63a1f8caabdb4178
Author: Barry Oglesby <bo...@users.noreply.github.com>
AuthorDate: Mon Oct 30 15:29:48 2017 -0700

    GEODE-3919: Changed test to wait for the appropriate queue size since conflation is async
---
 .../java/org/apache/geode/internal/cache/wan/WANTestBase.java     | 8 +-------
 .../internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java    | 4 ++--
 2 files changed, 3 insertions(+), 9 deletions(-)

diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/WANTestBase.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/WANTestBase.java
index 0b06a60..f3d0358 100644
--- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/WANTestBase.java
+++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/WANTestBase.java
@@ -2547,13 +2547,7 @@ public class WANTestBase extends JUnit4DistributedTestCase {
   }
 
   public static void testQueueSize(String senderId, int numQueueEntries) {
-    GatewaySender sender = null;
-    for (GatewaySender s : cache.getGatewaySenders()) {
-      if (s.getId().equals(senderId)) {
-        sender = s;
-        break;
-      }
-    }
+    GatewaySender sender = cache.getGatewaySender(senderId);
     if (sender.isParallel()) {
       int totalSize = 0;
       Set<RegionQueue> queues = ((AbstractGatewaySender) sender).getQueues();
diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
index 2a90308..e2df453 100644
--- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
+++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
@@ -505,8 +505,8 @@ public class ParallelWANStatsDUnitTest extends WANTestBase {
     int numIterations = 100;
     vm1.invoke(() -> putSameEntry(regionName, numIterations));
 
-    // Verify queue size (no need to wait)
-    vm1.invoke(() -> testQueueSize(senderId, 2));
+    // Wait for appropriate queue size
+    vm1.invoke(() -> checkQueueSize(senderId, 2));
 
     // Verify the conflation indexes size stat
     verifyConflationIndexesSize(senderId, 1, vm1);

-- 
To stop receiving notification emails like this one, please contact
['"commits@geode.apache.org" <co...@geode.apache.org>'].