Commit ff652551 authored by Nicolas Godbert's avatar Nicolas Godbert Committed by Romain Courteaud

Fix slapmonitor to follow latest slaplibrary API.

Squashed commit of the following:

commit b320e10451f60704f8bf17c3b15ed4760d7df705
Author: Romain Courteaud <romain@nexedi.com>
Date:   Tue Aug 30 16:48:28 2011 +0200

    Remove unwanted code.
    This will ease merging with the master.

commit 4bed989c16ede96ed49a698fb292d6df65afc5c3
Merge: 290b06b dd07d69e
Author: Romain Courteaud <romain@nexedi.com>
Date:   Tue Aug 30 16:36:54 2011 +0200

    Merge branch 'master' into usage_report

commit 290b06b12ea810918b59b9abe7b91becf9c8f702
Author: Nicolas Godbert <ngodbert@tiolive.com>
Date:   Wed Jun 1 10:41:38 2011 +0200

    Some fixes

commit 45735471d13c7eb98568408e07ae5b2023f6f57a
Author: Nicolas Godbert <ngodbert@tiolive.com>
Date:   Tue May 31 18:03:05 2011 +0200

    Modification of the methods which generate the XML report

commit b10d7ba05615d6c31d68350be8ae09e4020fbe5f
Author: Nicolas Godbert <ngodbert@tiolive.com>
Date:   Tue May 31 17:50:25 2011 +0200

    We count the CPU consumption time since the last XML report creation

commit b4abc09cb48664c026bab5acf26382ddca9537d5
Author: Nicolas Godbert <ngodbert@tiolive.com>
Date:   Tue May 31 17:39:47 2011 +0200

    Slapreport only generates a report if the database is not empty
