The TasksStateUpdateService class, is a listener of tasks state updates from DRCE FO of cluster nodes. More...

Inheritance diagram for dtm.TasksStateUpdateService.TasksStateUpdateService:

Collaboration diagram for dtm.TasksStateUpdateService.TasksStateUpdateService:

Public Member Functions
def	__init__ (self, configParser, connectionBuilderLight=None, connectionBuilder=None)
	constructor initialize fields More...

def	onUpdateTaskFieldsResponse (self, event)
	onUpdateTaskFieldsResponse event handler More...

def	onTCPServerRequest (self, event)
	onTCPServerRequest handler of TCP server requests. More...

def	onReceiveAllTaskIds (self, event)
	onReceiveAllTaskIds handler for receive running tasks from TasksManager More...

def	on_poll_timeout (self)
	on_poll_timeout handler, now just send CheckState to EEManager More...

def	tryCheckTasksState (self)
	send CheckState message to EEManager if don't have cached task id, then fetch from TasksManager More...

def	processUpdateTaskFields (self, taskResponse)
	Send UpdateTasksData event to the TasksManager. More...

Public Member Functions inherited from app.BaseServerManager.BaseServerManager
def	__init__ (self, poller_manager=None, admin_connection=None, conectionLightBuilder=None, exceptionForward=False, dumpStatVars=True)
	constructor More...

def	addConnection (self, name, connection)

def	setEventHandler (self, eventType, handler)
	set event handler rewrite the current handler for eventType More...

def	send (self, connect_name, event)
	send event More...

def	reply (self, event, reply_event)
	wrapper for sending event in reply for event More...

def	poll (self)
	poll function polling connections receive as multipart msg, the second argument is pickled pyobj More...

def	process (self, event)
	process event call the event handler method that was set by user or on_unhandled_event method if not set More...

def	run (self)

def	is_connection_registered (self, name)
	check is a connection was registered in a instance of BaseServerManager i object More...

def	on_poll_timeout (self)
	function will call every time when ConnectionTimeout exception arrive More...

def	on_unhandled_event (self, event)
	function will call every time when arrive doesn't set handler for event type of event.evenType More...

def	build_poller_list (self)

def	clear_poller (self)

def	onAdminState (self, event)
	onAdminState event handler process admin SHUTDOWN command More...

def	onAdminFetchStatData (self, event)
	onAdminState event handler process admin command More...

def	onAdminSuspend (self, event)
	onAdminState event handler process admin command More...

def	getStatDataFields (self, fields)
	getStatDataFields returns stat data from storage More...

def	getSystemStat (self)
	getSystemStat returns stat data for system indicators: RAMV, RAMR and CPU More...

def	getConfigVarsFields (self, fields)
	getConfigVarsFields returns config vars from storage More...

def	onAdminGetConfigVars (self, event)
	onAdminGetConfigVars event handler process getConfigVars admin command, fill and return config vars array from internal storage More...

def	onAdminSetConfigVars (self, event)
	onAdminSetConfigVars event handler process setConfigVars admin command More...

def	setConfigVars (self, setConfigVars)
	processSetConfigVars sets config vars in storage More...

def	sendAdminReadyEvent (self)
	send ready event to notify adminInterfaceService More...

def	createLogMsg (self, event)
	from string message from event object More...

def	initStatFields (self, connect_name)
	add record in statFields More...

def	updateStatField (self, field_name, value, operation=STAT_FIELDS_OPERATION_ADD)
	update values of stat field - default sum More...

def	processSpecialConfigVars (self, name, value)
	send ready event to notify adminInterfaceService More...

def	getLogLevel (self)
	Get log level from first of existing loggers. More...

def	setLogLevel (self, level)
	Set log level for all loggers. More...

def	saveStatVarsDump (self)
	Save stat vars in json file. More...

def	loadStatVarsDump (self)
	Load stat vars in json file. More...

def	getStatVarsDumpFileName (self)
	Get stat vars file name. More...

def	createDBIDict (self, configParser)

Public Attributes
	expect_response

	clientTasksManagerName

	serverHost

	serverPort

	clientExecutionEnvironmentManager

	drceIdGenerator

	drceCommandConvertor

	lastCheckStateTs
	timestamp of last send CheckState request More...

	checkStateInterval

	checkStateNum

	fetchTaskNum

	taskIdsForCheckState
	list of task ids for check state More...

Public Attributes inherited from app.BaseServerManager.BaseServerManager
	dumpStatVars

	poller_manager

	eventBuilder

	exit_flag

	pollTimeout

	connections

	event_handlers

	statFields
	stat fields container More...

	configVars

	exceptionForward

Static Public Attributes
string	CONFIG_SERVER_HOST = "serverHost"

string	CONFIG_SERVER_PORT = "serverPort"

string	CONFIG_TASKS_MANAGER_CLIENT = "clientTasksManager"

string	CONFIG_EE_MANAGER = "clientExecutionEnvironmentManager"

string	CONFIG_CHECK_STATE_NUM = "checkStateNum"

string	CONFIG_CHECK_STATE_INTERVAL = "checkStateInterval"

string	CONFIG_FETCH_TASK_NUM = "checkStateTasks"

string	ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION = "Update request error, possible wrong json format!"

string	ERROR_TASK_FIELDS_UPDATE = "Update of task fields response error."

int	UPDATE_TYPE_TASK_STATE = 100

int	UPDATE_TYPE_RESOURCES_STATE = 101

Static Public Attributes inherited from app.BaseServerManager.BaseServerManager
string	ADMIN_CONNECT_ENDPOINT = "Admin"

string	ADMIN_CONNECT_CLIENT = "Admin"

int	POLL_TIMEOUT_DEFAULT = 3000

int	STAT_FIELDS_OPERATION_ADD = 0

int	STAT_FIELDS_OPERATION_SUB = 1

int	STAT_FIELDS_OPERATION_SET = 2

int	STAT_FIELDS_OPERATION_INIT = 3

string	POLL_TIMEOUT_CONFIG_VAR_NAME = "POLL_TIMEOUT"

string	LOG_LEVEL_CONFIG_VAR_NAME = "LOG_LEVEL"

string	STAT_DUMPS_DEFAULT_DIR = "/tmp/"

string	STAT_DUMPS_DEFAULT_NAME = "%APP_NAME%_%CLASS_NAME%_stat_vars.dump"

dictionary	LOGGERS_NAMES = {APP_CONSTS.LOGGER_NAME, "dc", "dtm", "root", ""}

Detailed Description

The TasksStateUpdateService class, is a listener of tasks state updates from DRCE FO of cluster nodes.

TasksStateUpdateService object and related classes definitions. This object acts as listener of updates of tasks states inside DRCE Execution Environment. The DRCE Functional objects callback connects to this service and send update message when task changes its state. This call initiated by DRCE node FO watchdog.

Definition at line 49 of file TasksStateUpdateService.py.

Constructor & Destructor Documentation

◆ init()

def dtm.TasksStateUpdateService.TasksStateUpdateService.__init__	(	self,
		configParser,
		connectionBuilderLight = `None`,
		connectionBuilder = `None`
	)

constructor initialize fields

Parameters

configParser	config parser object
connectBuilderLight	network transport connection builder light
connectionBuilder	network transport connection builder

