/linux/net/ceph/ |
A D | osd_client.c | 2770 lreq->osdc = osdc; in linger_alloc() 2831 struct ceph_osd_client *osdc = lreq->osdc; in linger_registered() local 2843 struct ceph_osd_client *osdc = lreq->osdc; in linger_register() local 2855 struct ceph_osd_client *osdc = lreq->osdc; in linger_unregister() local 2924 struct ceph_osd_client *osdc = lreq->osdc; in lwork_queue() local 3126 struct ceph_osd_client *osdc = lreq->osdc; in send_linger_ping() local 3163 struct ceph_osd_client *osdc = lreq->osdc; in linger_submit() local 3185 struct ceph_osd_client *osdc = lreq->osdc; in cancel_linger_map_check() local 3216 struct ceph_osd_client *osdc = lreq->osdc; in linger_cancel() local 3228 struct ceph_osd_client *osdc = lreq->osdc; in check_linger_pool_dne() local [all …]
|
A D | debugfs.c | 58 struct ceph_osd_client *osdc = &client->osdc; in osdmap_show() local 59 struct ceph_osdmap *map = osdc->osdmap; in osdmap_show() 65 down_read(&osdc->lock); in osdmap_show() 67 osdc->epoch_barrier, map->flags); in osdmap_show() 134 up_read(&osdc->lock); in osdmap_show() 345 struct ceph_osd_client *osdc = &client->osdc; in osdc_show() local 348 down_read(&osdc->lock); in osdc_show() 350 atomic_read(&osdc->num_requests), in osdc_show() 351 atomic_read(&osdc->num_homeless)); in osdc_show() 374 up_read(&osdc->lock); in osdc_show() [all …]
|
A D | cls_lock_client.c | 25 int ceph_cls_lock(struct ceph_osd_client *osdc, in ceph_cls_lock() argument 75 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "lock", in ceph_cls_lock() 93 int ceph_cls_unlock(struct ceph_osd_client *osdc, in ceph_cls_unlock() argument 125 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "unlock", in ceph_cls_unlock() 144 int ceph_cls_break_lock(struct ceph_osd_client *osdc, in ceph_cls_break_lock() argument 180 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "break_lock", in ceph_cls_break_lock() 190 int ceph_cls_set_cookie(struct ceph_osd_client *osdc, in ceph_cls_set_cookie() argument 231 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "set_cookie", in ceph_cls_set_cookie() 334 int ceph_cls_lock_info(struct ceph_osd_client *osdc, in ceph_cls_lock_info() argument 371 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "get_info", in ceph_cls_lock_info()
|
A D | ceph_common.c | 765 err = ceph_osdc_init(&client->osdc, client); in ceph_create_client() 787 ceph_osdc_stop(&client->osdc); in ceph_destroy_client() 804 ceph_osdc_reopen_osds(&client->osdc); in ceph_reset_client_addr() 814 client->osdc.osdmap && client->osdc.osdmap->epoch; in have_mon_and_osd_map() 878 if (client->osdc.osdmap->epoch >= newest_epoch) in ceph_wait_for_latest_osdmap() 881 ceph_osdc_maybe_request_map(&client->osdc); in ceph_wait_for_latest_osdmap()
|
A D | mon_client.c | 1466 ceph_osdc_handle_map(&monc->client->osdc, msg); in mon_dispatch()
|
/linux/include/linux/ceph/ |
A D | osd_client.h | 253 struct ceph_osd_client *osdc; member 380 return osdc->osdmap->flags & flag; in ceph_osdmap_flag() 386 extern int ceph_osdc_init(struct ceph_osd_client *osdc, 388 extern void ceph_osdc_stop(struct ceph_osd_client *osdc); 513 extern void ceph_osdc_sync(struct ceph_osd_client *osdc); 518 int ceph_osdc_call(struct ceph_osd_client *osdc, 528 ceph_osdc_watch(struct ceph_osd_client *osdc, 534 int ceph_osdc_unwatch(struct ceph_osd_client *osdc, 537 int ceph_osdc_notify_ack(struct ceph_osd_client *osdc, 544 int ceph_osdc_notify(struct ceph_osd_client *osdc, [all …]
|
A D | cls_lock_client.h | 27 int ceph_cls_lock(struct ceph_osd_client *osdc, 32 int ceph_cls_unlock(struct ceph_osd_client *osdc, 36 int ceph_cls_break_lock(struct ceph_osd_client *osdc, 41 int ceph_cls_set_cookie(struct ceph_osd_client *osdc, 49 int ceph_cls_lock_info(struct ceph_osd_client *osdc,
|
A D | libceph.h | 143 struct ceph_osd_client osdc; member
|
/linux/fs/ceph/ |
A D | ioctl.c | 184 struct ceph_osd_client *osdc = in ceph_ioctl_get_dataloc() local 185 &ceph_sb_to_client(inode->i_sb)->client->osdc; in ceph_ioctl_get_dataloc() 197 down_read(&osdc->lock); in ceph_ioctl_get_dataloc() 215 r = ceph_object_locator_to_pg(osdc->osdmap, &oid, &oloc, &pgid); in ceph_ioctl_get_dataloc() 219 up_read(&osdc->lock); 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() 232 up_read(&osdc->lock); in ceph_ioctl_get_dataloc()
|
A D | addr.c | 494 struct ceph_osd_client *osdc = &fsc->client->osdc; in writepage_nounlock() local 551 err = ceph_osdc_start_request(osdc, req, true); in writepage_nounlock() 553 err = ceph_osdc_wait_request(osdc, req); in writepage_nounlock() 956 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_writepages_start() 963 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_writepages_start() 1667 err = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_uninline_data() 1709 err = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_uninline_data() 1826 rd_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL, in __ceph_pool_perm_get() 1844 wr_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL, in __ceph_pool_perm_get() 1875 err = ceph_osdc_wait_request(&fsc->client->osdc, rd_req); in __ceph_pool_perm_get() [all …]
|
A D | file.c | 858 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_read() local 890 req = ceph_osdc_new_request(osdc, &ci->i_layout, in ceph_sync_read() 915 ret = ceph_osdc_wait_request(osdc, req); in ceph_sync_read() 1691 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_write_iter() local 1747 down_read(&osdc->lock); in ceph_write_iter() 1748 map_flags = osdc->osdmap->flags; in ceph_write_iter() 1750 up_read(&osdc->lock); in ceph_write_iter() 2281 struct ceph_osd_client *osdc; in ceph_do_objects_copy() local 2293 osdc = &fsc->client->osdc; in ceph_do_objects_copy() 2317 ceph_osdc_start_request(osdc, req, false); in ceph_do_objects_copy() [all …]
|
A D | xattr.c | 61 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_vxattrcb_layout() local 73 down_read(&osdc->lock); in ceph_vxattrcb_layout() 74 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout() 109 up_read(&osdc->lock); in ceph_vxattrcb_layout() 165 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_vxattrcb_layout_pool() local 169 down_read(&osdc->lock); in ceph_vxattrcb_layout_pool() 170 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout_pool() 178 up_read(&osdc->lock); in ceph_vxattrcb_layout_pool() 1051 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_setxattr() local 1091 cpu_to_le32(osdc->osdmap->epoch); in ceph_sync_setxattr()
|
A D | super.c | 125 ceph_osdc_sync(&fsc->client->osdc); in ceph_sync_fs() 837 ceph_osdc_abort_requests(&fsc->client->osdc, -EIO); in __ceph_umount_begin() 1265 ceph_osdc_clear_abort_err(&fsc->client->osdc); in ceph_force_reconnect()
|
A D | caps.c | 1231 struct ceph_osd_client *osdc = &arg->session->s_mdsc->fsc->client->osdc; in encode_cap_msg() local 1288 ceph_encode_32(&p, READ_ONCE(osdc->epoch_barrier)); in encode_cap_msg() 4089 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_handle_caps() local 4093 ceph_osdc_update_epoch_barrier(osdc, epoch_barrier); in ceph_handle_caps()
|
A D | mds_client.c | 1995 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_send_cap_releases() local 2001 down_read(&osdc->lock); in ceph_send_cap_releases() 2002 barrier = cpu_to_le32(osdc->epoch_barrier); in ceph_send_cap_releases() 2003 up_read(&osdc->lock); in ceph_send_cap_releases()
|
/linux/drivers/block/ |
A D | rbd.c | 1413 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in __rbd_obj_add_osd_request() local 1708 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in rbd_object_map_lock() local 1766 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in rbd_object_map_unlock() local 1805 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in __rbd_object_map_load() local 2039 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in rbd_object_map_update() local 3647 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in rbd_lock() local 3670 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in rbd_unlock() local 3693 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in __rbd_notify_op_lock() local 3835 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in get_lock_owner_info() local 3882 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in find_watcher() local [all …]
|