Package cz.metacentrum.perun.core.entry

Class TasksManagerEntry

java.lang.Object

cz.metacentrum.perun.core.entry.TasksManagerEntry

All Implemented Interfaces:

TasksManager

@Service("tasksManager")
public class TasksManagerEntry
extends Object
implements TasksManager

TasksManager

Field Summary

Fields

Modifier and Type	Field	Description
protected PerunBl	perun

Constructor Summary

Constructors

Constructor	Description
TasksManagerEntry()

Method Summary

Modifier and Type	Method	Description
int	countTasks()	Get number of Tasks in DB.
void	deleteTask(PerunSession sess, Task task)	Delete Task and it's TaskResults.
void	deleteTaskResultById(PerunSession sess, int taskResultId)	Delete TaskResult by its ID
void	deleteTaskResults(PerunSession sess, Task task, Destination destination)	Delete all TaskResults related to specified Task and Destination
void	deleteTaskResultsByIds(PerunSession sess, List<Integer> taskResultIds)	Delete TaskResults by their IDs.
List<FacilityState>	getAllFacilitiesStates(PerunSession session)	Return propagation status of all facilities in Perun
List<FacilityState>	getAllFacilitiesStatesForVo(PerunSession session, Vo vo)	Return propagation status of all facilities related to VO resources
List<ServiceState>	getFacilityServicesState(PerunSession sess, Facility facility)	Returns list of ServiceStates for given facility.
FacilityState	getFacilityState(PerunSession session, Facility facility)	Return propagation status of facility
List<ResourceState>	getResourcesState(PerunSession session, Vo vo)	Returns list of ResourceStates for VO.
Task	getTask(PerunSession perunSession, Service service, Facility facility)	Find Task for given Service and Facility.
Task	getTaskById(PerunSession perunSession, int id)	Retrieve Task given its id.
TaskResult	getTaskResultById(PerunSession perunSession, int taskResultId)	Get TaskResult given its id.
List<TaskResult>	getTaskResults(PerunSession perunSession)	Get all TaskResults.
List<TaskResult>	getTaskResultsByDestinations(PerunSession session, List<String> destinationsNames)	Returns task results for defined destinations (string representation).
List<TaskResult>	getTaskResultsByTask(PerunSession sess, int taskId)	Get all TaskResult's for given Task
List<TaskResult>	getTaskResultsByTaskAndDestination(PerunSession session, int taskId, int destinationId)	Find all task results for given task and destination.
List<TaskResult>	getTaskResultsByTaskOnlyNewest(PerunSession session, int taskId)	Retrieve the newest task results for given task.
boolean	isSuspendedTasksPropagationPersistently(PerunSession session)	Check if propagating tasks to engine is suspended via the DB flag CAREFUL: even if not suspended though DB, can be disabled temporarily through synced field
boolean	isThereSuchTask(PerunSession session, Service service, Facility facility)	Check if if there is a task for given service and facility.
List<Task>	listAllTasks(PerunSession perunSession)	Retrieve all task results.
List<Task>	listAllTasksForFacility(PerunSession session, int facilityId)	Returns all tasks associated with selected facility
List<Task>	listAllTasksInState(PerunSession perunSession, Task.TaskStatus state)	Retrieve all tasks in given state
void	setPerunBl(PerunBl perunBl)
void	setTasksManagerBl(TasksManagerBl tasksManagerBl)
void	suspendTasksPropagation(PerunSession perunSession, boolean suspend, boolean persistently)	Suspends tasks propagation to engine.

Methods inherited from class java.lang.Object

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

Field Details

perun

@Autowired
protected PerunBl perun

Constructor Details

TasksManagerEntry

public TasksManagerEntry()

Method Details

countTasks

public int countTasks()

Description copied from interface: TasksManager

Get number of Tasks in DB.

Specified by:

countTasks in interface TasksManager

Returns:

Number of tasks.

deleteTask

public void deleteTask(PerunSession sess,
 Task task)
                throws PrivilegeException

Description copied from interface: TasksManager

Delete Task and it's TaskResults. Use this method only before deleting whole Facility.

Specified by:

deleteTask in interface TasksManager

Parameters:

sess - PerunSession

task - Task to delete

Throws:

PrivilegeException

deleteTaskResultById

public void deleteTaskResultById(PerunSession sess,
 int taskResultId)
                          throws PrivilegeException

Description copied from interface: TasksManager

Delete TaskResult by its ID

Specified by:

deleteTaskResultById in interface TasksManager

Parameters:

sess - PerunSession

taskResultId - Id of TaskResults to be deleted

