__init__(self, configParser, connectionBuilderLight=None) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
app::BaseServerManager::BaseServerManager.__init__(self, poller_manager=None, admin_connection=None, conectionLightBuilder=None, exceptionForward=False, dumpStatVars=True) | app.BaseServerManager.BaseServerManager | |
addConnection(self, name, connection) | app.BaseServerManager.BaseServerManager | |
ADMIN_CONNECT_CLIENT | app.BaseServerManager.BaseServerManager | static |
ADMIN_CONNECT_ENDPOINT | app.BaseServerManager.BaseServerManager | static |
build_poller_list(self) | app.BaseServerManager.BaseServerManager | |
checkDelTaskState(self, state, action) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
clear_poller(self) | app.BaseServerManager.BaseServerManager | |
clientTasksDataManagerName | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
clientTasksManagerName | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
CONFIG_DRCE_HOST | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
CONFIG_DRCE_PORT | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
CONFIG_DRCE_TIMEOUT | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
CONFIG_HCE_NODE_ADMIN_TIMEOUT | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
CONFIG_SERVER | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
CONFIG_TASKS_MANAGER_CLIENT | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
CONFIG_TASKS_MANAGER_DATA_CLIENT | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
configVars | app.BaseServerManager.BaseServerManager | |
connections | app.BaseServerManager.BaseServerManager | |
convertToEEResponse(self, response) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
convertToTaskResponse(self, rawResponse) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
createDBIDict(self, configParser) | app.BaseServerManager.BaseServerManager | |
createGeneralResponse(self, errCode, errMessage, errLog) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
createLogMsg(self, event) | app.BaseServerManager.BaseServerManager | |
createTaskDeleteRequest(self, deleteTaskObj) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
drceCommandConvertor | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
drceHost | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
drceIdGenerator | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
drceManager | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
drcePort | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
drceTimeout | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
dumpStatVars | app.BaseServerManager.BaseServerManager | |
ERROR_DELETE_TASK_RESULTS | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_DELETE_TASK_RESULTS_MESSAGE | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_EE_RESPONSE_OBJECT_TYPE_OR_RESPONSE_ERROR | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_HCE_ADMIN_REQUEST_ERROR | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_HCE_RESPONSE_PROCESSING_SPLIT | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_INSERT_EE_DATA | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_MSG_DRCE_ROUTER_NEW_TASK | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_UPDATE_TASKS_FIELDS | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
ERROR_WRONG_OBJECT_TYPE | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
event_handlers | app.BaseServerManager.BaseServerManager | |
eventBuilder | app.BaseServerManager.BaseServerManager | |
exceptionForward | app.BaseServerManager.BaseServerManager | |
exit_flag | app.BaseServerManager.BaseServerManager | |
getConfigVarsFields(self, fields) | app.BaseServerManager.BaseServerManager | |
getLogLevel(self) | app.BaseServerManager.BaseServerManager | |
getStatDataFields(self, fields) | app.BaseServerManager.BaseServerManager | |
getStatVarsDumpFileName(self) | app.BaseServerManager.BaseServerManager | |
getSystemStat(self) | app.BaseServerManager.BaseServerManager | |
hceNodeAdminTimeout | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
hceNodeManagerRequest | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
initStatFields(self, connect_name) | app.BaseServerManager.BaseServerManager | |
is_connection_registered(self, name) | app.BaseServerManager.BaseServerManager | |
loadStatVarsDump(self) | app.BaseServerManager.BaseServerManager | |
LOG_LEVEL_CONFIG_VAR_NAME | app.BaseServerManager.BaseServerManager | static |
LOGGERS_NAMES | app.BaseServerManager.BaseServerManager | static |
on_poll_timeout(self) | app.BaseServerManager.BaseServerManager | |
on_unhandled_event(self, event) | app.BaseServerManager.BaseServerManager | |
onAdminFetchStatData(self, event) | app.BaseServerManager.BaseServerManager | |
onAdminGetConfigVars(self, event) | app.BaseServerManager.BaseServerManager | |
onAdminSetConfigVars(self, event) | app.BaseServerManager.BaseServerManager | |
onAdminState(self, event) | app.BaseServerManager.BaseServerManager | |
onAdminSuspend(self, event) | app.BaseServerManager.BaseServerManager | |
onCheckTaskState(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
onDeleteEEDataResponse(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
onDeleteTaskResults(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
onExecuteTask(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
onFetchTaskDataResponse(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
onFetchTaskResults(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
onGetTaskManagerFieldsResponse(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
onInsertEEDataResponse(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
onUpdateTasksFieldsResponse(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
OPERATION_CHECK_STATE | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
OPERATION_DELETE_TASK | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
OPERATION_FETCH_RESULTS | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
OPERATION_NEW_TASK | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | static |
poll(self) | app.BaseServerManager.BaseServerManager | |
POLL_TIMEOUT_CONFIG_VAR_NAME | app.BaseServerManager.BaseServerManager | static |
POLL_TIMEOUT_DEFAULT | app.BaseServerManager.BaseServerManager | static |
poller_manager | app.BaseServerManager.BaseServerManager | |
pollTimeout | app.BaseServerManager.BaseServerManager | |
process(self, event) | app.BaseServerManager.BaseServerManager | |
processCheckTaskState(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
processDeleteTask(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
processDeleteTaskResults(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
processFetchTaskResults(self, event) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
processNewTask(self, newTaskObj) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
processSpecialConfigVars(self, name, value) | app.BaseServerManager.BaseServerManager | |
processUpdateTaskFields(self, operationType, eeResponseData, cookie=None) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
reply(self, event, reply_event) | app.BaseServerManager.BaseServerManager | |
run(self) | app.BaseServerManager.BaseServerManager | |
saveStatVarsDump(self) | app.BaseServerManager.BaseServerManager | |
send(self, connect_name, event) | app.BaseServerManager.BaseServerManager | |
sendAdminReadyEvent(self) | app.BaseServerManager.BaseServerManager | |
sendGetTaskManagerFieldsRequest(self, taskId, cookieData=None) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
sendToDRCERouter(self, request) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
sendToHCENodeAdmin(self, host, port, messageParameters) | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
serverName | dtm.ExecutionEnvironmentManager.ExecutionEnvironmentManager | |
setConfigVars(self, setConfigVars) | app.BaseServerManager.BaseServerManager | |
setEventHandler(self, eventType, handler) | app.BaseServerManager.BaseServerManager | |
setLogLevel(self, level) | app.BaseServerManager.BaseServerManager | |
STAT_DUMPS_DEFAULT_DIR | app.BaseServerManager.BaseServerManager | static |
STAT_DUMPS_DEFAULT_NAME | app.BaseServerManager.BaseServerManager | static |
STAT_FIELDS_OPERATION_ADD | app.BaseServerManager.BaseServerManager | static |
STAT_FIELDS_OPERATION_INIT | app.BaseServerManager.BaseServerManager | static |
STAT_FIELDS_OPERATION_SET | app.BaseServerManager.BaseServerManager | static |
STAT_FIELDS_OPERATION_SUB | app.BaseServerManager.BaseServerManager | static |
statFields | app.BaseServerManager.BaseServerManager | |
updateStatField(self, field_name, value, operation=STAT_FIELDS_OPERATION_ADD) | app.BaseServerManager.BaseServerManager | |