From 19fcec84d8d7d21e796c7624e521b60d28ee21ed Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 7 Apr 2024 20:45:59 +0200 Subject: Adding upstream version 16.2.11+ds. Signed-off-by: Daniel Baumann --- src/pybind/mgr/stats/module.py | 41 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100644 src/pybind/mgr/stats/module.py (limited to 'src/pybind/mgr/stats/module.py') diff --git a/src/pybind/mgr/stats/module.py b/src/pybind/mgr/stats/module.py new file mode 100644 index 000000000..fcc1bce97 --- /dev/null +++ b/src/pybind/mgr/stats/module.py @@ -0,0 +1,41 @@ +""" +performance stats for ceph filesystem (for now...) +""" + +import json +from typing import List, Dict + +from mgr_module import MgrModule, Option, NotifyType + +from .fs.perf_stats import FSPerfStats + +class Module(MgrModule): + COMMANDS = [ + { + "cmd": "fs perf stats " + "name=mds_rank,type=CephString,req=false " + "name=client_id,type=CephString,req=false " + "name=client_ip,type=CephString,req=false ", + "desc": "retrieve ceph fs performance stats", + "perm": "r" + }, + ] + MODULE_OPTIONS: List[Option] = [] + NOTIFY_TYPES = [NotifyType.command, NotifyType.fs_map] + + def __init__(self, *args, **kwargs): + super(Module, self).__init__(*args, **kwargs) + self.fs_perf_stats = FSPerfStats(self) + + def notify(self, notify_type: NotifyType, notify_id): + if notify_type == NotifyType.command: + self.fs_perf_stats.notify_cmd(notify_id) + elif notify_type == NotifyType.fs_map: + self.fs_perf_stats.notify_fsmap() + + def handle_command(self, inbuf, cmd): + prefix = cmd['prefix'] + # only supported command is `fs perf stats` right now + if prefix.startswith('fs perf stats'): + return self.fs_perf_stats.get_perf_data(cmd) + raise NotImplementedError(cmd['prefix']) -- cgit v1.2.3