|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.tum.binfo.jdrm.Session
Java Distributed Resource Management
Grid independent universal handler class for running arbitary java classes
over a cluster system like Sun's Grid Engine.
Designed for fast and easy implementation and high computation needs.
Field Summary | |
protected java.lang.String |
classpath
|
protected java.util.LinkedList |
entries
|
protected java.lang.String |
jvmOptions
|
protected int |
MINUTESTOWAIT
|
protected java.lang.String |
nameOfSessionFile
|
protected java.lang.String |
nameOfSessionFileFull
|
protected java.lang.String |
pathDelimiter
|
protected java.lang.String |
pathOfSessionFiles
|
protected java.util.Random |
rnd
|
protected boolean |
useClusterSystem
|
Constructor Summary | |
Session()
|
Method Summary | |
java.lang.String |
about()
|
boolean |
existJob(JobTemplate jt)
Checks if a job has been submitted already. |
boolean |
existJob(java.lang.String yourUniqueName)
Checks if a job has been submitted already. |
int[] |
getAllJobIds()
Returns all job ids which are known to this session. |
java.lang.String |
getClasspath()
|
JobTemplate |
getJobResultObj(int jobId)
Returns the job object after it has been run. |
java.lang.String |
getJvmOptions()
|
java.lang.String |
getPathOfSessionFiles()
|
void |
init(java.lang.String sessionName,
boolean useClusterSystem)
Reads an existing session administration file or creates a new one. |
protected boolean |
isValidSessionName(java.lang.String str)
|
protected boolean |
isValidSessionPath(java.lang.String str)
|
protected java.lang.String |
makeInName(java.lang.String filename)
|
protected java.lang.String |
makeOutName(java.lang.String filename)
|
protected void |
readSessionFile()
|
void |
setClasspath(java.lang.String string)
Sets the classpath which will be used executing the job-objects. |
void |
setJvmOptions(java.lang.String string)
Sets the options of the java virtual machine for executing a job. |
void |
setPathOfSessionFiles(java.lang.String string)
Sets the path where the session administration file, job input and output object files are stored. |
int |
submitJob(JobTemplate jt)
Submits any JobTemplate object and derived objects to our system. |
protected void |
subWaitForAllCluster()
|
void |
waitForAll()
Blocking routine which waits until all jobs have finished. |
protected void |
writeSessionFile()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected java.util.LinkedList entries
protected java.lang.String pathOfSessionFiles
protected java.lang.String nameOfSessionFile
protected java.lang.String nameOfSessionFileFull
protected java.lang.String pathDelimiter
protected boolean useClusterSystem
protected java.lang.String jvmOptions
protected final int MINUTESTOWAIT
protected java.util.Random rnd
protected java.lang.String classpath
Constructor Detail |
public Session()
Method Detail |
protected boolean isValidSessionName(java.lang.String str)
protected boolean isValidSessionPath(java.lang.String str)
public java.lang.String about()
public void init(java.lang.String sessionName, boolean useClusterSystem) throws java.lang.Exception
sessionName
- : unique name of the session file,(=also prefix of all job object files). Note: the suffix .session will be added automatically
java.lang.Exception
protected void readSessionFile()
protected void writeSessionFile() throws java.lang.Exception
java.lang.Exception
public boolean existJob(JobTemplate jt) throws java.lang.Exception
java.lang.Exception
public boolean existJob(java.lang.String yourUniqueName) throws java.lang.Exception
java.lang.Exception
protected java.lang.String makeInName(java.lang.String filename)
protected java.lang.String makeOutName(java.lang.String filename)
public int submitJob(JobTemplate jt) throws java.lang.Exception
java.lang.Exception
protected void subWaitForAllCluster()
public void waitForAll() throws java.lang.Exception
java.lang.Exception
public int[] getAllJobIds() throws java.lang.Exception
java.lang.Exception
public JobTemplate getJobResultObj(int jobId) throws java.lang.Exception
java.lang.Exception
public java.lang.String getClasspath()
public void setClasspath(java.lang.String string) throws java.lang.Exception
string
-
java.lang.Exception
public java.lang.String getPathOfSessionFiles()
public void setPathOfSessionFiles(java.lang.String string) throws java.lang.Exception
string
-
java.lang.Exception
public java.lang.String getJvmOptions()
public void setJvmOptions(java.lang.String string) throws java.lang.Exception
string
-
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |