svn commit: r678307 - /mina/trunk/core/src/main/java/org/apache/mina/filter/buffer/BufferedWriteFilter.java

[edeoliveira]

Author: edeoliveira
Date: Sun Jul 20 12:06:04 2008
New Revision: 678307

URL: http://svn.apache.org/viewvc?rev=678307&view=rev
Log:
Added logger / fixed svn tags / fixed flush method DIRMINA-519

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/filter/buffer/BufferedWriteFilter.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/filter/buffer/BufferedWriteFilter.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/buffer/BufferedWriteFilter.java?rev=678307&r1=678306&r2=678307&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/filter/buffer/BufferedWriteFilter.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/filter/buffer/BufferedWriteFilter.java
 Sun Jul 20 12:06:04 2008
@@ -30,6 +30,8 @@
 import org.apache.mina.core.write.DefaultWriteRequest;
 import org.apache.mina.core.write.WriteRequest;
 import org.apache.mina.filter.codec.ProtocolCodecFilter;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * An [EMAIL PROTECTED] IoFilter} implementation used to buffer outgoing 
[EMAIL PROTECTED] WriteRequest} almost 
@@ -41,11 +43,12 @@
  * as it only handles [EMAIL PROTECTED] WriteRequest}'s carrying [EMAIL 
PROTECTED] IoBuffer} objects.
  * 
  * @author The Apache MINA Project ([EMAIL PROTECTED])
- * @version $Rev: $, $Date: $
+ * @version $Rev$, $Date$
  * @since MINA 2.0.0-M2
  */
 public final class BufferedWriteFilter extends IoFilterAdapter {
-
+    private final Logger logger = 
LoggerFactory.getLogger(BufferedWriteFilter.class);
+    
     /**
      * Default buffer size value in bytes.
      */
@@ -184,7 +187,9 @@
     private void internalFlush(NextFilter nextFilter, IoSession session,
             IoBuffer data) throws Exception {
         if (data != null) {
-            nextFilter.filterWrite(session, new DefaultWriteRequest(data));
+            data.flip();
+            logger.debug("Flushing buffer: {}", data);            
+            nextFilter.filterWrite(session, new 
DefaultWriteRequest(data.duplicate()));
             data.clear();
         }
     }