svn commit: r1213662 - /mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java

[elecharny]

Author: elecharny
Date: Tue Dec 13 12:40:52 2011
New Revision: 1213662

URL: http://svn.apache.org/viewvc?rev=1213662&view=rev
Log:
Added some comments

Modified:
    mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java?rev=1213662&r1=1213661&r2=1213662&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java 
(original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java 
Tue Dec 13 12:40:52 2011
@@ -472,12 +472,14 @@ public abstract class AbstractIoSession 
      * {@inheritDoc}
      */
     public WriteRequest enqueueWriteRequest(Object message) {
-        DefaultWriteRequest request = null;
+        WriteRequest request = null;
         
         try {
+            // Lock the queue while the message is written into it
             writeQueueReadLock.lock();
             
             if ( isConnectedSecured()) {
+                // SSL/TLS : we have to encrypt the message
                 SslHelper sslHelper = getAttribute( IoSession.SSL_HELPER );
                 
                 if (sslHelper == null) {
@@ -486,6 +488,7 @@ public abstract class AbstractIoSession 
                 
                 request = sslHelper.processWrite(this, message, writeQueue);
             } else {
+                // Plain message
                 request = new DefaultWriteRequest(message);
                 
                 writeQueue.add(request);