Lines Matching refs:fsc
232 struct ceph_fs_client *fsc = ceph_inode_to_client(inode);
240 subreq->len = min(xlen, fsc->mount_options->rsize);
247 struct ceph_fs_client *fsc = ceph_inode_to_client(inode);
254 ceph_update_read_metrics(&fsc->mdsc->metric, req->r_start_latency,
264 fsc->blocklisted = true;
288 ceph_dec_osd_stopping_blocker(fsc->mdsc);
351 struct ceph_fs_client *fsc = ceph_inode_to_client(inode);
357 bool sparse = IS_ENCRYPTED(inode) || ceph_test_mount_opt(fsc, SPARSEREAD);
370 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, vino,
372 CEPH_OSD_FLAG_READ | fsc->client->osdc.client->options->read_from_replica,
418 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) {
661 struct ceph_fs_client *fsc = ceph_inode_to_client(inode);
668 struct ceph_osd_client *osdc = &fsc->client->osdc;
711 if (atomic_long_inc_return(&fsc->writeback_count) >
712 CONGESTION_ON_THRESH(fsc->mount_options->congestion_kb))
713 fsc->write_congested = true;
757 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency,
776 fsc->blocklisted = true;
791 if (atomic_long_dec_return(&fsc->writeback_count) <
792 CONGESTION_OFF_THRESH(fsc->mount_options->congestion_kb))
793 fsc->write_congested = false;
839 struct ceph_fs_client *fsc = ceph_inode_to_client(inode);
848 fsc->blocklisted = true;
886 if (atomic_long_dec_return(&fsc->writeback_count) <
888 fsc->mount_options->congestion_kb))
889 fsc->write_congested = false;
907 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency,
918 ceph_dec_osd_stopping_blocker(fsc->mdsc);
929 struct ceph_fs_client *fsc = ceph_inode_to_client(inode);
944 fsc->write_congested)
960 if (fsc->mount_options->wsize < wsize)
961 wsize = fsc->mount_options->wsize;
1149 if (atomic_long_inc_return(&fsc->writeback_count) >
1151 fsc->mount_options->congestion_kb))
1152 fsc->write_congested = true;
1206 req = ceph_osdc_new_request(&fsc->client->osdc,
1213 req = ceph_osdc_new_request(&fsc->client->osdc,
1227 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) {
1331 ceph_osdc_start_request(&fsc->client->osdc, req);
1826 struct ceph_fs_client *fsc = ceph_inode_to_client(inode);
1869 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout,
1879 ceph_osdc_start_request(&fsc->client->osdc, req);
1880 err = ceph_osdc_wait_request(&fsc->client->osdc, req);
1885 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout,
1921 ceph_osdc_start_request(&fsc->client->osdc, req);
1922 err = ceph_osdc_wait_request(&fsc->client->osdc, req);
1924 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency,
1932 down_read(&fsc->mdsc->snap_rwsem);
1937 up_read(&fsc->mdsc->snap_rwsem);
1980 struct ceph_fs_client *fsc = ceph_inode_to_client(&ci->netfs.inode);
1981 struct ceph_mds_client *mdsc = fsc->mdsc;
2050 rd_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL,
2068 wr_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL,
2093 ceph_osdc_start_request(&fsc->client->osdc, rd_req);
2096 ceph_osdc_start_request(&fsc->client->osdc, wr_req);
2098 err = ceph_osdc_wait_request(&fsc->client->osdc, rd_req);
2099 err2 = ceph_osdc_wait_request(&fsc->client->osdc, wr_req);
2105 fsc->blocklisted = true;
2113 fsc->blocklisted = true;