Package one.nio.server.acceptor

Class DefaultAcceptorGroup

java.lang.Object

one.nio.server.acceptor.DefaultAcceptorGroup

class DefaultAcceptorGroup
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private AcceptorThread[]	acceptors
private java.lang.String	address
private int	port
private Server	server
(package private) java.util.concurrent.CountDownLatch	syncLatch

Constructor Summary

Constructors

Constructor	Description
DefaultAcceptorGroup(Server server, AcceptorConfig ac)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

server

private final Server server

address

private final java.lang.String address

port

private final int port

acceptors

private volatile AcceptorThread[] acceptors

syncLatch

java.util.concurrent.CountDownLatch syncLatch

Constructor Detail

DefaultAcceptorGroup

public DefaultAcceptorGroup(Server server,
                            AcceptorConfig ac)
                     throws java.io.IOException

Throws:

java.io.IOException

Method Detail

reconfigure

public void reconfigure(AcceptorConfig ac)
                 throws java.io.IOException

Throws:

java.io.IOException

isSameAddressPort

public boolean isSameAddressPort(AcceptorConfig ac)

start

public void start()

syncStart

public void syncStart()
               throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

shutdown

public void shutdown()

getAddress

public java.lang.String getAddress()

getPort

public int getPort()

size

public int size()

getAcceptedSessions

public long getAcceptedSessions()

getRejectedSessions

public long getRejectedSessions()

resetCounters

public void resetCounters()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object