svn commit: r593506 - in /mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio: NioDatagramAcceptor.java NioSocketAcceptor.java

[trustin]

Author: trustin
Date: Fri Nov  9 04:08:26 2007
New Revision: 593506

URL: http://svn.apache.org/viewvc?rev=593506&view=rev
Log:
Fixed a problem that acceptor threads don't exit on partial bind failure in 
datagram and socket.

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

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java?rev=593506&r1=593505&r2=593506&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioDatagramAcceptor.java
 Fri Nov  9 04:08:26 2007
@@ -540,6 +540,7 @@
                             ExceptionMonitor.getInstance().exceptionCaught(e);
                         }
                     }
+                    selector.wakeup();
                 }
             }
         }

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioSocketAcceptor.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioSocketAcceptor.java?rev=593506&r1=593505&r2=593506&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioSocketAcceptor.java
 (original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NioSocketAcceptor.java
 Fri Nov  9 04:08:26 2007
@@ -446,7 +446,7 @@
                             ExceptionMonitor.getInstance().exceptionCaught(e);
                         }
                     }
-
+                    selector.wakeup();
                 }
             }
         }