HCE::drce::DRCEAsyncTasksQueue Class Reference

#include <DRCEAsyncTasksQueue.hpp>

Public Types
typedef std::map< unsigned int, AsyncTasks >	Tasks
typedef std::map< unsigned int, std::map< unsigned int, bool > >	SubTasks
typedef AsyncTasks	SyncTasks

Public Member Functions
	DRCEAsyncTasksQueue (DRCENodeOptions &nodeOptions_, DRCENotificationExecutor &notificationExecutor_, CustomMessage &message_)
	~DRCEAsyncTasksQueue (void)
void	cancelAll (void)
void	joinAll (void)
void	startTask (Poco::Task *pTask) throw (Poco::Exception)
bool	hasTask (unsigned int taskId)
void	cancelTask (unsigned int taskId)
void	setMaxThreadCount (unsigned int threadCount)
unsigned int	getMaxThreadCount (void) const
void	makeCanceledTasks (void)
void	checkExpiredTime (void)
void	checkUsageResources (void)
AsyncTasks	getAsyncTask (unsigned int taskId)
void	setAsyncTask (const AsyncTasks &asyncTask)
void	setAsyncTask (AsyncTasks &&asyncTask)
size_t	getAsyncTasksCount (void)
bool	isExistAsyncTask (unsigned int taskId)
bool	removeAsyncTask (unsigned int taskId)
void	lockAsyncTask (unsigned int taskId)
void	lockAsyncTask (const AsyncTasks &asyncTask)
void	unlockAsyncTask (unsigned int taskId)
void	unlockAsyncTask (const AsyncTasks &asyncTask)
bool	isLockedAsyncTask (unsigned int taskId)
void	run (void)
void	terminate (void)
bool	isTerminated (void)
void	changeState (AsyncTasks &&asyncTask, DRCEResultDataItem *pResultDataItem=nullptr, const std::string &errorMessage="", unsigned int errorCode=0) throw (Poco::Exception)
void	safeChangeState (AsyncTasks &&asyncTask, DRCEResultDataItem *pResultDataItem=nullptr, const std::string &errorMessage="", unsigned int errorCode=0)
void	setTasksQueueDumpPeriod (unsigned int tasksQueueDumpPeriod_)
unsigned int	getTasksQueueDumpPeriod (void)
void	loadTasksQueue (void)
void	saveTasksQueue (void)
void	executeNotification (const std::string &json)
void	executeNotification (const DRCEResultData &resultData, DRCETaskRequest::RequestType requestType)
void	setResetErrorCodeStateNotification (bool resetErrorCodeStateNotification_)
bool	getResetErrorCodeStateNotification (void) const
DRCEResultData	getTasksAsResultData (void)
void	startCleanupTask (unsigned int taskId)
DRCETasksQueue	getCurrentTasksQueue (void)
std::string	getCurrentTasksQueueAsString (void)
void	writeToTasksLog (const std::string &delimiter, const std::string &taskStatus, const AsyncTasks &asyncTask)
AsyncTasks &	getSyncTasks (void)
void	addSubtask (unsigned int taskId, unsigned int subtaskId, bool needCleanup)
void	setSubtaskCleanup (unsigned int subtaskId, bool needCleanup)
bool	getSubtaskCleanup (unsigned int subtaskId)
void	removeSubtasks (unsigned int taskId)
void	setAllSubtaskCleanup (unsigned int taskId)
SubTasks::const_iterator	getSubtasksBegin (void)
SubTasks::const_iterator	getSubtasksEnd (void)
std::map< unsigned int, bool >	getSubtasks (unsigned int taskId)

Detailed Description

Definition at line 94 of file DRCEAsyncTasksQueue.hpp.

Member Typedef Documentation

typedef std::map<unsigned int, std::map<unsigned int, bool> > HCE::drce::DRCEAsyncTasksQueue::SubTasks

Definition at line 100 of file DRCEAsyncTasksQueue.hpp.

typedef AsyncTasks HCE::drce::DRCEAsyncTasksQueue::SyncTasks

Definition at line 101 of file DRCEAsyncTasksQueue.hpp.

