Home
last modified time | relevance | path

Searched refs:osdc (Results 1 – 7 of 7) sorted by relevance

/fs/ceph/
Dioctl.c184 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()
Daddr.c256 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, vino, subreq->start, &len, in ceph_netfs_issue_op()
258 CEPH_OSD_FLAG_READ | fsc->client->osdc.client->options->read_from_replica, in ceph_netfs_issue_op()
493 struct ceph_osd_client *osdc = &fsc->client->osdc; in writepage_nounlock() local
534 req = ceph_osdc_new_request(osdc, &ci->i_layout, ceph_vino(inode), page_off, &len, 0, 1, in writepage_nounlock()
550 err = ceph_osdc_start_request(osdc, req, true); in writepage_nounlock()
552 err = ceph_osdc_wait_request(osdc, req); in writepage_nounlock()
955 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_writepages_start()
962 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_writepages_start()
1053 rc = ceph_osdc_start_request(&fsc->client->osdc, req, true); in ceph_writepages_start()
1654 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
[all …]
Dfile.c879 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_read() local
911 req = ceph_osdc_new_request(osdc, &ci->i_layout, in ceph_sync_read()
934 ret = ceph_osdc_start_request(osdc, req, false); in ceph_sync_read()
936 ret = ceph_osdc_wait_request(osdc, req); in ceph_sync_read()
1260 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_direct_read_write()
1332 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_direct_read_write()
1463 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_sync_write()
1508 ret = ceph_osdc_start_request(&fsc->client->osdc, req, false); in ceph_sync_write()
1510 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_sync_write()
1706 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_write_iter() local
[all …]
Dxattr.c61 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()
1059 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_setxattr() local
1099 cpu_to_le32(osdc->osdmap->epoch); in ceph_sync_setxattr()
Dsuper.c125 ceph_osdc_sync(&fsc->client->osdc); in ceph_sync_fs()
837 ceph_osdc_abort_requests(&fsc->client->osdc, -EIO); in __ceph_umount_begin()
1275 ceph_osdc_clear_abort_err(&fsc->client->osdc); in ceph_force_reconnect()
Dcaps.c1231 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()
4102 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_handle_caps() local
4106 ceph_osdc_update_epoch_barrier(osdc, epoch_barrier); in ceph_handle_caps()
Dmds_client.c2104 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_send_cap_releases() local
2110 down_read(&osdc->lock); in ceph_send_cap_releases()
2111 barrier = cpu_to_le32(osdc->epoch_barrier); in ceph_send_cap_releases()
2112 up_read(&osdc->lock); in ceph_send_cap_releases()