geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From upthewatersp...@apache.org
Subject [26/50] [abbrv] incubator-geode git commit: GEODE-704: Added check/wait for interest re-registration to complete after cache-server is restarted.
Date Fri, 22 Apr 2016 00:39:06 GMT
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/master
Commit: a77398877394a75afc8e0d09598146ccc31eeb3e
Parents: 12efa36
Author: agingade <agingade@pivotal.io>
Authored: Thu Apr 7 10:23:32 2016 -0700
Committer: agingade <agingade@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;


Mime
View raw message