dtm.DTMD.DTMD Class Reference

Inheritance diagram for dtm.DTMD.DTMD:

Collaboration diagram for dtm.DTMD.DTMD:

Classes
class	Meta

Public Member Functions
def	__init__ (self)
def	setup (self)
def	run (self)
def	createThreadObj (self, app_name)
def	joinThreadObj (self, app)
def	startThreadObj (self, app)
def	loadConfig (self)
def	loadStartAppsSequence (self)
def	loadLogConfigFile (self)
def	close (self)

Public Attributes
	logger
	threadObjs
	config

Static Public Attributes
int	CREATE_APP_DELAY = 0
int	START_APP_DELAY = 0
int	JOIN_APP_DELAY = 0

Detailed Description

Definition at line 49 of file DTMD.py.

Constructor & Destructor Documentation

__init__()

def dtm.DTMD.DTMD.__init__

(

self

)

Definition at line 64 of file DTMD.py.

  def __init__(self):
    # call base class __init__ method
    foundation.CementApp.__init__(self)
    self.logger = None
    self.threadObjs = None

Member Function Documentation

close()

def dtm.DTMD.DTMD.close

(

self

)

Definition at line 206 of file DTMD.py.

  def close(self):
    if self.logger is not None:
      self.logger.debug("dtm daemon is closed")
    # call base class run method
    foundation.CementApp.close(self)

createThreadObj()

def dtm.DTMD.DTMD.createThreadObj	(		self,
			app_name
	)

Definition at line 120 of file DTMD.py.

  def createThreadObj(self, app_name):
    app = None
    try:
      app = (app_name, eval(app_name)(self.config, ConnectionBuilderLight()))  #  pylint: disable=W0123
      app[1].setName(app[0])
      self.logger.debug("%s has been created!" % app_name)
      time.sleep(self.CREATE_APP_DELAY)
    except Exception as err:
      ExceptionLog.handler(self.logger, err, "Exception has been thrown during %s creation. %s" % (app_name, err.message), \
                           (err))
      raise
    return app

Here is the caller graph for this function:

joinThreadObj()

def dtm.DTMD.DTMD.joinThreadObj	(		self,
			app
	)

Definition at line 139 of file DTMD.py.

  def joinThreadObj(self, app):
    try:
      app[1].join()
      self.logger.debug("%s waiting for stopping!" % app[0])
      time.sleep(self.JOIN_APP_DELAY)
    except Exception as err:
      ExceptionLog.handler(self.logger, err, "Exception has been thrown during %s joining. %s" % (app[0], err.message), \
                           (err))
      raise

loadConfig()

def dtm.DTMD.DTMD.loadConfig

(

self

)

Definition at line 168 of file DTMD.py.

  def loadConfig(self):
    try:
      self.config = ConfigParser.ConfigParser()
      self.config.optionxform = str
      if self.pargs.config:
        self.config.read(self.pargs.config)
        # self.logger.debug("Load config from cli argument: " + self.pargs.config)
      else:
        self.config.read(APP_CONFIG_FILE)
        # self.logger.debug("Load config from default config file: " + APP_CONFIG_FILE)
    except:
      print ERROR_LOAD_CONFIG
      raise

Here is the caller graph for this function:

loadLogConfigFile()

def dtm.DTMD.DTMD.loadLogConfigFile

(

self

)

Definition at line 194 of file DTMD.py.

  def loadLogConfigFile(self):
    try:
      log_conf_file = self.config.get("Application", "log")
      logging.config.fileConfig(log_conf_file)
      self.logger = logging.getLogger(DTM_CONSTS.LOGGER_NAME)
    except:
      print ERROR_LOAD_LOG_CONFIG_FILE
      raise

Here is the caller graph for this function:

loadStartAppsSequence()

def dtm.DTMD.DTMD.loadStartAppsSequence

(

self

)

Definition at line 186 of file DTMD.py.

  def loadStartAppsSequence(self):
    self.logger.debug("Load application's start sequence.")
    self.threadObjs = self.config.get("Application", "instantiateSequence").split(",")

Here is the caller graph for this function:

run()

def dtm.DTMD.DTMD.run

(

self

)

Definition at line 80 of file DTMD.py.

  def run(self):
    # call base class run method
    foundation.CementApp.run(self)

    # config section
    self.loadConfig()

    # load self.logger config file
    self.loadLogConfigFile()

    # load application sequence
    self.loadStartAppsSequence()

    # create threadObjs
    # strictly ordered sequence caused connection establishment order
    try:
      self.threadObjs = [self.createThreadObj(app_name) for app_name in self.threadObjs]
    except:
      raise

    # run apps
    # strictly ordered
    try:
      [self.startThreadObj(app) for app in self.threadObjs]
    except:
      raise

    # wait for stop
    # strictly ordered
    # try:
    #  [self.joinThreadObj(app) for app in self.threadObjs]
    # except:
    #  raise

Here is the call graph for this function:

setup()

def dtm.DTMD.DTMD.setup

(

self

)

Definition at line 73 of file DTMD.py.

  def setup(self):
    # call base class setup method
    foundation.CementApp.setup(self)

startThreadObj()

def dtm.DTMD.DTMD.startThreadObj	(		self,
			app
	)

Definition at line 154 of file DTMD.py.

  def startThreadObj(self, app):
    try:
      app[1].setName(app[0])
      app[1].start()
      self.logger.debug("%s has been started!" % app[0])
      time.sleep(self.START_APP_DELAY)
    except Exception as err:
      ExceptionLog.handler(self.logger, err, "Exception has been thrown during %s start. %s" % (app[0], err.message), \
                           (err))
      raise

Here is the caller graph for this function:

Member Data Documentation

config

dtm.DTMD.DTMD.config

Definition at line 170 of file DTMD.py.

CREATE_APP_DELAY

int dtm.DTMD.DTMD.CREATE_APP_DELAY = 0

static

Definition at line 51 of file DTMD.py.

JOIN_APP_DELAY

int dtm.DTMD.DTMD.JOIN_APP_DELAY = 0

static

Definition at line 53 of file DTMD.py.

logger

dtm.DTMD.DTMD.logger

Definition at line 67 of file DTMD.py.

START_APP_DELAY

int dtm.DTMD.DTMD.START_APP_DELAY = 0

static

Definition at line 52 of file DTMD.py.

threadObjs

dtm.DTMD.DTMD.threadObjs

Definition at line 68 of file DTMD.py.

---

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

• sources/hce/dtm/DTMD.py