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

Namespaces

namespace  properties

Classes

class  Admin
class  AdminClientsSerializator
class  AdminCommandParameters
class  CalculatorAlgorithmData
class  CalculatorNodeResourceData
class  CalculatorAlgorithm
class  CalculatorAlgorithmDefault
class  CalculatorNodeExecution
class  ClientsQueueManager
class  TimeoutShiftCounter
struct  ClientWorkerItem
class  DataClientData
class  DataClientProxy
class  DataNodeOptions
class  DataProcessorData
class  DataReducerProxy
class  DataServerProxy
class  Dictionary
class  DictionaryConverter
class  Handler
class  HandlerProperties
struct  DefaultReducerResponseItem
class  LoggerConfigLoader
class  ResourceUsageLimitsChecker
class  ResourceUsageManager
class  RouterServerProxy
class  RouteMessage
class  RequestRouteMessage
class  HeartbeatMessage
class  PropertyMessage

Typedefs

typedef
HCE::drce::DRCECommonList
< CalculatorNodeResourceData
NodeResourceDataList
typedef
HCE::handlers::Dictionary
< std::string, double > 
ResourceUsageData
typedef std::deque
< ResourceUsageData
ResourceUsageCollection
typedef struct
HCE::handlers::ClientWorkerItem 
ClientWorkerItem
typedef Dictionary
< std::string, double > 
ResourceUsageLimitsData

Functions

std::istream & operator>> (std::istream &is, HandlerProperties &handlerProperties)
std::ostream & operator<< (std::ostream &os, const HandlerProperties &handlerProperties)

Variables

const unsigned char ADMIN_REQUEST_TYPE_UNDEFINED = 0
const unsigned char ADMIN_REQUEST_TYPE_EXTERNAL = 1
const unsigned char ADMIN_REQUEST_TYPE_INTERNAL = 2
const unsigned int HEARTBEAT_DELAY = 15000
 <Delay intervals
const unsigned int HEARTBEAT_TIMEOUT = 60000
 Heartbeat messages sent period interval, msec.
const unsigned int LOG_STATISTIC_PERIOD = 30000
 Statistics log interval, msec.
const unsigned int RECONNECT_INTERVAL_INIT = 10000
 Initial reconnect period, msec.
const unsigned int RECONNECR_INTERVAL_MAX = 30000
 Max reconnect period that can be reached during an exponential backoff.
const unsigned int POLL_TIMEOUT = HEARTBEAT_DELAY/2
 POLL timeout of main sockets polling in handlers, msec.
const unsigned int STAT_INTERVAL = 60000
 Stat logging action period interval, msec.
const unsigned int PROPERTY_INTERVAL = 10000
 Interval between resend PROPERTY values from Handles to Admin class.
const unsigned int DUMP_INTERVAL = 3600*1000
 Interval between dumps run-time variables.
const unsigned int MIN_ALLOWED_HEARTBEAT_DELAY = 5000
 Min allowed delay receiving of heartbeat messages from client, msec.
const unsigned int MIN_ALLOWED_HEARTBEAT_TIMEOUT = 5000
 Min allowed heartbeat messages sent period interval, msec.
const unsigned int MIN_ALLOWED_POLL_TIMEOUT = 5000
 Min allowed POLL timeout of main sockets polling in handlers, msec.
const unsigned int MIN_ALLOWED_PROPERTY_INTERVAL = 5000
 Min allowed interval between resend PROPERTY values from Handles to Admin class.
const unsigned int MIN_ALLOWED_DUMP_INTERVAL = 5000
 Min allowed interval between dump run-time variables.
const unsigned int HEARBEAT_MODE_FIXED_TIME = 0
const unsigned int HEARBEAT_MODE_IMMEDIATE_AFTER_HB = 1
const unsigned int HEARBEAT_MODE_MIXED = 2
const unsigned int HEARBEAT_MODE_ADAPTIVE = 3
const unsigned int HEARBEAT_MODE_DEFAULT = HEARBEAT_MODE_FIXED_TIME
const unsigned int HEARBEAT_MODE_MAX_NUMBER = HEARBEAT_MODE_ADAPTIVE
 Data processing and shard model modes.
const unsigned char NODE_MODE_PROXY = 0
 Multicast requests balancing (supposes proportional sharding of documents as sharding model)
const unsigned char NODE_MODE_SHARD = 1
 Round robin requests balancing (supposes mirroring of data documents as sharding model)
const unsigned char NODE_MODE_DATA = 2
 Node in data mode, i.e. - end of chain in cluster tree.
const unsigned char NODE_MODE_ROUTER = 3
 Multicast requests balancing.
const unsigned char NODE_MODE_SHARD_RND = 4
 Random single-cast balancing.
const unsigned char NODE_MODE_SHARD_RU = 5
 Resources usage balancing (supposes choose of data node based resources usage)
const unsigned int NODE_MSG_DATA_MIN_FIELDS = 2
 Minimal fields number to treat message as valid data message.
