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 Namespace Reference

Namespaces

namespace  drce_const
namespace  drce_json_message_const
namespace  message_const
namespace  reduce_task
namespace  tests

Classes

class  ProgressHandler
struct  AsyncTasks
class  DRCEAsyncTasksQueue
class  AsyncTaskLocker
struct  AvgCounts
class  AvgCountsConverter
class  DRCECleanupTask
class  DRCECommonList
class  DRCECommonTask
class  DRCEDefaultJSON
class  FileBuilder
class  DataFileBuilder
class  StatusFileBuilder
class  RequestFileBuilder
class  DataFileExtractor
class  RequestFileExtractor
struct  FileItem
class  DRCEFilesList
class  FileStream
class  DRCEFunctionalObject
class  DRCEFunctionalObjectBase
class  DRCEInputJsonMessage
struct  TaskInfoData
class  DRCEListAllTasks
class  DRCENodeOptions
class  DRCENotificationExecutor
class  DRCEOutputJsonMessage
struct  ProcessData
class  DRCEReadProcessData
class  DiskSpaceExtractor
class  CpuUsageExtractor
class  LoadAverageExtractor
class  MemoryExtractor
class  ProcessInfoExtractor
class  ResourceUsageExtractor
struct  ResourceUsageLimits
struct  ResourceLimits
class  DRCEResourceLimitsChecker
class  DRCEResourceMonitor
struct  ResourceUsage
class  ResourceUsageConverter
class  ResourceUsageSerializator
class  DRCEResultDataItem
class  DRCEResultData
class  DRCEResultDataSerializator
struct  SessionOptions
struct  StatVariableData
struct  StatVariables
class  StatVariablesConverter
class  DRCESubtasksList
class  DRCETaskFactory
class  DRCETaskRequest
class  DRCETaskRequestCheckState
class  DRCETaskRequestCheckStateExecutor
class  DRCETaskRequestDeleteData
class  DRCETaskRequestDeleteDataExecutor
class  DRCETaskRequestExecutor
class  DRCETaskRequestExecutorFactory
class  DRCETaskRequestFactory
class  DRCETaskRequestGetData
class  DRCETaskRequestGetDataExecutor
class  DRCETaskRequestSetExecute
class  DRCETaskRequestSetExecuteExecutor
class  DRCETaskRequestTerminate
class  DRCETaskRequestTerminateExecutor
class  DRCETaskShellHost
struct  TaskStatusData
class  DRCETasksQueue
class  DRCETaskSsh

Typedefs

typedef DRCESubtasksList
< DRCEInputJsonMessage
Subtasks

Enumerations

enum  {
  NO_ERROR = 0, PARSE_ERROR = 1, ERROR_INSTANTIATION_FO = 2, ERROR_MAKE_DEFAULT_JSON = 3,
  ERROR_SET_HOME_DIR = 4, ERROR_SET_MANDATORY_ENVIRONMENT = 5, ERROR_SERIALIZE = 11, ERROR_UNSERIALIZE = 12,
  ERROR_BAD_JSON_FORMAT = 13, ERROR_TASK_ID_NOT_RANGE = 14, ERROR_SHELL_SCRIPT_NOT_EXIST = 15, ERROR_SHELL_SCRIPT_CANNOT_EXECUTE = 16,
  ERROR_FUNCTIONAL_OBJECT = 100, ERROR_COMMAND_EXECUTION = 101, ERROR_SET_ENVIRONMENT = 102, ERROR_BAD_COMMAND_PARAMS = 103,
  ERROR_CREATE_NEW_TASK = 104, ERROR_BAD_TYPE_TASK_REQUEST = 105, ERROR_CREATE_OBJECT = 106, ERROR_EXECUTE_TASK = 107,
  ERROR_READ_STATUS_FILE = 108, ERROR_READ_DATA_FILE = 109, ERROR_READ_REQUEST_FILE = 110, ERROR_TASK_CONTINUES_TO_RUN = 111,
  ERROR_BAD_DATA_CONTENT = 112, ERROR_TERMINATE_TASK = 113, ERROR_INVALID_PID_PROCESS = 114, ERROR_EXECUTE_NOTIFICATION = 115,
  ERROR_TERMINATE_EXPIRED_TASK = 116, ERROR_TERMINATE_SUBTASK_AFTER_EXPIRED_MAIN_TASK = 117, ERROR_TERMINATE_CANCELED_TASK = 118, ERROR_EXCEEDED_RESOURCE_LIMITS = 119,
  ERROR_CLEANUP_TASK_DATA = 120, ERROR_DELETE_TASK_DATA = 121, ERROR_REBUILD_LIST_ALL_TASKS = 122, ERROR_CHECK_STATE_BUSY_TASK = 123,
  ERROR_CREATE_FILE_BEFORE_EXEC = 201, ERROR_DELETE_FILE_BEFORE_EXEC = 202, ERROR_READ_FILE_AFTER_EXEC = 203, ERROR_DELETE_FILE_AFTER_EXEC = 204,
  ERROR_TARGET_CLIENTS_NOT_AVAILABLE = 5000, ERROR_NODE_MODE_NOT_SUPPORTED = 5001, ERROR_NODE_HAS_NOT_ENOUGH_RESOURCE_LIMITS = 5002
}

Functions

std::ostream & operator<< (std::ostream &os, const AsyncTasks &rhs)
std::istream & operator>> (std::istream &is, AsyncTasks &rhs)
std::ostream & operator<< (std::ostream &os, const DRCEDefaultJSON &defaultJson)
std::string DRCEEncodeBase64 (const std::string &data)
std::string DRCEDecodeBase64 (const std::string &data)
std::istream & operator>> (std::istream &is, DRCEInputJsonMessage &inputJsonMessage)
std::ostream & operator<< (std::ostream &os, const DRCEInputJsonMessage &inputJsonMessage)
std::istream & operator>> (std::istream &is, DRCEOutputJsonMessage &outputJsonMessage)
std::ostream & operator<< (std::ostream &os, const DRCEOutputJsonMessage &outputJsonMessage)
std::istream & operator>> (std::istream &is, DRCETaskRequestCheckState &rhs)
std::ostream & operator<< (std::ostream &os, const DRCETaskRequestCheckState &rhs)
std::istream & operator>> (std::istream &is, DRCETaskRequestDeleteData &rhs)
std::ostream & operator<< (std::ostream &os, const DRCETaskRequestDeleteData &rhs)
std::istream & operator>> (std::istream &is, DRCETaskRequestGetData &rhs)
std::ostream & operator<< (std::ostream &os, const DRCETaskRequestGetData &rhs)
std::istream & operator>> (std::istream &is, DRCETaskRequestSetExecute &rhs)
std::ostream & operator<< (std::ostream &os, const DRCETaskRequestSetExecute &rhs)
std::istream & operator>> (std::istream &is, DRCETaskRequestTerminate &rhs)
std::ostream & operator<< (std::ostream &os, const DRCETaskRequestTerminate &rhs)
std::ostream & operator<< (std::ostream &os, const TaskStatusData &rhs)
std::istream & operator>> (std::istream &is, TaskStatusData &rhs)

Typedef Documentation

Enumeration Type Documentation

anonymous enum
Enumerator:
NO_ERROR 
PARSE_ERROR 
ERROR_INSTANTIATION_FO 
ERROR_MAKE_DEFAULT_JSON 
ERROR_SET_HOME_DIR 
ERROR_SET_MANDATORY_ENVIRONMENT 
ERROR_SERIALIZE 
ERROR_UNSERIALIZE 
ERROR_BAD_JSON_FORMAT 
ERROR_TASK_ID_NOT_RANGE 
ERROR_SHELL_SCRIPT_NOT_EXIST 
ERROR_SHELL_SCRIPT_CANNOT_EXECUTE 
ERROR_FUNCTIONAL_OBJECT 
ERROR_COMMAND_EXECUTION 
ERROR_SET_ENVIRONMENT 
ERROR_BAD_COMMAND_PARAMS 
ERROR_CREATE_NEW_TASK 
ERROR_BAD_TYPE_TASK_REQUEST 
ERROR_CREATE_OBJECT 
ERROR_EXECUTE_TASK 
ERROR_READ_STATUS_FILE 
ERROR_READ_DATA_FILE 
ERROR_READ_REQUEST_FILE 
ERROR_TASK_CONTINUES_TO_RUN 
ERROR_BAD_DATA_CONTENT 
ERROR_TERMINATE_TASK 
ERROR_INVALID_PID_PROCESS 
ERROR_EXECUTE_NOTIFICATION 
ERROR_TERMINATE_EXPIRED_TASK 
ERROR_TERMINATE_SUBTASK_AFTER_EXPIRED_MAIN_TASK 
ERROR_TERMINATE_CANCELED_TASK 
ERROR_EXCEEDED_RESOURCE_LIMITS 
ERROR_CLEANUP_TASK_DATA 
ERROR_DELETE_TASK_DATA 
ERROR_REBUILD_LIST_ALL_TASKS 
ERROR_CHECK_STATE_BUSY_TASK 
ERROR_CREATE_FILE_BEFORE_EXEC 
ERROR_DELETE_FILE_BEFORE_EXEC 
ERROR_READ_FILE_AFTER_EXEC 
ERROR_DELETE_FILE_AFTER_EXEC 
ERROR_TARGET_CLIENTS_NOT_AVAILABLE 
ERROR_NODE_MODE_NOT_SUPPORTED 
ERROR_NODE_HAS_NOT_ENOUGH_RESOURCE_LIMITS 

