svn commit: r413094 - in /tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/transport: AbstractSender.java ReceiverBase.java

[fhanik]

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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]