const unsigned int NODE_MSG_CMD_MIN_FIELDS = 1
 Minimal fields number to treat message as command (heartbit, ready and another node states)
const unsigned int NODE_LOG_MODE_NONE = 0
 A none error. In the application turn off any log.
const unsigned int NODE_LOG_MODE_FATAL = 1
 A fatal error. The application will most likely terminate. This is the highest priority.
const unsigned int NODE_LOG_MODE_CRITICAL = 2
 A critical error. The application might not be able to continue running successfully.
const unsigned int NODE_LOG_MODE_ERROR = 3
 An error. An operation did not complete successfully, but the application as a whole is not affected.
const unsigned int NODE_LOG_MODE_WARNING = 4
 A warning. An operation completed with an unexpected result.
const unsigned int NODE_LOG_MODE_NOTICE = 5
 A notice, which is an information with just a higher priority.
const unsigned int NODE_LOG_MODE_INFORMATION = 6
 An informational message, usually denoting the successful completion of an operation.
const unsigned int NODE_LOG_MODE_DEBUG = 7
 A debugging message.
const unsigned int NODE_LOG_MODE_TRACE = 8
 A tracing message. This is the lowest priority.
const unsigned int NODE_LOG_MODE_DEFAULT = NODE_LOG_MODE_INFORMATION
 Log mode default to enable logging all modes.
const unsigned int NODE_EXIT_CODE_GENERAL_CRITICAL_ERROR = 1
const unsigned int NODE_EXIT_CODE_SPHINX_CRITICAL_ERROR = 2
const unsigned int NODE_EXIT_CODE_DRCE_CRITICAL_ERROR = 3
 Connection delays and intervals.
const unsigned int NODE_CONNECTION_REBUILD_DELAY_DEFAULT = 60000
const unsigned int NODE_CONNECTION_REBUILD_MAX_TRIES = 100
const char NODE_ROUTER_MSG_DELIMITER = '@'
 <Message structure signatures
const char NODE_ADMIN_COMMAND_DELIMITER = 0x09
 ':';
const char NODE_JSON_BEGIN_CHAR = '{'
const std::string NODE_JSON_EMPTY_DEFAULT = "{}"
const char NODE_ADMIN_COMMAND_PROPERTY_ITEMS_DELIMITER = ','
const char NODE_ADMIN_COMMAND_PROPERTY_ITEM_PAIR_DELIMITER = ':'
const char ROUTE_TABLE_MSG_TITLE_DELIMITER = ':'
const char ROUTE_LIST_NAMES_DELIMITER = ','
const char ROUTE_LIST_COUNT_DELIMITER = ':'
const char HEARTBEAT_MSG_DELIMITER = ':'
const char PROPERTY_MSG_DELIMITER = ':'
const std::string HEARTBEAT_JSON_RESOURCES = "resources"
const std::string HEARTBEAT_JSON_ROUTES = "routes"
const char NODE_INI_FILE_PATH_START_CHAR = '/'
const char NODE_INI_FILE_PATH_DELIMITER_CHAR = '/'
 Data modes.
const unsigned int NODE_DATA_PROCESSING_MODE_NORMAL = 0
 Regular data processing supposes to involve FO call(s)
const unsigned int NODE_DATA_PROCESSING_MODE_SIMULATE = 1
 Simulation that avoid natural FO call(s) and to use auto-generated results to return.
const std::string ZMQ_PROTOCOL_PREFIX_TCP = "tcp://"
const std::string ZMQ_PROTOCOL_PREFIX_INPROC = "inproc://"
 Internal connection strings.
const std::string NODE_CS_INPROC_ADMIN = "inproc_admin"
const std::string NODE_CS_INPROC_PROXY = "inproc_proxy"
const std::string NODE_CS_INPROC_DATA = "inproc_data"
const std::string NODE_CS_INPROC_REDUCER_OUT = "inproc_reducer_out"
const std::string NODE_CS_INPROC_REDUCER_IN = "inproc_reducer_in"
 General handlers command messages.
const std::string NODE_MSG_READY = "READY"
const std::string NODE_MSG_HEARTBEAT = "HEARTBEAT"
const std::string NODE_MSG_BYE = "BYE"
 Admin handlers command messages supported by all handlers via parent.
