org.jppf.server.protocol

Class ServerTaskBundleNode

java.lang.Object

org.jppf.server.protocol.ServerTaskBundleNode

public class ServerTaskBundleNode
extends Object

Instances of this class group tasks for the same node channel together.

Constructor Summary

Constructors

Constructor and Description
ServerTaskBundleNode(ServerJob job, JPPFTaskBundle taskBundle, List taskList) Initialize this task bundle and set its build number.

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel() Called when this task bundle is cancelled.
void	checkTaskCount() Check the task count in this node bundle is equal to the one in its JPPFTaskBundle.
ExecutorChannel	getChannel() Get the channel to which the job is dispatched.
ServerJob	getClientJob() Get the client job this submission is for
DataLocation	getDataProviderL() Get shared data provider for this task.
Future<?>	getFuture() Get the future corresponding to the channel dispatch.
JPPFTaskBundle	getJob() Get the job this submission is for.
int	getTaskCount() Get the number of tasks in this node bundle.
List	getTaskList() Get the tasks to be executed by the node.
boolean	isCancelled() Get the cancelled indicator.
boolean	isRequeued() Get the requeued indicator.
void	jobDispatched(ExecutorChannel channel, Future<?> future) Called when all or part of a job is dispatched to a node.
void	resubmit() Called when this task bundle should be resubmitted
void	resultsReceived(List results) Called to notify that the results of a number of tasks have been received from the server.
void	resultsReceived(Throwable throwable) Called to notify that throwable eventually raised while receiving the results.
void	taskCompleted(Exception exception) Called to notify that the execution of a task has completed.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ServerTaskBundleNode

public ServerTaskBundleNode(ServerJob job,
                    JPPFTaskBundle taskBundle,
                    List taskList)

Initialize this task bundle and set its build number.

Parameters:

job - the job to execute.

taskBundle - the job.

taskList - the tasks to execute.

Method Detail

getJob

public JPPFTaskBundle getJob()

Get the job this submission is for.

Returns:

a JPPFTaskBundle instance.

getClientJob

public ServerJob getClientJob()

Get the client job this submission is for

Returns:

a ServerJob instance.

getDataProviderL

public DataLocation getDataProviderL()

Get shared data provider for this task.

Returns:

a DataProvider instance.

getTaskList

public List getTaskList()

Get the tasks to be executed by the node.

Returns:

the tasks as a List of arrays of bytes.

jobDispatched

public void jobDispatched(ExecutorChannel channel,
                 Future<?> future)

Called when all or part of a job is dispatched to a node.

Parameters:

channel - the node to which the job is dispatched.

future - future assigned to bundle execution.

resultsReceived

public void resultsReceived(List results)

Called to notify that the results of a number of tasks have been received from the server.

Parameters:

results - the list of tasks whose results have been received from the server.

resultsReceived

public void resultsReceived(Throwable throwable)

Called to notify that throwable eventually raised while receiving the results.

Parameters:

throwable - the throwable that was raised while receiving the results.

taskCompleted

public void taskCompleted(Exception exception)

Called to notify that the execution of a task has completed.

Parameters:

exception - the Exception thrown during job execution or null.

resubmit

public void resubmit()

Called when this task bundle should be resubmitted

isRequeued

public boolean isRequeued()

Get the requeued indicator.

Returns:

true if job is requeued, false otherwise.

cancel

public void cancel()

Called when this task bundle is cancelled.

isCancelled

public boolean isCancelled()

Get the cancelled indicator.

Returns:

true if job is cancelled, false otherwise.

getChannel

public ExecutorChannel getChannel()

Get the channel to which the job is dispatched.

Returns:

an ExecutorChannel instance.

getFuture

public Future<?> getFuture()

Get the future corresponding to the channel dispatch.

Returns:

a Future instance.

checkTaskCount

public void checkTaskCount()

Check the task count in this node bundle is equal to the one in its JPPFTaskBundle.

getTaskCount

public int getTaskCount()

Get the number of tasks in this node bundle.

Returns:

the number of tasks as an int.

toString

public String toString()

Overrides:

toString in class Object