Lines Matching refs:osds

1435 		pg->pg_temp.osds[i] = ceph_decode_32(p);  in __decode_pg_temp()
2204 !memcmp(lhs->osds, rhs->osds, rhs->size * sizeof(rhs->osds[0]))) in __osds_equal()
2238 if (set->osds[i] != CRUSH_ITEM_NONE) in osds_valid()
2250 memcpy(dest->osds, src->osds, src->size * sizeof(src->osds[0])); in ceph_osds_copy()
2313 if (acting->osds[i] == osd) in calc_pg_rank()
2491 if (!ceph_osd_exists(osdmap, set->osds[i])) { in remove_nonexistent_osds()
2496 set->osds[i - removed] = set->osds[i]; in remove_nonexistent_osds()
2502 if (!ceph_osd_exists(osdmap, set->osds[i])) in remove_nonexistent_osds()
2503 set->osds[i] = CRUSH_ITEM_NONE; in remove_nonexistent_osds()
2536 if (pi->size > ARRAY_SIZE(raw->osds)) { in pg_to_raw_osds()
2539 ARRAY_SIZE(raw->osds)); in pg_to_raw_osds()
2543 len = do_crush(osdmap, ruleno, pps, raw->osds, pi->size, in pg_to_raw_osds()
2568 int osd = pg->pg_upmap.osds[i]; in apply_upmap()
2578 raw->osds[i] = pg->pg_upmap.osds[i]; in apply_upmap()
2597 int osd = raw->osds[j]; in apply_upmap()
2612 raw->osds[pos] = to; in apply_upmap()
2638 if (ceph_osd_is_down(osdmap, set->osds[i])) { in raw_to_up_osds()
2643 set->osds[i - removed] = set->osds[i]; in raw_to_up_osds()
2647 set->primary = set->osds[0]; in raw_to_up_osds()
2651 if (ceph_osd_is_down(osdmap, set->osds[i])) in raw_to_up_osds()
2652 set->osds[i] = CRUSH_ITEM_NONE; in raw_to_up_osds()
2654 set->primary = set->osds[i]; in raw_to_up_osds()
2675 int osd = up->osds[i]; in apply_primary_affinity()
2692 int osd = up->osds[i]; in apply_primary_affinity()
2717 up->primary = up->osds[pos]; in apply_primary_affinity()
2722 up->osds[i] = up->osds[i - 1]; in apply_primary_affinity()
2723 up->osds[0] = up->primary; in apply_primary_affinity()
2749 if (ceph_osd_is_down(osdmap, pg->pg_temp.osds[i])) { in get_temp_osds()
2753 temp->osds[temp->size++] = CRUSH_ITEM_NONE; in get_temp_osds()
2755 temp->osds[temp->size++] = pg->pg_temp.osds[i]; in get_temp_osds()
2761 if (temp->osds[i] != CRUSH_ITEM_NONE) { in get_temp_osds()
2762 temp->primary = temp->osds[i]; in get_temp_osds()
2799 memcpy(acting->osds, up->osds, up->size * sizeof(up->osds[0])); in ceph_pg_to_up_acting_osds()
2827 if (acting.osds[i] == acting.primary) { in ceph_pg_to_primary_shard()