| Modifier and Type | Class and Description |
|---|---|
| protected static class | |
| private static class |
| Modifier and Type | Field and Description |
|---|---|
| private final AttributeHolder | attributes
Attributes, associated with the processing Context |
| private static final ThreadCache. | |
| private Connection | connection
Processing Connection |
| protected IOEvent | ioEvent
Processing IOEvent |
| protected boolean | |
| protected final Context. | lifeCycleListeners
IOEventProcessingHandler is called to notify about IOEvent processing life-cycle events like suspend, resume, complete. |
| private static final Logger | |
| private static final Processor | |
| private Processor | processor
Processor, responsible for I/O event processing |
| protected boolean | wasSuspended
true if this IOEvent processing was suspended during its processing, or false otherwise. |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| public void | |
| public static Context | |
| public static Context | create(final Connection<L> connection, final Processor<E extends Context> processor, final IOEvent ioEvent, final IOEventLifeCycleListener lifeCycleListener)
|
| public AttributeHolder | getAttributes()
Implements org. Get attributes ( |
| public Connection | |
| public IOEvent | |
| public Processor | |
| public boolean | |
| public boolean | isManualIOEventControl()
Returns: true, if processing was switched to the manual IOEvent control, or false otherwise. |
| public void | |
| protected void | |
| public void | |
| public boolean | |
| public void | reset()
If implementation uses |
| public void | |
| public void | setConnection(final Connection<L>
the processing connection)Connection.Set the processing |
| public void | |
| public void | |
| public void | |
| public void | |
| public boolean | wasSuspended()
Returns: true if this IOEvent processing was suspended during its processing, or false otherwise. |
| attributes | back to summary |
|---|---|
| private final AttributeHolder attributes Attributes, associated with the processing Context | |
| CACHE_IDX | back to summary |
|---|---|
| private static final ThreadCache. | |
| connection | back to summary |
|---|---|
| private Connection<L> connection Processing Connection | |
| ioEvent | back to summary |
|---|---|
| protected IOEvent ioEvent Processing IOEvent | |
| isManualIOEventControl | back to summary |
|---|---|
| protected boolean isManualIOEventControl | |
| lifeCycleListeners | back to summary |
|---|---|
| protected final Context. IOEventProcessingHandler is called to notify about IOEvent processing life-cycle events like suspend, resume, complete. | |
| LOGGER | back to summary |
|---|---|
| private static final Logger LOGGER | |
| NULL_PROCESSOR | back to summary |
|---|---|
| private static final Processor<E extends Context> NULL_PROCESSOR | |
| processor | back to summary |
|---|---|
| private Processor<E extends Context> processor Processor, responsible for I/O event processing | |
| wasSuspended | back to summary |
|---|---|
| protected boolean wasSuspended true if this IOEvent processing was suspended during its processing, or false otherwise. | |
| Context | back to summary |
|---|---|
| public Context() | |
| addLifeCycleListener | back to summary |
|---|---|
| public void addLifeCycleListener(final IOEventLifeCycleListener listener) | |
| complete | back to summary |
|---|---|
| public void complete(final ProcessorResult result) | |
| create | back to summary |
|---|---|
| public static Context create(final Connection<L> connection) | |
| create | back to summary |
|---|---|
| public static Context create(final Connection<L> connection, final Processor<E extends Context> processor, final IOEvent ioEvent, final IOEventLifeCycleListener lifeCycleListener) | |
| getAttributes | back to summary |
|---|---|
| public AttributeHolder getAttributes() Implements org. Get attributes (
| |
| getConnection | back to summary |
|---|---|
| public Connection Get the processing
| |
| getIoEvent | back to summary |
|---|---|
| public IOEvent getIoEvent() Get the processing | |
| getProcessor | back to summary |
|---|---|
| public Processor Get the | |
| hasLifeCycleListener | back to summary |
|---|---|
| public boolean hasLifeCycleListener(final IOEventLifeCycleListener listener) | |
| isManualIOEventControl | back to summary |
|---|---|
public boolean isManualIOEventControl()
| |
| recycle | back to summary |
|---|---|
| public void recycle() Implements org. Recycle this
| |
| release | back to summary |
|---|---|
| protected void release() Alternative to
| |
| removeAllLifeCycleListeners | back to summary |
|---|---|
| public void removeAllLifeCycleListeners() | |
| removeLifeCycleListener | back to summary |
|---|---|
| public boolean removeLifeCycleListener(final IOEventLifeCycleListener listener) | |
| reset | back to summary |
|---|---|
| public void reset() If implementation uses | |
| resume | back to summary |
|---|---|
| public void resume() Notify Context its processing will be resumed in the current thread. | |
| setConnection | back to summary |
|---|---|
| public void setConnection(final Connection<L> connection) Set the processing
| |
| setIoEvent | back to summary |
|---|---|
| public void setIoEvent(final IOEvent ioEvent) Set the processing | |
| setManualIOEventControl | back to summary |
|---|---|
| public void setManualIOEventControl() Switches processing to the manual IOEvent control. | |
| setProcessor | back to summary |
|---|---|
| public void setProcessor(final Processor<E extends Context> processor) Set the | |
| suspend | back to summary |
|---|---|
| public void suspend() Notify Context its processing will be suspended in the current thread. | |
| wasSuspended | back to summary |
|---|---|
public boolean wasSuspended()
| |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| public E[] | |
| public void | |
| public boolean | |
| public void | |
| private void | |
| private int | |
| private boolean | |
| public int |
| MinimalisticArrayList | back to summary |
|---|---|
private MinimalisticArrayList(final Class<E> clazz, final int initialCapacity)
| |
| add | back to summary |
|---|---|
| public void add(final E listener) | |
| array | back to summary |
|---|---|
| public E[] array() | |
| clear | back to summary |
|---|---|
| public void clear() | |
| contains | back to summary |
|---|---|
| public boolean contains(final E listener) | |
| copyFrom | back to summary |
|---|---|
| public void copyFrom(final Context. | |
| ensureCapacity | back to summary |
|---|---|
| private void ensureCapacity() | |
| indexOf | back to summary |
|---|---|
| private int indexOf(final E listener) | |
| remove | back to summary |
|---|---|
| private boolean remove(final E listener) | |
| size | back to summary |
|---|---|
| public int size() | |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public boolean | isInterested(IOEvent ioEvent)
Implements org. Is this |
| public Context | obtainContext(Connection<L> connection)
Implements org. Creates |
| public ProcessorResult | process(Context context)
Implements org. Method will be called by framework to process some event, which occurred on a connection |
| public void | read(Connection<L> connection, CompletionHandler<E> completionHandler)
Implements org.
|
| public void | setInterested(IOEvent ioEvent, boolean isInterested)
Implements org. Set the the i/o event, this |
| public void | write(Connection<L> connection, Object dstAddress, Object message, CompletionHandler<E> completionHandler)
Implements org.
|
| public void | write(Connection<L> connection, Object dstAddress, Object message, CompletionHandler<E> completionHandler, MessageCloner<E> messageCloner)
Implements org.
|
| public void | write(Connection<L> connection, Object dstAddress, Object message, CompletionHandler<E> completionHandler, PushBackHandler pushBackHandler)
Implements org.
Deprecated
|
| NullProcessor | back to summary |
|---|---|
| private NullProcessor() | |
| isInterested | back to summary |
|---|---|
| public boolean isInterested(IOEvent ioEvent) Implements org. Doc from org. Is this
| |
| obtainContext | back to summary |
|---|---|
| public Context obtainContext(Connection<L> connection) Implements org. Doc from org. Creates
| |
| process | back to summary |
|---|---|
| public ProcessorResult process(Context context) Implements org. Doc from org. Method will be called by framework to process some event, which occurred on a connection
| |
| read | back to summary |
|---|---|
| public void read(Connection<L> connection, CompletionHandler<E> completionHandler) Implements org.
| |
| setInterested | back to summary |
|---|---|
| public void setInterested(IOEvent ioEvent, boolean isInterested) Implements org. Doc from org. Set the the i/o event, this
| |
| write | back to summary |
|---|---|
| public void write(Connection<L> connection, Object dstAddress, Object message, CompletionHandler<E> completionHandler) Implements org.
| |
| write | back to summary |
|---|---|
| public void write(Connection<L> connection, Object dstAddress, Object message, CompletionHandler<E> completionHandler, MessageCloner<E> messageCloner) Implements org.
| |
| write | back to summary |
|---|---|
| public void write(Connection<L> connection, Object dstAddress, Object message, CompletionHandler<E> completionHandler, PushBackHandler pushBackHandler) Implements org. Deprecated
| |