svn commit: r805329 - /mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionImpl.java

[jvermillard]

Author: jvermillard
Date: Tue Aug 18 09:25:20 2009
New Revision: 805329

URL: http://svn.apache.org/viewvc?rev=805329&view=rev
Log:
Fix for DIRMINA-719

Modified:
    
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionImpl.java

Modified: 
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionImpl.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionImpl.java?rev=805329&r1=805328&r2=805329&view=diff
==============================================================================
--- 
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionImpl.java
 (original)
+++ 
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionImpl.java
 Tue Aug 18 09:25:20 2009
@@ -173,7 +173,6 @@
             if (buf.remaining() == 0) {
                 setCurrentWriteRequest(null);
                 buf.reset();
-
                 this.getFilterChain().fireMessageSent(req);
                 continue;
             }
@@ -186,17 +185,14 @@
                 // increase written bytes
                 increaseWrittenBytes(writtenBytes, System.currentTimeMillis());
                 
-                // finish the write request
-                req.getFuture().setWritten();
                 setCurrentWriteRequest(null);
+                buf.reset();
                 
                 // fire the message sent event
                 getFilterChain().fireMessageSent(req);
             } catch (IOException e) {
                 this.getFilterChain().fireExceptionCaught(e);
             }
-            
-            buf.reset();
 
         }
     }