Modifier and Type | Field and Description |
---|---|
static String |
GRIDSTART_MAINJOB_STATE
The state in the jobstate that is taken to designate the GRIDSTART_MAINJOB
time.
|
static String |
GRIDSTART_POSTJOB_STATE
The state in the jobstate that is taken to designate the GRIDSTART_POSTJOB
time.
|
static String |
GRIDSTART_PREJOB_STATE
The state in the jobstate that is taken to designate the GRIDSTART_PREJOB
time.
|
static String |
JOBSTATE_LOG
The name of the tailstatd file.
|
private String |
mDirectory
The directory where all the files reside.
|
private Map |
mJMStore
A Map store that stores JobMeasurements objects indexed by the name of the jobs.
|
protected JobMeasurements |
mJobMeasurements
Stores all the space readings for the current invocation record.
|
protected LogManager |
mLogger
The handle to the logger.
|
protected String |
mMainJob
The main job whose record is being parsed.
|
private Map |
mNumJobsStore
The number of jobs executing at any given time per site.
|
protected String |
mSite
The logical site where the job was run.
|
protected WorkflowMeasurements |
mWFMeasurements
The WorkflowMeasurements object created during the callback construction.
|
Constructor and Description |
---|
NodeUsageCallback()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
cbInputFile(String filename,
StatInfo info)
Callback function for when stat information for an input file is
encountered.
|
void |
cbInvocationEnd()
Callback signalling that an invocation record has been parsed.
|
void |
cbInvocationStart(String job,
String resource)
Callback for the starting of an invocation record.
|
void |
cbMachine(Machine machine)
Callback to pass the machine information on which the job is executed.
|
void |
cbMetadata(Map metadata)
Callback for the metadata retrieved from the kickstart record.
|
void |
cbOutputFile(String filename,
StatInfo info)
Callback function for when stat information for an output file is
encountered.
|
void |
cbStdERR(List jobs,
String data)
Callback function for the data section of stderr.
|
void |
cbStdIN(List jobs,
String data)
Callback function for the data section of stdin.
|
void |
cbStdOut(List jobs,
String data)
Callback function for the data section of stdout.
|
boolean |
cleanupJob(String name)
Returns boolean indicating whether the job is a cleanup job or not.
|
void |
done()
Callback signalling that we are done with the parsing of the files.
|
Object |
getConstructedObject()
Returns the SpaceUsage store built.
|
private int |
getCurrentNumOfJobs(String site)
Returns the number of jobs that are executing for a particular site
|
private int |
getEventType(String state)
Returns the event type matching a particular job type
|
void |
initialize(String directory,
boolean useStatInfo)
Initializes the callback.
|
protected boolean |
validState(String state)
Returns a boolean indicating whether the state is valid or not.
|
public static final String JOBSTATE_LOG
public static final String GRIDSTART_PREJOB_STATE
public static final String GRIDSTART_MAINJOB_STATE
public static final String GRIDSTART_POSTJOB_STATE
protected String mSite
protected WorkflowMeasurements mWFMeasurements
protected String mMainJob
protected LogManager mLogger
protected JobMeasurements mJobMeasurements
private Map mJMStore
private String mDirectory
private Map mNumJobsStore
public void initialize(String directory, boolean useStatInfo)
initialize
in interface Callback
directory
- the directory where all the files reside.useStatInfo
- boolean indicating whether to use stat info or not.public void cbInvocationStart(String job, String resource)
Callback
cbInvocationStart
in interface Callback
job
- the job/file being parsed.resource
- the site id where the job was executed.public void cbStdIN(List jobs, String data)
Callback
public void cbStdOut(List jobs, String data)
Callback
public void cbStdERR(List jobs, String data)
Callback
private int getCurrentNumOfJobs(String site)
site
- the name of the site.public void cbInputFile(String filename, StatInfo info)
cbInputFile
in interface Callback
filename
- the name of the file.info
- the StatInfo
about the file.public void cbOutputFile(String filename, StatInfo info)
cbOutputFile
in interface Callback
filename
- the name of the file.info
- the StatInfo
about the file.public void cbInvocationEnd()
cbInvocationEnd
in interface Callback
public Object getConstructedObject()
getConstructedObject
in interface Callback
public void done()
protected boolean validState(String state)
state
- the stateprivate int getEventType(String state)
state
- the state of the jobpublic boolean cleanupJob(String name)
name
- the name of the job.public void cbMetadata(Map metadata)
cbMetadata
in interface Callback
metadata
- Copyright © 2011 The University of Southern California. All Rights Reserved.