hce-node application  1.4.3
HCE Hierarchical Cluster Engine node application
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
HCE::drce::DRCEFunctionalObject Class Reference

#include <DRCEFunctionalObject.hpp>

Inheritance diagram for HCE::drce::DRCEFunctionalObject:
Collaboration diagram for HCE::drce::DRCEFunctionalObject:

Public Types

typedef std::map< std::string,
Poco::Dynamic::Var > 
Dictionary
 Dump and restore resource monitor states.

Public Member Functions

 DRCEFunctionalObject (const std::string &nodeName_, const std::string &homeDir_, const std::string &tasksDataDir_, const std::string &tasksStatusDir_, const std::string &nodeHost_="", const std::string &nodePort_="")
virtual ~DRCEFunctionalObject (void)
std::string Process (const std::string &json)
DRCEOutputJsonMessage Process (DRCEInputJsonMessage &inputJsonMessage)
void setNotificationFunctor (std::function< std::string(const std::string &)> notificationFunctor_)
bool setHomeDir (const std::string &homeDir_)
void resetError (void)
void setMaxThreadCount (unsigned int threadCount)
unsigned int getMaxThreadCount (void) const
void saveTaskQueue (void)
void loadTaskQueue (void)
void setTasksQueueDumpPeriod (unsigned int periodMs)
unsigned int getTasksQueueDumpPeriod (void)
void setResourceMonitorTimePeriod (unsigned int timePeriod_)
unsigned int getResourceMonitorTimePeriod (void)
void setResetErrorCodeStateNotification (bool resetErrorCodeStateNotification_)
bool getResetErrorCodeStateNotification (void)
StatVariables getStatVariables (void)
Dictionary dumpResourceMonitor (void)
void restoreResourceMonitor (const Dictionary &dictionary)
size_t getAsyncTasksCount (void)
bool hasTask (unsigned int taskId)
size_t getRequestTime (void) const
std::string getCurrentTasksQueue (void)
std::string getListInfoAllTasks (void)
std::string getHostResourceUsage (void)
void setResourceExtractorMaxThreadsCount (size_t maxThreadsCount_)
size_t getResourceExtractorMaxThreadsCount (void) const
void setResourceExtractorMaxProcessesCount (size_t maxProcessesCount_)
size_t getResourceExtractorMaxProcessesCount (void) const
void setResourceExtractorMaxDiskSize (size_t maxDiskSize_)
size_t getResourceExtractorMaxDiskSize (void) const
void setResourceExtractorMaxVramSize (size_t maxVramSize_)
size_t getResourceExtractorMaxVramSize (void) const
void setResourceExtractorMaxRramSize (size_t maxRramSize_)
size_t getResourceExtractorMaxRramSize (void) const
- Public Member Functions inherited from HCE::drce::DRCEFunctionalObjectBase
 DRCEFunctionalObjectBase (void)
virtual ~DRCEFunctionalObjectBase (void)
void setErrorMsg (const std::string &errorMsg_)
std::string getErrorMsg (void) const
void setErrorCode (unsigned int errorCode_)
unsigned int getErrorCode (void) const
void isError (bool isError_)
bool isError (void) const
void resetLogStream (void)
void setLogStream (std::ostream &os)
std::string logMsg (bool isReset=true)
std::ostream & log (LoggerStream::Priority logPriority)
void setLoggable (Loggable loggable)
void resetLoggable (void)
void setEnvironments (const std::string &env)
void applyEnvironments (DRCETaskRequest *pTaskRequest)
- Public Member Functions inherited from HCE::drce::DRCENodeOptions
 DRCENodeOptions (const std::string &nodeName_, const std::string &homeDir_, const std::string &tasksDataDir_, const std::string &tasksStatusDir_, const std::string &nodeHost_="", const std::string &nodePort_="")
 DRCENodeOptions (const DRCENodeOptions &rhs)
 DRCENodeOptions (DRCENodeOptions &&rhs)
virtual ~DRCENodeOptions (void)
DRCENodeOptionsoperator= (const DRCENodeOptions &rhs)
DRCENodeOptionsoperator= (DRCENodeOptions &&rhs)
void setNodeName (const std::string &nodeName_)
std::string getNodeName (void) const
std::string getHomeDir (void) const
void setTasksDataDir (const std::string &tasksDataDir_)
std::string getTasksDataDir (void) const
void setTasksStatusDir (const std::string &tasksStatusDir_)
std::string getTasksStatusDir (void) const
void setNodeHost (const std::string &nodeHost_)
std::string getNodeHost (void) const
void setNodePort (const std::string &nodePort_)
std::string getNodePort (void) const

Static Public Member Functions

static std::string makeErrorMessage (const std::string &inputMessage, unsigned int state, unsigned int errorCode, const std::string &errorMessage)

Additional Inherited Members

