Package org.jppf.server.nio.nodeserver.async

package org.jppf.server.nio.nodeserver.async
Classes supporting the server node-side of the JPPF asynchronous communication model.

Current flow for standard nodes:
upon connection:
SEND_INITIAL_BUNDLE
--> WAIT_INITIAL_BUNDLE
--> IDLE
when a job is disptached:
SENDING_BUNDLE
--> WAITING_RESULTS
--> IDLE

Current flow for offline nodes:
upon connection:
SEND_INITIAL_BUNDLE
--> WAIT_INITIAL_BUNDLE
--> IDLE
when a job is disptached:
SENDING_BUNDLE
--> channel is closed

Note that offline nodes never transition to WAITING_RESULTS. Getting the results of a previously dispatched job is done in WAIT_INITIAL_BUNDLE.

  • Classes
    Class
    Description
    AsyncJobScheduler
    This class ensures that idle nodes get assigned pending tasks in the queue.
    AsyncNodeContext
    Context or state information associated with a channel that exchanges heartbeat messages between the server and a node or client.
    AsyncNodeContextFuture
    Future associated with a context which handles the job cancellation.
    AsyncNodeMessageHandler
    Handles messages received from and to send to the nodes.
    AsyncNodeMessageReader
    Reads from the channel until no more data is available.
    AsyncNodeMessageWriter
    Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.
    AsyncNodeNioServer
    The NIO server that handles asynchronous client connections, which can handle multiple jobs concurrently.