const std::string NODE_MSG_ECHO = "ECHO"
const std::string NODE_MSG_LOG_LEVEL_SET = "LLSET"
const std::string NODE_MSG_LOG_LEVEL_GET = "LLGET"
const std::string NODE_MSG_HEARTBEAT_DELAY_SET = "HEARTBEAT_DELAY_SET"
const std::string NODE_MSG_HEARTBEAT_DELAY_GET = "HEARTBEAT_DELAY_GET"
const std::string NODE_MSG_HEARTBEAT_TIMEOUT_SET = "HEARTBEAT_TIMEOUT_SET"
const std::string NODE_MSG_HEARTBEAT_TIMEOUT_GET = "HEARTBEAT_TIMEOUT_GET"
const std::string NODE_MSG_HEARTBEAT_MODE_SET = "HEARTBEAT_MODE_SET"
const std::string NODE_MSG_HEARTBEAT_MODE_GET = "HEARTBEAT_MODE_GET"
const std::string NODE_MSG_POLL_TIMEOUT_SET = "POLL_TIMEOUT_SET"
const std::string NODE_MSG_POLL_TIMEOUT_GET = "POLL_TIMEOUT_GET"
const std::string NODE_MSG_PROPERTY_INTERVAL_SET = "PROPERTY_INTERVAL_SET"
const std::string NODE_MSG_PROPERTY_INTERVAL_GET = "PROPERTY_INTERVAL_GET"
const std::string NODE_MSG_DUMP_INTERVAL_SET = "DUMP_INTERVAL_SET"
const std::string NODE_MSG_DUMP_INTERVAL_GET = "DUMP_INTERVAL_GET"
 Admin handlers command messages supported by specific handler depends on command.
const std::string NODE_MSG_STAT = "STAT"
const std::string NODE_MSG_TIME = "TIME"
const std::string NODE_MSG_PROPERTIES = "PROPERTIES"
const std::string NODE_MSG_rebuildServerConnection = "rebuildServerConnection"
const std::string NODE_MSG_REBUILD_CLIENT_CONNECTION = "REBUILD_CLIENT_CONNECTION"
const std::string NODE_MSG_UPDATE_SCHEMA = "UPDATE_SCHEMA"
const std::string NODE_MSG_DISCONNECT_SERVER_CONNECTION = "DISCONNECT_SERVER_CONNECTION"
const std::string NODE_MSG_DISCONNECT_CLIENT_CONNECTION = "DISCONNECT_CLIENT_CONNECTION"
const std::string NODE_MSG_SHUTDOWN = "SHUTDOWN"
const std::string NODE_MSG_SPHINX = "SPHINX"
const std::string NODE_MSG_DRCE = "DRCE"
const std::string NODE_MSG_DRCE_SET_HOST = "DRCE_SET_HOST"
const std::string NODE_MSG_DRCE_GET_HOST = "DRCE_GET_HOST"
const std::string NODE_MSG_DRCE_SET_PORT = "DRCE_SET_PORT"
const std::string NODE_MSG_DRCE_GET_PORT = "DRCE_GET_PORT"
const std::string NODE_MSG_DRCE_GET_TASKS = "DRCE_GET_TASKS"
const std::string NODE_MSG_DRCE_GET_TASKS_INFO = "DRCE_GET_TASKS_INFO"
const std::string NODE_MSG_ROUTES = "NODE_ROUTES"
const std::string NODE_MSG_RESOURCE_USAGE = "NODE_RESOURCE_USAGE"
const std::string NODE_MSG_SET_DATA_PROCESSING_MODE = "SET_DATA_PROCESSING_MODE"
const std::string NODE_MSG_GET_DATA_PROCESSING_MODE = "GET_DATA_PROCESSING_MODE"
const std::string NODE_MSG_MANAGER_MODE_SET = "MMSET"
const std::string NODE_MSG_MANAGER_MODE_GET = "MMGET"
const std::string NODE_MSG_MANAGER_PURGE_MODE_SET = "MPMSET"
const std::string NODE_MSG_MANAGER_PURGE_MODE_GET = "MPMGET"
const std::string NODE_MSG_MANAGER_RESOURCES_COLLECTED_SIZE_SET = "MRCSSET"
const std::string NODE_MSG_MANAGER_RESOURCES_COLLECTED_SIZE_GET = "MRCSGET"
const std::string NODE_MSG_STOP = "STOP"
const std::string NODE_ADMIN_ERROR_WRONG_FORMAT = "Wrong admin message format, expected string - DESTINATION_IDENTITY:COMMAND_NAME:PARAMETERS, or destination admin handler not found"
 <Error messages
const std::string NODE_ADMIN_ERROR_UNSUPPORTED_COMMAND = "REDEFINED admin command handler - unsupported admin command!"
const std::string NODE_ADMIN_ERROR_HANDLER_NOT_FOUND = "Handler not found or not connected to inproc admin server"
const std::string NODE_ADMIN_ERROR_UNSUPPORTED_CC_REBUILD = "Client connection rebuild not supported for handler "
const std::string NODE_ADMIN_ERROR_OK = "OK"
const std::string NODE_ADMIN_ERROR_ERROR = "ERROR"
const std::string NODE_ADMIN_ERROR_MAIN_MSG_LOOP_STARTED = "Main messages loop started"
const std::string NODE_ADMIN_ERROR_MAIN_MSG_LOOP_STOPPED = "Main messages loop stopped"
 Internal handler names.
const std::string NODE_ADMIN_HANDLER = "Admin"
 Functional object Sphinx errors.
