You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by pe...@apache.org on 2009/05/15 12:28:29 UTC
svn commit: r775080 - in
/tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster:
mcast/McastServiceImpl.java membership/McastServiceImpl.java
Author: pero
Date: Fri May 15 10:28:29 2009
New Revision: 775080
URL: http://svn.apache.org/viewvc?rev=775080&view=rev
Log:
reset loopback=true that cluster member from same machine can communicate
Modified:
tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/mcast/McastServiceImpl.java
tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/membership/McastServiceImpl.java
Modified: tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/mcast/McastServiceImpl.java
URL: http://svn.apache.org/viewvc/tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/mcast/McastServiceImpl.java?rev=775080&r1=775079&r2=775080&view=diff
==============================================================================
--- tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/mcast/McastServiceImpl.java (original)
+++ tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/mcast/McastServiceImpl.java Fri May 15 10:28:29 2009
@@ -170,7 +170,8 @@
protected void setupSocket() throws IOException {
if (mcastBindAddress != null) {
try {
- log.info("Attempting to bind the multicast socket to "+address+":"+port);
+ if(log.isInfoEnabled())
+ log.info("Attempting to bind the multicast socket to "+address+":"+port);
socket = new MulticastSocket(new InetSocketAddress(address,port));
} catch (BindException e) {
/*
@@ -178,13 +179,13 @@
* to the multicast address. In this case only bind to the
* port.
*/
- log.info("Binding to multicast address, failed. Binding to port only.");
+ log.warn("Binding to multicast address, failed. Binding to port only.");
socket = new MulticastSocket(port);
}
} else {
socket = new MulticastSocket(port);
}
- socket.setLoopbackMode(true); //hint that we don't need loop back messages
+ socket.setLoopbackMode(false); //hint that we don't need loop back messages
if (mcastBindAddress != null) {
if(log.isInfoEnabled())
log.info("Setting multihome multicast interface to:" +
Modified: tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/membership/McastServiceImpl.java
URL: http://svn.apache.org/viewvc/tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/membership/McastServiceImpl.java?rev=775080&r1=775079&r2=775080&view=diff
==============================================================================
--- tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/membership/McastServiceImpl.java (original)
+++ tomcat/sandbox/tomcat-oacc/trunk/src/share/org/apache/catalina/cluster/membership/McastServiceImpl.java Fri May 15 10:28:29 2009
@@ -182,7 +182,8 @@
protected void setupSocket() throws IOException {
if (mcastBindAddress != null) {
try {
- log.info("Attempting to bind the multicast socket to "+address+":"+port);
+ if(log.isInfoEnabled())
+ log.info("Attempting to bind the multicast socket to "+address+":"+port);
socket = new MulticastSocket(new InetSocketAddress(address,port));
} catch (BindException e) {
/*
@@ -190,13 +191,13 @@
* to the multicast address. In this case only bind to the
* port.
*/
- log.info("Binding to multicast address, failed. Binding to port only.");
+ log.warn("Binding to multicast address, failed. Binding to port only.");
socket = new MulticastSocket(port);
}
} else {
socket = new MulticastSocket(port);
}
- socket.setLoopbackMode(true); //hint that we don't need loop back messages
+ socket.setLoopbackMode(false); //hint that we don't need loop back messages
if (mcastBindAddress != null) {
if(log.isInfoEnabled())
log.info("Setting multihome multicast interface to:" +
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org