| /linux-4.19.296/include/linux/ceph/ |
| D | osd_client.h | 241 struct ceph_osd_client *osdc; member
367 static inline bool ceph_osdmap_flag(struct ceph_osd_client *osdc, int flag) in ceph_osdmap_flag() argument
369 return osdc->osdmap->flags & flag; in ceph_osdmap_flag()
375 extern int ceph_osdc_init(struct ceph_osd_client *osdc,
377 extern void ceph_osdc_stop(struct ceph_osd_client *osdc);
379 extern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc,
381 extern void ceph_osdc_handle_map(struct ceph_osd_client *osdc,
383 void ceph_osdc_update_epoch_barrier(struct ceph_osd_client *osdc, u32 eb);
384 void ceph_osdc_abort_requests(struct ceph_osd_client *osdc, int err);
458 extern struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,
[all …]
|
| 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,
|
| D | libceph.h | 135 struct ceph_osd_client osdc; member
|
| /linux-4.19.296/fs/ceph/ |
| 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()
|
| D | addr.c | 183 struct ceph_osd_client *osdc = in ceph_do_readpage() local
184 &ceph_inode_to_client(inode)->client->osdc; in ceph_do_readpage()
213 err = ceph_osdc_readpages(osdc, ceph_vino(inode), &ci->i_layout, in ceph_do_readpage()
298 struct ceph_osd_client *osdc = in start_read() local
299 &ceph_inode_to_client(inode)->client->osdc; in start_read()
353 req = ceph_osdc_new_request(osdc, &ci->i_layout, vino, off, &len, in start_read()
398 ret = ceph_osdc_start_request(osdc, req, false); in start_read()
619 err = ceph_osdc_writepages(&fsc->client->osdc, ceph_vino(inode), in writepage_nounlock()
1031 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_writepages_start()
1038 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_writepages_start()
[all …]
|
| D | file.c | 589 ret = ceph_osdc_readpages(&fsc->client->osdc, ceph_vino(inode), in striped_read()
968 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_direct_read_write()
1040 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_direct_read_write()
1163 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_sync_write()
1208 ret = ceph_osdc_start_request(&fsc->client->osdc, req, false); in ceph_sync_write()
1210 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_sync_write()
1391 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_write_iter() local
1451 down_read(&osdc->lock); in ceph_write_iter()
1452 map_flags = osdc->osdmap->flags; in ceph_write_iter()
1453 pool_flags = ceph_pg_pool_flags(osdc->osdmap, ci->i_layout.pool_id); in ceph_write_iter()
[all …]
|
| D | xattr.c | 75 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_vxattrcb_layout() local
87 down_read(&osdc->lock); in ceph_vxattrcb_layout()
88 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout()
123 up_read(&osdc->lock); in ceph_vxattrcb_layout()
151 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_vxattrcb_layout_pool() local
155 down_read(&osdc->lock); in ceph_vxattrcb_layout_pool()
156 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout_pool()
161 up_read(&osdc->lock); in ceph_vxattrcb_layout_pool()
|
| D | super.c | 120 ceph_osdc_sync(&fsc->client->osdc); in ceph_sync_fs()
665 fsc->client->osdc.abort_on_full = true; in create_fs_client()
851 ceph_osdc_abort_requests(&fsc->client->osdc, -EIO); in ceph_umount_begin()
|
| D | caps.c | 1145 struct ceph_osd_client *osdc = &arg->session->s_mdsc->fsc->client->osdc; in send_cap_msg() local
1212 ceph_encode_32(&p, READ_ONCE(osdc->epoch_barrier)); in send_cap_msg()
3843 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_handle_caps() local
3847 ceph_osdc_update_epoch_barrier(osdc, epoch_barrier); in ceph_handle_caps()
|
| D | mds_client.c | 1686 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_send_cap_releases() local
1692 down_read(&osdc->lock); in ceph_send_cap_releases()
1693 barrier = cpu_to_le32(osdc->epoch_barrier); in ceph_send_cap_releases()
1694 up_read(&osdc->lock); in ceph_send_cap_releases()
|