Author: ron.sigal(a)jboss.com Date: 2008-02-29 03:21:21 -0500 (Fri, 29 Feb 2008) New Revision: 3537 Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java Log: JBREM-703: Added configuration for remaining socket parameters. Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java =================================================================== --- remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java 2008-02-29 04:04:36 UTC (rev 3536) +++ remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java 2008-02-29 08:21:21 UTC (rev 3537) @@ -222,6 +222,20 @@ */ protected ServerAddress address; protected Home home; + + /** + * Socket configuration parameters. + */ + protected boolean keepAlive; + protected boolean keepAliveSet; + protected boolean oOBInline; + protected boolean oOBInlineSet; + protected int receiveBufferSize = - 1; + protected int sendBufferSize = -1; + protected boolean soLinger; + protected boolean soLingerSet; + protected int soLingerDuration = -1; + protected int trafficClass = -1; // Constructors --------------------------------------------------------------------------------- @@ -287,6 +301,79 @@ 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 getReceiveBufferSize() + { + return receiveBufferSize; + } + + public void setReceiveBufferSize(int receiveBufferSize) + { + this.receiveBufferSize = receiveBufferSize; + } + + 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; + } + public synchronized void disconnect() { log.debug(this + " disconnecting ..."); @@ -1010,11 +1097,24 @@ protected Socket createSocket(String address, int port, int timeout) throws IOException { Socket s = new Socket(); - s.setReuseAddress(getReuseAddress()); + configureSocket(s); InetSocketAddress inetAddr = new InetSocketAddress(address, port); s.connect(inetAddr); return s; } + + 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); + } protected SocketWrapper getPooledConnection() {