/kernel/linux/linux-5.10/fs/nfs/filelayout/ |
H A D | filelayout.c | 210 hdr->ds_clp, hdr->lseg); in filelayout_read_done_cb() 282 if (nfs4_setup_sequence(hdr->ds_clp, in filelayout_read_prepare() 322 hdr->ds_clp, hdr->lseg); in filelayout_write_done_cb() 349 err = filelayout_async_handle_error(task, NULL, data->ds_clp, in filelayout_commit_done_cb() 380 if (nfs4_setup_sequence(hdr->ds_clp, in filelayout_write_prepare() 415 nfs4_setup_sequence(wdata->ds_clp, in filelayout_commit_prepare() 470 ds_clnt = nfs4_find_or_create_ds_client(ds->ds_clp, hdr->inode); in filelayout_read_pagelist() 475 ds->ds_remotestr, refcount_read(&ds->ds_clp->cl_count)); in filelayout_read_pagelist() 478 refcount_inc(&ds->ds_clp->cl_count); in filelayout_read_pagelist() 479 hdr->ds_clp in filelayout_read_pagelist() [all...] |
H A D | filelayoutdev.c | 278 if (ds->ds_clp) in nfs4_fl_prepare_ds() 291 if (ret->ds_clp == NULL || in nfs4_fl_prepare_ds()
|
/kernel/linux/linux-6.6/fs/nfs/filelayout/ |
H A D | filelayout.c | 212 hdr->ds_clp, hdr->lseg); in filelayout_read_done_cb() 284 if (nfs4_setup_sequence(hdr->ds_clp, in filelayout_read_prepare() 322 hdr->ds_clp, hdr->lseg); in filelayout_write_done_cb() 349 err = filelayout_async_handle_error(task, NULL, data->ds_clp, in filelayout_commit_done_cb() 380 if (nfs4_setup_sequence(hdr->ds_clp, in filelayout_write_prepare() 415 nfs4_setup_sequence(wdata->ds_clp, in filelayout_commit_prepare() 470 ds_clnt = nfs4_find_or_create_ds_client(ds->ds_clp, hdr->inode); in filelayout_read_pagelist() 475 ds->ds_remotestr, refcount_read(&ds->ds_clp->cl_count)); in filelayout_read_pagelist() 478 refcount_inc(&ds->ds_clp->cl_count); in filelayout_read_pagelist() 479 hdr->ds_clp in filelayout_read_pagelist() [all...] |
H A D | filelayoutdev.c | 276 if (ds->ds_clp) in nfs4_fl_prepare_ds() 289 if (ret->ds_clp == NULL || in nfs4_fl_prepare_ds()
|
/kernel/linux/linux-5.10/fs/nfs/ |
H A D | pnfs_nfs.c | 26 nfs_put_client(hdr->ds_clp); in pnfs_generic_rw_release() 57 nfs_put_client(data->ds_clp); in pnfs_generic_commit_release() 576 refcount_read(&ds->ds_count), ds->ds_clp, in print_ds() 577 ds->ds_clp ? ds->ds_clp->cl_exchange_flags : 0); in print_ds() 672 nfs_put_client(ds->ds_clp); in destroy_ds() 777 ds->ds_clp = NULL; in nfs4_pnfs_ds_add() 881 WRITE_ONCE(ds->ds_clp, clp); in _nfs4_pnfs_v3_ds_connect() 954 WRITE_ONCE(ds->ds_clp, clp); in _nfs4_pnfs_v4_ds_connect() 973 if (err || ds->ds_clp) in nfs4_pnfs_ds_connect() [all...] |
H A D | nfs4client.c | 50 struct list_head list; /* ds_clp->cl_ds_clients */ 56 * @ds_clp: pointer to the DS's nfs_client 60 nfs4_find_ds_client(struct nfs_client *ds_clp, rpc_authflavor_t flavor) in nfs4_find_ds_client() argument 65 list_for_each_entry_rcu(dss, &ds_clp->cl_ds_clients, list) { in nfs4_find_ds_client() 77 nfs4_add_ds_client(struct nfs_client *ds_clp, rpc_authflavor_t flavor, in nfs4_add_ds_client() argument 82 spin_lock(&ds_clp->cl_lock); in nfs4_add_ds_client() 83 list_for_each_entry(dss, &ds_clp->cl_ds_clients, list) { in nfs4_add_ds_client() 89 list_add_rcu(&new->list, &ds_clp->cl_ds_clients); in nfs4_add_ds_client() 92 spin_unlock(&ds_clp->cl_lock); /* need some lock to protect list */ in nfs4_add_ds_client() 97 nfs4_alloc_ds_server(struct nfs_client *ds_clp, rpc_authflavor_ argument 132 nfs4_find_or_create_ds_client(struct nfs_client *ds_clp, struct inode *inode) nfs4_find_or_create_ds_client() argument [all...] |
H A D | nfs4trace.h | 2210 __string(dstaddr, hdr->ds_clp ? 2211 rpc_peeraddr2str(hdr->ds_clp->cl_rpcclient, 2228 __assign_str(dstaddr, hdr->ds_clp ? 2229 rpc_peeraddr2str(hdr->ds_clp->cl_rpcclient, 2270 __string(dstaddr, data->ds_clp ? 2271 rpc_peeraddr2str(data->ds_clp->cl_rpcclient, 2284 __assign_str(dstaddr, data->ds_clp ? 2285 rpc_peeraddr2str(data->ds_clp->cl_rpcclient,
|
H A D | pnfs.h | 60 struct nfs_client *ds_clp; member
|
H A D | nfs4proc.c | 5445 if (hdr->ds_clp != NULL || hdr->dreq != NULL) in nfs4_write_need_cache_consistency_data() 5513 nfs4_state_protect_write(hdr->ds_clp ? hdr->ds_clp : server->nfs_client, clnt, msg, hdr); in nfs4_proc_write_setup() 5554 nfs4_state_protect(data->ds_clp ? data->ds_clp : server->nfs_client, in nfs4_proc_commit_setup()
|
/kernel/linux/linux-6.6/fs/nfs/ |
H A D | pnfs_nfs.c | 26 nfs_put_client(hdr->ds_clp); in pnfs_generic_rw_release() 57 nfs_put_client(data->ds_clp); in pnfs_generic_commit_release() 576 refcount_read(&ds->ds_count), ds->ds_clp, in print_ds() 577 ds->ds_clp ? ds->ds_clp->cl_exchange_flags : 0); in print_ds() 687 nfs_put_client(ds->ds_clp); in destroy_ds() 791 ds->ds_clp = NULL; in nfs4_pnfs_ds_add() 903 WRITE_ONCE(ds->ds_clp, clp); in _nfs4_pnfs_v3_ds_connect() 1023 WRITE_ONCE(ds->ds_clp, clp); in _nfs4_pnfs_v4_ds_connect() 1042 if (err || ds->ds_clp) in nfs4_pnfs_ds_connect() [all...] |
H A D | nfs4client.c | 51 struct list_head list; /* ds_clp->cl_ds_clients */ 57 * @ds_clp: pointer to the DS's nfs_client 61 nfs4_find_ds_client(struct nfs_client *ds_clp, rpc_authflavor_t flavor) in nfs4_find_ds_client() argument 66 list_for_each_entry_rcu(dss, &ds_clp->cl_ds_clients, list) { in nfs4_find_ds_client() 78 nfs4_add_ds_client(struct nfs_client *ds_clp, rpc_authflavor_t flavor, in nfs4_add_ds_client() argument 83 spin_lock(&ds_clp->cl_lock); in nfs4_add_ds_client() 84 list_for_each_entry(dss, &ds_clp->cl_ds_clients, list) { in nfs4_add_ds_client() 90 list_add_rcu(&new->list, &ds_clp->cl_ds_clients); in nfs4_add_ds_client() 93 spin_unlock(&ds_clp->cl_lock); /* need some lock to protect list */ in nfs4_add_ds_client() 98 nfs4_alloc_ds_server(struct nfs_client *ds_clp, rpc_authflavor_ argument 133 nfs4_find_or_create_ds_client(struct nfs_client *ds_clp, struct inode *inode) nfs4_find_or_create_ds_client() argument [all...] |
H A D | nfs4trace.h | 2010 __string(dstaddr, hdr->ds_clp ? 2011 rpc_peeraddr2str(hdr->ds_clp->cl_rpcclient, 2028 __assign_str(dstaddr, hdr->ds_clp ? 2029 rpc_peeraddr2str(hdr->ds_clp->cl_rpcclient, 2070 __string(dstaddr, data->ds_clp ? 2071 rpc_peeraddr2str(data->ds_clp->cl_rpcclient, 2084 __assign_str(dstaddr, data->ds_clp ? 2085 rpc_peeraddr2str(data->ds_clp->cl_rpcclient,
|
H A D | pnfs.h | 62 struct nfs_client *ds_clp; member
|
H A D | nfs4proc.c | 5466 if (nfs_server_capable(hdr->inode, NFS_CAP_READ_PLUS) && !hdr->ds_clp) { in nfs42_read_plus_support() 5563 if (hdr->ds_clp != NULL || hdr->dreq != NULL) in nfs4_write_need_cache_consistency_data() 5627 nfs4_state_protect_write(hdr->ds_clp ? hdr->ds_clp : server->nfs_client, clnt, msg, hdr); in nfs4_proc_write_setup() 5668 nfs4_state_protect(data->ds_clp ? data->ds_clp : server->nfs_client, in nfs4_proc_commit_setup()
|
/kernel/linux/linux-6.6/fs/nfs/flexfilelayout/ |
H A D | flexfilelayout.c | 1301 hdr->ds_clp, hdr->lseg, in ff_layout_read_done_cb() 1411 if (nfs4_setup_sequence(hdr->ds_clp, in ff_layout_read_prepare_v4() 1471 hdr->ds_clp, hdr->lseg, in ff_layout_write_done_cb() 1516 err = ff_layout_async_handle_error(task, NULL, data->ds_clp, in ff_layout_commit_done_cb() 1591 if (nfs4_setup_sequence(hdr->ds_clp, in ff_layout_write_prepare_v4() 1689 if (nfs4_setup_sequence(wdata->ds_clp, in ff_layout_commit_prepare_v4() 1783 ds_clnt = nfs4_ff_find_or_create_ds_client(mirror, ds->ds_clp, in ff_layout_read_pagelist() 1795 ds->ds_remotestr, refcount_read(&ds->ds_clp->cl_count), vers); in ff_layout_read_pagelist() 1798 refcount_inc(&ds->ds_clp->cl_count); in ff_layout_read_pagelist() 1799 hdr->ds_clp in ff_layout_read_pagelist() 2012 struct nfs_client *ds_clp; ff_layout_cancel_io() local [all...] |
H A D | flexfilelayoutdev.c | 383 if (READ_ONCE(ds->ds_clp)) in nfs4_ff_layout_prepare_ds() 399 nfs_block_size(rpc_max_payload(ds->ds_clp->cl_rpcclient), in nfs4_ff_layout_prepare_ds() 440 * @ds_clp: nfs_client for the DS 448 struct nfs_client *ds_clp, struct inode *inode) in nfs4_ff_find_or_create_ds_client() 453 return ds_clp->cl_rpcclient; in nfs4_ff_find_or_create_ds_client() 455 return nfs4_find_or_create_ds_client(ds_clp, inode); in nfs4_ff_find_or_create_ds_client() 447 nfs4_ff_find_or_create_ds_client(struct nfs4_ff_layout_mirror *mirror, struct nfs_client *ds_clp, struct inode *inode) nfs4_ff_find_or_create_ds_client() argument
|
H A D | flexfilelayout.h | 218 struct nfs_client *ds_clp,
|
/kernel/linux/linux-5.10/fs/nfs/flexfilelayout/ |
H A D | flexfilelayout.c | 1304 hdr->ds_clp, hdr->lseg, in ff_layout_read_done_cb() 1409 if (nfs4_setup_sequence(hdr->ds_clp, in ff_layout_read_prepare_v4() 1471 hdr->ds_clp, hdr->lseg, in ff_layout_write_done_cb() 1516 err = ff_layout_async_handle_error(task, NULL, data->ds_clp, in ff_layout_commit_done_cb() 1586 if (nfs4_setup_sequence(hdr->ds_clp, in ff_layout_write_prepare_v4() 1676 if (nfs4_setup_sequence(wdata->ds_clp, in ff_layout_commit_prepare_v4() 1770 ds_clnt = nfs4_ff_find_or_create_ds_client(mirror, ds->ds_clp, in ff_layout_read_pagelist() 1782 ds->ds_remotestr, refcount_read(&ds->ds_clp->cl_count), vers); in ff_layout_read_pagelist() 1785 refcount_inc(&ds->ds_clp->cl_count); in ff_layout_read_pagelist() 1786 hdr->ds_clp in ff_layout_read_pagelist() [all...] |
H A D | flexfilelayoutdev.c | 381 if (READ_ONCE(ds->ds_clp)) in nfs4_ff_layout_prepare_ds() 397 nfs_block_size(rpc_max_payload(ds->ds_clp->cl_rpcclient), in nfs4_ff_layout_prepare_ds() 438 * @ds_clp: nfs_client for the DS 446 struct nfs_client *ds_clp, struct inode *inode) in nfs4_ff_find_or_create_ds_client() 451 return ds_clp->cl_rpcclient; in nfs4_ff_find_or_create_ds_client() 453 return nfs4_find_or_create_ds_client(ds_clp, inode); in nfs4_ff_find_or_create_ds_client() 445 nfs4_ff_find_or_create_ds_client(struct nfs4_ff_layout_mirror *mirror, struct nfs_client *ds_clp, struct inode *inode) nfs4_ff_find_or_create_ds_client() argument
|
H A D | flexfilelayout.h | 218 struct nfs_client *ds_clp,
|
/kernel/linux/linux-5.10/include/linux/ |
H A D | nfs_xdr.h | 1618 struct nfs_client *ds_clp; /* pNFS data server */ member 1619 u32 ds_commit_idx; /* ds index if ds_clp is set */ 1658 struct nfs_client *ds_clp; /* pNFS data server */ member
|
/kernel/linux/linux-6.6/include/linux/ |
H A D | nfs_xdr.h | 1646 struct nfs_client *ds_clp; /* pNFS data server */ member 1647 u32 ds_commit_idx; /* ds index if ds_clp is set */ 1686 struct nfs_client *ds_clp; /* pNFS data server */ member
|