Author: ron.sigal(a)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); }