diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2008-05-13 15:46:23 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2008-05-13 15:46:23 +0000 |
| commit | f718f9e3c2a5ed015f797734979d71d17f64c84f (patch) | |
| tree | 390e87d4cf21b19f674bb91286e826f4871af38f /qpid/java/common | |
| parent | 8c9f5cf7454080b4056de1aa3d9e900813128d85 (diff) | |
| download | qpid-python-f718f9e3c2a5ed015f797734979d71d17f64c84f.tar.gz | |
QPID-1006: Don't use tcp-nodelay as default and set socket buffer size only when the corresponding property is set.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@655923 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java | 21 |
1 files changed, 13 insertions, 8 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java index 32b0d1ffd7..3021184842 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/mina/MinaHandler.java @@ -54,7 +54,7 @@ import org.apache.qpidity.transport.network.OutputHandler; //RA making this public until we sort out the package issues public class MinaHandler<E> implements IoHandler { - private static final int DEFAULT_BUFFER_SIZE = 64 * 1024; + private static final int MAX_FRAME_SIZE = 64 * 1024 - 1; /** Default buffer size for pending messages reads */ private static final String DEFAULT_READ_BUFFER_LIMIT = "262144"; /** Default buffer size for pending messages writes */ @@ -206,10 +206,17 @@ public class MinaHandler<E> implements IoHandler IoServiceConfig acceptorConfig = connector.getDefaultConfig(); acceptorConfig.setThreadModel(ThreadModel.MANUAL); SocketSessionConfig scfg = (SocketSessionConfig) acceptorConfig.getSessionConfig(); - scfg.setTcpNoDelay("true".equalsIgnoreCase(System.getProperty("amqj.tcpNoDelay", "true"))); - scfg.setSendBufferSize(Integer.getInteger("amqj.sendBufferSize", DEFAULT_BUFFER_SIZE)); - scfg.setReceiveBufferSize(Integer.getInteger("amqj.receiveBufferSize", DEFAULT_BUFFER_SIZE)); - + scfg.setTcpNoDelay(Boolean.getBoolean("amqj.tcpNoDelay")); + Integer sendBufferSize = Integer.getInteger("amqj.sendBufferSize"); + if (sendBufferSize != null && sendBufferSize > 0) + { + scfg.setSendBufferSize(sendBufferSize); + } + Integer receiveBufferSize = Integer.getInteger("amqj.receiveBufferSize"); + if (receiveBufferSize != null && receiveBufferSize > 0) + { + scfg.setReceiveBufferSize(receiveBufferSize); + } connector.setWorkerTimeout(0); ConnectFuture cf = connector.connect(address, handler); cf.join(); @@ -270,9 +277,7 @@ public class MinaHandler<E> implements IoHandler { // XXX: hardcoded max-frame return new Connection - (new Disassembler(new OutputHandler(sender), - Math.min(DEFAULT_BUFFER_SIZE, Integer.getInteger("amqj.sendBufferSize", DEFAULT_BUFFER_SIZE)) - 1), - delegate); + (new Disassembler(new OutputHandler(sender), MAX_FRAME_SIZE), delegate); } public Receiver<java.nio.ByteBuffer> receiver(Connection conn) |