[jboss-remoting-commits] JBoss Remoting SVN: r5082 - remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket.

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

Author: ron.sigal at jboss.com
Date: 2009-04-22 19:58:00 -0400 (Wed, 22 Apr 2009)
New Revision: 5082

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

Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java
===================================================================
--- remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java	2009-04-22 23:57:04 UTC (rev 5081)
+++ remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java	2009-04-22 23:58:00 UTC (rev 5082)
@@ -125,6 +125,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)
    {
@@ -591,7 +593,7 @@
    }
    
    /**
-    * @return Value of property serverBindPort.
+    * @return Number of idle ServerThreads
     * @jmx:managed-attribute
     */
    public int getCurrentThreadPoolSize()
@@ -600,7 +602,7 @@
    }
 
    /**
-    * @return Value of property serverBindPort.
+    * @return Number of ServerThreads current executing or waiting on an invocation
     * @jmx:managed-attribute
     */
    public int getCurrentClientPoolSize()
@@ -724,6 +726,16 @@
       this.immediateShutdown = immediateShutdown;
    }
 
+   public int getWriteTimeout()
+   {
+      return writeTimeout;
+   }
+
+   public void setWriteTimeout(int writeTimeout)
+   {
+      this.writeTimeout = writeTimeout;
+   }
+
    protected void configureSocket(Socket s) throws SocketException
    {
       s.setReuseAddress(getReuseAddress());
@@ -769,7 +781,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); }
                   newThread = true;
                }