mirror of
https://github.com/ceph/ceph
synced 2025-02-21 09:57:26 +00:00
Merge branch 'master' of github.com:ceph/teuthology
This commit is contained in:
commit
662fd9ecd8
@ -571,7 +571,7 @@ class CephManager:
|
||||
while True:
|
||||
out = self.raw_cluster_cmd('--', 'pg',pgid,'list_missing',
|
||||
json.dumps(offset))
|
||||
j = json.loads('\n'.join(out.split('\n')[1:]))
|
||||
j = json.loads(out)
|
||||
if r is None:
|
||||
r = j
|
||||
else:
|
||||
@ -643,7 +643,7 @@ class CephManager:
|
||||
def get_stuck_pgs(self, type_, threshold):
|
||||
out = self.raw_cluster_cmd('pg','dump_stuck', type_,
|
||||
'--format=json', '-t', str(threshold))
|
||||
return json.loads('\n'.join(out.split('\n')[1:]))
|
||||
return json.loads(out)
|
||||
|
||||
def get_num_unfound_objects(self):
|
||||
status = self.raw_cluster_status()
|
||||
|
@ -83,7 +83,7 @@ def task(ctx, config):
|
||||
for pg in pgs:
|
||||
out = manager.raw_cluster_cmd('pg', pg['pgid'], 'query')
|
||||
log.debug("out string %s",out)
|
||||
j = json.loads('\n'.join(out.split('\n')[1:]))
|
||||
j = json.loads(out)
|
||||
log.info("pg is %s, query json is %s", pg, j)
|
||||
|
||||
if pg['state'].count('down'):
|
||||
|
Loading…
Reference in New Issue
Block a user