Inheritance diagram for app.AdminInterfaceServer.AdminInterfaceServer:

Collaboration diagram for app.AdminInterfaceServer.AdminInterfaceServer:

Public Member Functions
def	__init__ (self, configParser, connectionBuilderLight=None)

def	onAdminState (self, event)

def	onAdminStateResponse (self, event)

def	onAdminStatData (self, event)

def	onAdminStatDataResponse (self, event)

def	onAdminGetConfigVars (self, event)

def	onAdminGetConfigVarsResponse (self, event)

def	onAdminSetConfigVars (self, event)

def	onAdminSetConfigVarsResponse (self, event)

def	onAdminSuspendResponse (self, event)

def	processOwnStateRequest (self, event)

def	processOwnStatDataRequest (self, event)

def	getConnectionIdentityByEvent (self, event)

def	processOwnGetConfigVarsRequest (self, event)

def	processOwnSetConfigVarsRequest (self, event)

def	onAdminSuspend (self, event)

def	onAdminSystem (self, event)

def	onAdminSQLCustom (self, event)

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
	adminServerClients

	dbi

	onSuspendConnectionIds

	onSuspendConnectionIdent

	onSuspendResponseDict

	tcpServerEventIdToConnectIdentity

	exit_flag

	serverHost

	serverPort

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	ERROR_EVENT_NOT_FOUND = "Event not found in queue"

string	VERSION_STRING_NAME = "VERSION"

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

Definition at line 41 of file AdminInterfaceServer.py.

Constructor & Destructor Documentation

◆ init()

def app.AdminInterfaceServer.AdminInterfaceServer.__init__	(	self,
		configParser,
		connectionBuilderLight = `None`
	)

Definition at line 57 of file AdminInterfaceServer.py.

   def __init__(self, configParser, connectionBuilderLight=None):
     super(AdminInterfaceServer, self).__init__()
 
     # Admin server connection clients dic, format [className]=connect_identity
     self.adminServerClients = {}
 
     # #@var dbi
     # db contains two tables log and backlog
     try:
       self.dbi = DBI(self.createDBIDict(configParser))
     except Exception:
       self.dbi = None
 
     # Suspend responses list, identity and results dict
     self.onSuspendConnectionIds = {}
     self.onSuspendConnectionIdent = None
     self.onSuspendResponseDict = {}
 
     # TCP server events to client identity cross reference dic, format [event_id]=connect_identity
     self.tcpServerEventIdToConnectIdentity = {}
 
     # Instantiate the connection builder light if not set
     if connectionBuilderLight is None:
       connectionBuilderLight = ConnectionBuilderLight()
 
     className = self.__class__.__name__
     self.exit_flag = False
 
     # Get configuration settings
     self.serverHost = configParser.get(className, self.CONFIG_SERVER_HOST)
     self.serverPort = configParser.get(className, self.CONFIG_SERVER_PORT)
 
     # Create connections and raise bind or connect actions for correspondent connection type
     tcpServerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
                                                        self.serverHost + ":" + self.serverPort,
                                                        TRANSPORT_CONSTS.TCP_TYPE)
     adminServerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
                                                          BaseServerManager.ADMIN_CONNECT_ENDPOINT)
 
     # Add connections to the polling set
     self.addConnection(BaseServerManager.ADMIN_CONNECT_ENDPOINT, adminServerConnection)
     self.addConnection(self.serverHost, tcpServerConnection)
 
     # Set event handler for ADMIN_FETCH_STAT_DATA event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_FETCH_STAT_DATA, self.onAdminStatData)
     # Set event handler for ADMIN_FETCH_STAT_DATA_RESPONSE event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_FETCH_STAT_DATA_RESPONSE, self.onAdminStatDataResponse)
     # Set event handler for ADMIN_STATE event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_STATE, self.onAdminState)
     # Set event handler for ADMIN_STATE_RESPONSE event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_STATE_RESPONSE, self.onAdminStateResponse)
     # Set event handler for ADMIN_GET_CONFIG_VARS event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_GET_CONFIG_VARS, self.onAdminGetConfigVars)
     # Set event handler for ADMIN_GET_CONFIG_VARS_RESPONSE event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_GET_CONFIG_VARS_RESPONSE, self.onAdminGetConfigVarsResponse)
     # Set event handler for ADMIN_SET_CONFIG_VARS event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_SET_CONFIG_VARS, self.onAdminSetConfigVars)
     # Set event handler for ADMIN_SET_CONFIG_VARS_RESPONSE event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_SET_CONFIG_VARS_RESPONSE, self.onAdminSetConfigVarsResponse)
     # Set event handler for ADMIN_SUSPEND event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_SUSPEND, self.onAdminSuspend)
     # Set event handler for ADMIN_SUSPEND_RESPONSE event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_SUSPEND_RESPONSE, self.onAdminSuspendResponse)
     # Set event handler for ADMIN_SYSTEM event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_SYSTEM, self.onAdminSystem)
     # Set event handler for ADMIN_SYSTEM event
     self.setEventHandler(DTM_CONSTS.EVENT_TYPES.ADMIN_SQL_CUSTOM, self.onAdminSQLCustom)
     # Version string init in config vars
     self.configVars[self.VERSION_STRING_NAME] = APP_CONSTS.VERSION_STRING
     # Version string init in stat vars
     self.statFields[self.VERSION_STRING_NAME] = APP_CONSTS.VERSION_STRING
 
 
 

Member Function Documentation

◆ getConnectionIdentityByEvent()

def app.AdminInterfaceServer.AdminInterfaceServer.getConnectionIdentityByEvent	(	self,
		event
	)

Definition at line 393 of file AdminInterfaceServer.py.

   def getConnectionIdentityByEvent(self, event):
     connect_identity = None
 
     try:
       # Set connect identity from dic
       connect_identity = self.tcpServerEventIdToConnectIdentity.pop(event.uid)
     except Exception, e:
       logger.error(LogFormatterEvent(event, [], self.ERROR_EVENT_NOT_FOUND + " : " + e.__doc__ + " : " + e.message))
 
     return connect_identity
 
 

Here is the caller graph for this function:

◆ onAdminGetConfigVars()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminGetConfigVars	(	self,
		event
	)

Definition at line 238 of file AdminInterfaceServer.py.

   def onAdminGetConfigVars(self, event):
     try:
       # get event object
       adminConfigVars = event.eventObj
       if adminConfigVars.className == self.__class__.__name__:
         # Process himself instance
         logger.debug("Process GET_CONGIG_VARS request for himself!")
         self.processOwnGetConfigVarsRequest(event)
       else:
         if adminConfigVars.className in self.adminServerClients:
           # Store event information in the queue
           self.tcpServerEventIdToConnectIdentity[event.uid] = event.connect_identity
           # Build new event with the same structure
           requestEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_GET_CONFIG_VARS, adminConfigVars)
           # Set the same uid to have a possibility to identify the reply
           requestEvent.uid = event.uid
           # Set connect identity from registered clients
           requestEvent.connect_identity = self.adminServerClients[adminConfigVars.className]
           # Send event to the internal Admin connection for target class as third parameter
           self.send(BaseServerManager.ADMIN_CONNECT_ENDPOINT, requestEvent)
         else:
           logger.debug("Wrong name of target class [" + adminConfigVars.className + "]")
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 
 

Here is the call graph for this function:

◆ onAdminGetConfigVarsResponse()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminGetConfigVarsResponse	(	self,
		event
	)

Definition at line 268 of file AdminInterfaceServer.py.

   def onAdminGetConfigVarsResponse(self, event):
     try:
       # Get event object
       adminConfigVars = event.eventObj
       # Create new event
       replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_GET_CONFIG_VARS_RESPONSE, adminConfigVars)
       # Set reply event uid from source request event
       replyEvent.uid = event.uid
       # Set connect_identity from events dict by event.uid
       replyEvent.connect_identity = self.getConnectionIdentityByEvent(event)
       if replyEvent.connect_identity is not None:
         self.send(self.serverHost, replyEvent)
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 

Here is the call graph for this function:

◆ onAdminSetConfigVars()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminSetConfigVars	(	self,
		event
	)

