Lines Matching refs:clp
33 if (!cps->clp) /* Always set for v4.0. Set in cb_sequence for v4.1 */ in nfs4_callback_getattr()
40 rpc_peeraddr2str(cps->clp->cl_rpcclient, RPC_DISPLAY_ADDR)); in nfs4_callback_getattr()
42 inode = nfs_delegation_find_inode(cps->clp, &args->fh); in nfs4_callback_getattr()
46 trace_nfs4_cb_getattr(cps->clp, &args->fh, NULL, in nfs4_callback_getattr()
68 trace_nfs4_cb_getattr(cps->clp, &args->fh, inode, -ntohl(res->status)); in nfs4_callback_getattr()
83 if (!cps->clp) /* Always set for v4.0. Set in cb_sequence for v4.1 */ in nfs4_callback_recall()
87 rpc_peeraddr2str(cps->clp->cl_rpcclient, RPC_DISPLAY_ADDR)); in nfs4_callback_recall()
90 inode = nfs_delegation_find_inode(cps->clp, &args->fh); in nfs4_callback_recall()
94 trace_nfs4_cb_recall(cps->clp, &args->fh, NULL, in nfs4_callback_recall()
109 trace_nfs4_cb_recall(cps->clp, &args->fh, inode, in nfs4_callback_recall()
124 static struct inode *nfs_layout_find_inode_by_stateid(struct nfs_client *clp, in nfs_layout_find_inode_by_stateid() argument
131 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) { in nfs_layout_find_inode_by_stateid()
141 spin_unlock(&clp->cl_lock); in nfs_layout_find_inode_by_stateid()
143 spin_lock(&clp->cl_lock); in nfs_layout_find_inode_by_stateid()
160 static struct inode *nfs_layout_find_inode_by_fh(struct nfs_client *clp, in nfs_layout_find_inode_by_fh() argument
168 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) { in nfs_layout_find_inode_by_fh()
180 spin_unlock(&clp->cl_lock); in nfs_layout_find_inode_by_fh()
182 spin_lock(&clp->cl_lock); in nfs_layout_find_inode_by_fh()
193 static struct inode *nfs_layout_find_inode(struct nfs_client *clp, in nfs_layout_find_inode() argument
199 spin_lock(&clp->cl_lock); in nfs_layout_find_inode()
201 inode = nfs_layout_find_inode_by_stateid(clp, stateid); in nfs_layout_find_inode()
203 inode = nfs_layout_find_inode_by_fh(clp, fh); in nfs_layout_find_inode()
205 spin_unlock(&clp->cl_lock); in nfs_layout_find_inode()
248 static u32 initiate_file_draining(struct nfs_client *clp, in initiate_file_draining() argument
256 ino = nfs_layout_find_inode(clp, &args->cbl_fh, &args->cbl_stateid); in initiate_file_draining()
312 trace_nfs4_cb_layoutrecall_file(clp, &args->cbl_fh, ino, in initiate_file_draining()
317 static u32 initiate_bulk_draining(struct nfs_client *clp, in initiate_bulk_draining() argument
323 stat = pnfs_destroy_layouts_byfsid(clp, &args->cbl_fsid, true); in initiate_bulk_draining()
325 stat = pnfs_destroy_layouts_byclid(clp, true); in initiate_bulk_draining()
331 static u32 do_callback_layoutrecall(struct nfs_client *clp, in do_callback_layoutrecall() argument
335 return initiate_file_draining(clp, args); in do_callback_layoutrecall()
336 return initiate_bulk_draining(clp, args); in do_callback_layoutrecall()
345 if (cps->clp) in nfs4_callback_layoutrecall()
346 res = do_callback_layoutrecall(cps->clp, args); in nfs4_callback_layoutrecall()
350 static void pnfs_recall_all_layouts(struct nfs_client *clp) in pnfs_recall_all_layouts() argument
358 do_callback_layoutrecall(clp, &args); in pnfs_recall_all_layouts()
367 struct nfs_client *clp = cps->clp; in nfs4_callback_devicenotify() local
370 if (!clp) { in nfs4_callback_devicenotify()
381 list_for_each_entry_rcu(server, &clp->cl_superblocks, client_link) in nfs4_callback_devicenotify()
392 nfs4_delete_deviceid(server->pnfs_curr_ld, clp, &dev->cbd_dev_id); in nfs4_callback_devicenotify()
445 static int referring_call_exists(struct nfs_client *clp, in referring_call_exists() argument
463 session = clp->cl_session; in referring_call_exists()
495 struct nfs_client *clp; in nfs4_callback_sequence() local
499 clp = nfs4_find_client_sessionid(cps->net, args->csa_addr, in nfs4_callback_sequence()
501 if (clp == NULL) in nfs4_callback_sequence()
504 if (!(clp->cl_session->flags & SESSION4_BACK_CHAN)) in nfs4_callback_sequence()
507 tbl = &clp->cl_session->bc_slot_table; in nfs4_callback_sequence()
522 if (test_bit(NFS4CLNT_SESSION_RESET, &clp->cl_state)) in nfs4_callback_sequence()
555 if (referring_call_exists(clp, args->csa_nrclists, args->csa_rclists, in nfs4_callback_sequence()
571 cps->clp = clp; /* put in nfs4_callback_compound */ in nfs4_callback_sequence()
600 if (!cps->clp) /* set in cb_sequence */ in nfs4_callback_recallany()
604 rpc_peeraddr2str(cps->clp->cl_rpcclient, RPC_DISPLAY_ADDR)); in nfs4_callback_recallany()
616 nfs_expire_unused_delegation_types(cps->clp, flags); in nfs4_callback_recallany()
619 pnfs_recall_all_layouts(cps->clp); in nfs4_callback_recallany()
634 if (!cps->clp) /* set in cb_sequence */ in nfs4_callback_recallslot()
638 rpc_peeraddr2str(cps->clp->cl_rpcclient, RPC_DISPLAY_ADDR), in nfs4_callback_recallslot()
641 fc_tbl = &cps->clp->cl_session->fc_slot_table; in nfs4_callback_recallslot()
646 nfs41_notify_server(cps->clp); in nfs4_callback_recallslot()
657 if (!cps->clp) /* set in cb_sequence */ in nfs4_callback_notify_lock()
661 rpc_peeraddr2str(cps->clp->cl_rpcclient, RPC_DISPLAY_ADDR)); in nfs4_callback_notify_lock()
665 __wake_up(&cps->clp->cl_lock_waitq, TASK_NORMAL, 0, args); in nfs4_callback_notify_lock()
692 spin_lock(&cps->clp->cl_lock); in nfs4_callback_offload()
694 list_for_each_entry_rcu(server, &cps->clp->cl_superblocks, in nfs4_callback_offload()
712 spin_unlock(&cps->clp->cl_lock); in nfs4_callback_offload()
717 list_add_tail(©->copies, &cps->clp->pending_cb_stateids); in nfs4_callback_offload()
719 spin_unlock(&cps->clp->cl_lock); in nfs4_callback_offload()