From 20cf766ec6465c52c56984780256791d97f481ac Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Fri, 14 Mar 2008 10:46:40 +0000 Subject: QPID-592 : Parameterised the Read/Write buffer limits. On the broker extra config [read|write]BufferLimitSize on the client System properties qpid.[read|write].buffer.limit. All the defaults are 256k(262144). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@637047 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/mina/SocketIOTest/IOWriterClient.java | 9 +++++---- .../java/org/apache/mina/SocketIOTest/IOWriterServer.java | 11 +++++++---- 2 files changed, 12 insertions(+), 8 deletions(-) (limited to 'java/common') diff --git a/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterClient.java b/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterClient.java index 0b6ed81d18..b93dc46741 100644 --- a/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterClient.java +++ b/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterClient.java @@ -131,19 +131,20 @@ public class IOWriterClient implements Runnable private int _receivedCount = 0; private int _sentCount = 0; + private static final String DEFAULT_READ_BUFFER = "262144"; + private static final String DEFAULT_WRITE_BUFFER = "262144"; public void sessionCreated(IoSession session) throws Exception { IoFilterChain chain = session.getFilterChain(); - int buf_size = ((SocketSessionConfig) session.getConfig()).getSendBufferSize(); ReadThrottleFilterBuilder readfilter = new ReadThrottleFilterBuilder(); - readfilter.setMaximumConnectionBufferSize(buf_size); + readfilter.setMaximumConnectionBufferSize(Integer.parseInt(System.getProperty("qpid.read.buffer.limit", DEFAULT_READ_BUFFER))); readfilter.attach(chain); WriteBufferLimitFilterBuilder writefilter = new WriteBufferLimitFilterBuilder(); -// writefilter.setMaximumConnectionBufferCount(1000); - writefilter.setMaximumConnectionBufferSize(buf_size * 2); + + writefilter.setMaximumConnectionBufferSize(Integer.parseInt(System.getProperty("qpid.write.buffer.limit", DEFAULT_WRITE_BUFFER))); writefilter.attach(chain); } diff --git a/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterServer.java b/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterServer.java index 82ef3d57cc..423e98c67b 100644 --- a/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterServer.java +++ b/java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterServer.java @@ -39,6 +39,9 @@ public class IOWriterServer static public int _PORT = 9999; + private static final String DEFAULT_READ_BUFFER = "262144"; + private static final String DEFAULT_WRITE_BUFFER = "262144"; + private static class TestHandler extends IoHandlerAdapter { @@ -52,14 +55,14 @@ public class IOWriterServer { IoFilterChain chain = ioSession.getFilterChain(); - int buf_size = ((SocketSessionConfig) ioSession.getConfig()).getReceiveBufferSize(); - ReadThrottleFilterBuilder readfilter = new ReadThrottleFilterBuilder(); - readfilter.setMaximumConnectionBufferSize(buf_size); + readfilter.setMaximumConnectionBufferSize(Integer.parseInt(System.getProperty("qpid.read.buffer.limit", DEFAULT_READ_BUFFER))); readfilter.attach(chain); WriteBufferLimitFilterBuilder writefilter = new WriteBufferLimitFilterBuilder(); - writefilter.setMaximumConnectionBufferSize(buf_size * 2); + + writefilter.setMaximumConnectionBufferSize(Integer.parseInt(System.getProperty("qpid.write.buffer.limit", DEFAULT_WRITE_BUFFER))); + writefilter.attach(chain); } -- cgit v1.2.1