From 82497c22065ca463cf0f7dfccc891f81facb3ae9 Mon Sep 17 00:00:00 2001 From: Antoine Busque Date: Mon, 21 Dec 2015 22:51:24 -0500 Subject: [PATCH] Initial core/stats module implementation Signed-off-by: Antoine Busque --- lttnganalyses/core/stats.py | 52 +++++++++++++++++++++++++++++++++++++ 1 file changed, 52 insertions(+) create mode 100644 lttnganalyses/core/stats.py diff --git a/lttnganalyses/core/stats.py b/lttnganalyses/core/stats.py new file mode 100644 index 0000000..8c15567 --- /dev/null +++ b/lttnganalyses/core/stats.py @@ -0,0 +1,52 @@ +# The MIT License (MIT) +# +# Copyright (C) 2015 - Antoine Busque +# +# Permission is hereby granted, free of charge, to any person obtaining a copy +# of this software and associated documentation files (the "Software"), to deal +# in the Software without restriction, including without limitation the rights +# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +# copies of the Software, and to permit persons to whom the Software is +# furnished to do so, subject to the following conditions: +# +# The above copyright notice and this permission notice shall be included in +# all copies or substantial portions of the Software. +# +# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE +# SOFTWARE. + +class Stats(): + def reset(self): + raise NotImplementedError() + + +class Process(Stats): + def __init__(self, pid, tid, comm): + self.pid = pid + self.tid = tid + self.comm = comm + + @classmethod + def new_from_process(cls, proc): + return cls(proc.pid, proc.tid, proc.comm) + + +class IO(Stats): + def __init__(self): + # Number of bytes read or written + self.read = 0 + self.write = 0 + + def reset(self): + self.read = 0 + self.write = 0 + + def __iadd__(self, other): + self.read += other.read + self.write += other.read + return self -- 2.34.1