Class AprSocketConnector

java.lang.Object

org.apache.mina.core.service.AbstractIoService

org.apache.mina.core.service.AbstractIoConnector

org.apache.mina.core.polling.AbstractPollingIoConnector<AprSession, Long>

org.apache.mina.transport.socket.apr.AprSocketConnector

All Implemented Interfaces:

IoConnector, IoService, SocketConnector

public final class AprSocketConnector
extends AbstractPollingIoConnector<AprSession, Long>
implements SocketConnector

IoConnector for APR based socket transport (TCP/IP).

Nested Class Summary

Nested classes/interfaces inherited from class AbstractPollingIoConnector

AbstractPollingIoConnector.ConnectionRequest

Nested classes/interfaces inherited from class AbstractIoService

AbstractIoService.ServiceOperationFuture

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	APR_TIMEUP_ERROR	This constant is deduced from the APR code.
private ByteBuffer	dummyBuffer
private final Set<Long>	failedHandles
private final Queue<Long>	polledHandles
private final long[]	polledSockets
private long	pollset
private static final int	POLLSET_SIZE
private long	pool
private final Map<Long, AbstractPollingIoConnector<AprSession, Long>.ConnectionRequest>	requests
private boolean	toBeWakenUp
private final Object	wakeupLock
private long	wakeupSocket

Fields inherited from class AbstractIoService

disposalLock, LOGGER, sessionConfig

Constructor Summary

Constructors

Constructor	Description
AprSocketConnector()	Create an AprSocketConnector with default configuration (multiple thread model).
AprSocketConnector(int processorCount)	Constructor for AprSocketConnector with default configuration, and given number of AprIoProcessor for multithreading I/O operations
AprSocketConnector(Executor executor, IoProcessor<AprSession> processor)	Constructor for AprSocketConnector with a given Executor for handling connection events and a given IoProcessor for handling I/O events, useful for sharing the same processor and executor over multiple IoService of the same type.
AprSocketConnector(IoProcessor<AprSession> processor)	Constructor for AprSocketConnector with default configuration but a specific IoProcessor, useful for sharing the same processor over multiple IoService of the same type.

Method Summary

Modifier and Type	Method	Description
protected Iterator<Long>	allHandles()	Iterator for all the client sockets polled for connection.
protected void	close(Long handle)	Close a client socket.
protected boolean	connect(Long handle, SocketAddress remoteAddress)	Connect a newly created client socket handle to a remote SocketAddress.
protected void	destroy()	Destroy the polling system, will be called when this IoConnector implementation will be disposed.
protected boolean	finishConnect(Long handle)	Finish the connection process of a client socket after it was marked as ready to process by the AbstractPollingIoConnector.select(int) call.
protected AbstractPollingIoConnector<AprSession, Long>.ConnectionRequest	getConnectionRequest(Long handle)	get the AbstractPollingIoConnector<S extends AbstractIoSession, H>.ConnectionRequest for a given client socket handle
InetSocketAddress	getDefaultRemoteAddress()
SocketSessionConfig	getSessionConfig()
TransportMetadata	getTransportMetadata()
protected void	init()	Initialize the polling system, will be called at construction time.
protected Long	newHandle(SocketAddress localAddress)	Create a new client socket handle from a local SocketAddress
protected AprSession	newSession(IoProcessor<AprSession> processor, Long handle)	Create a new IoSession from a connected socket client handle.
protected void	register(Long handle, AbstractPollingIoConnector<AprSession, Long>.ConnectionRequest request)	Register a new client socket for connection, add it to connection polling
protected int	select(int timeout)	Check for connected sockets, interrupt when at least a connection is processed (connected or failed to connect).
protected Iterator<Long>	selectedHandles()	Iterator for the set of client sockets found connected or failed to connect during the last AbstractPollingIoConnector.select(int) call.
void	setDefaultRemoteAddress(InetSocketAddress defaultRemoteAddress)	Sets the default remote InetSocketAddress to connect to when no argument is specified in IoConnector.connect() method.
private void	throwException(int code)	transform an APR error number in a more fancy exception
protected void	wakeup()	Interrupt the AbstractPollingIoConnector.select(int) method.

Methods inherited from class AbstractPollingIoConnector

connect0, dispose0

Methods inherited from class AbstractIoConnector

connect, connect, connect, connect, connect, connect, finishSessionInitialization0, getConnectTimeout, getConnectTimeoutCheckInterval, getConnectTimeoutMillis, getDefaultLocalAddress, setConnectTimeout, setConnectTimeoutCheckInterval, setConnectTimeoutMillis, setDefaultLocalAddress, setDefaultRemoteAddress, toString

Methods inherited from class AbstractIoService

addListener, broadcast, dispose, dispose, executeWorker, executeWorker, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getListeners, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, initSession, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

Methods inherited from class Object

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

Methods inherited from interface IoConnector

connect, connect, connect, connect, connect, connect, getConnectTimeout, getConnectTimeoutMillis, getDefaultLocalAddress, setConnectTimeout, setConnectTimeoutMillis, setDefaultLocalAddress, setDefaultRemoteAddress

Methods inherited from interface IoService

addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

Field Details

APR_TIMEUP_ERROR

private static final int APR_TIMEUP_ERROR

This constant is deduced from the APR code. It is used when the timeout has expired while doing a poll() operation.

See Also:

• Constant Field Values

POLLSET_SIZE

private static final int POLLSET_SIZE

See Also:

• Constant Field Values

requests

private final Map<Long, AbstractPollingIoConnector<AprSession, Long>.ConnectionRequest> requests

wakeupLock

private final Object wakeupLock

wakeupSocket

private volatile long wakeupSocket

toBeWakenUp

private volatile boolean toBeWakenUp

pool

private volatile long pool

pollset

private volatile long pollset

polledSockets

private final long[] polledSockets

polledHandles

private final Queue<Long> polledHandles

failedHandles

private final Set<Long> failedHandles

dummyBuffer

private volatile ByteBuffer dummyBuffer

Constructor Details

AprSocketConnector

public AprSocketConnector()

Create an AprSocketConnector with default configuration (multiple thread model).

AprSocketConnector

public AprSocketConnector(int processorCount)

Constructor for AprSocketConnector with default configuration, and given number of AprIoProcessor for multithreading I/O operations

Parameters:

processorCount - the number of processor to create and place in a SimpleIoProcessorPool

AprSocketConnector

public AprSocketConnector(IoProcessor<AprSession> processor)

Constructor for AprSocketConnector with default configuration but a specific IoProcessor, useful for sharing the same processor over multiple IoService of the same type.

Parameters:

processor - the processor to use for managing I/O events

AprSocketConnector

public AprSocketConnector(Executor executor,
 IoProcessor<AprSession> processor)

Constructor for AprSocketConnector with a given Executor for handling connection events and a given IoProcessor for handling I/O events, useful for sharing the same processor and executor over multiple IoService of the same type.

Parameters:

executor - the executor for connection

processor - the processor for I/O operations

Method Details

init

protected void init()
             throws Exception

Initialize the polling system, will be called at construction time.

Specified by:

init in class AbstractPollingIoConnector<AprSession, Long>

Throws:

Exception - any exception thrown by the underlying system calls

destroy

protected void destroy()
                throws Exception

Destroy the polling system, will be called when this IoConnector implementation will be disposed.

Specified by:

destroy in class AbstractPollingIoConnector<AprSession, Long>

Throws:

Exception - any exception thrown by the underlying systems calls

allHandles

protected Iterator<Long> allHandles()

Iterator for all the client sockets polled for connection.

Specified by:

allHandles in class AbstractPollingIoConnector<AprSession, Long>

Returns:

the list of client sockets currently polled for connection

connect

protected boolean connect(Long handle,
 SocketAddress remoteAddress)
                   throws Exception

Connect a newly created client socket handle to a remote SocketAddress. This operation is non-blocking, so at end of the call the socket can be still in connection process.

Specified by:

connect in class AbstractPollingIoConnector<AprSession, Long>

Parameters:

handle - the client socket handle

remoteAddress - the remote address where to connect

Returns:

true if a connection was established, false if this client socket is in non-blocking mode and the connection operation is in progress

Throws:

Exception - If the connect failed

getConnectionRequest

protected AbstractPollingIoConnector<AprSession, Long>.ConnectionRequest getConnectionRequest(Long handle)

get the AbstractPollingIoConnector<S extends AbstractIoSession, H>.ConnectionRequest for a given client socket handle

Specified by:

getConnectionRequest in class AbstractPollingIoConnector<AprSession, Long>

Parameters:

handle - the socket client handle

Returns:

the connection request if the socket is connecting otherwise null

close

protected void close(Long handle)
              throws Exception

