svn commit: r574910 - /mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketSessionImpl.java

[jvermillard]

Author: jvermillard
Date: Wed Sep 12 05:19:53 2007
New Revision: 574910

URL: http://svn.apache.org/viewvc?rev=574910&view=rev
Log:
sorting methods (code formating)

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketSessionImpl.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketSessionImpl.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketSessionImpl.java?rev=574910&r1=574909&r2=574910&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketSessionImpl.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketSessionImpl.java
 Wed Sep 12 05:19:53 2007
@@ -198,6 +198,22 @@
     AtomicBoolean getInFlushQueue() {
         return inFlushQueue;
     }
+    
+    void queueWriteRequest(WriteRequest writeRequest) {
+        if (writeRequest.getMessage() instanceof ByteBuffer) {
+            ByteBuffer buffer = (ByteBuffer) writeRequest.getMessage();
+            // SocketIoProcessor.doFlush() will reset it after write is 
finished
+            // because the buffer will be passed with messageSent event.
+            buffer.mark();
+            scheduledWriteBytes.addAndGet(buffer.remaining());
+        }
+
+        writeRequestQueue.add(writeRequest);
+
+        if (getTrafficMask().isWritable()) {
+            getIoProcessor().flush(this);
+        }
+    }
 
     private class SessionConfigImpl extends AbstractSocketSessionConfig 
implements SocketSessionConfig {
         public boolean isKeepAlive() {
@@ -343,22 +359,6 @@
                     throw new RuntimeIOException(e);
                 }
             }
-        }
-    }
-
-    void queueWriteRequest(WriteRequest writeRequest) {
-        if (writeRequest.getMessage() instanceof ByteBuffer) {
-            ByteBuffer buffer = (ByteBuffer) writeRequest.getMessage();
-            // SocketIoProcessor.doFlush() will reset it after write is 
finished
-            // because the buffer will be passed with messageSent event.
-            buffer.mark();
-            scheduledWriteBytes.addAndGet(buffer.remaining());
-        }
-
-        writeRequestQueue.add(writeRequest);
-
-        if (getTrafficMask().isWritable()) {
-            getIoProcessor().flush(this);
         }
     }
 }