Index (JPPF)

A B C D E F G H I J K L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractAsyncClassContext - Class in org.jppf.server.nio.classloader: Context object associated with a socket channel used by the class server of the JPPF driver.
AbstractAsyncClassContext(JPPFDriver, StatelessNioServer<? extends AbstractAsyncClassContext>) - Constructor for class org.jppf.server.nio.classloader.AbstractAsyncClassContext
AbstractNodeForwarding - Class in org.jppf.management.forwarding: Implementation of the JPPFNodeForwardingMBean interface.
AbstractNodeForwarding(JPPFDriver) - Constructor for class org.jppf.management.forwarding.AbstractNodeForwarding: Initialize this MBean implementation.
AbstractRemoteNode - Class in org.jppf.server.node.remote: Instances of this class encapsulate execution nodes.
AbstractRemoteNode(String, TypedProperties, DriverConnectionInfo, HookFactory) - Constructor for class org.jppf.server.node.remote.AbstractRemoteNode: Default constructor.
AbstractServerJob - Class in org.jppf.server.protocol: Abstract class that support job state management.
AbstractServerJob(Lock, TaskBundle) - Constructor for class org.jppf.server.protocol.AbstractServerJob: Initialized abstract client job with task bundle and list of tasks to execute.
AbstractServerJobBase - Class in org.jppf.server.protocol
AbstractServerJobBase(Lock, ServerJobChangeListener, TaskBundle, DataLocation) - Constructor for class org.jppf.server.protocol.AbstractServerJobBase: Initialized client job with task bundle and list of tasks to execute.
AbstractTaskBundleMessage - Class in org.jppf.server.nio: Common abstract superclass representing a message sent or received by a node.
AbstractTaskBundleMessage(NioContext) - Constructor for class org.jppf.server.nio.AbstractTaskBundleMessage: Initialize this nio message with the specified context.
accept(ServerSocketChannel, SocketChannel, SSLHandler, boolean, boolean, Object...) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
accept(ServerSocketChannel, SocketChannel, SSLHandler, boolean, boolean, Object...) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer
accept(ServerSocketChannel, SocketChannel, SSLHandler, boolean, boolean, Object...) - Method in class org.jppf.server.nio.client.AsyncClientNioServer
accept(ServerSocketChannel, SocketChannel, SSLHandler, boolean, boolean, Object...) - Method in class org.jppf.server.nio.heartbeat.HeartbeatNioServer
accept(ServerSocketChannel, SocketChannel, SSLHandler, boolean, boolean, Object...) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
activateNode(String, boolean) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Remove the specified connection wrapper from the list of connections handled by this manager.
add() - Method in class org.jppf.server.nio.client.AsyncClientContext.JobEntryDebugStats
addBundle(ServerTaskBundleClient) - Method in class org.jppf.server.protocol.AbstractServerJobBase: Add received bundle to this server job.
addBundle(ServerTaskBundleClient) - Method in class org.jppf.server.protocol.ServerJobBroadcast
addBundle(ServerTaskBundleClient) - Method in class org.jppf.server.queue.JPPFPriorityQueue
addCompletionListener(ServerTaskBundleClient.CompletionListener) - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Add a listener to the list of bundle listeners.
addConnectionInformation(JPPFConnectionInformation) - Method in class org.jppf.server.peer.PeerDiscoveryThread: Add the specified connection information to discovered map.
addDriverDiscovery(PeerDriverDiscovery) - Method in class org.jppf.server.JPPFDriver: Add a custom peer driver discovery mechanism to those already registered, if any.
addEntry(ServerTaskBundleClient) - Method in class org.jppf.server.nio.client.AsyncClientContext: Add a new job to the job map.
addExecutionStatusListener(ExecutorChannelStatusListener) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
addIdleChannel(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.async.AsyncJobScheduler: Add a channel to the list of idle channels.
addJobEntry(ServerTaskBundleNode) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Add a new job to the job map.
addJobListener(JobManagerListener) - Method in interface org.jppf.server.job.JobManager: Add a listener to the list of listeners.
addJobListener(JobManagerListener) - Method in class org.jppf.server.queue.JPPFPriorityQueue
addJobManagerListener(JobManagerListener) - Method in class org.jppf.server.job.JPPFJobManager: Add a listener to the list of listeners.
addJobTasksListener(JobTasksListener) - Method in class org.jppf.server.job.JPPFJobManager: Add a listener to the list of dispatch listeners.
addNodeBundle(ServerTaskBundleNode) - Method in class org.jppf.server.nio.nodeserver.OfflineNodeHandler: Add the specified node bundle to the map.
addNodeConnection(String, AsyncNodeClassContext) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer: Put the specified uuid / channel pair into the uuid map.
addNotificationListener(String, NodeSelector, String) - Method in class org.jppf.management.forwarding.ForwardingNotificationManager: Add the specified notification listener to the map of listeners.
addNotificationListener(NotificationListener, NotificationFilter, Object) - Method in class org.jppf.management.JPPFNodeConnectionNotifier
addNotificationListener(NotificationListener, NotificationFilter, Object) - Method in class org.jppf.management.JPPFNodeTaskMonitor
addNotificationListener(NotificationListener, NotificationFilter, Object) - Method in class org.jppf.server.job.management.DriverJobManagement
addOnDone(Runnable) - Method in class org.jppf.server.protocol.AbstractServerJob: Registers instance to be called on job finish.
addPendingResponse(JPPFResourceWrapper) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext: Add a pending response.
addProviderConnection(String, AsyncClientClassContext) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer: Add a provider connection to the map of existing available providers.
addRequest(AsyncResourceRequest) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext: Add a new request to send to the client.
addResults(String, Collection<ServerTask>) - Static method in class org.jppf.server.debug.DebugHelper: Add the specified completed tasks for the specified job uuid.
afterFirstRead() - Method in class org.jppf.server.nio.client.ClientMessage: Actions to take after the first object in the message has been fully read.
afterFirstRead() - Method in class org.jppf.server.nio.nodeserver.RemoteNodeMessage: Actions to take after the first object in the message has been fully read.
all() - Method in class org.jppf.server.debug.ServerDebug
all() - Method in interface org.jppf.server.debug.ServerDebugMBean: View all debug info in a formatted string.
allChannels() - Method in class org.jppf.server.debug.ServerDebug
allChannels() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the states of all channels.
allClientJobEntries() - Method in class org.jppf.server.debug.ServerDebug
allClientJobEntries() - Method in interface org.jppf.server.debug.ServerDebugMBean
AsyncClientClassContext - Class in org.jppf.server.nio.classloader.client: Context or state information associated with a channel that exchanges heartbeat messages between the server and a node or client.
AsyncClientClassMessageHandler - Class in org.jppf.server.nio.classloader.client: Performs periodic heartbeat echanges with the nodes and handles heartbeat failures detection.
AsyncClientClassMessageHandler(AsyncClientClassNioServer) - Constructor for class org.jppf.server.nio.classloader.client.AsyncClientClassMessageHandler
AsyncClientClassMessageReader - Class in org.jppf.server.nio.classloader.client: Reads from the channel until no more data is available.
AsyncClientClassMessageReader(AsyncClientClassNioServer) - Constructor for class org.jppf.server.nio.classloader.client.AsyncClientClassMessageReader: Initialize this message reader.
AsyncClientClassMessageWriter - Class in org.jppf.server.nio.classloader.client: Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.
AsyncClientClassMessageWriter(StatelessNioServer<AsyncClientClassContext>) - Constructor for class org.jppf.server.nio.classloader.client.AsyncClientClassMessageWriter: Initialize this message writer.
AsyncClientClassNioServer - Class in org.jppf.server.nio.classloader.client: The NIO server that handles asynchronous client connections, which can handle multiple jobs concurrently.
AsyncClientClassNioServer(JPPFDriver, int, boolean) - Constructor for class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
AsyncClientContext - Class in org.jppf.server.nio.client: Context or state information associated with a channel that exchanges heartbeat messages between the server and a node or client.
AsyncClientContext.JobEntryDebugStats - Class in org.jppf.server.nio.client
AsyncClientMessageHandler - Class in org.jppf.server.nio.client: Performs periodic heartbeat echanges with the nodes and handles heartbeat failures detection.
AsyncClientMessageHandler(JPPFDriver) - Constructor for class org.jppf.server.nio.client.AsyncClientMessageHandler
AsyncClientMessageReader - Class in org.jppf.server.nio.client: Reads from the channel until no more data is available.
AsyncClientMessageReader(AsyncClientNioServer) - Constructor for class org.jppf.server.nio.client.AsyncClientMessageReader: Initialize this message reader.
AsyncClientMessageWriter - Class in org.jppf.server.nio.client: Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.
AsyncClientMessageWriter(StatelessNioServer<AsyncClientContext>) - Constructor for class org.jppf.server.nio.client.AsyncClientMessageWriter: Initialize this message writer.
AsyncClientNioServer - Class in org.jppf.server.nio.client: The NIO server that handles asynchronous client connections, which can handle multiple jobs concurrently.
AsyncClientNioServer(JPPFDriver, int, boolean) - Constructor for class org.jppf.server.nio.client.AsyncClientNioServer
AsyncJobScheduler - Class in org.jppf.server.nio.nodeserver.async: This class ensures that idle nodes get assigned pending tasks in the queue.
AsyncLocalNodeConnection - Class in org.jppf.server.node.local
AsyncLocalNodeConnection(AsyncNodeContext) - Constructor for class org.jppf.server.node.local.AsyncLocalNodeConnection: Initialize this connection with the specified serializer.
AsyncLocalNodeIO - Class in org.jppf.server.node.local: This class performs the I/O operations requested by the JPPFNode, for reading the task bundles and sending the results back.
AsyncLocalNodeIO(JPPFLocalNode) - Constructor for class org.jppf.server.node.local.AsyncLocalNodeIO: Initialize this TaskIO with the specified node.
AsyncNodeClassContext - Class in org.jppf.server.nio.classloader.node
AsyncNodeClassContext(AsyncNodeClassNioServer, SocketChannel) - Constructor for class org.jppf.server.nio.classloader.node.AsyncNodeClassContext
AsyncNodeClassMessageHandler - Class in org.jppf.server.nio.classloader.node: Performs periodic heartbeat echanges with the nodes and handles heartbeat failures detection.
AsyncNodeClassMessageHandler(JPPFDriver) - Constructor for class org.jppf.server.nio.classloader.node.AsyncNodeClassMessageHandler
AsyncNodeClassMessageReader - Class in org.jppf.server.nio.classloader.node: Reads from the channel until no more data is available.
AsyncNodeClassMessageReader(AsyncNodeClassNioServer) - Constructor for class org.jppf.server.nio.classloader.node.AsyncNodeClassMessageReader: Initialize this message reader.
AsyncNodeClassMessageWriter - Class in org.jppf.server.nio.classloader.node: Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.
AsyncNodeClassMessageWriter(AsyncNodeClassNioServer) - Constructor for class org.jppf.server.nio.classloader.node.AsyncNodeClassMessageWriter: Initialize this message writer.
AsyncNodeClassNioServer - Class in org.jppf.server.nio.classloader.node: The NIO server that handles asynchronous client connections, which can handle multiple jobs concurrently.
AsyncNodeClassNioServer(JPPFDriver, int, boolean) - Constructor for class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer
AsyncNodeContext - Class in org.jppf.server.nio.nodeserver.async: Context or state information associated with a channel that exchanges heartbeat messages between the server and a node or client.
AsyncNodeContext(AsyncNodeNioServer, SocketChannel, boolean) - Constructor for class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
AsyncNodeContextFuture - Class in org.jppf.server.nio.nodeserver.async: Future associated with a context which handles the job cancellation.
AsyncNodeContextFuture(AsyncNodeContext, ServerTaskBundleNode) - Constructor for class org.jppf.server.nio.nodeserver.async.AsyncNodeContextFuture: Initialize with the specified runnable and result object.
AsyncNodeMessageHandler - Class in org.jppf.server.nio.nodeserver.async: Handles messages received from and to send to the nodes.
AsyncNodeMessageHandler(JPPFDriver) - Constructor for class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageHandler: COnstruct this object.
AsyncNodeMessageReader - Class in org.jppf.server.nio.nodeserver.async: Reads from the channel until no more data is available.
AsyncNodeMessageReader(AsyncNodeNioServer) - Constructor for class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageReader: Initialize this message reader.
AsyncNodeMessageWriter - Class in org.jppf.server.nio.nodeserver.async: Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.
AsyncNodeMessageWriter(StatelessNioServer<AsyncNodeContext>) - Constructor for class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageWriter: Initialize this message writer.
AsyncNodeNioServer - Class in org.jppf.server.nio.nodeserver.async: The NIO server that handles asynchronous client connections, which can handle multiple jobs concurrently.
AsyncNodeNioServer(JPPFDriver, int, boolean) - Constructor for class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
AsyncResourceRequest - Class in org.jppf.server.nio.classloader: Instances of this class represent a class loading request from a node to a client channel.
AsyncResourceRequest(AsyncNodeClassContext, JPPFResourceWrapper) - Constructor for class org.jppf.server.nio.classloader.AsyncResourceRequest: Initialize this request with the specified node channel and resource.
awaitLocalResponse() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext

B

BaseNodeContext - Class in org.jppf.server.nio.nodeserver
BaseNodeContext(AsyncNodeNioServer) - Constructor for class org.jppf.server.nio.nodeserver.BaseNodeContext
beforeFirstWrite() - Method in class org.jppf.server.nio.client.ClientMessage: Actions to take before the first object in the message is written.
beforeFirstWrite() - Method in class org.jppf.server.nio.nodeserver.RemoteNodeMessage: Actions to take before the first object in the message is written.
beforeNextJob(NodeLifeCycleEvent) - Method in class org.jppf.management.NodeStatusNotifier
broadcastCompleted(ServerJobBroadcast) - Method in class org.jppf.server.protocol.ServerJobBroadcast: Called to notify that the execution of broadcast job has completed.
broadcastDispatched(ServerJobBroadcast) - Method in class org.jppf.server.protocol.ServerJobBroadcast: Called when all or part of broadcast job is dispatched to a driver.
BroadcastManager - Class in org.jppf.server.queue
broadcastResultReceived() - Method in class org.jppf.server.protocol.ServerTask: Called to notify that the task broadcast was completed.
bundle - Variable in class org.jppf.server.nio.AbstractTaskBundleMessage: The latest bundle that was sent or received.
bundle() - Method in class org.jppf.server.nio.nodeserver.NodeBundleResults: Get the task bundle.
BundleCompletionListener - Class in org.jppf.server.protocol: Listener for handling completed bundles.
bundleEnded() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Notifies that bundle is completely executed.
bundleEnded(ServerTaskBundleClient) - Method in class org.jppf.server.nio.client.CompletionListener
bundleEnded(ServerTaskBundleClient) - Method in class org.jppf.server.protocol.BundleCompletionListener
bundleEnded(ServerTaskBundleClient) - Method in interface org.jppf.server.protocol.ServerTaskBundleClient.CompletionListener: Callback method invoked when execution of the bundle is done.

C

CacheClassKey - Class in org.jppf.server.nio.classloader: This class represents the key used in the class cache.
CacheClassKey(String, String) - Constructor for class org.jppf.server.nio.classloader.CacheClassKey: Initialize this key with a specified provider uuid and resource string.
cancel() - Method in class org.jppf.server.protocol.ServerTask: Mark this task as cancelled.
cancel() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Called when this task bundle is cancelled.
cancel() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Called when this task bundle is cancelled.
cancel(boolean) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContextFuture
cancel(JPPFDriver, boolean) - Method in class org.jppf.server.protocol.ServerJob: Cancel this job.
cancel(JPPFDriver, boolean) - Method in class org.jppf.server.protocol.ServerJobBroadcast
cancelBroadcastJobs(String) - Method in class org.jppf.server.queue.BroadcastManager: Cancels queued broadcast jobs for connection.
cancelDispatch(ServerTaskBundleNode) - Method in class org.jppf.server.protocol.ServerJob: Cancel the specified job dispatch.
cancelJob(String) - Method in interface org.jppf.server.job.JobManager: Cancel the job with the specified UUID
cancelJob(String) - Method in class org.jppf.server.job.management.DriverJobManagement
cancelJob(String) - Method in class org.jppf.server.queue.JPPFPriorityQueue
cancelJob(String, boolean) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Cancel the job with the specified id.
cancelJob(String, Boolean) - Method in class org.jppf.management.JPPFNodeAdmin: Cancel the job with the specified id.
cancelJob(NodeSelector, String, Boolean) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
cancelJob(NodeSelector, String, Boolean) - Method in class org.jppf.management.forwarding.NodeForwarding
cancelJobs(JobSelector) - Method in class org.jppf.server.job.management.DriverJobManagement
CANCELLED - Enum constant in enum class org.jppf.server.protocol.ServerJobStatus: Job status is cancelled.
cancelPendingAction() - Method in class org.jppf.management.JPPFNodeAdmin
changeLoadBalancerSettings(String, Map<Object, Object>) - Method in class org.jppf.management.JPPFDriverAdmin
ChannelJobPair - Class in org.jppf.server.job: Instances of this class associate a node channel with a job that is being executed on the corresponding node.
ChannelJobPair(ExecutorChannel<?>, AbstractServerJob) - Constructor for class org.jppf.server.job.ChannelJobPair: Initialize this object with the specified parameters.
channelSet - Variable in class org.jppf.server.protocol.AbstractServerJobBase: Set of all nodes to which this job is dispatched.
checkBundler(JPPFBundlerFactory, JPPFContext) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Check whether the bundler held by this context is up to date by comparison with the specified bundler.
If it is not, then it is replaced with a copy of the specified bundler, with a timestamp taken at creation time.
checkResults(String, Collection<ServerTask>) - Static method in class org.jppf.server.debug.DebugHelper: Check whether the specified tasks for the specified job have already completed.
checkTaskCount() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Check the task count in this node bundle is equal to the one in its JPPFTaskBundle.
ClassCache - Class in org.jppf.server.nio.classloader: A cache for resources loaded by client class loaders.
ClassCache() - Constructor for class org.jppf.server.nio.classloader.ClassCache
clearResults(String) - Static method in class org.jppf.server.debug.DebugHelper: Remove all results for the specified job.
clientBundles - Variable in class org.jppf.server.protocol.AbstractServerJobBase: The list of the incoming bundles.
clientClassLoaderChannels() - Method in class org.jppf.server.debug.ServerDebug
clientClassLoaderChannels() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the states of the class loader channels.
clientDataChannels() - Method in class org.jppf.server.debug.ServerDebug
clientDataChannels() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the states of the client data channels.
ClientMessage - Class in org.jppf.server.nio.client: Representation of a message sent or received by a remote node.
ClientMessage(NioContext, ServerTaskBundleClient) - Constructor for class org.jppf.server.nio.client.ClientMessage: Initialize this nio message with the specified context.
close() - Method in class org.jppf.server.job.JPPFJobManager: Close this job manager and release its resources.
close() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
close() - Method in class org.jppf.server.node.local.AsyncLocalNodeConnection
close() - Method in class org.jppf.server.node.remote.RemoteNodeConnection
close() - Method in class org.jppf.server.peer.JPPFPeerInitializer
close() - Method in class org.jppf.server.peer.PeerConnectionPool
close() - Method in class org.jppf.server.queue.JPPFPriorityQueue: Close this queue and all the resources it uses.
closeConnection(AsyncClientClassContext) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer: Close the specified connection.
closeConnection(AsyncClientClassContext, boolean) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer: Close the specified connection.
closeConnection(AsyncNodeClassContext) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer: Close the specified channel.
closeConnection(AsyncClientContext) - Method in class org.jppf.server.nio.client.AsyncClientNioServer: Close the specified channel.
closeConnection(AsyncNodeContext) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Close the specified channel.
closeDataChannel() - Method in class org.jppf.server.node.local.JPPFLocalNode
closeDataChannel() - Method in class org.jppf.server.node.remote.AbstractRemoteNode
compare(ServerJob, ServerJob) - Method in class org.jppf.server.queue.JobPriorityComparator
COMPLETE - Enum constant in enum class org.jppf.server.submission.SubmissionStatus: The job execution is complete.
completionBundles - Variable in class org.jppf.server.protocol.AbstractServerJob: List of bundles added after submission status set to COMPLETE.
CompletionListener - Class in org.jppf.server.nio.client: Completion listener that is used to notify that results were received from a node, and they should be sent back to the client.
CompletionListener(AsyncClientContext) - Constructor for class org.jppf.server.nio.client.CompletionListener: Initialize this completion listener with the specified channel.
connectionFailed(AsyncNodeClassContext) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer: Called when the node failed to respond to a heartbeat message.
connectionFailed(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Called when the node failed to respond to a heartbeat message.
createBroadcastJob(String) - Method in class org.jppf.server.protocol.ServerJobBroadcast: Make a copy of this client job wrapper.
createClassLoader() - Method in class org.jppf.server.node.remote.RemoteClassLoaderManager
createMBean() - Method in class org.jppf.job.persistence.PersistedJobsManagerMBeanProvider
createMBean() - Method in class org.jppf.management.diagnostics.spi.DriverDiagnosticsMBeanProvider
createMBean() - Method in interface org.jppf.management.spi.JPPFDriverMBeanProvider: Return a concrete MBean.
createMBean() - Method in class org.jppf.management.spi.JPPFNodeConnectionNotifierMBeanProvider
createMBean() - Method in class org.jppf.management.spi.LoadBalancerPersistenceManagerMBeanProvider
createMBean() - Method in class org.jppf.management.spi.PeerDriverMBeanProvider
createMBean() - Method in class org.jppf.server.job.management.DriverJobManagementMBeanProvider
createMBean() - Method in class org.jppf.server.job.management.JobDependencyManagerMBeanProvider
createMBean() - Method in class org.jppf.server.spi.JPPFDefaultDriverMBeanProvider
createMBean() - Method in class org.jppf.server.spi.JPPFNodeForwardingMBeanProvider: Deprecated.
createMBean() - Method in class org.jppf.server.spi.NodeForwardingMBeanProvider
createMBean(Node) - Method in class org.jppf.server.node.spi.JPPFDefaultNodeMBeanProvider: Return a concrete MBean.
The class of this MBean must implement the interface defined by getMBeanInterfaceName().
createMBean(Node) - Method in class org.jppf.server.node.spi.JPPFNodeMaintenanceMBeanProvider
createMBean(Node) - Method in class org.jppf.server.node.spi.JPPFNodeTaskMonitorProvider: Return a concrete MBean.
The class of this MBean must implement the interface defined by getMBeanInterfaceName().
createMBean(JPPFDriver) - Method in class org.jppf.job.persistence.PersistedJobsManagerMBeanProvider
createMBean(JPPFDriver) - Method in interface org.jppf.management.spi.JPPFDriverMBeanProvider: Return a concrete MBean.
createMBean(JPPFDriver) - Method in class org.jppf.management.spi.LoadBalancerPersistenceManagerMBeanProvider
createMBean(JPPFDriver) - Method in class org.jppf.management.spi.PeerDriverMBeanProvider
createMBean(JPPFDriver) - Method in class org.jppf.server.job.management.DriverJobManagementMBeanProvider
createMBean(JPPFDriver) - Method in class org.jppf.server.job.management.JobDependencyManagerMBeanProvider
createMBean(JPPFDriver) - Method in class org.jppf.server.spi.JPPFDefaultDriverMBeanProvider
createMBean(JPPFDriver) - Method in class org.jppf.server.spi.JPPFNodeForwardingMBeanProvider: Deprecated.
createMBean(JPPFDriver) - Method in class org.jppf.server.spi.NodeForwardingMBeanProvider
createMBeanImpl(JPPFDriverMBeanProvider, Object...) - Method in class org.jppf.management.spi.DriverMBeanProviderManager
createMessageHandler() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassMessageReader
createMessageHandler() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassMessageReader
createMessageHandler() - Method in class org.jppf.server.nio.client.AsyncClientMessageReader
createMessageHandler() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageReader
createNioContext(Object...) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
createNioContext(Object...) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer
createNioContext(Object...) - Method in class org.jppf.server.nio.client.AsyncClientNioServer
createNioContext(Object...) - Method in class org.jppf.server.nio.heartbeat.HeartbeatNioServer
createNioContext(Object...) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
createNodeDispatch(int) - Method in class org.jppf.server.protocol.ServerJob: Make a copy of this client job wrapper containing only the first nbTasks tasks it contains.

D

data() - Method in class org.jppf.server.nio.nodeserver.NodeBundleResults: Return the task data.
dataProvider - Variable in class org.jppf.server.protocol.AbstractServerJobBase: The data location of the data provider.
DebugHelper - Class in org.jppf.server.debug: Collection of utility methods to help investigate issues.
DebugHelper() - Constructor for class org.jppf.server.debug.DebugHelper
deleteJob(String) - Method in class org.jppf.server.queue.PersistenceHandler: Remove the specified job from the persistence store.
deleteLoadRequest(long) - Method in class org.jppf.job.persistence.PersistedJobsManager
deletePersistedJobs(JobSelector) - Method in class org.jppf.job.persistence.PersistedJobsManager
dependendedOnTasks - Variable in class org.jppf.server.protocol.AbstractServerJobBase: The list of the tasks.
deserializeBundle(AbstractTaskBundleMessage) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Deserialize a task bundle from the message read into this buffer.
deserializeBundle(ClientMessage) - Method in class org.jppf.server.nio.client.AsyncClientContext: Deserialize a task bundle from a message read from a connection.
deserializeObjects() - Method in class org.jppf.server.node.local.AsyncLocalNodeIO
deserializeObjects() - Method in class org.jppf.server.node.remote.RemoteNodeIO
deserializeObjects(Object[], int, ExecutorService) - Method in class org.jppf.server.node.local.JPPFLocalContainer
deserializeObjects(Object[], int, ExecutorService) - Method in class org.jppf.server.node.remote.JPPFRemoteContainer: Deserialize a number of objects from a socket client.
deserializeObjects(Object[], int, LocalNodeMessage, ExecutorService) - Method in class org.jppf.server.node.local.JPPFLocalContainer: Deserialize a number of objects from a socket client.
deserializeObjects(TaskBundle) - Method in class org.jppf.server.node.local.AsyncLocalNodeIO
deserializeObjects(TaskBundle) - Method in class org.jppf.server.node.remote.RemoteNodeIO
deserializeObjects(TaskBundle, LocalNodeMessage) - Method in class org.jppf.server.node.local.AsyncLocalNodeIO: Perform the deserialization of the objects received through the socket connection.
deserializeResource(ClassLoaderNioMessage) - Method in class org.jppf.server.nio.classloader.AbstractAsyncClassContext: Deserialize a resource wrapper from an array of bytes.
dispatchSet - Variable in class org.jppf.server.protocol.AbstractServerJobBase: Set of all dispatched bundles in this job.
done() - Method in class org.jppf.server.protocol.AbstractServerJob: Called when task was cancelled or finished.
DONE - Enum constant in enum class org.jppf.server.protocol.ServerJobStatus: Job status is done/complete.
doReservation(ServerJob, BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Reserve the specified node for the specified job.
driver - Variable in class org.jppf.server.nio.classloader.AbstractAsyncClassContext: Reference to the driver.
driver - Variable in class org.jppf.server.nio.nodeserver.BaseNodeContext: Reference to the JPPF driver.
DriverDiagnosticsMBeanProvider - Class in org.jppf.management.diagnostics.spi
DriverDiagnosticsMBeanProvider() - Constructor for class org.jppf.management.diagnostics.spi.DriverDiagnosticsMBeanProvider
DriverInitializer - Class in org.jppf.server: Handles various initializations for the driver.
DriverInitializer(JPPFDriver, TypedProperties) - Constructor for class org.jppf.server.DriverInitializer: Instantiate this initializer with the specified driver.
DriverJobManagement - Class in org.jppf.server.job.management: Implementation of the job management bean.
DriverJobManagement(JPPFDriver) - Constructor for class org.jppf.server.job.management.DriverJobManagement: Initialize this MBean.
DriverJobManagementMBeanProvider - Class in org.jppf.server.job.management: Provider for the default JPPF driver management and monitoring features.
DriverJobManagementMBeanProvider() - Constructor for class org.jppf.server.job.management.DriverJobManagementMBeanProvider
DriverLauncher - Class in org.jppf.server: This class is intended as a controller for the JPPF driver, to enable stopping and restarting it when requested.
DriverLauncher() - Constructor for class org.jppf.server.DriverLauncher
DriverMBeanProviderManager - Class in org.jppf.management.spi
DriverMBeanProviderManager(Class<JPPFDriverMBeanProvider>, ClassLoader, Object, Object...) - Constructor for class org.jppf.management.spi.DriverMBeanProviderManager: Initialize this mbean provider manager and register the MBeans implementing the specified provider interface.
dumpQueue() - Method in class org.jppf.server.debug.ServerDebug
dumpQueue() - Method in interface org.jppf.server.debug.ServerDebugMBean: Dump the job queue.
dumpQueueDetails() - Method in class org.jppf.server.debug.ServerDebug
dumpQueueDetails() - Method in interface org.jppf.server.debug.ServerDebugMBean: Dump the job queue with fine details of the jobs.
dumpQueueDetailsFromPriorityMap() - Method in class org.jppf.server.debug.ServerDebug
dumpQueueDetailsFromPriorityMap() - Method in interface org.jppf.server.debug.ServerDebugMBean: Dump the job queue with fine details of the jobs.

E

ENDED - Enum constant in enum class org.jppf.server.submission.SubmissionStatus: The job execution ended.
endProf() - Static method in class org.jppf.server.debug.ServerDebug: Trigger method for the profiler to stop profiling.
endProfiling() - Method in class org.jppf.server.debug.ServerDebug
endProfiling() - Method in interface org.jppf.server.debug.ServerDebugMBean: Trigger method for the profiler to stop profiling.
equals(Object) - Method in class org.jppf.server.job.ChannelJobPair: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class org.jppf.server.protocol.ServerTaskBundleNode
executeScript(String, String) - Method in class org.jppf.server.debug.ServerDebug
executeScript(String, String) - Method in interface org.jppf.server.debug.ServerDebugMBean: Execute the specified script.
EXECUTING - Enum constant in enum class org.jppf.server.protocol.ServerJobStatus: Job status is executing.
EXECUTING - Enum constant in enum class org.jppf.server.submission.SubmissionStatus: The job is being executed.
expire() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Called when this task bundle should be resubmitted

F

FAILED - Enum constant in enum class org.jppf.server.submission.SubmissionStatus: The job execution has failed.
fireExecutionStatusChanged(ExecutorStatus, ExecutorStatus) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Notify all listeners that the execution status of this channel has changed.
fireJobDispatched(ExecutorChannel<?>, ServerTaskBundleNode) - Method in class org.jppf.server.protocol.AbstractServerJob: A sub-job was dispatched to a node.
fireJobEvent(JobNotification) - Method in class org.jppf.server.job.JPPFJobManager: Fire job listener event.
fireJobReturned(ExecutorChannel<?>, ServerTaskBundleNode) - Method in class org.jppf.server.protocol.AbstractServerJob: A sub-job returned from a node.
fireJobUpdated(boolean) - Method in class org.jppf.server.protocol.AbstractServerJob: The current number of tasks in a job was updated.
fireNodeConnected(JPPFManagementInfo) - Method in class org.jppf.server.event.NodeConnectionEventHandler: Notify all listeners that a node is connected tot he server.
fireNodeDisconnected(JPPFManagementInfo) - Method in class org.jppf.server.event.NodeConnectionEventHandler: Notify all listeners that a node is disconnected from the server.
forwardGetAttribute(NodeSelector, String, String) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
forwardGetAttribute(NodeSelector, String, String) - Method in class org.jppf.management.forwarding.NodeForwarding
ForwardingNotificationEvent - Class in org.jppf.management.forwarding: Instances of this class represent events emitted each time a JMX notification is received from a node.
ForwardingNotificationEvent(String, String, Notification) - Constructor for class org.jppf.management.forwarding.ForwardingNotificationEvent: Initialize this event.
ForwardingNotificationEventListener - Interface in org.jppf.management.forwarding: Registered instances of this class will be notified of JMX notifications received from the nodes.
ForwardingNotificationManager - Class in org.jppf.management.forwarding: This class implements the logic of registering JMX notification listeners to the nodes and dispatching the received notifications to the client-side JMX listeners.
ForwardingNotificationManager(AbstractNodeForwarding) - Constructor for class org.jppf.management.forwarding.ForwardingNotificationManager: Initialize this manager.
forwardInvoke(NodeSelector, String, String) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
forwardInvoke(NodeSelector, String, String) - Method in class org.jppf.management.forwarding.NodeForwarding
forwardInvoke(NodeSelector, String, String, Object[], String[]) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
forwardInvoke(NodeSelector, String, String, Object[], String[]) - Method in class org.jppf.management.forwarding.NodeForwarding
forwardSetAttribute(NodeSelector, String, String, Object) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
forwardSetAttribute(NodeSelector, String, String, Object) - Method in class org.jppf.management.forwarding.NodeForwarding

G

gc(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
gc(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
getAcceptorServer() - Method in class org.jppf.server.JPPFDriver: Get the server which handles the initial handshake and peer channel identification.
getActiveState(NodeSelector) - Method in class org.jppf.management.JPPFDriverAdmin
getAllChannels() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get all the node connections handled by this server.
getAllChannelsAsSet() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
getAllJobIds() - Method in interface org.jppf.server.job.JobManager: Get the set of all job ids.
getAllJobIds() - Method in class org.jppf.server.job.JPPFJobManager: Get the set of ids for all the jobs currently queued or executing.
getAllJobIds() - Method in class org.jppf.server.queue.JPPFPriorityQueue: Get the set of ids for all the jobs currently queued or executing.
getAllJobIdsFromPriorityMap() - Method in class org.jppf.server.queue.JPPFPriorityQueue: Get the set of ids for all the jobs currently queued or executing.
getAllJobs() - Method in class org.jppf.server.queue.JPPFPriorityQueue: Get the set of all the jobs currently queued or executing.
getAllJobsFromPriorityMap() - Method in class org.jppf.server.queue.JPPFPriorityQueue: Get all the jobs in the queue, ordered by priority.
getAllJobUuids() - Method in class org.jppf.server.job.management.DriverJobManagement
getAllNodeConnections() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer
getAllNodes() - Method in class org.jppf.server.job.management.JobDependencyManager
getAllProviderConnections() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer: Get all the provider connections handled by this server.
getAllReservations() - Method in class org.jppf.server.debug.ServerDebug
getAllReservations() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get all the current reservations.
getAsyncClientClassServer() - Method in class org.jppf.server.JPPFDriver: Get the JPPF class server.
getAsyncClientNioServer() - Method in class org.jppf.server.JPPFDriver: Get the JPPF client server.
getAsyncNodeClassServer() - Method in class org.jppf.server.JPPFDriver: Get the JPPF class server.
getAsyncNodeNioServer() - Method in class org.jppf.server.JPPFDriver: Get the JPPF nodes server.
getAvailableGraphNodeCount() - Method in class org.jppf.server.protocol.ServerJob
getBroadcasting() - Method in class org.jppf.management.JPPFDriverAdmin
getBroadcastManager() - Method in class org.jppf.server.queue.JPPFPriorityQueue: Get the objects wich manages operations on broadcast jobs.
getBroadcastUUID() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the broadcast UUID.
getBroadcastUUID() - Method in class org.jppf.server.protocol.ServerJobBroadcast
getBundle() - Method in class org.jppf.server.nio.AbstractTaskBundleMessage: Get the latest bundle that was sent or received.
getBundle() - Method in class org.jppf.server.nio.client.JobEntry: Get the job submitted by the client.
getBundle() - Method in class org.jppf.server.protocol.ServerTask: Get the client bundle that owns this task.
getBundleForJob(String) - Method in interface org.jppf.server.job.JobManager: Get the job for the job unique identifier.
getBundleForJob(String) - Method in class org.jppf.server.queue.JPPFPriorityQueue
getBundler() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getBundlerAlgorithm() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getBundlerFactory() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the factory object used to create bundler instances.
getBundlerHandler() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
getCacheContent(String, String) - Method in class org.jppf.server.nio.classloader.ClassCache: Get a resource definition from the resource cache.
getChannel() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the channel to which the job is dispatched.
getChannels(NodeSelector) - Method in class org.jppf.management.NodeSelectionHelper: Get a set of channels based on a NodeSelector.
getChannels(NodeSelector, boolean, boolean) - Method in class org.jppf.management.NodeSelectionHelper: Get a set of channels based on a NodeSelector.
getClassCache() - Method in class org.jppf.server.DriverInitializer: Get the soft cache of classes downloaded form the clients r from this driver's classpath.
getClassCache() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
getClientBundle() - Method in class org.jppf.server.nio.client.ClientMessage
getClientBundles() - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get list of bundles received from client.
getClientJob() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the client job this submission is for
getClientJobEntryStats() - Method in class org.jppf.server.debug.ServerDebug
getClientJobEntryStats() - Method in interface org.jppf.server.debug.ServerDebugMBean
getCompletionBundles() - Method in class org.jppf.server.protocol.AbstractServerJob: Get list of bundles added after job completion.
getConfiguration() - Method in class org.jppf.server.JPPFDriver: Get this driver's configuration.
getConnectedNodes() - Method in class org.jppf.server.event.NodeConnectionEventHandler
getConnectedPeers() - Method in class org.jppf.server.event.NodeConnectionEventHandler
getConnectedRealNodes() - Method in class org.jppf.server.event.NodeConnectionEventHandler
getConnection(String) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the connection wrapper for the specified uuid.
getConnectionInfo() - Method in class org.jppf.server.peer.PeerConnectionPool
getConnectionInformation() - Method in class org.jppf.server.DriverInitializer: Read configuration for the host name and ports used to connect to this driver.
getContext() - Method in class org.jppf.server.nio.classloader.AsyncResourceRequest: Get the node class loader channel.
getCurrentNbJobs() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
getDataLocationList() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Extract DataLocation list from contained tasks.
getDataProvider() - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get the location for data shared between tasks.
getDataProvider() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get shared data provider for this task.
getDataProvider() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get shared data provider for this task.
getDelegationModel() - Method in class org.jppf.management.JPPFNodeAdmin
getDelegationModel(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
getDelegationModel(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
getDependenciesHandler() - Method in class org.jppf.server.queue.JPPFPriorityQueue
getDiscoveredPeers() - Method in class org.jppf.server.DriverInitializer: Get the discovered peers connection information.
getDispatchedBroadcasts() - Method in class org.jppf.server.protocol.ServerJobBroadcast
getDispatchExpirationHandler() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the handler for the expiration of dispatched bundles.
getDispatchSet() - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get the dispatch set.
getDispatchStartTime() - Method in class org.jppf.server.protocol.ServerTaskBundleNode
getDriver() - Method in class org.jppf.server.debug.ServerDebug
getDriver() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
getDriver() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
getDriver() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getEmitterUuid() - Method in class org.jppf.server.job.JPPFJobManager
getEntryMap() - Method in class org.jppf.server.nio.client.AsyncClientContext
getEntrystats() - Static method in class org.jppf.server.nio.client.AsyncClientContext
getExecutionStatus() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getExecutor() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageReader
getExpirationCount() - Method in class org.jppf.server.protocol.ServerTask: Get the number of times a dispatch of this task has expired.
getFuture() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the future corresponding to the channel dispatch.
getGraph() - Method in class org.jppf.server.job.management.JobDependencyManager
getGraph() - Method in class org.jppf.server.queue.JobDependenciesHandler
getGraphSize() - Method in class org.jppf.server.job.management.JobDependencyManager
getHandshakeBundle() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the task bundle sent to a newly connected node, so that it can check whether it is up to date, without having to wait for an actual request to be sent.
getHookFactory() - Method in class org.jppf.server.JPPFDriver: Get the factory that creates and invoke hook instances for this node.
getId() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the unique id for this client bundle.
getId() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the unique id for this node bundle.
getIdle() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getIdleChannels() - Method in class org.jppf.server.nio.nodeserver.async.AsyncJobScheduler: Get the list of idle channels.
getInfoSet() - Method in class org.jppf.server.peer.PeerDiscoveryThread: Contains the set of retrieved connection information objects.
getInitializer() - Method in class org.jppf.server.JPPFDriver: Get this driver's initializer.
getInitialTask() - Method in class org.jppf.server.protocol.ServerTask: Get the initial serialized task.
getInitialTaskCount() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the initial task count.
getInstance() - Static method in class org.jppf.management.JPPFNodeConnectionNotifier: Get the singleton instance of this class.
getJmxConnection() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getJmxServer(boolean) - Method in class org.jppf.server.DriverInitializer: Get the jmx server used to manage and monitor this driver.
getJob() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the underlying task bundle.
getJob() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the job this submission is for.
getJob() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the task bundle this node bundle is for.
getJob(String) - Method in class org.jppf.server.JPPFDriver: Get a server-side representation of a job from its uuid.
getJob(String) - Method in class org.jppf.server.queue.JPPFPriorityQueue: Get the job for the jobId.
getJobEntry(String, long) - Method in class org.jppf.server.nio.client.AsyncClientContext: Retrieve the job entry with the specified id.
getJobEntry(String, long) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Retrieve the job entry with the specified id.
getJobFromPriorityMap(String) - Method in class org.jppf.server.queue.JPPFPriorityQueue: Get the job for the jobId.
getJobInformation(String) - Method in class org.jppf.server.job.management.DriverJobManagement: Get an object describing the job with the specified uuid.
getJobInformation(JobSelector) - Method in class org.jppf.server.job.management.DriverJobManagement
getJobManager() - Method in class org.jppf.server.JPPFDriver: Get the object that manages and monitors the jobs throughout their processing within this driver.
getJobNotifCount() - Method in class org.jppf.server.debug.ServerDebug
getJobNotifCount() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the current count of job life cycle notifications.
getJobNotifPeak() - Method in class org.jppf.server.debug.ServerDebug
getJobNotifPeak() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the peak count of job life cycle notifications.
getJobReceivedTime() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the job received time.
getJobReceivedTime() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the job received time.
getJobReturnReason() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the reason why the task results are reeived.
getJobScheduler() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the task that dispatches queued jobs to available nodes.
getJobTasksListenerManager() - Method in class org.jppf.server.JPPFDriver: Get the object which manages the registration and unregistration of job dispatch listeners and notifies these listeners of job dispatch events.
getJPPFContext() - Method in class org.jppf.server.nio.nodeserver.async.AsyncJobScheduler: Get the corresponding node's context information.
getJPPFContext() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the corresponding node's context information.
getLoadBalanceThreshold() - Method in class org.jppf.server.peer.PeerConnectionPoolHandler
getLocalNodeReadLock() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
getLocalNodeWriteLock() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
getLock() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the lock used for synchronized access to job.
getManagementInfo() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getMaxBundleSize() - Method in class org.jppf.server.JPPFContextDriver
getMaxJobs() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
getMaxResubmits() - Method in class org.jppf.server.protocol.ServerTask: Get the maximum number of times a task can be resubmitted.
getMBeanInterfaceName() - Method in class org.jppf.job.persistence.PersistedJobsManagerMBeanProvider
getMBeanInterfaceName() - Method in class org.jppf.management.spi.JPPFNodeConnectionNotifierMBeanProvider
getMBeanInterfaceName() - Method in class org.jppf.management.spi.LoadBalancerPersistenceManagerMBeanProvider
getMBeanInterfaceName() - Method in class org.jppf.management.spi.PeerDriverMBeanProvider
getMBeanInterfaceName() - Method in class org.jppf.server.job.management.DriverJobManagementMBeanProvider
getMBeanInterfaceName() - Method in class org.jppf.server.job.management.JobDependencyManagerMBeanProvider
getMBeanInterfaceName() - Method in class org.jppf.server.node.spi.JPPFDefaultNodeMBeanProvider: Return the fully qualified name of the management interface defined by this provider.
getMBeanInterfaceName() - Method in class org.jppf.server.node.spi.JPPFNodeMaintenanceMBeanProvider
getMBeanInterfaceName() - Method in class org.jppf.server.node.spi.JPPFNodeTaskMonitorProvider: Return the fully qualified name of the management interface defined by this provider.
getMBeanInterfaceName() - Method in class org.jppf.server.spi.JPPFDefaultDriverMBeanProvider
getMBeanInterfaceName() - Method in class org.jppf.server.spi.JPPFNodeForwardingMBeanProvider: Deprecated.
getMBeanInterfaceName() - Method in class org.jppf.server.spi.NodeForwardingMBeanProvider
getMBeanName() - Method in class org.jppf.job.persistence.PersistedJobsManagerMBeanProvider
getMBeanName() - Method in class org.jppf.management.diagnostics.spi.DriverDiagnosticsMBeanProvider
getMBeanName() - Method in class org.jppf.management.forwarding.ForwardingNotificationEvent: Get the name of the MBean who emitted the notification.
getMBeanName() - Method in class org.jppf.management.spi.JPPFNodeConnectionNotifierMBeanProvider
getMBeanName() - Method in class org.jppf.management.spi.LoadBalancerPersistenceManagerMBeanProvider
getMBeanName() - Method in class org.jppf.management.spi.PeerDriverMBeanProvider
getMBeanName() - Method in class org.jppf.server.job.management.DriverJobManagementMBeanProvider
getMBeanName() - Method in class org.jppf.server.job.management.JobDependencyManagerMBeanProvider
getMBeanName() - Method in class org.jppf.server.node.spi.JPPFDefaultNodeMBeanProvider: Return the name of the specified MBean.
This is the name under which the MBean will be registered with the MBean server.
getMBeanName() - Method in class org.jppf.server.node.spi.JPPFNodeMaintenanceMBeanProvider
getMBeanName() - Method in class org.jppf.server.node.spi.JPPFNodeTaskMonitorProvider: Return the name of the specified MBean.
This is the name under which the MBean will be registered with the MBean server.
getMBeanName() - Method in class org.jppf.server.spi.JPPFDefaultDriverMBeanProvider
getMBeanName() - Method in class org.jppf.server.spi.JPPFNodeForwardingMBeanProvider: Deprecated.
getMBeanName() - Method in class org.jppf.server.spi.NodeForwardingMBeanProvider
getMessageHandler() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
getMessageHandler() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer
getMessageHandler() - Method in class org.jppf.server.nio.client.AsyncClientNioServer
getMessageHandler() - Method in class org.jppf.server.nio.heartbeat.HeartbeatNioServer
getMessageHandler() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
getMetadata() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the job metadata.
getMonitor() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
getName() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the user-defined display name for this job.
getName() - Method in interface org.jppf.server.protocol.SendResultsStrategy: Get the name of this strategy.
getName() - Method in class org.jppf.server.protocol.SendResultsStrategy.SendAllResultsStrategy
getName() - Method in class org.jppf.server.protocol.SendResultsStrategy.SendNodeResultsStrategy
getNbBundles() - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get the number of client bundles.
getNbBundlesForJob(String) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Get the number of dispatches to the node for the specified job.
getNbChannels() - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get count of channels on which this job is executed.
getNbChannels(NodeSelector, boolean, boolean) - Method in class org.jppf.management.NodeSelectionHelper: Get the number of channels matching a NodeSelector.
getNbDispatches() - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get count of dispatches being executed.
getNbDispatches(String) - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get count of dispatches executed on the specified channel.
getNbPendingRequests() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext
getNbPendingResponses() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext: Get the number of pending responses.
getNbReservedNodes(String) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Get the number of nodes reserved for the specified job.
getNbSlaves(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
getNbSlaves(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
getNode(String) - Method in class org.jppf.server.job.management.JobDependencyManager
getNodeBundle(long) - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get the node bundle with the specified id from the dispatch set.
getNodeConnection(String) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer: Get a channel from its uuid.
getNodeConnectionEventHandler() - Method in class org.jppf.server.DriverInitializer: Get the object that handles listeners to node connection events.
getNodeIdentifier() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getNodeIds() - Method in class org.jppf.server.job.management.JobDependencyManager
getNodeInformation() - Method in class org.jppf.server.event.NodeConnectionEvent: Get the node information for this event.
getNodeInformation(String) - Method in class org.jppf.server.job.management.DriverJobManagement
getNodeInformation(JobSelector) - Method in class org.jppf.server.job.management.DriverJobManagement
getNodeJobInformation() - Method in class org.jppf.server.protocol.ServerJob: Get a list of objects describing the nodes to which the whole or part of a job was dispatched.
getNodeReservationHandler() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the object that handles reservation of nodes to jobs.
getNodesForJob(String) - Method in class org.jppf.server.job.JPPFJobManager: Get all the nodes to which a all or part of a job is dispatched.
getNodeUuid() - Method in class org.jppf.management.forwarding.ForwardingNotificationEvent: Get the the uuid of the node that emitted the event.
getNotifCount() - Method in class org.jppf.server.job.JPPFJobManager: Get the count of notifications in the executor's quueue.
getNotification() - Method in class org.jppf.management.forwarding.ForwardingNotificationEvent: Get the notification to dispatch.
getNotifMax() - Method in class org.jppf.server.job.JPPFJobManager: Peak count of notifications in the executor's quueue.
getOfflineNodeHandler() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the object that holds the node bundles waiting for a node to reconnect and send the rsults.
getOriginalBundleId() - Method in class org.jppf.server.protocol.ServerTaskBundleClient
getParentJob() - Method in class org.jppf.server.protocol.ServerJobBroadcast
getPeerConnectionPoolHandler() - Method in class org.jppf.server.DriverInitializer
getPeerDiscoveryThread() - Method in class org.jppf.server.DriverInitializer: Get the thread that performs the peer servers discovery.
getPeerDriver() - Method in class org.jppf.server.JPPFDriver
getPeerHandler() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer: Get the peer handler.
getPeerJmxConnection() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getPeerName() - Method in class org.jppf.server.peer.PeerConnectionPool
getPeerProperties() - Method in class org.jppf.management.PeerDriver
getPendingJobUUID(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Get the UUID of the job for which the specified node has a pending reservation, if any.
getPendingTasksCount() - Method in class org.jppf.server.nio.client.JobEntry: Get the number of tasks that remain to be sent to the client.
getPendingTasksCount() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the number of tasks that remain to execute.
getPersistedJobObject(long, String, PersistenceObjectType, int) - Method in class org.jppf.job.persistence.PersistedJobsManager
getPersistedJobObject(String, PersistenceObjectType, int) - Method in class org.jppf.job.persistence.PersistedJobsManager
getPersistedJobPositions(String) - Method in class org.jppf.job.persistence.PersistedJobsManager
getPersistedJobPositions(String) - Method in class org.jppf.server.queue.PersistenceHandler: Get the positions of all tasks and task results for the specified persisted job.
getPersistedJobUuids() - Method in class org.jppf.server.queue.PersistenceHandler: Get the uuids of all persisted jobs.
getPersistedJobUuids(JobSelector) - Method in class org.jppf.job.persistence.PersistedJobsManager
getPersistence() - Method in class org.jppf.server.queue.PersistenceHandler: Get the persistence service.
getPersistenceHandler() - Method in class org.jppf.server.queue.JPPFPriorityQueue
getPosition() - Method in class org.jppf.server.protocol.ServerTask
getProviderConnections(String) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer: Get all the provider connections for the specified client uuid.
getQueue() - Method in class org.jppf.server.JPPFDriver: Get the queue that handles the tasks to execute.
getQueuedNodes() - Method in class org.jppf.server.job.management.JobDependencyManager
getQueuedNodes(JobSelector) - Method in class org.jppf.server.job.management.JobDependencyManager
getQueueEntryTime() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the time at which this wrapper was added to the queue.
getReadyJobUUID(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Get the UUID of the job for which the specified node is reserved, if any.
getReadyNodes(String) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Get the nodes for which the specified job is ready for dispatch.
getRecoveryConnection() - Method in class org.jppf.server.peer.PeerConnectionPool
getRemovalCondition() - Method in class org.jppf.server.protocol.AbstractServerJob
getRequests(JPPFResourceWrapper) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext: Retrieve the request matching a specified resource.
getRequestStartTime() - Method in class org.jppf.server.nio.classloader.AsyncResourceRequest: Get the time at which this request was submitted.
getReservations() - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Get the uuids of the jobs for which at least oone node is reserved.
getReservationScore() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getReservationTansition() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getReservedJobs() - Method in class org.jppf.server.debug.ServerDebug
getReservedJobs() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the jobs for which at least one node is reserved.
getReservedJobs() - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Get the uuids of the jobs for which at least oone node is reserved.
getReservedNodes() - Method in class org.jppf.server.debug.ServerDebug
getReservedNodes() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the nodes reserved for a job.
getReservedNodes() - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Get the uuids of the reserved nodes.
getResource() - Method in class org.jppf.server.nio.classloader.AsyncResourceRequest: Get the resource to lookup in the client.
getResourceName(JPPFResourceWrapper) - Static method in class org.jppf.server.nio.classloader.AbstractAsyncClassContext: Determine whether the specified resource is a request for a single resource definition.
getResourceProvider() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer: Get the resource provider for this server.
getResult() - Method in class org.jppf.server.protocol.ServerTask: Get the result of the task execution.
getSerializer() - Method in class org.jppf.server.JPPFDriver
getServer() - Method in class org.jppf.server.nio.classloader.AbstractAsyncClassContext
getServer() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext
getServer() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext
getServer() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
getServerDebug() - Method in class org.jppf.server.DriverInitializer: Get the object that collects debug information.
getServerJob() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the job this node bundle is a dispatch of.
getSize() - Method in class org.jppf.server.peer.PeerConnectionPool
getSize(ServerJob) - Method in class org.jppf.server.queue.JPPFPriorityQueue
getSLA() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the service level agreement between the job and the server.
getSLA() - Method in class org.jppf.server.protocol.ServerJobBroadcast
getSLA() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the service level agreement between the job and the server.
getState() - Method in class org.jppf.server.protocol.ServerTask: Get the state of this task.
getStatistics() - Method in class org.jppf.server.JPPFDriver: Get the object holding the statistics monitors.
getStrategy(String) - Static method in class org.jppf.server.protocol.SendResultsStrategyManager: Get a strategy from its name.
getSubmissionStatus() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the status of this submission.
getSystemInformation() - Method in class org.jppf.server.JPPFDriver: Get the system ibnformation for this driver.
getSystemInformation() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
getTaskCount() - Method in class org.jppf.server.protocol.AbstractServerJob
getTaskCount() - Method in class org.jppf.server.protocol.AbstractServerJobBase
getTaskCount() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the number of tasks in the bundle.
getTaskCount() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the number of tasks in this node bundle.
getTaskGraph() - Method in class org.jppf.server.protocol.ServerJob
getTaskGraphInfo() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the dependencies of the tasks in this bundle.
getTaskGraphInfo() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the dependencies of the tasks in this bundle.
getTaskList() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the tasks to be executed by the node.
getTaskList() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the tasks to be executed by the node.
getTaskResubmitCount() - Method in class org.jppf.server.protocol.ServerTask: Get the number of times a task resubmitted itself.
getTasksPositions() - Method in class org.jppf.server.protocol.ServerTaskBundleClient
getThrowable() - Method in class org.jppf.server.protocol.ServerTask: Get the eventual throwable raised during the processing of this task in the driver.
getTotalDispatches() - Method in class org.jppf.server.protocol.AbstractServerJobBase
getTotalNodes() - Method in class org.jppf.server.nio.nodeserver.PeerAttributesHandler: Get the total number of fully connected nodes.
getTotalTaskCpuTime() - Method in class org.jppf.management.JPPFNodeTaskMonitor: The total cpu time used by the tasks in milliseconds.
getTotalTaskElapsedTime() - Method in class org.jppf.management.JPPFNodeTaskMonitor: The total elapsed time used by the tasks in milliseconds.
getTotalTasksExecuted() - Method in class org.jppf.management.JPPFNodeTaskMonitor: Get the total number of tasks executed by the node.
getTotalTasksInError() - Method in class org.jppf.management.JPPFNodeTaskMonitor: The total number of tasks that ended in error.
getTotalTasksSucessfull() - Method in class org.jppf.management.JPPFNodeTaskMonitor: The total number of tasks that executed successfully.
getTotalThreads() - Method in class org.jppf.server.nio.nodeserver.PeerAttributesHandler: Get the total number of processing threads for all fully connected nodes.
getUuid() - Method in class org.jppf.server.JPPFDriver: Get this driver's unique identifier.
getUuid() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the universal unique id for this job.
getUuid() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the universal unique id for this bundle.
go(Set<SelectionKey>) - Method in class org.jppf.server.nio.client.AsyncClientNioServer

H

handleException(Exception) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext
handleException(Exception) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext
handleException(Exception) - Method in class org.jppf.server.nio.client.AsyncClientContext
handleException(Exception) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
handleNotification(Notification, Object) - Method in class org.jppf.server.nio.nodeserver.PeerAttributesHandler
handleNullTasks() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Send back the null tasks immediately.
handleProviderError() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext: Handle the scenario where an exception occurs while sending a request to or receiving a response from a provider, and a node channel is waiting for the response.
handleProviderResponse(AsyncResourceRequest) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext: Process a response ot a provider request.
handleReload() - Method in class org.jppf.server.node.local.AsyncLocalNodeIO: Performs the actions required if reloading the classes is necessary.
handleReload() - Method in class org.jppf.server.node.remote.RemoteNodeIO: Performs the actions required if reloading the classes is necessary.
handleSelectionException(SelectionKey, Exception) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
handleSelectionException(SelectionKey, Exception) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer
handleSelectionException(SelectionKey, Exception) - Method in class org.jppf.server.nio.client.AsyncClientNioServer
handleSelectionException(SelectionKey, Exception) - Method in class org.jppf.server.nio.heartbeat.HeartbeatNioServer
handleSelectionException(SelectionKey, Exception) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
handshakeReceived(AsyncNodeContext, AbstractTaskBundleMessage) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageHandler: Called when a hanshake response is received from a node.
hasAvailableGraphNode() - Method in class org.jppf.server.protocol.ServerJob
hasCompleted() - Method in class org.jppf.server.protocol.AbstractServerJobBase: DFetermine whether this job is in COMPLETED or ENDED state.
hasConnectionInformation(JPPFConnectionInformation) - Method in class org.jppf.server.peer.PeerDiscoveryThread: Determine whether a connection information object is already discovered.
hashCode() - Method in class org.jppf.server.protocol.ServerTaskBundleNode
hasPending() - Method in class org.jppf.server.protocol.AbstractServerJobBase: Get indicator whether job has pending tasks.
hasPendingDependencyOrCancelled(String) - Method in class org.jppf.server.queue.JobDependenciesHandler: Determine whether the specified job has any pending dependency.
hasReadyNode(String) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Determine whether the node with the specified uuid has at leat one reserved node.
healthSnapshot(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
healthSnapshot(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
heapDump(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
heapDump(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
heartbeatConnectionFailed(HeartbeatConnectionEvent) - Method in class org.jppf.server.node.remote.AbstractRemoteNode
heartbeatConnectionFailed(HeartbeatConnectionEvent) - Method in class org.jppf.server.peer.PeerConnectionPool
HeartbeatMessageWriter - Class in org.jppf.server.nio.heartbeat: Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.
HeartbeatMessageWriter(StatelessNioServer<HeartbeatContext>) - Constructor for class org.jppf.server.nio.heartbeat.HeartbeatMessageWriter: Initialize this message writer.
HeartbeatNioServer - Class in org.jppf.server.nio.heartbeat: The NIO server that handles heartbeat connections.
HeartbeatNioServer(JPPFDriver, int, boolean) - Constructor for class org.jppf.server.nio.heartbeat.HeartbeatNioServer

I

id - Variable in class org.jppf.server.protocol.AbstractServerJob: A unique id for this client bundle.
idleNodesInformation() - Method in class org.jppf.management.JPPFDriverAdmin
idleNodesInformation(NodeSelector) - Method in class org.jppf.management.JPPFDriverAdmin
incExpirationCount() - Method in class org.jppf.server.protocol.ServerTask: Increment and get the number of times a dispatch of this task has expired.
incResubmitCount() - Method in class org.jppf.server.protocol.ServerTask: Increment and get the number of times a task resubmitted itself.
init() - Method in class org.jppf.server.node.local.AsyncLocalNodeConnection
init() - Method in class org.jppf.server.node.remote.JPPFRemoteNode
init() - Method in class org.jppf.server.node.remote.RemoteNodeConnection
initBroadcaster() - Method in class org.jppf.server.DriverInitializer: Initialize and start the discovery service.
initClassLoaderManager() - Method in class org.jppf.server.node.remote.AbstractRemoteNode: Create and initialize the class loader manager.
initClassLoaderManager() - Method in class org.jppf.server.node.remote.JPPFRemoteNode
initDataChannel() - Method in class org.jppf.server.node.local.JPPFLocalNode
initDataChannel() - Method in class org.jppf.server.node.remote.AbstractRemoteNode
initializeJmxConnection() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Initialize the jmx connection using the specified jmx id.
initiateShutdownRestart(long, boolean, long) - Method in class org.jppf.server.JPPFDriver: Initialize this task with the specified parameters.
The shutdown is initiated after the specified shutdown delay has expired.
If the restart parameter is set to false then the JVM exits after the shutdown is complete.
initNioHandlers() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
initNioHandlers() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer
initNioHandlers() - Method in class org.jppf.server.nio.client.AsyncClientNioServer
initNioHandlers() - Method in class org.jppf.server.nio.heartbeat.HeartbeatNioServer
initNioHandlers() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
initReaderAndWriter() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer
initReaderAndWriter() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer
initReaderAndWriter() - Method in class org.jppf.server.nio.client.AsyncClientNioServer
initReaderAndWriter() - Method in class org.jppf.server.nio.heartbeat.HeartbeatNioServer
initReaderAndWriter() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
isAcceptingNewJobs() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
isActive() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
isBroadcastDispatch(AbstractServerJob) - Static method in class org.jppf.server.job.JPPFJobManager: Determine whether the specified job is the dispatch of a broadcast job to a node.
isBroadcasting() - Method in class org.jppf.server.DriverInitializer: Determine whether broadcasting is active.
isCancelled() - Method in class org.jppf.server.protocol.AbstractServerJob
isCancelled() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the cancelled indicator.
isCancelled() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the cancelled indicator.
isDone() - Method in class org.jppf.server.protocol.ServerTask: Determine whether this task has completed.
isDone() - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Get the done indicator.
isExpired() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the expired indicator.
isFromDiscovery() - Method in class org.jppf.server.peer.PeerConnectionPool
isJobComplete(String) - Method in class org.jppf.job.persistence.PersistedJobsManager
isJobersisted(String) - Method in class org.jppf.job.persistence.PersistedJobsManager
isJobExpired() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the job expired indicator.
isJobGraphAlreadyHandled() - Method in class org.jppf.server.protocol.AbstractServerJobBase
isJobPersisted(String) - Method in class org.jppf.server.queue.PersistenceHandler: Determine whether the specified job is persisted.
isJppfDebugEnabled() - Method in class org.jppf.server.JPPFDriver
isLocal() - Method in class org.jppf.server.node.local.JPPFLocalNode
isLocal() - Method in class org.jppf.server.node.remote.AbstractRemoteNode
isNodeAccepted(String, NodeSelector) - Method in class org.jppf.management.NodeSelectionHelper
isNodeAccepted(BaseNodeContext, NodeSelector) - Method in class org.jppf.management.NodeSelectionHelper: Determine whether the specified selector accepts the specified node.
isOffline() - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
isOffline() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the offline node indicator.
isPending() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the job pending indicator.
isPersistent() - Method in class org.jppf.server.protocol.AbstractServerJob
isProvider() - Method in class org.jppf.server.nio.classloader.AbstractAsyncClassContext: Determine whether this context relates to a provider or node connection.
isProvider() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext
isProvider() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext
isRequeued() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Get the requeued indicator.
isReturnedFromNode() - Method in class org.jppf.server.protocol.ServerTask
isSecure() - Method in class org.jppf.server.peer.PeerConnectionPool
isShuttingDown() - Method in class org.jppf.server.JPPFDriver: Determine whether this driver has initiated a shutdown, in which case it does not accept connections anymore.
isSuspended() - Method in class org.jppf.server.protocol.AbstractServerJob: Get the job suspended indicator.

J

job - Variable in class org.jppf.server.protocol.AbstractServerJob: The underlying task bundle.
jobCancelled(ServerJob) - Method in class org.jppf.server.queue.JobDependenciesHandler: Called when a job with dependencies is cancelled.
JobDependenciesHandler - Class in org.jppf.server.queue: This class handles the interactions between the server queue and jobs and the job dependency graph.
JobDependenciesHandler(JPPFPriorityQueue) - Constructor for class org.jppf.server.queue.JobDependenciesHandler: Create this dependency handler.
JobDependencyManager - Class in org.jppf.server.job.management: Concrete implementation of the job dependency graph management interface.
JobDependencyManager(JPPFDriver) - Constructor for class org.jppf.server.job.management.JobDependencyManager: Initialize this dependency manager with the specified JPPF driver.
JobDependencyManagerMBeanProvider - Class in org.jppf.server.job.management: Implemention of the Service Provider Interface (SPI) for a pluggable server MBean which managages the job dependency graph.
JobDependencyManagerMBeanProvider() - Constructor for class org.jppf.server.job.management.JobDependencyManagerMBeanProvider
jobDispatched(ExecutorChannel<?>, Future<?>) - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Called when all or part of a job is dispatched to a node.
jobDispatched(AbstractServerJob, ExecutorChannel<?>, ServerTaskBundleNode) - Method in class org.jppf.server.job.JPPFJobManager
jobDispatched(AbstractServerJob, ExecutorChannel<?>, ServerTaskBundleNode) - Method in interface org.jppf.server.protocol.ServerJobChangeListener: Called when all or part of a job is dispatched to a node.
jobDispatched(ServerTaskBundleNode) - Method in class org.jppf.server.protocol.AbstractServerJobBase: Called when all or part of a job is dispatched to a node.
jobDispatched(ServerTaskBundleNode) - Method in class org.jppf.server.protocol.ServerJobBroadcast
jobEnded() - Method in class org.jppf.server.protocol.ServerJobBroadcast: Called when the entire broadcast job is complete.
jobEnded(ServerJob) - Method in class org.jppf.server.job.JPPFJobManager: Called when a job is complete and returned to the client.
jobEnded(ServerJob) - Method in class org.jppf.server.queue.JobDependenciesHandler: Called when a job ends and is removed from the client or server queue.
jobEnding(NodeLifeCycleEvent) - Method in class org.jppf.management.NodeStatusNotifier
JobEntry - Class in org.jppf.server.nio.client: Instances of tyhis class represent the state of a task bundle sent over a client conenction.
JobEntryDebugStats() - Constructor for class org.jppf.server.nio.client.AsyncClientContext.JobEntryDebugStats
jobExpired - Variable in class org.jppf.server.protocol.AbstractServerJob: Job expired indicator, determines whether the job is should be cancelled.
jobExpired() - Method in class org.jppf.server.protocol.AbstractServerJob: Sets and notifies that job has expired.
jobHeaderLoaded(NodeLifeCycleEvent) - Method in class org.jppf.management.NodeStatusNotifier
JobManager - Interface in org.jppf.server.job: Interface for job manager that handles states and monitor the jobs throughout their processing within the JPPF.
JobPriorityComparator - Class in org.jppf.server.queue: A Comparator which compare CLientJob objects in descending order of their priority.
JobPriorityComparator() - Constructor for class org.jppf.server.queue.JobPriorityComparator
jobQueued(ServerJob) - Method in class org.jppf.server.job.JPPFJobManager: Called when a job is added to the server queue.
jobQueued(ServerJob) - Method in class org.jppf.server.queue.JobDependenciesHandler: Called when a job with dependencies arrives in the client or server queue.
jobReceivedTime - Variable in class org.jppf.server.protocol.AbstractServerJob: Time at which the job is received on the server side.
jobResultsReceived(ExecutorChannel<?>, ServerJob, Collection<ServerTask>) - Method in class org.jppf.server.job.JPPFJobManager: Called when final tasks results have been received and are about to be sent back to the client.
jobReturned(AbstractServerJob, ExecutorChannel<?>, ServerTaskBundleNode) - Method in class org.jppf.server.job.JPPFJobManager
jobReturned(AbstractServerJob, ExecutorChannel<?>, ServerTaskBundleNode) - Method in interface org.jppf.server.protocol.ServerJobChangeListener: Called when all or part of a job has returned from a node.
jobReturned(ServerTaskBundleNode) - Method in class org.jppf.server.protocol.AbstractServerJobBase: Called when all or part of a job is returned from node.
jobStarting(NodeLifeCycleEvent) - Method in class org.jppf.management.NodeStatusNotifier
jobStatusChanged(AbstractServerJob, SubmissionStatus, SubmissionStatus) - Method in class org.jppf.server.job.JPPFJobManager
jobStatusChanged(AbstractServerJob, SubmissionStatus, SubmissionStatus) - Method in interface org.jppf.server.protocol.ServerJobChangeListener: Called when job submission status is changed.
jobUpdated(AbstractServerJob, boolean) - Method in class org.jppf.server.job.JPPFJobManager
jobUpdated(AbstractServerJob, boolean) - Method in interface org.jppf.server.protocol.ServerJobChangeListener: Called when a job is added to the server queue.
JPPFContextDriver - Class in org.jppf.server: Context associated with a driver.
JPPFContextDriver(JPPFQueue<?, ?, ?>) - Constructor for class org.jppf.server.JPPFContextDriver: Default initializer.
JPPFDefaultDriverMBeanProvider - Class in org.jppf.server.spi: Provider for the default JPPF driver management and monitoring features.
JPPFDefaultDriverMBeanProvider() - Constructor for class org.jppf.server.spi.JPPFDefaultDriverMBeanProvider
JPPFDefaultNodeMBeanProvider - Class in org.jppf.server.node.spi: Provider for the default JPPF node management and monitoring features.
JPPFDefaultNodeMBeanProvider() - Constructor for class org.jppf.server.node.spi.JPPFDefaultNodeMBeanProvider
JPPFDriver - Class in org.jppf.server: This class serves as an initializer for the entire JPPF driver.
JPPFDriver(TypedProperties) - Constructor for class org.jppf.server.JPPFDriver: Initialize this JPPF driver with the specified configuration.
JPPFDriverAdmin - Class in org.jppf.management: Instances of this class encapsulate the administration functionalities for a JPPF driver.
JPPFDriverAdmin(JPPFDriver) - Constructor for class org.jppf.management.JPPFDriverAdmin
JPPFDriverMBeanProvider - Interface in org.jppf.management.spi: Service provider interface for pluggable management beans for JPPF drivers.
JPPFJobEndedException - Exception in org.jppf.server.protocol: Exception raised when trying to adding a client bundle to a job that is already in the SubmissionStatus.ENDED state.
JPPFJobEndedException(String) - Constructor for exception org.jppf.server.protocol.JPPFJobEndedException: Initialize this exception with a specified message.
JPPFJobEndedException(String, Throwable) - Constructor for exception org.jppf.server.protocol.JPPFJobEndedException: Initialize this exception with a specified message and cause exception.
JPPFJobEndedException(Throwable) - Constructor for exception org.jppf.server.protocol.JPPFJobEndedException: Initialize this exception with a specified cause exception.
JPPFJobManager - Class in org.jppf.server.job: Instances of this class manage and monitor the jobs throughout their processing within the JPPF driver.
JPPFJobManager(JPPFDriver) - Constructor for class org.jppf.server.job.JPPFJobManager: Default constructor.
JPPFLocalContainer - Class in org.jppf.server.node.local: 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.
JPPFLocalContainer(AbstractCommonNode, List<String>, AbstractJPPFClassLoader, boolean) - Constructor for class org.jppf.server.node.local.JPPFLocalContainer: Initialize this container with a specified application uuid.
JPPFLocalNode - Class in org.jppf.server.node.local: Local (in-VM) node implementation.
JPPFLocalNode(TypedProperties, AsyncLocalNodeConnection, AbstractClassLoaderConnection<?>, HookFactory) - Constructor for class org.jppf.server.node.local.JPPFLocalNode: Initialize this local node with the specified I/O handler.
JPPFNodeAdmin - Class in org.jppf.management: Management bean for a JPPF node.
JPPFNodeAdmin(JPPFNode) - Constructor for class org.jppf.management.JPPFNodeAdmin: Initialize this node management bean with the specified node.
JPPFNodeConnectionNotifier - Class in org.jppf.management
JPPFNodeConnectionNotifierMBeanProvider - Class in org.jppf.management.spi
JPPFNodeConnectionNotifierMBeanProvider() - Constructor for class org.jppf.management.spi.JPPFNodeConnectionNotifierMBeanProvider
JPPFNodeForwarding - Class in org.jppf.management.forwarding: Deprecated.
use NodeForwarding instead.
JPPFNodeForwarding(JPPFDriver) - Constructor for class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.

Initialize this MBean implementation.
JPPFNodeForwardingMBeanProvider - Class in org.jppf.server.spi: Deprecated.
use NodeForwardingMBeanProvider instead.
JPPFNodeForwardingMBeanProvider() - Constructor for class org.jppf.server.spi.JPPFNodeForwardingMBeanProvider: Deprecated.
JPPFNodeMaintenance - Class in org.jppf.management: Implementation of the JPPFNodeMaintenanceMBean MBean interface.
JPPFNodeMaintenance(JPPFNode) - Constructor for class org.jppf.management.JPPFNodeMaintenance: Initialize this node management bean with the specified node.
JPPFNodeMaintenanceMBeanProvider - Class in org.jppf.server.node.spi: SPI Provider implementation for the node maintenance MBean.
JPPFNodeMaintenanceMBeanProvider() - Constructor for class org.jppf.server.node.spi.JPPFNodeMaintenanceMBeanProvider
JPPFNodeTaskMonitor - Class in org.jppf.management: MBean implementation for task-level monitoring on each node.
JPPFNodeTaskMonitor(Node, String) - Constructor for class org.jppf.management.JPPFNodeTaskMonitor: Default constructor.
JPPFNodeTaskMonitorProvider - Class in org.jppf.server.node.spi: SPI Provider implementation for task-level monitoring MBean.
JPPFNodeTaskMonitorProvider() - Constructor for class org.jppf.server.node.spi.JPPFNodeTaskMonitorProvider
JPPFPeerInitializer - Class in org.jppf.server.peer: Instances of this class are used to initialize the connections to a peer driver in a separate thread.
JPPFPeerInitializer(JPPFDriver, String, JPPFConnectionInformation, boolean) - Constructor for class org.jppf.server.peer.JPPFPeerInitializer: Initialize this peer initializer from a specified peerName.
JPPFPeerInitializer(JPPFDriver, String, JPPFConnectionInformation, boolean, boolean) - Constructor for class org.jppf.server.peer.JPPFPeerInitializer: Initialize this peer initializer from a specified peerName.
JPPFPriorityQueue - Class in org.jppf.server.queue: A JPPF queue whose elements are ordered by decreasing priority.
JPPFPriorityQueue(JPPFDriver, JPPFJobManager) - Constructor for class org.jppf.server.queue.JPPFPriorityQueue: Initialize this queue.
JPPFRemoteContainer - Class in org.jppf.server.node.remote: 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.
JPPFRemoteContainer(AbstractCommonNode, List<String>, AbstractJPPFClassLoader, boolean) - Constructor for class org.jppf.server.node.remote.JPPFRemoteContainer: Initialize this container with a specified application uuid.
JPPFRemoteNode - Class in org.jppf.server.node.remote: Instances of this class encapsulate execution nodes.
JPPFRemoteNode(String, TypedProperties, DriverConnectionInfo, HookFactory) - Constructor for class org.jppf.server.node.remote.JPPFRemoteNode: Default constructor.

K

KEEP - Enum constant in enum class org.jppf.server.nio.nodeserver.NodeReservationHandler.Transition: No transition.

L

load(Collection<PersistenceInfo>) - Method in class org.jppf.server.queue.PersistenceHandler: Load the specified job elements from the persistence store.
load(PersistenceInfo) - Method in class org.jppf.server.queue.PersistenceHandler: Load the specified job element from the persistence store.
loadBalancerInformation() - Method in class org.jppf.management.JPPFDriverAdmin
LoadBalancerPersistenceManagerMBeanProvider - Class in org.jppf.management.spi
LoadBalancerPersistenceManagerMBeanProvider() - Constructor for class org.jppf.management.spi.LoadBalancerPersistenceManagerMBeanProvider
loadHeader(String) - Method in class org.jppf.server.queue.PersistenceHandler: Load and deserialize the header of the job with the sdpecified uuid.
loadListeners() - Method in class org.jppf.server.event.NodeConnectionEventHandler: Load all listener instances found in the class path via a service definition.
loadPersistedJobs() - Method in class org.jppf.server.queue.PersistenceHandler: Load all jobs in the persistence store.
loadTaskReturnListeners() - Method in class org.jppf.server.job.JPPFJobManager: Load all the dispatch listeners defined in the classpath with SPI.
loadToDisk(PersistenceInfo) - Method in class org.jppf.server.queue.PersistenceHandler: Load the specified job element from the persistence store.
LocalNodeMessage - Class in org.jppf.server.nio.nodeserver: Node message implementation for an in-VM node.
LocalNodeMessage(BaseNodeContext) - Constructor for class org.jppf.server.nio.nodeserver.LocalNodeMessage: Build this nio message.
lock - Variable in class org.jppf.server.protocol.AbstractServerJob: Used for synchronized access to job.
log(String) - Method in class org.jppf.server.debug.ServerDebug
log(String) - Method in interface org.jppf.server.debug.ServerDebugMBean: Print the specified message to the server's log.
log(String...) - Method in class org.jppf.server.debug.ServerDebug
log(String...) - Method in interface org.jppf.server.debug.ServerDebugMBean: Print the specified messages to the server's log.

M

main(String...) - Static method in class org.jppf.server.DriverLauncher: Start this application, then the JPPF driver a subprocess.
main(String...) - Static method in class org.jppf.server.JPPFDriver: Start the JPPF driver.
makeKey(String, long) - Static method in class org.jppf.server.protocol.ServerTaskBundleNode: Build a unique key for a node task bundle with the specified job uuid and node id.
makeKey(ServerTaskBundleNode) - Static method in class org.jppf.server.protocol.ServerTaskBundleNode: Build a unique key for the specified node task bundle.
MBEAN_NAME - Static variable in interface org.jppf.server.debug.ServerDebugMBean: The name of this mbean.
merge(List<ServerTask>, boolean) - Method in class org.jppf.server.protocol.AbstractServerJobBase: Merge this client job wrapper with another.

N

name - Variable in class org.jppf.server.protocol.AbstractServerJob: The user-defined display name for this job.
nbIdleNodes() - Method in class org.jppf.management.JPPFDriverAdmin
nbIdleNodes(NodeSelector) - Method in class org.jppf.management.JPPFDriverAdmin
nbIdleNodes(NodeSelector, boolean) - Method in class org.jppf.management.JPPFDriverAdmin
nbNodes() - Method in class org.jppf.management.JPPFDriverAdmin
nbNodes(NodeSelector) - Method in class org.jppf.management.JPPFDriverAdmin
NEW - Enum constant in enum class org.jppf.server.protocol.ServerJobStatus: Job status is new (just submitted).
newClassLoaderCreator(List<String>, Object...) - Method in class org.jppf.server.node.remote.RemoteClassLoaderManager
newJPPFContainer(List<String>, AbstractJPPFClassLoader, boolean) - Method in class org.jppf.server.node.remote.RemoteClassLoaderManager
newMessage() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Create a new message.
newMessage(ServerTaskBundleClient) - Method in class org.jppf.server.nio.client.AsyncClientContext: Create a new message.
newPool(String, int, JPPFConnectionInformation, boolean, boolean) - Method in class org.jppf.server.peer.PeerConnectionPoolHandler: Create a new peer connection pool.
nextBundle(ServerJob, int, ExecutorChannel<ServerTaskBundleNode>) - Method in class org.jppf.server.queue.JPPFPriorityQueue
nextMessageToSend() - Method in class org.jppf.server.nio.classloader.AbstractAsyncClassContext
nextMessageToSend() - Method in class org.jppf.server.nio.client.AsyncClientContext
nextMessageToSend() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
NodeBundleResults - Class in org.jppf.server.nio.nodeserver: Convenience class to simplify and improve readability of the code.
NodeBundleResults(TaskBundle, List<DataLocation>) - Constructor for class org.jppf.server.nio.nodeserver.NodeBundleResults: Initialize with the specified task bundle and task data.
nodeClassLoaderChannels() - Method in class org.jppf.server.debug.ServerDebug
nodeClassLoaderChannels() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the states of the class loader channels.
nodeConnected(NodeConnectionEvent) - Method in class org.jppf.management.forwarding.ForwardingNotificationManager
nodeConnected(NodeConnectionEvent) - Method in interface org.jppf.server.event.NodeConnectionListener: Called when a node is connected to the server.
nodeConnected(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
nodeConnected(BaseNodeContext) - Method in interface org.jppf.server.nio.nodeserver.NodeConnectionCompletionListener: Called when a channel is connected.
NodeConnectionCompletionListener - Interface in org.jppf.server.nio.nodeserver
NodeConnectionEvent - Class in org.jppf.server.event: Event emitted when a node connects to or disconnects from the server.
NodeConnectionEvent(JPPFManagementInfo) - Constructor for class org.jppf.server.event.NodeConnectionEvent: Initialize this event with the specified source.
NodeConnectionEventHandler - Class in org.jppf.server.event: This class handles operations for node connection events, including listener registration, event notifications and initial loading of listeners via SPI.
NodeConnectionEventHandler() - Constructor for class org.jppf.server.event.NodeConnectionEventHandler: Default constructor.
NodeConnectionListener - Interface in org.jppf.server.event: Interface for classes that wish to be notified of node connection events.
nodeConnections - Variable in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer: Mapping of channels to their uuid.
nodeDataChannels() - Method in class org.jppf.server.debug.ServerDebug
nodeDataChannels() - Method in interface org.jppf.server.debug.ServerDebugMBean: Get the states of the node data channels.
nodeDisconnected(NodeConnectionEvent) - Method in class org.jppf.management.forwarding.ForwardingNotificationManager
nodeDisconnected(NodeConnectionEvent) - Method in interface org.jppf.server.event.NodeConnectionListener: Called when a node is disconnected from the server.
NodeDispatchTimeoutAction - Class in org.jppf.server.nio.nodeserver
NodeDispatchTimeoutAction(OfflineNodeHandler, ServerTaskBundleNode, BaseNodeContext) - Constructor for class org.jppf.server.nio.nodeserver.NodeDispatchTimeoutAction: Initialize this action with the specified server and nodBundle.
nodeEnding(NodeLifeCycleEvent) - Method in class org.jppf.management.NodeStatusNotifier
NodeForwarding - Class in org.jppf.management.forwarding: Implementation of the JPPFNodeForwardingMBean interface.
NodeForwarding(JPPFDriver) - Constructor for class org.jppf.management.forwarding.NodeForwarding: Initialize this MBean implementation.
NodeForwardingMBeanProvider - Class in org.jppf.server.spi: Provider for the default JPPF driver management and monitoring features.
NodeForwardingMBeanProvider() - Constructor for class org.jppf.server.spi.NodeForwardingMBeanProvider
NodeJMXWrapperListener - Class in org.jppf.server.nio.nodeserver
NodeJMXWrapperListener(BaseNodeContext, NodeConnectionCompletionListener) - Constructor for class org.jppf.server.nio.nodeserver.NodeJMXWrapperListener: Initialize this listener.
NodeReservationHandler - Class in org.jppf.server.nio.nodeserver: Handles the reservation of nodes to jobs that request a specific node configuration.
NodeReservationHandler(JPPFDriver) - Constructor for class org.jppf.server.nio.nodeserver.NodeReservationHandler: Initialize with the specified node server.
NodeReservationHandler.Transition - Enum Class in org.jppf.server.nio.nodeserver: Types of transitions for a reservation, applied to a node.
NodeSelectionHelper - Class in org.jppf.management
NodeSelectionHelper(JPPFDriver) - Constructor for class org.jppf.management.NodeSelectionHelper
nodesInformation() - Method in class org.jppf.management.JPPFDriverAdmin
nodesInformation(NodeSelector) - Method in class org.jppf.management.JPPFDriverAdmin
nodesInformation(NodeSelector, boolean) - Method in class org.jppf.management.JPPFDriverAdmin
nodeStarting(NodeLifeCycleEvent) - Method in class org.jppf.management.NodeStatusNotifier
NodeStatusNotifier - Class in org.jppf.management: This NodeLifeCycleListener implementations is used to update the node state maintained by the node management MBean.
NodeStatusNotifier(JPPFNodeAdmin) - Constructor for class org.jppf.management.NodeStatusNotifier: Initialize this notifier with the specified node admin mbean.
notFound() - Method in class org.jppf.server.nio.client.AsyncClientContext.JobEntryDebugStats
notificationEmitter - Variable in class org.jppf.server.protocol.AbstractServerJob: Handler for job state notifications.
notificationReceived(ForwardingNotificationEvent) - Method in interface org.jppf.management.forwarding.ForwardingNotificationEventListener: Called when a JMX notification is received from any node with a registered notification listener.
notificationReceived(ForwardingNotificationEvent) - Method in class org.jppf.management.forwarding.ForwardingNotificationManager

O

offerMessageToSend(ClassLoaderNioMessage) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext: Add the specified message to the send queue.
OfflineNodeHandler - Class in org.jppf.server.nio.nodeserver
OfflineNodeHandler() - Constructor for class org.jppf.server.nio.nodeserver.OfflineNodeHandler
onCloseNode(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.PeerAttributesHandler: Called when a node gets closed.
onConnected(JMXConnectionWrapperEvent) - Method in class org.jppf.server.nio.nodeserver.NodeJMXWrapperListener
onConnectionTimeout(JMXConnectionWrapperEvent) - Method in class org.jppf.server.nio.nodeserver.NodeJMXWrapperListener
onDoneList - Variable in class org.jppf.server.protocol.AbstractServerJob: List of all runnables called on job completion.
onJobCancelled(ServerJob) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Remove all the node reservations for the specified job that is being cancelled.
onNewConnection(String, JPPFConnectionInformation) - Method in interface org.jppf.server.peer.PeerDiscoveryThread.ConnectionHandler: Called when a new connection is discovered.
onNewConnection(String, JPPFConnectionInformation) - Method in class org.jppf.server.peer.PeerDiscoveryThread: Add a newly found connection.
onNodeConnected(JPPFManagementInfo) - Method in class org.jppf.management.JPPFNodeConnectionNotifier: Called when a node is connected to the driver.
onNodeConnected(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.PeerAttributesHandler: Called when a node gets connected to the server.
onNodeDisconnected(JPPFManagementInfo) - Method in class org.jppf.management.JPPFNodeConnectionNotifier: Called when a node is disconnected from the driver.
onRequeue - Variable in class org.jppf.server.protocol.AbstractServerJobBase: The requeue handler.
org.jppf.job.persistence - package org.jppf.job.persistence: Support for jobs persistence on the server side.
org.jppf.management - package org.jppf.management: Support for the JMX-based management of JPPF components.
org.jppf.management.diagnostics.spi - package org.jppf.management.diagnostics.spi: Support for the SPI of the JVM health monitoring and diagnostics.
org.jppf.management.forwarding - package org.jppf.management.forwarding: Support for the forwarding of node JMX requests and notifications via the driver.
org.jppf.management.spi - package org.jppf.management.spi: Support for service provider interface, to provide pluggable management beans, including user-defined ones.
org.jppf.server - package org.jppf.server: The JPPF driver API.
org.jppf.server.debug - package org.jppf.server.debug: Classes providing server debug information via JMX.
org.jppf.server.event - package org.jppf.server.event: Support for node connection events occurring in the server.
org.jppf.server.job - package org.jppf.server.job: Support for job management in the server.
org.jppf.server.job.management - package org.jppf.server.job.management: Support for job management mbeans in the server.
org.jppf.server.nio - package org.jppf.server.nio: Classes supporting asynchronous communication through the NIO APIs.
org.jppf.server.nio.classloader - package org.jppf.server.nio.classloader: Support for NIO-based communication for the class loader channel.
org.jppf.server.nio.classloader.client - package org.jppf.server.nio.classloader.client: Support for NIO-based communication with the clients, for the class loader channel.
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.
org.jppf.server.nio.client - package org.jppf.server.nio.client: Support for NIO-based communication with the clients.
org.jppf.server.nio.heartbeat - package org.jppf.server.nio.heartbeat: Support for heartbeat messages betwen server and nodes.
org.jppf.server.nio.nodeserver - package org.jppf.server.nio.nodeserver: Classes supporting the server node-side of the JPPF asynchronous communication model.
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.
org.jppf.server.node.local - package org.jppf.server.node.local: Classes supporting local nodes, in the same JVM as the driver.
org.jppf.server.node.remote - package org.jppf.server.node.remote: Classes supporting remote nodes.
org.jppf.server.node.spi - package org.jppf.server.node.spi: Support for service provider interface, to provide pluggable management beans, including user-defined ones.
org.jppf.server.peer - package org.jppf.server.peer: Support for P2P communication between servers.
org.jppf.server.protocol - package org.jppf.server.protocol: Classes supporting the data transported between components of the communication model.
org.jppf.server.queue - package org.jppf.server.queue: Support for job queuing in the JPPF driver.
org.jppf.server.spi - package org.jppf.server.spi: Support for service provider interface, to provide pluggable functionality for JPPF drivers.
org.jppf.server.submission - package org.jppf.server.submission: Support submission status handling.
org.jppf.startup - package org.jppf.startup: Support for service provider interface, to provide pluggable startup classes for nodes and drivers.

P

PEER_TOTAL_NODES - Static variable in class org.jppf.server.nio.nodeserver.PeerAttributesHandler: Property for total nodes attached to a peer driver.
PEER_TOTAL_THREADS - Static variable in class org.jppf.server.nio.nodeserver.PeerAttributesHandler: Property for total threads for the nodes attached to a peer driver.
PeerAttributesHandler - Class in org.jppf.server.nio.nodeserver
PeerAttributesHandler(JPPFDriver, int) - Constructor for class org.jppf.server.nio.nodeserver.PeerAttributesHandler: Initialize this handler.
PeerConnectionPool - Class in org.jppf.server.peer
PeerConnectionPool(JPPFDriver, String, int, JPPFConnectionInformation, boolean, boolean) - Constructor for class org.jppf.server.peer.PeerConnectionPool: Initialize this connection pool.
PeerConnectionPoolHandler - Class in org.jppf.server.peer
PeerConnectionPoolHandler(JPPFDriver, TypedProperties) - Constructor for class org.jppf.server.peer.PeerConnectionPoolHandler: Initialize this connection pool handler.
PeerDiscoveryThread - Class in org.jppf.server.peer: Instances of this class discover peer drivers over the network.
PeerDiscoveryThread(TypedProperties, IPFilter, JPPFConnectionInformation, PeerDiscoveryThread.ConnectionHandler) - Constructor for class org.jppf.server.peer.PeerDiscoveryThread: Default constructor.
PeerDiscoveryThread.ConnectionHandler - Interface in org.jppf.server.peer: Defines a callback for objects wishing to be notified of discovery events.
PeerDriver - Class in org.jppf.management
PeerDriver(JPPFDriver) - Constructor for class org.jppf.management.PeerDriver: Direct instantiation not permitted.
PeerDriverMBeanProvider - Class in org.jppf.management.spi
PeerDriverMBeanProvider() - Constructor for class org.jppf.management.spi.PeerDriverMBeanProvider
pending - Variable in class org.jppf.server.protocol.AbstractServerJob: Job pending indicator, determines whether the job is waiting for its scheduled time to start.
PENDING - Enum constant in enum class org.jppf.server.submission.SubmissionStatus: The job is currently in the submission queue (on the client side).
pendingAction() - Method in class org.jppf.management.JPPFNodeAdmin: Get the current state of the node
pendingTasksCount - Variable in class org.jppf.server.protocol.ServerJobBroadcast: Number of remaining tasks that have not completed.
PersistedJobsManager - Class in org.jppf.job.persistence: Implementation of the PersistedJobsManagerMBean interface.
PersistedJobsManager(JPPFDriver) - Constructor for class org.jppf.job.persistence.PersistedJobsManager: Initialize this MBean.
PersistedJobsManagerMBeanProvider - Class in org.jppf.job.persistence: Provider for the default JPPF driver management and monitoring features.
PersistedJobsManagerMBeanProvider() - Constructor for class org.jppf.job.persistence.PersistedJobsManagerMBeanProvider
PersistenceHandler - Class in org.jppf.server.queue: This class is a facade to the job persistence service defined in the configuration.
PersistenceHandler(JPPFPriorityQueue) - Constructor for class org.jppf.server.queue.PersistenceHandler: Initialize this persistence handler.
postWrite(AsyncClientClassContext, NioMessage) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassMessageWriter
postWrite(AsyncNodeClassContext, NioMessage) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassMessageWriter
postWrite(AsyncClientContext, NioMessage) - Method in class org.jppf.server.nio.client.AsyncClientMessageWriter
postWrite(HeartbeatContext, NioMessage) - Method in class org.jppf.server.nio.heartbeat.HeartbeatMessageWriter
postWrite(AsyncNodeContext, NioMessage) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageWriter
preparePolicy(ExecutionPolicy, ServerJob, JPPFStatistics, int) - Static method in class org.jppf.server.nio.nodeserver.async.AsyncJobScheduler: Set the parameters needed as bounded variables for scripted execution policies.
preWrite(AsyncNodeContext, NioMessage) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageWriter
processPendingBroadcasts() - Method in class org.jppf.server.queue.BroadcastManager: Process the jobs in the pending broadcast queue.
provisionSlaveNodes(NodeSelector, int) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
provisionSlaveNodes(NodeSelector, int) - Method in class org.jppf.management.forwarding.NodeForwarding
provisionSlaveNodes(NodeSelector, int, boolean) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
provisionSlaveNodes(NodeSelector, int, boolean) - Method in class org.jppf.management.forwarding.NodeForwarding
provisionSlaveNodes(NodeSelector, int, boolean, TypedProperties) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
provisionSlaveNodes(NodeSelector, int, boolean, TypedProperties) - Method in class org.jppf.management.forwarding.NodeForwarding
provisionSlaveNodes(NodeSelector, int, TypedProperties) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
provisionSlaveNodes(NodeSelector, int, TypedProperties) - Method in class org.jppf.management.forwarding.NodeForwarding

Q

queueEntryTime - Variable in class org.jppf.server.protocol.AbstractServerJob: The time at which this wrapper was added to the queue.

R

read() - Method in class org.jppf.server.nio.nodeserver.LocalNodeMessage
readMessage() - Method in class org.jppf.server.nio.classloader.AbstractAsyncClassContext
readMessage() - Method in class org.jppf.server.nio.client.AsyncClientContext
readMessage() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
readNextObject() - Method in class org.jppf.server.nio.client.ClientMessage
readNextObject() - Method in class org.jppf.server.nio.nodeserver.LocalNodeMessage
READY - Enum constant in enum class org.jppf.server.nio.nodeserver.NodeReservationHandler.Transition: Pass the reservation to ready state
reconnect(Boolean) - Method in class org.jppf.management.JPPFNodeAdmin
reconnect(NodeSelector, Boolean) - Method in class org.jppf.management.forwarding.NodeForwarding
registerForwardingNotificationListener(NodeSelector, String) - Method in class org.jppf.management.forwarding.AbstractNodeForwarding: Register a listener with the specified node selector and MBean.
RemoteClassLoaderManager - Class in org.jppf.server.node.remote: Concrete implementation of AbstractClassLoaderManager for a remote node.
RemoteNodeConnection - Class in org.jppf.server.node.remote: This class encapsulates the network connection of a node to a server job channel.
RemoteNodeConnection(DriverConnectionInfo, ObjectSerializer, Node) - Constructor for class org.jppf.server.node.remote.RemoteNodeConnection: Initialize this connection with the specified serializer.
RemoteNodeIO - Class in org.jppf.server.node.remote: This class performs the I/O operations requested by the JPPFNode, for reading the task bundles and sending the results back.
RemoteNodeIO(AbstractRemoteNode) - Constructor for class org.jppf.server.node.remote.RemoteNodeIO: Initialize this TaskIO with the specified node.
RemoteNodeMessage - Class in org.jppf.server.nio.nodeserver: Representation of a message sent or received by a remote node.
RemoteNodeMessage(BaseNodeContext) - Constructor for class org.jppf.server.nio.nodeserver.RemoteNodeMessage: Initialize this nio message with the specified sll flag.
removalCondition - Variable in class org.jppf.server.protocol.AbstractServerJob: Condition signalled when this job is removed from the queue.
remove() - Method in class org.jppf.server.nio.client.AsyncClientContext.JobEntryDebugStats
REMOVE - Enum constant in enum class org.jppf.server.nio.nodeserver.NodeReservationHandler.Transition: Remove the reservation.
removeAllConnections() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer: Close and remove all connections accepted by this server.
removeAllConnections() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer: Close and remove all connections accepted by this server.
removeAllConnections() - Method in class org.jppf.server.nio.client.AsyncClientNioServer
removeAllConnections() - Method in class org.jppf.server.nio.heartbeat.HeartbeatNioServer
removeAllConnections() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeNioServer
removeBundle(ServerJob) - Method in class org.jppf.server.queue.JPPFPriorityQueue
removeBundle(ServerJob, boolean) - Method in class org.jppf.server.queue.JPPFPriorityQueue: Remove the specified bundle from the queue.
removeCompletionListener(ServerTaskBundleClient.CompletionListener) - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Remove a listener from the list of bundle listeners.
removeConnectionInformation(JPPFConnectionInformation) - Method in class org.jppf.server.peer.PeerDiscoveryThread: Remove a disconnected connection.
removeDriverDiscovery(PeerDriverDiscovery) - Method in class org.jppf.server.JPPFDriver: Remove a custom peer driver discovery mechanism from those already registered.
removeExecutionStatusListener(ExecutorChannelStatusListener) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
removeIdleChannelAsync(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.async.AsyncJobScheduler: Asynchronously remove a channel from the list of idle channels.
removeJobEntry(String, long) - Method in class org.jppf.server.nio.client.AsyncClientContext: Remove the job entry with the specified id.
removeJobEntry(String, long) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Remove the job entry with the specified id.
removeJobListener(JobManagerListener) - Method in interface org.jppf.server.job.JobManager: Remove a listener from the list of listeners.
removeJobListener(JobManagerListener) - Method in class org.jppf.server.queue.JPPFPriorityQueue
removeJobManagerListener(JobManagerListener) - Method in class org.jppf.server.job.JPPFJobManager: Remove a listener from the list of listeners.
removeJobReservations(String) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Remove all the node reservations for the specified job that is being cancelled.
removeJobTasksListener(JobTasksListener) - Method in class org.jppf.server.job.JPPFJobManager: Remove a listener from the list of dispatch listeners.
removeNodeBundle(String, long) - Method in class org.jppf.server.nio.nodeserver.OfflineNodeHandler: Remove the specified node bundle from the map.
removeNodeConnection(String) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassNioServer: Remove the specified uuid entry from the uuid map.
removeNotificationListener(String) - Method in class org.jppf.management.forwarding.ForwardingNotificationManager: Remove the specified notification listener from the map of listeners.
removeNotificationListener(NotificationListener) - Method in class org.jppf.management.JPPFNodeConnectionNotifier
removeNotificationListener(NotificationListener) - Method in class org.jppf.management.JPPFNodeTaskMonitor
removeNotificationListener(NotificationListener) - Method in class org.jppf.server.job.management.DriverJobManagement
removeNotificationListener(NotificationListener, NotificationFilter, Object) - Method in class org.jppf.management.JPPFNodeConnectionNotifier
removeNotificationListener(NotificationListener, NotificationFilter, Object) - Method in class org.jppf.management.JPPFNodeTaskMonitor
removeNotificationListener(NotificationListener, NotificationFilter, Object) - Method in class org.jppf.server.job.management.DriverJobManagement
removeNotificationListener(NotificationListenerWrapper) - Method in class org.jppf.management.forwarding.ForwardingNotificationManager: Remove the specified notification listener from the map of listeners.
removeOnDone(Runnable) - Method in class org.jppf.server.protocol.AbstractServerJob: Deregisters instance to be called on job finish.
removeProviderConnection(String, AsyncClientClassContext) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer: Add a provider connection to the map of existing available providers.
removeProviderConnections(String) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassNioServer: Remove all the provider connections for the specified client uuid.
removeRequest(JPPFResourceWrapper) - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext: Remove the request matching a specified resource.
removeReservation(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler: Remove the job reservation for the specified job, if any.
requestLoad(Collection<PersistenceInfo>) - Method in class org.jppf.job.persistence.PersistedJobsManager
requestResourceCacheReset() - Method in class org.jppf.management.JPPFNodeMaintenance
reset() - Method in class org.jppf.management.JPPFNodeTaskMonitor
resetStatistics() - Method in class org.jppf.management.JPPFDriverAdmin
resetTaskCounter() - Method in class org.jppf.management.JPPFNodeAdmin: Reset the node's executed tasks counter to zero.
resetTaskCounter(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
resetTaskCounter(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
resolveIPs - Variable in class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageHandler: Whether to resolve the nodes' ip addresses into host names.
restart() - Method in class org.jppf.management.JPPFNodeAdmin: Restart the node.
restart(Boolean) - Method in class org.jppf.management.JPPFNodeAdmin
restart(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
restart(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
restart(NodeSelector, Boolean) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
restart(NodeSelector, Boolean) - Method in class org.jppf.management.forwarding.NodeForwarding
restartShutdown(Long, Long) - Method in class org.jppf.management.JPPFDriverAdmin
resubmit() - Method in class org.jppf.server.protocol.ServerTask: Mark this task as to be resubmitted followxing expiration of a node dispatch.
resubmit() - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Called when this task bundle should be resubmitted
resultReceived(Throwable) - Method in class org.jppf.server.protocol.ServerTask: Called to notify that the task received exception during execution.
resultReceived(Collection<ServerTask>) - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Called to notify that the contained task received result.
resultReceived(Collection<ServerTask>, Throwable) - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Called to notify that the task received exception during execution.
resultReceived(DataLocation) - Method in class org.jppf.server.protocol.ServerTask: Called to notify that the task received result.
resultsReceived(Throwable) - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Called to notify that throwable eventually raised while receiving the results.
resultsReceived(List<DataLocation>) - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Called to notify that the results of a number of tasks have been received from the server.
resultsReceived(AsyncNodeContext, AbstractTaskBundleMessage) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageHandler: Called when job results are received from a node.
resultsReceived(ServerTaskBundleNode, Throwable) - Method in class org.jppf.server.protocol.ServerJob: Called to notify that throwable eventually raised while receiving the results.
resultsReceived(ServerTaskBundleNode, Throwable) - Method in class org.jppf.server.protocol.ServerJobBroadcast
resultsReceived(ServerTaskBundleNode, List<DataLocation>) - Method in class org.jppf.server.protocol.ServerJob: Called to notify that the results of a number of tasks have been received from the server.
resultsReceived(ServerTaskBundleNode, List<DataLocation>) - Method in class org.jppf.server.protocol.ServerJobBroadcast
resumeJob(String) - Method in class org.jppf.server.job.management.DriverJobManagement
resumeJobs(JobSelector) - Method in class org.jppf.server.job.management.DriverJobManagement
run() - Method in class org.jppf.server.nio.nodeserver.async.AsyncJobScheduler: Perform the assignment of tasks.
run() - Method in class org.jppf.server.nio.nodeserver.NodeDispatchTimeoutAction
run() - Method in class org.jppf.server.peer.JPPFPeerInitializer
run() - Method in class org.jppf.server.peer.PeerDiscoveryThread: Lookup server configurations from UDP multicasts.

S

selectJobs(JobSelector) - Method in class org.jppf.server.queue.JPPFPriorityQueue: Select the jobs specified by a given job selector.
SendAllResultsStrategy() - Constructor for class org.jppf.server.protocol.SendResultsStrategy.SendAllResultsStrategy
sendHandshakeBundle(AsyncNodeContext, ServerTaskBundleNode) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeMessageHandler: Send a hanshake bundle to a node.
SendNodeResultsStrategy() - Constructor for class org.jppf.server.protocol.SendResultsStrategy.SendNodeResultsStrategy
sendNotification(Notification) - Method in class org.jppf.management.forwarding.AbstractNodeForwarding
sendNotification(Notification) - Method in class org.jppf.server.job.management.DriverJobManagement
sendPeerHandshake(AsyncClientContext) - Method in class org.jppf.server.nio.client.AsyncClientMessageHandler: Called when a peer connection is established.
sendQueue - Variable in class org.jppf.server.nio.classloader.AbstractAsyncClassContext: This queue contains all the result bundles to send back to the node.
sendResponse(JPPFResourceWrapper) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext: Send a response back to the node
sendResults(TaskBundle, List<Task<?>>) - Method in class org.jppf.server.node.local.AsyncLocalNodeIO
sendResults(TaskBundle, List<Task<?>>) - Method in class org.jppf.server.node.remote.RemoteNodeIO
sendResults(ServerTaskBundleClient, Collection<ServerTask>) - Method in class org.jppf.server.protocol.SendResultsStrategy.SendAllResultsStrategy
sendResults(ServerTaskBundleClient, Collection<ServerTask>) - Method in class org.jppf.server.protocol.SendResultsStrategy.SendNodeResultsStrategy
sendResults(ServerTaskBundleClient, Collection<ServerTask>) - Method in interface org.jppf.server.protocol.SendResultsStrategy: Determine whether results should be sent immediately.
SendResultsStrategy - Interface in org.jppf.server.protocol: Strategy to determine whether results should be sent immediately.
SendResultsStrategy.SendAllResultsStrategy - Class in org.jppf.server.protocol: Strategy that sends the results when they have all been received for the client bundle.
SendResultsStrategy.SendNodeResultsStrategy - Class in org.jppf.server.protocol: Strategy that sends the results everytime time they are received from a node.
SendResultsStrategyManager - Class in org.jppf.server.protocol: This class manages the loading and use of strategies for sending results back to the JPPF clients.
SendResultsStrategyManager() - Constructor for class org.jppf.server.protocol.SendResultsStrategyManager
serializeBundle(ServerTaskBundleClient) - Method in class org.jppf.server.nio.client.AsyncClientContext: Serialize specified bundle into a message to send.
serializeBundle(ServerTaskBundleNode) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Serialize specified bundle into a message to send.
serializeResource(JPPFResourceWrapper) - Method in class org.jppf.server.nio.classloader.AbstractAsyncClassContext: Serialize a resource wrapper to an array of bytes.
server - Variable in class org.jppf.server.nio.nodeserver.BaseNodeContext: The server that handles this context.
ServerDebug - Class in org.jppf.server.debug
ServerDebug(JPPFDriver) - Constructor for class org.jppf.server.debug.ServerDebug
ServerDebugMBean - Interface in org.jppf.server.debug
ServerJob - Class in org.jppf.server.protocol: Server-side representation of a job.
ServerJob(Lock, ServerJobChangeListener, TaskBundle, DataLocation) - Constructor for class org.jppf.server.protocol.ServerJob: Initialized client job with task bundle and list of tasks to execute.
ServerJobBroadcast - Class in org.jppf.server.protocol
ServerJobBroadcast(Lock, ServerJobChangeListener, TaskBundle, DataLocation) - Constructor for class org.jppf.server.protocol.ServerJobBroadcast: Initialized broadcast job with task bundle and data provider.
ServerJobBroadcast(Lock, ServerJobChangeListener, TaskBundle, DataLocation, ServerJobBroadcast, String) - Constructor for class org.jppf.server.protocol.ServerJobBroadcast: Initialized broadcast job with task bundle and data provider.
ServerJobChangeListener - Interface in org.jppf.server.protocol: Listener interface for job events.
ServerJobStatus - Enum Class in org.jppf.server.protocol: An enumeration of the possible statuses of a job on the server side.
ServerTask - Class in org.jppf.server.protocol: Representation of an individual task on the server side.
ServerTask(ServerTaskBundleClient, DataLocation, int, int) - Constructor for class org.jppf.server.protocol.ServerTask
ServerTaskBundleClient - Class in org.jppf.server.protocol: Instances of this class group tasks from the same client channel together.
ServerTaskBundleClient(Collection<ServerTask>, TaskBundle, DataLocation) - Constructor for class org.jppf.server.protocol.ServerTaskBundleClient: Initialize this task bundle and set its build number.
ServerTaskBundleClient(TaskBundle, DataLocation, List<DataLocation>, boolean) - Constructor for class org.jppf.server.protocol.ServerTaskBundleClient: Initialize this task bundle and set its build number.
ServerTaskBundleClient.CompletionListener - Interface in org.jppf.server.protocol: Listener providing a callback to invoke when a task's execution has completed.
ServerTaskBundleNode - Class in org.jppf.server.protocol: Instances of this class group tasks for the same node channel together.
ServerTaskBundleNode(ServerJob, TaskBundle, Collection<ServerTask>) - Constructor for class org.jppf.server.protocol.ServerTaskBundleNode: Initialize this task bundle and set its build number.
setAcceptingNewJobs(boolean) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
setActive(boolean) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
setActiveState(NodeSelector, boolean) - Method in class org.jppf.management.JPPFDriverAdmin
setBroadcasting(boolean) - Method in class org.jppf.management.JPPFDriverAdmin
setBundle(TaskBundle) - Method in class org.jppf.server.nio.AbstractTaskBundleMessage: Set the latest bundle that was sent or received.
setBundle(ServerTaskBundleClient) - Method in class org.jppf.server.protocol.ServerTask: Get the client bundle that owns this task.
setBundler(Bundler<?>) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
setBundlerAlgorithm(String) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
setCacheContent(String, String, byte[]) - Method in class org.jppf.server.nio.classloader.ClassCache: Add a resource content to the class cache.
setCallableAllConnections(Callable<List<BaseNodeContext>>) - Method in class org.jppf.server.queue.JPPFPriorityQueue: Set the callable source for all available connections.
setCancelled(boolean) - Method in class org.jppf.server.protocol.AbstractServerJob: Cancels this job.
setChannel(ExecutorChannel<?>) - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Set the node channel onto this job dispatch.
setDelegationModel(DelegationModel) - Method in class org.jppf.management.JPPFNodeAdmin
setDelegationModel(NodeSelector, DelegationModel) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
setDelegationModel(NodeSelector, DelegationModel) - Method in class org.jppf.management.forwarding.NodeForwarding
setDependencies(List<DataLocation>, TaskGraphInfo) - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Set the dependencies of the tasks in this bundle.
setExecutionStatus(ExecutorStatus) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Set the execution status for the node.
setJmxConnection(JMXNodeConnectionWrapper) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Set the connection to the node's JMX server.
setJobReceivedTime(long) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the job received time.
setJobReceivedTime(long) - Method in class org.jppf.server.protocol.ServerTaskBundleClient: Set the job received time.
setJobReturnReason(JobReturnReason) - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Set the reason why the task results are reeived.
setLocalRequest(JPPFResourceWrapper) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext
setLocalResponse(JPPFResourceWrapper) - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext
setManagementInfo(JPPFManagementInfo) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Set the management information for the node.
setMaxJobs(int) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Set the maximum number of concurrent jobs for this channel.
setMaxNodes(int) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the maximum number of nodes this job can run on.
setMetadata(JobMetadata) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the job metadata.
setName(String) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the user-defined display name for this job.
setNodeConnection(RemoteNodeConnection) - Method in class org.jppf.server.node.remote.JPPFRemoteContainer: The node connection wrapper.
setNodeIdentifier(Pair<String, String>) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
setNodeInfo(JPPFSystemInformation, boolean) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Set the node system information.
setOffline(boolean) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Specify whether the node works in offline mode.
setOffline(boolean) - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Set the offline node indicator.
setOnRequeue(Runnable) - Method in class org.jppf.server.protocol.AbstractServerJobBase: Set the requeue handler.
setPeerDriver(PeerDriver) - Method in class org.jppf.server.JPPFDriver
setPeerJmxConnection(JMXDriverConnectionWrapper) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext: Set the connection to the peer driver's JMX server.
setPending(boolean) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the job pending indicator.
setQueueEntryTime(long) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the time at which this wrapper was added to the queue.
setRequestStartTime(long) - Method in class org.jppf.server.nio.classloader.AsyncResourceRequest: Set the time at which this request was submitted.
setReservationScore(int) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
setReservationTansition(NodeReservationHandler.Transition) - Method in class org.jppf.server.nio.nodeserver.BaseNodeContext
setResource(JPPFResourceWrapper) - Method in class org.jppf.server.nio.classloader.AsyncResourceRequest: Set the resource to lookup in the client.
setResult(DataLocation) - Method in class org.jppf.server.protocol.ServerTask: Set the result of the task execution.
setReturnedFromNode(boolean) - Method in class org.jppf.server.protocol.ServerTask: Set whether this task has returned from the node
setSize(int) - Method in class org.jppf.server.peer.PeerConnectionPool: Set the size of this pool.
setSLA(JobSLA) - Method in class org.jppf.server.protocol.AbstractServerJob: Get the service level agreement between the job and the server.
setSLA(JobSLA) - Method in class org.jppf.server.protocol.ServerJobBroadcast
setState(TaskState) - Method in class org.jppf.server.protocol.ServerTask: Set the state of this task.
setSubmissionStatus(SubmissionStatus) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the status of this submission.
setSuspended(boolean, boolean) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the job suspended indicator.
setTaskCounter(Integer) - Method in class org.jppf.management.JPPFNodeAdmin: Set the node's executed tasks counter to the specified value.
setTaskCounter(NodeSelector, Integer) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
setTaskCounter(NodeSelector, Integer) - Method in class org.jppf.management.forwarding.NodeForwarding
setUuid(String) - Method in class org.jppf.server.protocol.AbstractServerJob: Set the universal unique id for this job.
showResults() - Static method in class org.jppf.server.debug.DebugHelper: Show all the mapped results.
showResultsMap() - Method in class org.jppf.server.debug.ServerDebug
showResultsMap() - Method in interface org.jppf.server.debug.ServerDebugMBean: Show the multimap of job uuids to the positions of tasks that have completed.
shutdown() - Method in class org.jppf.management.JPPFNodeAdmin: Shutdown the node.
shutdown() - Method in class org.jppf.server.JPPFDriver: Shutdown this driver and all its components.
shutdown(Boolean) - Method in class org.jppf.management.JPPFNodeAdmin
shutdown(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
shutdown(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
shutdown(NodeSelector, Boolean) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
shutdown(NodeSelector, Boolean) - Method in class org.jppf.management.forwarding.NodeForwarding
start() - Method in class org.jppf.server.JPPFDriver: Initialize and start this driver.
start() - Method in class org.jppf.server.peer.JPPFPeerInitializer: Start a thread running this initializer.
startProf() - Static method in class org.jppf.server.debug.ServerDebug: Trigger method for the profiler to start profiling.
startProfiling() - Method in class org.jppf.server.debug.ServerDebug
startProfiling() - Method in interface org.jppf.server.debug.ServerDebugMBean: Trigger method for the profiler to start profiling.
state() - Method in class org.jppf.management.JPPFNodeAdmin: Get the latest state information from the node.
state(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
state(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
statistics() - Method in class org.jppf.management.JPPFDriverAdmin
status - Variable in class org.jppf.server.protocol.AbstractServerJob: The job status.
stopBroadcaster() - Method in class org.jppf.server.DriverInitializer: Stop the discovery service if it is running.
storeResults(ServerJob, Collection<ServerTask>) - Method in class org.jppf.server.queue.PersistenceHandler: Store the specified job results.
submissionStatus - Variable in class org.jppf.server.protocol.AbstractServerJob: The status of this submission.
SubmissionStatus - Enum Class in org.jppf.server.submission: The status of a submission.
submit(ServerTaskBundleNode) - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
SUBMITTED - Enum constant in enum class org.jppf.server.submission.SubmissionStatus: The job was just submitted.
suspendJob(String, Boolean) - Method in class org.jppf.server.job.management.DriverJobManagement
suspendJobs(JobSelector, Boolean) - Method in class org.jppf.server.job.management.DriverJobManagement
systemInformation() - Method in class org.jppf.management.JPPFDriverAdmin
systemInformation() - Method in class org.jppf.management.JPPFNodeAdmin: Get detailed information about the node's JVM properties, environment variables and runtime information such as memory usage and available processors.
systemInformation(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
systemInformation(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding

T

takeNextMessageToSend() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext: Take a message from the pending queue, waiting if necessary.
taskCompleted(Throwable) - Method in class org.jppf.server.protocol.ServerTaskBundleNode: Called to notify that the execution of a task has completed.
taskCompleted(ServerJob) - Method in interface org.jppf.server.protocol.TaskCompletionListener: Callback method invoked when the execution of a task has completed.
taskCompleted(ServerTaskBundleClient, List<ServerTask>) - Method in class org.jppf.server.nio.client.CompletionListener
taskCompleted(ServerTaskBundleClient, List<ServerTask>) - Method in class org.jppf.server.protocol.BundleCompletionListener
taskCompleted(ServerTaskBundleClient, List<ServerTask>) - Method in interface org.jppf.server.protocol.ServerTaskBundleClient.CompletionListener: Callback method invoked when the execution of the bundle has completed.
taskCompleted(ServerTaskBundleNode, Throwable) - Method in class org.jppf.server.protocol.ServerJob: Called to notify that the execution of a task has completed.
TaskCompletionListener - Interface in org.jppf.server.protocol: Listener providing a callback to invoke when a task's execution has completed.
taskExecuted(TaskExecutionEvent) - Method in class org.jppf.management.JPPFNodeTaskMonitor
taskNotification(TaskExecutionEvent) - Method in class org.jppf.management.JPPFNodeTaskMonitor
taskQueueCheckerChannels() - Method in class org.jppf.server.debug.ServerDebug
taskQueueCheckerChannels() - Method in interface org.jppf.server.debug.ServerDebugMBean: View all idle channels held by the org.jppf.server.nio.nodeserver.TaskQueueChecker.
tasks - Variable in class org.jppf.server.protocol.AbstractServerJobBase: The list of the tasks.
threadDump(NodeSelector) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
threadDump(NodeSelector) - Method in class org.jppf.management.forwarding.NodeForwarding
toggleActiveState(NodeSelector) - Method in class org.jppf.management.JPPFDriverAdmin
toString() - Method in class org.jppf.server.nio.AbstractTaskBundleMessage
toString() - Method in class org.jppf.server.nio.classloader.AsyncResourceRequest
toString() - Method in class org.jppf.server.nio.classloader.CacheClassKey
toString() - Method in class org.jppf.server.nio.classloader.client.AsyncClientClassContext
toString() - Method in class org.jppf.server.nio.classloader.node.AsyncNodeClassContext
toString() - Method in class org.jppf.server.nio.client.AsyncClientContext.JobEntryDebugStats
toString() - Method in class org.jppf.server.nio.client.AsyncClientContext
toString() - Method in class org.jppf.server.nio.client.ClientMessage
toString() - Method in class org.jppf.server.nio.client.JobEntry
toString() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
toString() - Method in class org.jppf.server.nio.nodeserver.RemoteNodeMessage
toString() - Method in class org.jppf.server.peer.PeerConnectionPool
toString() - Method in class org.jppf.server.protocol.AbstractServerJobBase
toString() - Method in class org.jppf.server.protocol.ServerTask
toString() - Method in class org.jppf.server.protocol.ServerTaskBundleClient
toString() - Method in class org.jppf.server.protocol.ServerTaskBundleNode
totalDispatches - Variable in class org.jppf.server.protocol.AbstractServerJobBase: Total number of dispatches in this job.
transitionReservation(BaseNodeContext) - Method in class org.jppf.server.nio.nodeserver.NodeReservationHandler

U

unregisterForwardingNotificationListener(String) - Method in class org.jppf.management.forwarding.AbstractNodeForwarding: Unregister the specified listener.
update(JPPFDriver, JobSLA, JobMetadata) - Method in class org.jppf.server.protocol.ServerJob: Update this job with the specified sla and metadata.
updateConfiguration(Map<Object, Object>, Boolean) - Method in class org.jppf.management.JPPFNodeAdmin: Update the configuration properties of the node.
updateConfiguration(Map<Object, Object>, Boolean, Boolean) - Method in class org.jppf.management.JPPFNodeAdmin: Update the configuration properties of the node.
updateConfiguration(NodeSelector, Map<Object, Object>, Boolean) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
updateConfiguration(NodeSelector, Map<Object, Object>, Boolean) - Method in class org.jppf.management.forwarding.NodeForwarding
updateConfiguration(NodeSelector, Map<Object, Object>, Boolean, Boolean) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
updateConfiguration(NodeSelector, Map<Object, Object>, Boolean, Boolean) - Method in class org.jppf.management.forwarding.NodeForwarding
updateJobDataLocation() - Method in class org.jppf.server.protocol.AbstractServerJob: Serialize the updated job header and cache the resulting serialized representation.
updateJobHeader(ServerJob) - Method in class org.jppf.server.queue.PersistenceHandler: Store the specified job upon initial queuing.
updateJobs(JobSelector, JobSLA, JobMetadata) - Method in class org.jppf.server.job.management.DriverJobManagement
updateMaxNodes(String, Integer) - Method in class org.jppf.server.job.management.DriverJobManagement
updateMaxNodes(JobSelector, Integer) - Method in class org.jppf.server.job.management.DriverJobManagement
updatePriority(String, int) - Method in interface org.jppf.server.job.JobManager: Update the priority of the job with the specified uuid.
updatePriority(String, int) - Method in class org.jppf.server.queue.JPPFPriorityQueue
updatePriority(String, Integer) - Method in class org.jppf.server.job.management.DriverJobManagement
updatePriority(JobSelector, Integer) - Method in class org.jppf.server.job.management.DriverJobManagement
updateSchedules(ServerJob) - Method in class org.jppf.server.queue.JPPFPriorityQueue: Update the start and expiration schedules of an existing job.
updateStatus(ServerJobStatus, ServerJobStatus) - Method in class org.jppf.server.protocol.AbstractServerJob: Updates status to new value if old value is equal to expect.
updateThreadPoolSize(Integer) - Method in class org.jppf.management.JPPFNodeAdmin: Set the size of the node's thread pool.
updateThreadPoolSize(NodeSelector, Integer) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
updateThreadPoolSize(NodeSelector, Integer) - Method in class org.jppf.management.forwarding.NodeForwarding
updateThreadsPriority(Integer) - Method in class org.jppf.management.JPPFNodeAdmin: Update the priority of all execution threads.
updateThreadsPriority(NodeSelector, Integer) - Method in class org.jppf.management.forwarding.JPPFNodeForwarding: Deprecated.
updateThreadsPriority(NodeSelector, Integer) - Method in class org.jppf.management.forwarding.NodeForwarding
updateWorkingConnections(ExecutorStatus, ExecutorStatus) - Method in class org.jppf.server.queue.JPPFPriorityQueue: Update count of working connections base on status change.
uuid - Variable in class org.jppf.server.protocol.AbstractServerJob: The universal unique id for this job.

V

VALUE_JPPF_DISCOVERY - Static variable in class org.jppf.server.DriverInitializer: Constant for JPPF automatic connection discovery
valueOf(String) - Static method in enum class org.jppf.server.nio.nodeserver.NodeReservationHandler.Transition: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jppf.server.protocol.ServerJobStatus: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.jppf.server.submission.SubmissionStatus: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.jppf.server.nio.nodeserver.NodeReservationHandler.Transition: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jppf.server.protocol.ServerJobStatus: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.jppf.server.submission.SubmissionStatus: Returns an array containing the constants of this enum class, in the order they are declared.

W

write() - Method in class org.jppf.server.nio.nodeserver.LocalNodeMessage
writeMessage() - Method in class org.jppf.server.nio.classloader.AbstractAsyncClassContext
writeMessage() - Method in class org.jppf.server.nio.client.AsyncClientContext
writeMessage() - Method in class org.jppf.server.nio.nodeserver.async.AsyncNodeContext
writeNextObject() - Method in class org.jppf.server.nio.nodeserver.LocalNodeMessage

A B C D E F G H I J K L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form