[jboss-remoting-commits] JBoss Remoting SVN: r5841 - remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote.

[jboss-remoting-commits at lists.jboss.org]

Author: david.lloyd at jboss.com
Date: 2010-03-26 14:41:34 -0400 (Fri, 26 Mar 2010)
New Revision: 5841

Modified:
   remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/RemoteMessageHandler.java
Log:
JBREM-1215 part 2.1: Push copies to other threads so our main buffer may be reused

Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/RemoteMessageHandler.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/RemoteMessageHandler.java	2010-03-26 18:38:10 UTC (rev 5840)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/RemoteMessageHandler.java	2010-03-26 18:41:34 UTC (rev 5841)
@@ -240,7 +240,7 @@
                     }
                     byteInput = inboundRequest.getByteInput();
                 }
-                byteInput.push(buffer);
+                byteInput.push(Buffers.flip(ByteBuffer.allocate(buffer.remaining()).put(buffer)));
                 return;
             }
             case RemoteProtocol.REQUEST_ABORT: {
@@ -301,7 +301,7 @@
                         byteInput = outboundRequest.getByteInput();
                     }
                 }
-                byteInput.push(buffer);
+                byteInput.push(Buffers.flip(ByteBuffer.allocate(buffer.remaining()).put(buffer)));
                 return;
             }
             case RemoteProtocol.REPLY_ACK_CHUNK: {
@@ -342,7 +342,7 @@
                         byteInput = outboundRequest.getByteInput();
                     }
                 }
-                byteInput.push(buffer);
+                byteInput.push(Buffers.flip(ByteBuffer.allocate(buffer.remaining()).put(buffer)));
                 return;
             }
             case RemoteProtocol.REPLY_EXCEPTION_ABORT: {