You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by fh...@apache.org on 2006/06/09 19:13:30 UTC
svn commit: r413094 - in
/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport:
AbstractSender.java ReceiverBase.java
Author: fhanik
Date: Fri Jun 9 10:13:30 2006
New Revision: 413094
URL: http://svn.apache.org/viewvc?rev=413094&view=rev
Log:
Changed timeout to a more reasonable value
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/AbstractSender.java
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/ReceiverBase.java
Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/AbstractSender.java
URL: http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/AbstractSender.java?rev=413094&r1=413093&r2=413094&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/AbstractSender.java (original)
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/AbstractSender.java Fri Jun 9 10:13:30 2006
@@ -44,7 +44,7 @@
private int requestCount = 0;
private long connectTime;
private long keepAliveTime = -1;
- private long timeout = 15000;
+ private long timeout = 3000;
private Member destination;
private InetAddress address;
private int port;
Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/ReceiverBase.java
URL: http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/ReceiverBase.java?rev=413094&r1=413093&r2=413094&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/ReceiverBase.java (original)
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport/ReceiverBase.java Fri Jun 9 10:13:30 2006
@@ -66,7 +66,7 @@
private boolean soLingerOn = true;
private int soLingerTime = 3;
private int soTrafficClass = 0x04 | 0x08 | 0x010;
- private int timeout = 15000; //15 seconds
+ private int timeout = 3000; //3 seconds
private boolean useBufferPool = true;
@@ -166,16 +166,20 @@
* @throws IOException
*/
protected int bind(ServerSocket socket, int portstart, int retries) throws IOException {
+ InetSocketAddress addr = null;
while ( retries > 0 ) {
try {
- InetSocketAddress addr = new InetSocketAddress(getBind(), portstart);
+ addr = new InetSocketAddress(getBind(), portstart);
socket.bind(addr);
setTcpListenPort(portstart);
log.info("Receiver Server Socket bound to:"+addr);
return 0;
}catch ( IOException x) {
retries--;
- if ( retries <= 0 ) throw x;
+ if ( retries <= 0 ) {
+ log.info("Unable to bind server socket to "+addr+" throwing error.");
+ throw x;
+ }
portstart++;
retries = bind(socket,portstart,retries);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org