Lines Matching refs:osds
1435 pg->pg_temp.osds[i] = ceph_decode_32(p); in __decode_pg_temp()
2223 !memcmp(lhs->osds, rhs->osds, rhs->size * sizeof(rhs->osds[0]))) in __osds_equal()
2257 if (set->osds[i] != CRUSH_ITEM_NONE) in osds_valid()
2269 memcpy(dest->osds, src->osds, src->size * sizeof(src->osds[0])); in ceph_osds_copy()
2332 if (acting->osds[i] == osd) in calc_pg_rank()
2510 if (!ceph_osd_exists(osdmap, set->osds[i])) { in remove_nonexistent_osds()
2515 set->osds[i - removed] = set->osds[i]; in remove_nonexistent_osds()
2521 if (!ceph_osd_exists(osdmap, set->osds[i])) in remove_nonexistent_osds()
2522 set->osds[i] = CRUSH_ITEM_NONE; in remove_nonexistent_osds()
2555 if (pi->size > ARRAY_SIZE(raw->osds)) { in pg_to_raw_osds()
2558 ARRAY_SIZE(raw->osds)); in pg_to_raw_osds()
2562 len = do_crush(osdmap, ruleno, pps, raw->osds, pi->size, in pg_to_raw_osds()
2587 int osd = pg->pg_upmap.osds[i]; in apply_upmap()
2597 raw->osds[i] = pg->pg_upmap.osds[i]; in apply_upmap()
2616 int osd = raw->osds[j]; in apply_upmap()
2631 raw->osds[pos] = to; in apply_upmap()
2657 if (ceph_osd_is_down(osdmap, set->osds[i])) { in raw_to_up_osds()
2662 set->osds[i - removed] = set->osds[i]; in raw_to_up_osds()
2666 set->primary = set->osds[0]; in raw_to_up_osds()
2670 if (ceph_osd_is_down(osdmap, set->osds[i])) in raw_to_up_osds()
2671 set->osds[i] = CRUSH_ITEM_NONE; in raw_to_up_osds()
2673 set->primary = set->osds[i]; in raw_to_up_osds()
2694 int osd = up->osds[i]; in apply_primary_affinity()
2711 int osd = up->osds[i]; in apply_primary_affinity()
2736 up->primary = up->osds[pos]; in apply_primary_affinity()
2741 up->osds[i] = up->osds[i - 1]; in apply_primary_affinity()
2742 up->osds[0] = up->primary; in apply_primary_affinity()
2768 if (ceph_osd_is_down(osdmap, pg->pg_temp.osds[i])) { in get_temp_osds()
2772 temp->osds[temp->size++] = CRUSH_ITEM_NONE; in get_temp_osds()
2774 temp->osds[temp->size++] = pg->pg_temp.osds[i]; in get_temp_osds()
2780 if (temp->osds[i] != CRUSH_ITEM_NONE) { in get_temp_osds()
2781 temp->primary = temp->osds[i]; in get_temp_osds()
2818 memcpy(acting->osds, up->osds, up->size * sizeof(up->osds[0])); in ceph_pg_to_up_acting_osds()
2846 if (acting.osds[i] == acting.primary) { in ceph_pg_to_primary_shard()