admin.NodeManagerRequest Namespace Reference

Classes
class	NodeManagerRequest
	NodeManagerRequest class contents all data needed for admin level's request sending. More...

Functions
def	raiseAdminExceptions (self, exceptionString)
	raiseAdminExceptions method generates exceptions based on analyze of exceptionString param's data More...
def	makeRequest (self, node, message, commandTimeout=None)
	makeRequest main class method, it gets node and message params, interact with transport layer, makes NodeManagerResponse object, based on transport layer's return data, returns it. More...

Detailed Description

Created on Feb 17, 2014

@author: scorp
@link: http://hierarchical-cluster-engine.com/
@copyright: Copyright © 2013-2014 IOIX Ukraine
@license: http://hierarchical-cluster-engine.com/license/
@since: 0.1

Function Documentation

makeRequest()

def admin.NodeManagerRequest.makeRequest	(		self,
			node,
			message,
			commandTimeout = None
	)

makeRequest main class method, it gets node and message params, interact with transport layer, makes NodeManagerResponse object, based on transport layer's return data, returns it.

Definition at line 56 of file NodeManagerRequest.py.

  def makeRequest(self, node, message, commandTimeout=None):
    exceptionString = None
    respond = None
    adminConnection = None
    connectParams = ConnectionParams(node.getHost(), node.getPort())
    try:
      adminConnection = self.connectionBuilder.build(transport.Consts.ADMIN_CONNECT_TYPE, connectParams)
    except KeyError as exp:
      exceptionString = CONSTANTS.STRING_EXCEPTION_WRONG_CONNECTION_KEY

    if adminConnection != None:
      request = Request(message[CONSTANTS.STRING_MSGID_NAME])
      request.add_data(message[CONSTANTS.STRING_BODY_NAME])
      adminConnection.send(request)

      localTimeout = -1
      if commandTimeout == None:
        elapsedTime = node.getElapsedTime()
        if elapsedTime >= node.getTimeout():
          exceptionString = CONSTANTS.STRING_EXCEPTION_ADMIN_TIMEOUT
        else:
          localTimeout = node.getTimeout() - elapsedTime
      else:
        localTimeout = commandTimeout

      if localTimeout >= 0:
        try:
          respond = adminConnection.recv(localTimeout)
        except ConnectionTimeout as exp:
          exceptionString = exp.message
      adminConnection.close()
    self.raiseAdminExceptions(exceptionString)
    return self.createNodeManagerResponse(respond, message)

raiseAdminExceptions()

def admin.NodeManagerRequest.raiseAdminExceptions	(		self,
			exceptionString
	)

raiseAdminExceptions method generates exceptions based on analyze of exceptionString param's data

Definition at line 46 of file NodeManagerRequest.py.

  def raiseAdminExceptions(self, exceptionString):
    if exceptionString != None:
      if exceptionString == CONSTANTS.STRING_EXCEPTION_WRONG_CONNECTION_KEY:
        raise AdminExceptions.AdminWrongConnectionKey(exceptionString)
      else:
        raise AdminExceptions.AdminTimeoutException(exceptionString)

Here is the caller graph for this function: