svn commit: r1145950 - in /commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net: LocalServerEndpoint.java ServerEndpoint.java

[mturk]

Author: mturk
Date: Wed Jul 13 10:30:15 2011
New Revision: 1145950

URL: http://svn.apache.org/viewvc?rev=1145950&view=rev
Log:
Add explicit blocking mode acceptor

Modified:
    
commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/LocalServerEndpoint.java
    
commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/ServerEndpoint.java

Modified: 
commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/LocalServerEndpoint.java
URL: 
http://svn.apache.org/viewvc/commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/LocalServerEndpoint.java?rev=1145950&r1=1145949&r2=1145950&view=diff
==============================================================================
--- 
commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/LocalServerEndpoint.java
 (original)
+++ 
commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/LocalServerEndpoint.java
 Wed Jul 13 10:30:15 2011
@@ -181,6 +181,13 @@ public class LocalServerEndpoint extends
     public LocalEndpoint accept()
         throws IOException
     {
+        return accept(blocking);
+    }
+
+    @Override
+    public LocalEndpoint accept(boolean blocking)
+        throws IOException
+    {
         if (sd.closed())
             throw new ClosedDescriptorException();
         long fd = accept0(sd.fd(), sa.sockaddr(), blocking);

Modified: 
commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/ServerEndpoint.java
URL: 
http://svn.apache.org/viewvc/commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/ServerEndpoint.java?rev=1145950&r1=1145949&r2=1145950&view=diff
==============================================================================
--- 
commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/ServerEndpoint.java
 (original)
+++ 
commons/sandbox/runtime/trunk/src/main/java/org/apache/commons/runtime/net/ServerEndpoint.java
 Wed Jul 13 10:30:15 2011
@@ -46,6 +46,9 @@ public abstract class ServerEndpoint<E> 
     public abstract E accept()
         throws IOException;
 
+    public abstract E accept(boolean blocking)
+        throws IOException;
+        
     public abstract void bind(EndpointAddress endpoint, int backlog)
         throws IOException;