Lines Matching refs:ds

469 	struct nfs4_pnfs_ds *ds;  in filelayout_read_pagelist()  local
482 ds = nfs4_fl_prepare_ds(lseg, idx); in filelayout_read_pagelist()
483 if (!ds) in filelayout_read_pagelist()
486 ds_clnt = nfs4_find_or_create_ds_client(ds->ds_clp, hdr->inode); in filelayout_read_pagelist()
491 ds->ds_remotestr, atomic_read(&ds->ds_clp->cl_count)); in filelayout_read_pagelist()
494 atomic_inc(&ds->ds_clp->cl_count); in filelayout_read_pagelist()
495 hdr->ds_clp = ds->ds_clp; in filelayout_read_pagelist()
516 struct nfs4_pnfs_ds *ds; in filelayout_write_pagelist() local
525 ds = nfs4_fl_prepare_ds(lseg, idx); in filelayout_write_pagelist()
526 if (!ds) in filelayout_write_pagelist()
529 ds_clnt = nfs4_find_or_create_ds_client(ds->ds_clp, hdr->inode); in filelayout_write_pagelist()
535 offset, ds->ds_remotestr, atomic_read(&ds->ds_clp->cl_count)); in filelayout_write_pagelist()
538 atomic_inc(&ds->ds_clp->cl_count); in filelayout_write_pagelist()
539 hdr->ds_clp = ds->ds_clp; in filelayout_write_pagelist()
775 if (cinfo->ds->nbuckets >= size) { in filelayout_alloc_commit_info()
797 if (cinfo->ds->nbuckets >= size) in filelayout_alloc_commit_info()
799 for (i = 0; i < cinfo->ds->nbuckets; i++) { in filelayout_alloc_commit_info()
800 list_splice(&cinfo->ds->buckets[i].written, in filelayout_alloc_commit_info()
802 list_splice(&cinfo->ds->buckets[i].committing, in filelayout_alloc_commit_info()
805 cinfo->ds->buckets[i].direct_verf.committed; in filelayout_alloc_commit_info()
806 buckets[i].wlseg = cinfo->ds->buckets[i].wlseg; in filelayout_alloc_commit_info()
807 buckets[i].clseg = cinfo->ds->buckets[i].clseg; in filelayout_alloc_commit_info()
809 swap(cinfo->ds->buckets, buckets); in filelayout_alloc_commit_info()
810 cinfo->ds->nbuckets = size; in filelayout_alloc_commit_info()
1001 struct nfs4_pnfs_ds *ds; in filelayout_initiate_commit() local
1007 ds = nfs4_fl_prepare_ds(lseg, idx); in filelayout_initiate_commit()
1008 if (!ds) in filelayout_initiate_commit()
1011 ds_clnt = nfs4_find_or_create_ds_client(ds->ds_clp, data->inode); in filelayout_initiate_commit()
1016 data->inode->i_ino, how, atomic_read(&ds->ds_clp->cl_count)); in filelayout_initiate_commit()
1018 atomic_inc(&ds->ds_clp->cl_count); in filelayout_initiate_commit()
1019 data->ds_clp = ds->ds_clp; in filelayout_initiate_commit()
1048 for (i = 0, b = cinfo->ds->buckets; i < cinfo->ds->nbuckets; i++, b++) { in filelayout_search_commit_reqs()