svn commit: r1210366 - /mina/trunk/core/src/main/java/org/apache/mina/transport/tcp/NioSelectorProcessor.java

[jvermillard]

Author: jvermillard
Date: Mon Dec  5 09:05:26 2011
New Revision: 1210366

URL: http://svn.apache.org/viewvc?rev=1210366&view=rev
Log:
BUG : write only work with debug enabled

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/transport/tcp/NioSelectorProcessor.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/transport/tcp/NioSelectorProcessor.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/tcp/NioSelectorProcessor.java?rev=1210366&r1=1210365&r2=1210366&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/transport/tcp/NioSelectorProcessor.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/transport/tcp/NioSelectorProcessor.java
 Mon Dec  5 09:05:26 2011
@@ -347,7 +347,7 @@ public class NioSelectorProcessor implem
                             if (!key.isValid()) {
                                 continue;
                             }
-                            
+
                             selector.selectedKeys().remove(key);
 
                             if (key.isReadable()) {
@@ -369,7 +369,7 @@ public class NioSelectorProcessor implem
                                     
session.getFilterChain().processMessageReceived(session, readBuffer);
                                 }
                             }
-                            
+
                             if (key.isWritable()) {
                                 if (LOGGER.isDebugEnabled()) {
                                     LOGGER.debug("writable session : {}", 
key.attachment());
@@ -378,7 +378,7 @@ public class NioSelectorProcessor implem
                                 session.setNotRegisteredForWrite();
                                 // write from the session write queue
                                 Queue<WriteRequest> queue = 
session.getWriteQueue();
-                                
+
                                 do {
                                     // get a write request from the queue
                                     WriteRequest wreq = queue.peek();
@@ -387,8 +387,8 @@ public class NioSelectorProcessor implem
                                     }
                                     ByteBuffer buf = (ByteBuffer) 
wreq.getMessage();
 
+                                    int wrote = 
session.getSocketChannel().write(buf);
                                     if (LOGGER.isDebugEnabled()) {
-                                        int wrote = 
session.getSocketChannel().write(buf);
                                         LOGGER.debug("wrote {} bytes to {}", 
wrote, session);
                                     }