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

[trustin]

Author: trustin
Date: Wed Nov  7 03:52:33 2007
New Revision: 592719

URL: http://svn.apache.org/viewvc?rev=592719&view=rev
Log:
Fixed compilation errors in transport-serial

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=592719&r1=592718&r2=592719&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
 Wed Nov  7 03:52:33 2007
@@ -160,14 +160,17 @@
 
     private void flushWrites() {
         for (; ;) {
-            WriteRequest req = getWriteRequestQueue().peek();
+            WriteRequest req = getCurrentWriteRequest();
             if (req == null) {
-                break;
+                req = getWriteRequestQueue().poll(this);
+                if (req == null) {
+                    break;
+                }
             }
 
             IoBuffer buf = (IoBuffer) req.getMessage();
             if (buf.remaining() == 0) {
-                getWriteRequestQueue().poll();
+                setCurrentWriteRequest(null);
                 buf.reset();
 
                 this.getFilterChain().fireMessageSent(req);