def get_mds_info(self, mds_id):
return FSStatus(self.mon_manager).get_mds(mds_id)
- def is_full(self):
- flags = json.loads(self.mon_manager.raw_cluster_cmd("osd", "dump", "--format=json-pretty"))['flags']
- return 'full' in flags
-
def is_pool_full(self, pool_name):
pools = json.loads(self.mon_manager.raw_cluster_cmd("osd", "dump", "--format=json-pretty"))['pools']
for pool in pools:
self.name, self.metadata_pool_name, data_pool_name,
'--allow-dangerous-metadata-overlay')
else:
- if self.ec_profile:
+ if self.ec_profile and 'disabled' not in self.ec_profile:
log.info("EC profile is %s", self.ec_profile)
cmd = ['osd', 'erasure-code-profile', 'set', data_pool_name]
cmd.extend(self.ec_profile)
return workers[0].value
else:
return None
+
+ def is_full(self):
+ return self.is_pool_full(self.get_data_pool_name())