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

Avoid fatal faults if volume stats are invalid

Browse Source 
Returns garbage data, but avoids causing the entire API call to fail if
this happens on very old clusters (or after any sort of ZK corruption).
This commit is contained in:
Joshua Boniface 2025-06-04 23:51:12 -04:00
parent 9ec2884e40
commit 9ca0217154
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
daemon-common/ceph.py
View File

@ -555,9 +555,16 @@ def getCephVolumes(zkhandler, pool):
def getVolumeInformation(zkhandler, pool, volume): def getVolumeInformation(zkhandler, pool, volume):
# Parse the stats data # Parse the stats data
volume_stats_raw = zkhandler.read(("volume.stats", f"{pool}/{volume}")) volume_stats_raw = zkhandler.read(("volume.stats", f"{pool}/{volume}"))
volume_stats = dict(json.loads(volume_stats_raw)) try:
# Format the size to something nicer volume_stats = dict(json.loads(volume_stats_raw))
volume_stats["size"] = format_bytes_tohuman(volume_stats["size"]) # Format the size to something nicer
volume_stats["size"] = format_bytes_tohuman(volume_stats["size"])
except Exception:
volume_stats = dict(
json.loads(
f'{"name":"{volume}","id":"","size":0,"objects":0,"order":0,"object_size":0,"snapshot_count":0,"block_name_prefix":"","format":0,"features":[],"op_features":[],"flags":[],"create_timestamp":"","access_timestamp":"","modify_timestamp":""}'
)
)
volume_information = {"name": volume, "pool": pool, "stats": volume_stats} volume_information = {"name": volume, "pool": pool, "stats": volume_stats}
return volume_information return volume_information