Definition at line 72 of file TasksStateUpdateService.py.

   def __init__(self, configParser, connectionBuilderLight=None, connectionBuilder=None):
     super(TasksStateUpdateService, self).__init__()
     self.expect_response = Response(["sock_identity", "id", "body"])
 
     #Instantiate the connection builder light if not set
     if connectionBuilderLight is None:
       connectionBuilderLight = ConnectionBuilderLight()
     #Instantiate the connection builder if not set
     if connectionBuilder is None:
       connectionBuilder = ConnectionBuilder(IDGenerator())
 
     className = self.__class__.__name__
 
     #Get configuration settings
     self.clientTasksManagerName = configParser.get(className, self.CONFIG_TASKS_MANAGER_CLIENT)
     self.serverHost = configParser.get(className, self.CONFIG_SERVER_HOST)
     self.serverPort = configParser.get(className, self.CONFIG_SERVER_PORT)
     self.clientExecutionEnvironmentManager = configParser.get(className, self.CONFIG_EE_MANAGER)
 
     #Create connections and raise bind or connect actions for correspondent connection type
     tasksManagerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.CLIENT_CONNECT, self.clientTasksManagerName)
     tcpServerConnection = connectionBuilder.build(TRANSPORT_CONSTS.DATA_CONNECT_TYPE,
                                                   ConnectionParams(self.serverHost, self.serverPort),
                                                   TRANSPORT_CONSTS.SERVER_CONNECT)
     eeManagerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.CLIENT_CONNECT,
                                                        self.clientExecutionEnvironmentManager)
 
     #Add connections to the polling set
     self.addConnection(self.clientTasksManagerName, tasksManagerConnection)
     self.addConnection(self.serverHost, tcpServerConnection)
     self.addConnection(self.clientExecutionEnvironmentManager, eeManagerConnection)
 
     #Set event handler for EXECUTE_TASK event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.UPDATE_TASK_FIELDS_RESPONSE, self.onUpdateTaskFieldsResponse)
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.SERVER_TCP_RAW, self.onTCPServerRequest)
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.AVAILABLE_TASK_IDS_RESPONSE, self.onReceiveAllTaskIds)
 
     #Initialize unique Id generator
     self.drceIdGenerator = UIDGenerator()
     #Initialize DRCE commands convertor
     self.drceCommandConvertor = CommandConvertor()
 
     #variables for auto send CheckState to EEManager
     
     self.lastCheckStateTs = 0
     self.checkStateInterval = configParser.getint(className, self.CONFIG_CHECK_STATE_INTERVAL)
     self.checkStateNum = configParser.getint(className, self.CONFIG_CHECK_STATE_NUM)
     self.fetchTaskNum = configParser.getint(className, self.CONFIG_FETCH_TASK_NUM)
 
     # Set connections poll timeout, defines period of tasks state checks
     self.configVars[self.POLL_TIMEOUT_CONFIG_VAR_NAME] = \
                    configParser.getint(className, self.POLL_TIMEOUT_CONFIG_VAR_NAME)
 
     
     self.taskIdsForCheckState = []
 
     logger.debug("Construction finished!")
 
 
 

Member Function Documentation

◆ on_poll_timeout()

def dtm.TasksStateUpdateService.TasksStateUpdateService.on_poll_timeout ( self )

on_poll_timeout handler, now just send CheckState to EEManager

Definition at line 183 of file TasksStateUpdateService.py.

   def on_poll_timeout(self):
     logger.debug("Possible time to check state of tasks, interval " + str(self.checkStateInterval) + "!")
     if time.time() - self.lastCheckStateTs > self.checkStateInterval:
       logger.debug("Now time to check state of tasks, interval " + str(self.checkStateInterval) + "!")
       self.lastCheckStateTs = time.time()
       self.tryCheckTasksState()
 
 
 

Here is the call graph for this function:

◆ onReceiveAllTaskIds()

def dtm.TasksStateUpdateService.TasksStateUpdateService.onReceiveAllTaskIds	(	self,
		event
	)

onReceiveAllTaskIds handler for receive running tasks from TasksManager

Parameters

event instance of Event object

Definition at line 174 of file TasksStateUpdateService.py.

   def onReceiveAllTaskIds(self, event):
     logger.debug("Available tasks list from TasksManager received, items " + str(len(event.eventObj.ids)))
     self.taskIdsForCheckState += event.eventObj.ids
     if len(self.taskIdsForCheckState) > 0:
       self.tryCheckTasksState()
 
 
 

Here is the call graph for this function:

◆ onTCPServerRequest()

def dtm.TasksStateUpdateService.TasksStateUpdateService.onTCPServerRequest	(	self,
		event
	)

onTCPServerRequest handler of TCP server requests.

Requests done by DRCE FO clients and send task state update, according with DRCE FO response protocol specification

Parameters

event instance of Event object

Definition at line 152 of file TasksStateUpdateService.py.

   def onTCPServerRequest(self, event):
     logger.debug("Update request received!")
 
     #Get request raw buffer from eventObj and convert if to the DRCE response object
     rawDRCEJsonResponse = event.eventObj.get_body()
     try:
       #Convert DRCE jason protocol response to TaskResponse object
       taskResponse = self.drceCommandConvertor.from_json(rawDRCEJsonResponse)
       logger.debug("rawDRCEJsonResponse:\n" + str(rawDRCEJsonResponse) + "\nObject:\n" + Utils.varDump(taskResponse))
       #Update task data on TasksManager object
       self.processUpdateTaskFields(taskResponse)
     except Exception, e:
       logger.error(self.ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION + " : " + str(e.message) + " : \n" + \
                    rawDRCEJsonResponse)
 
     logger.debug("TCP update request processing finished!")
 
 
 

