Uses of Class
org.jppf.server.protocol.ServerTaskBundleNode
Packages that use ServerTaskBundleNode
Package
Description
Support for job management in the server.
Classes supporting the server node-side of the JPPF asynchronous communication model.
Classes supporting the server node-side of the JPPF asynchronous communication model.
Classes supporting the data transported between components of the communication model.
Support for job queuing in the JPPF driver.
-
Uses of ServerTaskBundleNode in org.jppf.server.job
Methods in org.jppf.server.job with parameters of type ServerTaskBundleNodeModifier and TypeMethodDescriptionvoidJPPFJobManager.jobDispatched(AbstractServerJob serverJob, org.jppf.execute.ExecutorChannel<?> channel, ServerTaskBundleNode nodeBundle) voidJPPFJobManager.jobReturned(AbstractServerJob serverJob, org.jppf.execute.ExecutorChannel<?> channel, ServerTaskBundleNode nodeBundle) -
Uses of ServerTaskBundleNode in org.jppf.server.nio.nodeserver
Methods in org.jppf.server.nio.nodeserver that return ServerTaskBundleNodeModifier and TypeMethodDescriptionOfflineNodeHandler.removeNodeBundle(String jobUuid, long bundleId) Remove the specified node bundle from the map.Methods in org.jppf.server.nio.nodeserver with parameters of type ServerTaskBundleNodeModifier and TypeMethodDescriptionvoidOfflineNodeHandler.addNodeBundle(ServerTaskBundleNode nodeBundle) Add the specified node bundle to the map.Constructors in org.jppf.server.nio.nodeserver with parameters of type ServerTaskBundleNodeModifierConstructorDescriptionNodeDispatchTimeoutAction(OfflineNodeHandler server, ServerTaskBundleNode nodeBundle, BaseNodeContext context) Initialize this action with the specified server and nodBundle. -
Uses of ServerTaskBundleNode in org.jppf.server.nio.nodeserver.async
Methods in org.jppf.server.nio.nodeserver.async that return ServerTaskBundleNodeModifier and TypeMethodDescriptionAsyncNodeNioServer.getHandshakeBundle()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.AsyncNodeContext.getJobEntry(String uuid, long bundleId) Retrieve the job entry with the specified id.AsyncNodeContext.removeJobEntry(String uuid, long bundleId) Remove the job entry with the specified id.Methods in org.jppf.server.nio.nodeserver.async with parameters of type ServerTaskBundleNodeModifier and TypeMethodDescriptionvoidAsyncNodeContext.addJobEntry(ServerTaskBundleNode bundle) Add a new job to the job map.voidAsyncNodeMessageHandler.sendHandshakeBundle(AsyncNodeContext context, ServerTaskBundleNode bundle) Send a hanshake bundle to a node.AsyncNodeContext.serializeBundle(ServerTaskBundleNode bundle) Serialize specified bundle into a message to send.Future<?>AsyncNodeContext.submit(ServerTaskBundleNode nodeBundle) Constructors in org.jppf.server.nio.nodeserver.async with parameters of type ServerTaskBundleNodeModifierConstructorDescriptionAsyncNodeContextFuture(AsyncNodeContext context, ServerTaskBundleNode bundle) Initialize with the specified runnable and result object. -
Uses of ServerTaskBundleNode in org.jppf.server.protocol
Fields in org.jppf.server.protocol with type parameters of type ServerTaskBundleNodeModifier and TypeFieldDescriptionprotected final Map<Long,ServerTaskBundleNode> AbstractServerJobBase.dispatchSetSet of all dispatched bundles in this job.Methods in org.jppf.server.protocol that return ServerTaskBundleNodeModifier and TypeMethodDescriptionServerJob.createNodeDispatch(int nbTasks) Make a copy of this client job wrapper containing only the first nbTasks tasks it contains.AbstractServerJobBase.getNodeBundle(long id) Get the node bundle with the specified id from the dispatch set.Methods in org.jppf.server.protocol that return types with arguments of type ServerTaskBundleNodeMethods in org.jppf.server.protocol with parameters of type ServerTaskBundleNodeModifier and TypeMethodDescriptionvoidServerJob.cancelDispatch(ServerTaskBundleNode nodeBundle) Cancel the specified job dispatch.protected voidAbstractServerJob.fireJobDispatched(org.jppf.execute.ExecutorChannel<?> channel, ServerTaskBundleNode bundleNode) A sub-job was dispatched to a node.protected voidAbstractServerJob.fireJobReturned(org.jppf.execute.ExecutorChannel<?> channel, ServerTaskBundleNode bundleNode) A sub-job returned from a node.voidAbstractServerJobBase.jobDispatched(ServerTaskBundleNode bundle) Called when all or part of a job is dispatched to a node.voidServerJobBroadcast.jobDispatched(ServerTaskBundleNode bundle) voidServerJobChangeListener.jobDispatched(AbstractServerJob source, org.jppf.execute.ExecutorChannel<?> channel, ServerTaskBundleNode bundleNode) Called when all or part of a job is dispatched to a node.voidAbstractServerJobBase.jobReturned(ServerTaskBundleNode bundle) Called when all or part of a job is returned from node.voidServerJobChangeListener.jobReturned(AbstractServerJob source, org.jppf.execute.ExecutorChannel<?> channel, ServerTaskBundleNode bundleNode) Called when all or part of a job has returned from a node.static StringServerTaskBundleNode.makeKey(ServerTaskBundleNode bundle) Build a unique key for the specified node task bundle.voidServerJob.resultsReceived(ServerTaskBundleNode bundle, Throwable throwable) Called to notify that throwable eventually raised while receiving the results.voidServerJob.resultsReceived(ServerTaskBundleNode bundle, List<org.jppf.io.DataLocation> results) Called to notify that the results of a number of tasks have been received from the server.voidServerJobBroadcast.resultsReceived(ServerTaskBundleNode bundle, Throwable throwable) voidServerJobBroadcast.resultsReceived(ServerTaskBundleNode bundle, List<org.jppf.io.DataLocation> results) voidServerJob.taskCompleted(ServerTaskBundleNode bundle, Throwable throwable) Called to notify that the execution of a task has completed. -
Uses of ServerTaskBundleNode in org.jppf.server.queue
Methods in org.jppf.server.queue that return ServerTaskBundleNodeModifier and TypeMethodDescriptionJPPFPriorityQueue.nextBundle(ServerJob serverJob, int nbTasks, org.jppf.execute.ExecutorChannel<ServerTaskBundleNode> channel) Method parameters in org.jppf.server.queue with type arguments of type ServerTaskBundleNodeModifier and TypeMethodDescriptionJPPFPriorityQueue.nextBundle(ServerJob serverJob, int nbTasks, org.jppf.execute.ExecutorChannel<ServerTaskBundleNode> channel)