From 3bfaba7fd65f251b68e8c4085582a4b62edf8e5d Mon Sep 17 00:00:00 2001 From: Robert Greig Date: Mon, 26 Feb 2007 17:46:07 +0000 Subject: (Patch submitted by Tomas Restrepo) QPID-ByteBuffer.diff. Completely refactors the byte buffer implementation, doing away with a complex inheritance hierarchy. Fixes reading and writing of field table to permit interop with Java client. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@511923 13f79535-47bb-0310-9956-ffa450edef68 --- dotnet/Qpid.Codec/CumulativeProtocolDecoder.cs | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) (limited to 'dotnet/Qpid.Codec/CumulativeProtocolDecoder.cs') diff --git a/dotnet/Qpid.Codec/CumulativeProtocolDecoder.cs b/dotnet/Qpid.Codec/CumulativeProtocolDecoder.cs index 21614cf108..72c56e0b17 100644 --- a/dotnet/Qpid.Codec/CumulativeProtocolDecoder.cs +++ b/dotnet/Qpid.Codec/CumulativeProtocolDecoder.cs @@ -33,8 +33,8 @@ namespace Qpid.Codec /// protected CumulativeProtocolDecoder() { - _remaining = ByteBuffer.allocate(4096); - _remaining.setAutoExpand(true); + _remaining = ByteBuffer.Allocate(4096); + _remaining.IsAutoExpand = true; } /// @@ -48,7 +48,7 @@ namespace Qpid.Codec /// public void Decode(ByteBuffer input, IProtocolDecoderOutput output) { - if (_remaining.position() != 0) // If there were remaining undecoded bytes + if (_remaining.Position != 0) // If there were remaining undecoded bytes { DecodeRemainingAndInput(input, output); } @@ -67,9 +67,9 @@ namespace Qpid.Codec } finally { - if (input.hasRemaining()) + if (input.HasRemaining) { - _remaining.put(input); + _remaining.Put(input); } } } @@ -77,8 +77,8 @@ namespace Qpid.Codec private void DecodeRemainingAndInput(ByteBuffer input, IProtocolDecoderOutput output) { // Concatenate input buffer with left-over bytes. - _remaining.put(input); - _remaining.flip(); + _remaining.Put(input); + _remaining.Flip(); try { @@ -86,7 +86,7 @@ namespace Qpid.Codec } finally { - _remaining.compact(); + _remaining.Compact(); } } @@ -94,17 +94,17 @@ namespace Qpid.Codec { for (;;) { - int oldPos = buf.position(); + int oldPos = buf.Position; bool decoded = DoDecode(buf, output); if (decoded) { - if (buf.position() == oldPos) + if (buf.Position == oldPos) { throw new Exception( "doDecode() can't return true when buffer is not consumed."); } - if (!buf.hasRemaining()) + if (!buf.HasRemaining) { break; } -- cgit v1.2.1