parallelvirtualcluster
/
pvc
1
0
Fork 0
Code Issues 11 Pull Requests Projects Releases 111 Wiki Activity

Port Ceph functions to read_many 

Only ports getOSDInformation, as all the others feature 3 or less reads
which is acceptable sequentially.
This commit is contained in:
Joshua Boniface 2023-12-10 22:24:38 -05:00
parent 0c94f1b4f8
commit 9235187c6f
1 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
daemon-common/ceph.py
View File

@ -215,14 +215,26 @@ def getClusterOSDList(zkhandler):
def getOSDInformation(zkhandler, osd_id): def getOSDInformation(zkhandler, osd_id):
# Get the devices (
osd_fsid = zkhandler.read(("osd.ofsid", osd_id)) osd_fsid,
osd_node = zkhandler.read(("osd.node", osd_id)) osd_node,
osd_device = zkhandler.read(("osd.device", osd_id)) osd_device,
osd_is_split = bool(strtobool(zkhandler.read(("osd.is_split", osd_id)))) _osd_is_split,
osd_db_device = zkhandler.read(("osd.db_device", osd_id)) osd_db_device,
osd_stats_raw,
) = zkhandler.read_many(
[
("osd.ofsid", osd_id),
("osd.node", osd_id),
("osd.device", osd_id),
("osd.is_split", osd_id),
("osd.db_device", osd_id),
("osd.stats", osd_id),
]
)
osd_is_split = bool(strtobool(_osd_is_split))
# Parse the stats data # Parse the stats data
osd_stats_raw = zkhandler.read(("osd.stats", osd_id))
osd_stats = dict(json.loads(osd_stats_raw)) osd_stats = dict(json.loads(osd_stats_raw))
osd_information = { osd_information = {