You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by tr...@apache.org on 2006/11/27 11:01:27 UTC

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

Author: trustin
Date: Mon Nov 27 02:01:26 2006
New Revision: 479566

URL: http://svn.apache.org/viewvc?view=rev&rev=479566
Log:
Resolved issue: DIRMINA-308 (NullPointerException in SocketIoProcessor under heavy load)

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

Modified: mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketIoProcessor.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketIoProcessor.java?view=diff&rev=479566&r1=479565&r2=479566
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketIoProcessor.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketIoProcessor.java Mon Nov 27 02:01:26 2006
@@ -75,15 +75,12 @@
         newSessions.offer( session );
 
         startupWorker();
-
-        selector.wakeup();
     }
 
     void remove( SocketSessionImpl session ) throws IOException
     {
         scheduleRemove( session );
         startupWorker();
-        selector.wakeup();
     }
 
     private void startupWorker() throws IOException
@@ -96,6 +93,7 @@
                 worker = new Worker();
                 executor.execute( new NamePreservingRunnable( worker ) );
             }
+            selector.wakeup();
         }
     }