org.griphyn.cPlanner.code
Interface CodeGenerator

All Known Implementing Classes:

Abstract

public interface CodeGenerator

The interface that allows us to plug in various code generators for writing out the concrete plan. Each of Code Generators are dependant upon the underlying workflow executors being used. A Code Generator implementation generates the concrete plan in the input format of the underlying Workflow Executor. The appropriate format can be condor submit files, or some XML description.

Version:

$Revision: 1.1 $

Author:

Karan Vahi, Gaurang Mehta

Field Summary

static String

VERSION The version number associated with this API of Code Generator.

Method Summary

void	generateCode(ADag dag) Generates the code for the concrete workflow in the input format of the workflow executor being used.
void	generateCode(ADag dag, SubInfo job) Generates the code for a single job in the input format of the workflow executor being used.
void	initialize(PegasusProperties properties, String directory, PlannerOptions options) Initializes the Code Generator implementation.
void	reset() Resets the Code Generator implementation.
boolean	startMonitoring() Starts monitoring of the workflow by invoking a workflow monitor daemon.

Field Detail

VERSION

public static final String VERSION

The version number associated with this API of Code Generator.

See Also:

Constant Field Values

Method Detail

initialize

public void initialize(PegasusProperties properties,
                       String directory,
                       PlannerOptions options)
                throws CodeGeneratorException

Initializes the Code Generator implementation.

Parameters:

properties - the PegasusProperties object containing all the properties required by Pegasus.

directory - the base directory where the generated code should reside.

options - the options passed to the planner at runtime.

Throws:

CodeGeneratorException - in case of any error occuring code generation.

generateCode

public void generateCode(ADag dag)
                  throws CodeGeneratorException

Generates the code for the concrete workflow in the input format of the workflow executor being used.

Parameters:

dag - the concrete workflow.

Throws:

CodeGeneratorException - in case of any error occuring code generation.

generateCode

public void generateCode(ADag dag,
                         SubInfo job)
                  throws CodeGeneratorException

Generates the code for a single job in the input format of the workflow executor being used.

Parameters:

dag - the dag of which the job is a part of.

job - the SubInfo object holding the information about that particular job.

Throws:

CodeGeneratorException - in case of any error occuring code generation.

startMonitoring

public boolean startMonitoring()

Starts monitoring of the workflow by invoking a workflow monitor daemon. The monitoring should start only after the output files have been generated. FIXME: It should actually happen after the workflow has been submitted. Eventually should be a separate monitor interface, and submit writers should be loaded by an AbstractFactory.

Returns:

boolean indicating whether could successfully start the monitor daemon or not.

reset

public void reset()
           throws CodeGeneratorException

Resets the Code Generator implementation.

Throws:

CodeGeneratorException - in case of any error occuring code generation.