hce-node application
1.4.3
HCE Hierarchical Cluster Engine node application
|
#include <DRCEFunctionalObject.hpp>
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) |
DRCENodeOptions & | operator= (const DRCENodeOptions &rhs) |
DRCENodeOptions & | operator= (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 |
Definition at line 36 of file DRCEFunctionalObject.hpp.
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.
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_ = "" |
||
) |
|
virtual |
DRCEFunctionalObject::Dictionary HCE::drce::DRCEFunctionalObject::dumpResourceMonitor | ( | void | ) |
Definition at line 205 of file DRCEFunctionalObject.cpp.
size_t HCE::drce::DRCEFunctionalObject::getAsyncTasksCount | ( | void | ) |
Definition at line 238 of file DRCEFunctionalObject.cpp.
std::string HCE::drce::DRCEFunctionalObject::getCurrentTasksQueue | ( | void | ) |
Definition at line 248 of file DRCEFunctionalObject.cpp.
std::string HCE::drce::DRCEFunctionalObject::getHostResourceUsage | ( | void | ) |
Definition at line 271 of file DRCEFunctionalObject.cpp.
std::string HCE::drce::DRCEFunctionalObject::getListInfoAllTasks | ( | void | ) |
Definition at line 253 of file DRCEFunctionalObject.cpp.
unsigned int HCE::drce::DRCEFunctionalObject::getMaxThreadCount | ( | void | ) | const |
Definition at line 154 of file DRCEFunctionalObject.cpp.
|
inline |
bool HCE::drce::DRCEFunctionalObject::getResetErrorCodeStateNotification | ( | void | ) |
size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxDiskSize | ( | void | ) | const |
Definition at line 68 of file DRCEFunctionalObject.cpp.
size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxProcessesCount | ( | void | ) | const |
Definition at line 58 of file DRCEFunctionalObject.cpp.
size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxRramSize | ( | void | ) | const |
Definition at line 88 of file DRCEFunctionalObject.cpp.
size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxThreadsCount | ( | void | ) | const |
Definition at line 48 of file DRCEFunctionalObject.cpp.
size_t HCE::drce::DRCEFunctionalObject::getResourceExtractorMaxVramSize | ( | void | ) | const |
Definition at line 78 of file DRCEFunctionalObject.cpp.
unsigned int HCE::drce::DRCEFunctionalObject::getResourceMonitorTimePeriod | ( | void | ) |
Definition at line 188 of file DRCEFunctionalObject.cpp.
StatVariables HCE::drce::DRCEFunctionalObject::getStatVariables | ( | void | ) |
Definition at line 233 of file DRCEFunctionalObject.cpp.
unsigned int HCE::drce::DRCEFunctionalObject::getTasksQueueDumpPeriod | ( | void | ) |
Definition at line 176 of file DRCEFunctionalObject.cpp.
bool HCE::drce::DRCEFunctionalObject::hasTask | ( | unsigned int | taskId | ) |
Definition at line 243 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::loadTaskQueue | ( | void | ) |
|
static |
Definition at line 93 of file DRCEFunctionalObject.cpp.
std::string HCE::drce::DRCEFunctionalObject::Process | ( | const std::string & | json | ) |
Definition at line 311 of file DRCEFunctionalObject.cpp.
DRCEOutputJsonMessage HCE::drce::DRCEFunctionalObject::Process | ( | DRCEInputJsonMessage & | inputJsonMessage | ) |
void HCE::drce::DRCEFunctionalObject::resetError | ( | void | ) |
Definition at line 142 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::restoreResourceMonitor | ( | const Dictionary & | dictionary | ) |
Definition at line 221 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::saveTaskQueue | ( | void | ) |
bool HCE::drce::DRCEFunctionalObject::setHomeDir | ( | const std::string & | homeDir_ | ) |
Reimplemented from HCE::drce::DRCENodeOptions.
Definition at line 126 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setMaxThreadCount | ( | unsigned int | threadCount | ) |
Definition at line 149 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setNotificationFunctor | ( | std::function< std::string(const std::string &)> | notificationFunctor_ | ) |
Definition at line 121 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setResetErrorCodeStateNotification | ( | bool | resetErrorCodeStateNotification_ | ) |
Definition at line 194 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxDiskSize | ( | size_t | maxDiskSize_ | ) |
Definition at line 63 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxProcessesCount | ( | size_t | maxProcessesCount_ | ) |
Definition at line 53 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxRramSize | ( | size_t | maxRramSize_ | ) |
Definition at line 83 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxThreadsCount | ( | size_t | maxThreadsCount_ | ) |
Definition at line 43 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setResourceExtractorMaxVramSize | ( | size_t | maxVramSize_ | ) |
Definition at line 73 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setResourceMonitorTimePeriod | ( | unsigned int | timePeriod_ | ) |
Definition at line 182 of file DRCEFunctionalObject.cpp.
void HCE::drce::DRCEFunctionalObject::setTasksQueueDumpPeriod | ( | unsigned int | periodMs | ) |
Definition at line 171 of file DRCEFunctionalObject.cpp.