Definition at line 287 of file AdminInterfaceServer.py.

   def onAdminSetConfigVars(self, event):
     try:
       # get event object
       adminConfigVars = event.eventObj
       if adminConfigVars.className == self.__class__.__name__:
         # Process himself instance
         logger.debug("Process SET_CONFIG_VARS request for himself!")
         self.processOwnSetConfigVarsRequest(event)
       else:
         if adminConfigVars.className in self.adminServerClients:
           # Store event information in the queue
           self.tcpServerEventIdToConnectIdentity[event.uid] = event.connect_identity
           # Build new event with the same structure
           requestEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_SET_CONFIG_VARS, adminConfigVars)
           # Set the same uid to have a possibility to identify the reply
           requestEvent.uid = event.uid
           # Set connect identity from registered clients
           requestEvent.connect_identity = self.adminServerClients[adminConfigVars.className]
           # Send event to the internal Admin connection for target class as third parameter
           self.send(BaseServerManager.ADMIN_CONNECT_ENDPOINT, requestEvent)
         else:
           logger.debug("Wrong name of target class [" + adminConfigVars.className + "]!")
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 

Here is the call graph for this function:

◆ onAdminSetConfigVarsResponse()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminSetConfigVarsResponse	(	self,
		event
	)

Definition at line 316 of file AdminInterfaceServer.py.

   def onAdminSetConfigVarsResponse(self, event):
     try:
       # Get event object
       adminConfigVars = event.eventObj
       # Create new event
       replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_SET_CONFIG_VARS_RESPONSE, adminConfigVars)
       # Set reply event uid from source request event
       replyEvent.uid = event.uid
       # Set connect_identity from events dict by event.uid
       replyEvent.connect_identity = self.getConnectionIdentityByEvent(event)
       if replyEvent.connect_identity is not None:
         self.send(self.serverHost, replyEvent)
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 

Here is the call graph for this function:

◆ onAdminSQLCustom()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminSQLCustom	(	self,
		event
	)

Definition at line 487 of file AdminInterfaceServer.py.

   def onAdminSQLCustom(self, event):
     logger.debug(">>> onAdminSQLCustom uid = " + str(event.uid))
     responseObj = dtm.EventObjects.CustomResponse(event.eventObj.rid, event.eventObj.query, "dtm")
     try:
       if self.dbi is not None:
         sqlResponse = self.dbi.sqlCustom(event.eventObj.query)
         responseObj.result = [dict(row) for row in sqlResponse]
         if self.dbi.errorCode != DBI_CONSTANTS.DBI_SUCCESS_CODE:
           responseObj.errString = self.dbi.errorMessage
     except Exception as err:
       ExceptionLog.handler(logger, err, "onAdminSQLCustom:")
     replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_SQL_CUSTOM_RESPONSE, responseObj)
     self.reply(event, replyEvent)

Here is the call graph for this function:

◆ onAdminStatData()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminStatData	(	self,
		event
	)

Definition at line 187 of file AdminInterfaceServer.py.

   def onAdminStatData(self, event):
     try:
       # get event object
       adminStatData = event.eventObj
       if adminStatData.className == self.__class__.__name__:
         # Process himself instance
         logger.debug("Process STAT request for himself!")
         self.processOwnStatDataRequest(event)
       else:
         if adminStatData.className in self.adminServerClients:
           logger.debug("Forward the STAT request for target class [" + adminStatData.className + "]!")
           # Store event information in the queue
           self.tcpServerEventIdToConnectIdentity[event.uid] = event.connect_identity
           # Build new event with the same structure
           requestEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_FETCH_STAT_DATA, adminStatData)
           # Set the same uid to have a possibility to identify the reply
           requestEvent.uid = event.uid
           # Set connect identity from registered clients
           requestEvent.connect_identity = self.adminServerClients[adminStatData.className]
           # Send event to the internal Admin connection for target class as third parameter
           self.send(BaseServerManager.ADMIN_CONNECT_ENDPOINT, requestEvent)
         else:
           # Received wrong class name, do nothing to push the timeout on client-side
           # TODO: Create right response with error message
           logger.debug("Requested STAT request for unregistered class [" + adminStatData.className + "]!")
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 

Here is the call graph for this function:

◆ onAdminStatDataResponse()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminStatDataResponse	(	self,
		event
	)

Definition at line 219 of file AdminInterfaceServer.py.

   def onAdminStatDataResponse(self, event):
     try:
       # Get event object
       adminStatData = event.eventObj
       # Create new event
       replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_FETCH_STAT_DATA_RESPONSE, adminStatData)
       # Set reply event uid from source request event
       replyEvent.uid = event.uid
       # Set connect_identity from events dict by event.uid
       replyEvent.connect_identity = self.getConnectionIdentityByEvent(event)
       if replyEvent.connect_identity is not None:
         self.send(self.serverHost, replyEvent)
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 

Here is the call graph for this function:

◆ onAdminState()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminState	(	self,
		event
	)

Definition at line 134 of file AdminInterfaceServer.py.

   def onAdminState(self, event):
     try:
       # get event object
       adminState = event.eventObj
       if adminState.className == self.__class__.__name__:
         # Process himself instance
         self.processOwnStateRequest(event)
       else:
         # Store event information in the queue
         self.tcpServerEventIdToConnectIdentity[event.uid] = event.connect_identity
         # Build new event with the same structure
         requestEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_STATE, adminState)
         # Set the same uid to have a possibility to identify the reply
         requestEvent.uid = event.uid
         if adminState.className in self.adminServerClients:
           # Set connect identity from registered clients
           requestEvent.connect_identity = self.adminServerClients[adminState.className]
           # Send event to the internal Admin connection for target class as third parameter
           self.send(BaseServerManager.ADMIN_CONNECT_ENDPOINT, requestEvent)
         else:
           logger.info("Class instance [" + adminState.className + "] not found ")
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 

Here is the call graph for this function:

◆ onAdminStateResponse()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminStateResponse	(	self,
		event
	)

Definition at line 162 of file AdminInterfaceServer.py.

   def onAdminStateResponse(self, event):
     try:
       # Get event object
       adminState = event.eventObj
       if adminState.command == dtm.EventObjects.AdminState.STATE_READY:
         # Process READY state, remember  connection identity
         self.adminServerClients[adminState.className] = event.connect_identity
         logger.info("Class instance [" + adminState.className + "] registered!")
       else:
         # Create new event
         replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_STATE_RESPONSE, adminState)
         # Set reply event uid from source request event
         replyEvent.uid = event.uid
         # Set connect_identity from events dict by event.uid
         replyEvent.connect_identity = self.getConnectionIdentityByEvent(event)
         if replyEvent.connect_identity is not None:
           self.send(self.serverHost, replyEvent)
           logger.info("Response to admin client sent!")
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 

Here is the call graph for this function:

◆ onAdminSuspend()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminSuspend	(	self,
		event
	)

Definition at line 431 of file AdminInterfaceServer.py.

   def onAdminSuspend(self, event):
     try:
       if len(self.onSuspendConnectionIds) > 0:
         responseObj = dtm.EventObjects.GeneralResponse(dtm.EventObjects.GeneralResponse.ERROR_OK,
                                                        ">>> Suspend already in progress")
         replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_SUSPEND_RESPONSE, responseObj)
         replyEvent.connect_identity = event.connect_identity
         if replyEvent.connect_identity is not None:
           self.send(self.serverHost, replyEvent)
       else:
         suspendObj = event.eventObj
         for clientName in self.adminServerClients:
           self.onSuspendConnectionIdent = event.connect_identity
           # Build new event with the same structure
           requestEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_SUSPEND, suspendObj)
           # Set connect identity from registered clients
           requestEvent.connect_identity = self.adminServerClients[clientName]
           # Store event information in the queue
           self.onSuspendConnectionIds[requestEvent.uid] = requestEvent.connect_identity
           # Send event to the internal Admin connection for target class as third parameter
           self.send(BaseServerManager.ADMIN_CONNECT_ENDPOINT, requestEvent)
           logger.debug(">>> SuspendRequest uid = " + str(requestEvent.uid))
     except Exception as err:
       ExceptionLog.handler(logger, err, "Exception:")
 
 

Here is the call graph for this function:

◆ onAdminSuspendResponse()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminSuspendResponse	(	self,
		event
	)

Definition at line 335 of file AdminInterfaceServer.py.

   def onAdminSuspendResponse(self, event):
     logger.debug(">>> SuspendResponse uid = " + str(event.uid))
     if event.uid in self.onSuspendConnectionIds:
       for key in self.adminServerClients.keys():
         if self.adminServerClients[key] == self.onSuspendConnectionIds[event.uid]:
           self.onSuspendResponseDict[key] = event.eventObj.errorMessage
       del self.onSuspendConnectionIds[event.uid]
       if len(self.onSuspendConnectionIds) == 0:
         responseObj = dtm.EventObjects.GeneralResponse(dtm.EventObjects.GeneralResponse.ERROR_OK, "All thread response")
         responseObj.statuses.append(self.onSuspendResponseDict)
         replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_SUSPEND_RESPONSE, responseObj)
         replyEvent.connect_identity = self.onSuspendConnectionIdent
         if replyEvent.connect_identity is not None:
           self.send(self.serverHost, replyEvent)
           self.onSuspendConnectionIdent = None
           self.onSuspendResponseDict = {}
 
 

Here is the call graph for this function:

◆ onAdminSystem()

def app.AdminInterfaceServer.AdminInterfaceServer.onAdminSystem	(	self,
		event
	)

Definition at line 460 of file AdminInterfaceServer.py.

   def onAdminSystem(self, event):
     logger.debug(">>> onAdminSystem uid = " + str(event.uid))
     try:
       if event.eventObj.type is None:
         raise Exception('Wrong event data were got: ' + varDump(event))
 
       systemCommand = SystemCommandHandler(logger)
       errorCode = systemCommand.execute(event.eventObj.type, event.eventObj.data)
       errorMessage = ''
       if errorCode == dtm.EventObjects.GeneralResponse.ERROR_OK:
         errorMessage = ">>> SystemCommand successfully finished"
       else:
         errorMessage = systemCommand.errorMsg
 
       responseObj = dtm.EventObjects.GeneralResponse(errorCode, errorMessage)
       replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_SYSTEM_RESPONSE, responseObj)
       replyEvent.connect_identity = event.connect_identity
       if replyEvent.connect_identity is not None:
         self.send(self.serverHost, replyEvent)
 
     except Exception as err:
       ExceptionLog.handler(logger, err, "onAdminSystem:")
 
 

Here is the call graph for this function:

◆ processOwnGetConfigVarsRequest()

def app.AdminInterfaceServer.AdminInterfaceServer.processOwnGetConfigVarsRequest	(	self,
		event
	)

Definition at line 408 of file AdminInterfaceServer.py.

   def processOwnGetConfigVarsRequest(self, event):
     adminConfigVars = event.eventObj
     # Fill regular fields
     adminConfigVars.fields = self.getConfigVarsFields(adminConfigVars.fields)
     # Reply the same object
     replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_GET_CONFIG_VARS_RESPONSE, adminConfigVars)
     self.reply(event, replyEvent)
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

◆ processOwnSetConfigVarsRequest()

def app.AdminInterfaceServer.AdminInterfaceServer.processOwnSetConfigVarsRequest	(	self,
		event
	)

Definition at line 420 of file AdminInterfaceServer.py.

   def processOwnSetConfigVarsRequest(self, event):
     adminConfigVars = event.eventObj
     # Reply the same object
     replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_SET_CONFIG_VARS_RESPONSE,
                                          self.setConfigVars(adminConfigVars))
     self.reply(event, replyEvent)
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

◆ processOwnStatDataRequest()

def app.AdminInterfaceServer.AdminInterfaceServer.processOwnStatDataRequest	(	self,
		event
	)

Definition at line 370 of file AdminInterfaceServer.py.

   def processOwnStatDataRequest(self, event):
     adminStatData = event.eventObj
     fieldsListLen = len(adminStatData.fields)
     # Fill regular fields
     adminStatData.fields = self.getStatDataFields(adminStatData.fields)
     # Fill the FIELD_CLIENTS_LIST if defined in requested fields list or it is empty
     if dtm.EventObjects.AdminStatData.FIELD_CLIENTS_LIST in adminStatData.fields or fieldsListLen == 0:
       # Fill the clients list as classes names
       clientsList = []
       for key in self.adminServerClients.keys():
         clientsList.append(key)
       adminStatData.fields[dtm.EventObjects.AdminStatData.FIELD_CLIENTS_LIST] = clientsList
     # Reply the same object
     replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_FETCH_STAT_DATA_RESPONSE, adminStatData)
     self.reply(event, replyEvent)
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

◆ processOwnStateRequest()

def app.AdminInterfaceServer.AdminInterfaceServer.processOwnStateRequest	(	self,
		event
	)

