edu.isi.pegasus.planner.classes
Class WorkflowMetrics

java.lang.Object
  edu.isi.pegasus.planner.classes.Data
      edu.isi.pegasus.planner.classes.WorkflowMetrics

All Implemented Interfaces:

Cloneable

public class WorkflowMetrics
extends Data

A Workflow metrics class that stores the metrics about the workflow.

Version:

$Revision: 4720 $

Author:

Karan Vahi

Field Summary

private String	mDAXLabel The label of the dax.
private int	mNumChmodJobs
private int	mNumCleanupJobs The number of cleanup jobs.
private int	mNumClusteredJobs The number of clustered compute jobs.
private int	mNumComputeJobs The number of compute jobs.
private int	mNumComputeTasks The number of compute tasks in the DAX
private int	mNumCreateDirJobs The number of create dir jobs.
private int	mNumDAGJobs The number of DAG jobs in the workflow
private int	mNumDAGTasks The number of DAG tasks in the DAX.
private int	mNumDAXJobs The number of dax jobs in the workflow
private int	mNumDAXTasks The number of DAX tasks in the DAX
private int	mNumInterTxJobs The number of inter-site transfer jobs.
private int	mNumRegJobs The number of registration jobs.
private int	mNumSITxJobs The number of stage in transfer jobs.
private int	mNumSOTxJobs The number of stage-out transfer jobs.
private int	mNumTotalJobs The total number of jobs in the executable workflow.

Fields inherited from class edu.isi.pegasus.planner.classes.Data

mLogger, mLogMsg

Constructor Summary

WorkflowMetrics()
The default constructor.

Method Summary

protected void	append(StringBuffer buffer, String key, int value) Appends a key=value pair to the StringBuffer.
protected void	append(StringBuffer buffer, String key, String value) Appends a key=value pair to the StringBuffer.
Object	clone() Returns the clone of the object.
void	decrement(Job job) Decrement the metrics when on the basis of type of job.
String	getLabel() Returns the DAXlabel.
void	increment(Job job) Increment the metrics when on the basis of type of job.
void	reset() Resets the internal counters to zero.
void	setLabel(String label) Sets the DAXlabel.
String	toString() Returns a textual description of the object.

Methods inherited from class edu.isi.pegasus.planner.classes.Data

setToString, vectorToString

Methods inherited from class java.lang.Object

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

Field Detail

mNumTotalJobs

private int mNumTotalJobs

The total number of jobs in the executable workflow.

mNumComputeJobs

private int mNumComputeJobs

The number of compute jobs.

mNumClusteredJobs

private int mNumClusteredJobs

The number of clustered compute jobs.

mNumSITxJobs

private int mNumSITxJobs

The number of stage in transfer jobs.

mNumSOTxJobs

private int mNumSOTxJobs

The number of stage-out transfer jobs.

mNumInterTxJobs

private int mNumInterTxJobs

The number of inter-site transfer jobs.

mNumRegJobs

private int mNumRegJobs

The number of registration jobs.

mNumCleanupJobs

private int mNumCleanupJobs

The number of cleanup jobs.

mNumCreateDirJobs

private int mNumCreateDirJobs

The number of create dir jobs.

mNumDAXJobs

private int mNumDAXJobs

The number of dax jobs in the workflow

mNumDAGJobs

private int mNumDAGJobs

The number of DAG jobs in the workflow

mNumChmodJobs

private int mNumChmodJobs

mNumComputeTasks

private int mNumComputeTasks

The number of compute tasks in the DAX

mNumDAXTasks

private int mNumDAXTasks

The number of DAX tasks in the DAX

mNumDAGTasks

private int mNumDAGTasks

The number of DAG tasks in the DAX.

mDAXLabel

private String mDAXLabel

The label of the dax.

Constructor Detail

WorkflowMetrics

public WorkflowMetrics()

The default constructor.

Method Detail

reset

public void reset()

Resets the internal counters to zero.

setLabel

public void setLabel(String label)

Sets the DAXlabel.

Parameters:

label - the dax label

getLabel

public String getLabel()

Returns the DAXlabel.

Returns:

the dax label

increment

public void increment(Job job)

Increment the metrics when on the basis of type of job.

Parameters:

job - the job being added.

decrement

public void decrement(Job job)

Decrement the metrics when on the basis of type of job. Does not decrement the task related metrics.

Parameters:

job - the job being removed.

toString

public String toString()

Returns a textual description of the object.

Specified by:

toString in class Data

Returns:

Object

append

protected void append(StringBuffer buffer,
                      String key,
                      String value)

Appends a key=value pair to the StringBuffer.

Parameters:

buffer - the StringBuffer that is to be appended to.

key - the key.

value - the value.

append

protected void append(StringBuffer buffer,
                      String key,
                      int value)

Appends a key=value pair to the StringBuffer.

Parameters:

buffer - the StringBuffer that is to be appended to.

key - the key.

value - the value.

clone

public Object clone()

Returns the clone of the object.

Overrides:

clone in class Object

Returns:

the clone