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
dtm.ResourcesRecalculating.ResourcesRecalculating Class Reference

Class ResourcesRecalculating, that contains recalcularing algorithm of resource data. More...

Inheritance diagram for dtm.ResourcesRecalculating.ResourcesRecalculating:
Collaboration diagram for dtm.ResourcesRecalculating.ResourcesRecalculating:

Public Member Functions

def __init__ (self)
 constructor initialise all class variable and recieve config as param More...
 
def addUpdateResources (self, resources)
 
def recalculate (self)
 recalculate method recalculate method calls outside and performs recalculate processing, now it's empty More...
 
def getResourcesAVG (self)
 

Public Attributes

 resources
 
 resourcesAVG
 

Detailed Description

Class ResourcesRecalculating, that contains recalcularing algorithm of resource data.

Definition at line 18 of file ResourcesRecalculating.py.

Constructor & Destructor Documentation

◆ __init__()

def dtm.ResourcesRecalculating.ResourcesRecalculating.__init__ (   self)

constructor initialise all class variable and recieve config as param

Definition at line 23 of file ResourcesRecalculating.py.

23  def __init__(self):
24  self.resources = {}
25  self.resourcesAVG = EventObjects.ResourcesAVG()
26 
27 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ addUpdateResources()

def dtm.ResourcesRecalculating.ResourcesRecalculating.addUpdateResources (   self,
  resources 
)

Definition at line 28 of file ResourcesRecalculating.py.

28  def addUpdateResources(self, resources):
29  self.resources[resources.nodeId] = resources
30 
31 

◆ getResourcesAVG()

def dtm.ResourcesRecalculating.ResourcesRecalculating.getResourcesAVG (   self)

Definition at line 81 of file ResourcesRecalculating.py.

81  def getResourcesAVG(self):
82  return self.resourcesAVG
83 

◆ recalculate()

def dtm.ResourcesRecalculating.ResourcesRecalculating.recalculate (   self)

recalculate method recalculate method calls outside and performs recalculate processing, now it's empty

Definition at line 34 of file ResourcesRecalculating.py.

34  def recalculate(self):
35  rCount = 0
36  self.resourcesAVG.cpu = 0
37  self.resourcesAVG.io = 0
38  self.resourcesAVG.ramRU = 0
39  self.resourcesAVG.ramVU = 0
40  self.resourcesAVG.ramR = 0
41  self.resourcesAVG.ramV = 0
42  self.resourcesAVG.swap = 0
43  self.resourcesAVG.disk = 0
44  self.resourcesAVG.uDate = 0
45  self.resourcesAVG.cpuCores = 0
46  self.resourcesAVG.threads = 0
47  self.resourcesAVG.processes = 0
48  for resourceItem in self.resources.values():
49  if resourceItem.state == EventObjects.Resource.STATE_ACTIVE:
50  self.resourcesAVG.cpu += resourceItem.cpu
51  self.resourcesAVG.io += resourceItem.io
52  self.resourcesAVG.ramRU += resourceItem.ramRU
53  self.resourcesAVG.ramVU += resourceItem.ramVU
54  self.resourcesAVG.ramR += resourceItem.ramR
55  self.resourcesAVG.ramV += resourceItem.ramV
56  self.resourcesAVG.swap += resourceItem.swap
57  self.resourcesAVG.disk += resourceItem.disk
58  if rCount == 0 or resourceItem.uDate < self.resourcesAVG.uDate:
59  self.resourcesAVG.uDate = resourceItem.uDate
60  self.resourcesAVG.cpuCores += resourceItem.cpuCores
61  self.resourcesAVG.threads += resourceItem.threads
62  self.resourcesAVG.processes += resourceItem.processes
63  rCount += 1
64  if rCount > 0:
65  self.resourcesAVG.cpu = self.resourcesAVG.cpu / rCount
66  self.resourcesAVG.io = self.resourcesAVG.io / rCount
67  self.resourcesAVG.ramRU = self.resourcesAVG.ramRU / rCount
68  self.resourcesAVG.ramVU = self.resourcesAVG.ramVU / rCount
69  self.resourcesAVG.ramR = self.resourcesAVG.ramR / rCount
70  self.resourcesAVG.ramV = self.resourcesAVG.ramV / rCount
71  self.resourcesAVG.swap = self.resourcesAVG.swap / rCount
72  self.resourcesAVG.disk = self.resourcesAVG.disk / rCount
73  self.resourcesAVG.cpuCores = self.resourcesAVG.cpuCores / rCount
74  self.resourcesAVG.threads = self.resourcesAVG.threads / rCount
75  self.resourcesAVG.processes = self.resourcesAVG.processes / rCount
76  else:
77  self.resourcesAVG.cpu = sys.maxint
78  self.resourcesAVG.io = sys.maxint
79 
80 

Member Data Documentation

◆ resources

dtm.ResourcesRecalculating.ResourcesRecalculating.resources

Definition at line 24 of file ResourcesRecalculating.py.

◆ resourcesAVG

dtm.ResourcesRecalculating.ResourcesRecalculating.resourcesAVG

Definition at line 25 of file ResourcesRecalculating.py.


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