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.c350 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, vino, subreq->start, &len, in ceph_netfs_issue_read()
352 CEPH_OSD_FLAG_READ | fsc->client->osdc.client->options->read_from_replica, in ceph_netfs_issue_read()
614 struct ceph_osd_client *osdc = &fsc->client->osdc; in writepage_nounlock() local
659 req = ceph_osdc_new_request(osdc, &ci->i_layout, ceph_vino(inode), page_off, &len, 0, 1, in writepage_nounlock()
679 ceph_osdc_start_request(osdc, req); in writepage_nounlock()
680 err = ceph_osdc_wait_request(osdc, req); in writepage_nounlock()
1097 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_writepages_start()
1104 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_writepages_start()
1208 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_writepages_start()
1744 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
[all …]
Dfile.c928 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_read() local
960 req = ceph_osdc_new_request(osdc, &ci->i_layout, in ceph_sync_read()
983 ceph_osdc_start_request(osdc, req); in ceph_sync_read()
984 ret = ceph_osdc_wait_request(osdc, req); in ceph_sync_read()
1314 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_direct_read_write()
1385 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_direct_read_write()
1516 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_sync_write()
1561 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_sync_write()
1562 ret = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_sync_write()
1762 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()
1068 struct ceph_osd_client *osdc = &fsc->client->osdc; in ceph_sync_setxattr() local
1108 cpu_to_le32(osdc->osdmap->epoch); in ceph_sync_setxattr()
Dsuper.c129 ceph_osdc_sync(&fsc->client->osdc); in ceph_sync_fs()
973 ceph_osdc_abort_requests(&fsc->client->osdc, -EIO); in __ceph_umount_begin()
1487 ceph_osdc_clear_abort_err(&fsc->client->osdc); in ceph_force_reconnect()
Dcaps.c1232 struct ceph_osd_client *osdc = &arg->session->s_mdsc->fsc->client->osdc; in encode_cap_msg() local
1289 ceph_encode_32(&p, READ_ONCE(osdc->epoch_barrier)); in encode_cap_msg()
4152 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_handle_caps() local
4156 ceph_osdc_update_epoch_barrier(osdc, epoch_barrier); in ceph_handle_caps()
Dmds_client.c2117 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_send_cap_releases() local
2123 down_read(&osdc->lock); in ceph_send_cap_releases()
2124 barrier = cpu_to_le32(osdc->epoch_barrier); in ceph_send_cap_releases()
2125 up_read(&osdc->lock); in ceph_send_cap_releases()