typedef std::map<unsigned int, AsyncTasks> HCE::drce::DRCEAsyncTasksQueue::Tasks

Definition at line 99 of file DRCEAsyncTasksQueue.hpp.

Constructor & Destructor Documentation

HCE::drce::DRCEAsyncTasksQueue::DRCEAsyncTasksQueue	(	DRCENodeOptions &	nodeOptions_,
		DRCENotificationExecutor &	notificationExecutor_,
		CustomMessage &	message_
	)

Definition at line 167 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

HCE::drce::DRCEAsyncTasksQueue::~DRCEAsyncTasksQueue

(

void

)

Definition at line 181 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Member Function Documentation

void HCE::drce::DRCEAsyncTasksQueue::addSubtask	(	unsigned int	taskId,
		unsigned int	subtaskId,
		bool	needCleanup
	)

Definition at line 1012 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::cancelAll

(

void

)

Definition at line 190 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::cancelTask

(

unsigned int

taskId

)

Definition at line 249 of file DRCEAsyncTasksQueue.cpp.

void HCE::drce::DRCEAsyncTasksQueue::changeState	(	AsyncTasks &&	asyncTask,
		DRCEResultDataItem *	pResultDataItem = nullptr,
		const std::string &	errorMessage = "",
		unsigned int	errorCode = 0
	)		throw (Poco::Exception)

writeToTasksLog(drce_const::DRCE_TASKS_LOGGER_DELIMITER, drce_const::DRCE_TASKS_LOGGER_DELETED, asyncTask);

Definition at line 283 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::checkExpiredTime

(

void

)

<Call terminate task

Definition at line 800 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::checkUsageResources

(

void

)

Definition at line 894 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::executeNotification

(

const std::string &

json

)

Definition at line 588 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::executeNotification	(	const DRCEResultData &	resultData,
		DRCETaskRequest::RequestType	requestType
	)

Definition at line 594 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

AsyncTasks HCE::drce::DRCEAsyncTasksQueue::getAsyncTask

(

unsigned int

taskId

)

Definition at line 409 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

size_t HCE::drce::DRCEAsyncTasksQueue::getAsyncTasksCount

(

void

)

Definition at line 433 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

DRCETasksQueue HCE::drce::DRCEAsyncTasksQueue::getCurrentTasksQueue

(

void

)

Definition at line 689 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

std::string HCE::drce::DRCEAsyncTasksQueue::getCurrentTasksQueueAsString

(

void

)

Definition at line 703 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

unsigned int HCE::drce::DRCEAsyncTasksQueue::getMaxThreadCount

(

void

)

const

Definition at line 278 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

bool HCE::drce::DRCEAsyncTasksQueue::getResetErrorCodeStateNotification ( void  ) const

inline

Definition at line 156 of file DRCEAsyncTasksQueue.hpp.

Here is the caller graph for this function:

bool HCE::drce::DRCEAsyncTasksQueue::getSubtaskCleanup

(

unsigned int

subtaskId

)

Definition at line 1032 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

std::map< unsigned int, bool > HCE::drce::DRCEAsyncTasksQueue::getSubtasks

(

unsigned int

taskId

)

Definition at line 1079 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

DRCEAsyncTasksQueue::SubTasks::const_iterator HCE::drce::DRCEAsyncTasksQueue::getSubtasksBegin

(

void

)

Definition at line 1067 of file DRCEAsyncTasksQueue.cpp.

DRCEAsyncTasksQueue::SubTasks::const_iterator HCE::drce::DRCEAsyncTasksQueue::getSubtasksEnd

(

void

)

Definition at line 1073 of file DRCEAsyncTasksQueue.cpp.

AsyncTasks& HCE::drce::DRCEAsyncTasksQueue::getSyncTasks ( void  )

inline

Definition at line 166 of file DRCEAsyncTasksQueue.hpp.

DRCEResultData HCE::drce::DRCEAsyncTasksQueue::getTasksAsResultData

(

void

)

<Read current status if task exist in queue and update async task queue

Definition at line 639 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

unsigned int HCE::drce::DRCEAsyncTasksQueue::getTasksQueueDumpPeriod

(

void

)

Definition at line 518 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

bool HCE::drce::DRCEAsyncTasksQueue::hasTask

(

unsigned int

taskId

)

Definition at line 225 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

bool HCE::drce::DRCEAsyncTasksQueue::isExistAsyncTask

(

unsigned int

taskId

)

Definition at line 452 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

bool HCE::drce::DRCEAsyncTasksQueue::isLockedAsyncTask

(

unsigned int

taskId

)

Definition at line 488 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

bool HCE::drce::DRCEAsyncTasksQueue::isTerminated

(

void

)

Definition at line 506 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::joinAll

(

void

)

Definition at line 197 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::loadTasksQueue

(

void

)

Definition at line 524 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::lockAsyncTask

(

unsigned int

taskId

)

Definition at line 458 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::lockAsyncTask

(

const AsyncTasks &

asyncTask

)

Definition at line 468 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::makeCanceledTasks

(

void

)

Definition at line 946 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

bool HCE::drce::DRCEAsyncTasksQueue::removeAsyncTask

(

unsigned int

taskId

)

Definition at line 439 of file DRCEAsyncTasksQueue.cpp.

void HCE::drce::DRCEAsyncTasksQueue::removeSubtasks

(

unsigned int

taskId

)

Definition at line 1048 of file DRCEAsyncTasksQueue.cpp.

void HCE::drce::DRCEAsyncTasksQueue::run

(

void

)

Definition at line 970 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::safeChangeState	(	AsyncTasks &&	asyncTask,
		DRCEResultDataItem *	pResultDataItem = nullptr,
		const std::string &	errorMessage = "",
		unsigned int	errorCode = 0
	)

Definition at line 391 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::saveTasksQueue

(

void

)

Definition at line 572 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::setAllSubtaskCleanup

(

unsigned int

taskId

)

Definition at line 1054 of file DRCEAsyncTasksQueue.cpp.

void HCE::drce::DRCEAsyncTasksQueue::setAsyncTask

(

const AsyncTasks &

asyncTask

)

Definition at line 421 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::setAsyncTask

(

AsyncTasks &&

asyncTask

)

Definition at line 427 of file DRCEAsyncTasksQueue.cpp.

void HCE::drce::DRCEAsyncTasksQueue::setMaxThreadCount

(

unsigned int

threadCount

)

Definition at line 270 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::setResetErrorCodeStateNotification ( bool  resetErrorCodeStateNotification_ )

inline

Definition at line 155 of file DRCEAsyncTasksQueue.hpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::setSubtaskCleanup	(	unsigned int	subtaskId,
		bool	needCleanup
	)

Definition at line 1018 of file DRCEAsyncTasksQueue.cpp.

void HCE::drce::DRCEAsyncTasksQueue::setTasksQueueDumpPeriod

(

unsigned int

tasksQueueDumpPeriod_

)

Definition at line 512 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::startCleanupTask

(

unsigned int

taskId

)

Definition at line 673 of file DRCEAsyncTasksQueue.cpp.

void HCE::drce::DRCEAsyncTasksQueue::startTask

(

Poco::Task *

pTask

)

throw (Poco::Exception)

Definition at line 203 of file DRCEAsyncTasksQueue.cpp.

void HCE::drce::DRCEAsyncTasksQueue::terminate

(

void

)

Definition at line 500 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::unlockAsyncTask

(

unsigned int

taskId

)

Definition at line 473 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::unlockAsyncTask

(

const AsyncTasks &

asyncTask

)

Definition at line 483 of file DRCEAsyncTasksQueue.cpp.

Here is the call graph for this function:

void HCE::drce::DRCEAsyncTasksQueue::writeToTasksLog	(	const std::string &	delimiter,
		const std::string &	taskStatus,
		const AsyncTasks &	asyncTask
	)

Definition at line 716 of file DRCEAsyncTasksQueue.cpp.

Here is the caller graph for this function:

---

The documentation for this class was generated from the following files:

• sources/utils/DRCE/src/DRCEAsyncTasksQueue.hpp
• sources/utils/DRCE/src/DRCEAsyncTasksQueue.cpp