net/sunrpc/rpc_pipe.c

7  * and fs/sysfs/inode.c
129  * Call with an @inode created by rpc_mkpipe() to queue an upcall.
131  * read on an open file for this inode.  It is up to the caller to
165 rpc_inode_setowner(struct inode *inode, void *private)
167 	RPC_I(inode)->private = private;
171 rpc_close_pipes(struct inode *inode)
173 	struct rpc_pipe *pipe = RPC_I(inode)->pipe;
177 	inode_lock(inode);
186 	rpc_purge_list(&RPC_I(inode)->waitq, &free_list, pipe->ops->destroy_msg, -EPIPE);
189 		pipe->ops->release_pipe(inode);
191 	rpc_inode_setowner(inode, NULL);
192 	RPC_I(inode)->pipe = NULL;
193 	inode_unlock(inode);
196 static struct inode *
207 rpc_free_inode(struct inode *inode)
209 	kmem_cache_free(rpc_inode_cachep, RPC_I(inode));
213 rpc_pipe_open(struct inode *inode, struct file *filp)
219 	inode_lock(inode);
220 	pipe = RPC_I(inode)->pipe;
225 		res = pipe->ops->open_pipe(inode);
235 	inode_unlock(inode);
240 rpc_pipe_release(struct inode *inode, struct file *filp)
246 	inode_lock(inode);
247 	pipe = RPC_I(inode)->pipe;
268 			rpc_purge_list(&RPC_I(inode)->waitq, &free_list,
274 		pipe->ops->release_pipe(inode);
276 	inode_unlock(inode);
283 	struct inode *inode = file_inode(filp);
288 	inode_lock(inode);
289 	pipe = RPC_I(inode)->pipe;
320 	inode_unlock(inode);
327 	struct inode *inode = file_inode(filp);
330 	inode_lock(inode);
332 	if (RPC_I(inode)->pipe != NULL)
333 		res = RPC_I(inode)->pipe->ops->downcall(filp, buf, len);
334 	inode_unlock(inode);
341 	struct inode *inode = file_inode(filp);
342 	struct rpc_inode *rpci = RPC_I(inode);
347 	inode_lock(inode);
352 	inode_unlock(inode);
359 	struct inode *inode = file_inode(filp);
365 		inode_lock(inode);
366 		pipe = RPC_I(inode)->pipe;
368 			inode_unlock(inode);
379 		inode_unlock(inode);
415 rpc_info_open(struct inode *inode, struct file *file)
425 			clnt = RPC_I(inode)->private;
431 			single_release(inode, file);
439 rpc_info_release(struct inode *inode, struct file *file)
446 	return single_release(inode, file);
467 static struct inode *
470 	struct inode *inode = new_inode(sb);
471 	if (!inode)
473 	inode->i_ino = get_next_ino();
474 	inode->i_mode = mode;
475 	simple_inode_init_ts(inode);
478 		inode->i_fop = &simple_dir_operations;
479 		inode->i_op = &simple_dir_inode_operations;
480 		inc_nlink(inode);
485 	return inode;
488 static int __rpc_create_common(struct inode *dir, struct dentry *dentry,
493 	struct inode *inode;
496 	inode = rpc_get_inode(dir->i_sb, mode);
497 	if (!inode)
499 	inode->i_ino = iunique(dir->i_sb, 100);
501 		inode->i_fop = i_fop;
503 		rpc_inode_setowner(inode, private);
504 	d_add(dentry, inode);
507 	printk(KERN_WARNING "%s: %s failed to allocate inode for dentry %pd\n",
513 static int __rpc_create(struct inode *dir, struct dentry *dentry,
527 static int __rpc_mkdir(struct inode *dir, struct dentry *dentry,
578 static int __rpc_mkpipe_dentry(struct inode *dir, struct dentry *dentry,
597 static int __rpc_rmdir(struct inode *dir, struct dentry *dentry)
610 static int __rpc_unlink(struct inode *dir, struct dentry *dentry)
623 static int __rpc_rmpipe(struct inode *dir, struct dentry *dentry)
625 	struct inode *inode = d_inode(dentry);
627 	rpc_close_pipes(inode);
654 	struct inode *dir = d_inode(parent);
686 	struct inode *dir = d_inode(parent);
698 	struct inode *dir = d_inode(parent);
741 	struct inode *dir = d_inode(parent);
770 	struct inode *dir;
807 	struct inode *dir = d_inode(parent);
848 	struct inode *dir;
1361 	struct inode *inode;
1374 	inode = rpc_get_inode(sb, S_IFDIR | 0555);
1375 	sb->s_root = root = d_make_root(inode);