Here is the call graph for this function:

◆ onUpdateTaskFieldsResponse()

def dtm.TasksStateUpdateService.TasksStateUpdateService.onUpdateTaskFieldsResponse	(	self,
		event
	)

onUpdateTaskFieldsResponse event handler

Parameters

event instance of Event object

Definition at line 137 of file TasksStateUpdateService.py.

   def onUpdateTaskFieldsResponse(self, event):
     #Get task Id from event
     generalResponse = event.eventObj
     #Log error
     if generalResponse.errorCode != dtm.EventObjects.GeneralResponse.ERROR_OK:
       logger.error(LogFormatterEvent(event, [], self.ERROR_TASK_FIELDS_UPDATE))
 
     logger.debug("Update tasks state response finished!")
 
 
 

◆ processUpdateTaskFields()

def dtm.TasksStateUpdateService.TasksStateUpdateService.processUpdateTaskFields	(	self,
		taskResponse
	)

Send UpdateTasksData event to the TasksManager.

Parameters

taskResponse The DRCE response data object

Definition at line 217 of file TasksStateUpdateService.py.

   def processUpdateTaskFields(self, taskResponse):
     #taskResponse is an instance of drce.Commands.TaskResponse
     #it may contains 0 or many response items
     if len(taskResponse.items) == 0:
       logger.error("Received empty update request from drce node!")
     else:
       # Tasks state update notification
       for resItem in taskResponse.items:
         # If no errors in response from EE
         # TODO: strange, in case of error still continue to use resItem object...
         if resItem.error_code != dtm.EventObjects.EEResponseData.ERROR_CODE_OK:
           logger.error("Update request item from node %s, error: %s :%s",
                        resItem.node, resItem.error_code, resItem.error_message)
         # Update task's fields object for the TasksManager
         updateTaskFields = dtm.EventObjects.UpdateTaskFields(resItem.id)
         # Fill fields to update
         updateTaskFields.fields[DTM_CONSTS.DRCE_FIELDS.HOST] = resItem.host
         updateTaskFields.fields[DTM_CONSTS.DRCE_FIELDS.PORT] = resItem.port
 
         if resItem.type == self.UPDATE_TYPE_RESOURCES_STATE:
           # Resources state update notification, the "state" field possible is not valid
           logger.debug("Resources state update notification")
           updateTaskFields.fields["state"] = None
         else:
           # Task state update notification, the "state" field is valid
           logger.debug("Task state update notification")
           updateTaskFields.fields["state"] = resItem.state
 
         updateTaskFields.fields["pId"] = resItem.pid
         updateTaskFields.fields["nodeName"] = resItem.node
         updateTaskFields.fields["pTime"] = resItem.time
         if resItem.state == dtm.EventObjects.EEResponseData.TASK_STATE_NEW:
           updateTaskFields.fields["rDate"] = datetime.now()
         else:
           if resItem.state == dtm.EventObjects.EEResponseData.TASK_STATE_FINISHED:
             updateTaskFields.fields["fDate"] = datetime.now()
         #Fix due the TasksManager does not recognize UNDEFINED or TERMINATED state
         if resItem.state == dtm.EventObjects.EEResponseData.TASK_STATE_UNDEFINED or\
            resItem.state == dtm.EventObjects.EEResponseData.TASK_STATE_TERMINATED:
           updateTaskFields.fields["state"] = dtm.EventObjects.EEResponseData.TASK_STATE_FINISHED
 
         if DTM_CONSTS.DRCE_FIELDS.URRAM in resItem.fields:
           updateTaskFields.fields["uRRAM"] = resItem.fields[DTM_CONSTS.DRCE_FIELDS.URRAM]
         if DTM_CONSTS.DRCE_FIELDS.UVRAM in resItem.fields:
           updateTaskFields.fields["uVRAM"] = resItem.fields[DTM_CONSTS.DRCE_FIELDS.UVRAM]
         if DTM_CONSTS.DRCE_FIELDS.UCPU in resItem.fields:
           updateTaskFields.fields["uCPU"] = resItem.fields[DTM_CONSTS.DRCE_FIELDS.UCPU]
         if DTM_CONSTS.DRCE_FIELDS.UTHREADS in resItem.fields:
           updateTaskFields.fields["uThreads"] = resItem.fields[DTM_CONSTS.DRCE_FIELDS.UTHREADS]
 
         #Create update event
         updateTaskFieldsEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.UPDATE_TASK_FIELDS, updateTaskFields)
         #Send update event to TasksManager
         self.send(self.clientTasksManagerName, updateTaskFieldsEvent)
         logger.debug("Update TasksManager fields for task " + str(resItem.id) + " finished!")
 
     logger.debug("Update TasksManager fields for all tasks finished!")

