Package cz.metacentrum.perun.core.blImpl

Class TasksManagerBlImpl

java.lang.Object

cz.metacentrum.perun.core.blImpl.TasksManagerBlImpl

All Implemented Interfaces:

TasksManagerBl

public class TasksManagerBlImpl
extends Object
implements TasksManagerBl

TasksManagerBlImpl

Field Summary

Fields

Modifier and Type	Field	Description
protected PerunBl	perun
protected TasksManagerImplApi	tasksManagerImpl

Constructor Summary

Constructors

Constructor	Description
TasksManagerBlImpl(TasksManagerImplApi tasksManagerImpl)

Method Summary

Modifier and Type	Method	Description
int	countTasks()	Get number of tasks in DB.
int	deleteAllTaskResults(PerunSession sess)	Delete all TaskResults
int	deleteOldTaskResults(PerunSession sess, int numDays)	Delete all TaskResults older than specified number of days
void	deleteTask(PerunSession sess, Task task)	Delete Task and it's TaskResults.
void	deleteTaskResultById(PerunSession sess, int taskResultId)	Delete TaskResults by its ID
int	deleteTaskResults(PerunSession sess, int taskId)	Delete all TaskResults for the particular Task
int	deleteTaskResults(PerunSession sess, int taskId, int destinationId)	Delete all TaskResults for the particular Task and Destination.
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
PerunBl	getPerunBl()
List<ResourceState>	getResourcesState(PerunSession session, Vo vo)	Returns list of ResourceStates for VO.
ServicesManagerBl	getServicesManagerBl()
Task	getTask(PerunSession perunSession, Service service, Facility facility)	Find propagation task for given service and facility.
Task	getTaskById(PerunSession perunSession, int id)	Retrieve task given its id.
TaskResult	getTaskResultById(PerunSession sess, int taskResultId)	Retrieve all task results for given task (by task id)
List<TaskResult>	getTaskResults(PerunSession sess)	Retrieve all task results from DB.
List<TaskResult>	getTaskResultsByDestinations(PerunSession session, List<String> destinationsNames)	Returns task results for defined destinations (string representation).
List<TaskResult>	getTaskResultsByTask(PerunSession sess, int taskId)	Retrieve all tasks results for given task
List<TaskResult>	getTaskResultsByTaskAndDestination(PerunSession sess, int taskId, int destinationId)	List newest TaskResults tied to a certain task and destination
List<TaskResult>	getTaskResultsByTaskOnlyNewest(PerunSession sess, int taskId)	List newest TaskResults tied to a certain task
TasksManagerImplApi	getTasksManagerImpl()
int	insertNewTaskResult(PerunSession sess, TaskResult taskResult)	Insert TaskResult into DB.
int	insertTask(PerunSession sess, Task task)	Insert Task into DB.
boolean	isSuspendedTasksPropagation()	Check if propagating tasks to engine is suspended.
boolean	isSuspendedTasksPropagationPersistently()	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 sess, Service service, Facility facility)	Check if there is a task for given service and facility.
List<Task>	listAllTasks(PerunSession perunSession)	Retrieve all tasks from DB.
List<Task>	listAllTasksForFacility(PerunSession session, int facilityId)	Returns all tasks associated with selected facility.
List<Task>	listAllTasksForService(PerunSession sess, int serviceId)	Returns all tasks associated with given service.
List<Task>	listAllTasksInState(PerunSession perunSession, Task.TaskStatus state)	Retrieve all tasks in given state.
List<Task>	listAllTasksNotInState(PerunSession sess, Task.TaskStatus state)	Retrieve all tasks that are not in given state.
void	removeAllTasksForService(PerunSession sess, Service service)	Removes all tasks associated with given service including the associated task results
void	removeTask(PerunSession sess, int id)	Remove task with given id.
void	removeTask(PerunSession sess, Service service, Facility facility)	Remove task for given service and facility.
Task	retrieveRunIdForTask(PerunSession sess, Task task)	Retrieves a new run id for the task propagation.
void	setPerunBl(PerunBlImpl perunBl)
void	setServicesManagerBl(ServicesManagerBl servicesManagerBl)
void	suspendTasksPropagation(PerunSession perunSession, boolean suspend, boolean persistently)	Suspend propagating tasks to engine.
void	updateTask(PerunSession sess, Task task)	Update DB record for given task.

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

tasksManagerImpl

@Autowired
protected TasksManagerImplApi tasksManagerImpl

Constructor Details

TasksManagerBlImpl

public TasksManagerBlImpl(TasksManagerImplApi tasksManagerImpl)

Method Details

countTasks

public int countTasks()

Description copied from interface: TasksManagerBl

Get number of tasks in DB.

Specified by:

countTasks in interface TasksManagerBl

Returns:

int number of tasks

deleteAllTaskResults

public int deleteAllTaskResults(PerunSession sess)

Description copied from interface: TasksManagerBl

Delete all TaskResults

Specified by:

deleteAllTaskResults in interface TasksManagerBl

Returns:

number of deleted TaskResults

deleteOldTaskResults

public int deleteOldTaskResults(PerunSession sess,
 int numDays)

