Lines Matching refs:cinfo
62 static void nfs_init_cinfo_from_inode(struct nfs_commit_info *cinfo,
827 struct nfs_commit_info cinfo; in nfs_page_search_commits_for_head_request_locked() local
830 nfs_init_cinfo_from_inode(&cinfo, inode); in nfs_page_search_commits_for_head_request_locked()
833 freq = pnfs_search_commit_reqs(inode, &cinfo, page); in nfs_page_search_commits_for_head_request_locked()
838 list_for_each_entry_safe(freq, t, &cinfo.mds->list, wb_list) { in nfs_page_search_commits_for_head_request_locked()
861 struct nfs_commit_info *cinfo) in nfs_request_add_commit_list_locked() argument
865 atomic_long_inc(&cinfo->mds->ncommit); in nfs_request_add_commit_list_locked()
882 nfs_request_add_commit_list(struct nfs_page *req, struct nfs_commit_info *cinfo) in nfs_request_add_commit_list() argument
884 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_request_add_commit_list()
885 nfs_request_add_commit_list_locked(req, &cinfo->mds->list, cinfo); in nfs_request_add_commit_list()
886 mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_request_add_commit_list()
888 nfs_mark_page_unstable(req->wb_page, cinfo); in nfs_request_add_commit_list()
905 struct nfs_commit_info *cinfo) in nfs_request_remove_commit_list() argument
910 atomic_long_dec(&cinfo->mds->ncommit); in nfs_request_remove_commit_list()
914 static void nfs_init_cinfo_from_inode(struct nfs_commit_info *cinfo, in nfs_init_cinfo_from_inode() argument
917 cinfo->inode = inode; in nfs_init_cinfo_from_inode()
918 cinfo->mds = &NFS_I(inode)->commit_info; in nfs_init_cinfo_from_inode()
919 cinfo->ds = pnfs_get_ds_info(inode); in nfs_init_cinfo_from_inode()
920 cinfo->dreq = NULL; in nfs_init_cinfo_from_inode()
921 cinfo->completion_ops = &nfs_commit_completion_ops; in nfs_init_cinfo_from_inode()
924 void nfs_init_cinfo(struct nfs_commit_info *cinfo, in nfs_init_cinfo() argument
929 nfs_init_cinfo_from_dreq(cinfo, dreq); in nfs_init_cinfo()
931 nfs_init_cinfo_from_inode(cinfo, inode); in nfs_init_cinfo()
940 struct nfs_commit_info *cinfo, u32 ds_commit_idx) in nfs_mark_request_commit() argument
942 if (pnfs_mark_request_commit(req, lseg, cinfo, ds_commit_idx)) in nfs_mark_request_commit()
944 nfs_request_add_commit_list(req, cinfo); in nfs_mark_request_commit()
962 struct nfs_commit_info cinfo; in nfs_clear_request_commit() local
964 nfs_init_cinfo_from_inode(&cinfo, inode); in nfs_clear_request_commit()
966 if (!pnfs_clear_request_commit(req, &cinfo)) { in nfs_clear_request_commit()
967 nfs_request_remove_commit_list(req, &cinfo); in nfs_clear_request_commit()
988 struct nfs_commit_info cinfo; in nfs_write_completion() local
993 nfs_init_cinfo_from_inode(&cinfo, hdr->inode); in nfs_write_completion()
1009 nfs_mark_request_commit(req, hdr->lseg, &cinfo, in nfs_write_completion()
1025 nfs_reqs_to_commit(struct nfs_commit_info *cinfo) in nfs_reqs_to_commit() argument
1027 return atomic_long_read(&cinfo->mds->ncommit); in nfs_reqs_to_commit()
1033 struct nfs_commit_info *cinfo, int max) in nfs_scan_commit_list() argument
1050 mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_scan_commit_list()
1053 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_scan_commit_list()
1058 nfs_request_remove_commit_list(req, cinfo); in nfs_scan_commit_list()
1062 if ((ret == max) && !cinfo->dreq) in nfs_scan_commit_list()
1081 struct nfs_commit_info *cinfo) in nfs_scan_commit() argument
1085 if (!atomic_long_read(&cinfo->mds->ncommit)) in nfs_scan_commit()
1087 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_scan_commit()
1088 if (atomic_long_read(&cinfo->mds->ncommit) > 0) { in nfs_scan_commit()
1091 ret = nfs_scan_commit_list(&cinfo->mds->list, dst, in nfs_scan_commit()
1092 cinfo, max); in nfs_scan_commit()
1093 ret += pnfs_scan_commit_lists(inode, cinfo, max - ret); in nfs_scan_commit()
1095 mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex); in nfs_scan_commit()
1656 static int wait_on_commit(struct nfs_mds_commit_info *cinfo) in wait_on_commit() argument
1658 return wait_var_event_killable(&cinfo->rpcs_out, in wait_on_commit()
1659 !atomic_read(&cinfo->rpcs_out)); in wait_on_commit()
1662 static void nfs_commit_begin(struct nfs_mds_commit_info *cinfo) in nfs_commit_begin() argument
1664 atomic_inc(&cinfo->rpcs_out); in nfs_commit_begin()
1667 static void nfs_commit_end(struct nfs_mds_commit_info *cinfo) in nfs_commit_end() argument
1669 if (atomic_dec_and_test(&cinfo->rpcs_out)) in nfs_commit_end()
1670 wake_up_var(&cinfo->rpcs_out); in nfs_commit_end()
1736 struct nfs_commit_info *cinfo) in nfs_init_commit() argument
1754 data->completion_ops = cinfo->completion_ops; in nfs_init_commit()
1755 data->dreq = cinfo->dreq; in nfs_init_commit()
1770 struct nfs_commit_info *cinfo, in nfs_retry_commit() argument
1778 nfs_mark_request_commit(req, lseg, cinfo, ds_commit_idx); in nfs_retry_commit()
1779 if (!cinfo->dreq) in nfs_retry_commit()
1787 nfs_commit_resched_write(struct nfs_commit_info *cinfo, in nfs_commit_resched_write() argument
1798 struct nfs_commit_info *cinfo) in nfs_commit_list() argument
1809 nfs_init_commit(data, head, NULL, cinfo); in nfs_commit_list()
1810 atomic_inc(&cinfo->mds->rpcs_out); in nfs_commit_list()
1834 struct nfs_commit_info cinfo; in nfs_commit_release_pages() local
1879 nfs_init_cinfo(&cinfo, data->inode, data->dreq); in nfs_commit_release_pages()
1880 nfs_commit_end(cinfo.mds); in nfs_commit_release_pages()
1903 int how, struct nfs_commit_info *cinfo) in nfs_generic_commit_list() argument
1907 status = pnfs_commit_list(inode, head, how, cinfo); in nfs_generic_commit_list()
1909 status = nfs_commit_list(inode, head, how, cinfo); in nfs_generic_commit_list()
1917 struct nfs_commit_info cinfo; in __nfs_commit_inode() local
1921 nfs_init_cinfo_from_inode(&cinfo, inode); in __nfs_commit_inode()
1922 nfs_commit_begin(cinfo.mds); in __nfs_commit_inode()
1924 ret = nscan = nfs_scan_commit(inode, &head, &cinfo); in __nfs_commit_inode()
1927 ret = nfs_generic_commit_list(inode, &head, how, &cinfo); in __nfs_commit_inode()
1941 nfs_commit_end(cinfo.mds); in __nfs_commit_inode()
1944 return wait_on_commit(cinfo.mds); in __nfs_commit_inode()