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;