Lines Matching refs:osdmap

2424 int ceph_object_locator_to_pg(struct ceph_osdmap *osdmap,  in ceph_object_locator_to_pg()  argument
2431 pi = ceph_pg_pool_by_id(osdmap, oloc->pool); in ceph_object_locator_to_pg()
2512 static void remove_nonexistent_osds(struct ceph_osdmap *osdmap, in remove_nonexistent_osds() argument
2523 if (!ceph_osd_exists(osdmap, set->osds[i])) { in remove_nonexistent_osds()
2534 if (!ceph_osd_exists(osdmap, set->osds[i])) in remove_nonexistent_osds()
2546 static void pg_to_raw_osds(struct ceph_osdmap *osdmap, in pg_to_raw_osds() argument
2560 ruleno = crush_find_rule(osdmap->crush, pi->crush_ruleset, pi->type, in pg_to_raw_osds()
2575 len = do_crush(osdmap, ruleno, pps, raw->osds, pi->size, in pg_to_raw_osds()
2576 osdmap->osd_weight, osdmap->max_osd, pi->id); in pg_to_raw_osds()
2585 remove_nonexistent_osds(osdmap, pi, raw); in pg_to_raw_osds()
2589 static void apply_upmap(struct ceph_osdmap *osdmap, in apply_upmap() argument
2596 pg = lookup_pg_mapping(&osdmap->pg_upmap, pgid); in apply_upmap()
2603 osd < osdmap->max_osd && in apply_upmap()
2604 osdmap->osd_weight[osd] == 0) { in apply_upmap()
2615 pg = lookup_pg_mapping(&osdmap->pg_upmap_items, pgid); in apply_upmap()
2638 to < osdmap->max_osd && in apply_upmap()
2639 osdmap->osd_weight[to] == 0)) { in apply_upmap()
2656 static void raw_to_up_osds(struct ceph_osdmap *osdmap, in raw_to_up_osds() argument
2670 if (ceph_osd_is_down(osdmap, set->osds[i])) { in raw_to_up_osds()
2683 if (ceph_osd_is_down(osdmap, set->osds[i])) in raw_to_up_osds()
2691 static void apply_primary_affinity(struct ceph_osdmap *osdmap, in apply_primary_affinity() argument
2703 if (!osdmap->osd_primary_affinity) in apply_primary_affinity()
2710 osdmap->osd_primary_affinity[osd] != in apply_primary_affinity()
2730 aff = osdmap->osd_primary_affinity[osd]; in apply_primary_affinity()
2767 static void get_temp_osds(struct ceph_osdmap *osdmap, in get_temp_osds() argument
2778 pg = lookup_pg_mapping(&osdmap->pg_temp, pgid); in get_temp_osds()
2781 if (ceph_osd_is_down(osdmap, pg->pg_temp.osds[i])) { in get_temp_osds()
2801 pg = lookup_pg_mapping(&osdmap->primary_temp, pgid); in get_temp_osds()
2813 void ceph_pg_to_up_acting_osds(struct ceph_osdmap *osdmap, in ceph_pg_to_up_acting_osds() argument
2825 pg_to_raw_osds(osdmap, pi, raw_pgid, up, &pps); in ceph_pg_to_up_acting_osds()
2826 apply_upmap(osdmap, &pgid, up); in ceph_pg_to_up_acting_osds()
2827 raw_to_up_osds(osdmap, pi, up); in ceph_pg_to_up_acting_osds()
2828 apply_primary_affinity(osdmap, pi, pps, up); in ceph_pg_to_up_acting_osds()
2829 get_temp_osds(osdmap, pi, &pgid, acting); in ceph_pg_to_up_acting_osds()
2839 bool ceph_pg_to_primary_shard(struct ceph_osdmap *osdmap, in ceph_pg_to_primary_shard() argument
2857 ceph_pg_to_up_acting_osds(osdmap, pi, &pgid, &up, &acting); in ceph_pg_to_primary_shard()
2872 int ceph_pg_to_acting_primary(struct ceph_osdmap *osdmap, in ceph_pg_to_acting_primary() argument
2878 pi = ceph_pg_pool_by_id(osdmap, raw_pgid->pool); in ceph_pg_to_acting_primary()
2882 ceph_pg_to_up_acting_osds(osdmap, pi, raw_pgid, &up, &acting); in ceph_pg_to_acting_primary()
3084 int ceph_get_crush_locality(struct ceph_osdmap *osdmap, int id, in ceph_get_crush_locality() argument
3096 id = get_immediate_parent(osdmap->crush, id, &type_id, &loc); in ceph_get_crush_locality()