diff options
author | Andrew Donald Kennedy <grkvlt@apache.org> | 2011-02-17 15:28:33 +0000 |
---|---|---|
committer | Andrew Donald Kennedy <grkvlt@apache.org> | 2011-02-17 15:28:33 +0000 |
commit | c8e138d7b2ef48e7a111621473b3e48a6eb61778 (patch) | |
tree | da513ea820826dda95be91521ab5f5fabbc624eb | |
parent | ba8c1f7353e632a3b6ee392736c77b2553fe6b86 (diff) | |
download | qpid-python-c8e138d7b2ef48e7a111621473b3e48a6eb61778.tar.gz |
QPID-3065: Send header and frame data as single buffer
The Disassembler now fills a ByteBuffer with the entire frame contents before
passing it to the Sender.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1071641 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/network/Disassembler.java | 23 |
1 files changed, 13 insertions, 10 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/network/Disassembler.java b/java/common/src/main/java/org/apache/qpid/transport/network/Disassembler.java index ab174b00b3..bf439299b9 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/network/Disassembler.java +++ b/java/common/src/main/java/org/apache/qpid/transport/network/Disassembler.java @@ -101,20 +101,23 @@ public final class Disassembler implements Sender<ProtocolEvent>, { synchronized (sendlock) { - header.put(0, flags); - header.put(1, type); - header.putShort(2, (short) (size + HEADER_SIZE)); - header.put(5, track); - header.putShort(6, (short) channel); - - header.rewind(); - - sender.send(header); + ByteBuffer data = ByteBuffer.allocate(size + HEADER_SIZE); + data.order(ByteOrder.BIG_ENDIAN); + + data.put(0, flags); + data.put(1, type); + data.putShort(2, (short) (size + HEADER_SIZE)); + data.put(5, track); + data.putShort(6, (short) channel); + data.position(HEADER_SIZE); int limit = buf.limit(); buf.limit(buf.position() + size); - sender.send(buf); + data.put(buf); buf.limit(limit); + + data.rewind(); + sender.send(data); } } |