| /linux/net/ceph/ |
| H A D | osd_client.c | 70 static inline void verify_osdc_locked(struct ceph_osd_client *osdc) in verify_osdc_locked() argument
72 WARN_ON(!rwsem_is_locked(&osdc->lock)); in verify_osdc_locked()
74 static inline void verify_osdc_wrlocked(struct ceph_osd_client *osdc) in verify_osdc_wrlocked() argument
76 WARN_ON(!rwsem_is_wrlocked(&osdc->lock)); in verify_osdc_wrlocked()
80 struct ceph_osd_client *osdc = osd->o_osdc; in verify_osd_locked() local
83 rwsem_is_locked(&osdc->lock)) && in verify_osd_locked()
84 !rwsem_is_wrlocked(&osdc->lock)); in verify_osd_locked()
91 static inline void verify_osdc_locked(struct ceph_osd_client *osdc) { } in verify_osdc_locked() argument
92 static inline void verify_osdc_wrlocked(struct ceph_osd_client *osdc) { } in verify_osdc_wrlocked() argument
545 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request() argument
[all …]
|
| H A D | debugfs.c | 62 struct ceph_osd_client *osdc = &client->osdc; in osdmap_show() local
66 down_read(&osdc->lock); in osdmap_show()
67 map = osdc->osdmap; in osdmap_show()
72 osdc->epoch_barrier, map->flags); in osdmap_show()
140 up_read(&osdc->lock); in osdmap_show()
351 struct ceph_osd_client *osdc = &client->osdc; in osdc_show() local
354 down_read(&osdc->lock); in osdc_show()
356 atomic_read(&osdc->num_requests), in osdc_show()
357 atomic_read(&osdc->num_homeless)); in osdc_show()
358 for (n = rb_first(&osdc->osds); n; n = rb_next(n)) { in osdc_show()
[all …]
|
| H 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()
343 int ceph_cls_lock_info(struct ceph_osd_client *osdc, in ceph_cls_lock_info() argument
380 ret = ceph_osdc_call(osdc, oid, oloc, "lock", "get_info", in ceph_cls_lock_info()
|
| H A D | ceph_common.c | 744 err = ceph_osdc_init(&client->osdc, client); in ceph_create_client()
768 ceph_osdc_stop(&client->osdc); in ceph_destroy_client()
783 ceph_osdc_reopen_osds(&client->osdc); in ceph_reset_client_addr()
809 down_read(&client->osdc.lock); in __ceph_open_session()
810 have_osdmap = client->osdc.osdmap && client->osdc.osdmap->epoch; in __ceph_open_session()
811 up_read(&client->osdc.lock); in __ceph_open_session()
867 if (client->osdc.osdmap->epoch >= newest_epoch) in ceph_wait_for_latest_osdmap()
870 ceph_osdc_maybe_request_map(&client->osdc); in ceph_wait_for_latest_osdmap()
|
| H A D | mon_client.c | 1477 ceph_osdc_handle_map(&monc->client->osdc, msg); in mon_dispatch()
|
| /linux/include/linux/ceph/ |
| H A D | osd_client.h | 311 struct ceph_osd_client *osdc; member
439 static inline bool ceph_osdmap_flag(struct ceph_osd_client *osdc, int flag) in ceph_osdmap_flag() argument
441 return osdc->osdmap->flags & flag; in ceph_osdmap_flag()
447 extern int ceph_osdc_init(struct ceph_osd_client *osdc,
449 extern void ceph_osdc_stop(struct ceph_osd_client *osdc);
450 extern void ceph_osdc_reopen_osds(struct ceph_osd_client *osdc);
452 extern void ceph_osdc_handle_map(struct ceph_osd_client *osdc,
454 void ceph_osdc_update_epoch_barrier(struct ceph_osd_client *osdc, u32 eb);
455 void ceph_osdc_abort_requests(struct ceph_osd_client *osdc, int err);
456 void ceph_osdc_clear_abort_err(struct ceph_osd_client *osdc);
[all …]
|
| H 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,
|
| H A D | libceph.h | 134 struct ceph_osd_client osdc; member
|
| /linux/fs/ceph/ |
| H A D | ioctl.c | 191 struct ceph_osd_client *osdc = in ceph_ioctl_get_dataloc() local
192 &ceph_sb_to_fs_client(inode->i_sb)->client->osdc; in ceph_ioctl_get_dataloc()
204 down_read(&osdc->lock); in ceph_ioctl_get_dataloc()
222 r = ceph_object_locator_to_pg(osdc->osdmap, &oid, &oloc, &pgid); in ceph_ioctl_get_dataloc()
226 up_read(&osdc->lock); in ceph_ioctl_get_dataloc()
230 dl.osd = ceph_pg_to_acting_primary(osdc->osdmap, &pgid); in ceph_ioctl_get_dataloc()
233 ceph_osd_addr(osdc->osdmap, dl.osd); in ceph_ioctl_get_dataloc()
239 up_read(&osdc->lock); in ceph_ioctl_get_dataloc()
|
| H A D | file.c | 1074 struct ceph_osd_client *osdc = &fsc->client->osdc; in __ceph_sync_read() local
1121 req = ceph_osdc_new_request(osdc, &ci->i_layout, in __ceph_sync_read()
1161 ceph_osdc_start_request(osdc, req); in __ceph_sync_read()
1162 ret = ceph_osdc_wait_request(osdc, req); in __ceph_sync_read()
1580 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_direct_read_write()
1660 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_direct_read_write()
1768 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_write() local
1860 req = ceph_osdc_new_request(osdc, &ci->i_layout, in ceph_sync_write()
1923 ceph_osdc_start_request(osdc, req); in ceph_sync_write()
1924 ret = ceph_osdc_wait_request(osdc, req); in ceph_sync_write()
[all …]
|
| H A D | xattr.c | 62 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_vxattrcb_layout() local
74 down_read(&osdc->lock); in ceph_vxattrcb_layout()
75 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout()
110 up_read(&osdc->lock); in ceph_vxattrcb_layout()
166 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_vxattrcb_layout_pool() local
170 down_read(&osdc->lock); in ceph_vxattrcb_layout_pool()
171 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout_pool()
179 up_read(&osdc->lock); in ceph_vxattrcb_layout_pool()
1115 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_setxattr() local
1155 cpu_to_le32(osdc->osdmap->epoch); in ceph_sync_setxattr()
|
| H A D | addr.c | 389 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, vino, in ceph_netfs_issue_read()
739 struct ceph_osd_client *osdc = &fsc->client->osdc; in write_folio_nounlock() local
789 req = ceph_osdc_new_request(osdc, &ci->i_layout, ceph_vino(inode), in write_folio_nounlock()
835 ceph_osdc_start_request(osdc, req); in write_folio_nounlock()
836 err = ceph_osdc_wait_request(osdc, req); in write_folio_nounlock()
1463 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_submit_write()
1470 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_submit_write()
1620 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_submit_write()
2297 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
2307 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_uninline_data()
[all …]
|
| H A D | super.c | 139 ceph_osdc_sync(&fsc->client->osdc); in ceph_sync_fs()
1029 ceph_osdc_abort_requests(&fsc->client->osdc, -EIO); in __ceph_umount_begin()
1640 ceph_osdc_clear_abort_err(&fsc->client->osdc); in ceph_force_reconnect()
|
| H A D | caps.c | 1280 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in encode_cap_msg() local
1346 ceph_encode_32(&p, READ_ONCE(osdc->epoch_barrier)); in encode_cap_msg()
4490 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_handle_caps() local
4494 ceph_osdc_update_epoch_barrier(osdc, epoch_barrier); in ceph_handle_caps()
|
| H A D | mds_client.c | 2509 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_send_cap_releases() local
2515 down_read(&osdc->lock); in ceph_send_cap_releases()
2516 barrier = cpu_to_le32(osdc->epoch_barrier); in ceph_send_cap_releases()
2517 up_read(&osdc->lock); in ceph_send_cap_releases()
|
| /linux/drivers/block/ |
| H A D | rbd.c | 1424 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in __rbd_obj_add_osd_request() local
1430 req = ceph_osdc_alloc_request(osdc, snapc, num_ops, false, GFP_NOIO); in __rbd_obj_add_osd_request()
1723 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in rbd_object_map_lock() local
1735 ret = ceph_cls_lock(osdc, &oid, &rbd_dev->header_oloc, RBD_LOCK_NAME, in rbd_object_map_lock()
1745 ret = ceph_cls_lock_info(osdc, &oid, &rbd_dev->header_oloc, in rbd_object_map_lock()
1763 ret = ceph_cls_break_lock(osdc, &oid, &rbd_dev->header_oloc, in rbd_object_map_lock()
1781 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in rbd_object_map_unlock() local
1787 ret = ceph_cls_unlock(osdc, &oid, &rbd_dev->header_oloc, RBD_LOCK_NAME, in rbd_object_map_unlock()
1820 struct ceph_osd_client *osdc = &rbd_dev->rbd_client->client->osdc; in __rbd_object_map_load() local
1844 ret = ceph_osdc_call(osdc, &oid, &rbd_dev->header_oloc, in __rbd_object_map_load()
[all …]
|