Definition at line 356 of file AdminInterfaceServer.py.

   def processOwnStateRequest(self, event):
     adminState = event.eventObj
     if adminState.command == dtm.EventObjects.AdminState.STATE_SHUTDOWN:
       # Reply the same object
       replyEvent = self.eventBuilder.build(DTM_CONSTS.EVENT_TYPES.ADMIN_STATE_RESPONSE, adminState)
       self.reply(event, replyEvent)
       logger.info("Has successfully shutdown!")
       # Shutdown himself
       self.exit_flag = True
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ adminServerClients

app.AdminInterfaceServer.AdminInterfaceServer.adminServerClients

Definition at line 61 of file AdminInterfaceServer.py.

◆ CONFIG_SERVER_HOST

string app.AdminInterfaceServer.AdminInterfaceServer.CONFIG_SERVER_HOST = "serverHost"

static

Definition at line 44 of file AdminInterfaceServer.py.

◆ CONFIG_SERVER_PORT

string app.AdminInterfaceServer.AdminInterfaceServer.CONFIG_SERVER_PORT = "serverPort"

static

Definition at line 45 of file AdminInterfaceServer.py.

◆ dbi

app.AdminInterfaceServer.AdminInterfaceServer.dbi

Definition at line 66 of file AdminInterfaceServer.py.

◆ ERROR_EVENT_NOT_FOUND

string app.AdminInterfaceServer.AdminInterfaceServer.ERROR_EVENT_NOT_FOUND = "Event not found in queue"

static

Definition at line 47 of file AdminInterfaceServer.py.

◆ exit_flag

app.AdminInterfaceServer.AdminInterfaceServer.exit_flag

Definition at line 83 of file AdminInterfaceServer.py.

◆ onSuspendConnectionIdent

app.AdminInterfaceServer.AdminInterfaceServer.onSuspendConnectionIdent

Definition at line 72 of file AdminInterfaceServer.py.

◆ onSuspendConnectionIds

app.AdminInterfaceServer.AdminInterfaceServer.onSuspendConnectionIds

Definition at line 71 of file AdminInterfaceServer.py.

◆ onSuspendResponseDict

app.AdminInterfaceServer.AdminInterfaceServer.onSuspendResponseDict

Definition at line 73 of file AdminInterfaceServer.py.

◆ serverHost

app.AdminInterfaceServer.AdminInterfaceServer.serverHost

Definition at line 86 of file AdminInterfaceServer.py.

◆ serverPort

app.AdminInterfaceServer.AdminInterfaceServer.serverPort

Definition at line 87 of file AdminInterfaceServer.py.

◆ tcpServerEventIdToConnectIdentity

app.AdminInterfaceServer.AdminInterfaceServer.tcpServerEventIdToConnectIdentity

Definition at line 76 of file AdminInterfaceServer.py.

◆ VERSION_STRING_NAME

string app.AdminInterfaceServer.AdminInterfaceServer.VERSION_STRING_NAME = "VERSION"

static

Definition at line 49 of file AdminInterfaceServer.py.

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

sources/hce/app/AdminInterfaceServer.py

Public Member Functions

Public Attributes

Static Public Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __init__()

Member Function Documentation

◆ getConnectionIdentityByEvent()

◆ onAdminGetConfigVars()

◆ onAdminGetConfigVarsResponse()

◆ onAdminSetConfigVars()

◆ onAdminSetConfigVarsResponse()

◆ onAdminSQLCustom()

◆ onAdminStatData()

◆ onAdminStatDataResponse()

◆ onAdminState()

◆ onAdminStateResponse()

◆ onAdminSuspend()

◆ onAdminSuspendResponse()

◆ onAdminSystem()

◆ processOwnGetConfigVarsRequest()

◆ processOwnSetConfigVarsRequest()

◆ processOwnStatDataRequest()

◆ processOwnStateRequest()

Member Data Documentation

◆ adminServerClients

◆ CONFIG_SERVER_HOST

◆ CONFIG_SERVER_PORT

◆ dbi

◆ ERROR_EVENT_NOT_FOUND

◆ exit_flag

◆ onSuspendConnectionIdent

◆ onSuspendConnectionIds

◆ onSuspendResponseDict

◆ serverHost

◆ serverPort

◆ tcpServerEventIdToConnectIdentity

◆ VERSION_STRING_NAME

◆ init()