Description copied from interface: TasksManagerBl

Delete all TaskResults older than specified number of days

Specified by:

deleteOldTaskResults in interface TasksManagerBl

Parameters:

numDays - Number of days to keep

Returns:

number of deleted TaskResults

deleteTask

public void deleteTask(PerunSession sess,
 Task task)

Description copied from interface: TasksManagerBl

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

Specified by:

deleteTask in interface TasksManagerBl

Parameters:

sess - PerunSession

task - Task to delete

deleteTaskResultById

public void deleteTaskResultById(PerunSession sess,
 int taskResultId)

Description copied from interface: TasksManagerBl

Delete TaskResults by its ID

Specified by:

deleteTaskResultById in interface TasksManagerBl

Parameters:

taskResultId - ID of TaskResult to delete

deleteTaskResults

public int deleteTaskResults(PerunSession sess,
 int taskId)

Description copied from interface: TasksManagerBl

Delete all TaskResults for the particular Task

Specified by:

deleteTaskResults in interface TasksManagerBl

Parameters:

taskId - ID of Task to delete TaskResults

Returns:

number of deleted TaskResults

deleteTaskResults

public int deleteTaskResults(PerunSession sess,
 int taskId,
 int destinationId)

Description copied from interface: TasksManagerBl

Delete all TaskResults for the particular Task and Destination.

Specified by:

deleteTaskResults in interface TasksManagerBl

Parameters:

taskId - ID of Task to delete TaskResults

destinationId - ID of Destination to delete TaskResults

Returns:

number of deleted TaskResults

getAllFacilitiesStates

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

Description copied from interface: TasksManagerBl

Return propagation status of all facilities in Perun

Specified by:

getAllFacilitiesStates in interface TasksManagerBl

Parameters:

session - PerunSession

Returns:

all facilities propagation statuses

Throws:

FacilityNotExistsException

getAllFacilitiesStatesForVo

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

Description copied from interface: TasksManagerBl

Return propagation status of all facilities related to VO resources

Specified by:

getAllFacilitiesStatesForVo in interface TasksManagerBl

Parameters:

session - PerunSession

Returns:

all facilities propagation statuses

Throws:

VoNotExistsException

FacilityNotExistsException

getFacilityServicesState

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

Description copied from interface: TasksManagerBl

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 TasksManagerBl

Parameters:

sess -

facility -

Returns:

list of ServiceStates

getFacilityState

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

Description copied from interface: TasksManagerBl

Return propagation status of facility

Specified by:

getFacilityState in interface TasksManagerBl

Parameters:

session -

facility -

Returns:

propagation status of facility

Throws:

FacilityNotExistsException

getPerunBl

public PerunBl getPerunBl()

getResourcesState

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

Description copied from interface: TasksManagerBl

Returns list of ResourceStates for VO.

Specified by:

getResourcesState in interface TasksManagerBl

Parameters:

session - PerunSession

vo - VirtualOrganization

Returns:

list of ResourceStates

Throws:

VoNotExistsException

getServicesManagerBl

public ServicesManagerBl getServicesManagerBl()

getTask

public Task getTask(PerunSession perunSession,
 Service service,
 Facility facility)

Description copied from interface: TasksManagerBl

Find propagation task for given service and facility.

Specified by:

getTask in interface TasksManagerBl

Parameters:

perunSession -

service -

facility -

Returns:

Task

getTaskById

public Task getTaskById(PerunSession perunSession,
 int id)

Description copied from interface: TasksManagerBl

Retrieve task given its id.

Specified by:

getTaskById in interface TasksManagerBl

Parameters:

perunSession -

id -

Returns:

Task

getTaskResultById

public TaskResult getTaskResultById(PerunSession sess,
 int taskResultId)

Description copied from interface: TasksManagerBl

Retrieve all task results for given task (by task id)

Specified by:

getTaskResultById in interface TasksManagerBl

Parameters:

sess -

taskResultId -

Returns:

TaskResult

getTaskResults

public List<TaskResult> getTaskResults(PerunSession sess)

Description copied from interface: TasksManagerBl

Retrieve all task results from DB.

Specified by:

getTaskResults in interface TasksManagerBl

Parameters:

sess -

Returns:

List of TaskResult

getTaskResultsByDestinations

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

Description copied from interface: TasksManagerBl

Returns task results for defined destinations (string representation).

Specified by:

getTaskResultsByDestinations in interface TasksManagerBl

Parameters:

session -

destinationsNames -

Returns:

list of tasks results

getTaskResultsByTask

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

Description copied from interface: TasksManagerBl

Retrieve all tasks results for given task

Specified by:

getTaskResultsByTask in interface TasksManagerBl

Parameters:

sess -

taskId -

Returns:

List of TaskResult

getTaskResultsByTaskAndDestination

public List<TaskResult> getTaskResultsByTaskAndDestination(PerunSession sess,
 int taskId,
 int destinationId)

Description copied from interface: TasksManagerBl

List newest TaskResults tied to a certain task and destination

Specified by:

getTaskResultsByTaskAndDestination in interface TasksManagerBl

Parameters:

