Lines Matching refs:osds

1231 		pg->pg_temp.osds[i] = ceph_decode_32(p);  in __decode_pg_temp()
1995 !memcmp(lhs->osds, rhs->osds, rhs->size * sizeof(rhs->osds[0]))) in __osds_equal()
2029 if (set->osds[i] != CRUSH_ITEM_NONE) in osds_valid()
2041 memcpy(dest->osds, src->osds, src->size * sizeof(src->osds[0])); in ceph_osds_copy()
2104 if (acting->osds[i] == osd) in calc_pg_rank()
2282 if (!ceph_osd_exists(osdmap, set->osds[i])) { in remove_nonexistent_osds()
2287 set->osds[i - removed] = set->osds[i]; in remove_nonexistent_osds()
2293 if (!ceph_osd_exists(osdmap, set->osds[i])) in remove_nonexistent_osds()
2294 set->osds[i] = CRUSH_ITEM_NONE; in remove_nonexistent_osds()
2327 if (pi->size > ARRAY_SIZE(raw->osds)) { in pg_to_raw_osds()
2330 ARRAY_SIZE(raw->osds)); in pg_to_raw_osds()
2334 len = do_crush(osdmap, ruleno, pps, raw->osds, pi->size, in pg_to_raw_osds()
2359 int osd = pg->pg_upmap.osds[i]; in apply_upmap()
2369 raw->osds[i] = pg->pg_upmap.osds[i]; in apply_upmap()
2388 int osd = raw->osds[j]; in apply_upmap()
2403 raw->osds[pos] = to; in apply_upmap()
2429 if (ceph_osd_is_down(osdmap, set->osds[i])) { in raw_to_up_osds()
2434 set->osds[i - removed] = set->osds[i]; in raw_to_up_osds()
2438 set->primary = set->osds[0]; in raw_to_up_osds()
2442 if (ceph_osd_is_down(osdmap, set->osds[i])) in raw_to_up_osds()
2443 set->osds[i] = CRUSH_ITEM_NONE; in raw_to_up_osds()
2445 set->primary = set->osds[i]; in raw_to_up_osds()
2466 int osd = up->osds[i]; in apply_primary_affinity()
2483 int osd = up->osds[i]; in apply_primary_affinity()
2508 up->primary = up->osds[pos]; in apply_primary_affinity()
2513 up->osds[i] = up->osds[i - 1]; in apply_primary_affinity()
2514 up->osds[0] = up->primary; in apply_primary_affinity()
2540 if (ceph_osd_is_down(osdmap, pg->pg_temp.osds[i])) { in get_temp_osds()
2544 temp->osds[temp->size++] = CRUSH_ITEM_NONE; in get_temp_osds()
2546 temp->osds[temp->size++] = pg->pg_temp.osds[i]; in get_temp_osds()
2552 if (temp->osds[i] != CRUSH_ITEM_NONE) { in get_temp_osds()
2553 temp->primary = temp->osds[i]; in get_temp_osds()
2590 memcpy(acting->osds, up->osds, up->size * sizeof(up->osds[0])); in ceph_pg_to_up_acting_osds()
2618 if (acting.osds[i] == acting.primary) { in ceph_pg_to_primary_shard()