const std::string NODE_FUNCTIONAL_ERROR_SPHINX = "SPHINX_FO_ERR"
const std::string NODE_FUNCTIONAL_ERROR_SPHINX_ADMIN = "SPHINX_FO_ADMIN_ERR"
const std::string NODE_FUNCTIONAL_ERROR_SPHINX_ADMIN_JSON_MSG = "{\"error_code\":\"1\", \"error_message\": \"Sphinx FO error\", \"data\":\"ERROR\", \"time\":\"-1\"}"
const std::string NODE_FUNCTIONAL_ERROR_SPHINX_INTERNAL_LOG_BEGIN = "\n!!!SPHINXFO!!![\n"
const std::string NODE_FUNCTIONAL_ERROR_SPHINX_INTERNAL_LOG_END = "\n]!!!SPHINXFO!!!\n"
const std::string NODE_CRITICAL_ERROR_MESSAGE = "Critical error, can't continue, execution aborted!"
const std::string NODE_FUNCTIONAL_ERROR_SPHINX_REDUCER = "SPHINX_REDUCER_FO_ERR"
 Functional object Sphinx defaults.
const std::string NODE_FUNCTIONAL_PROJECT_ROOT_DIR = "hce-node-bundle"
const bool NODE_FUNCTIONAL_SPHINX_NOT_START_SEARCHD = false
const bool NODE_FUNCTIONAL_SPHINX_NOT_STOP_SEARCHD = false
const unsigned int NODE_FUNCTIONAL_SPHINX_RANKER_0 = 0
const std::string NODE_FUNCTIONAL_DRCE_TASKS_DATA_DIR = "data"
const std::string NODE_FUNCTIONAL_DRCE_TASKS_STATUS_DIR = "log"
 Functional object DRCE errors.
const std::string NODE_FUNCTIONAL_ERROR_DRCE = "DRCE_FO_ERR"
const std::string NODE_FUNCTIONAL_ERROR_DRCE_INTERNAL_LOG_BEGIN = "\n!!!DRCEFO!!![\n"
const std::string NODE_FUNCTIONAL_ERROR_DRCE_INTERNAL_LOG_END = "\n]!!!DRCEFO!!!\n"
 Admin command properties names.
const std::string NODE_ADMIN_PROPERTY_NAME_LOG = "log"
const std::string NODE_ADMIN_PROPERTY_NAME_MMODE = "mode"
const std::string NODE_ADMIN_PROPERTY_HEARTBEAT_DELAY = "hb_delay"
const std::string NODE_ADMIN_PROPERTY_HEARTBEAT_TIMEOUT = "hb_timeout"
const std::string NODE_ADMIN_PROPERTY_HEARTBEAT_MODE = "hb_mode"
const std::string NODE_ADMIN_PROPERTY_POLL_TIMEOUT = "poll_timeout"
const std::string NODE_ADMIN_PROPERTY_PROPERTY_INTERVAL = "property_interval"
const std::string NODE_ADMIN_PROPERTY_DUMP_INTERVAL = "dump_interval"
const std::string NODE_ADMIN_PROPERTY_RESOURCES_COLLECTED_SIZE = "collected_size"
 Default drce resources extractor values.
const size_t DRCE_RESOURCES_EXTRACTOR_MAX_THREADS = 1024
const size_t DRCE_RESOURCES_EXTRACTOR_MAX_PROCESSES = 1024
const size_t DRCE_RESOURCES_EXTRACTOR_MAX_DISK_SIZE = 0
const size_t DRCE_RESOURCES_EXTRACTOR_MAX_VRAM_SIZE = 0
const size_t DRCE_RESOURCES_EXTRACTOR_MAX_RRAM_SIZE = 0
 Default resources usage collected size value.
const unsigned int RESOURCES_USAGE_COLLECTED_SIZE = 10
 Default resources usage max allowed range value in percent.
const double RESOURCES_USAGE_MAX_ALLOWED_RANGE = 10.0
 Default log time mark format.
const std::string NODE_LOG_DEAFULT_TIME_FORMAT = "[%Y-%m-%d %H:%M:%s] "
const int NODE_LOG_DEAFULT_MASK = 8+4+2+1
 DRCE request error - can't set as new task.
const int DRCE_REQUEST_STATE_ERROR_SET_AS_NEW_TASK = 6
 Get property information parameters.
const unsigned int PROPERTY_REALTIME_DEFAULT = 1
 Allowed dump restore default value.
const unsigned int DUMP_ALLOWED_RESTORE = 1
 Dump dir default value.
const std::string DUMP_DIR = "/tmp/hce-node"
 Messages accumulator item.

Typedef Documentation

Definition at line 52 of file ClientWorkerItem.hpp.

Definition at line 51 of file ClientWorkerItem.hpp.

typedef Dictionary<std::string, double> HCE::handlers::ResourceUsageLimitsData

Definition at line 24 of file ResourceUsageLimitsChecker.hpp.

Function Documentation

std::ostream& HCE::handlers::operator<< ( std::ostream &  os,
const HandlerProperties &  handlerProperties 
)

Definition at line 176 of file HandlerProperties.cpp.

std::istream& HCE::handlers::operator>> ( std::istream &  is,
HandlerProperties &  handlerProperties 
)

Definition at line 165 of file HandlerProperties.cpp.

