Lines Matching refs:pipe
84 struct rpc_pipe *pipe; member
267 struct rpc_pipe *pipe; member
315 __gss_find_upcall(struct rpc_pipe *pipe, kuid_t uid, const struct gss_auth *auth) in __gss_find_upcall() argument
318 list_for_each_entry(pos, &pipe->in_downcall, list) { in __gss_find_upcall()
338 struct rpc_pipe *pipe = gss_msg->pipe; in gss_add_msg() local
341 spin_lock(&pipe->lock); in gss_add_msg()
342 old = __gss_find_upcall(pipe, gss_msg->uid, gss_msg->auth); in gss_add_msg()
345 list_add(&gss_msg->list, &pipe->in_downcall); in gss_add_msg()
348 spin_unlock(&pipe->lock); in gss_add_msg()
364 struct rpc_pipe *pipe = gss_msg->pipe; in gss_unhash_msg() local
368 spin_lock(&pipe->lock); in gss_unhash_msg()
371 spin_unlock(&pipe->lock); in gss_unhash_msg()
398 struct rpc_pipe *pipe = gss_msg->pipe; in gss_upcall_callback() local
400 spin_lock(&pipe->lock); in gss_upcall_callback()
402 spin_unlock(&pipe->lock); in gss_upcall_callback()
477 gss_msg->pipe = gss_auth->gss_pipe[vers]->pipe; in gss_alloc_msg()
518 res = rpc_queue_upcall(gss_new->pipe, &gss_new->msg); in gss_setup_upcall()
544 struct rpc_pipe *pipe; in gss_refresh_upcall() local
562 pipe = gss_msg->pipe; in gss_refresh_upcall()
563 spin_lock(&pipe->lock); in gss_refresh_upcall()
576 spin_unlock(&pipe->lock); in gss_refresh_upcall()
590 struct rpc_pipe *pipe; in gss_create_upcall() local
621 pipe = gss_msg->pipe; in gss_create_upcall()
624 spin_lock(&pipe->lock); in gss_create_upcall()
628 spin_unlock(&pipe->lock); in gss_create_upcall()
639 spin_unlock(&pipe->lock); in gss_create_upcall()
657 struct rpc_pipe *pipe = RPC_I(file_inode(filp))->pipe; in gss_pipe_downcall() local
694 spin_lock(&pipe->lock); in gss_pipe_downcall()
695 gss_msg = __gss_find_upcall(pipe, uid, NULL); in gss_pipe_downcall()
697 spin_unlock(&pipe->lock); in gss_pipe_downcall()
701 spin_unlock(&pipe->lock); in gss_pipe_downcall()
729 spin_lock(&pipe->lock); in gss_pipe_downcall()
731 spin_unlock(&pipe->lock); in gss_pipe_downcall()
780 struct rpc_pipe *pipe = RPC_I(inode)->pipe; in gss_pipe_release() local
784 spin_lock(&pipe->lock); in gss_pipe_release()
785 list_for_each_entry(gss_msg, &pipe->in_downcall, list) { in gss_pipe_release()
792 spin_unlock(&pipe->lock); in gss_pipe_release()
796 spin_unlock(&pipe->lock); in gss_pipe_release()
822 struct rpc_pipe *pipe = gss_pipe->pipe; in gss_pipe_dentry_destroy() local
824 if (pipe->dentry != NULL) { in gss_pipe_dentry_destroy()
825 rpc_unlink(pipe->dentry); in gss_pipe_dentry_destroy()
826 pipe->dentry = NULL; in gss_pipe_dentry_destroy()
836 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
839 p->pipe->dentry = dentry; in gss_pipe_dentry_create()
858 p->pipe = rpc_mkpipe_data(upcall_ops, RPC_PIPE_WAIT_FOR_OPEN); in gss_pipe_alloc()
859 if (IS_ERR(p->pipe)) { in gss_pipe_alloc()
860 err = PTR_ERR(p->pipe); in gss_pipe_alloc()
938 rpc_destroy_pipe_data(p->pipe); in __gss_pipe_free()