Close a client socket.

Specified by:

close in class AbstractPollingIoConnector<AprSession, Long>

Parameters:

handle - the client socket

Throws:

Exception - any exception thrown by the underlying systems calls

finishConnect

protected boolean finishConnect(Long handle)
                         throws Exception

Finish the connection process of a client socket after it was marked as ready to process by the AbstractPollingIoConnector.select(int) call. The socket will be connected or reported as connection failed.

Specified by:

finishConnect in class AbstractPollingIoConnector<AprSession, Long>

Parameters:

handle - the client socket handle to finish to connect

Returns:

true if the socket is connected

Throws:

Exception - any exception thrown by the underlying systems calls

newHandle

protected Long newHandle(SocketAddress localAddress)
                  throws Exception

Create a new client socket handle from a local SocketAddress

Specified by:

newHandle in class AbstractPollingIoConnector<AprSession, Long>

Parameters:

localAddress - the socket address for binding the new client socket

Returns:

a new client socket handle

Throws:

Exception - any exception thrown by the underlying systems calls

newSession

protected AprSession newSession(IoProcessor<AprSession> processor,
 Long handle)
                         throws Exception

Create a new IoSession from a connected socket client handle. Will assign the created IoSession to the given IoProcessor for managing future I/O events.

Specified by:

newSession in class AbstractPollingIoConnector<AprSession, Long>

Parameters:

processor - the processor in charge of this session

handle - the newly connected client socket handle

Returns:

a new IoSession

Throws:

Exception - any exception thrown by the underlying systems calls

register

protected void register(Long handle,
 AbstractPollingIoConnector<AprSession, Long>.ConnectionRequest request)
                 throws Exception

Register a new client socket for connection, add it to connection polling

Specified by:

register in class AbstractPollingIoConnector<AprSession, Long>

Parameters:

handle - client socket handle

request - the associated AbstractPollingIoConnector<S extends AbstractIoSession, H>.ConnectionRequest

Throws:

Exception - any exception thrown by the underlying systems calls

select

protected int select(int timeout)
              throws Exception

Check for connected sockets, interrupt when at least a connection is processed (connected or failed to connect). All the client socket descriptors processed need to be returned by AbstractPollingIoConnector.selectedHandles()

Specified by:

select in class AbstractPollingIoConnector<AprSession, Long>

Parameters:

timeout - The timeout for the select() method

Returns:

The number of socket having received some data

Throws:

Exception - any exception thrown by the underlying systems calls

selectedHandles

protected Iterator<Long> selectedHandles()

Iterator for the set of client sockets found connected or failed to connect during the last AbstractPollingIoConnector.select(int) call.

Specified by:

selectedHandles in class AbstractPollingIoConnector<AprSession, Long>

Returns:

the list of client socket handles to process

wakeup

protected void wakeup()

Interrupt the AbstractPollingIoConnector.select(int) method. Used when the poll set need to be modified.

Specified by:

wakeup in class AbstractPollingIoConnector<AprSession, Long>

getTransportMetadata

public TransportMetadata getTransportMetadata()

Specified by:

getTransportMetadata in interface IoService

Returns:

the TransportMetadata that this service runs on.

getSessionConfig

public SocketSessionConfig getSessionConfig()

Specified by:

getSessionConfig in interface IoService

Specified by:

getSessionConfig in interface SocketConnector

Returns:

the default configuration of the new IoSessions created by this service.

getDefaultRemoteAddress

public InetSocketAddress getDefaultRemoteAddress()

Specified by:

getDefaultRemoteAddress in interface IoConnector

Specified by:

getDefaultRemoteAddress in interface SocketConnector

Overrides:

getDefaultRemoteAddress in class AbstractIoConnector

Returns:

the default remote address to connect to when no argument is specified in IoConnector.connect() method.

setDefaultRemoteAddress

public void setDefaultRemoteAddress(InetSocketAddress defaultRemoteAddress)

Sets the default remote InetSocketAddress to connect to when no argument is specified in IoConnector.connect() method. This method overrides the IoConnector.setDefaultRemoteAddress(java.net.SocketAddress) method.

Specified by:

setDefaultRemoteAddress in interface SocketConnector

Parameters:

defaultRemoteAddress - The remote address to set

throwException

private void throwException(int code)
                     throws IOException

transform an APR error number in a more fancy exception

Parameters:

code - APR error code

Throws:

IOException - the produced exception for the given APR error number