Protected the selector againts concurrent access in a few more places

Author: Emmanuel Lécharny

mina-core/src/main/java/org/apache/mina/transport/socket/nio/NioProcessor.java

@@ -163,7 +163,14 @@ protected Iterator<NioSession> allSessions() {
     @Override
     protected int allSessionsCount()
     {
-        return selector.keys().size();
+        selectorLock.readLock().lock();
+        
+        try {
+            return selector.keys().size();
+        } finally {
+            selectorLock.readLock().unlock();
+        }
+
     }
 
     @SuppressWarnings("synthetic-access")
@@ -345,7 +352,14 @@ protected void setInterestedInRead(NioSession session, boolean isInterested) thr
         }
 
         if (oldInterestOps != newInterestOps) {
-            key.interestOps(newInterestOps);
+            // Protect the selector against concurrent accesses
+            selectorLock.readLock().lock();
+            
+            try {
+                key.interestOps(newInterestOps);
+            } finally {
+                selectorLock.readLock().unlock();
+            }
         }
     }
 
@@ -368,7 +382,14 @@ protected void setInterestedInWrite(NioSession session, boolean isInterested) th
             newInterestOps &= ~SelectionKey.OP_WRITE;
         }
 
-        key.interestOps(newInterestOps);
+        // Protect the selector against concurrent accesses
+        selectorLock.readLock().lock();
+        
+        try {
+            key.interestOps(newInterestOps);
+        } finally {
+            selectorLock.readLock().unlock();
+        }
     }
 
     @Override