diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2015-01-31 20:15:42 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2015-01-31 20:15:42 +0000 |
| commit | e8a5ab04596ff422b3609cf1c454bdc76b473399 (patch) | |
| tree | cabed59c05be25118118e906b13762b9a0ad9b3b | |
| parent | 26eab7ed4556717fca50ad93025fdc8d112f9715 (diff) | |
| download | qpid-python-e8a5ab04596ff422b3609cf1c454bdc76b473399.tar.gz | |
Change server encoder default capacity/threshold
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1656249 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java index 94a444b590..6437015208 100644 --- a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java +++ b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java @@ -29,7 +29,8 @@ import org.apache.qpid.transport.codec.AbstractEncoder; public final class ServerEncoder extends AbstractEncoder { - public static final int DEFAULT_CAPACITY = 4096; + public static final int DEFAULT_CAPACITY = 8192; + private final int _threshold; private ByteBuffer _out; private int _segment; private int _initialCapacity; @@ -42,6 +43,7 @@ public final class ServerEncoder extends AbstractEncoder public ServerEncoder(int capacity) { _initialCapacity = capacity; + _threshold = capacity/16; _out = ByteBuffer.allocate(capacity); _segment = 0; } @@ -51,7 +53,7 @@ public final class ServerEncoder extends AbstractEncoder _out.position(_out.limit()); _out.limit(_out.capacity()); _out = _out.slice(); - if(_out.remaining() < 256) + if(_out.remaining() < _threshold) { _out = ByteBuffer.allocate(_initialCapacity); } |