activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r803465 - /activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java
Date Wed, 12 Aug 2009 12:03:17 GMT
Author: dejanb
Date: Wed Aug 12 12:03:17 2009
New Revision: 803465

URL: http://svn.apache.org/viewvc?rev=803465&view=rev
Log:
fix for intermittent failure of org.apache.activegroups.GroupStateTest.testExpire test

Modified:
    activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java

Modified: activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java?rev=803465&r1=803464&r2=803465&view=diff
==============================================================================
--- activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java (original)
+++ activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java Wed Aug
12 12:03:17 2009
@@ -1340,8 +1340,8 @@
 
     void checkMembership() {
         if (this.started.get() && this.electionFinished.get()) {
-            long checkTime = System.currentTimeMillis() - getHeartBeatInterval();
-            boolean doElection = false;
+            long checkTime = System.currentTimeMillis() - (2 * getHeartBeatInterval()); //
give it a bit more time since scheduler can be late
+        	boolean doElection = false;
             for (Member member : this.members.values()) {
                 if (member.getTimeStamp() < checkTime) {
                     LOG.info("Member timestamp expired " + member);



Mime
View raw message