if not result_table.rows:
return
- values = []
graph = Pyasciigraph()
graph_data = []
result_table = self._mi_create_result_table(
self._MI_TABLE_CLASS_PART_LATENCY_STATS, begin, end)
- append_fn = self._append_latency_stats_row_from_requests
for disk in self._analysis.disks.values():
if disk.rq_count:
counts[index] += 1
- graph_data = []
-
for index, count in enumerate(counts):
lower_bound = index * step + min_duration
upper_bound = (index + 1) * step + min_duration
class TableClass:
- def __init__(self, name, title, column_descriptions_tuples=[],
+ def __init__(self, name, title, column_descriptions_tuples=None,
inherit=None):
+ if column_descriptions_tuples is None:
+ column_descriptions_tuples = []
+
self._inherit = inherit
self._name = name
self._title = title
def subtitle(self):
return self._subtitle
- @property
- def title(self):
- return self._table_class.title
-
def append_row(self, **kwargs):
row = self._column_named_tuple(**kwargs)
self._rows.append(row)
from .command import Command
from ..core import sched
from ..linuxautomaton import common
-from ..ascii_graph import Pyasciigraph
from . import mi
import math
import operator
self._mi_create_result_table(self._MI_TABLE_CLASS_PER_PRIO_STATS,
begin_ns, end_ns)
- prio_sched_lists, prio_stats = self._get_prio_sched_lists_stats()
+ _, prio_stats = self._get_prio_sched_lists_stats()
for prio in sorted(prio_stats):
stats = prio_stats[prio]
buckets.append(i * step)
counts.append(0)
- for sched in sched_list:
- duration = sched.latency / 1000
+ for sched_event in sched_list:
+ duration = sched_event.latency / 1000
index = int((duration - min_duration) / step)
if index >= resolution:
timestamp = kwargs['timestamp']
cpu_id = kwargs['cpu_id']
wakee_proc = kwargs['wakee_proc']
- next_tid = kwargs['next_tid']
if not self._filter_cpu(cpu_id):
return