Definition at line 22 of file DRCEError.hpp.

Function Documentation

std::string HCE::drce::DRCEDecodeBase64 ( const std::string &  data)

Definition at line 23 of file DRCEEncodeDecodeBase64.cpp.

Here is the caller graph for this function:

std::string HCE::drce::DRCEEncodeBase64 ( const std::string &  data)

Definition at line 13 of file DRCEEncodeDecodeBase64.cpp.

Here is the caller graph for this function:

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const DRCEOutputJsonMessage &  outputJsonMessage 
)

Definition at line 68 of file DRCEOutputJsonMessage.cpp.

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const TaskStatusData &  rhs 
)

Definition at line 70 of file DRCETasksQueue.cpp.

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const DRCETaskRequestDeleteData &  rhs 
)

Definition at line 86 of file DRCETaskRequestDeleteData.cpp.

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const DRCEDefaultJSON &  defaultJson 
)

Definition at line 94 of file DRCEDefaultJSON.cpp.

Here is the call graph for this function:

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const DRCETaskRequestGetData &  rhs 
)

Definition at line 97 of file DRCETaskRequestGetData.cpp.

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const DRCETaskRequestCheckState &  rhs 
)

Definition at line 99 of file DRCETaskRequestCheckState.cpp.

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const DRCETaskRequestTerminate &  rhs 
)

Definition at line 118 of file DRCETaskRequestTerminate.cpp.

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const AsyncTasks &  rhs 
)

Definition at line 144 of file DRCEAsyncTasksQueue.cpp.

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const DRCEInputJsonMessage &  inputJsonMessage 
)

Definition at line 271 of file DRCEInputJsonMessage.cpp.

std::ostream& HCE::drce::operator<< ( std::ostream &  os,
const DRCETaskRequestSetExecute &  rhs 
)

Definition at line 347 of file DRCETaskRequestSetExecute.cpp.

std::istream& HCE::drce::operator>> ( std::istream &  is,
DRCEOutputJsonMessage &  outputJsonMessage 
)

Definition at line 57 of file DRCEOutputJsonMessage.cpp.

Here is the call graph for this function:

std::istream& HCE::drce::operator>> ( std::istream &  is,
DRCETaskRequestDeleteData &  rhs 
)

Definition at line 75 of file DRCETaskRequestDeleteData.cpp.

Here is the call graph for this function:

std::istream& HCE::drce::operator>> ( std::istream &  is,
TaskStatusData &  rhs 
)

Definition at line 76 of file DRCETasksQueue.cpp.

std::istream& HCE::drce::operator>> ( std::istream &  is,
DRCETaskRequestGetData &  rhs 
)

Definition at line 86 of file DRCETaskRequestGetData.cpp.

Here is the call graph for this function:

std::istream& HCE::drce::operator>> ( std::istream &  is,
DRCETaskRequestCheckState &  rhs 
)

Definition at line 88 of file DRCETaskRequestCheckState.cpp.

Here is the call graph for this function:

std::istream& HCE::drce::operator>> ( std::istream &  is,
DRCETaskRequestTerminate &  rhs 
)

Definition at line 107 of file DRCETaskRequestTerminate.cpp.

Here is the call graph for this function:

std::istream& HCE::drce::operator>> ( std::istream &  is,
AsyncTasks &  rhs 
)

Definition at line 151 of file DRCEAsyncTasksQueue.cpp.

std::istream& HCE::drce::operator>> ( std::istream &  is,
DRCEInputJsonMessage &  inputJsonMessage 
)

Definition at line 260 of file DRCEInputJsonMessage.cpp.

Here is the call graph for this function:

std::istream& HCE::drce::operator>> ( std::istream &  is,
DRCETaskRequestSetExecute &  rhs 
)

Definition at line 336 of file DRCETaskRequestSetExecute.cpp.

Here is the call graph for this function: