|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectjlite.GridSessionImpl
public class GridSessionImpl
Default implementation of the GridSession interface.
GridSession| Method Summary | |
|---|---|
void |
cancelJob(java.lang.String jobId)
Requests cancellation of a job. The WMProxy service endpoint is determined by the default VO of the proxy certificate. |
void |
cancelJob(java.lang.String wmProxyURL,
java.lang.String jobId)
Requests cancellation of a job. |
org.globus.gsi.GlobusCredential |
createProxy(java.lang.String[] vomsArgs,
int lifetime,
int proxyType,
boolean limited)
Creates a VOMS user proxy certificate (advanced version). |
org.globus.gsi.GlobusCredential |
createProxy(java.lang.String vo,
int lifetime)
Creates a VOMS user proxy certificate. If you want to request specific ACs or create a limited proxy, check the advanced version. |
void |
delegateProxy(java.lang.String delegationId)
Delegates a proxy certificate linked to the session to WMProxy service. The WMProxy service endpoint is determined by the default VO of the proxy certificate. |
void |
delegateProxy(java.lang.String wmProxyURL,
java.lang.String delegationId)
Delegates a proxy certificate linked to the session to the specified WMProxy service. |
void |
destroyProxy()
Destroys a proxy certificate linked to the session. |
void |
getJobOutput(java.lang.String jobId,
java.lang.String outputDir,
boolean purge)
Retrieves the output of a job via GridFTP. The WMProxy service endpoint is determined by the default VO of the proxy certificate. Throws GridAPIException if the job is not in DONE state. |
void |
getJobOutput(java.lang.String wmProxyURL,
java.lang.String jobId,
java.lang.String outputDir,
boolean purge)
Retrieves the output of a job via GridFTP. Throws GridAPIException if the job is not in DONE state. |
java.lang.String |
getJobState(java.lang.String jobId)
Retrieves current job state of a job. Possible job states are: SUBMITTED, WAITING, READY, SCHEDULED, RUNNING, DONE, ABORTED, CANCELED, CLEARED (refer to gLite documentation). |
org.glite.wsdl.types.lb.JobStatus |
getJobStatus(java.lang.String jobId)
Retrieves the status of a job. |
org.globus.gsi.GlobusCredential |
getProxy()
Returns a proxy certificate linked to the session. |
java.util.List<java.lang.String> |
listJobOutput(java.lang.String jobId)
Returns URIs of the job output files on the server. The WMProxy service endpoint is determined by the default VO of the proxy certificate. Throws GridAPIException if the job is not in DONE state. |
java.util.List<java.lang.String> |
listJobOutput(java.lang.String wmProxyURL,
java.lang.String jobId)
Returns URIs of the job output files on the server. Throws GridAPIException if the job is not in DONE state. |
java.util.List<MatchedCE> |
listMatchedCE(java.lang.String jdl)
Matches available grid resources (computing elements, CE) to requirements specified in the job description. The WMProxy service endpoint is determined by the default VO of the proxy certificate. Returns a list of matched CEs sorted in decreasing rank order. |
java.util.List<MatchedCE> |
listMatchedCE(java.lang.String wmProxyURL,
java.lang.String jdl)
Matches available grid resources (computing elements) to requirements specified in the job description. Returns a list of matched CEs sorted in decreasing rank order. |
java.lang.String |
submitJob(java.lang.String jdl)
Submits a job via WMProxy service. The WMProxy service endpoint is determined by the default VO of the proxy certificate. |
java.lang.String |
submitJob(java.lang.String jdl,
java.lang.String inputDir)
Submits a job via WMProxy service. The WMProxy service endpoint is determined by the default VO of the proxy certificate. |
java.lang.String |
submitJob(java.lang.String wmProxyURL,
java.lang.String jdl,
java.lang.String inputDir)
Submits a job via WMProxy service. |
| Methods inherited from class java.lang.Object |
|---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Method Detail |
|---|
public void cancelJob(java.lang.String jobId)
throws GridAPIException
GridSession
cancelJob in interface GridSessionjobId - job identifier
GridAPIException
public void cancelJob(java.lang.String wmProxyURL,
java.lang.String jobId)
throws GridAPIException
GridSession
cancelJob in interface GridSessionwmProxyURL - WMProxy service endpointjobId - job identifier
GridAPIException
public org.globus.gsi.GlobusCredential createProxy(java.lang.String vo,
int lifetime)
throws GridAPIException
GridSession
createProxy in interface GridSessionvo - VO namelifetime - proxy validity time in seconds
GridAPIException
public org.globus.gsi.GlobusCredential createProxy(java.lang.String[] vomsArgs,
int lifetime,
int proxyType,
boolean limited)
throws GridAPIException
GridSession
createProxy in interface GridSessionvomsArgs - a list of VOMS commands in the form lifetime - proxy validity time in secondsproxyType - version of proxy certificate {2,3,4} (use 2 for default gLite behavior)limited - creates a limited proxy (use false for default gLite behavior)
GridAPIException
public void delegateProxy(java.lang.String delegationId)
throws GridAPIException
GridSession
delegateProxy in interface GridSessiondelegationId - delegation identifier
GridAPIException
public void delegateProxy(java.lang.String wmProxyURL,
java.lang.String delegationId)
throws GridAPIException
GridSession
delegateProxy in interface GridSessionwmProxyURL - WMProxy service endpointdelegationId - delegation identifier
GridAPIException
public void destroyProxy()
throws GridAPIException
GridSession
destroyProxy in interface GridSessionGridAPIException
public void getJobOutput(java.lang.String jobId,
java.lang.String outputDir,
boolean purge)
throws GridAPIException
GridSession
getJobOutput in interface GridSessionjobId - job identifieroutputDir - directory to store retrieved filespurge - purge job output from the server after retrieval
(use true for default gLite behavior)
GridAPIException
public void getJobOutput(java.lang.String wmProxyURL,
java.lang.String jobId,
java.lang.String outputDir,
boolean purge)
throws GridAPIException
GridSession
getJobOutput in interface GridSessionwmProxyURL - WMProxy service endpointjobId - job identifieroutputDir - directory to store retrieved filespurge - purge job output from the server after retrieval
(use true for default gLite behavior)
GridAPIException
public java.lang.String getJobState(java.lang.String jobId)
throws GridAPIException
GridSession
getJobState in interface GridSessionjobId - job identifier
GridAPIException
public org.glite.wsdl.types.lb.JobStatus getJobStatus(java.lang.String jobId)
throws GridAPIException
GridSession
getJobStatus in interface GridSessionjobId - job identifier
GridAPIExceptionpublic org.globus.gsi.GlobusCredential getProxy()
GridSession
getProxy in interface GridSession
public java.util.List<java.lang.String> listJobOutput(java.lang.String jobId)
throws GridAPIException
GridSession
listJobOutput in interface GridSessionjobId - job identifier
GridAPIException
public java.util.List<java.lang.String> listJobOutput(java.lang.String wmProxyURL,
java.lang.String jobId)
throws GridAPIException
GridSession
listJobOutput in interface GridSessionwmProxyURL - WMProxy service endpointjobId - job identifier
GridAPIException
public java.util.List<MatchedCE> listMatchedCE(java.lang.String jdl)
throws GridAPIException
GridSession
listMatchedCE in interface GridSessionjdl - job description in JDL format
GridAPIException
public java.util.List<MatchedCE> listMatchedCE(java.lang.String wmProxyURL,
java.lang.String jdl)
throws GridAPIException
GridSession
listMatchedCE in interface GridSessionwmProxyURL - WMProxy service endpointjdl - job description in JDL format
GridAPIException
public java.lang.String submitJob(java.lang.String jdl)
throws GridAPIException
GridSession
submitJob in interface GridSessionjdl - job description in JDL format
GridAPIException
public java.lang.String submitJob(java.lang.String jdl,
java.lang.String inputDir)
throws GridAPIException
GridSession
submitJob in interface GridSessionjdl - job description in JDL formatinputDir - all input files with relative paths
will be searched in the specified directory
GridAPIException
public java.lang.String submitJob(java.lang.String wmProxyURL,
java.lang.String jdl,
java.lang.String inputDir)
throws GridAPIException
GridSession
submitJob in interface GridSessionwmProxyURL - WMProxy service endpointjdl - job description in JDL formatinputDir - search input files in the specified directory
GridAPIException
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||