You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2015/09/07 19:01:12 UTC
svn commit: r1701654 -
/qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerDisassembler.java
Author: kwall
Date: Mon Sep 7 17:01:11 2015
New Revision: 1701654
URL: http://svn.apache.org/r1701654
Log:
QPID-6662: Make 0-10 frameheaders use direct (pooled) rather than heap memory
Modified:
qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerDisassembler.java
Modified: qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerDisassembler.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/ServerDisassembler.java?rev=1701654&r1=1701653&r2=1701654&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerDisassembler.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerDisassembler.java Mon Sep 7 17:01:11 2015
@@ -98,7 +98,7 @@ public final class ServerDisassembler im
private void frame(byte flags, byte type, byte track, int channel, int size, Collection<QpidByteBuffer> buffers)
{
- QpidByteBuffer data = QpidByteBuffer.allocate(HEADER_SIZE);
+ QpidByteBuffer data = QpidByteBuffer.allocateDirect(HEADER_SIZE);
data.put(0, flags);
data.put(1, type);
@@ -109,6 +109,8 @@ public final class ServerDisassembler im
_sender.send(data);
+ data.dispose();
+
if(size > 0)
{
int residual = size;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org