Here is the call graph for this function:

Variable Documentation

const unsigned char HCE::handlers::ADMIN_REQUEST_TYPE_EXTERNAL = 1

Definition at line 8 of file Admin.cpp.

const unsigned char HCE::handlers::ADMIN_REQUEST_TYPE_INTERNAL = 2

Definition at line 9 of file Admin.cpp.

const unsigned char HCE::handlers::ADMIN_REQUEST_TYPE_UNDEFINED = 0

Definition at line 7 of file Admin.cpp.

const int HCE::handlers::DRCE_REQUEST_STATE_ERROR_SET_AS_NEW_TASK = 6

Get property information parameters.

Definition at line 232 of file HandlerTypes.hpp.

const size_t HCE::handlers::DRCE_RESOURCES_EXTRACTOR_MAX_DISK_SIZE = 0

Definition at line 219 of file HandlerTypes.hpp.

const size_t HCE::handlers::DRCE_RESOURCES_EXTRACTOR_MAX_PROCESSES = 1024

Definition at line 218 of file HandlerTypes.hpp.

const size_t HCE::handlers::DRCE_RESOURCES_EXTRACTOR_MAX_RRAM_SIZE = 0

Default resources usage collected size value.

Definition at line 221 of file HandlerTypes.hpp.

const size_t HCE::handlers::DRCE_RESOURCES_EXTRACTOR_MAX_THREADS = 1024

Definition at line 217 of file HandlerTypes.hpp.

const size_t HCE::handlers::DRCE_RESOURCES_EXTRACTOR_MAX_VRAM_SIZE = 0

Definition at line 220 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::DUMP_ALLOWED_RESTORE = 1

Dump dir default value.

Definition at line 238 of file HandlerTypes.hpp.

const std::string HCE::handlers::DUMP_DIR = "/tmp/hce-node"

Messages accumulator item.

Definition at line 241 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::DUMP_INTERVAL = 3600*1000

Interval between dumps run-time variables.

Definition at line 32 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::HEARBEAT_MODE_ADAPTIVE = 3

Definition at line 44 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::HEARBEAT_MODE_DEFAULT = HEARBEAT_MODE_FIXED_TIME

Definition at line 46 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::HEARBEAT_MODE_FIXED_TIME = 0

Definition at line 41 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::HEARBEAT_MODE_IMMEDIATE_AFTER_HB = 1

Definition at line 42 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::HEARBEAT_MODE_MAX_NUMBER = HEARBEAT_MODE_ADAPTIVE

Data processing and shard model modes.

Definition at line 47 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::HEARBEAT_MODE_MIXED = 2

Definition at line 43 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::HEARTBEAT_DELAY = 15000

<Delay intervals

Delay receiving of heartbeat messages from client, msec

Definition at line 24 of file HandlerTypes.hpp.

const std::string HCE::handlers::HEARTBEAT_JSON_RESOURCES = "resources"

Definition at line 95 of file HandlerTypes.hpp.

const std::string HCE::handlers::HEARTBEAT_JSON_ROUTES = "routes"

Definition at line 96 of file HandlerTypes.hpp.

const char HCE::handlers::HEARTBEAT_MSG_DELIMITER = ':'

Definition at line 93 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::HEARTBEAT_TIMEOUT = 60000

Heartbeat messages sent period interval, msec.

Definition at line 25 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::LOG_STATISTIC_PERIOD = 30000

Statistics log interval, msec.

Definition at line 26 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::MIN_ALLOWED_DUMP_INTERVAL = 5000

Min allowed interval between dump run-time variables.

Heartbeat modes

Definition at line 38 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::MIN_ALLOWED_HEARTBEAT_DELAY = 5000

Min allowed delay receiving of heartbeat messages from client, msec.

Definition at line 34 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::MIN_ALLOWED_HEARTBEAT_TIMEOUT = 5000

Min allowed heartbeat messages sent period interval, msec.

Definition at line 35 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::MIN_ALLOWED_POLL_TIMEOUT = 5000

Min allowed POLL timeout of main sockets polling in handlers, msec.

Definition at line 36 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::MIN_ALLOWED_PROPERTY_INTERVAL = 5000

Min allowed interval between resend PROPERTY values from Handles to Admin class.

Definition at line 37 of file HandlerTypes.hpp.

const char HCE::handlers::NODE_ADMIN_COMMAND_DELIMITER = 0x09

':';

Definition at line 85 of file HandlerTypes.hpp.

const char HCE::handlers::NODE_ADMIN_COMMAND_PROPERTY_ITEM_PAIR_DELIMITER = ':'

Definition at line 89 of file HandlerTypes.hpp.

const char HCE::handlers::NODE_ADMIN_COMMAND_PROPERTY_ITEMS_DELIMITER = ','

Definition at line 88 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_ERROR_ERROR = "ERROR"

Definition at line 176 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_ERROR_HANDLER_NOT_FOUND = "Handler not found or not connected to inproc admin server"

Definition at line 173 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_ERROR_MAIN_MSG_LOOP_STARTED = "Main messages loop started"

Definition at line 177 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_ERROR_MAIN_MSG_LOOP_STOPPED = "Main messages loop stopped"

Internal handler names.

Definition at line 178 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_ERROR_OK = "OK"

Definition at line 175 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_ERROR_UNSUPPORTED_CC_REBUILD = "Client connection rebuild not supported for handler "

Definition at line 174 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_ERROR_UNSUPPORTED_COMMAND = "REDEFINED admin command handler - unsupported admin command!"

Definition at line 172 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_ERROR_WRONG_FORMAT = "Wrong admin message format, expected string - DESTINATION_IDENTITY:COMMAND_NAME:PARAMETERS, or destination admin handler not found"

<Error messages

Definition at line 171 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_HANDLER = "Admin"

Functional object Sphinx errors.

Definition at line 181 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_DUMP_INTERVAL = "dump_interval"

Definition at line 213 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_HEARTBEAT_DELAY = "hb_delay"

Definition at line 208 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_HEARTBEAT_MODE = "hb_mode"

Definition at line 210 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_HEARTBEAT_TIMEOUT = "hb_timeout"

Definition at line 209 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_NAME_LOG = "log"

Definition at line 206 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_NAME_MMODE = "mode"

Definition at line 207 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_POLL_TIMEOUT = "poll_timeout"

Definition at line 211 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_PROPERTY_INTERVAL = "property_interval"

Definition at line 212 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_ADMIN_PROPERTY_RESOURCES_COLLECTED_SIZE = "collected_size"

Default drce resources extractor values.

Definition at line 214 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_CONNECTION_REBUILD_DELAY_DEFAULT = 60000

Definition at line 80 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_CONNECTION_REBUILD_MAX_TRIES = 100

Definition at line 81 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_CRITICAL_ERROR_MESSAGE = "Critical error, can't continue, execution aborted!"

Definition at line 189 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_CS_INPROC_ADMIN = "inproc_admin"

Definition at line 111 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_CS_INPROC_DATA = "inproc_data"

Definition at line 113 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_CS_INPROC_PROXY = "inproc_proxy"

Definition at line 112 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_CS_INPROC_REDUCER_IN = "inproc_reducer_in"

General handlers command messages.

Definition at line 115 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_CS_INPROC_REDUCER_OUT = "inproc_reducer_out"

Definition at line 114 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_DATA_PROCESSING_MODE_NORMAL = 0

Regular data processing supposes to involve FO call(s)

Definition at line 103 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_DATA_PROCESSING_MODE_SIMULATE = 1

Simulation that avoid natural FO call(s) and to use auto-generated results to return.

ZMQ connection protocols names prefix

Definition at line 104 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_EXIT_CODE_DRCE_CRITICAL_ERROR = 3

Connection delays and intervals.

Definition at line 77 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_EXIT_CODE_GENERAL_CRITICAL_ERROR = 1

Definition at line 75 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_EXIT_CODE_SPHINX_CRITICAL_ERROR = 2

Definition at line 76 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_DRCE_TASKS_DATA_DIR = "data"

Definition at line 197 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_DRCE_TASKS_STATUS_DIR = "log"

Functional object DRCE errors.

Definition at line 198 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_DRCE = "DRCE_FO_ERR"

Definition at line 201 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_DRCE_INTERNAL_LOG_BEGIN = "\n!!!DRCEFO!!![\n"

Definition at line 202 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_DRCE_INTERNAL_LOG_END = "\n]!!!DRCEFO!!!\n"

Admin command properties names.

Definition at line 203 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_SPHINX = "SPHINX_FO_ERR"

Definition at line 184 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_SPHINX_ADMIN = "SPHINX_FO_ADMIN_ERR"

Definition at line 185 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_SPHINX_ADMIN_JSON_MSG = "{\"error_code\":\"1\", \"error_message\": \"Sphinx FO error\", \"data\":\"ERROR\", \"time\":\"-1\"}"

Definition at line 186 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_SPHINX_INTERNAL_LOG_BEGIN = "\n!!!SPHINXFO!!![\n"

Definition at line 187 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_SPHINX_INTERNAL_LOG_END = "\n]!!!SPHINXFO!!!\n"

Definition at line 188 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_ERROR_SPHINX_REDUCER = "SPHINX_REDUCER_FO_ERR"

Functional object Sphinx defaults.

Definition at line 190 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_FUNCTIONAL_PROJECT_ROOT_DIR = "hce-node-bundle"

Definition at line 193 of file HandlerTypes.hpp.

const bool HCE::handlers::NODE_FUNCTIONAL_SPHINX_NOT_START_SEARCHD = false

Definition at line 194 of file HandlerTypes.hpp.

const bool HCE::handlers::NODE_FUNCTIONAL_SPHINX_NOT_STOP_SEARCHD = false

Definition at line 195 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_FUNCTIONAL_SPHINX_RANKER_0 = 0

Definition at line 196 of file HandlerTypes.hpp.

