dc.DCD.DCD Class Reference

Inheritance diagram for dc.DCD.DCD:

Collaboration diagram for dc.DCD.DCD:

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, code=None)

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 45 of file DCD.py.

Constructor & Destructor Documentation

__init__()

def dc.DCD.DCD.__init__

(

self

)

Definition at line 60 of file DCD.py.

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

Member Function Documentation

close()

def dc.DCD.DCD.close	(		self,
			code = None
	)

Definition at line 204 of file DCD.py.

  def close(self, code=None):
    if self.logger is not None:
      self.logger.debug(LOG_MSG_CLOSE_APP)
    # call base class run method
    foundation.CementApp.close(self)

createThreadObj()

def dc.DCD.DCD.createThreadObj	(		self,
			app_name
	)

Definition at line 119 of file DCD.py.

  def createThreadObj(self, app_name):
    app = None
    try:
      app = (app_name, eval(app_name)(self.config, ConnectionBuilderLight()))  # pylint: disable = I0011, eval-used
      app[1].setName(app[0])
      self.logger.debug("%s has been created!", app_name)
      time.sleep(self.CREATE_APP_DELAY)
    except:
      self.logger.error("Exception has been thrown during %s creation!", app_name)
      raise
    return app

Here is the caller graph for this function:

joinThreadObj()

def dc.DCD.DCD.joinThreadObj	(		self,
			app
	)

Definition at line 137 of file DCD.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:
      self.logger.error("Exception has been thrown during %s joining!", app[0])
      raise

Here is the caller graph for this function:

loadConfig()

def dc.DCD.DCD.loadConfig

(

self

)

Definition at line 164 of file DCD.py.

  def loadConfig(self):
    try:
      self.config = ConfigParser.ConfigParser()
      self.config.optionxform = str
      if self.pargs.config:
        self.config.read(self.pargs.config)
      else:
        raise Exception("Error load config")
        # self.config.read(APP_CONFIG_FILE)
    except Exception as err:
      print ERROR_LOAD_CONFIG + err.message
      raise

Here is the caller graph for this function:

loadLogConfigFile()

def dc.DCD.DCD.loadLogConfigFile

(

self

)

Definition at line 189 of file DCD.py.

  def loadLogConfigFile(self):
    try:
      log_conf_file = self.config.get("Application", "log")
      logging.config.fileConfig(log_conf_file)
      #self.logger = logging.getLogger(APP_NAME)
      # Logger initialization
      self.logger = logging.getLogger(APP_CONSTS.LOGGER_NAME)

    except Exception as err:
      print ERROR_LOAD_LOG_CONFIG_FILE + err.message
      raise

Here is the caller graph for this function:

loadStartAppsSequence()

def dc.DCD.DCD.loadStartAppsSequence

(

self

)

Definition at line 181 of file DCD.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 dc.DCD.DCD.run

(

self

)

Definition at line 76 of file DCD.py.

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

    # config section
    self.loadConfig()

    # load logger config file
    self.loadLogConfigFile()

    # load application sequence
    self.loadStartAppsSequence()

    # create threadObjs
    # strictly ordered sequence caused connection establishment order
    try:
      self.threadObjs = [self.createThreadObj(threadObj) for threadObj in self.threadObjs]
    except:
      self.logger.error("Exception during creation thread-based class!\n" + Utils.getTracebackInfo())
      raise

    # run apps
    # strictly ordered
    try:
      [self.startThreadObj(threadObj) for threadObj in self.threadObjs]
    except:
      self.logger.error("Exception during run thread-based class!\n" + Utils.getTracebackInfo())
      raise

    # wait for stop
    # strictly ordered
    try:
      [self.joinThreadObj(threadObj) for threadObj in self.threadObjs]
    except:
      self.logger.error("Exception during stop thread-based class!\n" + Utils.getTracebackInfo())
      raise

Here is the call graph for this function:

setup()

def dc.DCD.DCD.setup

(

self

)

Definition at line 69 of file DCD.py.

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

startThreadObj()

def dc.DCD.DCD.startThreadObj	(		self,
			app
	)

Definition at line 151 of file DCD.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:
      self.logger.error("Exception has been thrown during %s start!", app[0])
      raise

Here is the caller graph for this function:

Member Data Documentation

config

dc.DCD.DCD.config

Definition at line 166 of file DCD.py.

CREATE_APP_DELAY

int dc.DCD.DCD.CREATE_APP_DELAY = 0

static

Definition at line 47 of file DCD.py.

JOIN_APP_DELAY

int dc.DCD.DCD.JOIN_APP_DELAY = 0

static

Definition at line 49 of file DCD.py.

logger

dc.DCD.DCD.logger

Definition at line 63 of file DCD.py.

START_APP_DELAY

int dc.DCD.DCD.START_APP_DELAY = 0

static

Definition at line 48 of file DCD.py.

threadObjs

dc.DCD.DCD.threadObjs

Definition at line 64 of file DCD.py.

---

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

• sources/hce/dc/DCD.py