/fs/nfs/ |
D | read.c | 61 void nfs_pageio_init_read(struct nfs_pageio_descriptor *pgio, in nfs_pageio_init_read() argument 72 nfs_pageio_init(pgio, inode, pg_ops, compl_ops, &nfs_rw_read_ops, in nfs_pageio_init_read() 77 static void nfs_pageio_complete_read(struct nfs_pageio_descriptor *pgio) in nfs_pageio_complete_read() argument 82 nfs_pageio_complete(pgio); in nfs_pageio_complete_read() 85 WARN_ON_ONCE(pgio->pg_mirror_count != 1); in nfs_pageio_complete_read() 87 pgm = &pgio->pg_mirrors[0]; in nfs_pageio_complete_read() 88 NFS_I(pgio->pg_inode)->read_io += pgm->pg_bytes_written; in nfs_pageio_complete_read() 90 nfs_add_stats(pgio->pg_inode, NFSIOS_READPAGES, npages); in nfs_pageio_complete_read() 94 void nfs_pageio_reset_read_mds(struct nfs_pageio_descriptor *pgio) in nfs_pageio_reset_read_mds() argument 98 if (pgio->pg_ops && pgio->pg_ops->pg_cleanup) in nfs_pageio_reset_read_mds() [all …]
|
D | pagelist.c | 1007 static void nfs_pageio_setup_mirroring(struct nfs_pageio_descriptor *pgio, in nfs_pageio_setup_mirroring() argument 1012 if (pgio->pg_ops->pg_get_mirror_count) in nfs_pageio_setup_mirroring() 1013 mirror_count = pgio->pg_ops->pg_get_mirror_count(pgio, req); in nfs_pageio_setup_mirroring() 1014 if (mirror_count == pgio->pg_mirror_count || pgio->pg_error < 0) in nfs_pageio_setup_mirroring() 1018 pgio->pg_error = -EINVAL; in nfs_pageio_setup_mirroring() 1022 pgio->pg_mirrors = nfs_pageio_alloc_mirrors(pgio, mirror_count); in nfs_pageio_setup_mirroring() 1023 if (pgio->pg_mirrors == NULL) { in nfs_pageio_setup_mirroring() 1024 pgio->pg_error = -ENOMEM; in nfs_pageio_setup_mirroring() 1025 pgio->pg_mirrors = pgio->pg_mirrors_static; in nfs_pageio_setup_mirroring() 1028 pgio->pg_mirror_count = mirror_count; in nfs_pageio_setup_mirroring() [all …]
|
D | pnfs.c | 2692 pnfs_generic_pg_check_layout(struct nfs_pageio_descriptor *pgio) in pnfs_generic_pg_check_layout() argument 2694 if (pgio->pg_lseg == NULL || in pnfs_generic_pg_check_layout() 2695 test_bit(NFS_LSEG_VALID, &pgio->pg_lseg->pls_flags)) in pnfs_generic_pg_check_layout() 2697 pnfs_put_lseg(pgio->pg_lseg); in pnfs_generic_pg_check_layout() 2698 pgio->pg_lseg = NULL; in pnfs_generic_pg_check_layout() 2707 pnfs_generic_pg_check_range(struct nfs_pageio_descriptor *pgio, struct nfs_page *req) in pnfs_generic_pg_check_range() argument 2709 if (pgio->pg_lseg && !pnfs_lseg_request_intersecting(pgio->pg_lseg, req)) { in pnfs_generic_pg_check_range() 2710 pnfs_put_lseg(pgio->pg_lseg); in pnfs_generic_pg_check_range() 2711 pgio->pg_lseg = NULL; in pnfs_generic_pg_check_range() 2717 pnfs_generic_pg_init_read(struct nfs_pageio_descriptor *pgio, struct nfs_page *req) in pnfs_generic_pg_init_read() argument [all …]
|
D | write.c | 609 struct nfs_pageio_descriptor *pgio) in nfs_page_async_flush() argument 625 ret = pgio->pg_error; in nfs_page_async_flush() 630 if (!nfs_pageio_add_request(pgio, req)) { in nfs_page_async_flush() 631 ret = pgio->pg_error; in nfs_page_async_flush() 641 pgio->pg_error = 0; in nfs_page_async_flush() 653 struct nfs_pageio_descriptor *pgio) in nfs_do_writepage() argument 655 nfs_pageio_cond_complete(pgio, page_index(page)); in nfs_do_writepage() 656 return nfs_page_async_flush(page, wbc, pgio); in nfs_do_writepage() 665 struct nfs_pageio_descriptor pgio; in nfs_writepage_locked() local 670 nfs_pageio_init_write(&pgio, inode, 0, in nfs_writepage_locked() [all …]
|
D | internal.h | 469 extern void nfs_pageio_init_read(struct nfs_pageio_descriptor *pgio, 473 extern void nfs_pageio_reset_read_mds(struct nfs_pageio_descriptor *pgio); 485 extern void nfs_pageio_init_write(struct nfs_pageio_descriptor *pgio, 488 extern void nfs_pageio_reset_write_mds(struct nfs_pageio_descriptor *pgio); 531 void nfs_pageio_stop_mirroring(struct nfs_pageio_descriptor *pgio);
|
D | pnfs.h | 259 void pnfs_generic_pg_check_layout(struct nfs_pageio_descriptor *pgio); 260 void pnfs_generic_pg_check_range(struct nfs_pageio_descriptor *pgio, struct nfs_page *req); 263 void pnfs_generic_pg_init_write(struct nfs_pageio_descriptor *pgio, 267 size_t pnfs_generic_pg_test(struct nfs_pageio_descriptor *pgio,
|
/fs/nfs/flexfilelayout/ |
D | flexfilelayout.c | 790 ff_layout_get_ds_for_read(struct nfs_pageio_descriptor *pgio, in ff_layout_get_ds_for_read() argument 793 struct pnfs_layout_segment *lseg = pgio->pg_lseg; in ff_layout_get_ds_for_read() 796 ds = ff_layout_choose_best_ds_for_read(lseg, pgio->pg_mirror_idx, in ff_layout_get_ds_for_read() 798 if (ds || !pgio->pg_mirror_idx) in ff_layout_get_ds_for_read() 804 ff_layout_pg_get_read(struct nfs_pageio_descriptor *pgio, in ff_layout_pg_get_read() argument 808 pnfs_put_lseg(pgio->pg_lseg); in ff_layout_pg_get_read() 809 pgio->pg_lseg = pnfs_update_layout(pgio->pg_inode, in ff_layout_pg_get_read() 816 if (IS_ERR(pgio->pg_lseg)) { in ff_layout_pg_get_read() 817 pgio->pg_error = PTR_ERR(pgio->pg_lseg); in ff_layout_pg_get_read() 818 pgio->pg_lseg = NULL; in ff_layout_pg_get_read() [all …]
|
/fs/nfs/blocklayout/ |
D | blocklayout.c | 821 is_aligned_req(struct nfs_pageio_descriptor *pgio, in is_aligned_req() argument 828 if (pgio->pg_dreq == NULL) in is_aligned_req() 838 (req_offset(req) + req->wb_bytes == i_size_read(pgio->pg_inode))) { in is_aligned_req() 853 bl_pg_init_read(struct nfs_pageio_descriptor *pgio, struct nfs_page *req) in bl_pg_init_read() argument 855 if (!is_aligned_req(pgio, req, SECTOR_SIZE, false)) { in bl_pg_init_read() 856 nfs_pageio_reset_read_mds(pgio); in bl_pg_init_read() 860 pnfs_generic_pg_init_read(pgio, req); in bl_pg_init_read() 862 if (pgio->pg_lseg && in bl_pg_init_read() 863 test_bit(NFS_LSEG_UNAVAILABLE, &pgio->pg_lseg->pls_flags)) { in bl_pg_init_read() 864 pnfs_error_mark_layout_for_return(pgio->pg_inode, pgio->pg_lseg); in bl_pg_init_read() [all …]
|
/fs/nfs/filelayout/ |
D | filelayout.c | 799 filelayout_pg_test(struct nfs_pageio_descriptor *pgio, struct nfs_page *prev, in filelayout_pg_test() argument 805 u64 segment_offset = pgio->pg_lseg->pls_range.offset; in filelayout_pg_test() 806 u32 stripe_unit = FILELAYOUT_LSEG(pgio->pg_lseg)->stripe_unit; in filelayout_pg_test() 809 size = pnfs_generic_pg_test(pgio, prev, req); in filelayout_pg_test() 812 else if (!filelayout_lseg_is_striped(FILELAYOUT_LSEG(pgio->pg_lseg))) in filelayout_pg_test() 868 filelayout_pg_init_read(struct nfs_pageio_descriptor *pgio, in filelayout_pg_init_read() argument 871 pnfs_generic_pg_check_layout(pgio); in filelayout_pg_init_read() 872 if (!pgio->pg_lseg) { in filelayout_pg_init_read() 873 pgio->pg_lseg = fl_pnfs_update_layout(pgio->pg_inode, in filelayout_pg_init_read() 880 if (IS_ERR(pgio->pg_lseg)) { in filelayout_pg_init_read() [all …]
|