(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

1 files changed, 5 insertions, 4 deletions

diff --git a/dotnet/Qpid.Client/Client/Transport/Socket/Blocking/BlockingSocketProcessor.cs b/dotnet/Qpid.Client/Client/Transport/Socket/Blocking/BlockingSocketProcessor.cs
index bdec584b7b..7a9ead0c06 100644
--- a/dotnet/Qpid.Client/Client/Transport/Socket/Blocking/BlockingSocketProcessor.cs
+++ b/dotnet/Qpid.Client/Client/Transport/Socket/Blocking/BlockingSocketProcessor.cs
@@ -71,7 +71,7 @@ namespace Qpid.Client.Transport.Socket.Blocking
         {            

             try

             {

-                _networkStream.Write(byteBuffer.array(), byteBuffer.position(), byteBuffer.limit()); // FIXME

+                _networkStream.Write(byteBuffer.Array, byteBuffer.Position, byteBuffer.Limit); // FIXME

             }

             catch (Exception e)

             {

@@ -87,10 +87,10 @@ namespace Qpid.Client.Transport.Socket.Blocking
             

             int numOctets = _networkStream.Read(bytes, 0, bytes.Length);

 

-            ByteBuffer byteBuffer = ByteBuffer.wrap(bytes);

-            byteBuffer.limit(numOctets);

+            ByteBuffer byteBuffer = ByteBuffer.Wrap(bytes);

+            byteBuffer.Limit = numOctets;

             

-            byteBuffer.flip();

+            byteBuffer.Flip();

 

             return byteBuffer;

         }

@@ -114,3 +114,4 @@ namespace Qpid.Client.Transport.Socket.Blocking
     }

 }

 

+