Package one.nio.server.acceptor

Class DefaultAcceptorGroup

java.lang.Object

one.nio.server.acceptor.DefaultAcceptorGroup

class DefaultAcceptorGroup
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private AcceptorThread[]	acceptors
private final String	address
private final int	port
private final Server	server
(package private) CountDownLatch	syncLatch

Constructor Summary

Constructors

Constructor	Description
DefaultAcceptorGroup(Server server, AcceptorConfig ac)

Method Summary

Modifier and Type	Method	Description
long	getAcceptedSessions()
String	getAddress()
int	getPort()
long	getRejectedSessions()
boolean	isSameAddressPort(AcceptorConfig ac)
void	reconfigure(AcceptorConfig ac)
void	resetCounters()
void	shutdown()
int	size()
void	start()
void	syncStart()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

server

private final Server server

address

private final String address

port

private final int port

acceptors

private volatile AcceptorThread[] acceptors

syncLatch

CountDownLatch syncLatch

Constructor Details

DefaultAcceptorGroup

public DefaultAcceptorGroup(Server server,
 AcceptorConfig ac)
                     throws IOException

Throws:

IOException

Method Details

reconfigure

public void reconfigure(AcceptorConfig ac)
                 throws IOException

Throws:

IOException

isSameAddressPort

public boolean isSameAddressPort(AcceptorConfig ac)

start

public void start()

syncStart

public void syncStart()
               throws InterruptedException

Throws:

InterruptedException

shutdown

public void shutdown()

getAddress

public String getAddress()

getPort

public int getPort()

size

public int size()

getAcceptedSessions

public long getAcceptedSessions()

getRejectedSessions

public long getRejectedSessions()

resetCounters

public void resetCounters()

toString

public String toString()

Overrides:

toString in class Object