Lines Matching refs:fsc

200 	struct ceph_fs_client *fsc = ceph_inode_to_client(inode);  in ceph_netfs_clamp_length()  local
208 subreq->len = min(xlen, fsc->mount_options->rsize); in ceph_netfs_clamp_length()
214 struct ceph_fs_client *fsc = ceph_inode_to_client(req->r_inode); in finish_netfs_read() local
220 ceph_update_read_metrics(&fsc->mdsc->metric, req->r_start_latency, in finish_netfs_read()
230 fsc->blocklisted = true; in finish_netfs_read()
247 struct ceph_fs_client *fsc = ceph_inode_to_client(inode); in ceph_netfs_issue_op() local
256 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()
487 struct ceph_fs_client *fsc = ceph_inode_to_client(inode); in writepage_nounlock() local
493 struct ceph_osd_client *osdc = &fsc->client->osdc; in writepage_nounlock()
529 if (atomic_long_inc_return(&fsc->writeback_count) > in writepage_nounlock()
530 CONGESTION_ON_THRESH(fsc->mount_options->congestion_kb)) in writepage_nounlock()
554 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, in writepage_nounlock()
573 fsc->blocklisted = true; in writepage_nounlock()
588 if (atomic_long_dec_return(&fsc->writeback_count) < in writepage_nounlock()
589 CONGESTION_OFF_THRESH(fsc->mount_options->congestion_kb)) in writepage_nounlock()
629 struct ceph_fs_client *fsc = ceph_inode_to_client(inode); in writepages_finish() local
638 fsc->blocklisted = true; in writepages_finish()
668 if (atomic_long_dec_return(&fsc->writeback_count) < in writepages_finish()
670 fsc->mount_options->congestion_kb)) in writepages_finish()
690 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, in writepages_finish()
711 struct ceph_fs_client *fsc = ceph_inode_to_client(inode); in ceph_writepages_start() local
727 if (READ_ONCE(fsc->mount_state) >= CEPH_MOUNT_SHUTDOWN) { in ceph_writepages_start()
736 if (fsc->mount_options->wsize < wsize) in ceph_writepages_start()
737 wsize = fsc->mount_options->wsize; in ceph_writepages_start()
914 if (atomic_long_inc_return(&fsc->writeback_count) > in ceph_writepages_start()
916 fsc->mount_options->congestion_kb)) { in ceph_writepages_start()
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()
1148 struct ceph_fs_client *fsc = ceph_inode_to_client(inode); in ceph_find_incompatible() local
1151 if (READ_ONCE(fsc->mount_state) >= CEPH_MOUNT_SHUTDOWN) { in ceph_find_incompatible()
1598 struct ceph_fs_client *fsc = ceph_inode_to_client(inode); in ceph_uninline_data() local
1654 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
1664 err = ceph_osdc_start_request(&fsc->client->osdc, req, false); in ceph_uninline_data()
1666 err = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_uninline_data()
1671 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
1706 err = ceph_osdc_start_request(&fsc->client->osdc, req, false); in ceph_uninline_data()
1708 err = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_uninline_data()
1710 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, in ceph_uninline_data()
1755 struct ceph_fs_client *fsc = ceph_inode_to_client(&ci->vfs_inode); in __ceph_pool_perm_get() local
1756 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_pool_perm_get()
1825 rd_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL, in __ceph_pool_perm_get()
1843 wr_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL, in __ceph_pool_perm_get()
1868 err = ceph_osdc_start_request(&fsc->client->osdc, rd_req, false); in __ceph_pool_perm_get()
1871 err2 = ceph_osdc_start_request(&fsc->client->osdc, wr_req, false); in __ceph_pool_perm_get()
1874 err = ceph_osdc_wait_request(&fsc->client->osdc, rd_req); in __ceph_pool_perm_get()
1876 err2 = ceph_osdc_wait_request(&fsc->client->osdc, wr_req); in __ceph_pool_perm_get()
1882 fsc->blocklisted = true; in __ceph_pool_perm_get()
1890 fsc->blocklisted = true; in __ceph_pool_perm_get()