drce.CommandExecutor.CommandExecutor Class Reference

Inheritance diagram for drce.CommandExecutor.CommandExecutor:

Collaboration diagram for drce.CommandExecutor.CommandExecutor:

Public Member Functions
def	__init__ (self, connection, cmd_convertor)
def	replace_connection (self, connection)
def	execute (self, command, timeout=1000, ttl=30000, maxTries=100)

Public Attributes
	connection
	cmd_convertor
	id_generator

Detailed Description

Definition at line 32 of file CommandExecutor.py.

Constructor & Destructor Documentation

__init__()

def drce.CommandExecutor.CommandExecutor.__init__	(		self,
			connection,
			cmd_convertor
	)

Definition at line 39 of file CommandExecutor.py.

  def __init__(self, connection, cmd_convertor):
    self.connection = connection
    self.cmd_convertor = cmd_convertor
    # @var id_generator
    # a member variable, used to generate uid for messages
    self.id_generator = UIDGenerator()

Member Function Documentation

execute()

def drce.CommandExecutor.CommandExecutor.execute	(		self,
			command,
			timeout = 1000,
			ttl = 30000,
			maxTries = 100
	)

Definition at line 67 of file CommandExecutor.py.

  def execute(self, command, timeout=1000, ttl=30000, maxTries=100):
    if maxTries < 0:
      maxTries = 0

    try:
      logger.debug("command: %s", Utils.varDump(command, strTypeMaxLen=10000))
      cmd_json = self.cmd_convertor.to_json(command, logger)
      drce_cover_envelop = DRCECover(ttl, cmd_json)
      request = Request(self.id_generator.get_uid())
      request.add_data(json.dumps(drce_cover_envelop, cls=TaskExecuteStructEncoder))
      request.route = command.route
      request.task_type = command.task_type

      uid = request.get_uid()
      logger.debug("Send DRCE request msg Id:" + uid + ", route: " + str(request.route))

      self.connection.send(request, uid)

      for i in range(int(maxTries) + 1):
        response = self.connection.recv(timeout, uid)
        logger.debug("Received DRCE response msg Id:" + response.get_uid())
        if response.get_uid() == request.get_uid() or maxTries == 0:
          cover_envelop_response = json.loads(response.get_body())
          return self.cmd_convertor.from_json(cover_envelop_response["data"])
        else:
          logger.error("DRCE response msg Id:" + response.get_uid() + \
                       " not matched with the request msg Id:" + request.get_uid() + \
                       ", try: " + str(i))
    except (ResponseFormatErr, CommandConvertorError, KeyError, CommandExecutorErr) as err:
      logger.error("DRCE object model error: %s", str(err))
      raise CommandExecutorErr(str(err))
    except Exception as err:
      logger.error("General error: %s", str(err))
      raise CommandExecutorErr(str(err))

replace_connection()

def drce.CommandExecutor.CommandExecutor.replace_connection	(		self,
			connection
	)

Definition at line 52 of file CommandExecutor.py.

  def replace_connection(self, connection):
    self.connection = connection

Member Data Documentation

cmd_convertor

drce.CommandExecutor.CommandExecutor.cmd_convertor

Definition at line 41 of file CommandExecutor.py.

connection

drce.CommandExecutor.CommandExecutor.connection

Definition at line 40 of file CommandExecutor.py.

id_generator

drce.CommandExecutor.CommandExecutor.id_generator

Definition at line 44 of file CommandExecutor.py.

---

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

• sources/hce/drce/CommandExecutor.py