public class BaseIOReactor extends AbstractIOReactor
AbstractIOReactor
that serves as a base
for more advanced IOReactor
implementations. This class adds support for the I/O event dispatching
using IOEventDispatch
, management of buffering sessions, and
session timeout handling.Constructor and Description |
---|
BaseIOReactor(long selectTimeout)
Creates new BaseIOReactor instance.
|
BaseIOReactor(long selectTimeout,
boolean interestOpsQueueing)
Creates new BaseIOReactor instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
acceptable(SelectionKey key)
This I/O reactor implementation does not react to the
SelectionKey.OP_ACCEPT event. |
protected void |
connectable(SelectionKey key)
This I/O reactor implementation does not react to the
SelectionKey.OP_CONNECT event. |
void |
execute(IOEventDispatch eventDispatch)
Activates the I/O reactor.
|
protected void |
handleRuntimeException(RuntimeException ex)
Handles the given
RuntimeException . |
protected void |
readable(SelectionKey key)
Processes
SelectionKey.OP_READ event on the given selection key. |
protected void |
sessionClosed(IOSession session)
Processes closed I/O session.
|
protected void |
sessionCreated(SelectionKey key,
IOSession session)
Processes newly created I/O session.
|
protected void |
sessionTimedOut(IOSession session)
Processes timed out I/O session.
|
void |
setExceptionHandler(IOReactorExceptionHandler exceptionHandler)
Sets exception handler for this I/O reactor.
|
protected void |
validate(Set<SelectionKey> keys)
Verifies whether any of the sessions associated with the given selection
keys timed out by invoking the
AbstractIOReactor.timeoutCheck(SelectionKey, long)
method. |
protected void |
writable(SelectionKey key)
Processes
SelectionKey.OP_WRITE event on the given selection key. |
addChannel, awaitShutdown, closeActiveChannels, closeNewChannels, closeSessions, execute, getInterestOpsQueueing, getSession, getStatus, gracefulShutdown, hardShutdown, processEvent, queueClosedSession, shutdown, shutdown, timeoutCheck
public BaseIOReactor(long selectTimeout) throws IOReactorException
selectTimeout
- the select timeout.IOReactorException
- in case if a non-recoverable I/O error.public BaseIOReactor(long selectTimeout, boolean interestOpsQueueing) throws IOReactorException
selectTimeout
- the select timeout.interestOpsQueueing
- Ops queueing flag.IOReactorException
- in case if a non-recoverable I/O error.public void execute(IOEventDispatch eventDispatch) throws InterruptedIOException, IOReactorException
IOEventDispatch
.eventDispatch
- the I/O event dispatch.InterruptedIOException
- if the dispatch thread is interrupted.IOReactorException
- in case if a non-recoverable I/O error.public void setExceptionHandler(IOReactorExceptionHandler exceptionHandler)
exceptionHandler
- the exception handler.protected void handleRuntimeException(RuntimeException ex)
RuntimeException
. This method delegates
handling of the exception to the IOReactorExceptionHandler
,
if available.ex
- the runtime exception.protected void acceptable(SelectionKey key)
SelectionKey.OP_ACCEPT
event.
Super-classes can override this method to react to the event.
acceptable
in class AbstractIOReactor
key
- the selection key.protected void connectable(SelectionKey key)
SelectionKey.OP_CONNECT
event.
Super-classes can override this method to react to the event.
connectable
in class AbstractIOReactor
key
- the selection key.protected void readable(SelectionKey key)
SelectionKey.OP_READ
event on the given selection key.
This method dispatches the event notification to the
IOEventDispatch.inputReady(IOSession)
method.readable
in class AbstractIOReactor
key
- the selection key.protected void writable(SelectionKey key)
SelectionKey.OP_WRITE
event on the given selection key.
This method dispatches the event notification to the
IOEventDispatch.outputReady(IOSession)
method.writable
in class AbstractIOReactor
key
- the selection key.protected void validate(Set<SelectionKey> keys)
AbstractIOReactor.timeoutCheck(SelectionKey, long)
method.
This method will also invoke the
IOEventDispatch.inputReady(IOSession)
method on all sessions
that have buffered input data.
validate
in class AbstractIOReactor
keys
- all selection keys registered with the selector.protected void sessionCreated(SelectionKey key, IOSession session)
IOEventDispatch.connected(IOSession)
method.sessionCreated
in class AbstractIOReactor
key
- the selection key.session
- new I/O session.protected void sessionTimedOut(IOSession session)
IOEventDispatch.timeout(IOSession)
method.sessionTimedOut
in class AbstractIOReactor
session
- timed out I/O session.protected void sessionClosed(IOSession session)
IOEventDispatch.disconnected(IOSession)
method.sessionClosed
in class AbstractIOReactor
session
- closed I/O session.Copyright © 2005–2022 The Apache Software Foundation. All rights reserved.