HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
Public Member Functions | Public Attributes | List of all members
ftests.ftest_ResourcesManager.TestResoursesManager Class Reference
Inheritance diagram for ftests.ftest_ResourcesManager.TestResoursesManager:
Inheritance graph
[legend]
Collaboration diagram for ftests.ftest_ResourcesManager.TestResoursesManager:
Collaboration graph
[legend]

Public Member Functions

def setUp (self)
 
def fillLocalResources (self, localTestResources, idx)
 
def connectionInit (self)
 
def tearDown (self)
 
def testFunctional1 (self)
 

Public Attributes

 config
 
 servIndex
 
 connectionBuilder
 
 adminServerConnection
 
 taskResourcesManager
 
 moduleName
 
 eventBuilder
 
 event
 
 reply_event
 
 recvEvent
 
 localConnection
 

Detailed Description

Definition at line 39 of file ftest_ResourcesManager.py.

Member Function Documentation

◆ connectionInit()

def ftests.ftest_ResourcesManager.TestResoursesManager.connectionInit (   self)

Definition at line 74 of file ftest_ResourcesManager.py.

74  def connectionInit(self):
75  self.connectionBuilder = ConnectionBuilderLight()
76  try:
77  self.localConnection = self.taskResourcesManager.connectionBuilder.build(transport.Consts.CLIENT_CONNECT, \
78  self.config.get(self.moduleName, ResourcesManager.RESOURCE_MANAGER_SERV_CONFIG_NAME))
79  self.servIndex = self.servIndex + 1
80  except ConfigParser.NoSectionError:
81  logger.error(">>> TasksDataManager can't read config - Section Error")
82  except ConfigParser.NoOptionError:
83  logger.error(">>> TasksDataManager can't read config - Option Error")
84 
85 

◆ fillLocalResources()

def ftests.ftest_ResourcesManager.TestResoursesManager.fillLocalResources (   self,
  localTestResources,
  idx 
)

Definition at line 59 of file ftest_ResourcesManager.py.

59  def fillLocalResources(self, localTestResources, idx):
60  ret = dtm.EventObjects.Resource(localTestResources[idx]["id"])
61  ret.cpu = localTestResources[idx]["cpu"]
62  ret.io = localTestResources[idx]["io"]
63  ret.ramR = localTestResources[idx]["ramR"]
64  ret.ramV = localTestResources[idx]["ramV"]
65  ret.swap = localTestResources[idx]["swap"]
66  ret.disk = localTestResources[idx]["disk"]
67  ret.uDate = localTestResources[idx]["uDate"]
68  ret.state = localTestResources[idx]["state"]
69  ret.cpuCores = localTestResources[idx]["cpuCores"]
70  ret.threads = localTestResources[idx]["threads"]
71  ret.processes = localTestResources[idx]["processes"]
72 
73 
dtm.EventObjects.Resource
Resource event object, represents resource's data fields .
Definition: EventObjects.py:843
Here is the caller graph for this function:

◆ setUp()

def ftests.ftest_ResourcesManager.TestResoursesManager.setUp (   self)

Definition at line 42 of file ftest_ResourcesManager.py.

42  def setUp(self):
43  self.config = ConfigParser.ConfigParser()
44  self.servIndex = 1
45  self.config.read("./dtmd.ini")
46  self.connectionBuilder = ConnectionBuilderLight()
47  self.adminServerConnection = self.connectionBuilder.build(transport.Consts.SERVER_CONNECT,
48  BaseServerManager.ADMIN_CONNECT_ENDPOINT)
49  self.taskResourcesManager = ResourcesManager(self.config, self.connectionBuilder)
50  self.moduleName = self.taskResourcesManager.__class__.__name__
51  self.eventBuilder = EventBuilder()
52  self.event = None
53  self.reply_event = None
54  self.taskResourcesManager.start()
55  self.connectionInit()
56  self.recvEvent = None
57 
58 
ftests.ftest_MPLogger.start
bool start
Definition: ftest_MPLogger.py:57

◆ tearDown()

def ftests.ftest_ResourcesManager.TestResoursesManager.tearDown (   self)

