__init__(self, configParser, connectBuilderLight, pollerManager=None) | dtm.TasksManager.TasksManager | |
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 | |
addNewTaskData(self, event) | dtm.TasksManager.TasksManager | |
ADMIN_CONNECT_CLIENT | app.BaseServerManager.BaseServerManager | static |
ADMIN_CONNECT_ENDPOINT | app.BaseServerManager.BaseServerManager | static |
AUTO_CLEANUP_TIME_SLOT_PERIOD | dtm.TasksManager.TasksManager | static |
build_poller_list(self) | app.BaseServerManager.BaseServerManager | |
cfg_section | dtm.TasksManager.TasksManager | |
checkCleanUp(self, taskId=None) | dtm.TasksManager.TasksManager | |
checkTaskPresence(self, taskId) | dtm.TasksManager.TasksManager | |
cleanAfterDBIErr(self, event) | dtm.TasksManager.TasksManager | |
CLEANUP_TABLES_LIST | dtm.TasksManager.TasksManager | static |
cleanUpOnStart(self, isClearOnStart) | dtm.TasksManager.TasksManager | |
cleanupTables(self) | dtm.TasksManager.TasksManager | |
cleanUpTask(self, taskBackLogScheme) | dtm.TasksManager.TasksManager | |
cleanUpTaskNetworkOperation(self, taskId, delFromTDMData) | dtm.TasksManager.TasksManager | |
cleanUpTimeout | dtm.TasksManager.TasksManager | |
clear_poller(self) | app.BaseServerManager.BaseServerManager | |
clearEmptyFields(self, fields, taskId) | dtm.TasksManager.TasksManager | |
CONFIG_TIME_SLOT_PERIOD | dtm.TasksManager.TasksManager | static |
configVars | app.BaseServerManager.BaseServerManager | |
connections | app.BaseServerManager.BaseServerManager | |
createDBIDict(self, configParser) | app.BaseServerManager.BaseServerManager | |
createLogMsg(self, event) | app.BaseServerManager.BaseServerManager | |
createOperationSteps(self, event, dataManagerEventType, onlyLastTwo=False) | dtm.TasksManager.TasksManager | |
createTaskLog(self, taskObj) | dtm.TasksManager.TasksManager | |
createTaskLogFromDic(self, fields) | dtm.TasksManager.TasksManager | |
createTaskManagerFields(self, taskLog) | dtm.TasksManager.TasksManager | |
dbi | dtm.TasksManager.TasksManager | |
deleteOnCleanUp(self, taskData, autoCleanupFields) | dtm.TasksManager.TasksManager | |
dumpStatVars | app.BaseServerManager.BaseServerManager | |
event_handlers | app.BaseServerManager.BaseServerManager | |
eventBuilder | app.BaseServerManager.BaseServerManager | |
exceptionForward | app.BaseServerManager.BaseServerManager | |
exit_flag | app.BaseServerManager.BaseServerManager | |
fetchEvents | dtm.TasksManager.TasksManager | |
finishNewTaskData(self, event) | dtm.TasksManager.TasksManager | |
getConfigVarsFields(self, fields) | app.BaseServerManager.BaseServerManager | |
getDeletedTask(self, taskLog) | dtm.TasksManager.TasksManager | |
getLogLevel(self) | app.BaseServerManager.BaseServerManager | |
getStatDataFields(self, fields) | app.BaseServerManager.BaseServerManager | |
getStatVarsDumpFileName(self) | app.BaseServerManager.BaseServerManager | |
getSystemStat(self) | app.BaseServerManager.BaseServerManager | |
groupDeleteResponseEvent | dtm.TasksManager.TasksManager | |
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 |
newTaskRollback(self, event) | dtm.TasksManager.TasksManager | |
on_poll_timeout(self) | dtm.TasksManager.TasksManager | |
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 | |
onDeleteTask(self, event) | dtm.TasksManager.TasksManager | |
onDeleteTaskResponse(self, event) | dtm.TasksManager.TasksManager | |
onFetchAvailableTasks(self, event) | dtm.TasksManager.TasksManager | |
onFetchResultResponse(self, event) | dtm.TasksManager.TasksManager | |
onFetchResultsCache(self, event) | dtm.TasksManager.TasksManager | |
onFetchTaskDataResponse(self, event) | dtm.TasksManager.TasksManager | |
onGetTaskFields(self, event) | dtm.TasksManager.TasksManager | |
onGetTaskStatus(self, event) | dtm.TasksManager.TasksManager | |
onNewTask(self, event) | dtm.TasksManager.TasksManager | |
onTasksManagerGeneralResponse(self, event) | dtm.TasksManager.TasksManager | |
onUpdateTask(self, event) | dtm.TasksManager.TasksManager | |
onUpdateTaskField(self, event) | dtm.TasksManager.TasksManager | |
pendingTasks | dtm.TasksManager.TasksManager | |
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 | |
prevCleanUpTime | dtm.TasksManager.TasksManager | |
process(self, event) | app.BaseServerManager.BaseServerManager | |
processOperationStep(self, event) | dtm.TasksManager.TasksManager | |
processSchedulerFailure(self, event) | dtm.TasksManager.TasksManager | |
processSpecialConfigVars(self, name, value) | app.BaseServerManager.BaseServerManager | |
processTasksDataManagerFailure(self, event) | dtm.TasksManager.TasksManager | |
reply(self, event, reply_event) | app.BaseServerManager.BaseServerManager | |
replyGeneralResponse(self, event) | dtm.TasksManager.TasksManager | |
restoreTaskSteps(self, taskId) | dtm.TasksManager.TasksManager | |
run(self) | app.BaseServerManager.BaseServerManager | |
saveStatVarsDump(self) | app.BaseServerManager.BaseServerManager | |
SCHEDULER_CLIENT | dtm.TasksManager.TasksManager | static |
send(self, connect_name, event) | app.BaseServerManager.BaseServerManager | |
sendAdminReadyEvent(self) | app.BaseServerManager.BaseServerManager | |
sendGroupDeleteResponse(self) | dtm.TasksManager.TasksManager | |
SERVER | dtm.TasksManager.TasksManager | static |
setConfigVars(self, setConfigVars) | app.BaseServerManager.BaseServerManager | |
setEventHandler(self, eventType, handler) | app.BaseServerManager.BaseServerManager | |
setLogLevel(self, level) | app.BaseServerManager.BaseServerManager | |
simpleDeleteTask(self, event, responseEventType) | dtm.TasksManager.TasksManager | |
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 | |
statFieldsRecalculate(self, taskLogScheme) | dtm.TasksManager.TasksManager | |
TASKS_DATA_MANAGER_CLIENT | dtm.TasksManager.TasksManager | static |
tasksQueue | dtm.TasksManager.TasksManager | |
updateStatField(self, field_name, value, operation=STAT_FIELDS_OPERATION_ADD) | app.BaseServerManager.BaseServerManager | |
updateTaskBackLogToSchedulerStep(self, localId, incr, newState) | dtm.TasksManager.TasksManager | |
VAR_TASKS_DELETE_TRIES | dtm.TasksManager.TasksManager | static |
VAR_TASKS_ERRORS | dtm.TasksManager.TasksManager | static |
VAR_TASKS_RETRIES | dtm.TasksManager.TasksManager | static |
VAR_TASKS_RETRIES_DEL | dtm.TasksManager.TasksManager | static |
VAR_TASKS_TIME_AVG | dtm.TasksManager.TasksManager | static |
VAR_TASKS_TIME_COUNT | dtm.TasksManager.TasksManager | static |
VAR_TASKS_TIME_MAX | dtm.TasksManager.TasksManager | static |
VAR_TASKS_TIME_MIN | dtm.TasksManager.TasksManager | static |
VAR_TASKS_TIME_SUM | dtm.TasksManager.TasksManager | static |
VAR_TASKS_TOTAL | dtm.TasksManager.TasksManager | static |
VAR_TASKS_TOTAL_DEL | dtm.TasksManager.TasksManager | static |