taskId -

Returns:

List of TaskResult

getTaskResultsByTaskOnlyNewest

public List<TaskResult> getTaskResultsByTaskOnlyNewest(PerunSession sess,
 int taskId)

Description copied from interface: TasksManagerBl

List newest TaskResults tied to a certain task

Specified by:

getTaskResultsByTaskOnlyNewest in interface TasksManagerBl

Parameters:

taskId -

Returns:

List of TaskResult

getTasksManagerImpl

public TasksManagerImplApi getTasksManagerImpl()

insertNewTaskResult

public int insertNewTaskResult(PerunSession sess,
 TaskResult taskResult)

Description copied from interface: TasksManagerBl

Insert TaskResult into DB.

Specified by:

insertNewTaskResult in interface TasksManagerBl

Parameters:

sess -

taskResult -

Returns:

int id of the new task result

insertTask

public int insertTask(PerunSession sess,
 Task task)

Description copied from interface: TasksManagerBl

Insert Task into DB.

Specified by:

insertTask in interface TasksManagerBl

Parameters:

sess -

task -

Returns:

int id of the inserted task

isSuspendedTasksPropagation

public boolean isSuspendedTasksPropagation()

Description copied from interface: TasksManagerBl

Check if propagating tasks to engine is suspended.

Specified by:

isSuspendedTasksPropagation in interface TasksManagerBl

Returns:

True if suspended, false if propagating

isSuspendedTasksPropagationPersistently

public boolean isSuspendedTasksPropagationPersistently()

Description copied from interface: TasksManagerBl

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 TasksManagerBl

Returns:

True if suspended in DB, false otherwise

isThereSuchTask

public boolean isThereSuchTask(PerunSession sess,
 Service service,
 Facility facility)

Description copied from interface: TasksManagerBl

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

Specified by:

isThereSuchTask in interface TasksManagerBl

Parameters:

sess -

service -

facility -

Returns:

boolean true if there is a task, false otherwise

listAllTasks

public List<Task> listAllTasks(PerunSession perunSession)

Description copied from interface: TasksManagerBl

Retrieve all tasks from DB.

Specified by:

listAllTasks in interface TasksManagerBl

Parameters:

perunSession -

Returns:

List of Task

listAllTasksForFacility

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

Description copied from interface: TasksManagerBl

Returns all tasks associated with selected facility.

Specified by:

listAllTasksForFacility in interface TasksManagerBl

Parameters:

session -

facilityId -

Returns:

all tasks for facility

listAllTasksForService

public List<Task> listAllTasksForService(PerunSession sess,
 int serviceId)

Description copied from interface: TasksManagerBl

Returns all tasks associated with given service.

Specified by:

listAllTasksForService in interface TasksManagerBl

Parameters:

serviceId -

Returns:

tasks for service

listAllTasksInState

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

Description copied from interface: TasksManagerBl

Retrieve all tasks in given state.

Specified by:

listAllTasksInState in interface TasksManagerBl

Parameters:

perunSession -

state -

Returns:

List of Task

listAllTasksNotInState

public List<Task> listAllTasksNotInState(PerunSession sess,
 Task.TaskStatus state)

Description copied from interface: TasksManagerBl

Retrieve all tasks that are not in given state.

Specified by:

listAllTasksNotInState in interface TasksManagerBl

Parameters:

sess -

state -

Returns:

List of Task

removeAllTasksForService

public void removeAllTasksForService(PerunSession sess,
 Service service)

Description copied from interface: TasksManagerBl

Removes all tasks associated with given service including the associated task results

Specified by:

removeAllTasksForService in interface TasksManagerBl

Parameters:

service -

removeTask

public void removeTask(PerunSession sess,
 int id)

Description copied from interface: TasksManagerBl

Remove task with given id.

Specified by:

removeTask in interface TasksManagerBl

Parameters:

sess -

id -

removeTask

public void removeTask(PerunSession sess,
 Service service,
 Facility facility)

Description copied from interface: TasksManagerBl

Remove task for given service and facility.

Specified by:

removeTask in interface TasksManagerBl

Parameters:

sess -

service -

facility -

setPerunBl

public void setPerunBl(PerunBlImpl perunBl)

setServicesManagerBl

public void setServicesManagerBl(ServicesManagerBl servicesManagerBl)

suspendTasksPropagation

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

Description copied from interface: TasksManagerBl

Suspend propagating tasks to engine.

Specified by:

suspendTasksPropagation in interface TasksManagerBl

Parameters:

perunSession -

suspend - True for suspending propagation, false for resuming propagation

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

updateTask

public void updateTask(PerunSession sess,
 Task task)

Description copied from interface: TasksManagerBl

Update DB record for given task.

Specified by:

updateTask in interface TasksManagerBl

Parameters:

sess -

task -

retrieveRunIdForTask

public Task retrieveRunIdForTask(PerunSession sess,
 Task task)

Description copied from interface: TasksManagerBl

Retrieves a new run id for the task propagation.

Specified by:

retrieveRunIdForTask in interface TasksManagerBl

Parameters:

sess - session

task - task to schedule

Returns:

task with updated run id