const char HCE::handlers::NODE_INI_FILE_PATH_DELIMITER_CHAR = '/'

Data modes.

Definition at line 100 of file HandlerTypes.hpp.

const char HCE::handlers::NODE_INI_FILE_PATH_START_CHAR = '/'

Definition at line 99 of file HandlerTypes.hpp.

const char HCE::handlers::NODE_JSON_BEGIN_CHAR = '{'

Definition at line 86 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_JSON_EMPTY_DEFAULT = "{}"

Definition at line 87 of file HandlerTypes.hpp.

const int HCE::handlers::NODE_LOG_DEAFULT_MASK = 8+4+2+1

DRCE request error - can't set as new task.

Definition at line 229 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_LOG_DEAFULT_TIME_FORMAT = "[%Y-%m-%d %H:%M:%s] "

Definition at line 228 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_CRITICAL = 2

A critical error. The application might not be able to continue running successfully.

Definition at line 64 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_DEBUG = 7

A debugging message.

Definition at line 69 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_DEFAULT = NODE_LOG_MODE_INFORMATION

Log mode default to enable logging all modes.

Exit codes

Definition at line 72 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_ERROR = 3

An error. An operation did not complete successfully, but the application as a whole is not affected.

Definition at line 65 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_FATAL = 1

A fatal error. The application will most likely terminate. This is the highest priority.

Definition at line 63 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_INFORMATION = 6

An informational message, usually denoting the successful completion of an operation.

Definition at line 68 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_NONE = 0

A none error. In the application turn off any log.

Definition at line 62 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_NOTICE = 5

A notice, which is an information with just a higher priority.

Definition at line 67 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_TRACE = 8

A tracing message. This is the lowest priority.

Definition at line 70 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_LOG_MODE_WARNING = 4

A warning. An operation completed with an unexpected result.

Definition at line 66 of file HandlerTypes.hpp.

const unsigned char HCE::handlers::NODE_MODE_DATA = 2

Node in data mode, i.e. - end of chain in cluster tree.

Definition at line 52 of file HandlerTypes.hpp.

const unsigned char HCE::handlers::NODE_MODE_PROXY = 0

Multicast requests balancing (supposes proportional sharding of documents as sharding model)

Definition at line 50 of file HandlerTypes.hpp.

const unsigned char HCE::handlers::NODE_MODE_ROUTER = 3

Multicast requests balancing.

Definition at line 53 of file HandlerTypes.hpp.

const unsigned char HCE::handlers::NODE_MODE_SHARD = 1

Round robin requests balancing (supposes mirroring of data documents as sharding model)

Definition at line 51 of file HandlerTypes.hpp.

const unsigned char HCE::handlers::NODE_MODE_SHARD_RND = 4

Random single-cast balancing.

Definition at line 54 of file HandlerTypes.hpp.

const unsigned char HCE::handlers::NODE_MODE_SHARD_RU = 5

Resources usage balancing (supposes choose of data node based resources usage)

Messages fields number structure

Definition at line 55 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_BYE = "BYE"

Admin handlers command messages supported by all handlers via parent.

Definition at line 120 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_MSG_CMD_MIN_FIELDS = 1

Minimal fields number to treat message as command (heartbit, ready and another node states)

Log mode priorities

Definition at line 59 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::NODE_MSG_DATA_MIN_FIELDS = 2

Minimal fields number to treat message as valid data message.

Definition at line 58 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DISCONNECT_CLIENT_CONNECTION = "DISCONNECT_CLIENT_CONNECTION"

Definition at line 147 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DISCONNECT_SERVER_CONNECTION = "DISCONNECT_SERVER_CONNECTION"

Definition at line 146 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DRCE = "DRCE"

Definition at line 150 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DRCE_GET_HOST = "DRCE_GET_HOST"

Definition at line 152 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DRCE_GET_PORT = "DRCE_GET_PORT"

Definition at line 154 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DRCE_GET_TASKS = "DRCE_GET_TASKS"

Definition at line 155 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DRCE_GET_TASKS_INFO = "DRCE_GET_TASKS_INFO"

Definition at line 156 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DRCE_SET_HOST = "DRCE_SET_HOST"

Definition at line 151 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DRCE_SET_PORT = "DRCE_SET_PORT"

Definition at line 153 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DUMP_INTERVAL_GET = "DUMP_INTERVAL_GET"

Admin handlers command messages supported by specific handler depends on command.

Definition at line 137 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_DUMP_INTERVAL_SET = "DUMP_INTERVAL_SET"

Definition at line 136 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_ECHO = "ECHO"

Definition at line 123 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_GET_DATA_PROCESSING_MODE = "GET_DATA_PROCESSING_MODE"

Definition at line 161 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_HEARTBEAT = "HEARTBEAT"

Definition at line 119 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_HEARTBEAT_DELAY_GET = "HEARTBEAT_DELAY_GET"

Definition at line 127 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_HEARTBEAT_DELAY_SET = "HEARTBEAT_DELAY_SET"

