directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trus...@apache.org
Subject svn commit: r123280 - /incubator/directory/network/trunk/mina/src/java/org/apache/mina/io/socket/SocketIoProcessor.java
Date Fri, 24 Dec 2004 07:06:15 GMT
Author: trustin
Date: Thu Dec 23 23:06:14 2004
New Revision: 123280

URL: http://svn.apache.org/viewcvs?view=rev&rev=123280
Log:
Removed unused methods from SocketIoProcessor
Modified:
   incubator/directory/network/trunk/mina/src/java/org/apache/mina/io/socket/SocketIoProcessor.java

Modified: incubator/directory/network/trunk/mina/src/java/org/apache/mina/io/socket/SocketIoProcessor.java
Url: http://svn.apache.org/viewcvs/incubator/directory/network/trunk/mina/src/java/org/apache/mina/io/socket/SocketIoProcessor.java?view=diff&rev=123280&p1=incubator/directory/network/trunk/mina/src/java/org/apache/mina/io/socket/SocketIoProcessor.java&r1=123279&p2=incubator/directory/network/trunk/mina/src/java/org/apache/mina/io/socket/SocketIoProcessor.java&r2=123280
==============================================================================
--- incubator/directory/network/trunk/mina/src/java/org/apache/mina/io/socket/SocketIoProcessor.java
(original)
+++ incubator/directory/network/trunk/mina/src/java/org/apache/mina/io/socket/SocketIoProcessor.java
Thu Dec 23 23:06:14 2004
@@ -167,31 +167,6 @@
         }
     }
 
-    private void addReadableSessions()
-    {
-        if( readableSessions.isEmpty() )
-            return;
-
-        SocketSession session;
-
-        for( ;; )
-        {
-            synchronized( readableSessions )
-            {
-                session = ( SocketSession ) readableSessions.pop();
-            }
-
-            if( session == null )
-                break;
-
-            SelectionKey key = session.getSelectionKey();
-            if( ( key.interestOps() & SelectionKey.OP_READ ) == 0 )
-            {
-                key.interestOps( key.interestOps() | SelectionKey.OP_READ );
-            }
-        }
-    }
-
     private void removeSessions()
     {
         if( removingSessions.isEmpty() )
@@ -288,10 +263,6 @@
                     else
                     {
                         // FIXME will spin in multi-threaded env.
-                        
-//                        SelectionKey key = session.getSelectionKey();
-//                        key.interestOps( key.interestOps()
-//                                         & ( ~SelectionKey.OP_READ ) );
                     }
                 }
                 else
@@ -480,8 +451,6 @@
                             }
                         }
                     }
-
-                    addReadableSessions();
 
                     if( nKeys > 0 )
                     {

Mime
View raw message