Public Member Functions
	ReducingHandler (const Poco::SharedPtr< ReducingPartsCountersStorageIf > &reducingPartsCountersStorage, const Poco::SharedPtr< ReduceAdditionsStorageIf > &reduceAdditionsStorage, const Poco::SharedPtr< TaskReducersManagerFactoryIf > &taskReducersManagerFactory, const Poco::SharedPtr< ReducingOutputMessageBuilderIf > &reducingOutputMessageBuilder, const Poco::SharedPtr< SupportNotifierIf > &supportNotifier)
virtual	~ReducingHandler ()
void	accumulateReducingData (unsigned long long itemId, Poco::SharedPtr< reduce_types::ReducingInputMessage > &reducingInputMessage)
Poco::SharedPtr < reduce_types::ReducingOutputMessage >	makeReducing (unsigned long long itemId)
void	deleteReducingTaskBy (unsigned long long itemId)
int	getAccumulateReducingPartsNumberBy (unsigned long long itemId)
unsigned int	getTasksNumber ()
bool	isTaskTerminatedByTTL (unsigned long long taskId) const
bool	isTaskExpired (unsigned long long taskId, unsigned int ttl=USE_TASK_TTL_VALUE)
int	cleanupExpiredTasksByTTL (unsigned int maxRemoveTasks=1, unsigned int ttl=USE_TASK_TTL_VALUE)
unsigned int	cleanupExpiredTasksByTTLQueue (unsigned int maxRemoveItems, unsigned int minTerminateTime)
void	getExceededTTLTasks (unsigned int maxTaskNumber, std::vector< unsigned long long > &exceededTTLTasks, unsigned int ttl=USE_TASK_TTL_VALUE) const

Detailed Description

Definition at line 30 of file ReducingHandler.hpp.

Constructor & Destructor Documentation

HCE::reduce::ReducingHandler::ReducingHandler	(	const Poco::SharedPtr< ReducingPartsCountersStorageIf > &	reducingPartsCountersStorage,
		const Poco::SharedPtr< ReduceAdditionsStorageIf > &	reduceAdditionsStorage,
		const Poco::SharedPtr< TaskReducersManagerFactoryIf > &	taskReducersManagerFactory,
		const Poco::SharedPtr< ReducingOutputMessageBuilderIf > &	reducingOutputMessageBuilder,
		const Poco::SharedPtr< SupportNotifierIf > &	supportNotifier
	)

Definition at line 6 of file ReducingHandler.cpp.

HCE::reduce::ReducingHandler::~ReducingHandler ( )

virtual

Definition at line 20 of file ReducingHandler.cpp.

void HCE::reduce::ReducingHandler::accumulateReducingData	(	unsigned long long	itemId,
		Poco::SharedPtr< reduce_types::ReducingInputMessage > &	reducingInputMessage
	)

Definition at line 22 of file ReducingHandler.cpp.

Here is the call graph for this function:

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

Definition at line 93 of file ReducingHandler.cpp.

Here is the call graph for this function:

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

Definition at line 99 of file ReducingHandler.cpp.

Here is the call graph for this function:

void HCE::reduce::ReducingHandler::deleteReducingTaskBy ( unsigned long long itemId )

Definition at line 61 of file ReducingHandler.cpp.

int HCE::reduce::ReducingHandler::getAccumulateReducingPartsNumberBy ( unsigned long long itemId )

Definition at line 73 of file ReducingHandler.cpp.

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