Lines Matching refs:pipe
83 struct rpc_pipe *pipe; member
295 struct rpc_pipe *pipe; member
343 __gss_find_upcall(struct rpc_pipe *pipe, kuid_t uid) in __gss_find_upcall() argument
346 list_for_each_entry(pos, &pipe->in_downcall, list) { in __gss_find_upcall()
364 struct rpc_pipe *pipe = gss_msg->pipe; in gss_add_msg() local
367 spin_lock(&pipe->lock); in gss_add_msg()
368 old = __gss_find_upcall(pipe, gss_msg->uid); in gss_add_msg()
371 list_add(&gss_msg->list, &pipe->in_downcall); in gss_add_msg()
374 spin_unlock(&pipe->lock); in gss_add_msg()
390 struct rpc_pipe *pipe = gss_msg->pipe; in gss_unhash_msg() local
394 spin_lock(&pipe->lock); in gss_unhash_msg()
397 spin_unlock(&pipe->lock); in gss_unhash_msg()
424 struct rpc_pipe *pipe = gss_msg->pipe; in gss_upcall_callback() local
426 spin_lock(&pipe->lock); in gss_upcall_callback()
428 spin_unlock(&pipe->lock); in gss_upcall_callback()
503 gss_msg->pipe = gss_auth->gss_pipe[vers]->pipe; in gss_alloc_msg()
542 int res = rpc_queue_upcall(gss_new->pipe, &gss_new->msg); in gss_setup_upcall()
566 struct rpc_pipe *pipe; in gss_refresh_upcall() local
584 pipe = gss_msg->pipe; in gss_refresh_upcall()
585 spin_lock(&pipe->lock); in gss_refresh_upcall()
598 spin_unlock(&pipe->lock); in gss_refresh_upcall()
612 struct rpc_pipe *pipe; in gss_create_upcall() local
643 pipe = gss_msg->pipe; in gss_create_upcall()
646 spin_lock(&pipe->lock); in gss_create_upcall()
650 spin_unlock(&pipe->lock); in gss_create_upcall()
661 spin_unlock(&pipe->lock); in gss_create_upcall()
679 struct rpc_pipe *pipe = RPC_I(file_inode(filp))->pipe; in gss_pipe_downcall() local
716 spin_lock(&pipe->lock); in gss_pipe_downcall()
717 gss_msg = __gss_find_upcall(pipe, uid); in gss_pipe_downcall()
719 spin_unlock(&pipe->lock); in gss_pipe_downcall()
723 spin_unlock(&pipe->lock); in gss_pipe_downcall()
751 spin_lock(&pipe->lock); in gss_pipe_downcall()
753 spin_unlock(&pipe->lock); in gss_pipe_downcall()
802 struct rpc_pipe *pipe = RPC_I(inode)->pipe; in gss_pipe_release() local
806 spin_lock(&pipe->lock); in gss_pipe_release()
807 list_for_each_entry(gss_msg, &pipe->in_downcall, list) { in gss_pipe_release()
814 spin_unlock(&pipe->lock); in gss_pipe_release()
818 spin_unlock(&pipe->lock); in gss_pipe_release()
843 struct rpc_pipe *pipe = gss_pipe->pipe; in gss_pipe_dentry_destroy() local
845 if (pipe->dentry != NULL) { in gss_pipe_dentry_destroy()
846 rpc_unlink(pipe->dentry); in gss_pipe_dentry_destroy()
847 pipe->dentry = NULL; in gss_pipe_dentry_destroy()
857 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
860 p->pipe->dentry = dentry; in gss_pipe_dentry_create()
879 p->pipe = rpc_mkpipe_data(upcall_ops, RPC_PIPE_WAIT_FOR_OPEN); in gss_pipe_alloc()
880 if (IS_ERR(p->pipe)) { in gss_pipe_alloc()
881 err = PTR_ERR(p->pipe); in gss_pipe_alloc()
959 rpc_destroy_pipe_data(p->pipe); in __gss_pipe_free()