You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by ak...@apache.org on 2005/03/24 03:42:51 UTC

svn commit: r158865 - directory/network/trunk/src/java/org/apache/mina/io/socket/SocketAcceptor.java

Author: akarasulu
Date: Wed Mar 23 18:42:49 2005
New Revision: 158865

URL: http://svn.apache.org/viewcvs?view=rev&rev=158865
Log:
more formatting and replaced @author tags

Modified:
    directory/network/trunk/src/java/org/apache/mina/io/socket/SocketAcceptor.java

Modified: directory/network/trunk/src/java/org/apache/mina/io/socket/SocketAcceptor.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/io/socket/SocketAcceptor.java?view=diff&r1=158864&r2=158865
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/io/socket/SocketAcceptor.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/io/socket/SocketAcceptor.java Wed Mar 23 18:42:49 2005
@@ -18,6 +18,7 @@
  */
 package org.apache.mina.io.socket;
 
+
 import java.io.IOException;
 import java.net.InetSocketAddress;
 import java.net.SocketAddress;
@@ -37,10 +38,11 @@
 import org.apache.mina.io.IoHandlerFilterChain;
 import org.apache.mina.util.Queue;
 
+
 /**
  * {@link IoAcceptor} for socket transport (TCP/IP).
  * 
- * @author Trustin Lee (trustin@apache.org)
+ * @author <a href="mailto:dev@directory.apache.org">Apache Directory Project</a>
  * @version $Rev$, $Date$
  */
 public class SocketAcceptor implements IoAcceptor
@@ -63,6 +65,7 @@
 
     private Worker worker;
 
+
     /**
      * Creates a new instance.
      * 
@@ -73,12 +76,13 @@
         selector = Selector.open();
     }
 
-    public void bind( SocketAddress address, IoHandler handler )
-            throws IOException
+
+    public void bind( SocketAddress address, IoHandler handler ) throws IOException
     {
         this.bind( address, 50, handler );
     }
 
+
     /**
      * Binds to the specified <code>address</code> and handles incoming
      * connections with the specified <code>handler</code>.
@@ -152,6 +156,7 @@
         }
     }
 
+
     public void unbind( SocketAddress address )
     {
         if( address == null )
@@ -190,6 +195,7 @@
         }
     }
 
+
     private class Worker extends Thread
     {
         public Worker()
@@ -270,6 +276,7 @@
         }
     }
 
+
     private void registerNew()
     {
         if( registerQueue.isEmpty() )
@@ -443,6 +450,7 @@
         }
     }
 
+    
     public ExceptionMonitor getExceptionMonitor()
     {
         return exceptionMonitor;