| /kernel/linux/linux-5.10/net/ceph/ |
| H A D | osdmap.c | 9 #include <linux/ceph/osdmap.h>
1312 /* old osdmap enconding */ in get_osdmap_client_data_v()
1776 dout("full osdmap epoch %d max_osd %d\n", map->epoch, map->max_osd); in osdmap_decode()
1782 pr_err("corrupt full osdmap (%d) epoch %d off %d (%p of %p-%p)\n", in osdmap_decode()
1784 print_hex_dump(KERN_DEBUG, "osdmap: ", in osdmap_decode()
2069 dout("inc osdmap epoch %d max_osd %d\n", map->epoch, map->max_osd); in osdmap_apply_incremental()
2075 pr_err("corrupt inc osdmap (%d) epoch %d off %d (%p of %p-%p)\n", in osdmap_apply_incremental()
2077 print_hex_dump(KERN_DEBUG, "osdmap: ", in osdmap_apply_incremental()
2392 int ceph_object_locator_to_pg(struct ceph_osdmap *osdmap, in ceph_object_locator_to_pg() argument
2399 pi = ceph_pg_pool_by_id(osdmap, olo in ceph_object_locator_to_pg()
2480 remove_nonexistent_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, struct ceph_osds *set) remove_nonexistent_osds() argument
2514 pg_to_raw_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, const struct ceph_pg *raw_pgid, struct ceph_osds *raw, u32 *ppps) pg_to_raw_osds() argument
2557 apply_upmap(struct ceph_osdmap *osdmap, const struct ceph_pg *pgid, struct ceph_osds *raw) apply_upmap() argument
2624 raw_to_up_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, struct ceph_osds *set) raw_to_up_osds() argument
2659 apply_primary_affinity(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, u32 pps, struct ceph_osds *up) apply_primary_affinity() argument
2735 get_temp_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, const struct ceph_pg *pgid, struct ceph_osds *temp) get_temp_osds() argument
2781 ceph_pg_to_up_acting_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, const struct ceph_pg *raw_pgid, struct ceph_osds *up, struct ceph_osds *acting) ceph_pg_to_up_acting_osds() argument
2807 ceph_pg_to_primary_shard(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, const struct ceph_pg *raw_pgid, struct ceph_spg *spgid) ceph_pg_to_primary_shard() argument
2840 ceph_pg_to_acting_primary(struct ceph_osdmap *osdmap, const struct ceph_pg *raw_pgid) ceph_pg_to_acting_primary() argument
3052 ceph_get_crush_locality(struct ceph_osdmap *osdmap, int id, struct rb_root *locs) ceph_get_crush_locality() argument
[all...] |
| H A D | Makefile | 10 osd_client.o osdmap.o crush/crush.o crush/mapper.o crush/hash.o \
|
| H A D | osd_client.c | 1339 peer_addr = &osd->o_osdc->osdmap->osd_addr[osd->o_osd]; in reopen_osd()
1384 &osdc->osdmap->osd_addr[osd->o_osd]); in lookup_create_osd()
1439 for (n = rb_first(&osdc->osdmap->pg_pools); n; n = rb_next(n)) { in have_pool_full()
1454 pi = ceph_pg_pool_by_id(osdc->osdmap, pool_id); in pool_full()
1463 * based on the current osdmap and osd_client settings.
1477 (osdc->osdmap->epoch < osdc->epoch_barrier); in target_should_be_paused()
1502 locality = ceph_get_crush_locality(osdc->osdmap, in pick_closest_replica()
1543 t->epoch = osdc->osdmap->epoch; in calc_target()
1544 pi = ceph_pg_pool_by_id(osdc->osdmap, t->base_oloc.pool); in calc_target()
1551 if (osdc->osdmap in calc_target()
[all...] |
| H A D | ceph_common.c | 758 client->osdc.osdmap && client->osdc.osdmap->epoch; in have_mon_and_osd_map()
818 ret = ceph_monc_get_version(&client->monc, "osdmap", &newest_epoch); in ceph_wait_for_latest_osdmap()
822 if (client->osdc.osdmap->epoch >= newest_epoch) in ceph_wait_for_latest_osdmap()
|
| H A D | debugfs.c | 22 * .../osdmap - current osdmap
59 struct ceph_osdmap *map = osdc->osdmap; in osdmap_show()
392 DEFINE_SHOW_ATTRIBUTE(osdmap); variable
436 client->debugfs_osdmap = debugfs_create_file("osdmap", in ceph_debugfs_client_init()
|
| /kernel/linux/linux-6.6/net/ceph/ |
| H A D | osdmap.c | 9 #include <linux/ceph/osdmap.h>
1328 /* old osdmap encoding */ in get_osdmap_client_data_v()
1800 dout("full osdmap epoch %d max_osd %d\n", map->epoch, map->max_osd); in osdmap_decode()
1806 pr_err("corrupt full osdmap (%d) epoch %d off %d (%p of %p-%p)\n", in osdmap_decode()
1808 print_hex_dump(KERN_DEBUG, "osdmap: ", in osdmap_decode()
2104 dout("inc osdmap epoch %d max_osd %d\n", map->epoch, map->max_osd); in osdmap_apply_incremental()
2110 pr_err("corrupt inc osdmap (%d) epoch %d off %d (%p of %p-%p)\n", in osdmap_apply_incremental()
2112 print_hex_dump(KERN_DEBUG, "osdmap: ", in osdmap_apply_incremental()
2427 int ceph_object_locator_to_pg(struct ceph_osdmap *osdmap, in ceph_object_locator_to_pg() argument
2434 pi = ceph_pg_pool_by_id(osdmap, olo in ceph_object_locator_to_pg()
2515 remove_nonexistent_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, struct ceph_osds *set) remove_nonexistent_osds() argument
2549 pg_to_raw_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, const struct ceph_pg *raw_pgid, struct ceph_osds *raw, u32 *ppps) pg_to_raw_osds() argument
2592 apply_upmap(struct ceph_osdmap *osdmap, const struct ceph_pg *pgid, struct ceph_osds *raw) apply_upmap() argument
2659 raw_to_up_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, struct ceph_osds *set) raw_to_up_osds() argument
2694 apply_primary_affinity(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, u32 pps, struct ceph_osds *up) apply_primary_affinity() argument
2770 get_temp_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, const struct ceph_pg *pgid, struct ceph_osds *temp) get_temp_osds() argument
2816 ceph_pg_to_up_acting_osds(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, const struct ceph_pg *raw_pgid, struct ceph_osds *up, struct ceph_osds *acting) ceph_pg_to_up_acting_osds() argument
2842 ceph_pg_to_primary_shard(struct ceph_osdmap *osdmap, struct ceph_pg_pool_info *pi, const struct ceph_pg *raw_pgid, struct ceph_spg *spgid) ceph_pg_to_primary_shard() argument
2875 ceph_pg_to_acting_primary(struct ceph_osdmap *osdmap, const struct ceph_pg *raw_pgid) ceph_pg_to_acting_primary() argument
3087 ceph_get_crush_locality(struct ceph_osdmap *osdmap, int id, struct rb_root *locs) ceph_get_crush_locality() argument
[all...] |
| H A D | Makefile | 10 osd_client.o osdmap.o crush/crush.o crush/mapper.o crush/hash.o \
|
| H A D | osd_client.c | 1415 peer_addr = &osd->o_osdc->osdmap->osd_addr[osd->o_osd]; in reopen_osd()
1460 &osdc->osdmap->osd_addr[osd->o_osd]); in lookup_create_osd()
1519 for (n = rb_first(&osdc->osdmap->pg_pools); n; n = rb_next(n)) { in have_pool_full()
1534 pi = ceph_pg_pool_by_id(osdc->osdmap, pool_id); in pool_full()
1543 * based on the current osdmap and osd_client settings.
1557 (osdc->osdmap->epoch < osdc->epoch_barrier); in target_should_be_paused()
1582 locality = ceph_get_crush_locality(osdc->osdmap, in pick_closest_replica()
1623 t->epoch = osdc->osdmap->epoch; in calc_target()
1624 pi = ceph_pg_pool_by_id(osdc->osdmap, t->base_oloc.pool); in calc_target()
1631 if (osdc->osdmap in calc_target()
[all...] |
| H A D | ceph_common.c | 794 client->osdc.osdmap && client->osdc.osdmap->epoch; in have_mon_and_osd_map()
854 ret = ceph_monc_get_version(&client->monc, "osdmap", &newest_epoch); in ceph_wait_for_latest_osdmap()
858 if (client->osdc.osdmap->epoch >= newest_epoch) in ceph_wait_for_latest_osdmap()
|
| H A D | debugfs.c | 22 * .../osdmap - current osdmap
59 struct ceph_osdmap *map = osdc->osdmap; in osdmap_show()
392 DEFINE_SHOW_ATTRIBUTE(osdmap); variable
436 client->debugfs_osdmap = debugfs_create_file("osdmap", in ceph_debugfs_client_init()
|
| /kernel/linux/linux-5.10/include/linux/ceph/ |
| H A D | osdmap.h | 298 int ceph_object_locator_to_pg(struct ceph_osdmap *osdmap,
303 void ceph_pg_to_up_acting_osds(struct ceph_osdmap *osdmap,
308 bool ceph_pg_to_primary_shard(struct ceph_osdmap *osdmap,
312 int ceph_pg_to_acting_primary(struct ceph_osdmap *osdmap,
330 int ceph_get_crush_locality(struct ceph_osdmap *osdmap, int id,
|
| H A D | osd_client.h | 14 #include <linux/ceph/osdmap.h>
350 struct ceph_osdmap *osdmap; /* current map */ member
383 return osdc->osdmap->flags & flag; in ceph_osdmap_flag()
|
| /kernel/linux/linux-6.6/include/linux/ceph/ |
| H A D | osdmap.h | 298 int ceph_object_locator_to_pg(struct ceph_osdmap *osdmap,
303 void ceph_pg_to_up_acting_osds(struct ceph_osdmap *osdmap,
308 bool ceph_pg_to_primary_shard(struct ceph_osdmap *osdmap,
312 int ceph_pg_to_acting_primary(struct ceph_osdmap *osdmap,
330 int ceph_get_crush_locality(struct ceph_osdmap *osdmap, int id,
|
| H A D | osd_client.h | 14 #include <linux/ceph/osdmap.h>
408 struct ceph_osdmap *osdmap; /* current map */ member
441 return osdc->osdmap->flags & flag; in ceph_osdmap_flag()
|
| /kernel/linux/linux-5.10/fs/ceph/ |
| H A D | ioctl.c | 215 r = ceph_object_locator_to_pg(osdc->osdmap, &oid, &oloc, &pgid); in ceph_ioctl_get_dataloc()
223 dl.osd = ceph_pg_to_acting_primary(osdc->osdmap, &pgid); in ceph_ioctl_get_dataloc()
226 ceph_osd_addr(osdc->osdmap, dl.osd); in ceph_ioctl_get_dataloc()
|
| H A D | xattr.c | 73 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout()
169 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout_pool()
|
| H A D | file.c | 1761 map_flags = osdc->osdmap->flags; in ceph_write_iter()
1762 pool_flags = ceph_pg_pool_flags(osdc->osdmap, ci->i_layout.pool_id); in ceph_write_iter()
|
| /kernel/linux/linux-6.6/fs/ceph/ |
| H A D | ioctl.c | 216 r = ceph_object_locator_to_pg(osdc->osdmap, &oid, &oloc, &pgid); in ceph_ioctl_get_dataloc()
224 dl.osd = ceph_pg_to_acting_primary(osdc->osdmap, &pgid); in ceph_ioctl_get_dataloc()
227 ceph_osd_addr(osdc->osdmap, dl.osd); in ceph_ioctl_get_dataloc()
|
| H A D | xattr.c | 74 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout()
170 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout_pool()
1141 cpu_to_le32(osdc->osdmap->epoch); in ceph_sync_setxattr()
|
| H A D | file.c | 2289 map_flags = osdc->osdmap->flags; in ceph_write_iter()
2290 pool_flags = ceph_pg_pool_flags(osdc->osdmap, ci->i_layout.pool_id); in ceph_write_iter()
|
| /kernel/linux/linux-5.10/drivers/block/ |
| H A D | rbd.c | 969 rbd_warn(NULL, "failed to get latest osdmap: %d", ret); in rbd_get_client()
6093 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, spec->pool_id); in rbd_spec_fill_names()
7191 rc = ceph_pg_poolid_by_name(rbdc->client->osdc.osdmap, spec->pool_name); in do_rbd_add()
|
| /kernel/linux/linux-6.6/drivers/block/ |
| H A D | rbd.c | 917 rbd_warn(NULL, "failed to get latest osdmap: %d", ret); in rbd_get_client()
6020 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, spec->pool_id); in rbd_spec_fill_names()
7117 rc = ceph_pg_poolid_by_name(rbdc->client->osdc.osdmap, spec->pool_name); in do_rbd_add()
|