Lines Matching refs:osds

1247 		pg->pg_temp.osds[i] = ceph_decode_32(p);  in __decode_pg_temp()
2016 !memcmp(lhs->osds, rhs->osds, rhs->size * sizeof(rhs->osds[0]))) in __osds_equal()
2050 if (set->osds[i] != CRUSH_ITEM_NONE) in osds_valid()
2062 memcpy(dest->osds, src->osds, src->size * sizeof(src->osds[0])); in ceph_osds_copy()
2125 if (acting->osds[i] == osd) in calc_pg_rank()
2303 if (!ceph_osd_exists(osdmap, set->osds[i])) { in remove_nonexistent_osds()
2308 set->osds[i - removed] = set->osds[i]; in remove_nonexistent_osds()
2314 if (!ceph_osd_exists(osdmap, set->osds[i])) in remove_nonexistent_osds()
2315 set->osds[i] = CRUSH_ITEM_NONE; in remove_nonexistent_osds()
2348 if (pi->size > ARRAY_SIZE(raw->osds)) { in pg_to_raw_osds()
2351 ARRAY_SIZE(raw->osds)); in pg_to_raw_osds()
2355 len = do_crush(osdmap, ruleno, pps, raw->osds, pi->size, in pg_to_raw_osds()
2380 int osd = pg->pg_upmap.osds[i]; in apply_upmap()
2390 raw->osds[i] = pg->pg_upmap.osds[i]; in apply_upmap()
2409 int osd = raw->osds[j]; in apply_upmap()
2424 raw->osds[pos] = to; in apply_upmap()
2450 if (ceph_osd_is_down(osdmap, set->osds[i])) { in raw_to_up_osds()
2455 set->osds[i - removed] = set->osds[i]; in raw_to_up_osds()
2459 set->primary = set->osds[0]; in raw_to_up_osds()
2463 if (ceph_osd_is_down(osdmap, set->osds[i])) in raw_to_up_osds()
2464 set->osds[i] = CRUSH_ITEM_NONE; in raw_to_up_osds()
2466 set->primary = set->osds[i]; in raw_to_up_osds()
2487 int osd = up->osds[i]; in apply_primary_affinity()
2504 int osd = up->osds[i]; in apply_primary_affinity()
2529 up->primary = up->osds[pos]; in apply_primary_affinity()
2534 up->osds[i] = up->osds[i - 1]; in apply_primary_affinity()
2535 up->osds[0] = up->primary; in apply_primary_affinity()
2561 if (ceph_osd_is_down(osdmap, pg->pg_temp.osds[i])) { in get_temp_osds()
2565 temp->osds[temp->size++] = CRUSH_ITEM_NONE; in get_temp_osds()
2567 temp->osds[temp->size++] = pg->pg_temp.osds[i]; in get_temp_osds()
2573 if (temp->osds[i] != CRUSH_ITEM_NONE) { in get_temp_osds()
2574 temp->primary = temp->osds[i]; in get_temp_osds()
2611 memcpy(acting->osds, up->osds, up->size * sizeof(up->osds[0])); in ceph_pg_to_up_acting_osds()
2639 if (acting.osds[i] == acting.primary) { in ceph_pg_to_primary_shard()