Lines Matching refs:pipe
62 struct rpc_pipe *pipe; member
249 struct rpc_pipe *pipe; member
298 __gss_find_upcall(struct rpc_pipe *pipe, kuid_t uid, const struct gss_auth *auth) in __gss_find_upcall() argument
301 list_for_each_entry(pos, &pipe->in_downcall, list) { in __gss_find_upcall()
319 struct rpc_pipe *pipe = gss_msg->pipe; in gss_add_msg() local
322 spin_lock(&pipe->lock); in gss_add_msg()
323 old = __gss_find_upcall(pipe, gss_msg->uid, gss_msg->auth); in gss_add_msg()
326 list_add(&gss_msg->list, &pipe->in_downcall); in gss_add_msg()
329 spin_unlock(&pipe->lock); in gss_add_msg()
345 struct rpc_pipe *pipe = gss_msg->pipe; in gss_unhash_msg() local
349 spin_lock(&pipe->lock); in gss_unhash_msg()
352 spin_unlock(&pipe->lock); in gss_unhash_msg()
379 struct rpc_pipe *pipe = gss_msg->pipe; in gss_upcall_callback() local
381 spin_lock(&pipe->lock); in gss_upcall_callback()
383 spin_unlock(&pipe->lock); in gss_upcall_callback()
520 gss_msg->pipe = gss_auth->gss_pipe[vers]->pipe; in gss_alloc_msg()
559 res = rpc_queue_upcall(gss_new->pipe, &gss_new->msg); in gss_setup_upcall()
585 struct rpc_pipe *pipe; in gss_refresh_upcall() local
602 pipe = gss_msg->pipe; in gss_refresh_upcall()
603 spin_lock(&pipe->lock); in gss_refresh_upcall()
615 spin_unlock(&pipe->lock); in gss_refresh_upcall()
628 struct rpc_pipe *pipe; in gss_create_upcall() local
658 pipe = gss_msg->pipe; in gss_create_upcall()
661 spin_lock(&pipe->lock); in gss_create_upcall()
665 spin_unlock(&pipe->lock); in gss_create_upcall()
678 spin_unlock(&pipe->lock); in gss_create_upcall()
689 gss_find_downcall(struct rpc_pipe *pipe, kuid_t uid) in gss_find_downcall() argument
692 list_for_each_entry(pos, &pipe->in_downcall, list) { in gss_find_downcall()
711 struct rpc_pipe *pipe = RPC_I(file_inode(filp))->pipe; in gss_pipe_downcall() local
748 spin_lock(&pipe->lock); in gss_pipe_downcall()
749 gss_msg = gss_find_downcall(pipe, uid); in gss_pipe_downcall()
751 spin_unlock(&pipe->lock); in gss_pipe_downcall()
755 spin_unlock(&pipe->lock); in gss_pipe_downcall()
783 spin_lock(&pipe->lock); in gss_pipe_downcall()
785 spin_unlock(&pipe->lock); in gss_pipe_downcall()
833 struct rpc_pipe *pipe = RPC_I(inode)->pipe; in gss_pipe_release() local
837 spin_lock(&pipe->lock); in gss_pipe_release()
838 list_for_each_entry(gss_msg, &pipe->in_downcall, list) { in gss_pipe_release()
845 spin_unlock(&pipe->lock); in gss_pipe_release()
849 spin_unlock(&pipe->lock); in gss_pipe_release()
873 struct rpc_pipe *pipe = gss_pipe->pipe; in gss_pipe_dentry_destroy() local
875 if (pipe->dentry != NULL) { in gss_pipe_dentry_destroy()
876 rpc_unlink(pipe->dentry); in gss_pipe_dentry_destroy()
877 pipe->dentry = NULL; in gss_pipe_dentry_destroy()
887 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
890 p->pipe->dentry = dentry; in gss_pipe_dentry_create()
909 p->pipe = rpc_mkpipe_data(upcall_ops, RPC_PIPE_WAIT_FOR_OPEN); in gss_pipe_alloc()
910 if (IS_ERR(p->pipe)) { in gss_pipe_alloc()
911 err = PTR_ERR(p->pipe); in gss_pipe_alloc()
989 rpc_destroy_pipe_data(p->pipe); in __gss_pipe_free()