Here is the call graph for this function:






Here is the caller graph for this function:

◆ tryCheckTasksState()

def dtm.TasksStateUpdateService.TasksStateUpdateService.tryCheckTasksState ( self )

send CheckState message to EEManager if don't have cached task id, then fetch from TasksManager

Definition at line 194 of file TasksStateUpdateService.py.

   def tryCheckTasksState(self):
     if self.taskIdsForCheckState:
       logger.debug("Tasks to check " + str(len(self.taskIdsForCheckState)))
       for taskId in self.taskIdsForCheckState[:self.checkStateNum]:
         req = dtm.EventObjects.CheckTaskState(taskId)
         event = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.CHECK_TASK_STATE, req)
         event.cookie = self.__class__.__name__
         self.send(self.clientExecutionEnvironmentManager, event)
         logger.debug("Task " + str(taskId) + " sent to check state to EEManager")
       self.taskIdsForCheckState = self.taskIdsForCheckState[self.checkStateNum:]
     else:
       logger.debug("Get available tasks list from TasksManager")
       req = dtm.EventObjects.FetchAvailabelTaskIds(self.fetchTaskNum)
       if req.criterions is not None:
         req.criterions[app.SQLCriterions.CRITERION_WHERE] = "deleteTaskId = 0 AND state < 100"
       event = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.FETCH_AVAILABLE_TASK_IDS, req)
       self.send(self.clientTasksManagerName, event)
 
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ checkStateInterval

dtm.TasksStateUpdateService.TasksStateUpdateService.checkStateInterval

Definition at line 118 of file TasksStateUpdateService.py.

◆ checkStateNum

dtm.TasksStateUpdateService.TasksStateUpdateService.checkStateNum

Definition at line 119 of file TasksStateUpdateService.py.

◆ clientExecutionEnvironmentManager

dtm.TasksStateUpdateService.TasksStateUpdateService.clientExecutionEnvironmentManager

Definition at line 89 of file TasksStateUpdateService.py.

◆ clientTasksManagerName

dtm.TasksStateUpdateService.TasksStateUpdateService.clientTasksManagerName

Definition at line 86 of file TasksStateUpdateService.py.

◆ CONFIG_CHECK_STATE_INTERVAL

string dtm.TasksStateUpdateService.TasksStateUpdateService.CONFIG_CHECK_STATE_INTERVAL = "checkStateInterval"

static

Definition at line 57 of file TasksStateUpdateService.py.

◆ CONFIG_CHECK_STATE_NUM

string dtm.TasksStateUpdateService.TasksStateUpdateService.CONFIG_CHECK_STATE_NUM = "checkStateNum"

static

Definition at line 56 of file TasksStateUpdateService.py.

◆ CONFIG_EE_MANAGER

string dtm.TasksStateUpdateService.TasksStateUpdateService.CONFIG_EE_MANAGER = "clientExecutionEnvironmentManager"

static

Definition at line 55 of file TasksStateUpdateService.py.

◆ CONFIG_FETCH_TASK_NUM

string dtm.TasksStateUpdateService.TasksStateUpdateService.CONFIG_FETCH_TASK_NUM = "checkStateTasks"

static

Definition at line 58 of file TasksStateUpdateService.py.

◆ CONFIG_SERVER_HOST

string dtm.TasksStateUpdateService.TasksStateUpdateService.CONFIG_SERVER_HOST = "serverHost"

static

Definition at line 52 of file TasksStateUpdateService.py.

◆ CONFIG_SERVER_PORT

string dtm.TasksStateUpdateService.TasksStateUpdateService.CONFIG_SERVER_PORT = "serverPort"

