diff options
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterClient.java | 9 | ||||
| -rw-r--r-- | java/common/src/test/java/org/apache/mina/SocketIOTest/IOWriterServer.java | 11 |
2 files changed, 12 insertions, 8 deletions
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); } |