You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by lq...@apache.org on 2016/10/19 14:35:54 UTC
svn commit: r1765609 -
/qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java
Author: lquack
Date: Wed Oct 19 14:35:54 2016
New Revision: 1765609
URL: http://svn.apache.org/viewvc?rev=1765609&view=rev
Log:
QPID-7465: [Java Broker] Stop ServerEncoder from unnecessarily allocating ByteBuffers
Modified:
qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java
Modified: qpid/java/trunk/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/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java?rev=1765609&r1=1765608&r2=1765609&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java Wed Oct 19 14:35:54 2016
@@ -49,18 +49,15 @@ public final class ServerEncoder extends
public void init()
{
- _out.position(_out.limit());
- _out.limit(_out.capacity());
- QpidByteBuffer old = _out;
- if(_out.remaining() < _threshold)
+ if(_out.capacity() < _threshold)
{
+ _out.dispose();
_out = QpidByteBuffer.allocateDirect(_initialCapacity);
}
else
{
- _out = _out.slice();
+ _out.clear();
}
- old.dispose();
}
public QpidByteBuffer getBuffer()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org