Class DefaultAcceptor

java.lang.Object

one.nio.server.acceptor.DefaultAcceptor

All Implemented Interfaces:

Acceptor

public class DefaultAcceptor
extends Object
implements Acceptor

Field Summary

Fields

Modifier and Type	Field	Description
private DefaultAcceptorGroup[]	acceptorGroups
private static final org.slf4j.Logger	log
private final Server	server

Constructor Summary

Constructors

Constructor	Description
DefaultAcceptor(Server server, AcceptorConfig... configs)

Method Summary

Modifier and Type	Method	Description
long	getAcceptedSessions()
long	getRejectedSessions()
int	getSinglePort()
void	reconfigure(AcceptorConfig... configs)
void	resetCounters()
void	shutdown()
void	start()
void	syncStart()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

log

private static final org.slf4j.Logger log

server

private final Server server

acceptorGroups

private volatile DefaultAcceptorGroup[] acceptorGroups

Constructor Details

DefaultAcceptor

DefaultAcceptor(Server server,
 AcceptorConfig... configs)
         throws IOException

Throws:

IOException

Method Details

reconfigure

public void reconfigure(AcceptorConfig... configs)
                 throws IOException

Specified by:

reconfigure in interface Acceptor

Throws:

IOException

start

public void start()

Specified by:

start in interface Acceptor

shutdown

public void shutdown()

Specified by:

shutdown in interface Acceptor

syncStart

public void syncStart()
               throws InterruptedException

Specified by:

syncStart in interface Acceptor

Throws:

InterruptedException

getAcceptedSessions

public long getAcceptedSessions()

Specified by:

getAcceptedSessions in interface Acceptor

getRejectedSessions

public long getRejectedSessions()

Specified by:

getRejectedSessions in interface Acceptor

resetCounters

public void resetCounters()

Specified by:

resetCounters in interface Acceptor

getSinglePort

public int getSinglePort()

Specified by:

getSinglePort in interface Acceptor