[jboss-remoting-commits] JBoss Remoting SVN: r5367 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2009-08-18 22:01:05 -0400 (Tue, 18 Aug 2009)
New Revision: 5367

Modified:
   remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java
Log:
JBREM-1120: Added writeTimeout facility; also, corrected some javadoc. 

Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java	2009-08-19 02:00:04 UTC (rev 5366)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java	2009-08-19 02:01:05 UTC (rev 5367)
@@ -95,6 +95,8 @@
    // defaults to -1 as to not have idle timeouts
    protected int idleTimeout = -1;
    protected IdleTimerTask idleTimerTask = null;
+   
+   protected int writeTimeout = -1;
 
    public SocketServerInvoker(InvokerLocator locator)
    {
@@ -376,7 +378,7 @@
    }
 
    /**
-    * @return Value of property serverBindPort.
+    * @return Number of idle ServerThreads
     * @jmx:managed-attribute
     */
    public int getCurrentThreadPoolSize()
@@ -385,7 +387,7 @@
    }
 
    /**
-    * @return Value of property serverBindPort.
+    * @return Number of ServerThreads current executing or waiting on an invocation
     * @jmx:managed-attribute
     */
    public int getCurrentClientPoolSize()
@@ -498,7 +500,17 @@
          }
       }
    }
+   
+   public int getWriteTimeout()
+   {
+      return writeTimeout;
+   }
 
+   public void setWriteTimeout(int writeTimeout)
+   {
+      this.writeTimeout = writeTimeout;
+   }
+
    public void run()
    {
       if(trace) { log.trace(this + " started execution of method run()"); }
@@ -594,7 +606,7 @@
                   if(trace) { log.trace(this + " creating new worker thread"); }
 
                   worker = new ServerThread(socket, this, clientpool, threadpool,
-                                            getTimeout(), serverSocketClass);
+                                            getTimeout(), writeTimeout, serverSocketClass);
 
                   if(trace) { log.trace(this + " created " + worker); }