Definition at line 86 of file ftest_ResourcesManager.py.

86  def tearDown(self):
87  self.taskResourcesManager.exit_flag = True
88  self.taskResourcesManager.join()
89  for connection in self.taskResourcesManager.connections.values():
90  connection.close()
91  self.adminServerConnection.close()
92  time.sleep(1)
93 
94 
join
Definition: join.py:1

◆ testFunctional1()

def ftests.ftest_ResourcesManager.TestResoursesManager.testFunctional1 (   self)

Definition at line 95 of file ftest_ResourcesManager.py.

95  def testFunctional1(self):
96  localResourcesList = []
97  localResources = self.fillLocalResources(testResources, 0)
98  localResourcesList.append(localResources)
99  event = self.eventBuilder.build(EVENT.UPDATE_RESOURCES_DATA, localResourcesList)
100  self.localConnection.send(event)
101  self.recvEvent = self.localConnection.recv()
102  self.assertTrue(self.recvEvent != None, ">>> ret reply_event is None")
103  self.assertTrue(self.recvEvent.eventObj != None, ">>> ret reply_event_obj is None")
104  self.assertTrue(len(self.recvEvent.eventObj.statuses) == 1, ">>> ret reply_event_obj size is wrong")
105  self.assertTrue(self.recvEvent.eventType == EVENT.UPDATE_RESOURCES_DATA_RESPONSE,
106  ">>> reply_event event.eventType is wrong")
107 
108  localResourcesList = []
109  localResources = self.fillLocalResources(testResources, 1)
110  localResourcesList.append(localResources)
111  localResources = self.fillLocalResources(testResources, 2)
112  localResourcesList.append(localResources)
113  localResources = self.fillLocalResources(testResources, 3)
114  localResourcesList.append(localResources)
115  event = self.eventBuilder.build(EVENT.UPDATE_RESOURCES_DATA, localResourcesList)
116  self.localConnection.send(event)
117  self.recvEvent = self.localConnection.recv()
118  self.assertTrue(self.recvEvent != None, ">>> ret reply_event is None")
119  self.assertTrue(self.recvEvent.eventObj != None, ">>> ret reply_event_obj is None")
120  self.assertTrue(len(self.recvEvent.eventObj.statuses) == 3, ">>> ret reply_event_obj size is wrong")
121  self.assertTrue(self.recvEvent.eventType == EVENT.UPDATE_RESOURCES_DATA_RESPONSE,
122  ">>> reply_event event.eventType is wrong")
123 
124  localResourcesList = []
125  localResources = self.fillLocalResources(testResources, 4)
126  localResourcesList.append(localResources)
127  event = self.eventBuilder.build(EVENT.UPDATE_RESOURCES_DATA, localResourcesList)
128  self.localConnection.send(event)
129  self.recvEvent = self.localConnection.recv()
130  self.assertTrue(self.recvEvent != None, ">>> ret reply_event is None")
131  self.assertTrue(self.recvEvent.eventObj != None, ">>> ret reply_event_obj is None")
132  self.assertTrue(len(self.recvEvent.eventObj.statuses) == 1, ">>> ret reply_event_obj size is wrong")
133  self.assertTrue(self.recvEvent.eventType == EVENT.UPDATE_RESOURCES_DATA_RESPONSE,
134  ">>> reply_event event.eventType is wrong")
135 
136  event = self.eventBuilder.build(EVENT.GET_AVG_RESOURCES, None)
137  self.localConnection.send(event)
138  self.recvEvent = self.localConnection.recv()
139  self.assertTrue(self.recvEvent != None, ">>> ret reply_event is None")
140  self.assertTrue(self.recvEvent.eventObj != None, ">>> ret reply_event_obj is None")
141  self.assertTrue(self.recvEvent.eventType == EVENT.GET_AVG_RESOURCES_RESPONSE,
142  ">>> reply_event event.eventType is wrong")
143  # only 1th, 2th and 4th elements are present and active on ResourceManager now
144  compareVal = (testResources[1]["cpu"] + testResources[2]["cpu"] + testResources[4]["cpu"]) / 3
145  self.assertTrue(self.recvEvent.eventObj.cpu == compareVal, ">>> cpuAVG wrong")
146  compareVal = (testResources[1]["io"] + testResources[2]["io"] + testResources[4]["io"]) / 3
147  self.assertTrue(self.recvEvent.eventObj.io == compareVal, ">>> ioAVG wrong")
148  compareVal = (testResources[1]["ramR"] + testResources[2]["ramR"] + testResources[4]["ramR"]) / 3
149  self.assertTrue(self.recvEvent.eventObj.ramR == compareVal, ">>> ramRAVG wrong")
150  compareVal = (testResources[1]["ramV"] + testResources[2]["ramV"] + testResources[4]["ramV"]) / 3
151  self.assertTrue(self.recvEvent.eventObj.ramV == compareVal, ">>> ramVAVG wrong")
152  compareVal = (testResources[1]["swap"] + testResources[2]["swap"] + testResources[4]["swap"]) / 3
153  self.assertTrue(self.recvEvent.eventObj.swap == compareVal, ">>> swapAVG wrong")
154  compareVal = (testResources[1]["disk"] + testResources[2]["disk"] + testResources[4]["disk"]) / 3
155  self.assertTrue(self.recvEvent.eventObj.disk == compareVal, ">>> diskAVG wrong")
156  compareVal = (testResources[1]["cpuCores"] + testResources[2]["cpuCores"] + testResources[4]["cpuCores"]) / 3
157  self.assertTrue(self.recvEvent.eventObj.cpuCores == compareVal, ">>> cpuCores wrong")
158  compareVal = (testResources[1]["threads"] + testResources[2]["threads"] + testResources[4]["threads"]) / 3
159  self.assertTrue(self.recvEvent.eventObj.threads == compareVal, ">>> threads wrong")
160  compareVal = (testResources[1]["processes"] + testResources[2]["processes"] + testResources[4]["processes"]) / 3
161  self.assertTrue(self.recvEvent.eventObj.processes == compareVal, ">>> processes wrong")
162  self.assertTrue(self.recvEvent.eventObj.uDate == testResources[4]["uDate"] , ">>> diskAVG wrong")
163 
164 
Here is the call graph for this function:

