• Home
  • Raw
  • Download

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()
544 res = rpc_queue_upcall(gss_new->pipe, &gss_new->msg); in gss_setup_upcall()
570 struct rpc_pipe *pipe; in gss_refresh_upcall() local
588 pipe = gss_msg->pipe; in gss_refresh_upcall()
589 spin_lock(&pipe->lock); in gss_refresh_upcall()
602 spin_unlock(&pipe->lock); in gss_refresh_upcall()
616 struct rpc_pipe *pipe; in gss_create_upcall() local
647 pipe = gss_msg->pipe; in gss_create_upcall()
650 spin_lock(&pipe->lock); in gss_create_upcall()
654 spin_unlock(&pipe->lock); in gss_create_upcall()
665 spin_unlock(&pipe->lock); in gss_create_upcall()
683 struct rpc_pipe *pipe = RPC_I(file_inode(filp))->pipe; in gss_pipe_downcall() local
720 spin_lock(&pipe->lock); in gss_pipe_downcall()
721 gss_msg = __gss_find_upcall(pipe, uid); in gss_pipe_downcall()
723 spin_unlock(&pipe->lock); in gss_pipe_downcall()
727 spin_unlock(&pipe->lock); in gss_pipe_downcall()
755 spin_lock(&pipe->lock); in gss_pipe_downcall()
757 spin_unlock(&pipe->lock); in gss_pipe_downcall()
806 struct rpc_pipe *pipe = RPC_I(inode)->pipe; in gss_pipe_release() local
810 spin_lock(&pipe->lock); in gss_pipe_release()
811 list_for_each_entry(gss_msg, &pipe->in_downcall, list) { in gss_pipe_release()
818 spin_unlock(&pipe->lock); in gss_pipe_release()
822 spin_unlock(&pipe->lock); in gss_pipe_release()
848 struct rpc_pipe *pipe = gss_pipe->pipe; in gss_pipe_dentry_destroy() local
850 if (pipe->dentry != NULL) { in gss_pipe_dentry_destroy()
851 rpc_unlink(pipe->dentry); in gss_pipe_dentry_destroy()
852 pipe->dentry = NULL; in gss_pipe_dentry_destroy()
862 dentry = rpc_mkpipe_dentry(dir, p->name, p->clnt, p->pipe); in gss_pipe_dentry_create()
865 p->pipe->dentry = dentry; in gss_pipe_dentry_create()
884 p->pipe = rpc_mkpipe_data(upcall_ops, RPC_PIPE_WAIT_FOR_OPEN); in gss_pipe_alloc()
885 if (IS_ERR(p->pipe)) { in gss_pipe_alloc()
886 err = PTR_ERR(p->pipe); in gss_pipe_alloc()
964 rpc_destroy_pipe_data(p->pipe); in __gss_pipe_free()