Author: david.lloyd(a)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: {