| /linux-4.4.14/net/ceph/ |
| D | osd_client.c | 29 static void __send_queued(struct ceph_osd_client *osdc);
30 static int __reset_osd(struct ceph_osd_client *osdc, struct ceph_osd *osd);
31 static void __register_request(struct ceph_osd_client *osdc,
33 static void __unregister_request(struct ceph_osd_client *osdc,
35 static void __unregister_linger_request(struct ceph_osd_client *osdc,
38 static void __send_request(struct ceph_osd_client *osdc,
362 struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc, in ceph_osdc_alloc_request() argument
386 req = mempool_alloc(osdc->req_mempool, gfp_flags); in ceph_osdc_alloc_request()
394 req->r_osdc = osdc; in ceph_osdc_alloc_request()
413 msg = ceph_msgpool_get(&osdc->msgpool_op_reply, 0); in ceph_osdc_alloc_request()
[all …]
|
| D | debugfs.c | 57 struct ceph_osdmap *map = client->osdc.osdmap; in osdmap_show()
144 struct ceph_osd_client *osdc = &client->osdc; in osdc_show() local
147 mutex_lock(&osdc->request_mutex); in osdc_show()
148 for (p = rb_first(&osdc->requests); p; p = rb_next(p)) { in osdc_show()
177 mutex_unlock(&osdc->request_mutex); in osdc_show()
236 client->osdc.debugfs_file = debugfs_create_file("osdc", in ceph_debugfs_client_init()
241 if (!client->osdc.debugfs_file) in ceph_debugfs_client_init()
281 debugfs_remove(client->osdc.debugfs_file); in ceph_debugfs_client_cleanup()
|
| D | ceph_common.c | 617 err = ceph_osdc_init(&client->osdc, client); in ceph_create_client()
639 ceph_osdc_stop(&client->osdc); in ceph_destroy_client()
658 client->osdc.osdmap && client->osdc.osdmap->epoch; in have_mon_and_osd_map()
|
| D | mon_client.c | 1024 ceph_osdc_handle_map(&monc->client->osdc, msg); in dispatch()
|
| /linux-4.4.14/include/linux/ceph/ |
| D | osd_client.h | 186 struct ceph_osd_client *osdc; member
242 extern int ceph_osdc_init(struct ceph_osd_client *osdc,
244 extern void ceph_osdc_stop(struct ceph_osd_client *osdc);
246 extern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc,
248 extern void ceph_osdc_handle_map(struct ceph_osd_client *osdc,
316 extern struct ceph_osd_request *ceph_osdc_alloc_request(struct ceph_osd_client *osdc,
337 extern void ceph_osdc_set_request_linger(struct ceph_osd_client *osdc,
343 extern int ceph_osdc_start_request(struct ceph_osd_client *osdc,
347 extern int ceph_osdc_wait_request(struct ceph_osd_client *osdc,
349 extern void ceph_osdc_sync(struct ceph_osd_client *osdc);
[all …]
|
| D | libceph.h | 131 struct ceph_osd_client osdc; member
|
| /linux-4.4.14/fs/ceph/ |
| D | ioctl.c | 183 struct ceph_osd_client *osdc = in ceph_ioctl_get_dataloc() local
184 &ceph_sb_to_client(inode->i_sb)->client->osdc; in ceph_ioctl_get_dataloc()
196 down_read(&osdc->map_sem); in ceph_ioctl_get_dataloc()
201 up_read(&osdc->map_sem); in ceph_ioctl_get_dataloc()
218 r = ceph_oloc_oid_to_pg(osdc->osdmap, &oloc, &oid, &pgid); in ceph_ioctl_get_dataloc()
220 up_read(&osdc->map_sem); in ceph_ioctl_get_dataloc()
224 dl.osd = ceph_calc_pg_primary(osdc->osdmap, pgid); in ceph_ioctl_get_dataloc()
227 ceph_osd_addr(osdc->osdmap, dl.osd); in ceph_ioctl_get_dataloc()
233 up_read(&osdc->map_sem); in ceph_ioctl_get_dataloc()
|
| D | addr.c | 196 struct ceph_osd_client *osdc = in readpage_nounlock() local
197 &ceph_inode_to_client(inode)->client->osdc; in readpage_nounlock()
226 err = ceph_osdc_readpages(osdc, ceph_vino(inode), &ci->i_layout, in readpage_nounlock()
313 struct ceph_osd_client *osdc = in start_read() local
314 &ceph_inode_to_client(inode)->client->osdc; in start_read()
343 req = ceph_osdc_new_request(osdc, &ci->i_layout, vino, off, &len, in start_read()
382 ret = ceph_osdc_start_request(osdc, req, false); in start_read()
480 struct ceph_osd_client *osdc; in writepage_nounlock() local
498 osdc = &fsc->client->osdc; in writepage_nounlock()
543 err = ceph_osdc_writepages(osdc, ceph_vino(inode), in writepage_nounlock()
[all …]
|
| D | file.c | 443 ret = ceph_osdc_readpages(&fsc->client->osdc, ceph_vino(inode), in striped_read()
667 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_sync_direct_write()
701 ret = ceph_osdc_start_request(&fsc->client->osdc, req, false); in ceph_sync_direct_write()
703 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_sync_direct_write()
783 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_sync_write()
832 ret = ceph_osdc_start_request(&fsc->client->osdc, req, false); in ceph_sync_write()
834 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_sync_write()
1003 struct ceph_osd_client *osdc = in ceph_write_iter() local
1004 &ceph_sb_to_client(inode->i_sb)->client->osdc; in ceph_write_iter()
1049 if (ceph_osdmap_flag(osdc->osdmap, CEPH_OSDMAP_FULL)) { in ceph_write_iter()
[all …]
|
| D | xattr.c | 72 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_vxattrcb_layout() local
78 down_read(&osdc->map_sem); in ceph_vxattrcb_layout()
79 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout()
110 up_read(&osdc->map_sem); in ceph_vxattrcb_layout()
140 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_vxattrcb_layout_pool() local
144 down_read(&osdc->map_sem); in ceph_vxattrcb_layout_pool()
145 pool_name = ceph_pg_pool_name_by_id(osdc->osdmap, pool); in ceph_vxattrcb_layout_pool()
150 up_read(&osdc->map_sem); in ceph_vxattrcb_layout_pool()
|
| D | super.c | 101 ceph_osdc_sync(&fsc->client->osdc); in ceph_sync_fs()
|
| /linux-4.4.14/drivers/block/ |
| D | rbd.c | 1555 static int rbd_obj_request_submit(struct ceph_osd_client *osdc, in rbd_obj_request_submit() argument
1559 return ceph_osdc_start_request(osdc, obj_request->osd_req, false); in rbd_obj_request_submit()
1938 struct ceph_osd_client *osdc; in rbd_osd_req_create() local
1956 osdc = &rbd_dev->rbd_client->client->osdc; in rbd_osd_req_create()
1957 osd_req = ceph_osdc_alloc_request(osdc, snapc, num_ops, false, in rbd_osd_req_create()
1988 struct ceph_osd_client *osdc; in rbd_osd_req_create_copyup() local
2005 osdc = &rbd_dev->rbd_client->client->osdc; in rbd_osd_req_create_copyup()
2006 osd_req = ceph_osdc_alloc_request(osdc, snapc, num_osd_ops, in rbd_osd_req_create_copyup()
2594 struct ceph_osd_client *osdc; in rbd_img_obj_parent_read_full_callback() local
2631 struct ceph_osd_client *osdc; in rbd_img_obj_parent_read_full_callback() local
[all …]
|