Definition at line 126 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_HEARTBEAT_MODE_GET = "HEARTBEAT_MODE_GET"

Definition at line 131 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_HEARTBEAT_MODE_SET = "HEARTBEAT_MODE_SET"

Definition at line 130 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_HEARTBEAT_TIMEOUT_GET = "HEARTBEAT_TIMEOUT_GET"

Definition at line 129 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_HEARTBEAT_TIMEOUT_SET = "HEARTBEAT_TIMEOUT_SET"

Definition at line 128 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_LOG_LEVEL_GET = "LLGET"

Definition at line 125 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_LOG_LEVEL_SET = "LLSET"

Definition at line 124 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_MANAGER_MODE_GET = "MMGET"

Definition at line 163 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_MANAGER_MODE_SET = "MMSET"

Definition at line 162 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_MANAGER_PURGE_MODE_GET = "MPMGET"

Definition at line 165 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_MANAGER_PURGE_MODE_SET = "MPMSET"

Definition at line 164 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_MANAGER_RESOURCES_COLLECTED_SIZE_GET = "MRCSGET"

Definition at line 167 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_MANAGER_RESOURCES_COLLECTED_SIZE_SET = "MRCSSET"

Definition at line 166 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_POLL_TIMEOUT_GET = "POLL_TIMEOUT_GET"

Definition at line 133 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_POLL_TIMEOUT_SET = "POLL_TIMEOUT_SET"

Definition at line 132 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_PROPERTIES = "PROPERTIES"

Definition at line 142 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_PROPERTY_INTERVAL_GET = "PROPERTY_INTERVAL_GET"

Definition at line 135 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_PROPERTY_INTERVAL_SET = "PROPERTY_INTERVAL_SET"

Definition at line 134 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_READY = "READY"

Definition at line 118 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_REBUILD_CLIENT_CONNECTION = "REBUILD_CLIENT_CONNECTION"

Definition at line 144 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_rebuildServerConnection = "rebuildServerConnection"

Definition at line 143 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_RESOURCE_USAGE = "NODE_RESOURCE_USAGE"

Definition at line 159 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_ROUTES = "NODE_ROUTES"

Definition at line 158 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_SET_DATA_PROCESSING_MODE = "SET_DATA_PROCESSING_MODE"

Definition at line 160 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_SHUTDOWN = "SHUTDOWN"

Definition at line 148 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_SPHINX = "SPHINX"

Definition at line 149 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_STAT = "STAT"

Definition at line 140 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_STOP = "STOP"

Definition at line 168 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_TIME = "TIME"

Definition at line 141 of file HandlerTypes.hpp.

const std::string HCE::handlers::NODE_MSG_UPDATE_SCHEMA = "UPDATE_SCHEMA"

Definition at line 145 of file HandlerTypes.hpp.

const char HCE::handlers::NODE_ROUTER_MSG_DELIMITER = '@'

<Message structure signatures

Definition at line 84 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::POLL_TIMEOUT = HEARTBEAT_DELAY/2

POLL timeout of main sockets polling in handlers, msec.

Definition at line 29 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::PROPERTY_INTERVAL = 10000

Interval between resend PROPERTY values from Handles to Admin class.

Definition at line 31 of file HandlerTypes.hpp.

const char HCE::handlers::PROPERTY_MSG_DELIMITER = ':'

Definition at line 94 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::PROPERTY_REALTIME_DEFAULT = 1

Allowed dump restore default value.

Definition at line 235 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::RECONNECR_INTERVAL_MAX = 30000

Max reconnect period that can be reached during an exponential backoff.

Definition at line 28 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::RECONNECT_INTERVAL_INIT = 10000

Initial reconnect period, msec.

Definition at line 27 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::RESOURCES_USAGE_COLLECTED_SIZE = 10

Default resources usage max allowed range value in percent.

Definition at line 223 of file HandlerTypes.hpp.

const double HCE::handlers::RESOURCES_USAGE_MAX_ALLOWED_RANGE = 10.0

Default log time mark format.

Definition at line 225 of file HandlerTypes.hpp.

const char HCE::handlers::ROUTE_LIST_COUNT_DELIMITER = ':'

Definition at line 92 of file HandlerTypes.hpp.

const char HCE::handlers::ROUTE_LIST_NAMES_DELIMITER = ','

Definition at line 91 of file HandlerTypes.hpp.

const char HCE::handlers::ROUTE_TABLE_MSG_TITLE_DELIMITER = ':'

Definition at line 90 of file HandlerTypes.hpp.

const unsigned int HCE::handlers::STAT_INTERVAL = 60000

Stat logging action period interval, msec.

Definition at line 30 of file HandlerTypes.hpp.

const std::string HCE::handlers::ZMQ_PROTOCOL_PREFIX_INPROC = "inproc://"

Internal connection strings.

Definition at line 108 of file HandlerTypes.hpp.

const std::string HCE::handlers::ZMQ_PROTOCOL_PREFIX_TCP = "tcp://"

Definition at line 107 of file HandlerTypes.hpp.