Throws:

PrivilegeException

deleteTaskResults

public void deleteTaskResults(PerunSession sess,
 Task task,
 Destination destination)
                       throws PrivilegeException

Description copied from interface: TasksManager

Delete all TaskResults related to specified Task and Destination

Specified by:

deleteTaskResults in interface TasksManager

Parameters:

sess - PerunSession

task - Task to have TaskResults deleted

destination - Destination to have TasksResults deleted

Throws:

PrivilegeException

deleteTaskResultsByIds

public void deleteTaskResultsByIds(PerunSession sess,
 List<Integer> taskResultIds)
                            throws PrivilegeException,
FacilityMismatchException

Description copied from interface: TasksManager

Delete TaskResults by their IDs. TaskResults are expected to be from the same facility.

Specified by:

deleteTaskResultsByIds in interface TasksManager

Parameters:

sess - sess

taskResultIds - list of ids

Throws:

PrivilegeException

FacilityMismatchException - when the Tasks are not from the same facility

getAllFacilitiesStates

public List<FacilityState> getAllFacilitiesStates(PerunSession session)
                                           throws FacilityNotExistsException

Description copied from interface: TasksManager

Return propagation status of all facilities in Perun

Specified by:

getAllFacilitiesStates in interface TasksManager

Parameters:

session - PerunSession

Returns:

all facilities propagation statuses

Throws:

FacilityNotExistsException

getAllFacilitiesStatesForVo

public List<FacilityState> getAllFacilitiesStatesForVo(PerunSession session,
 Vo vo)
                                                throws PrivilegeException,
VoNotExistsException,
FacilityNotExistsException

Description copied from interface: TasksManager

Return propagation status of all facilities related to VO resources

Specified by:

getAllFacilitiesStatesForVo in interface TasksManager

Parameters:

session - PerunSession

Returns:

all facilities propagation statuses

Throws:

PrivilegeException

VoNotExistsException

FacilityNotExistsException

getFacilityServicesState

public List<ServiceState> getFacilityServicesState(PerunSession sess,
 Facility facility)
                                            throws PrivilegeException,
FacilityNotExistsException

Description copied from interface: TasksManager

Returns list of ServiceStates for given facility. It lists states for all services, which are currently assigned to the facility or has any Task related to this facility.

So results are returned even when there was no previous propagation of such service or service is no longer assigned.

Specified by:

getFacilityServicesState in interface TasksManager

Parameters:

sess - PerunSession

facility -

Returns:

list of ServiceStates

Throws:

PrivilegeException

FacilityNotExistsException

getFacilityState

public FacilityState getFacilityState(PerunSession session,
 Facility facility)
                               throws PrivilegeException,
FacilityNotExistsException

Description copied from interface: TasksManager

Return propagation status of facility

Specified by:

getFacilityState in interface TasksManager

Parameters:

session -

facility -

Returns:

propagation status of facility

Throws:

PrivilegeException

FacilityNotExistsException

getResourcesState

public List<ResourceState> getResourcesState(PerunSession session,
 Vo vo)
                                      throws PrivilegeException,
VoNotExistsException

Description copied from interface: TasksManager

Returns list of ResourceStates for VO.

Specified by:

getResourcesState in interface TasksManager

Parameters:

session - PerunSession

vo - VirtualOrganization

Returns:

list of ResourceStates

Throws:

PrivilegeException

VoNotExistsException

getTask

public Task getTask(PerunSession perunSession,
 Service service,
 Facility facility)
             throws PrivilegeException,
FacilityNotExistsException,
ServiceNotExistsException

Description copied from interface: TasksManager

Find Task for given Service and Facility.

Specified by:

getTask in interface TasksManager

Parameters:

perunSession -

service -

facility -

Returns:

Throws:

PrivilegeException

FacilityNotExistsException

ServiceNotExistsException

getTaskById

public Task getTaskById(PerunSession perunSession,
 int id)
                 throws PrivilegeException

Description copied from interface: TasksManager

Retrieve Task given its id.

Specified by:

getTaskById in interface TasksManager

Parameters:

perunSession -

id -

Returns:

Task with given id

Throws:

PrivilegeException

getTaskResultById

public TaskResult getTaskResultById(PerunSession perunSession,
 int taskResultId)

Description copied from interface: TasksManager

Get TaskResult given its id.

Specified by:

getTaskResultById in interface TasksManager

Parameters:

perunSession -

taskResultId -

Returns:

TaskResult

getTaskResults

public List<TaskResult> getTaskResults(PerunSession perunSession)

Description copied from interface: TasksManager

