svn commit: r563371 - in /mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio: SocketAcceptor.java support/DatagramAcceptorDelegate.java support/DatagramConnectorDelegate.java

[trustin]

Author: trustin
Date: Mon Aug  6 19:46:43 2007
New Revision: 563371

URL: http://svn.apache.org/viewvc?view=rev&rev=563371
Log:
Just trivial changes to the startup order of selector, which doesn't affect 
anything at all.
(Wanted to look things good ;)

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java
    
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
    
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java?view=diff&rev=563371&r1=563370&r2=563371
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java
 Mon Aug  6 19:46:43 2007
@@ -251,13 +251,13 @@
     protected void doBind() throws IOException {
         RegistrationRequest request = new RegistrationRequest();
 
-        // adds the Registration request to the queue for the Workers 
-        // to handle
-        registerQueue.offer(request);
-        
         // creates an instance of a Worker and has the local 
         // executor kick it off.
         startupWorker();
+
+        // adds the Registration request to the queue for the Workers 
+        // to handle
+        registerQueue.offer(request);
         selector.wakeup();
 
         synchronized (request) {

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java?view=diff&rev=563371&r1=563370&r2=563371
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
 Mon Aug  6 19:46:43 2007
@@ -125,8 +125,8 @@
     protected void doBind() throws IOException {
         RegistrationRequest request = new RegistrationRequest();
 
-        registerQueue.offer(request);
         startupWorker();
+        registerQueue.offer(request);
         selector.wakeup();
 
         synchronized (request) {
@@ -150,8 +150,8 @@
     protected void doUnbind() {
         CancellationRequest request = new CancellationRequest();
 
-        cancelQueue.offer(request);
         startupWorker();
+        cancelQueue.offer(request);
         selector.wakeup();
 
         synchronized (request) {

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java?view=diff&rev=563371&r1=563370&r2=563371
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
 Mon Aug  6 19:46:43 2007
@@ -147,8 +147,8 @@
 
         RegistrationRequest request = new RegistrationRequest(ch);
 
-        registerQueue.offer(request);
         startupWorker();
+        registerQueue.offer(request);
         selector.wakeup();
 
         return request;
@@ -162,8 +162,8 @@
     }
 
     public void closeSession(DatagramSessionImpl session) {
-        cancelQueue.offer(session);
         startupWorker();
+        cancelQueue.offer(session);
         selector.wakeup();
     }