Member Data Documentation

◆ adminServerConnection

ftests.ftest_ResourcesManager.TestResoursesManager.adminServerConnection

Definition at line 47 of file ftest_ResourcesManager.py.

◆ config

ftests.ftest_ResourcesManager.TestResoursesManager.config

Definition at line 43 of file ftest_ResourcesManager.py.

◆ connectionBuilder

ftests.ftest_ResourcesManager.TestResoursesManager.connectionBuilder

Definition at line 46 of file ftest_ResourcesManager.py.

◆ event

ftests.ftest_ResourcesManager.TestResoursesManager.event

Definition at line 52 of file ftest_ResourcesManager.py.

◆ eventBuilder

ftests.ftest_ResourcesManager.TestResoursesManager.eventBuilder

Definition at line 51 of file ftest_ResourcesManager.py.

◆ localConnection

ftests.ftest_ResourcesManager.TestResoursesManager.localConnection

Definition at line 77 of file ftest_ResourcesManager.py.

◆ moduleName

ftests.ftest_ResourcesManager.TestResoursesManager.moduleName

Definition at line 50 of file ftest_ResourcesManager.py.

◆ recvEvent

ftests.ftest_ResourcesManager.TestResoursesManager.recvEvent

Definition at line 56 of file ftest_ResourcesManager.py.

◆ reply_event

ftests.ftest_ResourcesManager.TestResoursesManager.reply_event

Definition at line 53 of file ftest_ResourcesManager.py.

◆ servIndex

ftests.ftest_ResourcesManager.TestResoursesManager.servIndex

Definition at line 44 of file ftest_ResourcesManager.py.

◆ taskResourcesManager

ftests.ftest_ResourcesManager.TestResoursesManager.taskResourcesManager

Definition at line 49 of file ftest_ResourcesManager.py.

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