Author: ron.sigal(a)jboss.com Date: 2008-02-29 03:23:09 -0500 (Fri, 29 Feb 2008) New Revision: 3539 Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java Log: JBREM-703: Added configuration for remaining socket parameters. 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 2008-02-29 08:21:41 UTC (rev 3538) +++ remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java 2008-02-29 08:23:09 UTC (rev 3539) @@ -66,7 +66,7 @@ static int clientCount = 0; - private Properties props = new Properties(); + protected Properties props = new Properties(); private static int BACKLOG_DEFAULT = 200; protected static int MAX_POOL_SIZE_DEFAULT = 300; @@ -98,6 +98,20 @@ protected Object serverSocketFactoryLock = new Object(); protected boolean reuseAddress = true; + protected int receiveBufferSize = -1; + + /** + * More socket configuration parameters. + */ + protected boolean keepAlive; + protected boolean keepAliveSet; + protected boolean oOBInline; + protected boolean oOBInlineSet; + protected int sendBufferSize = -1; + protected boolean soLinger; + protected boolean soLingerSet; + protected int soLingerDuration = -1; + protected int trafficClass = -1; // defaults to -1 as to not have idle timeouts protected int idleTimeout = -1; @@ -270,10 +284,12 @@ log.warn("Unable to create unbound ServerSocket: cannot set reuseAddress to true",e); ss = factory.createServerSocket(serverBindPort, backlog, bindAddress); + configureServerSocket(ss); return ss; } ss.setReuseAddress(getReuseAddress()); + configureServerSocket(ss); InetSocketAddress address = new InetSocketAddress(bindAddress, serverBindPort); ss.bind(address, backlog); return ss; @@ -294,6 +310,7 @@ { ss = factory.createServerSocket(); ss.setReuseAddress(getReuseAddress()); + configureServerSocket(ss); InetSocketAddress address = new InetSocketAddress(inetAddress, home.port); ss.bind(address, backlog); if (log.isDebugEnabled()) log.debug(this + " created " + ss); @@ -306,6 +323,7 @@ try { ss = factory.createServerSocket(home.port, backlog, inetAddress); + configureServerSocket(ss); } catch (IOException e2) { @@ -326,6 +344,14 @@ serverSockets.add(ss); } } + + protected void configureServerSocket(ServerSocket ss) throws SocketException + { + if (receiveBufferSize != -1) + { + ss.setReceiveBufferSize(receiveBufferSize); + } + } protected String getThreadName(int i) { @@ -416,6 +442,17 @@ log.debug(this + " exiting"); } + + public int getReceiveBufferSize() + { + return receiveBufferSize; + } + + public void setReceiveBufferSize(int receiveBufferSize) + { + this.receiveBufferSize = receiveBufferSize; + } + /** * Indicates if SO_REUSEADDR is enabled on server sockets * Default is true. @@ -436,6 +473,69 @@ this.reuseAddress = reuse; } + public boolean isKeepAlive() + { + return keepAlive; + } + + public void setKeepAlive(boolean keepAlive) + { + this.keepAlive = keepAlive; + keepAliveSet = true; + } + + public boolean isOOBInline() + { + return oOBInline; + } + + public void setOOBInline(boolean inline) + { + oOBInline = inline; + oOBInlineSet = true; + } + + public int getSendBufferSize() + { + return sendBufferSize; + } + + public void setSendBufferSize(int sendBufferSize) + { + this.sendBufferSize = sendBufferSize; + } + + public boolean isSoLinger() + { + return soLinger; + } + + public int getSoLingerDuration() + { + return soLingerDuration; + } + + public void setSoLinger(boolean soLinger) + { + this.soLinger = soLinger; + soLingerSet = true; + } + + public void setSoLingerDuration(int soLingerDuration) + { + this.soLingerDuration = soLingerDuration; + } + + public int getTrafficClass() + { + return trafficClass; + } + + public void setTrafficClass(int trafficClass) + { + this.trafficClass = trafficClass; + } + /** * @return Value of property serverBindPort. * @jmx:managed-attribute @@ -560,7 +660,19 @@ } } - + protected void configureSocket(Socket s) throws SocketException + { + s.setReuseAddress(getReuseAddress()); + + if (keepAliveSet) s.setKeepAlive(keepAlive); + if (oOBInlineSet) s.setOOBInline(oOBInline); + if (receiveBufferSize > -1) s.setReceiveBufferSize(receiveBufferSize); + if (sendBufferSize > -1) s.setSendBufferSize(sendBufferSize); + if (soLingerSet && + soLingerDuration > 0) s.setSoLinger(soLinger, soLingerDuration); + if (trafficClass > -1) s.setTrafficClass(trafficClass); + } + /** * The acceptor thread should spend as little time as possbile doing any kind of operation, and * under no circumstances should perform IO on the new socket, which can potentially block and @@ -872,6 +984,7 @@ // should grab a worker thread and delegate all subsequent work to it. This is what // processInvocation() does. + configureSocket(socket); processInvocation(socket); } catch (SSLException e)