org.trianacode.enactment

Class TrianaRun

java.lang.Object

org.trianacode.enactment.TrianaRun

public class TrianaRun
extends java.lang.Object

A class for running a taskgraph. Unlike TrianaExec, TrianaRun does not handle synchronuizing between multiple invocations.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.trianacode.enactment.TrianaRun.ExecCable[]	incables
protected org.trianacode.enactment.TrianaRun.ExecCable[]	outcables
protected Scheduler	scheduler
protected org.trianacode.enactment.TrianaRun.ExecServer	server
protected Task	task
protected TaskGraph	taskgraph

Constructor Summary

Constructors

Constructor and Description
TrianaRun(TaskGraph taskgraph) Constructs a TrianaExec to execute a clone of the specified taskgraph.
TrianaRun(Tool tool) Constructs a TrianaExec to execute a clone of the specified tool.

Method Summary

Methods

Modifier and Type	Method and Description
void	dispose() Clean up after a run execution.
java.lang.String	getDummyToolName()
int	getInputNodeCount()
int	getOutputNodeCount()
SchedulerInterface	getScheduler()
Task	getTask()
TaskGraph	getTaskGraph()
protected void	init(Tool tool) Initializes the triana exec
boolean	isDataSent(int count)
boolean	isFinished()
boolean	isOutputReady()
boolean	isOutputReady(int count)
java.lang.Object	receiveOutputData(int count)
java.lang.Object	receiveOutputData(int count, boolean unpack)
void	runTaskGraph() Runs the unconnected tasks with the taskgraph
void	sendInputData(int count, java.lang.Object obj) Sends output data using the specified input node
void	setDummyToolName(java.lang.String dummyname) Sets the dummy tool name
protected java.lang.Object	unpackResult(java.lang.Object result)

Methods inherited from class java.lang.Object

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

Field Detail

task

protected Task task

taskgraph

protected TaskGraph taskgraph

server

protected org.trianacode.enactment.TrianaRun.ExecServer server

scheduler

protected Scheduler scheduler

incables

protected org.trianacode.enactment.TrianaRun.ExecCable[] incables

outcables

protected org.trianacode.enactment.TrianaRun.ExecCable[] outcables

Constructor Detail

TrianaRun

public TrianaRun(TaskGraph taskgraph)
          throws TaskGraphException

Constructs a TrianaExec to execute a clone of the specified taskgraph. Uses a default tool table

Throws:

TaskGraphException

TrianaRun

public TrianaRun(Tool tool)
          throws TaskGraphException

Constructs a TrianaExec to execute a clone of the specified tool. Uses a default tool table.

Throws:

TaskGraphException

Method Detail

getScheduler

public SchedulerInterface getScheduler()

init

protected void init(Tool tool)
             throws TaskGraphException

Initializes the triana exec

Throws:

TaskGraphException

getTaskGraph

public TaskGraph getTaskGraph()

Returns:

the taskgraph that is being executed. If a single task was executed then this returns that task wrapped in a simple taskgraph.

getTask

public Task getTask()

Returns:

the task that is being executed.

getDummyToolName

public java.lang.String getDummyToolName()

Returns:

the dummy tool name

setDummyToolName

public void setDummyToolName(java.lang.String dummyname)

Sets the dummy tool name

runTaskGraph

public void runTaskGraph()
                  throws SchedulerException

Runs the unconnected tasks with the taskgraph

Throws:

SchedulerException

isFinished

public boolean isFinished()

Returns:

true if the taskgraph has finished executing

getInputNodeCount

public int getInputNodeCount()

Returns:

the number of input nodes

isDataSent

public boolean isDataSent(int count)

Returns:

true if the input data on the specified node is successfully sent

sendInputData

public void sendInputData(int count,
                 java.lang.Object obj)

Sends output data using the specified input node

getOutputNodeCount

public int getOutputNodeCount()

Returns:

the number of output nodes

isOutputReady

public boolean isOutputReady(int count)

Returns:

true if data is ready at the specified output node

receiveOutputData

public java.lang.Object receiveOutputData(int count)

Returns:

the data at the specified output node, automatically unpacking it from any data message.

receiveOutputData

public java.lang.Object receiveOutputData(int count,
                                 boolean unpack)

Returns:

the data at the specified output node, optionally unpacking it from any data message.

isOutputReady

public boolean isOutputReady()

Returns:

true if data is ready at every output node

unpackResult

protected java.lang.Object unpackResult(java.lang.Object result)

dispose

public void dispose()

Clean up after a run execution.