net.grinder.communication

Class Acceptor

java.lang.Object

net.grinder.communication.Acceptor

public final class Acceptor
extends Object

Active object that accepts connections on a ServerSocket.

Author:

Philip Aston

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Acceptor.Listener Listener interface.
static class	Acceptor.ShutdownException Indicates the Acceptor has been shut down.

Constructor Summary

Constructors

Constructor and Description
Acceptor(String addressString, int port, int numberOfThreads, TimeAuthority timeAuthority) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(ConnectionType connectionType, Acceptor.Listener listener) Add a new listener.
int	getNumberOfConnections() The number of connections that have been accepted and are still active.
Exception	getPendingException() Asynchronous exception handling.
int	getPort() Get the port this Acceptor is listening on.
void	shutdown() Shut down this acceptor.

Methods inherited from class java.lang.Object

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

Constructor Detail

Acceptor

public Acceptor(String addressString,
        int port,
        int numberOfThreads,
        TimeAuthority timeAuthority)
         throws CommunicationException

Constructor.

Parameters:

addressString - The TCP address to listen on. Zero-length string => listen on all interfaces.

port - The TCP port to listen to. 0 => use any free port.

numberOfThreads - Number of acceptor threads.

timeAuthority - Knows the time.

Throws:

CommunicationException - If server socket could not be bound.

Method Detail

shutdown

public void shutdown()
              throws CommunicationException

Shut down this acceptor.

Throws:

CommunicationException - If an IO exception occurs.

getPort

public int getPort()

Get the port this Acceptor is listening on.

Returns:

The port.

getPendingException

public Exception getPendingException()

Asynchronous exception handling.

Returns:

The exception, or null if this Acceptor has been shut down.

getNumberOfConnections

public int getNumberOfConnections()

The number of connections that have been accepted and are still active. Used by the unit tests.

Returns:

The number of accepted connections.

addListener

public void addListener(ConnectionType connectionType,
               Acceptor.Listener listener)

Add a new listener.

Parameters:

connectionType - The connection type.

listener - The listener.