Author: remm Date: Wed Nov 28 22:32:57 2018 New Revision: 1847685 URL: http://svn.apache.org/viewvc?rev=1847685&view=rev Log: Copy code from static provider to remove a todo
Modified: tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java Modified: tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java?rev=1847685&r1=1847684&r2=1847685&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java (original) +++ tomcat/trunk/java/org/apache/catalina/tribes/membership/cloud/CloudMembershipProvider.java Wed Nov 28 22:32:57 2018 @@ -55,6 +55,8 @@ public abstract class CloudMembershipPro protected int port; protected String hostName; + protected long expirationTime = 5000; + public CloudMembershipProvider() { try { md5 = MessageDigest.getInstance("md5"); @@ -87,6 +89,8 @@ public abstract class CloudMembershipPro hostName = InetAddress.getLocalHost().getHostName(); port = Integer.parseInt(properties.getProperty("tcpListenPort")); + + expirationTime = Long.parseLong(properties.getProperty("expirationTime", "5000")); } @Override @@ -127,7 +131,7 @@ public abstract class CloudMembershipPro } } // Remove non refreshed members from the membership - Member[] expired = membership.expire(100); // TODO: is 100ms a good value? + Member[] expired = membership.expire(expirationTime); for (Member member : expired) { if (log.isDebugEnabled()) { log.debug("Member disappeared: " + member); --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org