dtm.TasksDataManager.TasksDataManager Class Reference

Class contents TasksDataManager module implementation. More...

Inheritance diagram for dtm.TasksDataManager.TasksDataManager:

Collaboration diagram for dtm.TasksDataManager.TasksDataManager:

Public Member Functions
def	__init__ (self, config, connectionBuilder=None)
	constructor initialise all class variable and recieve config as param More...
def	connectionInit (self)
	connectionInit method initializes internal inproc connection More...
def	dbInit (self)
	dbInit method initializes internal database API More...
def	dbiProcessing (self, data, eventType)
	dbiProcessing method Method contains main processing with database API More...
def	getResponceEventType (self, eventType)
	Get responce event type method. More...
def	eventProcessing (self, event)
	eventProcessing method Method contains main processing with incoming events More...
def	badEventType (self, msg, event)
	eventProcessing method Method contains main error processing for incoming events More...
def	onNewTask (self, event)
	Callbacks methods Event callbacks. More...
def	onFetchTask (self, event)
def	onUpdateTask (self, event)
def	onDeleteTask (self, event)
def	onInsertEEResponse (self, event)
def	onFetchEEResponse (self, event)
def	onDeleteEEResponse (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
	moduleName
	servIndex
	eventBuilder
	connectionBuilder
	config
	dbi
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	TASK_DATA_MANAGER_SERV_NAME = "Server"
string	TASK_DATA_MANAGER_SERV_CONFIG_NAME = "ServerName"
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

Class contents TasksDataManager module implementation.

Definition at line 37 of file TasksDataManager.py.

Constructor & Destructor Documentation

__init__()

def dtm.TasksDataManager.TasksDataManager.__init__	(		self,
			config,
			connectionBuilder = None
	)

constructor initialise all class variable and recieve config as param

Definition at line 46 of file TasksDataManager.py.

  def __init__(self, config, connectionBuilder=None):
    BaseServerManager.__init__(self)
    self.moduleName = self.__class__.__name__
    self.servIndex = 1
    self.eventBuilder = EventBuilder()
    self.setEventHandler(EVENT.NEW_TASK, self.onNewTask)
    self.setEventHandler(EVENT.FETCH_TASK_DATA, self.onFetchTask)
    self.setEventHandler(EVENT.UPDATE_TASK, self.onUpdateTask)
    self.setEventHandler(EVENT.DELETE_TASK_DATA, self.onDeleteTask)
    self.setEventHandler(EVENT.INSERT_EE_DATA, self.onInsertEEResponse)
    self.setEventHandler(EVENT.FETCH_EE_DATA, self.onFetchEEResponse)
    self.setEventHandler(EVENT.DELETE_EE_DATA, self.onDeleteEEResponse)
    self.connectionBuilder = connectionBuilder
    self.config = config
    self.dbi = None
    self.connectionInit()
    self.dbInit()

Member Function Documentation

badEventType()

def dtm.TasksDataManager.TasksDataManager.badEventType	(		self,
			msg,
			event
	)

eventProcessing method Method contains main error processing for incoming events

Definition at line 177 of file TasksDataManager.py.

  def badEventType(self, msg, event):
    errorStr = msg + str(event.eventType)
    logger.error(LogFormatterEvent(event, [], errorStr))
#    raise Exception(errorStr)

Here is the caller graph for this function:

connectionInit()

def dtm.TasksDataManager.TasksDataManager.connectionInit

(

self

)

connectionInit method initializes internal inproc connection

Definition at line 67 of file TasksDataManager.py.

  def connectionInit(self):
    if self.connectionBuilder is None:
      self.connectionBuilder = ConnectionBuilderLight()
    try:
      localConnection = self.connectionBuilder.build(transport.Consts.SERVER_CONNECT, \
                        self.config.get(self.moduleName, self.TASK_DATA_MANAGER_SERV_CONFIG_NAME))
      self.addConnection(self.TASK_DATA_MANAGER_SERV_NAME + str(self.servIndex), localConnection)
      self.servIndex = self.servIndex + 1
    except ConfigParser.NoSectionError:
      logger.error(">>> TasksDataManager can't read config - Section Error")
    except ConfigParser.NoOptionError:
      logger.error(">>> TasksDataManager can't read config - Option Error")

Here is the call graph for this function:

Here is the caller graph for this function:

dbInit()

def dtm.TasksDataManager.TasksDataManager.dbInit

(

self

)

dbInit method initializes internal database API

Definition at line 83 of file TasksDataManager.py.

  def dbInit(self):
    if self.config != None:
      dic = None
      dic = dict(self.config.items(CONSTANTS.DB_CONFIG_SECTION))
      if dic != None:
        self.dbi = DBI(dic)

dbiProcessing()

def dtm.TasksDataManager.TasksDataManager.dbiProcessing	(		self,
			data,
			eventType
	)

dbiProcessing method Method contains main processing with database API

Definition at line 93 of file TasksDataManager.py.

  def dbiProcessing(self, data, eventType):
    # variable for result
    ret = None

    if eventType == EVENT.NEW_TASK:
      self.dbi.insert(data)
    elif eventType == EVENT.FETCH_TASK_DATA:
      ret = self.dbi.fetch(data, "id=%s" % data.id)
    elif eventType == EVENT.UPDATE_TASK:
      self.dbi.update(data, "id=%s" % data.id)
    elif eventType == EVENT.DELETE_TASK_DATA:
      self.dbi.delete(data, "id=%s" % data.id)
    elif eventType == EVENT.INSERT_EE_DATA:
      self.dbi.insert(data)
    elif eventType == EVENT.FETCH_EE_DATA:
      ret = self.dbi.fetch(data, "id=%s" % data.id)
    elif eventType == EVENT.DELETE_EE_DATA:
      self.dbi.delete(data, "id=%s" % data.id)

    return ret

Here is the caller graph for this function:

eventProcessing()

def dtm.TasksDataManager.TasksDataManager.eventProcessing	(		self,
			event
	)

eventProcessing method Method contains main processing with incoming events

Definition at line 143 of file TasksDataManager.py.

  def eventProcessing(self, event):
    serializeStr = pickle.dumps(event.eventObj)
    if event.eventType == EVENT.NEW_TASK or \
       event.eventType == EVENT.FETCH_TASK_DATA or \
       event.eventType == EVENT.UPDATE_TASK or \
       event.eventType == EVENT.DELETE_TASK_DATA:
      data = TasksDataTable()
    else:
      data = EEResponsesTable()  # pylint: disable=R0204
    data.id = event.eventObj.id
    data.data = serializeStr
    dbiRet = None
    retEventType = None
    try:
      retEventType = self.getResponceEventType(event.eventType)
      dbiRet = GeneralResponse()
      res = self.dbiProcessing(data, event.eventType)
      if res is not None and len(res) > 0 and res[0] != None and hasattr(res[0], 'data') and res[0].data != None:
        dbiRet = pickle.loads(str(res[0].data))

    except DBIErr as err:
      logger.error("DB error: %s", str(err))
      dbiRet.errorCode = err.errCode
      dbiRet.errorMessage = "Some DB error in TasksDataManager.eventProcessing [" + str(err) + "]"
    except Exception, err:
      logger.error("Error: %s", str(err))
      dbiRet.errorMessage = "Some error in TasksDataManager.eventProcessing [" + str(err) + "]"

    retEvent = self.eventBuilder.build(retEventType, dbiRet)
    return retEvent

Here is the call graph for this function:

Here is the caller graph for this function:

getResponceEventType()

def dtm.TasksDataManager.TasksDataManager.getResponceEventType	(		self,
			eventType
	)

Get responce event type method.

Parameters

eventType

- event type

Returns

responce event type

Definition at line 119 of file TasksDataManager.py.

  def getResponceEventType(self, eventType):
    #variable for result
    retEventType = EVENT.GENERAL_RESPONSE
    
    if eventType == EVENT.NEW_TASK:
      retEventType = EVENT.NEW_TASK_RESPONSE
    elif eventType == EVENT.FETCH_TASK_DATA:
      retEventType = EVENT.FETCH_TASK_DATA_RESPONSE
    elif eventType == EVENT.UPDATE_TASK:
      retEventType = EVENT.UPDATE_TASK_RESPONSE
    elif eventType == EVENT.DELETE_TASK_DATA:
      retEventType = EVENT.DELETE_TASK_DATA_RESPONSE
    elif eventType == EVENT.INSERT_EE_DATA:
      retEventType = EVENT.INSERT_EE_DATA_RESPONSE
    elif eventType == EVENT.FETCH_EE_DATA:
      retEventType = EVENT.FETCH_EE_DATA_RESPONSE
    elif eventType == EVENT.DELETE_EE_DATA:
      retEventType = EVENT.DELETE_EE_DATA_RESPONSE

    return retEventType
  
  

Here is the caller graph for this function:

onDeleteEEResponse()

def dtm.TasksDataManager.TasksDataManager.onDeleteEEResponse	(		self,
			event
	)

Definition at line 233 of file TasksDataManager.py.

  def onDeleteEEResponse(self, event):
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [DELETE_EE_REQUEST] Handler start"))
    if event.eventType != EVENT.DELETE_EE_DATA:
      self.badEventType(">>> Wrong Event type [DELETE_EE_REQUEST] != ", event)
    self.reply(event, self.eventProcessing(event))
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [DELETE_EE_REQUEST] Handler finish"))

onDeleteTask()

def dtm.TasksDataManager.TasksDataManager.onDeleteTask	(		self,
			event
	)

Definition at line 209 of file TasksDataManager.py.

  def onDeleteTask(self, event):
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [DELETE_TASK_DATA_REQUEST] Handler start"))
    if event.eventType != EVENT.DELETE_TASK_DATA:
      self.badEventType(">>> Wrong Event type [DELETE_TASK_DATA_REQUEST] != ", event)
    self.reply(event, self.eventProcessing(event))
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [DELETE_TASK_DATA_REQUEST] Handler finish"))

Here is the call graph for this function:

Here is the caller graph for this function:

onFetchEEResponse()

def dtm.TasksDataManager.TasksDataManager.onFetchEEResponse	(		self,
			event
	)

Definition at line 225 of file TasksDataManager.py.

  def onFetchEEResponse(self, event):
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [FETCH_EE_REQUEST] Handler start"))
    if event.eventType != EVENT.FETCH_EE_DATA:
      self.badEventType(">>> Wrong Event type [FETCH_EE_REQUEST] != ", event)
    self.reply(event, self.eventProcessing(event))
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [FETCH_EE_REQUEST] Handler finish"))

Here is the call graph for this function:

onFetchTask()

def dtm.TasksDataManager.TasksDataManager.onFetchTask	(		self,
			event
	)

Definition at line 193 of file TasksDataManager.py.

  def onFetchTask(self, event):
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [FETCH_TASK_REQUEST] Handler start"))
    if event.eventType != EVENT.FETCH_TASK_DATA:
      self.badEventType(">>> Wrong Event type [FETCH_TASK_REQUEST] != ", event)
    self.reply(event, self.eventProcessing(event))
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [FETCH_TASK_REQUEST] Handler finish"))

Here is the call graph for this function:

onInsertEEResponse()

def dtm.TasksDataManager.TasksDataManager.onInsertEEResponse	(		self,
			event
	)

Definition at line 217 of file TasksDataManager.py.

  def onInsertEEResponse(self, event):
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [INSERT_EE_REQUEST] Handler start"))
    if event.eventType != EVENT.INSERT_EE_DATA:
      self.badEventType(">>> Wrong Event type [INSERT_EE_REQUEST] != ", event)
    self.reply(event, self.eventProcessing(event))
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [INSERT_EE_REQUEST] Handler finish"))

Here is the call graph for this function:

onNewTask()

def dtm.TasksDataManager.TasksDataManager.onNewTask	(		self,
			event
	)

Callbacks methods Event callbacks.

Definition at line 185 of file TasksDataManager.py.

  def onNewTask(self, event):
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [NEW_TASK_REQUEST] Handler start"))
    if event.eventType != EVENT.NEW_TASK:
      self.badEventType(">>> Wrong Event type [NEW_TASK_REQUEST] != ", event)
    self.reply(event, self.eventProcessing(event))
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [NEW_TASK_REQUEST] Handler finish"))

Here is the call graph for this function:

onUpdateTask()

def dtm.TasksDataManager.TasksDataManager.onUpdateTask	(		self,
			event
	)

Definition at line 201 of file TasksDataManager.py.

  def onUpdateTask(self, event):
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [UPDATE_TASK_REQUEST] Handler start"))
    if event.eventType != EVENT.UPDATE_TASK:
      self.badEventType(">>> Wrong Event type [UPDATE_TASK_REQUEST] != ", event)
    self.reply(event, self.eventProcessing(event))
    logger.debug(LogFormatterEvent(event, [], ">>> TasksDataManager [UPDATE_TASK_REQUEST] Handler finish"))

Here is the call graph for this function:

Member Data Documentation

config

dtm.TasksDataManager.TasksDataManager.config

Definition at line 59 of file TasksDataManager.py.

connectionBuilder

dtm.TasksDataManager.TasksDataManager.connectionBuilder

Definition at line 58 of file TasksDataManager.py.

dbi

dtm.TasksDataManager.TasksDataManager.dbi

Definition at line 60 of file TasksDataManager.py.

eventBuilder

dtm.TasksDataManager.TasksDataManager.eventBuilder

Definition at line 50 of file TasksDataManager.py.

moduleName

dtm.TasksDataManager.TasksDataManager.moduleName

Definition at line 48 of file TasksDataManager.py.

servIndex

dtm.TasksDataManager.TasksDataManager.servIndex

Definition at line 49 of file TasksDataManager.py.

TASK_DATA_MANAGER_SERV_CONFIG_NAME

string dtm.TasksDataManager.TasksDataManager.TASK_DATA_MANAGER_SERV_CONFIG_NAME = "ServerName"

static

Definition at line 41 of file TasksDataManager.py.

TASK_DATA_MANAGER_SERV_NAME

string dtm.TasksDataManager.TasksDataManager.TASK_DATA_MANAGER_SERV_NAME = "Server"

static

Definition at line 40 of file TasksDataManager.py.

---

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

• sources/hce/dtm/TasksDataManager.py