|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecteu.xtreemos.xosd.jobmng.data.XJob
public class XJob
This class manages job's status, dependencies and resources where it's present.
Field Summary | |
---|---|
private java.util.Hashtable<CommunicationAddress,java.lang.Boolean> |
bufferLocations
|
private java.util.concurrent.Semaphore |
cprstSem
|
private java.util.Hashtable<java.lang.String,java.util.ArrayList<java.lang.String>> |
dependenciesDown
|
private java.util.Hashtable<java.lang.String,java.util.ArrayList<java.lang.String>> |
dependenciesUp
|
private int |
exitStatus
|
private java.lang.String |
jobId
|
java.lang.String |
jsdlFile
|
private JSDLInfo |
jsdlInfo
|
private java.util.Hashtable<CommunicationAddress,java.lang.String> |
resources
|
private JobState |
state
|
private java.lang.String |
user
|
private java.lang.String |
vo
|
Constructor Summary | |
---|---|
XJob(java.lang.String jobId,
JSDLInfo subInfo,
java.lang.String user)
|
Method Summary | |
---|---|
void |
addBufferLocation(CommunicationAddress resource)
|
void |
addBufferLocation(CommunicationAddress resource,
java.lang.Boolean enable)
Adds resource to a structure that keeps track of the used resources that will need cleaning after job's death. |
void |
addDependenceDown(java.lang.String toJobId,
java.lang.String TAG)
|
void |
addDependenceUp(java.lang.String FromJobId,
java.lang.String TAG)
|
int |
addResource(CommunicationAddress resource)
Add the resource to the list of resources |
void |
deleteDependenceDown(java.lang.String toJobId,
java.lang.String TAG)
|
void |
deleteDependenceUp(java.lang.String FromJobId,
java.lang.String TAG)
|
void |
finished(int exitStatus)
|
java.util.Set<CommunicationAddress> |
getBufferLocations()
|
java.util.ArrayList<java.lang.String> |
getDependencesDown(java.lang.String TAG)
|
java.util.ArrayList<java.lang.String> |
getDependencesUp(java.lang.String TAG)
|
int |
getExitStatus()
This method is called from JobMng's jobWait |
java.lang.String |
getJobId()
|
java.lang.String |
getJsdlFile()
|
java.util.ArrayList<CommunicationAddress> |
getListResources()
|
int |
getResourceNeededCount()
Returns the number of exact resources needed in the JSDL |
JobState |
getState()
|
java.lang.String |
getSubmitParam(java.lang.String paramName)
|
java.util.ArrayList<java.lang.String> |
getSubmitParamList(java.lang.String paramName)
|
java.lang.String |
getUser()
|
java.lang.String |
getVO()
|
void |
lockCheckpointRestart()
synchronize checkpoint/restart requests |
void |
removeBufferLocation(CommunicationAddress resource)
|
void |
removeResource(CommunicationAddress resource)
Remove the resource from the list of resources |
boolean |
setRunning()
Sets XJob state to Running. |
void |
setUser(java.lang.String user)
|
void |
setVO(java.lang.String vo)
|
void |
start(java.util.ArrayList<CommunicationAddress> resAddr)
|
void |
start(CommunicationAddress resAddr)
|
void |
unlockCheckpointRestart()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private java.lang.String jobId
private JobState state
private JSDLInfo jsdlInfo
public java.lang.String jsdlFile
private java.util.Hashtable<CommunicationAddress,java.lang.String> resources
private java.util.Hashtable<CommunicationAddress,java.lang.Boolean> bufferLocations
private int exitStatus
private java.lang.String user
private java.lang.String vo
private java.util.Hashtable<java.lang.String,java.util.ArrayList<java.lang.String>> dependenciesDown
private java.util.Hashtable<java.lang.String,java.util.ArrayList<java.lang.String>> dependenciesUp
private java.util.concurrent.Semaphore cprstSem
Constructor Detail |
---|
public XJob(java.lang.String jobId, JSDLInfo subInfo, java.lang.String user)
jobId
- jsdlInfo
- Method Detail |
---|
public void start(java.util.ArrayList<CommunicationAddress> resAddr)
public void start(CommunicationAddress resAddr)
public void finished(int exitStatus)
public boolean setRunning()
public java.lang.String getSubmitParam(java.lang.String paramName)
public java.util.ArrayList<java.lang.String> getSubmitParamList(java.lang.String paramName)
public java.util.ArrayList<CommunicationAddress> getListResources()
public int addResource(CommunicationAddress resource)
public void removeResource(CommunicationAddress resource)
public void addBufferLocation(CommunicationAddress resource, java.lang.Boolean enable)
resource
- enable
- a Boolean no longer used.public void removeBufferLocation(CommunicationAddress resource)
public java.util.Set<CommunicationAddress> getBufferLocations()
public void addBufferLocation(CommunicationAddress resource)
public int getExitStatus()
public java.lang.String getJobId()
public JobState getState()
public java.lang.String getUser()
public void setUser(java.lang.String user)
user
- the user to setpublic java.lang.String getVO()
public void setVO(java.lang.String vo)
vo
- a String with the identifier of the virtual organization.public void addDependenceUp(java.lang.String FromJobId, java.lang.String TAG)
public void addDependenceDown(java.lang.String toJobId, java.lang.String TAG)
public void deleteDependenceUp(java.lang.String FromJobId, java.lang.String TAG)
public void deleteDependenceDown(java.lang.String toJobId, java.lang.String TAG)
public java.util.ArrayList<java.lang.String> getDependencesUp(java.lang.String TAG)
public java.util.ArrayList<java.lang.String> getDependencesDown(java.lang.String TAG)
public int getResourceNeededCount()
public void lockCheckpointRestart() throws java.lang.Exception
jobId
-
java.lang.Exception
public void unlockCheckpointRestart() throws java.lang.Exception
java.lang.Exception
public java.lang.String getJsdlFile()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |