HCE::drce::DRCETaskSsh Class Reference

#include <DRCETaskSsh.hpp>

Inheritance diagram for HCE::drce::DRCETaskSsh:

Collaboration diagram for HCE::drce::DRCETaskSsh:

Public Member Functions
	DRCETaskSsh (const std::string &taskName_, DRCENodeOptions &nodeOptions_, CustomMessage &message_, const DRCETaskRequestSetExecute &taskRequestSetExecute_, DRCEAsyncTasksQueue &asyncTasksQueue_, DRCEResourceMonitor &resourceMonitor_, const DRCEInputJsonMessage &inputJsonMessage_, unsigned int parentTaskId_)
void	runTask (void)
DRCEResultDataItem	execute (Process::CallbackFunction fn) throw (Poco::Exception)
Public Member Functions inherited from HCE::drce::DRCECommonTask
	DRCECommonTask (const std::string &taskName_, DRCENodeOptions &nodeOptions_, CustomMessage &message_, const DRCETaskRequestSetExecute &taskRequestSetExecute_, DRCEAsyncTasksQueue &asyncTasksQueue_, DRCEResourceMonitor &resourceMonitor_, const DRCEInputJsonMessage &inputJsonMessage, unsigned int parentTaskId_)
void	updateTasks (DRCEResultDataItem &resultDataItem, unsigned int &progressCount)
void	makeFilesBefore (DRCEFilesList &filesList) throw (Poco::Exception)
void	makeFilesAfter (DRCEFilesList &filesList, DRCEResultDataItem &resultDataItem)
unsigned int	getParentTaskId (void) const
void	saveRequestData (void)
void	saveResultData (DRCEResultDataItem &resultDataItem)
void	executeSubtasks (DRCEResultDataItem &resultDataItem)
void	cleanup (bool needCleanup=false)

Additional Inherited Members
Public Types inherited from HCE::drce::DRCECommonTask
typedef std::vector< std::pair < unsigned int, SessionOptions::CleanupFlag > >	SubtasksList
Static Public Member Functions inherited from HCE::drce::DRCECommonTask
static void	updateTasks (DRCEResultDataItem &resultDataItem, DRCENodeOptions &nodeOptions, CustomMessage &message, DRCEAsyncTasksQueue &asyncTasksQueue, unsigned int &progressCount, DRCECommonTask *pCommonTask=nullptr)
static size_t	getElapsedTimeMsec (const Poco::Timestamp &tsStart)
static void	getSubtasksList (DRCEInputJsonMessage &inputJsonMessage, SubtasksList &subtasks)
static DRCEInputJsonMessage	getRequestData (unsigned int taskId, DRCENodeOptions &nodeOptions, CustomMessage &message)
static void	waitUpdateAllTasks (unsigned int taskId, DRCENodeOptions &nodeOptions, CustomMessage &message, DRCEAsyncTasksQueue &asyncTasksQueue, Poco::Task *pTask=nullptr)
static void	waitEndAllTask (DRCEInputJsonMessage &inputJsonMessage, DRCEAsyncTasksQueue &asyncTasksQueue, Poco::Task *pTask=nullptr)
static void	cleanup (unsigned int taskId, DRCENodeOptions &nodeOptions, CustomMessage &message, bool needCleanup=false)
static void	cleanup (DRCEInputJsonMessage &inputJsonMessage, DRCENodeOptions &nodeOptions, CustomMessage &message, bool needCleanup=false)
static void	saveRequestData (DRCEInputJsonMessage &inputJsonMessage, DRCENodeOptions &nodeOptions, CustomMessage &message)
static void	saveRequest (unsigned int taskId, DRCENodeOptions &nodeOptions, CustomMessage &message)
static void	saveRequest (DRCEInputJsonMessage &inputJsonMessage, DRCENodeOptions &nodeOptions, CustomMessage &message)
static void	saveResultData (DRCEResultDataItem &resultDataItem, DRCENodeOptions &nodeOptions, CustomMessage &message, DRCEAsyncTasksQueue &asyncTasksQueue)
static DRCEResultDataItem	makeResultDataItem (DRCEInputJsonMessage &inputJsonMessage, DRCENodeOptions &nodeOptions, CustomMessage &message, DRCETaskRequest::RequestType requestType, DRCETaskRequest::TaskState taskState, unsigned int errorCode=NO_ERROR, const std::string &errorMessage="", unsigned int pid=0, size_t timeElapsed=0, unsigned int exitStatus=0)
static unsigned int	getHostParentTaskId (unsigned int taskId, DRCEAsyncTasksQueue &asyncTasksQueue)
static DRCEResultDataItem	extractStatusResultDataItem (unsigned int taskId, DRCENodeOptions &nodeOptions, DRCEAsyncTasksQueue &asyncTasksQueue)
static DRCEResultDataItem	extractDataResultDataItem (unsigned int taskId, DRCENodeOptions &nodeOptions, DRCEAsyncTasksQueue &asyncTasksQueue)
static void	safeCleanup (const std::string &path)
static DRCEResultDataItem	extractResultDataItem (const std::string &fileName)
Protected Attributes inherited from HCE::drce::DRCECommonTask
DRCENodeOptions &	nodeOptions
CustomMessage &	message
DRCETaskRequestSetExecute	taskRequestSetExecute
DRCEAsyncTasksQueue &	asyncTasksQueue
DRCEResourceMonitor &	resourceMonitor
DRCEInputJsonMessage	inputJsonMessage
unsigned int	parentTaskId

Detailed Description

Definition at line 24 of file DRCETaskSsh.hpp.

Constructor & Destructor Documentation

HCE::drce::DRCETaskSsh::DRCETaskSsh	(	const std::string &	taskName_,
		DRCENodeOptions &	nodeOptions_,
		CustomMessage &	message_,
		const DRCETaskRequestSetExecute &	taskRequestSetExecute_,
		DRCEAsyncTasksQueue &	asyncTasksQueue_,
		DRCEResourceMonitor &	resourceMonitor_,
		const DRCEInputJsonMessage &	inputJsonMessage_,
		unsigned int	parentTaskId_
	)

Definition at line 14 of file DRCETaskSsh.cpp.

Member Function Documentation

DRCEResultDataItem HCE::drce::DRCETaskSsh::execute ( Process::CallbackFunction  fn ) throw (Poco::Exception)

virtual

Implements HCE::drce::DRCECommonTask.

Definition at line 26 of file DRCETaskSsh.cpp.

void HCE::drce::DRCETaskSsh::runTask ( void  )

virtual

Implements HCE::drce::DRCECommonTask.

Definition at line 21 of file DRCETaskSsh.cpp.

---

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

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