Author: jvermillard
Date: Mon Aug 17 13:03:17 2009
New Revision: 804964
URL: http://svn.apache.org/viewvc?rev=804964&view=rev
Log:
DIRMINA-719 firing message sent event from serial writes
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=804964&r1=804963&r2=804964&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 Mon Aug 17 13:03:17 2009
@@ -182,10 +182,22 @@
try {
outputStream.write(buf.array(), buf.position(), writtenBytes);
buf.position(buf.position() + writtenBytes);
+
+ // increase written bytes
+ increaseWrittenBytes(writtenBytes, System.currentTimeMillis());
+
+ // finish the write request
req.getFuture().setWritten();
+ setCurrentWriteRequest(null);
+
+ // fire the message sent event
+ getFilterChain().fireMessageSent(req);
} catch (IOException e) {
this.getFilterChain().fireExceptionCaught(e);
}
+
+ buf.reset();
+
}
}