You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2016/04/12 19:43:17 UTC

[27/50] [abbrv] incubator-geode git commit: GEODE-704: Added check/wait for interest re-registration to complete after cache-server is restarted.

GEODE-704: Added check/wait for interest re-registration to complete after cache-server is restarted.

CI failure: HAInterestPart2DUnitTest.testRefreshEntriesFromPrimaryWhenDSMDetectsServerLive

In the test client re-registers the interests after cache-server is started and expects
entries to be refreshed (it stops and starts the cache-server, without closing the cache)...
It looks like we are not waiting enough to see the client registration is complete
and events are refreshed (the re-registratin happens with redundancy satisfier thread).

Added wait/check to see interest registration is complete before check is done for the
cache entries...

Testing:
Run the test 100+ times.


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/a7739887
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/a7739887
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/a7739887

Branch: refs/heads/feature/GEODE-1162
Commit: a77398877394a75afc8e0d09598146ccc31eeb3e
Parents: 12efa36
Author: agingade <ag...@pivotal.io>
Authored: Thu Apr 7 10:23:32 2016 -0700
Committer: agingade <ag...@pivotal.io>
Committed: Fri Apr 8 12:36:49 2016 -0700

----------------------------------------------------------------------
 .../internal/cache/tier/sockets/HAInterestPart2DUnitTest.java      | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a7739887/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAInterestPart2DUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAInterestPart2DUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAInterestPart2DUnitTest.java
index 02c3e71..8a30f08 100755
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAInterestPart2DUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/HAInterestPart2DUnitTest.java
@@ -158,6 +158,8 @@ public class HAInterestPart2DUnitTest extends HAInterestTestCase {
     verifyDeadAndLiveServers(0, 1);
     final Region r1 = cache.getRegion(Region.SEPARATOR + REGION_NAME);
     assertNotNull(r1);
+    // Verify for interest registration after cache-server is started.
+    server1.invoke(() -> HAInterestTestCase.verifyInterestRegistration());
 
     WaitCriterion wc = new WaitCriterion() {
       private String excuse;