Lines Matching refs:ds
470 struct nfs4_pnfs_ds *ds; in filelayout_read_pagelist() local
483 ds = nfs4_fl_prepare_ds(lseg, idx); in filelayout_read_pagelist()
484 if (!ds) in filelayout_read_pagelist()
487 ds_clnt = nfs4_find_or_create_ds_client(ds->ds_clp, hdr->inode); in filelayout_read_pagelist()
492 ds->ds_remotestr, atomic_read(&ds->ds_clp->cl_count)); in filelayout_read_pagelist()
495 atomic_inc(&ds->ds_clp->cl_count); in filelayout_read_pagelist()
496 hdr->ds_clp = ds->ds_clp; in filelayout_read_pagelist()
517 struct nfs4_pnfs_ds *ds; in filelayout_write_pagelist() local
526 ds = nfs4_fl_prepare_ds(lseg, idx); in filelayout_write_pagelist()
527 if (!ds) in filelayout_write_pagelist()
530 ds_clnt = nfs4_find_or_create_ds_client(ds->ds_clp, hdr->inode); in filelayout_write_pagelist()
536 offset, ds->ds_remotestr, atomic_read(&ds->ds_clp->cl_count)); in filelayout_write_pagelist()
539 atomic_inc(&ds->ds_clp->cl_count); in filelayout_write_pagelist()
540 hdr->ds_clp = ds->ds_clp; in filelayout_write_pagelist()
776 if (cinfo->ds->nbuckets >= size) { in filelayout_alloc_commit_info()
798 if (cinfo->ds->nbuckets >= size) in filelayout_alloc_commit_info()
800 for (i = 0; i < cinfo->ds->nbuckets; i++) { in filelayout_alloc_commit_info()
801 list_splice(&cinfo->ds->buckets[i].written, in filelayout_alloc_commit_info()
803 list_splice(&cinfo->ds->buckets[i].committing, in filelayout_alloc_commit_info()
806 cinfo->ds->buckets[i].direct_verf.committed; in filelayout_alloc_commit_info()
807 buckets[i].wlseg = cinfo->ds->buckets[i].wlseg; in filelayout_alloc_commit_info()
808 buckets[i].clseg = cinfo->ds->buckets[i].clseg; in filelayout_alloc_commit_info()
810 swap(cinfo->ds->buckets, buckets); in filelayout_alloc_commit_info()
811 cinfo->ds->nbuckets = size; in filelayout_alloc_commit_info()
1002 struct nfs4_pnfs_ds *ds; in filelayout_initiate_commit() local
1008 ds = nfs4_fl_prepare_ds(lseg, idx); in filelayout_initiate_commit()
1009 if (!ds) in filelayout_initiate_commit()
1012 ds_clnt = nfs4_find_or_create_ds_client(ds->ds_clp, data->inode); in filelayout_initiate_commit()
1017 data->inode->i_ino, how, atomic_read(&ds->ds_clp->cl_count)); in filelayout_initiate_commit()
1019 atomic_inc(&ds->ds_clp->cl_count); in filelayout_initiate_commit()
1020 data->ds_clp = ds->ds_clp; in filelayout_initiate_commit()
1049 for (i = 0, b = cinfo->ds->buckets; i < cinfo->ds->nbuckets; i++, b++) { in filelayout_search_commit_reqs()