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