Package net.officefloor.server

Class SocketManager

java.lang.Object

net.officefloor.server.SocketManager

public class SocketManager
extends Object

Manages the Socket interaction.

Author:

Daniel Sagenschneider

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_SERVER_SOCKET_BACKLOG_SIZE	Default ServerSocket backlog size.

Constructor Summary

Constructors

Constructor	Description
SocketManager(int listenerCount, int socketReceiveBufferSize, int maxReadsOnSelect, int maxActiveSocketRequests, StreamBufferPool<ByteBuffer> bufferPool, int socketSendBufferSize)	Instantiate.

Method Summary

Modifier and Type	Method	Description
final <R> ServerSocket	bindServerSocket(int port, ServerSocketDecorator serverSocketDecorator, AcceptedSocketDecorator acceptedSocketDecorator, SocketServicerFactory<R> socketServicerFactory, RequestServicerFactory<R> requestServicerFactory)	Binds a ServerSocket to be serviced.
static long	getMaxDirectMemory()	Obtains the max direct memory.
static long	getMaxHeapMemory()	Obtains the max heap memory.
final Runnable[]	getRunnables()	Obtains the Runnable instances to be executed for this SocketManager.
final void	shutdown()	Shuts down this SocketManager.

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SERVER_SOCKET_BACKLOG_SIZE

public static final int DEFAULT_SERVER_SOCKET_BACKLOG_SIZE

Default ServerSocket backlog size.

See Also:

• Constant Field Values

Constructor Details

SocketManager

public SocketManager(int listenerCount,
 int socketReceiveBufferSize,
 int maxReadsOnSelect,
 int maxActiveSocketRequests,
 StreamBufferPool<ByteBuffer> bufferPool,
 int socketSendBufferSize)
              throws IOException

Instantiate.

Parameters:

listenerCount - Number of SocketManager.SocketListener instances.

socketReceiveBufferSize - Receive buffer size for the Socket.

maxReadsOnSelect - Maximum number of reads per SocketChannel per select. The Selector has locking overheads that slow performance. By undertaking multiple reads on the SocketChannel it makes draining and servicing more efficient (and subsequently faster). This also allows the StreamBuffer sizes to be smaller than the receive Socket buffer size (but still maintain efficiency).

maxActiveSocketRequests - Maximum number of active SocketManager.SocketRequest instances per accepted Socket.

bufferPool - StreamBufferPool.

socketSendBufferSize - Send buffer size for the Socket.

Throws:

IOException - If fails to initialise Socket management.

Method Details

getMaxDirectMemory

public static long getMaxDirectMemory()

Obtains the max direct memory.

Returns:

Max direct memory.

getMaxHeapMemory

public static long getMaxHeapMemory()

Obtains the max heap memory.

Returns:

Max heap memory.

getRunnables

public final Runnable[] getRunnables()

Obtains the Runnable instances to be executed for this SocketManager.

Returns:

Runnable instances to be executed for this SocketManager.

bindServerSocket

public final <R> ServerSocket bindServerSocket(int port,
 ServerSocketDecorator serverSocketDecorator,
 AcceptedSocketDecorator acceptedSocketDecorator,
 SocketServicerFactory<R> socketServicerFactory,
 RequestServicerFactory<R> requestServicerFactory)
                                        throws IOException

Binds a ServerSocket to be serviced.

Type Parameters:

R - Request type.

Parameters:

port - Port for the ServerSocket.

serverSocketDecorator - Optional ServerSocketDecorator. May be null.

acceptedSocketDecorator - Optional AcceptedSocketDecorator. May be null.

socketServicerFactory - SocketServicerFactory to service accepted connections.

requestServicerFactory - RequestServicerFactory to service requests on the Socket.

Returns:

Bound ServerSocket.

Throws:

IOException - If fails to bind the ServerSocket.

shutdown

public final void shutdown()
                    throws IOException

Shuts down this SocketManager. This involves closing all Socket instances being managed and stopping the SocketManager.SocketListener instances.

Throws:

IOException - If fails to shutdown this SocketManager.