2005-04-16 16:20:36 -06:00
|
|
|
/*
|
|
|
|
* net/sunrpc/rpc_pipe.c
|
|
|
|
*
|
|
|
|
* Userland/kernel interface for rpcauth_gss.
|
|
|
|
* Code shamelessly plagiarized from fs/nfsd/nfsctl.c
|
2005-09-02 00:59:25 -06:00
|
|
|
* and fs/sysfs/inode.c
|
2005-04-16 16:20:36 -06:00
|
|
|
*
|
|
|
|
* Copyright (c) 2002, Trond Myklebust <trond.myklebust@fys.uio.no>
|
|
|
|
*
|
|
|
|
*/
|
|
|
|
#include <linux/module.h>
|
|
|
|
#include <linux/slab.h>
|
|
|
|
#include <linux/string.h>
|
|
|
|
#include <linux/pagemap.h>
|
|
|
|
#include <linux/mount.h>
|
|
|
|
#include <linux/namei.h>
|
2007-06-07 20:44:34 -06:00
|
|
|
#include <linux/fsnotify.h>
|
2005-04-16 16:20:36 -06:00
|
|
|
#include <linux/kernel.h>
|
|
|
|
|
|
|
|
#include <asm/ioctls.h>
|
|
|
|
#include <linux/fs.h>
|
|
|
|
#include <linux/poll.h>
|
|
|
|
#include <linux/wait.h>
|
|
|
|
#include <linux/seq_file.h>
|
|
|
|
|
|
|
|
#include <linux/sunrpc/clnt.h>
|
|
|
|
#include <linux/workqueue.h>
|
|
|
|
#include <linux/sunrpc/rpc_pipe_fs.h>
|
|
|
|
|
2005-08-26 13:05:31 -06:00
|
|
|
static struct vfsmount *rpc_mount __read_mostly;
|
2005-04-16 16:20:36 -06:00
|
|
|
static int rpc_mount_count;
|
|
|
|
|
|
|
|
static struct file_system_type rpc_pipe_fs_type;
|
|
|
|
|
|
|
|
|
2006-12-06 21:33:20 -07:00
|
|
|
static struct kmem_cache *rpc_inode_cachep __read_mostly;
|
2005-04-16 16:20:36 -06:00
|
|
|
|
|
|
|
#define RPC_UPCALL_TIMEOUT (30*HZ)
|
|
|
|
|
2006-02-01 10:18:44 -07:00
|
|
|
static void rpc_purge_list(struct rpc_inode *rpci, struct list_head *head,
|
|
|
|
void (*destroy_msg)(struct rpc_pipe_msg *), int err)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
|
|
|
struct rpc_pipe_msg *msg;
|
|
|
|
|
2006-02-01 10:18:44 -07:00
|
|
|
if (list_empty(head))
|
|
|
|
return;
|
|
|
|
do {
|
2005-11-25 15:10:11 -07:00
|
|
|
msg = list_entry(head->next, struct rpc_pipe_msg, list);
|
2006-02-01 10:18:44 -07:00
|
|
|
list_del(&msg->list);
|
2005-04-16 16:20:36 -06:00
|
|
|
msg->errno = err;
|
2005-11-25 15:10:11 -07:00
|
|
|
destroy_msg(msg);
|
2006-02-01 10:18:44 -07:00
|
|
|
} while (!list_empty(head));
|
2005-04-16 16:20:36 -06:00
|
|
|
wake_up(&rpci->waitq);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2006-11-22 07:55:48 -07:00
|
|
|
rpc_timeout_upcall_queue(struct work_struct *work)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
2006-02-01 10:18:44 -07:00
|
|
|
LIST_HEAD(free_list);
|
2006-11-22 07:55:48 -07:00
|
|
|
struct rpc_inode *rpci =
|
|
|
|
container_of(work, struct rpc_inode, queue_timeout.work);
|
2005-04-16 16:20:36 -06:00
|
|
|
struct inode *inode = &rpci->vfs_inode;
|
2006-02-01 10:18:44 -07:00
|
|
|
void (*destroy_msg)(struct rpc_pipe_msg *);
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2006-02-01 10:18:44 -07:00
|
|
|
spin_lock(&inode->i_lock);
|
|
|
|
if (rpci->ops == NULL) {
|
|
|
|
spin_unlock(&inode->i_lock);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
destroy_msg = rpci->ops->destroy_msg;
|
|
|
|
if (rpci->nreaders == 0) {
|
|
|
|
list_splice_init(&rpci->pipe, &free_list);
|
|
|
|
rpci->pipelen = 0;
|
|
|
|
}
|
|
|
|
spin_unlock(&inode->i_lock);
|
|
|
|
rpc_purge_list(rpci, &free_list, destroy_msg, -ETIMEDOUT);
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
|
2007-11-06 11:06:03 -07:00
|
|
|
/**
|
|
|
|
* rpc_queue_upcall
|
|
|
|
* @inode: inode of upcall pipe on which to queue given message
|
|
|
|
* @msg: message to queue
|
|
|
|
*
|
|
|
|
* Call with an @inode created by rpc_mkpipe() to queue an upcall.
|
|
|
|
* A userspace process may then later read the upcall by performing a
|
|
|
|
* read on an open file for this inode. It is up to the caller to
|
|
|
|
* initialize the fields of @msg (other than @msg->list) appropriately.
|
|
|
|
*/
|
2005-04-16 16:20:36 -06:00
|
|
|
int
|
|
|
|
rpc_queue_upcall(struct inode *inode, struct rpc_pipe_msg *msg)
|
|
|
|
{
|
|
|
|
struct rpc_inode *rpci = RPC_I(inode);
|
2005-10-27 20:12:46 -06:00
|
|
|
int res = -EPIPE;
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2006-02-01 10:18:44 -07:00
|
|
|
spin_lock(&inode->i_lock);
|
2005-10-27 20:12:46 -06:00
|
|
|
if (rpci->ops == NULL)
|
|
|
|
goto out;
|
2005-04-16 16:20:36 -06:00
|
|
|
if (rpci->nreaders) {
|
|
|
|
list_add_tail(&msg->list, &rpci->pipe);
|
|
|
|
rpci->pipelen += msg->len;
|
2005-10-27 20:12:46 -06:00
|
|
|
res = 0;
|
2005-04-16 16:20:36 -06:00
|
|
|
} else if (rpci->flags & RPC_PIPE_WAIT_FOR_OPEN) {
|
|
|
|
if (list_empty(&rpci->pipe))
|
2006-03-20 11:44:08 -07:00
|
|
|
queue_delayed_work(rpciod_workqueue,
|
|
|
|
&rpci->queue_timeout,
|
2005-04-16 16:20:36 -06:00
|
|
|
RPC_UPCALL_TIMEOUT);
|
|
|
|
list_add_tail(&msg->list, &rpci->pipe);
|
|
|
|
rpci->pipelen += msg->len;
|
2005-10-27 20:12:46 -06:00
|
|
|
res = 0;
|
|
|
|
}
|
|
|
|
out:
|
2006-02-01 10:18:44 -07:00
|
|
|
spin_unlock(&inode->i_lock);
|
2005-04-16 16:20:36 -06:00
|
|
|
wake_up(&rpci->waitq);
|
|
|
|
return res;
|
|
|
|
}
|
2008-12-23 13:21:31 -07:00
|
|
|
EXPORT_SYMBOL_GPL(rpc_queue_upcall);
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2005-10-27 20:12:46 -06:00
|
|
|
static inline void
|
|
|
|
rpc_inode_setowner(struct inode *inode, void *private)
|
|
|
|
{
|
|
|
|
RPC_I(inode)->private = private;
|
|
|
|
}
|
|
|
|
|
2005-04-16 16:20:36 -06:00
|
|
|
static void
|
|
|
|
rpc_close_pipes(struct inode *inode)
|
|
|
|
{
|
|
|
|
struct rpc_inode *rpci = RPC_I(inode);
|
2009-08-09 13:14:15 -06:00
|
|
|
const struct rpc_pipe_ops *ops;
|
2008-12-23 14:09:47 -07:00
|
|
|
int need_release;
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_lock(&inode->i_mutex);
|
2006-02-01 10:18:44 -07:00
|
|
|
ops = rpci->ops;
|
|
|
|
if (ops != NULL) {
|
|
|
|
LIST_HEAD(free_list);
|
|
|
|
spin_lock(&inode->i_lock);
|
2008-12-23 14:09:47 -07:00
|
|
|
need_release = rpci->nreaders != 0 || rpci->nwriters != 0;
|
2005-04-16 16:20:36 -06:00
|
|
|
rpci->nreaders = 0;
|
2006-02-01 10:18:44 -07:00
|
|
|
list_splice_init(&rpci->in_upcall, &free_list);
|
|
|
|
list_splice_init(&rpci->pipe, &free_list);
|
|
|
|
rpci->pipelen = 0;
|
2005-04-16 16:20:36 -06:00
|
|
|
rpci->ops = NULL;
|
2006-02-01 10:18:44 -07:00
|
|
|
spin_unlock(&inode->i_lock);
|
|
|
|
rpc_purge_list(rpci, &free_list, ops->destroy_msg, -EPIPE);
|
|
|
|
rpci->nwriters = 0;
|
2008-12-23 14:09:47 -07:00
|
|
|
if (need_release && ops->release_pipe)
|
2006-02-01 10:18:44 -07:00
|
|
|
ops->release_pipe(inode);
|
2007-08-07 13:33:01 -06:00
|
|
|
cancel_delayed_work_sync(&rpci->queue_timeout);
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
2005-10-27 20:12:46 -06:00
|
|
|
rpc_inode_setowner(inode, NULL);
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
|
|
|
|
static struct inode *
|
|
|
|
rpc_alloc_inode(struct super_block *sb)
|
|
|
|
{
|
|
|
|
struct rpc_inode *rpci;
|
2006-12-06 21:33:17 -07:00
|
|
|
rpci = (struct rpc_inode *)kmem_cache_alloc(rpc_inode_cachep, GFP_KERNEL);
|
2005-04-16 16:20:36 -06:00
|
|
|
if (!rpci)
|
|
|
|
return NULL;
|
|
|
|
return &rpci->vfs_inode;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
rpc_destroy_inode(struct inode *inode)
|
|
|
|
{
|
|
|
|
kmem_cache_free(rpc_inode_cachep, RPC_I(inode));
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
rpc_pipe_open(struct inode *inode, struct file *filp)
|
|
|
|
{
|
|
|
|
struct rpc_inode *rpci = RPC_I(inode);
|
2008-12-23 14:08:32 -07:00
|
|
|
int first_open;
|
2005-04-16 16:20:36 -06:00
|
|
|
int res = -ENXIO;
|
|
|
|
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_lock(&inode->i_mutex);
|
2008-12-23 14:08:32 -07:00
|
|
|
if (rpci->ops == NULL)
|
|
|
|
goto out;
|
|
|
|
first_open = rpci->nreaders == 0 && rpci->nwriters == 0;
|
|
|
|
if (first_open && rpci->ops->open_pipe) {
|
|
|
|
res = rpci->ops->open_pipe(inode);
|
|
|
|
if (res)
|
|
|
|
goto out;
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
2008-12-23 14:08:32 -07:00
|
|
|
if (filp->f_mode & FMODE_READ)
|
|
|
|
rpci->nreaders++;
|
|
|
|
if (filp->f_mode & FMODE_WRITE)
|
|
|
|
rpci->nwriters++;
|
|
|
|
res = 0;
|
|
|
|
out:
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
return res;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
rpc_pipe_release(struct inode *inode, struct file *filp)
|
|
|
|
{
|
2006-01-03 01:55:36 -07:00
|
|
|
struct rpc_inode *rpci = RPC_I(inode);
|
2005-04-16 16:20:36 -06:00
|
|
|
struct rpc_pipe_msg *msg;
|
2008-12-23 14:09:47 -07:00
|
|
|
int last_close;
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_lock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
if (rpci->ops == NULL)
|
|
|
|
goto out;
|
|
|
|
msg = (struct rpc_pipe_msg *)filp->private_data;
|
|
|
|
if (msg != NULL) {
|
2006-02-01 10:18:44 -07:00
|
|
|
spin_lock(&inode->i_lock);
|
2005-12-19 15:11:22 -07:00
|
|
|
msg->errno = -EAGAIN;
|
2006-02-01 10:18:44 -07:00
|
|
|
list_del(&msg->list);
|
|
|
|
spin_unlock(&inode->i_lock);
|
2005-04-16 16:20:36 -06:00
|
|
|
rpci->ops->destroy_msg(msg);
|
|
|
|
}
|
|
|
|
if (filp->f_mode & FMODE_WRITE)
|
|
|
|
rpci->nwriters --;
|
2006-02-01 10:18:44 -07:00
|
|
|
if (filp->f_mode & FMODE_READ) {
|
2005-04-16 16:20:36 -06:00
|
|
|
rpci->nreaders --;
|
2006-02-01 10:18:44 -07:00
|
|
|
if (rpci->nreaders == 0) {
|
|
|
|
LIST_HEAD(free_list);
|
|
|
|
spin_lock(&inode->i_lock);
|
|
|
|
list_splice_init(&rpci->pipe, &free_list);
|
|
|
|
rpci->pipelen = 0;
|
|
|
|
spin_unlock(&inode->i_lock);
|
|
|
|
rpc_purge_list(rpci, &free_list,
|
|
|
|
rpci->ops->destroy_msg, -EAGAIN);
|
|
|
|
}
|
|
|
|
}
|
2008-12-23 14:09:47 -07:00
|
|
|
last_close = rpci->nwriters == 0 && rpci->nreaders == 0;
|
|
|
|
if (last_close && rpci->ops->release_pipe)
|
2005-04-16 16:20:36 -06:00
|
|
|
rpci->ops->release_pipe(inode);
|
|
|
|
out:
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static ssize_t
|
|
|
|
rpc_pipe_read(struct file *filp, char __user *buf, size_t len, loff_t *offset)
|
|
|
|
{
|
2006-12-08 03:37:42 -07:00
|
|
|
struct inode *inode = filp->f_path.dentry->d_inode;
|
2005-04-16 16:20:36 -06:00
|
|
|
struct rpc_inode *rpci = RPC_I(inode);
|
|
|
|
struct rpc_pipe_msg *msg;
|
|
|
|
int res = 0;
|
|
|
|
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_lock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
if (rpci->ops == NULL) {
|
|
|
|
res = -EPIPE;
|
|
|
|
goto out_unlock;
|
|
|
|
}
|
|
|
|
msg = filp->private_data;
|
|
|
|
if (msg == NULL) {
|
2006-02-01 10:18:44 -07:00
|
|
|
spin_lock(&inode->i_lock);
|
2005-04-16 16:20:36 -06:00
|
|
|
if (!list_empty(&rpci->pipe)) {
|
|
|
|
msg = list_entry(rpci->pipe.next,
|
|
|
|
struct rpc_pipe_msg,
|
|
|
|
list);
|
|
|
|
list_move(&msg->list, &rpci->in_upcall);
|
|
|
|
rpci->pipelen -= msg->len;
|
|
|
|
filp->private_data = msg;
|
|
|
|
msg->copied = 0;
|
|
|
|
}
|
2006-02-01 10:18:44 -07:00
|
|
|
spin_unlock(&inode->i_lock);
|
2005-04-16 16:20:36 -06:00
|
|
|
if (msg == NULL)
|
|
|
|
goto out_unlock;
|
|
|
|
}
|
|
|
|
/* NOTE: it is up to the callback to update msg->copied */
|
|
|
|
res = rpci->ops->upcall(filp, msg, buf, len);
|
|
|
|
if (res < 0 || msg->len == msg->copied) {
|
|
|
|
filp->private_data = NULL;
|
2006-02-01 10:18:44 -07:00
|
|
|
spin_lock(&inode->i_lock);
|
|
|
|
list_del(&msg->list);
|
|
|
|
spin_unlock(&inode->i_lock);
|
2005-04-16 16:20:36 -06:00
|
|
|
rpci->ops->destroy_msg(msg);
|
|
|
|
}
|
|
|
|
out_unlock:
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
return res;
|
|
|
|
}
|
|
|
|
|
|
|
|
static ssize_t
|
|
|
|
rpc_pipe_write(struct file *filp, const char __user *buf, size_t len, loff_t *offset)
|
|
|
|
{
|
2006-12-08 03:37:42 -07:00
|
|
|
struct inode *inode = filp->f_path.dentry->d_inode;
|
2005-04-16 16:20:36 -06:00
|
|
|
struct rpc_inode *rpci = RPC_I(inode);
|
|
|
|
int res;
|
|
|
|
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_lock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
res = -EPIPE;
|
|
|
|
if (rpci->ops != NULL)
|
|
|
|
res = rpci->ops->downcall(filp, buf, len);
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
return res;
|
|
|
|
}
|
|
|
|
|
|
|
|
static unsigned int
|
|
|
|
rpc_pipe_poll(struct file *filp, struct poll_table_struct *wait)
|
|
|
|
{
|
|
|
|
struct rpc_inode *rpci;
|
|
|
|
unsigned int mask = 0;
|
|
|
|
|
2006-12-08 03:37:42 -07:00
|
|
|
rpci = RPC_I(filp->f_path.dentry->d_inode);
|
2005-04-16 16:20:36 -06:00
|
|
|
poll_wait(filp, &rpci->waitq, wait);
|
|
|
|
|
|
|
|
mask = POLLOUT | POLLWRNORM;
|
|
|
|
if (rpci->ops == NULL)
|
|
|
|
mask |= POLLERR | POLLHUP;
|
2007-11-06 11:05:36 -07:00
|
|
|
if (filp->private_data || !list_empty(&rpci->pipe))
|
2005-04-16 16:20:36 -06:00
|
|
|
mask |= POLLIN | POLLRDNORM;
|
|
|
|
return mask;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
rpc_pipe_ioctl(struct inode *ino, struct file *filp,
|
|
|
|
unsigned int cmd, unsigned long arg)
|
|
|
|
{
|
2006-12-08 03:37:42 -07:00
|
|
|
struct rpc_inode *rpci = RPC_I(filp->f_path.dentry->d_inode);
|
2005-04-16 16:20:36 -06:00
|
|
|
int len;
|
|
|
|
|
|
|
|
switch (cmd) {
|
|
|
|
case FIONREAD:
|
|
|
|
if (rpci->ops == NULL)
|
|
|
|
return -EPIPE;
|
|
|
|
len = rpci->pipelen;
|
|
|
|
if (filp->private_data) {
|
|
|
|
struct rpc_pipe_msg *msg;
|
|
|
|
msg = (struct rpc_pipe_msg *)filp->private_data;
|
|
|
|
len += msg->len - msg->copied;
|
|
|
|
}
|
|
|
|
return put_user(len, (int __user *)arg);
|
|
|
|
default:
|
|
|
|
return -EINVAL;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2007-02-12 01:55:36 -07:00
|
|
|
static const struct file_operations rpc_pipe_fops = {
|
2005-04-16 16:20:36 -06:00
|
|
|
.owner = THIS_MODULE,
|
|
|
|
.llseek = no_llseek,
|
|
|
|
.read = rpc_pipe_read,
|
|
|
|
.write = rpc_pipe_write,
|
|
|
|
.poll = rpc_pipe_poll,
|
|
|
|
.ioctl = rpc_pipe_ioctl,
|
|
|
|
.open = rpc_pipe_open,
|
|
|
|
.release = rpc_pipe_release,
|
|
|
|
};
|
|
|
|
|
|
|
|
static int
|
|
|
|
rpc_show_info(struct seq_file *m, void *v)
|
|
|
|
{
|
|
|
|
struct rpc_clnt *clnt = m->private;
|
|
|
|
|
|
|
|
seq_printf(m, "RPC server: %s\n", clnt->cl_server);
|
|
|
|
seq_printf(m, "service: %s (%d) version %d\n", clnt->cl_protname,
|
|
|
|
clnt->cl_prog, clnt->cl_vers);
|
2006-08-22 18:06:19 -06:00
|
|
|
seq_printf(m, "address: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_ADDR));
|
|
|
|
seq_printf(m, "protocol: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_PROTO));
|
2007-09-26 12:38:09 -06:00
|
|
|
seq_printf(m, "port: %s\n", rpc_peeraddr2str(clnt, RPC_DISPLAY_PORT));
|
2005-04-16 16:20:36 -06:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
rpc_info_open(struct inode *inode, struct file *file)
|
|
|
|
{
|
|
|
|
struct rpc_clnt *clnt;
|
|
|
|
int ret = single_open(file, rpc_show_info, NULL);
|
|
|
|
|
|
|
|
if (!ret) {
|
|
|
|
struct seq_file *m = file->private_data;
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_lock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
clnt = RPC_I(inode)->private;
|
|
|
|
if (clnt) {
|
2007-06-14 14:40:31 -06:00
|
|
|
kref_get(&clnt->cl_kref);
|
2005-04-16 16:20:36 -06:00
|
|
|
m->private = clnt;
|
|
|
|
} else {
|
|
|
|
single_release(inode, file);
|
|
|
|
ret = -EINVAL;
|
|
|
|
}
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&inode->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
rpc_info_release(struct inode *inode, struct file *file)
|
|
|
|
{
|
|
|
|
struct seq_file *m = file->private_data;
|
|
|
|
struct rpc_clnt *clnt = (struct rpc_clnt *)m->private;
|
|
|
|
|
|
|
|
if (clnt)
|
|
|
|
rpc_release_client(clnt);
|
|
|
|
return single_release(inode, file);
|
|
|
|
}
|
|
|
|
|
2007-02-12 01:55:36 -07:00
|
|
|
static const struct file_operations rpc_info_operations = {
|
2005-04-16 16:20:36 -06:00
|
|
|
.owner = THIS_MODULE,
|
|
|
|
.open = rpc_info_open,
|
|
|
|
.read = seq_read,
|
|
|
|
.llseek = seq_lseek,
|
|
|
|
.release = rpc_info_release,
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
* We have a single directory with 1 node in it.
|
|
|
|
*/
|
|
|
|
enum {
|
|
|
|
RPCAUTH_Root = 1,
|
|
|
|
RPCAUTH_lockd,
|
|
|
|
RPCAUTH_mount,
|
|
|
|
RPCAUTH_nfs,
|
|
|
|
RPCAUTH_portmap,
|
|
|
|
RPCAUTH_statd,
|
2008-12-23 14:19:00 -07:00
|
|
|
RPCAUTH_nfsd4_cb,
|
2005-04-16 16:20:36 -06:00
|
|
|
RPCAUTH_RootEOF
|
|
|
|
};
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Description of fs contents.
|
|
|
|
*/
|
|
|
|
struct rpc_filelist {
|
|
|
|
char *name;
|
2006-03-28 02:56:41 -07:00
|
|
|
const struct file_operations *i_fop;
|
2009-08-09 13:14:16 -06:00
|
|
|
umode_t mode;
|
2005-04-16 16:20:36 -06:00
|
|
|
};
|
|
|
|
|
|
|
|
static struct rpc_filelist files[] = {
|
|
|
|
[RPCAUTH_lockd] = {
|
|
|
|
.name = "lockd",
|
|
|
|
.mode = S_IFDIR | S_IRUGO | S_IXUGO,
|
|
|
|
},
|
|
|
|
[RPCAUTH_mount] = {
|
|
|
|
.name = "mount",
|
|
|
|
.mode = S_IFDIR | S_IRUGO | S_IXUGO,
|
|
|
|
},
|
|
|
|
[RPCAUTH_nfs] = {
|
|
|
|
.name = "nfs",
|
|
|
|
.mode = S_IFDIR | S_IRUGO | S_IXUGO,
|
|
|
|
},
|
|
|
|
[RPCAUTH_portmap] = {
|
|
|
|
.name = "portmap",
|
|
|
|
.mode = S_IFDIR | S_IRUGO | S_IXUGO,
|
|
|
|
},
|
|
|
|
[RPCAUTH_statd] = {
|
|
|
|
.name = "statd",
|
|
|
|
.mode = S_IFDIR | S_IRUGO | S_IXUGO,
|
|
|
|
},
|
2008-12-23 14:19:00 -07:00
|
|
|
[RPCAUTH_nfsd4_cb] = {
|
|
|
|
.name = "nfsd4_cb",
|
|
|
|
.mode = S_IFDIR | S_IRUGO | S_IXUGO,
|
|
|
|
},
|
2005-04-16 16:20:36 -06:00
|
|
|
};
|
|
|
|
|
|
|
|
enum {
|
|
|
|
RPCAUTH_info = 2,
|
|
|
|
RPCAUTH_EOF
|
|
|
|
};
|
|
|
|
|
|
|
|
static struct rpc_filelist authfiles[] = {
|
|
|
|
[RPCAUTH_info] = {
|
|
|
|
.name = "info",
|
|
|
|
.i_fop = &rpc_info_operations,
|
|
|
|
.mode = S_IFREG | S_IRUSR,
|
|
|
|
},
|
|
|
|
};
|
|
|
|
|
2006-03-20 11:44:49 -07:00
|
|
|
struct vfsmount *rpc_get_mount(void)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
2006-03-20 11:44:49 -07:00
|
|
|
int err;
|
|
|
|
|
2006-06-09 07:34:16 -06:00
|
|
|
err = simple_pin_fs(&rpc_pipe_fs_type, &rpc_mount, &rpc_mount_count);
|
2006-03-20 11:44:49 -07:00
|
|
|
if (err != 0)
|
|
|
|
return ERR_PTR(err);
|
|
|
|
return rpc_mount;
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
|
2006-03-20 11:44:49 -07:00
|
|
|
void rpc_put_mount(void)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
|
|
|
simple_release_fs(&rpc_mount, &rpc_mount_count);
|
|
|
|
}
|
|
|
|
|
2007-06-08 12:14:46 -06:00
|
|
|
static int rpc_delete_dentry(struct dentry *dentry)
|
|
|
|
{
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
2009-02-19 23:02:22 -07:00
|
|
|
static const struct dentry_operations rpc_dentry_operations = {
|
2007-06-08 12:14:46 -06:00
|
|
|
.d_delete = rpc_delete_dentry,
|
|
|
|
};
|
|
|
|
|
2005-09-23 09:08:25 -06:00
|
|
|
static int
|
|
|
|
rpc_lookup_parent(char *path, struct nameidata *nd)
|
|
|
|
{
|
2007-07-19 02:48:20 -06:00
|
|
|
struct vfsmount *mnt;
|
|
|
|
|
2005-09-23 09:08:25 -06:00
|
|
|
if (path[0] == '\0')
|
|
|
|
return -ENOENT;
|
2007-07-19 02:48:20 -06:00
|
|
|
|
|
|
|
mnt = rpc_get_mount();
|
|
|
|
if (IS_ERR(mnt)) {
|
2005-09-23 09:08:25 -06:00
|
|
|
printk(KERN_WARNING "%s: %s failed to mount "
|
2008-03-05 21:47:47 -07:00
|
|
|
"pseudofilesystem \n", __FILE__, __func__);
|
2007-07-19 02:48:20 -06:00
|
|
|
return PTR_ERR(mnt);
|
2005-09-23 09:08:25 -06:00
|
|
|
}
|
|
|
|
|
2007-07-19 02:48:20 -06:00
|
|
|
if (vfs_path_lookup(mnt->mnt_root, mnt, path, LOOKUP_PARENT, nd)) {
|
2005-09-23 09:08:25 -06:00
|
|
|
printk(KERN_WARNING "%s: %s failed to find path %s\n",
|
2008-03-05 21:47:47 -07:00
|
|
|
__FILE__, __func__, path);
|
2005-09-23 09:08:25 -06:00
|
|
|
rpc_put_mount();
|
|
|
|
return -ENOENT;
|
|
|
|
}
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
rpc_release_path(struct nameidata *nd)
|
|
|
|
{
|
2008-02-14 20:34:35 -07:00
|
|
|
path_put(&nd->path);
|
2005-09-23 09:08:25 -06:00
|
|
|
rpc_put_mount();
|
|
|
|
}
|
|
|
|
|
2005-04-16 16:20:36 -06:00
|
|
|
static struct inode *
|
2009-08-09 13:14:16 -06:00
|
|
|
rpc_get_inode(struct super_block *sb, umode_t mode)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
|
|
|
struct inode *inode = new_inode(sb);
|
|
|
|
if (!inode)
|
|
|
|
return NULL;
|
|
|
|
inode->i_mode = mode;
|
|
|
|
inode->i_atime = inode->i_mtime = inode->i_ctime = CURRENT_TIME;
|
|
|
|
switch(mode & S_IFMT) {
|
|
|
|
case S_IFDIR:
|
|
|
|
inode->i_fop = &simple_dir_operations;
|
|
|
|
inode->i_op = &simple_dir_inode_operations;
|
2006-10-01 00:29:04 -06:00
|
|
|
inc_nlink(inode);
|
2005-04-16 16:20:36 -06:00
|
|
|
default:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
return inode;
|
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* FIXME: This probably has races.
|
|
|
|
*/
|
2007-10-26 11:31:04 -06:00
|
|
|
static void rpc_depopulate(struct dentry *parent,
|
|
|
|
unsigned long start, unsigned long eof)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
|
|
|
struct inode *dir = parent->d_inode;
|
|
|
|
struct list_head *pos, *next;
|
|
|
|
struct dentry *dentry, *dvec[10];
|
|
|
|
int n = 0;
|
|
|
|
|
2006-07-03 01:25:16 -06:00
|
|
|
mutex_lock_nested(&dir->i_mutex, I_MUTEX_CHILD);
|
2005-04-16 16:20:36 -06:00
|
|
|
repeat:
|
|
|
|
spin_lock(&dcache_lock);
|
|
|
|
list_for_each_safe(pos, next, &parent->d_subdirs) {
|
[PATCH] shrink dentry struct
Some long time ago, dentry struct was carefully tuned so that on 32 bits
UP, sizeof(struct dentry) was exactly 128, ie a power of 2, and a multiple
of memory cache lines.
Then RCU was added and dentry struct enlarged by two pointers, with nice
results for SMP, but not so good on UP, because breaking the above tuning
(128 + 8 = 136 bytes)
This patch reverts this unwanted side effect, by using an union (d_u),
where d_rcu and d_child are placed so that these two fields can share their
memory needs.
At the time d_free() is called (and d_rcu is really used), d_child is known
to be empty and not touched by the dentry freeing.
Lockless lookups only access d_name, d_parent, d_lock, d_op, d_flags (so
the previous content of d_child is not needed if said dentry was unhashed
but still accessed by a CPU because of RCU constraints)
As dentry cache easily contains millions of entries, a size reduction is
worth the extra complexity of the ugly C union.
Signed-off-by: Eric Dumazet <dada1@cosmosbay.com>
Cc: Dipankar Sarma <dipankar@in.ibm.com>
Cc: Maneesh Soni <maneesh@in.ibm.com>
Cc: Miklos Szeredi <miklos@szeredi.hu>
Cc: "Paul E. McKenney" <paulmck@us.ibm.com>
Cc: Ian Kent <raven@themaw.net>
Cc: Paul Jackson <pj@sgi.com>
Cc: Al Viro <viro@ftp.linux.org.uk>
Cc: Christoph Hellwig <hch@lst.de>
Cc: Trond Myklebust <trond.myklebust@fys.uio.no>
Cc: Neil Brown <neilb@cse.unsw.edu.au>
Cc: James Morris <jmorris@namei.org>
Cc: Stephen Smalley <sds@epoch.ncsc.mil>
Signed-off-by: Andrew Morton <akpm@osdl.org>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
2006-01-08 02:03:32 -07:00
|
|
|
dentry = list_entry(pos, struct dentry, d_u.d_child);
|
2007-06-08 12:14:46 -06:00
|
|
|
if (!dentry->d_inode ||
|
|
|
|
dentry->d_inode->i_ino < start ||
|
|
|
|
dentry->d_inode->i_ino >= eof)
|
|
|
|
continue;
|
2005-04-16 16:20:36 -06:00
|
|
|
spin_lock(&dentry->d_lock);
|
|
|
|
if (!d_unhashed(dentry)) {
|
|
|
|
dget_locked(dentry);
|
|
|
|
__d_drop(dentry);
|
|
|
|
spin_unlock(&dentry->d_lock);
|
|
|
|
dvec[n++] = dentry;
|
|
|
|
if (n == ARRAY_SIZE(dvec))
|
|
|
|
break;
|
|
|
|
} else
|
|
|
|
spin_unlock(&dentry->d_lock);
|
|
|
|
}
|
|
|
|
spin_unlock(&dcache_lock);
|
|
|
|
if (n) {
|
|
|
|
do {
|
|
|
|
dentry = dvec[--n];
|
2007-06-08 12:14:46 -06:00
|
|
|
if (S_ISREG(dentry->d_inode->i_mode))
|
2005-04-16 16:20:36 -06:00
|
|
|
simple_unlink(dir, dentry);
|
2007-06-08 12:14:46 -06:00
|
|
|
else if (S_ISDIR(dentry->d_inode->i_mode))
|
|
|
|
simple_rmdir(dir, dentry);
|
|
|
|
d_delete(dentry);
|
2005-04-16 16:20:36 -06:00
|
|
|
dput(dentry);
|
|
|
|
} while (n);
|
|
|
|
goto repeat;
|
|
|
|
}
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&dir->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
rpc_populate(struct dentry *parent,
|
|
|
|
struct rpc_filelist *files,
|
|
|
|
int start, int eof)
|
|
|
|
{
|
|
|
|
struct inode *inode, *dir = parent->d_inode;
|
|
|
|
void *private = RPC_I(dir)->private;
|
|
|
|
struct dentry *dentry;
|
2009-08-09 13:14:16 -06:00
|
|
|
umode_t mode;
|
|
|
|
int i;
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_lock(&dir->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
for (i = start; i < eof; i++) {
|
|
|
|
dentry = d_alloc_name(parent, files[i].name);
|
|
|
|
if (!dentry)
|
|
|
|
goto out_bad;
|
2007-06-08 12:14:46 -06:00
|
|
|
dentry->d_op = &rpc_dentry_operations;
|
2005-04-16 16:20:36 -06:00
|
|
|
mode = files[i].mode;
|
|
|
|
inode = rpc_get_inode(dir->i_sb, mode);
|
|
|
|
if (!inode) {
|
|
|
|
dput(dentry);
|
|
|
|
goto out_bad;
|
|
|
|
}
|
|
|
|
inode->i_ino = i;
|
|
|
|
if (files[i].i_fop)
|
|
|
|
inode->i_fop = files[i].i_fop;
|
|
|
|
if (private)
|
|
|
|
rpc_inode_setowner(inode, private);
|
|
|
|
if (S_ISDIR(mode))
|
2006-10-01 00:29:04 -06:00
|
|
|
inc_nlink(dir);
|
2005-04-16 16:20:36 -06:00
|
|
|
d_add(dentry, inode);
|
2007-06-07 20:44:34 -06:00
|
|
|
fsnotify_create(dir, dentry);
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&dir->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
return 0;
|
|
|
|
out_bad:
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&dir->i_mutex);
|
2005-04-16 16:20:36 -06:00
|
|
|
printk(KERN_WARNING "%s: %s failed to populate directory %s\n",
|
2008-03-05 21:47:47 -07:00
|
|
|
__FILE__, __func__, parent->d_name.name);
|
2005-04-16 16:20:36 -06:00
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
2005-09-23 09:08:25 -06:00
|
|
|
static int
|
|
|
|
__rpc_mkdir(struct inode *dir, struct dentry *dentry)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
|
|
|
struct inode *inode;
|
2005-09-23 09:08:25 -06:00
|
|
|
|
2007-02-02 16:56:06 -07:00
|
|
|
inode = rpc_get_inode(dir->i_sb, S_IFDIR | S_IRUGO | S_IXUGO);
|
2005-09-23 09:08:25 -06:00
|
|
|
if (!inode)
|
|
|
|
goto out_err;
|
|
|
|
inode->i_ino = iunique(dir->i_sb, 100);
|
|
|
|
d_instantiate(dentry, inode);
|
2006-10-01 00:29:04 -06:00
|
|
|
inc_nlink(dir);
|
2007-06-07 20:44:34 -06:00
|
|
|
fsnotify_mkdir(dir, dentry);
|
2005-09-23 09:08:25 -06:00
|
|
|
return 0;
|
|
|
|
out_err:
|
|
|
|
printk(KERN_WARNING "%s: %s failed to allocate inode for dentry %s\n",
|
2008-03-05 21:47:47 -07:00
|
|
|
__FILE__, __func__, dentry->d_name.name);
|
2005-09-23 09:08:25 -06:00
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int
|
|
|
|
__rpc_rmdir(struct inode *dir, struct dentry *dentry)
|
|
|
|
{
|
2005-04-16 16:20:36 -06:00
|
|
|
int error;
|
2007-06-08 12:14:46 -06:00
|
|
|
error = simple_rmdir(dir, dentry);
|
|
|
|
if (!error)
|
|
|
|
d_delete(dentry);
|
|
|
|
return error;
|
2005-09-23 09:08:25 -06:00
|
|
|
}
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2005-09-23 09:08:25 -06:00
|
|
|
static struct dentry *
|
2007-06-07 16:28:02 -06:00
|
|
|
rpc_lookup_create(struct dentry *parent, const char *name, int len, int exclusive)
|
2005-09-23 09:08:25 -06:00
|
|
|
{
|
2006-08-23 23:03:17 -06:00
|
|
|
struct inode *dir = parent->d_inode;
|
2005-09-23 09:08:25 -06:00
|
|
|
struct dentry *dentry;
|
2005-07-24 16:53:01 -06:00
|
|
|
|
2006-07-03 01:25:16 -06:00
|
|
|
mutex_lock_nested(&dir->i_mutex, I_MUTEX_PARENT);
|
2006-08-23 23:03:17 -06:00
|
|
|
dentry = lookup_one_len(name, parent, len);
|
2005-04-16 16:20:36 -06:00
|
|
|
if (IS_ERR(dentry))
|
2005-09-23 09:08:25 -06:00
|
|
|
goto out_err;
|
2007-06-08 12:14:46 -06:00
|
|
|
if (!dentry->d_inode)
|
|
|
|
dentry->d_op = &rpc_dentry_operations;
|
|
|
|
else if (exclusive) {
|
2005-09-23 09:08:25 -06:00
|
|
|
dput(dentry);
|
2005-04-16 16:20:36 -06:00
|
|
|
dentry = ERR_PTR(-EEXIST);
|
2005-09-23 09:08:25 -06:00
|
|
|
goto out_err;
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
2005-09-23 09:08:25 -06:00
|
|
|
return dentry;
|
|
|
|
out_err:
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&dir->i_mutex);
|
2006-08-23 23:03:17 -06:00
|
|
|
return dentry;
|
|
|
|
}
|
|
|
|
|
|
|
|
static struct dentry *
|
|
|
|
rpc_lookup_negative(char *path, struct nameidata *nd)
|
|
|
|
{
|
|
|
|
struct dentry *dentry;
|
|
|
|
int error;
|
|
|
|
|
|
|
|
if ((error = rpc_lookup_parent(path, nd)) != 0)
|
|
|
|
return ERR_PTR(error);
|
2008-02-14 20:34:32 -07:00
|
|
|
dentry = rpc_lookup_create(nd->path.dentry, nd->last.name, nd->last.len,
|
|
|
|
1);
|
2006-08-23 23:03:17 -06:00
|
|
|
if (IS_ERR(dentry))
|
|
|
|
rpc_release_path(nd);
|
2005-09-23 09:08:25 -06:00
|
|
|
return dentry;
|
|
|
|
}
|
2005-07-24 16:53:01 -06:00
|
|
|
|
2007-11-06 11:06:03 -07:00
|
|
|
/**
|
|
|
|
* rpc_mkdir - Create a new directory in rpc_pipefs
|
|
|
|
* @path: path from the rpc_pipefs root to the new directory
|
2008-02-13 16:03:23 -07:00
|
|
|
* @rpc_client: rpc client to associate with this directory
|
2007-11-06 11:06:03 -07:00
|
|
|
*
|
|
|
|
* This creates a directory at the given @path associated with
|
|
|
|
* @rpc_clnt, which will contain a file named "info" with some basic
|
|
|
|
* information about the client, together with any "pipes" that may
|
|
|
|
* later be created using rpc_mkpipe().
|
|
|
|
*/
|
2005-09-23 09:08:25 -06:00
|
|
|
struct dentry *
|
|
|
|
rpc_mkdir(char *path, struct rpc_clnt *rpc_client)
|
|
|
|
{
|
|
|
|
struct nameidata nd;
|
|
|
|
struct dentry *dentry;
|
|
|
|
struct inode *dir;
|
|
|
|
int error;
|
|
|
|
|
|
|
|
dentry = rpc_lookup_negative(path, &nd);
|
|
|
|
if (IS_ERR(dentry))
|
|
|
|
return dentry;
|
2008-02-14 20:34:32 -07:00
|
|
|
dir = nd.path.dentry->d_inode;
|
2005-09-23 09:08:25 -06:00
|
|
|
if ((error = __rpc_mkdir(dir, dentry)) != 0)
|
|
|
|
goto err_dput;
|
|
|
|
RPC_I(dentry->d_inode)->private = rpc_client;
|
2005-04-16 16:20:36 -06:00
|
|
|
error = rpc_populate(dentry, authfiles,
|
|
|
|
RPCAUTH_info, RPCAUTH_EOF);
|
|
|
|
if (error)
|
2005-09-23 09:08:25 -06:00
|
|
|
goto err_depopulate;
|
2006-07-29 15:37:40 -06:00
|
|
|
dget(dentry);
|
2005-09-23 09:08:25 -06:00
|
|
|
out:
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&dir->i_mutex);
|
2005-09-23 09:08:25 -06:00
|
|
|
rpc_release_path(&nd);
|
2006-07-29 15:37:40 -06:00
|
|
|
return dentry;
|
2005-09-23 09:08:25 -06:00
|
|
|
err_depopulate:
|
2007-06-08 12:14:46 -06:00
|
|
|
rpc_depopulate(dentry, RPCAUTH_info, RPCAUTH_EOF);
|
2005-09-23 09:08:25 -06:00
|
|
|
__rpc_rmdir(dir, dentry);
|
|
|
|
err_dput:
|
|
|
|
dput(dentry);
|
|
|
|
printk(KERN_WARNING "%s: %s() failed to create directory %s (errno = %d)\n",
|
2008-03-05 21:47:47 -07:00
|
|
|
__FILE__, __func__, path, error);
|
2005-09-23 09:08:25 -06:00
|
|
|
dentry = ERR_PTR(error);
|
|
|
|
goto out;
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
|
2007-11-06 11:06:03 -07:00
|
|
|
/**
|
|
|
|
* rpc_rmdir - Remove a directory created with rpc_mkdir()
|
|
|
|
* @dentry: directory to remove
|
|
|
|
*/
|
2005-09-23 09:08:25 -06:00
|
|
|
int
|
2006-07-31 15:17:18 -06:00
|
|
|
rpc_rmdir(struct dentry *dentry)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
2006-07-31 15:17:18 -06:00
|
|
|
struct dentry *parent;
|
2005-09-23 09:08:25 -06:00
|
|
|
struct inode *dir;
|
|
|
|
int error;
|
2005-07-24 16:53:01 -06:00
|
|
|
|
2006-07-31 15:17:18 -06:00
|
|
|
parent = dget_parent(dentry);
|
|
|
|
dir = parent->d_inode;
|
2006-07-03 01:25:16 -06:00
|
|
|
mutex_lock_nested(&dir->i_mutex, I_MUTEX_PARENT);
|
2007-06-08 12:14:46 -06:00
|
|
|
rpc_depopulate(dentry, RPCAUTH_info, RPCAUTH_EOF);
|
2005-09-23 09:08:25 -06:00
|
|
|
error = __rpc_rmdir(dir, dentry);
|
|
|
|
dput(dentry);
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&dir->i_mutex);
|
2006-07-31 15:17:18 -06:00
|
|
|
dput(parent);
|
2005-09-23 09:08:25 -06:00
|
|
|
return error;
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
|
2007-11-06 11:06:03 -07:00
|
|
|
/**
|
|
|
|
* rpc_mkpipe - make an rpc_pipefs file for kernel<->userspace communication
|
|
|
|
* @parent: dentry of directory to create new "pipe" in
|
|
|
|
* @name: name of pipe
|
|
|
|
* @private: private data to associate with the pipe, for the caller's use
|
|
|
|
* @ops: operations defining the behavior of the pipe: upcall, downcall,
|
2008-12-23 14:08:32 -07:00
|
|
|
* release_pipe, open_pipe, and destroy_msg.
|
2008-02-13 16:03:23 -07:00
|
|
|
* @flags: rpc_inode flags
|
2007-11-06 11:06:03 -07:00
|
|
|
*
|
|
|
|
* Data is made available for userspace to read by calls to
|
|
|
|
* rpc_queue_upcall(). The actual reads will result in calls to
|
|
|
|
* @ops->upcall, which will be called with the file pointer,
|
|
|
|
* message, and userspace buffer to copy to.
|
|
|
|
*
|
|
|
|
* Writes can come at any time, and do not necessarily have to be
|
|
|
|
* responses to upcalls. They will result in calls to @msg->downcall.
|
|
|
|
*
|
|
|
|
* The @private argument passed here will be available to all these methods
|
|
|
|
* from the file pointer, via RPC_I(file->f_dentry->d_inode)->private.
|
|
|
|
*/
|
2009-08-09 13:14:15 -06:00
|
|
|
struct dentry *rpc_mkpipe(struct dentry *parent, const char *name,
|
|
|
|
void *private, const struct rpc_pipe_ops *ops,
|
|
|
|
int flags)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
|
|
|
struct dentry *dentry;
|
2005-09-23 09:08:25 -06:00
|
|
|
struct inode *dir, *inode;
|
2005-04-16 16:20:36 -06:00
|
|
|
struct rpc_inode *rpci;
|
2009-08-09 13:14:16 -06:00
|
|
|
umode_t umode = S_IFIFO | S_IRUSR | S_IWUSR;
|
|
|
|
|
|
|
|
if (ops->upcall == NULL)
|
|
|
|
umode &= ~S_IRUGO;
|
|
|
|
if (ops->downcall == NULL)
|
|
|
|
umode &= ~S_IWUGO;
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2007-06-07 16:28:02 -06:00
|
|
|
dentry = rpc_lookup_create(parent, name, strlen(name), 0);
|
2005-04-16 16:20:36 -06:00
|
|
|
if (IS_ERR(dentry))
|
2005-09-23 09:08:25 -06:00
|
|
|
return dentry;
|
2006-08-23 23:03:17 -06:00
|
|
|
dir = parent->d_inode;
|
2007-06-07 16:28:02 -06:00
|
|
|
if (dentry->d_inode) {
|
|
|
|
rpci = RPC_I(dentry->d_inode);
|
|
|
|
if (rpci->private != private ||
|
|
|
|
rpci->ops != ops ||
|
|
|
|
rpci->flags != flags) {
|
|
|
|
dput (dentry);
|
|
|
|
dentry = ERR_PTR(-EBUSY);
|
|
|
|
}
|
2007-06-08 12:14:53 -06:00
|
|
|
rpci->nkern_readwriters++;
|
2007-06-07 16:28:02 -06:00
|
|
|
goto out;
|
|
|
|
}
|
2009-08-09 13:14:16 -06:00
|
|
|
inode = rpc_get_inode(dir->i_sb, umode);
|
2005-09-23 09:08:25 -06:00
|
|
|
if (!inode)
|
|
|
|
goto err_dput;
|
2005-04-16 16:20:36 -06:00
|
|
|
inode->i_ino = iunique(dir->i_sb, 100);
|
|
|
|
inode->i_fop = &rpc_pipe_fops;
|
2005-09-23 09:08:25 -06:00
|
|
|
d_instantiate(dentry, inode);
|
2005-04-16 16:20:36 -06:00
|
|
|
rpci = RPC_I(inode);
|
|
|
|
rpci->private = private;
|
|
|
|
rpci->flags = flags;
|
|
|
|
rpci->ops = ops;
|
2007-06-08 12:14:53 -06:00
|
|
|
rpci->nkern_readwriters = 1;
|
2007-06-07 20:44:34 -06:00
|
|
|
fsnotify_create(dir, dentry);
|
2006-07-29 15:37:40 -06:00
|
|
|
dget(dentry);
|
2005-09-23 09:08:25 -06:00
|
|
|
out:
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&dir->i_mutex);
|
2006-07-29 15:37:40 -06:00
|
|
|
return dentry;
|
2005-09-23 09:08:25 -06:00
|
|
|
err_dput:
|
2005-04-16 16:20:36 -06:00
|
|
|
dput(dentry);
|
2005-09-23 09:08:25 -06:00
|
|
|
dentry = ERR_PTR(-ENOMEM);
|
2006-08-23 23:03:17 -06:00
|
|
|
printk(KERN_WARNING "%s: %s() failed to create pipe %s/%s (errno = %d)\n",
|
2008-03-05 21:47:47 -07:00
|
|
|
__FILE__, __func__, parent->d_name.name, name,
|
2006-08-23 23:03:17 -06:00
|
|
|
-ENOMEM);
|
2005-09-23 09:08:25 -06:00
|
|
|
goto out;
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
2008-12-23 13:21:31 -07:00
|
|
|
EXPORT_SYMBOL_GPL(rpc_mkpipe);
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2007-11-06 11:06:03 -07:00
|
|
|
/**
|
|
|
|
* rpc_unlink - remove a pipe
|
|
|
|
* @dentry: dentry for the pipe, as returned from rpc_mkpipe
|
|
|
|
*
|
|
|
|
* After this call, lookups will no longer find the pipe, and any
|
|
|
|
* attempts to read or write using preexisting opens of the pipe will
|
|
|
|
* return -EPIPE.
|
|
|
|
*/
|
2005-09-23 09:08:25 -06:00
|
|
|
int
|
2006-07-31 15:11:48 -06:00
|
|
|
rpc_unlink(struct dentry *dentry)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
2006-07-31 15:11:48 -06:00
|
|
|
struct dentry *parent;
|
2005-09-23 09:08:25 -06:00
|
|
|
struct inode *dir;
|
2006-07-31 15:11:48 -06:00
|
|
|
int error = 0;
|
2005-04-16 16:20:36 -06:00
|
|
|
|
2006-07-31 15:11:48 -06:00
|
|
|
parent = dget_parent(dentry);
|
|
|
|
dir = parent->d_inode;
|
2006-07-03 01:25:16 -06:00
|
|
|
mutex_lock_nested(&dir->i_mutex, I_MUTEX_PARENT);
|
2007-06-08 12:14:53 -06:00
|
|
|
if (--RPC_I(dentry->d_inode)->nkern_readwriters == 0) {
|
|
|
|
rpc_close_pipes(dentry->d_inode);
|
|
|
|
error = simple_unlink(dir, dentry);
|
|
|
|
if (!error)
|
|
|
|
d_delete(dentry);
|
|
|
|
}
|
2005-09-23 09:08:25 -06:00
|
|
|
dput(dentry);
|
2006-01-09 16:59:24 -07:00
|
|
|
mutex_unlock(&dir->i_mutex);
|
2006-07-31 15:11:48 -06:00
|
|
|
dput(parent);
|
2005-09-23 09:08:25 -06:00
|
|
|
return error;
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
2008-12-23 13:21:31 -07:00
|
|
|
EXPORT_SYMBOL_GPL(rpc_unlink);
|
2005-04-16 16:20:36 -06:00
|
|
|
|
|
|
|
/*
|
|
|
|
* populate the filesystem
|
|
|
|
*/
|
|
|
|
static struct super_operations s_ops = {
|
|
|
|
.alloc_inode = rpc_alloc_inode,
|
|
|
|
.destroy_inode = rpc_destroy_inode,
|
|
|
|
.statfs = simple_statfs,
|
|
|
|
};
|
|
|
|
|
|
|
|
#define RPCAUTH_GSSMAGIC 0x67596969
|
|
|
|
|
|
|
|
static int
|
|
|
|
rpc_fill_super(struct super_block *sb, void *data, int silent)
|
|
|
|
{
|
|
|
|
struct inode *inode;
|
|
|
|
struct dentry *root;
|
|
|
|
|
|
|
|
sb->s_blocksize = PAGE_CACHE_SIZE;
|
|
|
|
sb->s_blocksize_bits = PAGE_CACHE_SHIFT;
|
|
|
|
sb->s_magic = RPCAUTH_GSSMAGIC;
|
|
|
|
sb->s_op = &s_ops;
|
|
|
|
sb->s_time_gran = 1;
|
|
|
|
|
|
|
|
inode = rpc_get_inode(sb, S_IFDIR | 0755);
|
|
|
|
if (!inode)
|
|
|
|
return -ENOMEM;
|
|
|
|
root = d_alloc_root(inode);
|
|
|
|
if (!root) {
|
|
|
|
iput(inode);
|
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
if (rpc_populate(root, files, RPCAUTH_Root + 1, RPCAUTH_RootEOF))
|
|
|
|
goto out;
|
|
|
|
sb->s_root = root;
|
|
|
|
return 0;
|
|
|
|
out:
|
|
|
|
d_genocide(root);
|
|
|
|
dput(root);
|
|
|
|
return -ENOMEM;
|
|
|
|
}
|
|
|
|
|
[PATCH] VFS: Permit filesystem to override root dentry on mount
Extend the get_sb() filesystem operation to take an extra argument that
permits the VFS to pass in the target vfsmount that defines the mountpoint.
The filesystem is then required to manually set the superblock and root dentry
pointers. For most filesystems, this should be done with simple_set_mnt()
which will set the superblock pointer and then set the root dentry to the
superblock's s_root (as per the old default behaviour).
The get_sb() op now returns an integer as there's now no need to return the
superblock pointer.
This patch permits a superblock to be implicitly shared amongst several mount
points, such as can be done with NFS to avoid potential inode aliasing. In
such a case, simple_set_mnt() would not be called, and instead the mnt_root
and mnt_sb would be set directly.
The patch also makes the following changes:
(*) the get_sb_*() convenience functions in the core kernel now take a vfsmount
pointer argument and return an integer, so most filesystems have to change
very little.
(*) If one of the convenience function is not used, then get_sb() should
normally call simple_set_mnt() to instantiate the vfsmount. This will
always return 0, and so can be tail-called from get_sb().
(*) generic_shutdown_super() now calls shrink_dcache_sb() to clean up the
dcache upon superblock destruction rather than shrink_dcache_anon().
This is required because the superblock may now have multiple trees that
aren't actually bound to s_root, but that still need to be cleaned up. The
currently called functions assume that the whole tree is rooted at s_root,
and that anonymous dentries are not the roots of trees which results in
dentries being left unculled.
However, with the way NFS superblock sharing are currently set to be
implemented, these assumptions are violated: the root of the filesystem is
simply a dummy dentry and inode (the real inode for '/' may well be
inaccessible), and all the vfsmounts are rooted on anonymous[*] dentries
with child trees.
[*] Anonymous until discovered from another tree.
(*) The documentation has been adjusted, including the additional bit of
changing ext2_* into foo_* in the documentation.
[akpm@osdl.org: convert ipath_fs, do other stuff]
Signed-off-by: David Howells <dhowells@redhat.com>
Acked-by: Al Viro <viro@zeniv.linux.org.uk>
Cc: Nathan Scott <nathans@sgi.com>
Cc: Roland Dreier <rolandd@cisco.com>
Signed-off-by: Andrew Morton <akpm@osdl.org>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
2006-06-23 03:02:57 -06:00
|
|
|
static int
|
2005-04-16 16:20:36 -06:00
|
|
|
rpc_get_sb(struct file_system_type *fs_type,
|
[PATCH] VFS: Permit filesystem to override root dentry on mount
Extend the get_sb() filesystem operation to take an extra argument that
permits the VFS to pass in the target vfsmount that defines the mountpoint.
The filesystem is then required to manually set the superblock and root dentry
pointers. For most filesystems, this should be done with simple_set_mnt()
which will set the superblock pointer and then set the root dentry to the
superblock's s_root (as per the old default behaviour).
The get_sb() op now returns an integer as there's now no need to return the
superblock pointer.
This patch permits a superblock to be implicitly shared amongst several mount
points, such as can be done with NFS to avoid potential inode aliasing. In
such a case, simple_set_mnt() would not be called, and instead the mnt_root
and mnt_sb would be set directly.
The patch also makes the following changes:
(*) the get_sb_*() convenience functions in the core kernel now take a vfsmount
pointer argument and return an integer, so most filesystems have to change
very little.
(*) If one of the convenience function is not used, then get_sb() should
normally call simple_set_mnt() to instantiate the vfsmount. This will
always return 0, and so can be tail-called from get_sb().
(*) generic_shutdown_super() now calls shrink_dcache_sb() to clean up the
dcache upon superblock destruction rather than shrink_dcache_anon().
This is required because the superblock may now have multiple trees that
aren't actually bound to s_root, but that still need to be cleaned up. The
currently called functions assume that the whole tree is rooted at s_root,
and that anonymous dentries are not the roots of trees which results in
dentries being left unculled.
However, with the way NFS superblock sharing are currently set to be
implemented, these assumptions are violated: the root of the filesystem is
simply a dummy dentry and inode (the real inode for '/' may well be
inaccessible), and all the vfsmounts are rooted on anonymous[*] dentries
with child trees.
[*] Anonymous until discovered from another tree.
(*) The documentation has been adjusted, including the additional bit of
changing ext2_* into foo_* in the documentation.
[akpm@osdl.org: convert ipath_fs, do other stuff]
Signed-off-by: David Howells <dhowells@redhat.com>
Acked-by: Al Viro <viro@zeniv.linux.org.uk>
Cc: Nathan Scott <nathans@sgi.com>
Cc: Roland Dreier <rolandd@cisco.com>
Signed-off-by: Andrew Morton <akpm@osdl.org>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
2006-06-23 03:02:57 -06:00
|
|
|
int flags, const char *dev_name, void *data, struct vfsmount *mnt)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
[PATCH] VFS: Permit filesystem to override root dentry on mount
Extend the get_sb() filesystem operation to take an extra argument that
permits the VFS to pass in the target vfsmount that defines the mountpoint.
The filesystem is then required to manually set the superblock and root dentry
pointers. For most filesystems, this should be done with simple_set_mnt()
which will set the superblock pointer and then set the root dentry to the
superblock's s_root (as per the old default behaviour).
The get_sb() op now returns an integer as there's now no need to return the
superblock pointer.
This patch permits a superblock to be implicitly shared amongst several mount
points, such as can be done with NFS to avoid potential inode aliasing. In
such a case, simple_set_mnt() would not be called, and instead the mnt_root
and mnt_sb would be set directly.
The patch also makes the following changes:
(*) the get_sb_*() convenience functions in the core kernel now take a vfsmount
pointer argument and return an integer, so most filesystems have to change
very little.
(*) If one of the convenience function is not used, then get_sb() should
normally call simple_set_mnt() to instantiate the vfsmount. This will
always return 0, and so can be tail-called from get_sb().
(*) generic_shutdown_super() now calls shrink_dcache_sb() to clean up the
dcache upon superblock destruction rather than shrink_dcache_anon().
This is required because the superblock may now have multiple trees that
aren't actually bound to s_root, but that still need to be cleaned up. The
currently called functions assume that the whole tree is rooted at s_root,
and that anonymous dentries are not the roots of trees which results in
dentries being left unculled.
However, with the way NFS superblock sharing are currently set to be
implemented, these assumptions are violated: the root of the filesystem is
simply a dummy dentry and inode (the real inode for '/' may well be
inaccessible), and all the vfsmounts are rooted on anonymous[*] dentries
with child trees.
[*] Anonymous until discovered from another tree.
(*) The documentation has been adjusted, including the additional bit of
changing ext2_* into foo_* in the documentation.
[akpm@osdl.org: convert ipath_fs, do other stuff]
Signed-off-by: David Howells <dhowells@redhat.com>
Acked-by: Al Viro <viro@zeniv.linux.org.uk>
Cc: Nathan Scott <nathans@sgi.com>
Cc: Roland Dreier <rolandd@cisco.com>
Signed-off-by: Andrew Morton <akpm@osdl.org>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
2006-06-23 03:02:57 -06:00
|
|
|
return get_sb_single(fs_type, flags, data, rpc_fill_super, mnt);
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
|
|
|
|
static struct file_system_type rpc_pipe_fs_type = {
|
|
|
|
.owner = THIS_MODULE,
|
|
|
|
.name = "rpc_pipefs",
|
|
|
|
.get_sb = rpc_get_sb,
|
|
|
|
.kill_sb = kill_litter_super,
|
|
|
|
};
|
|
|
|
|
|
|
|
static void
|
2008-07-25 20:45:34 -06:00
|
|
|
init_once(void *foo)
|
2005-04-16 16:20:36 -06:00
|
|
|
{
|
|
|
|
struct rpc_inode *rpci = (struct rpc_inode *) foo;
|
|
|
|
|
2007-05-16 23:10:57 -06:00
|
|
|
inode_init_once(&rpci->vfs_inode);
|
|
|
|
rpci->private = NULL;
|
|
|
|
rpci->nreaders = 0;
|
|
|
|
rpci->nwriters = 0;
|
|
|
|
INIT_LIST_HEAD(&rpci->in_upcall);
|
2007-06-07 13:31:36 -06:00
|
|
|
INIT_LIST_HEAD(&rpci->in_downcall);
|
2007-05-16 23:10:57 -06:00
|
|
|
INIT_LIST_HEAD(&rpci->pipe);
|
|
|
|
rpci->pipelen = 0;
|
|
|
|
init_waitqueue_head(&rpci->waitq);
|
|
|
|
INIT_DELAYED_WORK(&rpci->queue_timeout,
|
|
|
|
rpc_timeout_upcall_queue);
|
|
|
|
rpci->ops = NULL;
|
2005-04-16 16:20:36 -06:00
|
|
|
}
|
|
|
|
|
|
|
|
int register_rpc_pipefs(void)
|
|
|
|
{
|
2007-05-09 03:34:51 -06:00
|
|
|
int err;
|
|
|
|
|
2005-04-16 16:20:36 -06:00
|
|
|
rpc_inode_cachep = kmem_cache_create("rpc_inode_cache",
|
2006-03-24 04:16:06 -07:00
|
|
|
sizeof(struct rpc_inode),
|
|
|
|
0, (SLAB_HWCACHE_ALIGN|SLAB_RECLAIM_ACCOUNT|
|
|
|
|
SLAB_MEM_SPREAD),
|
2007-07-19 19:11:58 -06:00
|
|
|
init_once);
|
2005-04-16 16:20:36 -06:00
|
|
|
if (!rpc_inode_cachep)
|
|
|
|
return -ENOMEM;
|
2007-05-09 03:34:51 -06:00
|
|
|
err = register_filesystem(&rpc_pipe_fs_type);
|
|
|
|
if (err) {
|
|
|
|
kmem_cache_destroy(rpc_inode_cachep);
|
|
|
|
return err;
|
|
|
|
}
|
|
|
|
|
2005-04-16 16:20:36 -06:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
void unregister_rpc_pipefs(void)
|
|
|
|
{
|
2006-09-27 02:49:40 -06:00
|
|
|
kmem_cache_destroy(rpc_inode_cachep);
|
2005-04-16 16:20:36 -06:00
|
|
|
unregister_filesystem(&rpc_pipe_fs_type);
|
|
|
|
}
|