Lines Matching refs:pipe
60 struct rpc_pipe *pipe; member
276 struct rpc_pipe *pipe; member
325 __gss_find_upcall(struct rpc_pipe *pipe, kuid_t uid, const struct gss_auth *auth) in __gss_find_upcall() argument
328 list_for_each_entry(pos, &pipe->in_downcall, list) { in __gss_find_upcall()
346 struct rpc_pipe *pipe = gss_msg->pipe; in gss_add_msg() local
349 spin_lock(&pipe->lock); in gss_add_msg()
350 old = __gss_find_upcall(pipe, gss_msg->uid, gss_msg->auth); in gss_add_msg()
353 list_add(&gss_msg->list, &pipe->in_downcall); in gss_add_msg()
356 spin_unlock(&pipe->lock); in gss_add_msg()
372 struct rpc_pipe *pipe = gss_msg->pipe; in gss_unhash_msg() local
376 spin_lock(&pipe->lock); in gss_unhash_msg()
379 spin_unlock(&pipe->lock); in gss_unhash_msg()
406 struct rpc_pipe *pipe = gss_msg->pipe; in gss_upcall_callback() local
408 spin_lock(&pipe->lock); in gss_upcall_callback()
410 spin_unlock(&pipe->lock); in gss_upcall_callback()
547 gss_msg->pipe = gss_auth->gss_pipe[vers]->pipe; in gss_alloc_msg()
586 res = rpc_queue_upcall(gss_new->pipe, &gss_new->msg); in gss_setup_upcall()
612 struct rpc_pipe *pipe; in gss_refresh_upcall() local
629 pipe = gss_msg->pipe; in gss_refresh_upcall()
630 spin_lock(&pipe->lock); in gss_refresh_upcall()
642 spin_unlock(&pipe->lock); in gss_refresh_upcall()
655 struct rpc_pipe *pipe; in gss_create_upcall() local
685 pipe = gss_msg->pipe; in gss_create_upcall()
688 spin_lock(&pipe->lock); in gss_create_upcall()
692 spin_unlock(&pipe->lock); in gss_create_upcall()
703 spin_unlock(&pipe->lock); in gss_create_upcall()
721 struct rpc_pipe *pipe = RPC_I(file_inode(filp))->pipe; in gss_pipe_downcall() local
758 spin_lock(&pipe->lock); in gss_pipe_downcall()
759 gss_msg = __gss_find_upcall(pipe, uid, NULL); in gss_pipe_downcall()
761 spin_unlock(&pipe->lock); in gss_pipe_downcall()
765 spin_unlock(&pipe->lock); in gss_pipe_downcall()
793 spin_lock(&pipe->lock); in gss_pipe_downcall()
795 spin_unlock(&pipe->lock); in gss_pipe_downcall()
843 struct rpc_pipe *pipe = RPC_I(inode)->pipe; in gss_pipe_release() local
847 spin_lock(&pipe->lock); in gss_pipe_release()
848 list_for_each_entry(gss_msg, &pipe->in_downcall, list) { in gss_pipe_release()
855 spin_unlock(&pipe->lock); in gss_pipe_release()
859 spin_unlock(&pipe->lock); in gss_pipe_release()
883 struct rpc_pipe *pipe = gss_pipe->pipe; in gss_pipe_dentry_destroy() local
885 if (pipe->dentry != NULL) { in gss_pipe_dentry_destroy()
886 rpc_unlink(pipe->dentry); in gss_pipe_dentry_destroy()
887 pipe->dentry = NULL; in gss_pipe_dentry_destroy()
897 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
900 p->pipe->dentry = dentry; in gss_pipe_dentry_create()
919 p->pipe = rpc_mkpipe_data(upcall_ops, RPC_PIPE_WAIT_FOR_OPEN); in gss_pipe_alloc()
920 if (IS_ERR(p->pipe)) { in gss_pipe_alloc()
921 err = PTR_ERR(p->pipe); in gss_pipe_alloc()
999 rpc_destroy_pipe_data(p->pipe); in __gss_pipe_free()