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 2007/08/07 04:46:43 UTC
svn commit: r563371 - in
/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio:
SocketAcceptor.java support/DatagramAcceptorDelegate.java
support/DatagramConnectorDelegate.java
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();
}