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-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