parent dd07d69e
...@@ -73,8 +73,11 @@ class GenerateXML(object): ...@@ -73,8 +73,11 @@ class GenerateXML(object):
for row in cursor: for row in cursor:
consumption_infos.append(row) consumption_infos.append(row)
#If the database is not empty
if consumption_infos != []:
consumption_summary = self._eval_consumption_summary (consumption_infos) consumption_summary = self._eval_consumption_summary (consumption_infos)
self._write_xml_output(consumption_summary, self.path_xml) self._write_xml_output(consumption_summary, self.path_xml)
#Once we got infos we delete the table 'data' #Once we got infos we delete the table 'data'
cursor.execute("DELETE FROM data") cursor.execute("DELETE FROM data")
conn.commit() conn.commit()
...@@ -83,25 +86,48 @@ class GenerateXML(object): ...@@ -83,25 +86,48 @@ class GenerateXML(object):
def _eval_consumption_summary(self, consumption_infos): def _eval_consumption_summary(self, consumption_infos):
"""This function return a resources usage summary, for pricing purpose""" """This function return a resources usage summary, for pricing purpose"""
cpu_percentage = []
memory_percentage = [] memory_percentage = []
memory_space = [] memory_space = []
cpu_time = []
total_cpu_time = 0.00
previous = 0.00
first_time = False
#The total time that the cpu spent to work on it #The total time that the cpu spent to work on it
cpu_time = consumption_infos[-1][1] #Start-end time and date
#start-end time and date
start_time = consumption_infos[0][5] start_time = consumption_infos[0][5]
end_time = consumption_infos[-1][5] end_time = consumption_infos[-1][5]
start_date = consumption_infos[0][4] start_date = consumption_infos[0][4]
end_date = consumption_infos[-1][4] end_date = consumption_infos[-1][4]
for item in consumption_infos: for item in consumption_infos:
cpu_percentage.append(item[0]) cpu_time.append(item[1])
memory_percentage.append(item[2]) memory_percentage.append(item[2])
memory_space.append(item[3]) memory_space.append(item[3])
#For all the samples, we calculate CPU consumption time
return [cpu_time, sum(memory_space) / float(len(memory_space)), end_date, end_time, end_time] for indice,element in enumerate(cpu_time):
if indice == 0:
first_sample = float(element)
first_time = True
else:
#If the partition has been restarted...
if previous > float(element):
#If the partition has been restarted for the first time...
if first_time:
#We count the usage before the stop
previous = previous - first_sample
first_time = False
total_cpu_time = total_cpu_time + previous
previous = float(element)
#If the partition hasn't been restarted, we count only the difference between the last and the first sample
if first_time:
total_cpu_time = cpu_time[-1] - first_sample
#Else, we add the last sample to the total CPU consumption time
else:
total_cpu_time = total_cpu_time + cpu_time[-1]
return [total_cpu_time, sum(memory_space) / float(len(memory_space)), start_time, end_time, start_date, end_date]
#return [scipy.mean(cpu_percentage), cpu_time, scipy.mean(memory_percentage), #return [scipy.mean(cpu_percentage), cpu_time, scipy.mean(memory_percentage),
# scipy.mean(memory_space), start_time, end_time, start_date, end_date] # scipy.mean(memory_space), start_time, end_time, start_date, end_date]
...@@ -122,45 +148,48 @@ class GenerateXML(object): ...@@ -122,45 +148,48 @@ class GenerateXML(object):
res_list = map(str, res_list) res_list = map(str, res_list)
cpu_list = ['Cpu consumption', cpu_list = ['CPU Consumption',
'Cpu consumption of the partition on %s at %s' % (res_list[2], res_list[3]), 'CPU consumption of the partition on %s at %s' % (res_list[5], res_list[3]),
res_list[0], res_list[0],
] ]
memory_list = ['Memory consumption', memory_list = ['Memory consumption',
'Memory consumption of the partition on %s at %s' % (res_list[2], res_list[3]), 'Memory consumption of the partition on %s at %s' % (res_list[5], res_list[3]),
res_list[1], res_list[1],
] ]
root = ElementTree.Element("consumption") root = ElementTree.Element("consumption")
#Now we'll add two movement elements, one for cpu #Then, we add two movement elements, one for cpu
tree = self._add_nodes(root, cpu_list ) tree = self._add_movement(root, cpu_list )
tree.write(storage_path) #And one for memory
tree = self._add_movement(root, memory_list)
#one for memory
tree = self._add_nodes(root, memory_list) #We add the XML header to the file to be valid
tree.write(storage_path) report = ElementTree.tostring(tree)
fd = open(storage_path, 'w')
def _add_nodes(self, root, single_resource_list): fd.write("<?xml version='1.0' encoding='utf-8'?>%s" % report)
fd.close()
child_root = ElementTree.SubElement(root, "movement")
#child_root.set ('type', 'Sale Packing List') def _add_movement(self, consumption, single_resource_list):
child_data_start_date = ElementTree.SubElement(child_root, "resource") child_consumption = ElementTree.SubElement(consumption, "movement")
child_data_start_date.text = single_resource_list[0]
child_data_end_date = ElementTree.SubElement(child_root, "title") child_movement = ElementTree.SubElement(child_consumption, "resource")
child_data_end_date.text = single_resource_list[1] child_movement.text = single_resource_list[0]
child_data_end_date = ElementTree.SubElement(child_root, "reference") child_movement = ElementTree.SubElement(child_consumption, "title")
child_data_end_date.text = '' child_movement.text = single_resource_list[1]
child_data_end_date = ElementTree.SubElement(child_root, "quantity") child_movement = ElementTree.SubElement(child_consumption, "reference")
child_data_end_date.text = single_resource_list[2] child_movement.text = ''
child_data_end_date = ElementTree.SubElement(child_root, "price") child_movement = ElementTree.SubElement(child_consumption, "quantity")
child_data_end_date.text = '' child_movement.text = single_resource_list[2]
child_data_end_date = ElementTree.SubElement(child_root, "VAT") child_movement = ElementTree.SubElement(child_consumption, "price")
child_data_end_date.text = '' child_movement.text = '0.00'
child_data_end_date = ElementTree.SubElement(child_root, "category") child_movement = ElementTree.SubElement(child_consumption, "VAT")
child_data_end_date.text = '' child_movement.text = ''
child_movement = ElementTree.SubElement(child_consumption, "category")
tree = self.element_tree.ElementTree(root) child_movement.text = ''
tree = self.element_tree.ElementTree(consumption)
return tree return tree
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment