edu.isi.pegasus.planner.invocation
public class InvocationRecord extends Invocation
Modifier and Type | Field and Description |
---|---|
private WorkingDir |
m_cwd
Working directory at startup.
|
private String |
m_derivation
Name of the Derivation that produced this invocation.
|
private double |
m_duration
total duration of call.
|
private Environment |
m_environment
Environment settings.
|
private int |
m_gid
numerical group id of the effective user.
|
private String |
m_group
symbolical group name of the effective user.
|
private InetAddress |
m_hostaddr
host address where gridlaunch ran (primary interface).
|
private String |
m_hostname
Symbolic hostname where gridlaunch ran (primary interface).
|
private String |
m_interface
Symbolic name of primary interface we used to determine host-name and -address.
|
private List |
m_job
Job records: prejob, main job, postjob
|
private Machine |
m_machine
The Machine object capturing machine information.
|
private int |
m_pid
process id of gridlaunch itself.
|
private long |
m_pmem
Records the physical memory on the remote machine, if available.
|
private String |
m_resource
Resource, site or pool at which the jobs was run.
|
private Date |
m_start
start of gridlaunch timestamp.
|
private List |
m_stat
Array with stat() and fstat() information about various files.
|
private String |
m_transformation
Name of the: Transformation that produced this invocation.
|
private int |
m_uid
numerical user id of the effective user.
|
private int |
m_umask
Currently active umask while kickstart was executing.
|
private Architecture |
m_uname
Architectural information.
|
private Usage |
m_usage
Total resource consumption by gridlaunch and all siblings.
|
private String |
m_user
symbolical user name of the effective user.
|
private String |
m_version
protocol version information.
|
private String |
m_wf_label
Workflow label, currently optional?
|
private Date |
m_wf_stamp
Workflow timestamp to make the label more unique.
|
static String |
SCHEMA_LOCATION
The "not-so-official" location URL of the invocation record definition.
|
static String |
SCHEMA_NAMESPACE
The "official" namespace URI of the invocation record schema.
|
Constructor and Description |
---|
InvocationRecord()
Default c'tor: Construct a hollow shell and allow further
information to be added later.
|
Modifier and Type | Method and Description |
---|---|
void |
addJob(int index,
Job job)
Accessor: Inserts a Job into a specific position of the job list.
|
void |
addJob(Job job)
Accessor: Appends a job to the list of jobs.
|
void |
addStatCall(int index,
StatCall stat)
Accessor: Inserts a StatCall into a specific position of the stat list.
|
void |
addStatCall(StatCall stat)
Accessor: Appends a stat to the list of stats.
|
Architecture |
getArchitecture()
Accessor
|
String |
getDerivation()
Accessor
|
double |
getDuration()
Accessor
|
Environment |
getEnvironment()
Accessor
|
int |
getGID()
Accessor
|
String |
getGroup()
Accessor
|
InetAddress |
getHostAddress()
Accessor
|
String |
getHostname()
Accessor
|
String |
getInterface()
Accessor.
|
Job |
getJob(int index)
Accessor: Obtains a job at a certain position in the job list.
|
int |
getJobCount()
Accessor: Obtains the size of the job list.
|
List |
getJobList()
Accessor: Gets an array of all values that constitute the current
content.
|
Machine |
getMachine()
Accessor.
|
long |
getPhysicalMemory()
Accessor.
|
int |
getPID()
Accessor
|
String |
getResource()
Accessor
|
Date |
getStart()
Accessor
|
StatCall |
getStatCall(int index)
Accessor: Obtains a stat at a certain position in the stat list.
|
int |
getStatCount()
Accessor: Obtains the size of the stat list.
|
List |
getStatList()
Accessor: Gets an array of all values that constitute the current
content.
|
String |
getTransformation()
Accessor
|
int |
getUID()
Accessor
|
int |
getUMask()
Accessor
|
Usage |
getUsage()
Accessor
|
String |
getUser()
Accessor
|
String |
getVersion()
Accessor
|
String |
getWorkflowLabel()
Accessor
|
Date |
getWorkflowTimestamp()
Accessor
|
WorkingDir |
getWorkingDirectory()
Accessor
|
Iterator |
iterateJob()
Accessor: Enumerates the internal values that constitute the content
of the job list.
|
Iterator |
iterateStatCall()
Accessor: Enumerates the internal values that constitute the content
of the stat list.
|
ListIterator |
listIterateJob()
Accessor: Enumerates the internal values that constitute the content
of the job list.
|
ListIterator |
listIterateStatCall()
Accessor: Enumerates the internal values that constitute the content
of the stat list.
|
void |
removeAllJob()
Accessor: Removes all values from the job list.
|
void |
removeAllStatCall()
Accessor: Removes all values from the stat list.
|
Job |
removeJob(int index)
Accessor: Removes a specific job from the job list.
|
StatCall |
removeStatCall(int index)
Accessor: Removes a specific stat from the stat list.
|
void |
setArchitecture(Architecture uname)
Accessor.
|
void |
setDerivation(String derivation)
Accessor.
|
void |
setDuration(double duration)
Accessor.
|
void |
setEnvironment(Environment environment)
Accessor.
|
void |
setGID(int gid)
Accessor.
|
void |
setGroup(String group)
Accessor.
|
void |
setHostAddress(InetAddress hostaddr)
Accessor.
|
void |
setHostname(String hostname)
Accessor.
|
void |
setInterface(String p_interface)
Accessor.
|
void |
setJob(Collection jobs)
Accessor: Overwrites internal list with an external list
representing jobs.
|
void |
setJob(int index,
Job job)
Accessor: Overwrites a job at a certain position.
|
void |
setMachine(Machine machine)
Accessor.
|
void |
setPhysicalMemory(long pmem)
Accessor.
|
void |
setPID(int pid)
Accessor.
|
void |
setResource(String resource)
Accessor.
|
void |
setStart(Date start)
Accessor.
|
void |
setStatCall(Collection stats)
Accessor: Overwrites internal list with an external list
representing stats.
|
void |
setStatCall(int index,
StatCall stat)
Accessor: Overwrites a stat at a certain position.
|
void |
setTransformation(String transformation)
Accessor.
|
void |
setUID(int uid)
Accessor.
|
void |
setUMask(int umask)
Accessor.
|
void |
setUsage(Usage usage)
Accessor.
|
void |
setUser(String user)
Accessor.
|
void |
setVersion(String version)
Accessor.
|
void |
setWorkflowLabel(String label)
Accessor.
|
void |
setWorkflowTimestamp(Date stamp)
Accessor.
|
void |
setWorkingDirectory(String cwd)
Accessor.
|
void |
setWorkingDirectory(WorkingDir cwd)
Accessor.
|
void |
toString(Writer stream)
Converts the active state into something meant for human consumption.
|
void |
toXML(Writer stream,
String indent,
String namespace)
Dump the state of the current element as XML output.
|
void |
writeXMLHeader(Writer stream,
String indent,
String namespace)
Writes the header of the XML output.
|
public static final String SCHEMA_NAMESPACE
public static final String SCHEMA_LOCATION
private String m_version
private Date m_start
private double m_duration
private String m_transformation
private String m_derivation
private long m_pmem
private int m_pid
private InetAddress m_hostaddr
private String m_hostname
private String m_interface
private int m_uid
private String m_user
private int m_gid
private String m_group
private WorkingDir m_cwd
private Architecture m_uname
private Usage m_usage
private List m_job
private List m_stat
private String m_resource
private String m_wf_label
private Date m_wf_stamp
private Environment m_environment
private int m_umask
private Machine m_machine
public InvocationRecord()
public int getUMask()
setUMask(int)
public void setUMask(int umask)
umask
- getUMask()
public String getVersion()
setVersion(String)
public void setVersion(String version)
version
- getVersion()
public Date getStart()
setStart(Date)
public void setStart(Date start)
start
- getStart()
public double getDuration()
setDuration(double)
public void setDuration(double duration)
duration
- getDuration()
public void setMachine(Machine machine)
machine
- getMachine()
public Machine getMachine()
#setMachine(org.griphyn.vdl.invocation.Machine)
public String getTransformation()
setTransformation(String)
public void setTransformation(String transformation)
transformation
- getTransformation()
public String getDerivation()
setDerivation(String)
public void setDerivation(String derivation)
derivation
- getDerivation()
public int getPID()
setPID(int)
public void setPID(int pid)
pid
- getPID()
public InetAddress getHostAddress()
setHostAddress(InetAddress)
public void setHostAddress(InetAddress hostaddr)
hostaddr
- getHostAddress()
public String getHostname()
setHostname(String)
public void setHostname(String hostname)
hostname
- getHostname()
public String getInterface()
setInterface(String)
public void setInterface(String p_interface)
p_interface
- getInterface()
public int getUID()
setUID(int)
public void setUID(int uid)
uid
- getUID()
public String getUser()
setUser(String)
public int getGID()
setGID(int)
public void setGID(int gid)
gid
- getGID()
public String getGroup()
setGroup(String)
public void setGroup(String group)
group
- getGroup()
public Usage getUsage()
setUsage(Usage)
public void setUsage(Usage usage)
usage
- getUsage()
public Architecture getArchitecture()
setArchitecture(Architecture)
public void setArchitecture(Architecture uname)
uname
- getArchitecture()
public String getResource()
setResource( String )
public void setResource(String resource)
resource
- getResource()
public String getWorkflowLabel()
setWorkflowLabel( String )
public void setWorkflowLabel(String label)
label
- getWorkflowLabel()
public Date getWorkflowTimestamp()
setWorkflowTimestamp( Date )
public void setWorkflowTimestamp(Date stamp)
stamp
- getResource()
public Environment getEnvironment()
setEnvironment(Environment)
public void setEnvironment(Environment environment)
environment
- getEnvironment()
public void addJob(Job job)
job
- is the job to append to the list.public void addJob(int index, Job job)
index
- is the position to insert the item intojob
- is the job to insert into the list.public Job getJob(int index) throws IndexOutOfBoundsException
index
- is the position in the list to obtain a job fromIndexOutOfBoundsException
- if the index points to an element
in the list that does not contain any elments.public int getJobCount()
public List getJobList()
public Iterator iterateJob()
public ListIterator listIterateJob()
public void removeAllJob()
public Job removeJob(int index)
index
- is the position at which an element is to be removed.public void setJob(int index, Job job) throws IndexOutOfBoundsException
index
- position to overwrite an elment in.job
- is the Job to replace with.IndexOutOfBoundsException
- if the position pointed to is invalid.public void setJob(Collection jobs)
jobs
- is the external list of job to overwrite with.public void addStatCall(StatCall stat)
stat
- is the stat to append to the list.public void addStatCall(int index, StatCall stat)
index
- is the position to insert the item intostat
- is the stat to insert into the list.public StatCall getStatCall(int index) throws IndexOutOfBoundsException
index
- is the position in the list to obtain a stat fromIndexOutOfBoundsException
- if the index points to an element
in the list that does not contain any elments.public int getStatCount()
public List getStatList()
public Iterator iterateStatCall()
public ListIterator listIterateStatCall()
public void removeAllStatCall()
public StatCall removeStatCall(int index)
index
- is the position at which an element is to be removed.public void setStatCall(int index, StatCall stat) throws IndexOutOfBoundsException
index
- position to overwrite an elment in.stat
- is the StatCall to replace with.IndexOutOfBoundsException
- if the position pointed to is invalid.public void setStatCall(Collection stats)
stats
- is the external list of stat to overwrite with.public WorkingDir getWorkingDirectory()
public void setWorkingDirectory(String cwd)
cwd
- getWorkingDirectory()
,
setWorkingDirectory(WorkingDir)
public void setWorkingDirectory(WorkingDir cwd)
cwd
- getWorkingDirectory()
,
setWorkingDirectory(String)
public long getPhysicalMemory()
setPhysicalMemory( long )
public void setPhysicalMemory(long pmem)
pmem
- getPhysicalMemory()
public void toString(Writer stream) throws IOException
toString
in class org.griphyn.vdl.Chimera
stream
- is a stream opened and ready for writing. This can also
be a string stream for efficient output.IOException
- if something fishy happens to the stream.public void writeXMLHeader(Writer stream, String indent, String namespace) throws IOException
stream
- is a stream opened and ready for writing. This can also
be a string stream for efficient output.indent
- is a String
of spaces used for pretty
printing. The initial amount of spaces should be an empty string.
The parameter is used internally for the recursive traversal.namespace
- is the XML schema namespace prefix. If neither
empty nor null, each element will be prefixed with this prefix,
and the root element will map the XML namespace.IOException
- if something fishy happens to the stream.public void toXML(Writer stream, String indent, String namespace) throws IOException
toXML
in class org.griphyn.vdl.Chimera
stream
- is a stream opened and ready for writing. This can also
be a string stream for efficient output.indent
- is a String
of spaces used for pretty
printing. The initial amount of spaces should be an empty string.
The parameter is used internally for the recursive traversal.namespace
- is the XML schema namespace prefix. If neither
empty nor null, each element will be prefixed with this prefix,
and the root element will map the XML namespace.IOException
- if something fishy happens to the stream.BufferedWriter