All Classes and Interfaces
Class
Description
Context object associated with a socket channel used by the class server of the JPPF driver.
Implementation of the
JPPFNodeForwardingMBean interface.Instances of this class encapsulate execution nodes.
Abstract class that support job state management.
Common abstract superclass representing a message sent or received by a node.
Context or state information associated with a channel that exchanges heartbeat messages between the server and a node or client.
Performs 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.
Context or state information associated with a channel that exchanges heartbeat messages between the server and a node or client.
Performs 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.
This class ensures that idle nodes get assigned pending tasks in the queue.
This class performs the I/O operations requested by the JPPFNode, for reading the task bundles and sending the results back.
Performs 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.
Context or state information associated with a channel that exchanges heartbeat messages between the server and a node or client.
Future associated with a context which handles the job cancellation.
Handles messages received from and to send to the nodes.
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.
Instances of this class represent a class loading request from a node to a client channel.
Listener for handling completed bundles.
This class represents the key used in the class cache.
Instances of this class associate a node channel with a job that is being executed on the corresponding node.
A cache for resources loaded by client class loaders.
Representation of a message sent or received by a remote node.
Completion listener that is used to notify that results were received from a node,
and they should be sent back to the client.
Collection of utility methods to help investigate issues.
Handles various initializations for the driver.
Implementation of the job management bean.
Provider for the default JPPF driver management and monitoring features.
This class is intended as a controller for the JPPF driver, to enable stopping and restarting it when requested.
Instances of this class represent events emitted each time a JMX notification is received from a node.
Registered instances of this class will be notified of JMX notifications received from the nodes.
This class implements the logic of registering JMX notification listeners to the nodes and dispatching
the received notifications to the client-side JMX listeners.
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 heartbeat connections.
This class handles the interactions between the server queue and jobs and the job dependency graph.
Concrete implementation of the job dependency graph management interface.
Implemention of the Service Provider Interface (SPI) for a pluggable server MBean
which managages the job dependency graph.
Instances of tyhis class represent the state of a task bundle sent over a client conenction.
Interface for job manager that handles states and monitor the jobs throughout their processing within the JPPF.
A Comparator which compare CLientJob objects in descending order of their priority.
Context associated with a driver.
Provider for the default JPPF driver management and monitoring features.
Provider for the default JPPF node management and monitoring features.
This class serves as an initializer for the entire JPPF driver.
Instances of this class encapsulate the administration functionalities for a JPPF driver.
Service provider interface for pluggable management beans for JPPF drivers.
Exception raised when trying to adding a client bundle to a job that is already in the
SubmissionStatus.ENDED state.Instances of this class manage and monitor the jobs throughout their processing within the JPPF driver.
Instances of this class represent dynamic class loading, and serialization/deserialization, capabilities, associated
with a specific client application.
The application is identified through a unique uuid.
The application is identified through a unique uuid.
Local (in-VM) node implementation.
Management bean for a JPPF node.
Deprecated.
Deprecated.
use
NodeForwardingMBeanProvider instead.Implementation of the
JPPFNodeMaintenanceMBean MBean interface.SPI Provider implementation for the node maintenance MBean.
MBean implementation for task-level monitoring on each node.
SPI Provider implementation for task-level monitoring MBean.
Instances of this class are used to initialize the connections to a peer driver
in a separate thread.
A JPPF queue whose elements are ordered by decreasing priority.
Instances of this class represent dynamic class loading, and serialization/deserialization, capabilities, associated
with a specific client application.
The application is identified through a unique uuid.
The application is identified through a unique uuid.
Instances of this class encapsulate execution nodes.
Node message implementation for an in-VM node.
Convenience class to simplify and improve readability of the code.
Event emitted when a node connects to or disconnects from the server.
This class handles operations for node connection events, including
listener registration, event notifications and initial loading of listeners via SPI.
Interface for classes that wish to be notified of node connection events.
Implementation of the
JPPFNodeForwardingMBean interface.Provider for the default JPPF driver management and monitoring features.
Handles the reservation of nodes to jobs that request a specific node configuration.
Types of transitions for a reservation, applied to a node.
This NodeLifeCycleListener implementations is used to update the node state
maintained by the node management MBean.
Instances of this class discover peer drivers over the network.
Defines a callback for objects wishing to be notified of discovery events.
Implementation of the
PersistedJobsManagerMBean interface.Provider for the default JPPF driver management and monitoring features.
This class is a facade to the job persistence service defined in the configuration.
Concrete implementation of
AbstractClassLoaderManager for a remote node.This class encapsulates the network connection of a node to a server job channel.
This class performs the I/O operations requested by the JPPFNode, for reading the task bundles and sending the results back.
Representation of a message sent or received by a remote node.
Strategy to determine whether results should be sent immediately.
Strategy that sends the results when they have all been received for the client bundle.
Strategy that sends the results everytime time they are received from a node.
This class manages the loading and use of strategies for sending results back to the JPPF clients.
Server-side representation of a job.
Listener interface for job events.
An enumeration of the possible statuses of a job on the server side.
Representation of an individual task on the server side.
Instances of this class group tasks from the same client channel together.
Listener providing a callback to invoke when a task's execution has completed.
Instances of this class group tasks for the same node channel together.
The status of a submission.
Listener providing a callback to invoke when a task's execution has completed.
NodeForwardinginstead.