You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by jf...@apache.org on 2009/04/06 18:40:13 UTC
svn commit: r762411 -
/tomcat/trunk/java/org/apache/catalina/cluster/HeartbeatListener.java
Author: jfclere
Date: Mon Apr 6 16:40:12 2009
New Revision: 762411
URL: http://svn.apache.org/viewvc?rev=762411&view=rev
Log:
Arrange the code according to Rainer's comments.
Modified:
tomcat/trunk/java/org/apache/catalina/cluster/HeartbeatListener.java
Modified: tomcat/trunk/java/org/apache/catalina/cluster/HeartbeatListener.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/cluster/HeartbeatListener.java?rev=762411&r1=762410&r2=762411&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/cluster/HeartbeatListener.java (original)
+++ tomcat/trunk/java/org/apache/catalina/cluster/HeartbeatListener.java Mon Apr 6 16:40:12 2009
@@ -46,7 +46,7 @@
public class HeartbeatListener
implements LifecycleListener, ContainerListener {
- public static Log log = LogFactory.getLog(HeartbeatListener.class);
+ private static Log log = LogFactory.getLog(HeartbeatListener.class);
/* To allow to select the connector */
int port = 0;
@@ -59,9 +59,14 @@
InetAddress group = null;
String ip = "224.0.1.105"; /* Multicast IP */
int multiport = 23364; /* Multicast Port */
+ int ttl = 16;
public void setGroup(String ip) { this.ip = ip; }
+ public String getGroup() { return ip; }
public void setMultiport(int multiport) { this.multiport = multiport; }
+ public int getMultiport() { return multiport; }
+ public void setTtl(int ttl) { this.ttl = ttl; }
+ public int getTtl() { return ttl; }
private CollectedInfo coll = null;
@@ -83,10 +88,8 @@
return;
}
}
-// * *msg_format = "v=%u&ready=%u&busy=%u"; (message to send).
-// v = version (1)
-// ready & ready are read from the scoreboard in httpd.
-// Endpoint ( getCurrentThreadsBusy ) ( getMaxThreads )
+
+ /* Read busy and ready */
if (coll == null) {
try {
coll = new CollectedInfo(host, port);
@@ -116,7 +119,6 @@
s.send(data);
} catch (Exception ex) {
log.error("Unable to send colllected load information: " + ex);
- System.out.println(ex);
s.close();
s = null;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org