You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by el...@apache.org on 2009/03/21 20:07:19 UTC
svn commit: r756989 -
/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java
Author: elecharny
Date: Sat Mar 21 19:07:19 2009
New Revision: 756989
URL: http://svn.apache.org/viewvc?rev=756989&view=rev
Log:
The fix I applied for DIRMINA-672 was not sufficient : we have to get out of the loop if the decode method returns false.
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=756989&r1=756988&r2=756989&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 Sat Mar 21 19:07:19 2009
@@ -123,8 +123,10 @@
public void decode(IoSession session, IoBuffer in,
ProtocolDecoderOutput out) throws Exception {
if (!session.getTransportMetadata().hasFragmentation()) {
- while (in.hasRemaining() ) {
- doDecode(session, in, out);
+ while (in.hasRemaining()) {
+ if (!doDecode(session, in, out)) {
+ break;
+ }
}
return;