syscallstats

Signed-off-by: Julien Desfossez <jdesfossez@efficios.com>

diff --git a/lttnganalysescli/lttnganalysescli/syscallstats.py b/lttnganalysescli/lttnganalysescli/syscallstats.py
new file mode 100644 (file)
index 0000000..81215f1
--- /dev/null
+++ b/lttnganalysescli/lttnganalysescli/syscallstats.py
@@ -0,0 +1,91 @@
+from .command import Command
+import lttnganalyses.syscalls
+from linuxautomaton import common
+import operator
+
+
+class SyscallsAnalysis(Command):
+    _VERSION = '0.1.0'
+    _DESC = """The I/O command."""
+
+    def __init__(self):
+        super().__init__(self._add_arguments,
+                         enable_proc_filter_args=True)
+#                         enable_max_min_args=True,
+#                         enable_max_min_size_arg=True,
+#                         enable_freq_arg=True,
+#                         enable_log_arg=True,
+#                         enable_stats_arg=True)
+
+    def _validate_transform_args(self):
+        pass
+
+    def run(self):
+        # parse arguments first
+        self._parse_args()
+        # validate, transform and save specific arguments
+        self._validate_transform_args()
+        # open the trace
+        self._open_trace()
+        # create the appropriate analysis/analyses
+        self._create_analysis()
+        # run the analysis
+        self._run_analysis(self._reset_total, self._refresh)
+        # process the results
+        self._compute_stats()
+        # print results
+        self._print_results(self.start_ns, self.trace_end_ts, final=1)
+        # close the trace
+        self._close_trace()
+
+    def _create_analysis(self):
+        self._analysis = lttnganalyses.syscalls.SyscallsAnalysis(
+            self._automaton.state)
+
+    def _compute_stats(self):
+        self.state = self._automaton.state
+        pass
+
+    def _refresh(self, begin, end):
+        self._compute_stats()
+        self._print_results(begin, end, final=0)
+        self._reset_total(end)
+
+    def _print_results(self, begin_ns, end_ns, final=0):
+        count = 0
+        limit = self._arg_limit
+        print('%s to %s' % (common.ns_to_asctime(begin_ns),
+                            common.ns_to_asctime(end_ns)))
+        print("Per-TID syscalls usage")
+        for tid in sorted(self.state.tids.values(),
+                          key=operator.attrgetter('total_syscalls'),
+                          reverse=True):
+
+            print("%s (%d), %d syscalls:" % (tid.comm, tid.tid,
+                                             tid.total_syscalls))
+            for syscall in sorted(tid.syscalls.values(),
+                                  key=operator.attrgetter('count'),
+                                  reverse=True):
+                print("- %s : %d" % (syscall.name, syscall.count))
+            count = count + 1
+            if limit > 0 and count >= limit:
+                break
+            print("")
+
+        print("\nTotal syscalls: %d" % (self.state.syscalls["total"]))
+
+    def _reset_total(self, start_ts):
+        pass
+
+    def _add_arguments(self, ap):
+        # specific argument
+        pass
+
+
+# entry point
+def run():
+    # create command
+    syscallscmd = SyscallsAnalysis()
+
+    # execute command
+    syscallscmd.run()

diff --git a/syscallstats b/syscallstats
new file mode 100755 (executable)
index 0000000..a870be7
--- /dev/null
+++ b/syscallstats
@@ -0,0 +1,11 @@
+#!/usr/bin/env python3
+
+import sys
+
+sys.path += ['linuxautomaton', 'lttnganalyses', 'lttnganalysescli']
+
+import lttnganalysescli.syscallstats
+
+
+if __name__ == '__main__':
+    lttnganalysescli.syscallstats.run()