You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by nn...@apache.org on 2017/10/10 21:30:55 UTC
[geode] branch develop updated: GEODE-3131: Awaitility clause added
to reference count verification.
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 <nn...@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" <co...@geode.apache.org>'].