Get all TaskResults.

Specified by:

getTaskResults in interface TasksManager

Parameters:

perunSession -

Returns:

List of TaskResult

getTaskResultsByDestinations

public List<TaskResult> getTaskResultsByDestinations(PerunSession session,
 List<String> destinationsNames)

Description copied from interface: TasksManager

Returns task results for defined destinations (string representation).

Specified by:

getTaskResultsByDestinations in interface TasksManager

Parameters:

session -

destinationsNames -

Returns:

list of tasks results

getTaskResultsByTask

public List<TaskResult> getTaskResultsByTask(PerunSession sess,
 int taskId)
                                      throws PrivilegeException

Description copied from interface: TasksManager

Get all TaskResult's for given Task

Specified by:

getTaskResultsByTask in interface TasksManager

Parameters:

sess -

taskId -

Returns:

List of TaskResult

Throws:

PrivilegeException

getTaskResultsByTaskAndDestination

public List<TaskResult> getTaskResultsByTaskAndDestination(PerunSession session,
 int taskId,
 int destinationId)
                                                    throws DestinationNotExistsException,
FacilityNotExistsException,
PrivilegeException

Description copied from interface: TasksManager

Find all task results for given task and destination.

Specified by:

getTaskResultsByTaskAndDestination in interface TasksManager

Parameters:

session -

taskId -

destinationId -

Returns:

List of TaskResult

Throws:

DestinationNotExistsException

FacilityNotExistsException

PrivilegeException

getTaskResultsByTaskOnlyNewest

public List<TaskResult> getTaskResultsByTaskOnlyNewest(PerunSession session,
 int taskId)
                                                throws PrivilegeException

Description copied from interface: TasksManager

Retrieve the newest task results for given task.

Specified by:

getTaskResultsByTaskOnlyNewest in interface TasksManager

Parameters:

session -

taskId -

Returns:

List of TaskResult

Throws:

PrivilegeException

isThereSuchTask

public boolean isThereSuchTask(PerunSession session,
 Service service,
 Facility facility)
                        throws PrivilegeException,
FacilityNotExistsException,
ServiceNotExistsException

Description copied from interface: TasksManager

Check if if there is a task for given service and facility.

Specified by:

isThereSuchTask in interface TasksManager

Parameters:

session -

service -

facility -

Returns:

true if task exists, false otherwise

Throws:

PrivilegeException

FacilityNotExistsException

ServiceNotExistsException

isSuspendedTasksPropagationPersistently

public boolean isSuspendedTasksPropagationPersistently(PerunSession session)
                                                throws PrivilegeException

Description copied from interface: TasksManager

Check if propagating tasks to engine is suspended via the DB flag CAREFUL: even if not suspended though DB, can be disabled temporarily through synced field

Specified by:

isSuspendedTasksPropagationPersistently in interface TasksManager

Returns:

True if suspended in DB, false otherwise

Throws:

PrivilegeException - insufficient rights

listAllTasks

public List<Task> listAllTasks(PerunSession perunSession)

Description copied from interface: TasksManager

Retrieve all task results.

Specified by:

listAllTasks in interface TasksManager

Parameters:

perunSession -

Returns:

List of TaskResult

listAllTasksForFacility

public List<Task> listAllTasksForFacility(PerunSession session,
 int facilityId)
                                   throws PrivilegeException

Description copied from interface: TasksManager

Returns all tasks associated with selected facility

Specified by:

listAllTasksForFacility in interface TasksManager

Parameters:

session -

facilityId -

Returns:

all tasks for facility

Throws:

PrivilegeException

listAllTasksInState

public List<Task> listAllTasksInState(PerunSession perunSession,
 Task.TaskStatus state)
                               throws PrivilegeException

Description copied from interface: TasksManager

Retrieve all tasks in given state

Specified by:

listAllTasksInState in interface TasksManager

Parameters:

perunSession -

state -

Returns:

List of Task

Throws:

PrivilegeException

setPerunBl

public void setPerunBl(PerunBl perunBl)

setTasksManagerBl

public void setTasksManagerBl(TasksManagerBl tasksManagerBl)

suspendTasksPropagation

public void suspendTasksPropagation(PerunSession perunSession,
 boolean suspend,
 boolean persistently)
                             throws PrivilegeException

Description copied from interface: TasksManager

Suspends tasks propagation to engine.

Specified by:

suspendTasksPropagation in interface TasksManager

Parameters:

perunSession -

suspend - True to suspend propagation, false to resume propagation

persistently - True for the change to persist even after Perun restart

Throws:

PrivilegeException