Public Member Functions
void	addTaskTTL (unsigned long long taskId, unsigned int ttl)
void	removeTaskTTL (unsigned long long taskId)
unsigned int	getTaskTTL (unsigned long long taskId) const
int	cleanupExpiredTasksByTTL (unsigned int maxRemoveTasks, unsigned int ttl=USE_TASK_TTL_VALUE)
bool	isTaskTerminatedByTTL (unsigned long long taskId) const
unsigned int	cleanupExpiredTasksByTTLQueue (unsigned int maxRemoveItems, unsigned int minTerminateTime)
bool	isTaskExpired (unsigned long long taskId, unsigned int ttl=USE_TASK_TTL_VALUE)
void	getExceededTTLTasks (unsigned int maxTaskNumber, std::vector< unsigned long long > &exceededTTLTasks, unsigned int ttl=0) const

Detailed Description

Definition at line 30 of file ReducingTaskTTLManager.hpp.

Member Function Documentation

void HCE::reduce::ReducingTaskTTLManager::addTaskTTL	(	unsigned long long	taskId,
		unsigned int	ttl
	)

inline

Definition at line 32 of file ReducingTaskTTLManager.hpp.

Here is the call graph for this function:

Here is the caller graph for this function:

int HCE::reduce::ReducingTaskTTLManager::cleanupExpiredTasksByTTL	(	unsigned int	maxRemoveTasks,
		unsigned int	ttl = `USE_TASK_TTL_VALUE`
	)

inline

Definition at line 69 of file ReducingTaskTTLManager.hpp.

Here is the call graph for this function:

Here is the caller graph for this function:

unsigned int HCE::reduce::ReducingTaskTTLManager::cleanupExpiredTasksByTTLQueue	(	unsigned int	maxRemoveItems,
		unsigned int	minTerminateTime
	)

inline

Definition at line 87 of file ReducingTaskTTLManager.hpp.

Here is the caller graph for this function:

void HCE::reduce::ReducingTaskTTLManager::getExceededTTLTasks	(	unsigned int	maxTaskNumber,
		std::vector< unsigned long long > &	exceededTTLTasks,
		unsigned int	ttl = `0`
	)		const