osdmap 6229 drivers/block/rbd.c pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, spec->pool_id); osdmap 7077 drivers/block/rbd.c rc = ceph_pg_poolid_by_name(rbdc->client->osdc.osdmap, spec->pool_name); osdmap 1488 fs/ceph/file.c map_flags = osdc->osdmap->flags; osdmap 1489 fs/ceph/file.c pool_flags = ceph_pg_pool_flags(osdc->osdmap, ci->i_layout.pool_id); osdmap 215 fs/ceph/ioctl.c r = ceph_object_locator_to_pg(osdc->osdmap, &oid, &oloc, &pgid); osdmap 223 fs/ceph/ioctl.c dl.osd = ceph_pg_to_acting_primary(osdc->osdmap, &pgid); osdmap 226 fs/ceph/ioctl.c ceph_osd_addr(osdc->osdmap, dl.osd); osdmap 73 fs/ceph/xattr.c pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); osdmap 168 fs/ceph/xattr.c pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); osdmap 342 include/linux/ceph/osd_client.h struct ceph_osdmap *osdmap; /* current map */ osdmap 375 include/linux/ceph/osd_client.h return osdc->osdmap->flags & flag; osdmap 288 include/linux/ceph/osdmap.h int ceph_object_locator_to_pg(struct ceph_osdmap *osdmap, osdmap 293 include/linux/ceph/osdmap.h void ceph_pg_to_up_acting_osds(struct ceph_osdmap *osdmap, osdmap 298 include/linux/ceph/osdmap.h bool ceph_pg_to_primary_shard(struct ceph_osdmap *osdmap, osdmap 302 include/linux/ceph/osdmap.h int ceph_pg_to_acting_primary(struct ceph_osdmap *osdmap, osdmap 728 net/ceph/ceph_common.c client->osdc.osdmap && client->osdc.osdmap->epoch; osdmap 792 net/ceph/ceph_common.c if (client->osdc.osdmap->epoch >= newest_epoch) osdmap 59 net/ceph/debugfs.c struct ceph_osdmap *map = osdc->osdmap; osdmap 1359 net/ceph/osd_client.c peer_addr = &osd->o_osdc->osdmap->osd_addr[osd->o_osd]; osdmap 1404 net/ceph/osd_client.c &osdc->osdmap->osd_addr[osd->o_osd]); osdmap 1459 net/ceph/osd_client.c for (n = rb_first(&osdc->osdmap->pg_pools); n; n = rb_next(n)) { osdmap 1474 net/ceph/osd_client.c pi = ceph_pg_pool_by_id(osdc->osdmap, pool_id); osdmap 1497 net/ceph/osd_client.c (osdc->osdmap->epoch < osdc->epoch_barrier); osdmap 1522 net/ceph/osd_client.c t->epoch = osdc->osdmap->epoch; osdmap 1523 net/ceph/osd_client.c pi = ceph_pg_pool_by_id(osdc->osdmap, t->base_oloc.pool); osdmap 1530 net/ceph/osd_client.c if (osdc->osdmap->epoch == pi->last_force_request_resend) { osdmap 1548 net/ceph/osd_client.c pi = ceph_pg_pool_by_id(osdc->osdmap, t->target_oloc.pool); osdmap 1560 net/ceph/osd_client.c ceph_pg_to_up_acting_osds(osdc->osdmap, pi, &pgid, &up, &acting); osdmap 1590 net/ceph/osd_client.c ceph_pg_to_primary_shard(osdc->osdmap, pi, &pgid, &t->spgid); osdmap 2061 net/ceph/osd_client.c ceph_encode_32(&p, req->r_osdc->osdmap->epoch); osdmap 2259 net/ceph/osd_client.c WARN_ON(!osdc->osdmap->epoch); osdmap 2271 net/ceph/osd_client.c osdc->osdmap->epoch + 1, continuous)) osdmap 2304 net/ceph/osd_client.c } else if (osdc->osdmap->epoch < osdc->epoch_barrier) { osdmap 2305 net/ceph/osd_client.c dout("req %p epoch %u barrier %u\n", req, osdc->osdmap->epoch, osdmap 2510 net/ceph/osd_client.c if (eb > osdc->osdmap->epoch) osdmap 2544 net/ceph/osd_client.c update_epoch_barrier(osdc, osdc->osdmap->epoch); osdmap 2571 net/ceph/osd_client.c struct ceph_osdmap *map = osdc->osdmap; osdmap 3168 net/ceph/osd_client.c struct ceph_osdmap *map = osdc->osdmap; osdmap 3708 net/ceph/osd_client.c for (n = rb_first(&osdc->osdmap->pg_pools); n; n = rb_next(n)) { osdmap 3720 net/ceph/osd_client.c pi = ceph_pg_pool_by_id(osdc->osdmap, pool_id); osdmap 3843 net/ceph/osd_client.c newmap = osdmap_apply_incremental(&p, end, osdc->osdmap); osdmap 3849 net/ceph/osd_client.c if (newmap != osdc->osdmap) { osdmap 3860 net/ceph/osd_client.c old_pi = ceph_pg_pool_by_id(osdc->osdmap, pi->id); osdmap 3867 net/ceph/osd_client.c if (osdc->osdmap->epoch && osdmap 3868 net/ceph/osd_client.c osdc->osdmap->epoch + 1 < newmap->epoch) { osdmap 3873 net/ceph/osd_client.c ceph_osdmap_destroy(osdc->osdmap); osdmap 3874 net/ceph/osd_client.c osdc->osdmap = newmap; osdmap 3888 net/ceph/osd_client.c if (!ceph_osd_is_up(osdc->osdmap, osd->o_osd) || osdmap 3890 net/ceph/osd_client.c ceph_osd_addr(osdc->osdmap, osd->o_osd), osdmap 3913 net/ceph/osd_client.c if (req->r_t.epoch < osdc->osdmap->epoch) { osdmap 3969 net/ceph/osd_client.c dout("%s have %u\n", __func__, osdc->osdmap->epoch); osdmap 3991 net/ceph/osd_client.c if (osdc->osdmap->epoch && osdmap 3992 net/ceph/osd_client.c osdc->osdmap->epoch + 1 == epoch) { osdmap 4021 net/ceph/osd_client.c } else if (osdc->osdmap->epoch >= epoch) { osdmap 4024 net/ceph/osd_client.c osdc->osdmap->epoch); osdmap 4047 net/ceph/osd_client.c osdc->osdmap->epoch < osdc->epoch_barrier) osdmap 4054 net/ceph/osd_client.c osdc->osdmap->epoch); osdmap 5154 net/ceph/osd_client.c osdc->osdmap = ceph_osdmap_alloc(); osdmap 5155 net/ceph/osd_client.c if (!osdc->osdmap) osdmap 5198 net/ceph/osd_client.c ceph_osdmap_destroy(osdc->osdmap); osdmap 5227 net/ceph/osd_client.c ceph_osdmap_destroy(osdc->osdmap); osdmap 2213 net/ceph/osdmap.c int ceph_object_locator_to_pg(struct ceph_osdmap *osdmap, osdmap 2220 net/ceph/osdmap.c pi = ceph_pg_pool_by_id(osdmap, oloc->pool); osdmap 2301 net/ceph/osdmap.c static void remove_nonexistent_osds(struct ceph_osdmap *osdmap, osdmap 2312 net/ceph/osdmap.c if (!ceph_osd_exists(osdmap, set->osds[i])) { osdmap 2323 net/ceph/osdmap.c if (!ceph_osd_exists(osdmap, set->osds[i])) osdmap 2335 net/ceph/osdmap.c static void pg_to_raw_osds(struct ceph_osdmap *osdmap, osdmap 2349 net/ceph/osdmap.c ruleno = crush_find_rule(osdmap->crush, pi->crush_ruleset, pi->type, osdmap 2364 net/ceph/osdmap.c len = do_crush(osdmap, ruleno, pps, raw->osds, pi->size, osdmap 2365 net/ceph/osdmap.c osdmap->osd_weight, osdmap->max_osd, pi->id); osdmap 2374 net/ceph/osdmap.c remove_nonexistent_osds(osdmap, pi, raw); osdmap 2378 net/ceph/osdmap.c static void apply_upmap(struct ceph_osdmap *osdmap, osdmap 2385 net/ceph/osdmap.c pg = lookup_pg_mapping(&osdmap->pg_upmap, pgid); osdmap 2392 net/ceph/osdmap.c osd < osdmap->max_osd && osdmap 2393 net/ceph/osdmap.c osdmap->osd_weight[osd] == 0) { osdmap 2404 net/ceph/osdmap.c pg = lookup_pg_mapping(&osdmap->pg_upmap_items, pgid); osdmap 2427 net/ceph/osdmap.c to < osdmap->max_osd && osdmap 2428 net/ceph/osdmap.c osdmap->osd_weight[to] == 0)) { osdmap 2445 net/ceph/osdmap.c static void raw_to_up_osds(struct ceph_osdmap *osdmap, osdmap 2459 net/ceph/osdmap.c if (ceph_osd_is_down(osdmap, set->osds[i])) { osdmap 2472 net/ceph/osdmap.c if (ceph_osd_is_down(osdmap, set->osds[i])) osdmap 2480 net/ceph/osdmap.c static void apply_primary_affinity(struct ceph_osdmap *osdmap, osdmap 2492 net/ceph/osdmap.c if (!osdmap->osd_primary_affinity) osdmap 2499 net/ceph/osdmap.c osdmap->osd_primary_affinity[osd] != osdmap 2519 net/ceph/osdmap.c aff = osdmap->osd_primary_affinity[osd]; osdmap 2556 net/ceph/osdmap.c static void get_temp_osds(struct ceph_osdmap *osdmap, osdmap 2567 net/ceph/osdmap.c pg = lookup_pg_mapping(&osdmap->pg_temp, pgid); osdmap 2570 net/ceph/osdmap.c if (ceph_osd_is_down(osdmap, pg->pg_temp.osds[i])) { osdmap 2590 net/ceph/osdmap.c pg = lookup_pg_mapping(&osdmap->primary_temp, pgid); osdmap 2602 net/ceph/osdmap.c void ceph_pg_to_up_acting_osds(struct ceph_osdmap *osdmap, osdmap 2614 net/ceph/osdmap.c pg_to_raw_osds(osdmap, pi, raw_pgid, up, &pps); osdmap 2615 net/ceph/osdmap.c apply_upmap(osdmap, &pgid, up); osdmap 2616 net/ceph/osdmap.c raw_to_up_osds(osdmap, pi, up); osdmap 2617 net/ceph/osdmap.c apply_primary_affinity(osdmap, pi, pps, up); osdmap 2618 net/ceph/osdmap.c get_temp_osds(osdmap, pi, &pgid, acting); osdmap 2628 net/ceph/osdmap.c bool ceph_pg_to_primary_shard(struct ceph_osdmap *osdmap, osdmap 2646 net/ceph/osdmap.c ceph_pg_to_up_acting_osds(osdmap, pi, &pgid, &up, &acting); osdmap 2661 net/ceph/osdmap.c int ceph_pg_to_acting_primary(struct ceph_osdmap *osdmap, osdmap 2667 net/ceph/osdmap.c pi = ceph_pg_pool_by_id(osdmap, raw_pgid->pool); osdmap 2671 net/ceph/osdmap.c ceph_pg_to_up_acting_osds(osdmap, pi, raw_pgid, &up, &acting);