Uses of Class
org.jppf.server.protocol.ServerJob
Packages that use ServerJob
Package
Description
Support for job management in the server.
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 ServerJob in org.jppf.server.job
Methods in org.jppf.server.job that return ServerJobModifier and TypeMethodDescriptionJobManager.getBundleForJob(String jobUuid) Get the job for the job unique identifier.Methods in org.jppf.server.job with parameters of type ServerJobModifier and TypeMethodDescriptionvoidCalled when a job is complete and returned to the client.voidCalled when a job is added to the server queue.voidJPPFJobManager.jobResultsReceived(org.jppf.execute.ExecutorChannel<?> channel, ServerJob job, Collection<ServerTask> tasks) Called when final tasks results have been received and are about to be sent back to the client. -
Uses of ServerJob in org.jppf.server.nio.nodeserver
Methods in org.jppf.server.nio.nodeserver with parameters of type ServerJobModifier and TypeMethodDescriptionvoidNodeReservationHandler.doReservation(ServerJob job, BaseNodeContext node) Reserve the specified node for the specified job.voidNodeReservationHandler.onJobCancelled(ServerJob job) Remove all the node reservations for the specified job that is being cancelled. -
Uses of ServerJob in org.jppf.server.protocol
Subclasses of ServerJob in org.jppf.server.protocolMethods in org.jppf.server.protocol that return ServerJobModifier and TypeMethodDescriptionServerTaskBundleNode.getClientJob()Get the client job this submission is forServerTaskBundleNode.getServerJob()Get the job this node bundle is a dispatch of.Methods in org.jppf.server.protocol with parameters of type ServerJobModifier and TypeMethodDescriptionvoidTaskCompletionListener.taskCompleted(ServerJob result) Callback method invoked when the execution of a task has completed.Constructors in org.jppf.server.protocol with parameters of type ServerJobModifierConstructorDescriptionServerTaskBundleNode(ServerJob job, org.jppf.node.protocol.TaskBundle taskBundle, Collection<ServerTask> taskList) Initialize this task bundle and set its build number. -
Uses of ServerJob in org.jppf.server.queue
Methods in org.jppf.server.queue that return ServerJobModifier and TypeMethodDescriptionJPPFPriorityQueue.addBundle(ServerTaskBundleClient clientBundle) JPPFPriorityQueue.getBundleForJob(String jobUuid) Get the job for the jobId.JPPFPriorityQueue.getJobFromPriorityMap(String jobId) Get the job for the jobId.JPPFPriorityQueue.removeBundle(ServerJob serverJob) JPPFPriorityQueue.removeBundle(ServerJob serverJob, boolean removeFromJobMap) Remove the specified bundle from the queue.Methods in org.jppf.server.queue that return types with arguments of type ServerJobModifier and TypeMethodDescriptionJPPFPriorityQueue.getAllJobs()Get the set of all the jobs currently queued or executing.JPPFPriorityQueue.getAllJobsFromPriorityMap()Get all the jobs in the queue, ordered by priority.JPPFPriorityQueue.selectJobs(org.jppf.job.JobSelector selector) Select the jobs specified by a given job selector.Methods in org.jppf.server.queue with parameters of type ServerJobModifier and TypeMethodDescriptionintprotected intvoidJobDependenciesHandler.jobCancelled(ServerJob job) Called when a job with dependencies is cancelled.voidCalled when a job ends and is removed from the client or server queue.booleanCalled when a job with dependencies arrives in the client or server queue.JPPFPriorityQueue.nextBundle(ServerJob serverJob, int nbTasks, org.jppf.execute.ExecutorChannel<ServerTaskBundleNode> channel) JPPFPriorityQueue.removeBundle(ServerJob serverJob) JPPFPriorityQueue.removeBundle(ServerJob serverJob, boolean removeFromJobMap) Remove the specified bundle from the queue.voidPersistenceHandler.storeResults(ServerJob job, Collection<ServerTask> tasks) Store the specified job results.voidPersistenceHandler.updateJobHeader(ServerJob job) Store the specified job upon initial queuing.voidJPPFPriorityQueue.updateSchedules(ServerJob job) Update the start and expiration schedules of an existing job.