Lines Matching refs:fsc
214 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in finish_netfs_read() local
215 struct ceph_client *cl = fsc->client; in finish_netfs_read()
222 ceph_update_read_metrics(&fsc->mdsc->metric, req->r_start_latency, in finish_netfs_read()
234 fsc->blocklisted = true; in finish_netfs_read()
269 ceph_dec_osd_stopping_blocker(fsc->mdsc); in finish_netfs_read()
339 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_netfs_prepare_read() local
346 rreq->io_streams[0].sreq_max_len = umin(xlen, fsc->mount_options->rsize); in ceph_netfs_prepare_read()
355 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_netfs_issue_read() local
356 struct ceph_client *cl = fsc->client; in ceph_netfs_issue_read()
361 bool sparse = IS_ENCRYPTED(inode) || ceph_test_mount_opt(fsc, SPARSEREAD); in ceph_netfs_issue_read()
381 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, vino, in ceph_netfs_issue_read()
438 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) { in ceph_netfs_issue_read()
461 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_init_request() local
513 rreq->io_streams[0].sreq_max_len = fsc->mount_options->rsize; in ceph_init_request()
723 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in write_folio_nounlock() local
724 struct ceph_client *cl = fsc->client; in write_folio_nounlock()
731 struct ceph_osd_client *osdc = &fsc->client->osdc; in write_folio_nounlock()
777 if (atomic_long_inc_return(&fsc->writeback_count) > in write_folio_nounlock()
778 CONGESTION_ON_THRESH(fsc->mount_options->congestion_kb)) in write_folio_nounlock()
779 fsc->write_congested = true; in write_folio_nounlock()
824 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, in write_folio_nounlock()
844 fsc->blocklisted = true; in write_folio_nounlock()
860 if (atomic_long_dec_return(&fsc->writeback_count) < in write_folio_nounlock()
861 CONGESTION_OFF_THRESH(fsc->mount_options->congestion_kb)) in write_folio_nounlock()
862 fsc->write_congested = false; in write_folio_nounlock()
885 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in writepages_finish() local
895 fsc->blocklisted = true; in writepages_finish()
935 if (atomic_long_dec_return(&fsc->writeback_count) < in writepages_finish()
937 fsc->mount_options->congestion_kb)) in writepages_finish()
938 fsc->write_congested = false; in writepages_finish()
963 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, in writepages_finish()
974 ceph_dec_osd_stopping_blocker(fsc->mdsc); in writepages_finish()
982 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in is_forced_umount() local
983 struct ceph_client *cl = fsc->client; in is_forced_umount()
1002 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_define_write_size() local
1005 if (fsc->mount_options->wsize < wsize) in ceph_define_write_size()
1006 wsize = fsc->mount_options->wsize; in ceph_define_write_size()
1072 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_define_writeback_range() local
1073 struct ceph_client *cl = fsc->client; in ceph_define_writeback_range()
1143 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_check_page_before_write() local
1144 struct ceph_client *cl = fsc->client; in ceph_check_page_before_write()
1244 bool is_write_congestion_happened(struct ceph_fs_client *fsc) in is_write_congestion_happened() argument
1246 return atomic_long_inc_return(&fsc->writeback_count) > in is_write_congestion_happened()
1247 CONGESTION_ON_THRESH(fsc->mount_options->congestion_kb); in is_write_congestion_happened()
1255 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in move_dirty_folio_in_page_array() local
1256 struct ceph_client *cl = fsc->client; in move_dirty_folio_in_page_array()
1293 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_process_folio_batch() local
1294 struct ceph_client *cl = fsc->client; in ceph_process_folio_batch()
1369 fsc->write_congested = is_write_congestion_happened(fsc); in ceph_process_folio_batch()
1415 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_submit_write() local
1416 struct ceph_client *cl = fsc->client; in ceph_submit_write()
1429 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_submit_write()
1436 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_submit_write()
1453 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) { in ceph_submit_write()
1585 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_submit_write()
1634 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_writepages_start() local
1635 struct ceph_client *cl = fsc->client; in ceph_writepages_start()
1639 if (wbc->sync_mode == WB_SYNC_NONE && fsc->write_congested) in ceph_writepages_start()
1653 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) { in ceph_writepages_start()
1755 ceph_dec_osd_stopping_blocker(fsc->mdsc); in ceph_writepages_start()
2200 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_uninline_data() local
2201 struct ceph_client *cl = fsc->client; in ceph_uninline_data()
2244 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
2254 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_uninline_data()
2255 err = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_uninline_data()
2260 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
2296 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_uninline_data()
2297 err = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_uninline_data()
2299 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, in ceph_uninline_data()
2307 down_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data()
2312 up_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data()
2355 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(&ci->netfs.inode); in __ceph_pool_perm_get() local
2356 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_pool_perm_get()
2357 struct ceph_client *cl = fsc->client; in __ceph_pool_perm_get()
2426 rd_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL, in __ceph_pool_perm_get()
2444 wr_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL, in __ceph_pool_perm_get()
2469 ceph_osdc_start_request(&fsc->client->osdc, rd_req); in __ceph_pool_perm_get()
2472 ceph_osdc_start_request(&fsc->client->osdc, wr_req); in __ceph_pool_perm_get()
2474 err = ceph_osdc_wait_request(&fsc->client->osdc, rd_req); in __ceph_pool_perm_get()
2475 err2 = ceph_osdc_wait_request(&fsc->client->osdc, wr_req); in __ceph_pool_perm_get()
2481 fsc->blocklisted = true; in __ceph_pool_perm_get()
2489 fsc->blocklisted = true; in __ceph_pool_perm_get()