Author: trustin
Date: Sun Nov 11 18:23:28 2007
New Revision: 594007

URL: http://svn.apache.org/viewvc?rev=594007&view=rev
Log:
Changed CumulativeProtocolDecoder to use UnderivableBuffer to prevent 
unexpectedly disabled autoExpand

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java?rev=594007&r1=594006&r2=594007&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java
 Sun Nov 11 18:23:28 2007
@@ -22,6 +22,7 @@
 import org.apache.mina.common.AttributeKey;
 import org.apache.mina.common.IoBuffer;
 import org.apache.mina.common.IoSession;
+import org.apache.mina.common.UnderivableBuffer;
 
 /**
  * A [EMAIL PROTECTED] ProtocolDecoder} that cumulates the content of received
@@ -189,10 +190,12 @@
     }
 
     private void storeRemainingInSession(IoBuffer buf, IoSession session) {
-        final IoBuffer remainingBuf = IoBuffer.allocate(buf.capacity());
-        remainingBuf.setAutoExpand(true);
+        final IoBuffer remainingBuf = new UnderivableBuffer(
+                IoBuffer.allocate(buf.capacity()).setAutoExpand(true));
+        
         remainingBuf.order(buf.order());
         remainingBuf.put(buf);
+        
         session.setAttribute(BUFFER, remainingBuf);
     }
 }


Reply via email to