From 6f4dce11d203ec606650497fa64f1519ecdf43c3 Mon Sep 17 00:00:00 2001 From: Arnaud Simon Date: Wed, 14 Nov 2007 13:50:50 +0000 Subject: changed for setting offset when buffers are fragmented git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@594881 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'qpid/java') diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java index 76229a7ddd..474211ced2 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java @@ -97,11 +97,13 @@ public class FragmentDecoder extends AbstractDecoder protected void doGet(byte[] bytes) { int remaining = bytes.length; + int offset = 0; while (remaining > 0) { preRead(); int size = min(remaining, current.remaining()); - current.get(bytes, 0, size); + current.get(bytes, offset, size); + offset += size; remaining -= size; postRead(); } -- cgit v1.2.1