org.globus.cog.abstraction.impl.execution.condor
Class TaskHandlerImpl

java.lang.Object
  org.globus.cog.abstraction.impl.execution.condor.TaskHandlerImpl

All Implemented Interfaces:

StatusListener, TaskHandler

public class TaskHandlerImpl

extends Object

implements TaskHandler, StatusListener

Provides a condor TaskHandler for job submission to a condor submit machine without any security context.

Field Summary

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

EXECUTION, FILE_OPERATION, FILE_TRANSFER, GENERIC

Constructor Summary

TaskHandlerImpl()

Method Summary

void	cancel(Task task)
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
Collection	getResumedTasks() return a collection of resumed tasks
Collection	getSuspendedTasks() return a collection of suspended tasks
int	getType()
void	remove(Task task)
void	resume(Task task)
void	setType(int type)
void	statusChanged(StatusEvent event)
void	submit(Task task)
void	suspend(Task 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)

Specified by:

setType in interface TaskHandler

getType

public int getType()

Specified by:

getType in interface TaskHandler

submit

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

Specified by:

submit in interface TaskHandler

Throws:

IllegalSpecException

InvalidSecurityContextException

InvalidServiceContactException

TaskSubmissionException

suspend

public void suspend(Task task)
             throws InvalidSecurityContextException,
                    TaskSubmissionException

Specified by:

suspend in interface TaskHandler

Throws:

InvalidSecurityContextException

TaskSubmissionException

resume

public void resume(Task task)
            throws InvalidSecurityContextException,
                   TaskSubmissionException

Specified by:

resume in interface TaskHandler

Throws:

InvalidSecurityContextException

TaskSubmissionException

cancel

public void cancel(Task task)
            throws InvalidSecurityContextException,
                   TaskSubmissionException

Specified by:

cancel in interface TaskHandler

Throws:

InvalidSecurityContextException

TaskSubmissionException

remove

public void remove(Task task)
            throws ActiveTaskException

Specified by:

remove in interface TaskHandler

Throws:

ActiveTaskException

getAllTasks

public Collection getAllTasks()

return a collection of all tasks submitted to the handler

Specified by:

getAllTasks in interface TaskHandler

getActiveTasks

public Collection getActiveTasks()

return a collection of active tasks

Specified by:

getActiveTasks in interface TaskHandler

getFailedTasks

public Collection getFailedTasks()

return a collection of failed tasks

Specified by:

getFailedTasks in interface TaskHandler

getCompletedTasks

public Collection getCompletedTasks()

return a collection of completed tasks

Specified by:

getCompletedTasks in interface TaskHandler

getSuspendedTasks

public Collection getSuspendedTasks()

return a collection of suspended tasks

Specified by:

getSuspendedTasks in interface TaskHandler

getResumedTasks

public Collection getResumedTasks()

return a collection of resumed tasks

Specified by:

getResumedTasks in interface TaskHandler

getCanceledTasks

public Collection getCanceledTasks()

return a collection of canceled tasks

Specified by:

getCanceledTasks in interface TaskHandler

statusChanged

public void statusChanged(StatusEvent event)

Specified by:

statusChanged in interface StatusListener