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;
+
/**
* [EMAIL PROTECTED] IoAcceptor} for socket transport (TCP/IP).
*
- * @author Trustin Lee ([EMAIL PROTECTED])
+ * @author <a href="mailto:[email protected]">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;