4:10 a.m.
From: Ondrej Lichtner <olichtne(a)redhat.com>
The module defines classes for storing performance measurement data and
a statistics class that calculates some statistic properties of this
data for use in reporting the results.
This commit adds a prototype implementation of these classes, more work
on these is expected.
Signed-off-by: Ondrej Lichtner <olichtne(a)redhat.com>
---
v2: fixed class names and removed a debug print
---
lnst/RecipeCommon/PerfResult.py | 151 ++++++++++++++++++++++++++++++++
1 file changed, 151 insertions(+)
create mode 100644 lnst/RecipeCommon/PerfResult.py
diff --git a/lnst/RecipeCommon/PerfResult.py b/lnst/RecipeCommon/PerfResult.py
new file mode 100644
index 0000000..a8d2245
--- /dev/null
+++ b/lnst/RecipeCommon/PerfResult.py
@@ -0,0 +1,151 @@
+from lnst.Common.LnstError import LnstError
+from lnst.Common.Utils import std_deviation
+
+class PerfStatMixin(object):
+ @property
+ def average(self):
+ return float(self.value) / self.duration
+
+ @property
+ def std_deviation(self):
+ return std_deviation([i.value for i in self])
+
+class PerfInterval(PerfStatMixin):
+ def __init__(self, value, duration, unit):
+ self._value = value
+ self._duration = duration
+ self._unit = unit
+
+ @property
+ def value(self):
+ return self._value
+
+ @property
+ def duration(self):
+ return self._duration
+
+ @property
+ def unit(self):
+ return self._unit
+
+class PerfList(list):
+ _sub_type = None
+
+ def __init__(self, iterable=[]):
+ unit = None
+
+ for i, item in enumerate(iterable):
+ if not isinstance(item, self._sub_type):
+ raise LnstError("{} only accepts {} objects."
+ .format(self.__class__.__name__,
+ self._sub_type.__name__))
+
+ if i == 0:
+ unit = item.unit
+
+ if item.unit != unit:
+ raise LnstError("PerfList items must have the same unit.")
+
+ super(PerfList, self).__init__(iterable)
+
+ def _validate_item(self, item):
+ if not isinstance(item, self._sub_type):
+ raise LnstError("{} only accepts {} objects."
+ .format(self.__class__.__name__,
+ self._sub_type.__name__))
+
+ if len(self) > 0 and item.unit != self[0].unit:
+ raise LnstError("PerfList items must have the same unit.")
+
+ def append(self, item):
+ self._validate_item(item)
+
+ super(PerfList, self).append(item)
+
+ def extend(self, iterable):
+ for i in iterable:
+ self._validate_item(i)
+
+ super(PerfList, self).extend(iterable)
+
+ def insert(self, index, item):
+ self._validate_item(item)
+
+ super(PerfList, self).insert(index, item)
+
+ def __add__(self, iterable):
+ for i in iterable:
+ self._validate_item(i)
+
+ super(PerfList, self).__add__(iterable)
+
+ def __iadd__(self, iterable):
+ for i in iterable:
+ self._validate_item(i)
+
+ super(PerfList, self).__iadd__(iterable)
+
+ def __setitem__(self, i, item):
+ self._validate_item(item)
+
+ super(PerfList, self).__setitem__(i, item)
+
+ def __setslice__(self, i, j, iterable):
+ for i in iterable:
+ self._validate_item(i)
+
+ super(PerfList, self).__setslice__(i, j, iterable)
+
+class StreamPerf(PerfList, PerfStatMixin):
+ _sub_type = PerfInterval
+
+ @property
+ def value(self):
+ return sum([i.value for i in self])
+
+ @property
+ def duration(self):
+ return sum([i.duration for i in self])
+
+ @property
+ def unit(self):
+ if len(self) > 0:
+ return self[0].unit
+ else:
+ return None
+
+class MultiStreamPerf(PerfList, PerfStatMixin):
+ _sub_type = StreamPerf
+
+ @property
+ def value(self):
+ return sum([i.value for i in self])
+
+ @property
+ def duration(self):
+ return max([i.duration for i in self])
+
+ @property
+ def unit(self):
+ if len(self) > 0:
+ return self[0].unit
+ else:
+ return None
+
+class MultiRunPerf(PerfList, PerfStatMixin):
+ _sub_type = MultiStreamPerf
+
+ @property
+ def value(self):
+ return sum([i.value for i in self])
+
+ @property
+ def duration(self):
+ return sum([i.duration for i in self])
+
+ @property
+ def unit(self):
+ if len(self) > 0:
+ return self[0].unit
+ else:
+ return None
--
2.17.0