Lines Matching refs:osds

1451 		pg->pg_temp.osds[i] = ceph_decode_32(p);  in __decode_pg_temp()
2239 !memcmp(lhs->osds, rhs->osds, rhs->size * sizeof(rhs->osds[0]))) in __osds_equal()
2273 if (set->osds[i] != CRUSH_ITEM_NONE) in osds_valid()
2285 memcpy(dest->osds, src->osds, src->size * sizeof(src->osds[0])); in ceph_osds_copy()
2348 if (acting->osds[i] == osd) in calc_pg_rank()
2526 if (!ceph_osd_exists(osdmap, set->osds[i])) { in remove_nonexistent_osds()
2531 set->osds[i - removed] = set->osds[i]; in remove_nonexistent_osds()
2537 if (!ceph_osd_exists(osdmap, set->osds[i])) in remove_nonexistent_osds()
2538 set->osds[i] = CRUSH_ITEM_NONE; in remove_nonexistent_osds()
2571 if (pi->size > ARRAY_SIZE(raw->osds)) { in pg_to_raw_osds()
2574 ARRAY_SIZE(raw->osds)); in pg_to_raw_osds()
2578 len = do_crush(osdmap, ruleno, pps, raw->osds, pi->size, in pg_to_raw_osds()
2603 int osd = pg->pg_upmap.osds[i]; in apply_upmap()
2613 raw->osds[i] = pg->pg_upmap.osds[i]; in apply_upmap()
2632 int osd = raw->osds[j]; in apply_upmap()
2647 raw->osds[pos] = to; in apply_upmap()
2673 if (ceph_osd_is_down(osdmap, set->osds[i])) { in raw_to_up_osds()
2678 set->osds[i - removed] = set->osds[i]; in raw_to_up_osds()
2682 set->primary = set->osds[0]; in raw_to_up_osds()
2686 if (ceph_osd_is_down(osdmap, set->osds[i])) in raw_to_up_osds()
2687 set->osds[i] = CRUSH_ITEM_NONE; in raw_to_up_osds()
2689 set->primary = set->osds[i]; in raw_to_up_osds()
2710 int osd = up->osds[i]; in apply_primary_affinity()
2727 int osd = up->osds[i]; in apply_primary_affinity()
2752 up->primary = up->osds[pos]; in apply_primary_affinity()
2757 up->osds[i] = up->osds[i - 1]; in apply_primary_affinity()
2758 up->osds[0] = up->primary; in apply_primary_affinity()
2784 if (ceph_osd_is_down(osdmap, pg->pg_temp.osds[i])) { in get_temp_osds()
2788 temp->osds[temp->size++] = CRUSH_ITEM_NONE; in get_temp_osds()
2790 temp->osds[temp->size++] = pg->pg_temp.osds[i]; in get_temp_osds()
2796 if (temp->osds[i] != CRUSH_ITEM_NONE) { in get_temp_osds()
2797 temp->primary = temp->osds[i]; in get_temp_osds()
2834 memcpy(acting->osds, up->osds, up->size * sizeof(up->osds[0])); in ceph_pg_to_up_acting_osds()
2862 if (acting.osds[i] == acting.primary) { in ceph_pg_to_primary_shard()