diff options
| author | Steven Shaw <steshaw@apache.org> | 2006-12-12 17:36:17 +0000 |
|---|---|---|
| committer | Steven Shaw <steshaw@apache.org> | 2006-12-12 17:36:17 +0000 |
| commit | ad8fa512e788075a4573678738b6f11f1c8cbd59 (patch) | |
| tree | 69eef3dfec5848f489a9f129237e38ae35b3079c /qpid/dotnet/Qpid.Codec/Demux | |
| parent | 4e1735463fdb63f87d03541c33a816a5c7af563f (diff) | |
| download | qpid-python-ad8fa512e788075a4573678738b6f11f1c8cbd59.tar.gz | |
QPID-139. Initial (re)port of MINA's bytebuffer abstraction. Now includes the autoexpand feature. References to java.nio.Buffer were replaced with FixedByteBuffer and necessary methods added and implemented. FixedByteBuffer delegates to our existing HeapByteBuffer.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486248 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/dotnet/Qpid.Codec/Demux')
| -rw-r--r-- | qpid/dotnet/Qpid.Codec/Demux/DemuxingProtocolCodecFactory.cs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/qpid/dotnet/Qpid.Codec/Demux/DemuxingProtocolCodecFactory.cs b/qpid/dotnet/Qpid.Codec/Demux/DemuxingProtocolCodecFactory.cs index 8a58eecda4..6577909cff 100644 --- a/qpid/dotnet/Qpid.Codec/Demux/DemuxingProtocolCodecFactory.cs +++ b/qpid/dotnet/Qpid.Codec/Demux/DemuxingProtocolCodecFactory.cs @@ -217,8 +217,8 @@ namespace Qpid.Codec.Demux for (int i = decoders.Length - 1; i >= 0; i --) { IMessageDecoder decoder = decoders[i]; - int limit = input.Limit; - int pos = input.Position; + int limit = input.limit(); + int pos = input.position(); try { @@ -226,8 +226,8 @@ namespace Qpid.Codec.Demux } finally { - input.Position = pos; - input.Limit = limit; + input.position(pos); + input.limit(limit); } if (result == MessageDecoderResult.OK) @@ -248,7 +248,7 @@ namespace Qpid.Codec.Demux if (undecodables == _decoders.Length) { // Throw an exception if all decoders cannot decode data. - input.Position = input.Limit; // Skip data + input.position(input.limit()); // Skip data throw new ProtocolDecoderException( "No appropriate message decoder: " + input.HexDump); } |