Modifier and Type | Method and Description |
---|---|
static org.json.JSONObject |
Json4Uws.getJobInfoJson(UWSJob job)
Gets the JSON representation of the jobInfo of the given job.
|
static org.json.JSONObject |
Json4Uws.getJobParamsJson(UWSJob job)
Gets the JSON representation of the parameters of the given job.
|
static org.json.JSONArray |
Json4Uws.getJobResultsJson(UWSJob job)
Gets the JSON representation of the results of the given job.
|
static org.json.JSONObject |
Json4Uws.getJson(UWSJob job)
Gets the JSON representation of the given job.
|
static org.json.JSONObject |
Json4Uws.getJson(UWSJob job,
UWSUrl jobsListUrl,
boolean reference)
Gets the JSON representation of the given job.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
UWSToolBox.writeErrorFile(java.lang.Exception ex,
ErrorSummary error,
UWSJob job,
java.io.OutputStream output)
Writes the stack trace of the given exception in the file whose the name and the parent directory are given in parameters.
|
Modifier and Type | Method and Description |
---|---|
UWSJob |
ConfigurableUWSFactory.createJob(javax.servlet.http.HttpServletRequest request,
JobOwner user) |
UWSJob |
ConfigurableUWSFactory.createJob(java.lang.String jobID,
long creationTime,
JobOwner owner,
UWSParameters params,
long quote,
long startTime,
long endTime,
java.util.List<Result> results,
ErrorSummary error) |
Modifier and Type | Method and Description |
---|---|
JobThread |
ConfigurableUWSFactory.createJobThread(UWSJob jobDescription) |
Modifier and Type | Field and Description |
---|---|
protected UWSJob |
JobThread.job
The job which contains all parameters for its execution and which must be filled at the end of the execution.
|
protected UWSJob |
JobPhase.job
The job whose the current phase is represented by this class.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.String,UWSJob> |
JobList.jobsList
[Required] List of jobs.
|
protected java.util.Map<JobOwner,java.util.Map<java.lang.String,UWSJob>> |
JobList.ownerJobs
[Required] List of jobs per owner.
|
Modifier and Type | Method and Description |
---|---|
UWSJob |
JobThread.getJob()
Gets the job instance associated to this thread.
|
UWSJob |
JobPhase.getJob()
Gets the job whose the execution phase is represented by this object.
|
UWSJob |
JobList.getJob(java.lang.String jobID)
Gets the job whose the ID is given in parameter.
|
UWSJob |
JobList.getJob(java.lang.String jobID,
JobOwner user)
Gets the job whose the ID is given in parameter ONLY IF it is the one of
the specified user OR IF the specified job is owned by an anonymous user.
|
protected UWSJob |
JobList.removeJob(java.lang.String jobId)
Lets removing (NOT DESTROYING) the specified job from this jobs list.
|
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<UWSJob> |
JobList.getJobs()
Gets an iterator on the whole jobs list.
|
java.util.Iterator<UWSJob> |
JobList.getJobs(JobOwner user)
Gets an iterator on the jobs list of the specified user.
|
java.util.Iterator<UWSJob> |
JobList.iterator()
Gets an iterator on the jobs list.
|
java.util.List<UWSJob> |
JobList.searchJobs(java.lang.String runID)
Gets all job whose the runID is equals (not case sensitive) to the given
runID.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
JobList.addNewJob(UWSJob j)
Add the given job to the list except if a job with the same jobID already
exists.
|
protected static java.lang.String |
JobThread.getDefaultTaskDescription(UWSJob job)
Gets a default description of the task executed by a
JobThread . |
static java.lang.String |
Result.getDefaultUrl(java.lang.String id,
UWSJob job)
Gets the HREF as {jobList}/{job}/results/ID.
|
static boolean |
Result.isRedirectionUrl(java.lang.String url,
java.lang.String resultId,
UWSJob job)
Tells whether the given URL is different from the default URL of the specified result of the given job.
|
void |
JobObserver.update(UWSJob job,
ExecutionPhase oldPhase,
ExecutionPhase newPhase)
Used when one of the observed jobs notifies its observers of a modification of its execution phase.
|
void |
JobList.updateDestruction(UWSJob job)
Lets notifying the destruction manager of a possible modification of the
destructionTime of the given job.
|
Constructor and Description |
---|
JobPhase(UWSJob j)
Builds the phase manager of the given job.
|
JobThread(UWSJob j)
Builds the JobThread instance which will be used by the given job to execute its task.
|
JobThread(UWSJob j,
ServiceErrorWriter errorWriter)
Builds the JobThread instance which will be used by the given job to execute its task.
|
JobThread(UWSJob j,
java.lang.String task)
Builds the JobThread instance which will be used by the given job to execute its task.
|
JobThread(UWSJob j,
java.lang.String task,
ServiceErrorWriter errorWriter)
Builds the JobThread instance which will be used by the given job to execute its task.
|
Result(UWSJob job,
java.lang.String name)
Builds a result with just a name/ID.
|
Result(UWSJob job,
java.lang.String name,
java.lang.String resultUrl)
Builds a result with an ID/name and the URL toward the file which contains the result content.
|
Result(UWSJob job,
java.lang.String name,
java.lang.String resultType,
java.lang.String resultUrl)
Builds a result with an ID/name, a result type and the URL toward the file which contains the result content.
|
Result(UWSJob job,
java.net.URL resultUrl)
Builds a result with the URL toward the file which contains the result content.
|
Modifier and Type | Field and Description |
---|---|
protected UWSJob |
XMLJobInfo.job
The job owning this
JobInfo . |
Modifier and Type | Method and Description |
---|---|
void |
JobInfo.setJob(UWSJob myJob)
Notify this
JobInfo that it is now owned by the given job. |
void |
SingleValueJobInfo.setJob(UWSJob myJob) |
void |
XMLJobInfo.setJob(UWSJob myJob) |
Modifier and Type | Field and Description |
---|---|
protected UWSJob |
DefaultDestructionManager.currentJob
The job currently planned for destruction.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.TreeSet<UWSJob> |
DefaultDestructionManager.jobsToDestroy
The list of jobs to destroy.
|
protected java.util.Vector<UWSJob> |
AbstractQueuedExecutionManager.queuedJobs
List of queued jobs.
|
protected java.util.Map<java.lang.String,UWSJob> |
AbstractQueuedExecutionManager.runningJobs
List of running jobs.
|
protected java.util.Map<java.lang.String,UWSJob> |
DefaultExecutionManager.runningJobs
List of running jobs.
|
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<UWSJob> |
ExecutionManager.getQueuedJobs()
Gets the list of queued jobs.
|
java.util.Iterator<UWSJob> |
AbstractQueuedExecutionManager.getQueuedJobs() |
java.util.Iterator<UWSJob> |
DefaultExecutionManager.getQueuedJobs()
Always returns a Null Iterator (iterator whose next() returns null and hasNext() returns false).
|
java.util.Iterator<UWSJob> |
ExecutionManager.getRunningJobs()
Gets the list of running jobs.
|
java.util.Iterator<UWSJob> |
AbstractQueuedExecutionManager.getRunningJobs() |
java.util.Iterator<UWSJob> |
DefaultExecutionManager.getRunningJobs() |
Modifier and Type | Method and Description |
---|---|
int |
DefaultDestructionManager.TimeComparator.compare(UWSJob job1,
UWSJob job2) |
protected void |
DefaultDestructionManager.destroyJob(UWSJob job)
Merely destroys the given job
(if not NULL and not
ARCHIVED ). |
ExecutionPhase |
ExecutionManager.execute(UWSJob job)
Lets deciding whether the given job can start immediately or whether it must be put in the queue.
|
ExecutionPhase |
AbstractQueuedExecutionManager.execute(UWSJob jobToExecute)
Refreshes this manager and then put the given job into the queue (if
it is not already into it).
|
ExecutionPhase |
DefaultExecutionManager.execute(UWSJob jobToExecute) |
boolean |
QueuedExecutionManager.isReadyForExecution(UWSJob jobToExecute) |
abstract boolean |
AbstractQueuedExecutionManager.isReadyForExecution(UWSJob jobToExecute)
Tells whether the given job can be executed NOW.
|
void |
DefaultDestructionManager.remove(UWSJob job)
Merely removes the given job from the list of jobs to destroyed.
|
void |
DestructionManager.remove(UWSJob job)
Removes the given job from this manager.
|
void |
ExecutionManager.remove(UWSJob jobToRemove)
Removes the job from this manager whatever is its current execution phase.
|
void |
AbstractQueuedExecutionManager.remove(UWSJob jobToRemove)
Removes the given job from the lists of queued and running jobs and
then refreshes the manager.
|
void |
DefaultExecutionManager.remove(UWSJob jobToRemove) |
protected void |
AbstractQueuedExecutionManager.startJob(UWSJob jobToStartNow)
Starts immediately the given job.
|
void |
DefaultDestructionManager.update(UWSJob job)
This function does something only if the given job knows its jobs list
and has a valid destruction time.
|
void |
DestructionManager.update(UWSJob job)
Updates the list of jobs to destroy with the given job.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
XMLSerializer.getAdditionalParameters(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getAdditionalParameters(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getAdditionalParameters(UWSJob job,
boolean root)
Serializes the parameters of the given job.
|
java.lang.String |
XMLSerializer.getCreationTime(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getCreationTime(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getCreationTime(UWSJob job,
boolean root)
Serializes the creation date/time of the given job.
|
java.lang.String |
XMLSerializer.getDestructionTime(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getDestructionTime(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getDestructionTime(UWSJob job,
boolean root)
Serializes the destruction time of the given job.
|
java.lang.String |
XMLSerializer.getEndTime(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getEndTime(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getEndTime(UWSJob job,
boolean root)
Serializes the end time of the given job.
|
java.lang.String |
XMLSerializer.getExecutionDuration(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getExecutionDuration(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getExecutionDuration(UWSJob job,
boolean root)
Serializes the execution duration of the given job.
|
java.lang.String |
XMLSerializer.getJob(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getJob(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getJob(UWSJob job,
boolean root)
Serializes the whole given job.
|
java.lang.String |
UWSSerializer.getJob(UWSJob job,
java.lang.String[] attributes,
boolean root)
Serializes the given parameter of the given job
or serializes the whole job if the given attributes array is empty or null.
|
java.lang.String |
XMLSerializer.getJobID(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getJobID(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getJobID(UWSJob job,
boolean root)
Serializes the ID of the given job.
|
java.lang.String |
XMLSerializer.getJobInfo(UWSJob job)
Serialize into XML the
JobInfo of the given job, if any. |
java.lang.String |
XMLSerializer.getJobRef(UWSJob job,
UWSUrl jobsListUrl) |
java.lang.String |
JSONSerializer.getJobRef(UWSJob job,
UWSUrl jobsListUrl) |
abstract java.lang.String |
UWSSerializer.getJobRef(UWSJob job,
UWSUrl jobsListUrl)
Serializes just a reference on the given job.
|
java.lang.String |
XMLSerializer.getOwnerID(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getOwnerID(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getOwnerID(UWSJob job,
boolean root)
Serializes the owner ID of the given job.
|
java.lang.String |
XMLSerializer.getPhase(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getPhase(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getPhase(UWSJob job,
boolean root)
Serializes the phase of the given job.
|
java.lang.String |
XMLSerializer.getQuote(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getQuote(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getQuote(UWSJob job,
boolean root)
Serializes the quote of the given job.
|
java.lang.String |
XMLSerializer.getResults(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getResults(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getResults(UWSJob job,
boolean root)
Serializes the results of the given job.
|
java.lang.String |
XMLSerializer.getRunID(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getRunID(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getRunID(UWSJob job,
boolean root)
Serializes the run ID of the given job.
|
java.lang.String |
XMLSerializer.getStartTime(UWSJob job,
boolean root) |
java.lang.String |
JSONSerializer.getStartTime(UWSJob job,
boolean root) |
abstract java.lang.String |
UWSSerializer.getStartTime(UWSJob job,
boolean root)
Serializes the start time of the given job.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.List<UWSJob> |
JobListRefiner.jobList
List of retained jobs after filtering.
|
protected java.util.Comparator<UWSJob> |
JobListRefiner.sortComp
Indicate how jobs must be sorted in the
JobListRefiner.jobList list. |
Modifier and Type | Method and Description |
---|---|
UWSJob |
JobListRefiner.TopIterator.next() |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<UWSJob> |
JobListRefiner.refine(java.util.Iterator<UWSJob> jobList)
Filter (and eventually sort and/or limit in size) the given list of jobs.
|
Modifier and Type | Method and Description |
---|---|
protected void |
JobListRefiner.addJob(UWSJob job)
Add the given job in the temporary internal list of filtered jobs by
preserving the specified sorting.
|
int |
JobListRefiner.JobComparator.compare(UWSJob o1,
UWSJob o2) |
boolean |
JobFilter.match(UWSJob job)
Tell whether the given job match this filter.
|
boolean |
AfterFilter.match(UWSJob job) |
boolean |
PhasesFilter.match(UWSJob job) |
protected boolean |
JobListRefiner.match(UWSJob job)
Tell whether the given job matches all the job filters.
|
boolean |
NoArchivedFilter.match(UWSJob job) |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<UWSJob> |
JobListRefiner.refine(java.util.Iterator<UWSJob> jobList)
Filter (and eventually sort and/or limit in size) the given list of jobs.
|
Constructor and Description |
---|
TopIterator(java.util.List<UWSJob> joblist,
int topSize,
boolean reverse)
Create an iterator which will read the
topSize first
item of the given list. |
Modifier and Type | Method and Description |
---|---|
boolean |
JobOwner.hasExecutePermission(UWSJob job)
Tells whether this user has the right to execute and to abort the given job.
|
boolean |
DefaultJobOwner.hasExecutePermission(UWSJob job)
By default: ONLY owners of the given job have the EXECUTE permission.
|
boolean |
JobOwner.hasReadPermission(UWSJob job)
Tells whether this user has the right to read all parameters, errors and results of the given job.
|
boolean |
DefaultJobOwner.hasReadPermission(UWSJob job)
By default: ONLY owners of the given job have the READ permission.
|
boolean |
JobOwner.hasWritePermission(UWSJob job)
Tells whether this user has the right to destroy the given job and to change the value of its parameters.
|
boolean |
DefaultJobOwner.hasWritePermission(UWSJob job)
By default: ONLY owners of the given job have the WRITE permission.
|
Modifier and Type | Method and Description |
---|---|
UWSJob |
UWSServlet.createJob(javax.servlet.http.HttpServletRequest request,
JobOwner user) |
UWSJob |
UWSFactory.createJob(javax.servlet.http.HttpServletRequest request,
JobOwner user)
Creates a (PENDING) UWS job from the given HTTP request.
|
UWSJob |
AbstractUWSFactory.createJob(javax.servlet.http.HttpServletRequest request,
JobOwner user) |
UWSJob |
UWSServlet.createJob(java.lang.String jobID,
long creationTime,
JobOwner owner,
UWSParameters params,
long quote,
long startTime,
long endTime,
java.util.List<Result> results,
ErrorSummary error) |
UWSJob |
UWSFactory.createJob(java.lang.String jobID,
long creationTime,
JobOwner owner,
UWSParameters params,
long quote,
long startTime,
long endTime,
java.util.List<Result> results,
ErrorSummary error)
Creates a UWS job with the following attributes.
|
UWSJob |
AbstractUWSFactory.createJob(java.lang.String jobID,
long creationTime,
JobOwner owner,
UWSParameters params,
long quote,
long startTime,
long endTime,
java.util.List<Result> results,
ErrorSummary error) |
UWSJob |
UWSServlet.getJob(UWSUrl requestUrl) |
UWSJob |
UWSServlet.getJob(UWSUrl requestUrl,
JobOwner user) |
Modifier and Type | Method and Description |
---|---|
JobThread |
UWSFactory.createJobThread(UWSJob jobDescription)
Creates the thread which will executes the task described by the given
UWSJob instance. |
Modifier and Type | Method and Description |
---|---|
protected UWSJob |
UWSAction.getJob(UWSUrl urlInterpreter)
Extracts the job ID from the given UWS URL
and gets the corresponding job from the UWS.
|
protected UWSJob |
UWSAction.getJob(UWSUrl urlInterpreter,
JobList jobsList)
Extracts the job ID from the given UWS URL and gets the corresponding job from the given jobs list.
|
protected UWSJob |
UWSAction.getJob(UWSUrl urlInterpreter,
JobList jobsList,
JobOwner user)
Extracts the job ID from the given UWS URL and gets the corresponding job from the given jobs list.
|
protected UWSJob |
UWSAction.getJob(UWSUrl urlInterpreter,
JobOwner user)
Extracts the job ID from the given UWS URL and gets the corresponding job from the UWS.
|
Modifier and Type | Method and Description |
---|---|
static void |
JobSummary.block(BlockingPolicy policy,
javax.servlet.http.HttpServletRequest req,
UWSJob job,
JobOwner user)
Block the current thread until the specified duration (in seconds) is
elapsed or if the execution phase of the target job changes.
|
boolean |
GetJobParam.isDefaultUrl(Result result,
UWSJob job)
Tells whether the URL of this Result is the default one.
|
Modifier and Type | Method and Description |
---|---|
protected org.json.JSONObject |
DefaultUWSBackupManager.getJSONJob(UWSJob job,
java.lang.String jlName)
Serializes the given job into a JSON object.
|
protected void |
DefaultUWSBackupManager.restoreOtherJobParams(org.json.JSONObject json,
UWSJob job)
Restores other job parameters, either from the given JSON object or from the parameters map of the given job.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceErrorWriter.writeError(java.lang.Throwable t,
ErrorSummary error,
UWSJob job,
java.io.OutputStream output)
Write the given error in the given output stream.
|
void |
DefaultUWSErrorWriter.writeError(java.lang.Throwable t,
ErrorSummary error,
UWSJob job,
java.io.OutputStream output) |
Modifier and Type | Method and Description |
---|---|
boolean |
LocalUWSFileManager.deleteError(ErrorSummary error,
UWSJob job) |
boolean |
UWSFileManager.deleteError(ErrorSummary error,
UWSJob job)
Deletes the error file corresponding to the given job error summary.
|
boolean |
LocalUWSFileManager.deleteResult(Result result,
UWSJob job) |
boolean |
UWSFileManager.deleteResult(Result result,
UWSJob job)
Deletes the result file corresponding to the given job result's
description.
|
protected java.io.File |
LocalUWSFileManager.getErrorFile(ErrorSummary error,
UWSJob job)
Gets the file corresponding to the described error.
|
protected java.lang.String |
LocalUWSFileManager.getErrorFileName(ErrorSummary error,
UWSJob job)
Gets the name of the file in which the described error is/must be written.
|
java.io.InputStream |
LocalUWSFileManager.getErrorInput(ErrorSummary error,
UWSJob job) |
java.io.InputStream |
UWSFileManager.getErrorInput(ErrorSummary error,
UWSJob job)
Gets an input stream on the error file corresponding to the given error
and job.
|
java.io.OutputStream |
LocalUWSFileManager.getErrorOutput(ErrorSummary error,
UWSJob job) |
java.io.OutputStream |
UWSFileManager.getErrorOutput(ErrorSummary error,
UWSJob job)
Gets an output stream on the error file corresponding to the given error
and job.
|
long |
LocalUWSFileManager.getErrorSize(ErrorSummary error,
UWSJob job) |
long |
UWSFileManager.getErrorSize(ErrorSummary error,
UWSJob job)
Gets the size of the specified error summary file.
|
protected java.io.File |
LocalUWSFileManager.getResultFile(Result result,
UWSJob job)
Gets the file corresponding to the given result.
|
protected java.lang.String |
LocalUWSFileManager.getResultFileName(Result result,
UWSJob job)
Gets the name of the file in which the given result is/must be written.
|
java.io.InputStream |
LocalUWSFileManager.getResultInput(Result result,
UWSJob job) |
java.io.InputStream |
UWSFileManager.getResultInput(Result result,
UWSJob job)
Gets an input stream on the result file corresponding to the given job
result.
|
java.io.OutputStream |
LocalUWSFileManager.getResultOutput(Result result,
UWSJob job) |
java.io.OutputStream |
UWSFileManager.getResultOutput(Result result,
UWSJob job)
Gets an output stream on the result file corresponding to the given job
result.
|
long |
LocalUWSFileManager.getResultSize(Result result,
UWSJob job) |
long |
UWSFileManager.getResultSize(Result result,
UWSJob job)
Gets the size of the specified result file.
|
java.lang.String |
LocalUWSFileManager.moveUpload(UploadFile upload,
UWSJob destination) |
java.lang.String |
UWSFileManager.moveUpload(UploadFile upload,
UWSJob destination)
Move the specified file from its current location to a location related
to the given job.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultUWSLog.logJob(UWSLog.LogLevel level,
UWSJob job,
java.lang.String event,
java.lang.String message,
java.lang.Throwable error) |
void |
Slf4jUWSLog.logJob(UWSLog.LogLevel level,
UWSJob job,
java.lang.String event,
java.lang.String message,
java.lang.Throwable error) |
void |
UWSLog.logJob(UWSLog.LogLevel level,
UWSJob job,
java.lang.String event,
java.lang.String message,
java.lang.Throwable error)
Log a message and/or an error in the JOB context.
|
Modifier and Type | Field and Description |
---|---|
protected UWSJob |
UploadFile.owner
Jobs that owns this uploaded file.
|
Modifier and Type | Method and Description |
---|---|
UWSJob |
UploadFile.getOwner()
Get the job that uses this uploaded file.
|
Modifier and Type | Method and Description |
---|---|
void |
UploadFile.move(UWSJob destination)
Move this uploaded file in a location related to the given
UWSJob . |
Modifier and Type | Method and Description |
---|---|
long |
LimitedBlockingPolicy.block(java.lang.Thread thread,
long userDuration,
UWSJob job,
JobOwner user,
javax.servlet.http.HttpServletRequest request) |
long |
UserLimitedBlockingPolicy.block(java.lang.Thread thread,
long userDuration,
UWSJob job,
JobOwner user,
javax.servlet.http.HttpServletRequest request) |
long |
BlockingPolicy.block(java.lang.Thread thread,
long userDuration,
UWSJob job,
JobOwner user,
javax.servlet.http.HttpServletRequest request)
Notify this
BlockingPolicy that the given thread is going to
be blocked for the specified duration. |
protected java.lang.String |
UserLimitedBlockingPolicy.buildKey(UWSJob job,
JobOwner user,
javax.servlet.http.HttpServletRequest request)
Build the key for the map
UserLimitedBlockingPolicy.blockedThreads . |
void |
LimitedBlockingPolicy.unblocked(java.lang.Thread unblockedThread,
UWSJob job,
JobOwner user,
javax.servlet.http.HttpServletRequest request) |
void |
UserLimitedBlockingPolicy.unblocked(java.lang.Thread unblockedThread,
UWSJob job,
JobOwner user,
javax.servlet.http.HttpServletRequest request) |
void |
BlockingPolicy.unblocked(java.lang.Thread unblockedThread,
UWSJob job,
JobOwner user,
javax.servlet.http.HttpServletRequest request)
Notify this
BlockingPolicy that the given thread is not blocked
anymore. |
void |
WaitObserver.update(UWSJob job,
ExecutionPhase oldPhase,
ExecutionPhase newPhase) |