diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 18:45:59 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 18:45:59 +0000 |
commit | 19fcec84d8d7d21e796c7624e521b60d28ee21ed (patch) | |
tree | 42d26aa27d1e3f7c0b8bd3fd14e7d7082f5008dc /src/pybind/mgr/iostat | |
parent | Initial commit. (diff) | |
download | ceph-6d07fdb6bb33b1af39833b850bb6cf8af79fe293.tar.xz ceph-6d07fdb6bb33b1af39833b850bb6cf8af79fe293.zip |
Adding upstream version 16.2.11+ds.upstream/16.2.11+dsupstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to '')
-rw-r--r-- | src/pybind/mgr/iostat/__init__.py | 1 | ||||
-rw-r--r-- | src/pybind/mgr/iostat/module.py | 60 |
2 files changed, 61 insertions, 0 deletions
diff --git a/src/pybind/mgr/iostat/__init__.py b/src/pybind/mgr/iostat/__init__.py new file mode 100644 index 000000000..8f210ac92 --- /dev/null +++ b/src/pybind/mgr/iostat/__init__.py @@ -0,0 +1 @@ +from .module import Module diff --git a/src/pybind/mgr/iostat/module.py b/src/pybind/mgr/iostat/module.py new file mode 100644 index 000000000..7a340ff4a --- /dev/null +++ b/src/pybind/mgr/iostat/module.py @@ -0,0 +1,60 @@ +from mgr_module import CLIReadCommand, HandleCommandResult, MgrModule + + +class Module(MgrModule): + def __init__(self, *args, **kwargs): + super().__init__(*args, **kwargs) + + def self_test(self): + r = self.get('io_rate') + assert 'pg_stats_delta' in r + assert 'stamp_delta' in r['pg_stats_delta'] + assert 'stat_sum' in r['pg_stats_delta'] + assert 'num_read_kb' in r['pg_stats_delta']['stat_sum'] + assert 'num_write_kb' in r['pg_stats_delta']['stat_sum'] + assert 'num_write' in r['pg_stats_delta']['stat_sum'] + assert 'num_read' in r['pg_stats_delta']['stat_sum'] + + @CLIReadCommand('iostat', poll=True) + def iostat(self, width: int = 80, print_header: bool = False): + """ + Get IO rates + """ + rd = 0 + wr = 0 + total = 0 + rd_ops = 0 + wr_ops = 0 + total_ops = 0 + ret = '' + + r = self.get('io_rate') + + stamp_delta = int(float(r['pg_stats_delta']['stamp_delta'])) + if stamp_delta > 0: + rd = r['pg_stats_delta']['stat_sum']['num_read_kb'] // stamp_delta + wr = r['pg_stats_delta']['stat_sum']['num_write_kb'] // stamp_delta + # The values are in kB, but to_pretty_iec() requires them to be in bytes + rd = rd << 10 + wr = wr << 10 + total = rd + wr + + rd_ops = r['pg_stats_delta']['stat_sum']['num_read'] // stamp_delta + wr_ops = r['pg_stats_delta']['stat_sum']['num_write'] // stamp_delta + total_ops = rd_ops + wr_ops + + if print_header: + elems = ['Read', 'Write', 'Total', 'Read IOPS', 'Write IOPS', 'Total IOPS'] + ret += self.get_pretty_header(elems, width) + + elems = [ + self.to_pretty_iec(rd) + 'B/s', + self.to_pretty_iec(wr) + 'B/s', + self.to_pretty_iec(total) + 'B/s', + str(rd_ops), + str(wr_ops), + str(total_ops) + ] + ret += self.get_pretty_row(elems, width) + + return HandleCommandResult(stdout=ret) |