[geode] branch develop updated: GEODE-3131: Awaitility clause added to reference count verification.

[nnag]

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

nnag 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 ac071ee  GEODE-3131: Awaitility clause added to reference count 
verification.
ac071ee is described below

commit ac071eede5d4a7bc20483f8deeadf2844685a62c
Author: nabarun <n...@pivotal.io>
AuthorDate: Fri Oct 6 11:07:20 2017 -0700

    GEODE-3131: Awaitility clause added to reference count verification.
---
 .../internal/cache/ha/HARQueueNewImplDUnitTest.java      | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git 
a/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARQueueNewImplDUnitTest.java
 
b/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARQueueNewImplDUnitTest.java
index 4f70144..d85d945 100755
--- 
a/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARQueueNewImplDUnitTest.java
+++ 
b/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARQueueNewImplDUnitTest.java
@@ -1071,13 +1071,15 @@ public class HARQueueNewImplDUnitTest extends 
JUnit4DistributedTestCase {
 
       Iterator iter = msgsRegion.entrySet().iterator();
       while (iter.hasNext()) {
-        Region.Entry entry = (Region.Entry) iter.next();
-        HAEventWrapper wrapper = (HAEventWrapper) entry.getKey();
-        ClientUpdateMessage cum = (ClientUpdateMessage) entry.getValue();
-        Object key = cum.getKeyOfInterest();
-        logger.fine("key<feedCount, regionCount>: " + key + "<" + ((Long) 
map.get(key)).longValue()
-            + ", " + wrapper.getReferenceCount() + ">");
-        assertEquals(((Long) map.get(key)).longValue(), 
wrapper.getReferenceCount());
+        Awaitility.await().atMost(60, TimeUnit.SECONDS).until(() -> {
+          Region.Entry entry = (Region.Entry) iter.next();
+          HAEventWrapper wrapper = (HAEventWrapper) entry.getKey();
+          ClientUpdateMessage cum = (ClientUpdateMessage) entry.getValue();
+          Object key = cum.getKeyOfInterest();
+          logger.fine("key<feedCount, regionCount>: " + key + "<"
+              + ((Long) map.get(key)).longValue() + ", " + 
wrapper.getReferenceCount() + ">");
+          assertEquals(((Long) map.get(key)).longValue(), 
wrapper.getReferenceCount());
+        });
       }
     } catch (Exception e) {
       fail("failed in verifyQueueData()" + e);

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