Package org.jppf.server.nio.classloader.node
package org.jppf.server.nio.classloader.node
Support for NIO-based communication with the nodes, for the class loader channel.
The possible states for these channels, and the possible transitions from these states are as follows:
- WAITING_INITIAL_NODE_REQUEST
--> WAITING_INITIAL_NODE_REQUEST
--> SENDING_INITIAL_NODE_RESPONSE
- SENDING_INITIAL_NODE_RESPONSE
--> SENDING_INITIAL_NODE_RESPONSE
--> WAITING_NODE_REQUEST
- WAITING_NODE_REQUEST
--> WAITING_NODE_REQUEST
--> IDLE_NODE
--> SENDING_NODE_RESPONSE
- IDLE_NODE
--> NODE_WAITING_PROVIDER_RESPONSE (by client channel)
- NODE_WAITING_PROVIDER_RESPONSE
--> IDLE_NODE
--> SENDING_NODE_RESPONSE
- SENDING_NODE_RESPONSE
--> SENDING_NODE_RESPONSE
--> WAITING_NODE_REQUEST
-
ClassesClassDescriptionPerforms periodic heartbeat echanges with the nodes and handles heartbeat failures detection.Reads from the channel until no more data is available.Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.The NIO server that handles asynchronous client connections, which can handle multiple jobs concurrently.