Package org.apache.hc.core5.reactor

Class SingleCoreListeningIOReactor

java.lang.Object

org.apache.hc.core5.reactor.AbstractSingleCoreIOReactor

org.apache.hc.core5.reactor.SingleCoreListeningIOReactor

All Implemented Interfaces:

Closeable, AutoCloseable, ModalCloseable, ConnectionAcceptor, IOReactor

class SingleCoreListeningIOReactor
extends AbstractSingleCoreIOReactor
implements ConnectionAcceptor

Field Summary

Fields

Modifier and Type	Field	Description
private final Callback<ChannelEntry>	callback
private final ConcurrentMap<ListenerEndpointImpl,Boolean>	endpoints
private final AtomicBoolean	paused
private final IOReactorConfig	reactorConfig
private final Queue<ListenerEndpointRequest>	requestQueue
private final long	selectTimeoutMillis

Fields inherited from class org.apache.hc.core5.reactor.AbstractSingleCoreIOReactor

selector

Constructor Summary

Constructors

Constructor	Description
SingleCoreListeningIOReactor(Callback<Exception> exceptionCallback, IOReactorConfig ioReactorConfig, Callback<ChannelEntry> callback)

Method Summary

Modifier and Type	Method	Description
protected final void	doExecute()
(package private) void	doTerminate()
Set<ListenerEndpoint>	getEndpoints()	Returns a set of endpoints for this I/O reactor.
Future<ListenerEndpoint>	listen(SocketAddress address, Object attachment, FutureCallback<ListenerEndpoint> callback)	Opens a new listener endpoint with the given socket address.
Future<ListenerEndpoint>	listen(SocketAddress address, FutureCallback<ListenerEndpoint> callback)	Opens a new listener endpoint with the given socket address.
void	pause()	Suspends the I/O reactor preventing it from accepting new connections on all active endpoints.
private void	processEvent(SelectionKey key)
private void	processEvents(int readyCount)
private void	processSessionRequests()
void	resume()	Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints.

Methods inherited from class org.apache.hc.core5.reactor.AbstractSingleCoreIOReactor

awaitShutdown, close, close, close, execute, getStatus, initiateShutdown, logException, toString

Methods inherited from class java.lang.Object

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

Field Details

reactorConfig

private final IOReactorConfig reactorConfig

callback

private final Callback<ChannelEntry> callback

requestQueue

private final Queue<ListenerEndpointRequest> requestQueue

endpoints

private final ConcurrentMap<ListenerEndpointImpl,Boolean> endpoints

paused

private final AtomicBoolean paused

selectTimeoutMillis

private final long selectTimeoutMillis

Constructor Details

SingleCoreListeningIOReactor

SingleCoreListeningIOReactor(Callback<Exception> exceptionCallback,
 IOReactorConfig ioReactorConfig,
 Callback<ChannelEntry> callback)

Method Details

doTerminate

void doTerminate()

Specified by:

doTerminate in class AbstractSingleCoreIOReactor

doExecute

protected final void doExecute()
                        throws IOException

Specified by:

doExecute in class AbstractSingleCoreIOReactor

Throws:

IOException

processEvents

private void processEvents(int readyCount)
                    throws IOException

Throws:

IOException

processEvent

private void processEvent(SelectionKey key)
                   throws IOException

Throws:

IOException

listen

public Future<ListenerEndpoint> listen(SocketAddress address,
 Object attachment,
 FutureCallback<ListenerEndpoint> callback)

Description copied from interface: ConnectionAcceptor

Opens a new listener endpoint with the given socket address. Once the endpoint is fully initialized it starts accepting incoming connections and propagates I/O activity notifications to the I/O event dispatcher.

Specified by:

listen in interface ConnectionAcceptor

Parameters:

address - the socket address to listen on.

attachment - the attachment object.

callback - the result callback.

Returns:

listener endpoint.

listen

public Future<ListenerEndpoint> listen(SocketAddress address,
 FutureCallback<ListenerEndpoint> callback)

Description copied from interface: ConnectionAcceptor

Opens a new listener endpoint with the given socket address. Once the endpoint is fully initialized it starts accepting incoming connections and propagates I/O activity notifications to the I/O event dispatcher.

Specified by:

listen in interface ConnectionAcceptor

Parameters:

address - the socket address to listen on.

callback - the result callback.

Returns:

listener endpoint.

processSessionRequests

private void processSessionRequests()
                             throws IOException

Throws:

IOException

getEndpoints

public Set<ListenerEndpoint> getEndpoints()

Description copied from interface: ConnectionAcceptor

Returns a set of endpoints for this I/O reactor.

Specified by:

getEndpoints in interface ConnectionAcceptor

Returns:

set of endpoints.

pause

public void pause()
           throws IOException

Description copied from interface: ConnectionAcceptor

Suspends the I/O reactor preventing it from accepting new connections on all active endpoints.

Specified by:

pause in interface ConnectionAcceptor

Throws:

IOException - in case of an I/O error.

resume

public void resume()
            throws IOException

Description copied from interface: ConnectionAcceptor

Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints.

Specified by:

resume in interface ConnectionAcceptor

Throws:

IOException - in case of an I/O error.