Package org.jppf.nio

package org.jppf.nio

Support for asynchronous communication between JPPF components. Classes in this package build a transport-independant layer, to provide a unified interface for all tyes of I/O (network socket or channel-based, file or in-memory I/O). They also abstract the notion of secure vs. non-secure communications.

Related Packages

Package	Description
org.jppf	Base classes used throughout the framework.
org.jppf.nio.acceptor	Support for NIO-based communication with the clients.

Class	Description
AbstractNioContext	Context associated with an open communication channel.
AbstractNioMessage	Common abstract superclass representing a message sent or received by a channel.
AbstractNioMessageBase	Common abstract superclass representing a message sent or received by a channel.
AbstractNioObject	Abstract implementation of the NioObject interface, providing the means to keep stateful information across multiple calls to the read() or write() methods.
AbstractSSLHandler	Wrapper for an SSLEngine and an associated channel.
AcceptChannelTask	This task performs the processing of a newly accepted channel.
ClassLoaderNioMessage	Nio message that reads or writes a single object from/to the network.
CloseableContext
NioChannelHandler
NioConstants
NioContext	Context associated with an open communication channel.
NioHelper	Utility methods to help with managing nio servers.
NioMessage	Common interface for sending data over a communication channel.
NioMessageReader<C extends AbstractNioContext>	Reads from the channel until no more data is available.
NioMessageReader.MessageHandler<C extends AbstractNioContext>
NioMessageWriter<C extends AbstractNioContext>	Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.
NioObject	Abstraction of a sequence of data read from, or written to a data channel.
NioServer	Generic server for non-blocking asynchronous socket channel based communications. Instances of this class rely on a number of possible states for each socket channel, along with the possible transitions between thoses states. The design of this class enforces the use of typesafe enumerations for the states and transitions, so the developers must think ahead of how to implement their server as a state machine.
PlainNioObject	Instances of this class represent a data frame read asynchronously from an input source.
SelectorSynchronizer	Synchronization aid for a Selector, to prevent SelectionKey.interestOps(int) invocations from blocking for too long.
SelectorSynchronizerImpl	Synchronization aid for a Selector, to prevent SelectionKey.interestOps(int) invocations from blocking for too long.
SelectorSynchronizerLock	Synchronization aid for a Selector, to prevent SelectionKey.interestOps(int) invocations from blocking for too long.
SimpleNioMessage	An NioMessage that reads or writes a single object.
SSLHandler	Wrapper for an SSLEngine and an associated channel.
SSLHandlerImpl	Wrapper for an SSLEngine and an associated channel.
SSLNioObject	Implementation of NioObject for reading or writing data from or to an SSL channel.
StatelessNioServer<C extends AbstractNioContext>
StatelessNioServer.ContextAction<C extends AbstractNioContext>	An action ot execute on a context.
StatelessNioServer.ContextFilter<C extends AbstractNioContext>	Interface for context filtering.
StatelessNioServer.KeysetHandler<C extends AbstractNioContext>	A fuctional interface wrapping an operation on a set of selected channels.