expression+="select(contains(\"active\") and contains(\"clean\")) | "
expression+="select(contains(\"stale\") | not)"
ceph --format json pg dump pgs 2>/dev/null | \
- jq "[.[] | .state | $expression] | length"
+ jq ".pg_stats | [.[] | .state | $expression] | length"
}
function test_get_num_active_clean() {
# @return 0 on success, 1 on error
#
function get_osd_id_used_by_pgs() {
- ceph --format json pg dump pgs 2>/dev/null | jq '.[] | .up[], .acting[]' | sort
+ ceph --format json pg dump pgs 2>/dev/null | jq '.pg_stats | .[] | .up[], .acting[]' | sort
}
function test_get_osd_id_used_by_pgs() {
local pgid=$1
local sname=${2:-last_scrub_stamp}
ceph --format json pg dump pgs 2>/dev/null | \
- jq -r ".[] | select(.pgid==\"$pgid\") | .$sname"
+ jq -r ".pg_stats | .[] | select(.pgid==\"$pgid\") | .$sname"
}
function test_get_last_scrub_stamp() {
"""
out = self.raw_cluster_cmd('pg', 'dump', '--format=json')
j = json.loads('\n'.join(out.split('\n')[1:]))
- return j['pg_stats']
+ try:
+ return j['pg_map']['pg_stats']
+ except KeyError:
+ return j['pg_stats']
def get_pgids_to_force(self, backfill):
"""