hce-node application  1.4.3
HCE Hierarchical Cluster Engine node application
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Public Member Functions | List of all members
HCE::drce::DRCETaskShellHost Class Reference

#include <DRCETaskShellHost.hpp>

Inheritance diagram for HCE::drce::DRCETaskShellHost:
Inheritance graph
[legend]
Collaboration diagram for HCE::drce::DRCETaskShellHost:
Collaboration graph
[legend]

Public Member Functions

 DRCETaskShellHost (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 DRCETaskShellHost.hpp.

Constructor & Destructor Documentation

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

Definition at line 27 of file DRCETaskShellHost.cpp.

Member Function Documentation

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

Implements HCE::drce::DRCECommonTask.

Definition at line 202 of file DRCETaskShellHost.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCETaskShellHost::runTask ( void  )
virtual

<Make list of subtasks

<Start cleanup processing

<Subtasks list

Implements HCE::drce::DRCECommonTask.

Definition at line 35 of file DRCETaskShellHost.cpp.

Here is the call graph for this function:

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