static

Definition at line 53 of file TasksStateUpdateService.py.

◆ CONFIG_TASKS_MANAGER_CLIENT

string dtm.TasksStateUpdateService.TasksStateUpdateService.CONFIG_TASKS_MANAGER_CLIENT = "clientTasksManager"

static

Definition at line 54 of file TasksStateUpdateService.py.

◆ drceCommandConvertor

dtm.TasksStateUpdateService.TasksStateUpdateService.drceCommandConvertor

Definition at line 112 of file TasksStateUpdateService.py.

◆ drceIdGenerator

dtm.TasksStateUpdateService.TasksStateUpdateService.drceIdGenerator

Definition at line 110 of file TasksStateUpdateService.py.

◆ ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION

string dtm.TasksStateUpdateService.TasksStateUpdateService.ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION = "Update request error, possible wrong json format!"

static

Definition at line 60 of file TasksStateUpdateService.py.

◆ ERROR_TASK_FIELDS_UPDATE

string dtm.TasksStateUpdateService.TasksStateUpdateService.ERROR_TASK_FIELDS_UPDATE = "Update of task fields response error."

static

Definition at line 61 of file TasksStateUpdateService.py.

◆ expect_response

dtm.TasksStateUpdateService.TasksStateUpdateService.expect_response

Definition at line 74 of file TasksStateUpdateService.py.

◆ fetchTaskNum

dtm.TasksStateUpdateService.TasksStateUpdateService.fetchTaskNum

Definition at line 120 of file TasksStateUpdateService.py.

◆ lastCheckStateTs

dtm.TasksStateUpdateService.TasksStateUpdateService.lastCheckStateTs

timestamp of last send CheckState request

Definition at line 117 of file TasksStateUpdateService.py.

◆ serverHost

dtm.TasksStateUpdateService.TasksStateUpdateService.serverHost

Definition at line 87 of file TasksStateUpdateService.py.

◆ serverPort

dtm.TasksStateUpdateService.TasksStateUpdateService.serverPort

Definition at line 88 of file TasksStateUpdateService.py.

◆ taskIdsForCheckState

dtm.TasksStateUpdateService.TasksStateUpdateService.taskIdsForCheckState

list of task ids for check state

Definition at line 128 of file TasksStateUpdateService.py.

◆ UPDATE_TYPE_RESOURCES_STATE

int dtm.TasksStateUpdateService.TasksStateUpdateService.UPDATE_TYPE_RESOURCES_STATE = 101

static

Definition at line 64 of file TasksStateUpdateService.py.

◆ UPDATE_TYPE_TASK_STATE

int dtm.TasksStateUpdateService.TasksStateUpdateService.UPDATE_TYPE_TASK_STATE = 100

static

Definition at line 63 of file TasksStateUpdateService.py.

The documentation for this class was generated from the following file:

sources/hce/dtm/TasksStateUpdateService.py

Public Member Functions

Public Attributes

Static Public Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __init__()

Member Function Documentation

◆ on_poll_timeout()

◆ onReceiveAllTaskIds()

◆ onTCPServerRequest()

◆ onUpdateTaskFieldsResponse()

◆ processUpdateTaskFields()

◆ tryCheckTasksState()

Member Data Documentation

◆ checkStateInterval

◆ checkStateNum

◆ clientExecutionEnvironmentManager

◆ clientTasksManagerName

◆ CONFIG_CHECK_STATE_INTERVAL

◆ CONFIG_CHECK_STATE_NUM

◆ CONFIG_EE_MANAGER

◆ CONFIG_FETCH_TASK_NUM

◆ CONFIG_SERVER_HOST

◆ CONFIG_SERVER_PORT

◆ CONFIG_TASKS_MANAGER_CLIENT

◆ drceCommandConvertor

◆ drceIdGenerator

◆ ERROR_HCE_RESPONSE_PROCESSING_EXCEPTION

◆ ERROR_TASK_FIELDS_UPDATE

◆ expect_response

◆ fetchTaskNum

◆ lastCheckStateTs

◆ serverHost

◆ serverPort

◆ taskIdsForCheckState

◆ UPDATE_TYPE_RESOURCES_STATE

◆ UPDATE_TYPE_TASK_STATE

◆ init()