[geode] branch develop updated: GEODE-4177: client does not receive all put all creates when servers close cache

[la...@apache.org]

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

ladyvader 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 12307b8  GEODE-4177: client does not receive all put all creates when servers close cache
12307b8 is described below

commit 12307b8ca09029e795767a97e650234a0c7ceb9e
Author: Lynn Hughes-Godfrey <lh...@pivotal.io>
AuthorDate: Wed Jan 3 17:41:26 2018 -0800

    GEODE-4177: client does not receive all put all creates when servers close cache
    
    - Added an Awaitility.await() clause to give the client time to failover to another server
    and process outstanding events.
---
 .../java/org/apache/geode/internal/cache/PutAllCSDUnitTest.java   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/geode-cq/src/test/java/org/apache/geode/internal/cache/PutAllCSDUnitTest.java b/geode-cq/src/test/java/org/apache/geode/internal/cache/PutAllCSDUnitTest.java
index 88dc6d2..4d4d0c3 100755
--- a/geode-cq/src/test/java/org/apache/geode/internal/cache/PutAllCSDUnitTest.java
+++ b/geode-cq/src/test/java/org/apache/geode/internal/cache/PutAllCSDUnitTest.java
@@ -31,7 +31,9 @@ import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 import java.util.Set;
+import java.util.concurrent.TimeUnit;
 
+import org.awaitility.Awaitility;
 import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
@@ -2972,8 +2974,10 @@ public class PutAllCSDUnitTest extends ClientServerTestCase {
       }
     });
 
-    LogWriterUtils.getLogWriter().info("event counters : " + myListener.sc);
-    assertEquals(numberOfEntries, myListener.sc.num_create_event);
+    LogWriterUtils.getLogWriter().info("event counters before wait : " + myListener.sc);
+    Awaitility.await().atMost(10, TimeUnit.SECONDS)
+        .until(() -> assertEquals(numberOfEntries, myListener.sc.num_create_event));
+    LogWriterUtils.getLogWriter().info("event counters after wait : " + myListener.sc);
     assertEquals(0, myListener.sc.num_update_event);
 
     server1.invoke(removeExceptionTag1(expectedExceptions));

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