You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2015/01/31 21:15:42 UTC
svn commit: r1656249 -
/qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java
Author: rgodfrey
Date: Sat Jan 31 20:15:42 2015
New Revision: 1656249
URL: http://svn.apache.org/r1656249
Log:
Change server encoder default capacity/threshold
Modified:
qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java
Modified: qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java
URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java?rev=1656249&r1=1656248&r2=1656249&view=diff
==============================================================================
--- qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java (original)
+++ qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java Sat Jan 31 20:15:42 2015
@@ -29,7 +29,8 @@ import org.apache.qpid.transport.codec.A
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
public ServerEncoder(int capacity)
{
_initialCapacity = capacity;
+ _threshold = capacity/16;
_out = ByteBuffer.allocate(capacity);
_segment = 0;
}
@@ -51,7 +53,7 @@ public final class ServerEncoder extends
_out.position(_out.limit());
_out.limit(_out.capacity());
_out = _out.slice();
- if(_out.remaining() < 256)
+ if(_out.remaining() < _threshold)
{
_out = ByteBuffer.allocate(_initialCapacity);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org