org.globus.cog.abstraction.impl.file
Class TaskHandlerImpl

java.lang.Object
  org.globus.cog.abstraction.impl.file.TaskHandlerImpl

All Implemented Interfaces:

StatusListener, TaskHandler

Direct Known Subclasses:

CachingDelegatedFileOperationHandler

public class TaskHandlerImpl

extends Object

implements TaskHandler, StatusListener

The base class for task handlers in all file providers

Field Summary

Fields inherited from interface org.globus.cog.abstraction.interfaces.TaskHandler

EXECUTION, FILE_OPERATION, FILE_TRANSFER, GENERIC

Constructor Summary

TaskHandlerImpl()

Method Summary

void	addValidCommands() Add a list of valid commands to a vector
void	cancel(Task task) cancel a task
protected Object	execute(FileResource fileResource, FileOperationSpecification spec) execute the command on the file resource.
Collection	getActiveTasks() return a collection of active tasks
Collection	getAllTasks() return a collection of all tasks submitted to the handler
Collection	getCanceledTasks() return a collection of canceled tasks
Collection	getCompletedTasks() return a collection of completed tasks
Collection	getFailedTasks() return a collection of failed tasks
protected FileResource	getResource()
Collection	getResumedTasks() return a collection of resumed tasks
Collection	getSuspendedTasks() return a collection of suspended tasks
int	getType() return type of task handler
boolean	isValidSpecification(FileOperationSpecification spec) is the specification valid
void	remove(Task task) remove a task completely
void	resume(Task task) resume a task
void	setType(int type) set type of task handler
void	statusChanged(StatusEvent event) listen to the status changes of the task
void	submit(Task task) submit the task for execution.
void	submit(Task task, FileResource fileResource) submit task to the appropriate file resource to carry out the operation.
void	suspend(Task task) Suspend a task

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskHandlerImpl

public TaskHandlerImpl()

Method Detail

setType

public void setType(int type)

set type of task handler

Specified by:

setType in interface TaskHandler

Parameters:

type - an integer representing the type of TaskHandler. Valid options are TaskHandler.GENERIC, TaskHandler.EXECUTION, TaskHandler.FILE_OPERATION, and TaskHandler.FILE_TRANSFER

getType

public int getType()

return type of task handler

Specified by:

getType in interface TaskHandler

submit

public void submit(Task task)
            throws IllegalSpecException,
                   InvalidSecurityContextException,
                   InvalidServiceContactException,
                   TaskSubmissionException

submit the task for execution. Synchronized because additions and deletions are made to the same data resource

Specified by:

submit in interface TaskHandler

Parameters:

task - the Task to be submitted

Throws:

InvalidServiceContactException - when the ServiceContactassociated with the task is invalid

TaskSubmissionException - when generic errors occur during task submission

InvalidSecurityContextException - when the SecurityContextassociated with the task is invalid

IllegalSpecException - when the Specificationassociated with the task is illegal

submit

public void submit(Task task,
                   FileResource fileResource)
            throws TaskSubmissionException,
                   IllegalSpecException,
                   InvalidProviderException,
                   ProviderMethodException,
                   IllegalHostException,
                   InvalidSecurityContextException,
                   DirectoryNotFoundException,
                   FileNotFoundException,
                   GeneralException

submit task to the appropriate file resource to carry out the operation. Called from submit(Task)

Throws:

TaskSubmissionException

IllegalSpecException

InvalidProviderException

ProviderMethodException

InvalidSecurityContextException

IllegalHostException

GeneralException

FileNotFoundException

DirectoryNotFoundException

execute

protected Object execute(FileResource fileResource,
                         FileOperationSpecification spec)
                  throws DirectoryNotFoundException,
                         FileNotFoundException,
                         GeneralException

execute the command on the file resource. Called from submit(Task, FileResource)

Throws:

GeneralException

DirectoryNotFoundException

GeneralException

FileNotFoundException

isValidSpecification

public boolean isValidSpecification(FileOperationSpecification spec)

is the specification valid

suspend

public void suspend(Task task)
             throws InvalidSecurityContextException,
                    TaskSubmissionException

Suspend a task

Specified by:

suspend in interface TaskHandler

Parameters:

task - the Task to be suspended

Throws:

TaskSubmissionException - when generic errors occur

InvalidSecurityContextException - when the SecurityContextassociated with the task is invalid

resume

public void resume(Task task)
            throws InvalidSecurityContextException,
                   TaskSubmissionException

resume a task

Specified by:

resume in interface TaskHandler

Parameters:

task - the Task to be resumed

Throws:

TaskSubmissionException - when generic errors occur

InvalidSecurityContextException - when the SecurityContextassociated with the task is invalid

cancel

public void cancel(Task task)
            throws InvalidSecurityContextException,
                   TaskSubmissionException

cancel a task

Specified by:

cancel in interface TaskHandler

Parameters:

task - the Task to be canceled

Throws:

TaskSubmissionException - when generic errors occur

InvalidSecurityContextException - when the SecurityContextassociated with the task is invalid

remove

public void remove(Task task)
            throws ActiveTaskException

remove a task completely

Specified by:

remove in interface TaskHandler

Parameters:

task - the Task object to be removed from the cache

Throws:

ActiveTaskException - when the task to be removed in an Status.ACTIVE state.

getAllTasks

public Collection getAllTasks()

return a collection of all tasks submitted to the handler

Specified by:

getAllTasks in interface TaskHandler

Returns:

a collection of Taskobjects

getActiveTasks

public Collection getActiveTasks()

return a collection of active tasks

Specified by:

getActiveTasks in interface TaskHandler

Returns:

a collection of Taskobjects

getFailedTasks

public Collection getFailedTasks()

return a collection of failed tasks

Specified by:

getFailedTasks in interface TaskHandler

Returns:

a collection of Taskobjects

getCompletedTasks

public Collection getCompletedTasks()

return a collection of completed tasks

Specified by:

getCompletedTasks in interface TaskHandler

Returns:

a collection of Taskobjects

getSuspendedTasks

public Collection getSuspendedTasks()

return a collection of suspended tasks

Specified by:

getSuspendedTasks in interface TaskHandler

Returns:

a collection of Taskobjects

getResumedTasks

public Collection getResumedTasks()

return a collection of resumed tasks

Specified by:

getResumedTasks in interface TaskHandler

Returns:

a collection of Taskobjects

getCanceledTasks

public Collection getCanceledTasks()

return a collection of canceled tasks

Specified by:

getCanceledTasks in interface TaskHandler

Returns:

a collection of Taskobjects

statusChanged

public void statusChanged(StatusEvent event)

listen to the status changes of the task

Specified by:

statusChanged in interface StatusListener

addValidCommands

public void addValidCommands()

Add a list of valid commands to a vector

getResource

protected FileResource getResource()