Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

setting socket options also on accept()

  • Loading branch information...
commit f7dde7c4d157a3acb12d026d2a343f5b677d93f7 1 parent 4416da9
@belaban authored
View
4 src/org/jgroups/Version.java
@@ -5,9 +5,9 @@
public class Version {
- public static String version="2.2.7SP1";
+ public static String version="2.2.7.SP1";
public static byte[] version_id={'0', '2', '2', '7', '1'};
- public static String cvs="$Id: Version.java,v 1.13.4.1 2006/09/27 18:46:14 belaban Exp $";
+ public static String cvs="$Id: Version.java,v 1.13.4.2 2006/09/28 16:05:56 belaban Exp $";
public static void main(String[] args) {
System.out.println("\nVersion: \t" + version);
View
19 src/org/jgroups/blocks/ConnectionTable.java
@@ -1,4 +1,4 @@
-// $Id: ConnectionTable.java,v 1.7.4.1 2006/09/27 19:05:23 belaban Exp $
+// $Id: ConnectionTable.java,v 1.7.4.2 2006/09/28 16:05:55 belaban Exp $
package org.jgroups.blocks;
@@ -386,6 +386,23 @@ public void run() {
try {
client_sock=srv_sock.accept();
if(log.isInfoEnabled()) log.info("accepted connection, client_sock=" + client_sock);
+ try {
+ client_sock.setSendBufferSize(send_buf_size);
+ }
+ catch(IllegalArgumentException ex) {
+ if(log.isErrorEnabled()) log.error("exception setting send buffer size to " +
+ send_buf_size + " bytes", ex);
+ }
+ try {
+ client_sock.setReceiveBufferSize(recv_buf_size);
+ }
+ catch(IllegalArgumentException ex) {
+ if(log.isErrorEnabled()) log.error("exception setting receive buffer size to " +
+ send_buf_size + " bytes", ex);
+ }
+
+ client_sock.setKeepAlive(true);
+ client_sock.setTcpNoDelay(tcp_nodelay);
// create new thread and add to conn table
conn=new Connection(client_sock, null); // will call receive(msg)
Please sign in to comment.
Something went wrong with that request. Please try again.