Lines Matching refs:cinfo
79 struct nfs_commit_info *cinfo) in pnfs_generic_clear_request_commit() argument
85 cinfo->ds->nwritten--; in pnfs_generic_clear_request_commit()
90 nfs_request_remove_commit_list(req, cinfo); in pnfs_generic_clear_request_commit()
242 struct nfs_commit_info *cinfo, in pnfs_bucket_scan_ds_commit_list() argument
249 lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_bucket_scan_ds_commit_list()
250 ret = nfs_scan_commit_list(src, dst, cinfo, max); in pnfs_bucket_scan_ds_commit_list()
252 cinfo->ds->nwritten -= ret; in pnfs_bucket_scan_ds_commit_list()
253 cinfo->ds->ncommitting += ret; in pnfs_bucket_scan_ds_commit_list()
258 static int pnfs_bucket_scan_array(struct nfs_commit_info *cinfo, in pnfs_bucket_scan_array() argument
267 cnt = pnfs_bucket_scan_ds_commit_list(&buckets[i], cinfo, max); in pnfs_bucket_scan_array()
277 int pnfs_generic_scan_commit_lists(struct nfs_commit_info *cinfo, int max) in pnfs_generic_scan_commit_lists() argument
279 struct pnfs_ds_commit_info *fl_cinfo = cinfo->ds; in pnfs_generic_scan_commit_lists()
288 cnt = pnfs_bucket_scan_array(cinfo, array->buckets, in pnfs_generic_scan_commit_lists()
291 pnfs_put_commit_array(array, cinfo->inode); in pnfs_generic_scan_commit_lists()
306 struct nfs_commit_info *cinfo) in pnfs_bucket_recover_commit_reqs() argument
315 nwritten = nfs_scan_commit_list(&b->written, dst, cinfo, 0); in pnfs_bucket_recover_commit_reqs()
330 struct nfs_commit_info *cinfo) in pnfs_generic_recover_commit_reqs() argument
332 struct pnfs_ds_commit_info *fl_cinfo = cinfo->ds; in pnfs_generic_recover_commit_reqs()
336 lockdep_assert_held(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_generic_recover_commit_reqs()
345 cinfo); in pnfs_generic_recover_commit_reqs()
347 pnfs_put_commit_array(array, cinfo->inode); in pnfs_generic_recover_commit_reqs()
384 struct nfs_page *pnfs_generic_search_commit_reqs(struct nfs_commit_info *cinfo, in pnfs_generic_search_commit_reqs() argument
387 struct pnfs_ds_commit_info *fl_cinfo = cinfo->ds; in pnfs_generic_search_commit_reqs()
404 struct nfs_commit_info *cinfo) in pnfs_bucket_get_committing() argument
410 cinfo->ds->ncommitting--; in pnfs_bucket_get_committing()
420 struct nfs_commit_info *cinfo) in pnfs_bucket_fetch_commitdata() argument
426 data->lseg = pnfs_bucket_get_committing(&data->pages, bucket, cinfo); in pnfs_bucket_fetch_commitdata()
432 struct nfs_commit_info *cinfo, in pnfs_generic_retry_commit() argument
442 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_generic_retry_commit()
443 freeme = pnfs_bucket_get_committing(&pages, bucket, cinfo); in pnfs_generic_retry_commit()
444 mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_generic_retry_commit()
445 nfs_retry_commit(&pages, freeme, cinfo, idx); in pnfs_generic_retry_commit()
454 struct nfs_commit_info *cinfo) in pnfs_bucket_alloc_ds_commits() argument
464 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_bucket_alloc_ds_commits()
466 data = pnfs_bucket_fetch_commitdata(bucket, cinfo); in pnfs_bucket_alloc_ds_commits()
473 mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_bucket_alloc_ds_commits()
477 mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_bucket_alloc_ds_commits()
479 pnfs_generic_retry_commit(buckets, nbuckets, cinfo, i); in pnfs_bucket_alloc_ds_commits()
486 struct nfs_commit_info *cinfo) in pnfs_alloc_ds_commits_list() argument
497 array->nbuckets, cinfo); in pnfs_alloc_ds_commits_list()
499 pnfs_put_commit_array(array, cinfo->inode); in pnfs_alloc_ds_commits_list()
508 int how, struct nfs_commit_info *cinfo, in pnfs_generic_commit_pagelist() argument
512 struct pnfs_ds_commit_info *fl_cinfo = cinfo->ds; in pnfs_generic_commit_pagelist()
520 nfs_retry_commit(mds_pages, NULL, cinfo, -1); in pnfs_generic_commit_pagelist()
529 nreq += pnfs_alloc_ds_commits_list(&list, fl_cinfo, cinfo); in pnfs_generic_commit_pagelist()
536 nfs_init_commit(data, NULL, NULL, cinfo); in pnfs_generic_commit_pagelist()
542 nfs_init_commit(data, NULL, data->lseg, cinfo); in pnfs_generic_commit_pagelist()
1157 struct nfs_commit_info *cinfo, in pnfs_layout_mark_request_commit() argument
1164 mutex_lock(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_layout_mark_request_commit()
1165 array = pnfs_lookup_commit_array(cinfo->ds, lseg); in pnfs_layout_mark_request_commit()
1179 cinfo->ds->nwritten++; in pnfs_layout_mark_request_commit()
1181 nfs_request_add_commit_list_locked(req, list, cinfo); in pnfs_layout_mark_request_commit()
1182 mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_layout_mark_request_commit()
1183 nfs_folio_mark_unstable(nfs_page_to_folio(req), cinfo); in pnfs_layout_mark_request_commit()
1186 mutex_unlock(&NFS_I(cinfo->inode)->commit_mutex); in pnfs_layout_mark_request_commit()
1187 cinfo->completion_ops->resched_write(cinfo, req); in pnfs_layout_mark_request_commit()