Applied patch provided by David Robison already 4 years ago :/ (#28)

Author: elecharny

mina-core/src/main/java/org/apache/mina/core/filterchain/IoFilterEvent.java

@@ -19,6 +19,7 @@
  */
 package org.apache.mina.core.filterchain;
 
+import org.apache.mina.core.buffer.IoBuffer;
 import org.apache.mina.core.filterchain.IoFilter.NextFilter;
 import org.apache.mina.core.session.IdleStatus;
 import org.apache.mina.core.session.IoEvent;
@@ -104,6 +105,11 @@ public void fire() {
             case MESSAGE_RECEIVED:
                 Object parameter = getParameter();
                 nextFilter.messageReceived(session, parameter);
+                
+                if (parameter instanceof IoBuffer) {
+                    ((IoBuffer)parameter).free();
+                }
+                
                 break;
 
             case MESSAGE_SENT:

mina-core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java

@@ -165,6 +165,7 @@ public void decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) th
                 newBuf.put(buf);
                 newBuf.put(in);
                 newBuf.flip();
+                buf.free();
                 buf = newBuf;
 
                 // Update the session attribute.
@@ -230,11 +231,19 @@ public void decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) th
      */
     @Override
     public void dispose(IoSession session) throws Exception {
-        removeSessionBuffer(session);
+        IoBuffer oldBuf = (IoBuffer) session.removeAttribute(BUFFER);
+        
+        if (oldBuf != null) {
+            oldBuf.free();
+        }
     }
 
     private void removeSessionBuffer(IoSession session) {
-        session.removeAttribute(BUFFER);
+        IoBuffer oldBuf = (IoBuffer) session.getAttribute(BUFFER);
+        
+        if (oldBuf != null) {
+            oldBuf.free();
+        }
     }
 
     private void storeRemainingInSession(IoBuffer buf, IoSession session) {
@@ -243,6 +252,12 @@ private void storeRemainingInSession(IoBuffer buf, IoSession session) {
         remainingBuf.order(buf.order());
         remainingBuf.put(buf);
 
+        IoBuffer oldBuf = (IoBuffer) session.removeAttribute(BUFFER);
+        
+        if (oldBuf != null) {
+            oldBuf.free();
+        }
+        
         session.setAttribute(BUFFER, remainingBuf);
     }