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
1006 if (fsc->mount_options->wsize < wsize) in ceph_define_write_size()
1007 wsize = fsc->mount_options->wsize; in ceph_define_write_size()
1069 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_define_writeback_range() local
1070 struct ceph_client *cl = fsc->client; in ceph_define_writeback_range()
1140 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_check_page_before_write() local
1141 struct ceph_client *cl = fsc->client; in ceph_check_page_before_write()
1239 bool is_write_congestion_happened(struct ceph_fs_client *fsc) in is_write_congestion_happened() argument
1241 return atomic_long_inc_return(&fsc->writeback_count) > in is_write_congestion_happened()
1242 CONGESTION_ON_THRESH(fsc->mount_options->congestion_kb); in is_write_congestion_happened()
1250 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in move_dirty_folio_in_page_array() local
1251 struct ceph_client *cl = fsc->client; in move_dirty_folio_in_page_array()
1290 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_process_folio_batch() local
1291 struct ceph_client *cl = fsc->client; in ceph_process_folio_batch()
1363 fsc->write_congested = is_write_congestion_happened(fsc); in ceph_process_folio_batch()
1407 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_submit_write() local
1408 struct ceph_client *cl = fsc->client; in ceph_submit_write()
1421 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_submit_write()
1428 req = ceph_osdc_new_request(&fsc->client->osdc, in ceph_submit_write()
1445 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) { in ceph_submit_write()
1577 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_submit_write()
1626 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_writepages_start() local
1627 struct ceph_client *cl = fsc->client; in ceph_writepages_start()
1631 if (wbc->sync_mode == WB_SYNC_NONE && fsc->write_congested) in ceph_writepages_start()
1645 if (!ceph_inc_osd_stopping_blocker(fsc->mdsc)) { in ceph_writepages_start()
1746 ceph_dec_osd_stopping_blocker(fsc->mdsc); in ceph_writepages_start()
2191 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(inode); in ceph_uninline_data() local
2192 struct ceph_client *cl = fsc->client; in ceph_uninline_data()
2224 down_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data()
2240 up_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data()
2254 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
2264 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_uninline_data()
2265 err = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_uninline_data()
2270 req = ceph_osdc_new_request(&fsc->client->osdc, &ci->i_layout, in ceph_uninline_data()
2306 ceph_osdc_start_request(&fsc->client->osdc, req); in ceph_uninline_data()
2307 err = ceph_osdc_wait_request(&fsc->client->osdc, req); in ceph_uninline_data()
2309 ceph_update_write_metrics(&fsc->mdsc->metric, req->r_start_latency, in ceph_uninline_data()
2317 down_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data()
2322 up_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data()
2366 struct ceph_fs_client *fsc = ceph_inode_to_fs_client(&ci->netfs.inode); in __ceph_pool_perm_get() local
2367 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_pool_perm_get()
2368 struct ceph_client *cl = fsc->client; in __ceph_pool_perm_get()
2437 rd_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL, in __ceph_pool_perm_get()
2455 wr_req = ceph_osdc_alloc_request(&fsc->client->osdc, NULL, in __ceph_pool_perm_get()
2480 ceph_osdc_start_request(&fsc->client->osdc, rd_req); in __ceph_pool_perm_get()
2483 ceph_osdc_start_request(&fsc->client->osdc, wr_req); in __ceph_pool_perm_get()
2485 err = ceph_osdc_wait_request(&fsc->client->osdc, rd_req); in __ceph_pool_perm_get()
2486 err2 = ceph_osdc_wait_request(&fsc->client->osdc, wr_req); in __ceph_pool_perm_get()
2492 fsc->blocklisted = true; in __ceph_pool_perm_get()
2500 fsc->blocklisted = true; in __ceph_pool_perm_get()