[jboss-cvs] JBoss Messaging SVN: r4826 - trunk/src/main/org/jboss/messaging/core/remoting/impl/netty.

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

Author: trustin
Date: 2008-08-18 09:11:34 -0400 (Mon, 18 Aug 2008)
New Revision: 4826

Modified:
   trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/ChannelBufferWrapper.java
Log:
Fixed a bug where ChannelBufferWrapper zaps data on expansion

Modified: trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/ChannelBufferWrapper.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/ChannelBufferWrapper.java	2008-08-18 13:11:27 UTC (rev 4825)
+++ trunk/src/main/org/jboss/messaging/core/remoting/impl/netty/ChannelBufferWrapper.java	2008-08-18 13:11:34 UTC (rev 4826)
@@ -150,6 +150,7 @@
    {
       int limit = buffer.writerIndex();
       buffer.writerIndex(buffer.readerIndex());
+      buffer.readerIndex(0);
       try {
          buffer.writeByte(byteValue);
       } finally {
@@ -165,6 +166,7 @@
    {
       int limit = buffer.writerIndex();
       buffer.writerIndex(buffer.readerIndex());
+      buffer.readerIndex(0);
       try {
          buffer.writeBytes(byteArray);
       } finally {
@@ -180,6 +182,7 @@
    {
       int limit = buffer.writerIndex();
       buffer.writerIndex(buffer.readerIndex());
+      buffer.readerIndex(0);
       try {
          buffer.writeBytes(bytes, offset, length);
       } finally {
@@ -195,6 +198,7 @@
    {
       int limit = buffer.writerIndex();
       buffer.writerIndex(buffer.readerIndex());
+      buffer.readerIndex(0);
       try {
          buffer.writeInt(intValue);
       } finally {
@@ -215,6 +219,7 @@
    {
       int limit = buffer.writerIndex();
       buffer.writerIndex(buffer.readerIndex());
+      buffer.readerIndex(0);
       try {
          buffer.writeLong(longValue);
       } finally {
@@ -240,6 +245,7 @@
    {
       int limit = buffer.writerIndex();
       buffer.writerIndex(buffer.readerIndex());
+      buffer.readerIndex(0);
       try {
          buffer.writeShort(s);
       } finally {
@@ -390,6 +396,7 @@
 
       int limit = buffer.writerIndex();
       buffer.writerIndex(buffer.readerIndex());
+      buffer.readerIndex(0);
       try {
          buffer.writeShort((short) length);
          buffer.writeBytes(encoded);