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);
}
}