- Static Protected Member Functions inherited from HCE::drce::DRCEFunctionalObjectBase
static bool insensitiveCompare (const std::string &lhs, const std::string &rhs)
static size_t getElapsedTimeMsec (const Poco::Timestamp &ts)
- Protected Attributes inherited from HCE::drce::DRCEFunctionalObjectBase
std::string errorMsg
unsigned int errorCode
bool _isError
LoggerStream logger
std::vector< std::pair
< std::string, std::string > > 
environments
- Protected Attributes inherited from HCE::drce::DRCENodeOptions
std::string nodeName
std::string homeDir
std::string tasksDataDir
std::string tasksStatusDir
std::string nodeHost
std::string nodePort

Detailed Description

Definition at line 36 of file DRCEFunctionalObject.hpp.

Member Typedef Documentation

typedef std::map<std::string, Poco::Dynamic::Var> HCE::drce::DRCEFunctionalObject::Dictionary

Dump and restore resource monitor states.

Definition at line 68 of file DRCEFunctionalObject.hpp.

Constructor & Destructor Documentation

HCE::drce::DRCEFunctionalObject::DRCEFunctionalObject ( const std::string &  nodeName_,
const std::string &  homeDir_,
const std::string &  tasksDataDir_,
const std::string &  tasksStatusDir_,
const std::string &  nodeHost_ = "",
const std::string &  nodePort_ = "" 
)

Definition at line 25 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

HCE::drce::DRCEFunctionalObject::~DRCEFunctionalObject ( void  )
virtual

Definition at line 37 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Member Function Documentation

DRCEFunctionalObject::Dictionary HCE::drce::DRCEFunctionalObject::dumpResourceMonitor ( void  )

Definition at line 205 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

size_t HCE::drce::DRCEFunctionalObject::getAsyncTasksCount ( void  )

Definition at line 238 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

std::string HCE::drce::DRCEFunctionalObject::getCurrentTasksQueue ( void  )

Definition at line 248 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

std::string HCE::drce::DRCEFunctionalObject::getHostResourceUsage ( void  )

Definition at line 271 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

std::string HCE::drce::DRCEFunctionalObject::getListInfoAllTasks ( void  )

Definition at line 253 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

unsigned int HCE::drce::DRCEFunctionalObject::getMaxThreadCount ( void  ) const

Definition at line 154 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

size_t HCE::drce::DRCEFunctionalObject::getRequestTime ( void  ) const
inline

Definition at line 75 of file DRCEFunctionalObject.hpp.

Here is the caller graph for this function:

bool HCE::drce::DRCEFunctionalObject::getResetErrorCodeStateNotification ( void  )

Definition at line 200 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxDiskSize ( void  ) const

Definition at line 68 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxProcessesCount ( void  ) const

Definition at line 58 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxRramSize ( void  ) const

Definition at line 88 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxThreadsCount ( void  ) const

Definition at line 48 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxVramSize ( void  ) const

Definition at line 78 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

unsigned int HCE::drce::DRCEFunctionalObject::getResourceMonitorTimePeriod ( void  )

Definition at line 188 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

StatVariables HCE::drce::DRCEFunctionalObject::getStatVariables ( void  )

Definition at line 233 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

unsigned int HCE::drce::DRCEFunctionalObject::getTasksQueueDumpPeriod ( void  )

Definition at line 176 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

bool HCE::drce::DRCEFunctionalObject::hasTask ( unsigned int  taskId)

Definition at line 243 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::loadTaskQueue ( void  )

Definition at line 166 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

std::string HCE::drce::DRCEFunctionalObject::makeErrorMessage ( const std::string &  inputMessage,
unsigned int  state,
unsigned int  errorCode,
const std::string &  errorMessage 
)
static

Definition at line 93 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

std::string HCE::drce::DRCEFunctionalObject::Process ( const std::string &  json)

Definition at line 311 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

DRCEOutputJsonMessage HCE::drce::DRCEFunctionalObject::Process ( DRCEInputJsonMessage inputJsonMessage)

Definition at line 340 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

void HCE::drce::DRCEFunctionalObject::resetError ( void  )

Definition at line 142 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::restoreResourceMonitor ( const Dictionary dictionary)

Definition at line 221 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::saveTaskQueue ( void  )

Definition at line 160 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

bool HCE::drce::DRCEFunctionalObject::setHomeDir ( const std::string &  homeDir_)

Reimplemented from HCE::drce::DRCENodeOptions.

Definition at line 126 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setMaxThreadCount ( unsigned int  threadCount)

Definition at line 149 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setNotificationFunctor ( std::function< std::string(const std::string &)>  notificationFunctor_)

Definition at line 121 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 194 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxDiskSize ( size_t  maxDiskSize_)

Definition at line 63 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxProcessesCount ( size_t  maxProcessesCount_)

Definition at line 53 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxRramSize ( size_t  maxRramSize_)

Definition at line 83 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxThreadsCount ( size_t  maxThreadsCount_)

Definition at line 43 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxVramSize ( size_t  maxVramSize_)

Definition at line 73 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setResourceMonitorTimePeriod ( unsigned int  timePeriod_)

Definition at line 182 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void HCE::drce::DRCEFunctionalObject::setTasksQueueDumpPeriod ( unsigned int  periodMs)

Definition at line 171 of file DRCEFunctionalObject.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:


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