[net-next-2.6.git] / arch / powerpc / platforms / cell / spufs / inode.c

/*
 * SPU file system
 *
 * (C) Copyright IBM Deutschland Entwicklung GmbH 2005
 *
 * Author: Arnd Bergmann <arndb@de.ibm.com>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2, or (at your option)
 * any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

#include <linux/file.h>
#include <linux/fs.h>
#include <linux/backing-dev.h>
#include <linux/init.h>
#include <linux/ioctl.h>
#include <linux/module.h>
#include <linux/mount.h>
#include <linux/namei.h>
#include <linux/pagemap.h>
#include <linux/poll.h>
#include <linux/slab.h>
#include <linux/parser.h>

#include <asm/prom.h>
#include <asm/semaphore.h>
#include <asm/spu.h>
#include <asm/uaccess.h>

#include "spufs.h"

static kmem_cache_t *spufs_inode_cache;
char *isolated_loader;

static struct inode *
spufs_alloc_inode(struct super_block *sb)
{
	struct spufs_inode_info *ei;

	ei = kmem_cache_alloc(spufs_inode_cache, SLAB_KERNEL);
	if (!ei)
		return NULL;

	ei->i_gang = NULL;
	ei->i_ctx = NULL;

	return &ei->vfs_inode;
}

static void
spufs_destroy_inode(struct inode *inode)
{
	kmem_cache_free(spufs_inode_cache, SPUFS_I(inode));
}

static void
spufs_init_once(void *p, kmem_cache_t * cachep, unsigned long flags)
{
	struct spufs_inode_info *ei = p;

	if ((flags & (SLAB_CTOR_VERIFY|SLAB_CTOR_CONSTRUCTOR)) ==
	    SLAB_CTOR_CONSTRUCTOR) {
		inode_init_once(&ei->vfs_inode);
	}
}

static struct inode *
spufs_new_inode(struct super_block *sb, int mode)
{
	struct inode *inode;

	inode = new_inode(sb);
	if (!inode)
		goto out;

	inode->i_mode = mode;
	inode->i_uid = current->fsuid;
	inode->i_gid = current->fsgid;
	inode->i_blocks = 0;
	inode->i_atime = inode->i_mtime = inode->i_ctime = CURRENT_TIME;
out:
	return inode;
}

static int
spufs_setattr(struct dentry *dentry, struct iattr *attr)
{
	struct inode *inode = dentry->d_inode;

	if ((attr->ia_valid & ATTR_SIZE) &&
	    (attr->ia_size != inode->i_size))
		return -EINVAL;
	return inode_setattr(inode, attr);
}


static int
spufs_new_file(struct super_block *sb, struct dentry *dentry,
		const struct file_operations *fops, int mode,
		struct spu_context *ctx)
{
	static struct inode_operations spufs_file_iops = {
		.setattr = spufs_setattr,
	};
	struct inode *inode;
	int ret;

	ret = -ENOSPC;
	inode = spufs_new_inode(sb, S_IFREG | mode);
	if (!inode)
		goto out;

	ret = 0;
	inode->i_op = &spufs_file_iops;
	inode->i_fop = fops;
	inode->i_private = SPUFS_I(inode)->i_ctx = get_spu_context(ctx);
	d_add(dentry, inode);
out:
	return ret;
}

static void
spufs_delete_inode(struct inode *inode)
{
	struct spufs_inode_info *ei = SPUFS_I(inode);

	if (ei->i_ctx)
		put_spu_context(ei->i_ctx);
	if (ei->i_gang)
		put_spu_gang(ei->i_gang);
	clear_inode(inode);
}

static void spufs_prune_dir(struct dentry *dir)
{
	struct dentry *dentry, *tmp;

	mutex_lock(&dir->d_inode->i_mutex);
	list_for_each_entry_safe(dentry, tmp, &dir->d_subdirs, d_u.d_child) {
		spin_lock(&dcache_lock);
		spin_lock(&dentry->d_lock);
		if (!(d_unhashed(dentry)) && dentry->d_inode) {
			dget_locked(dentry);
			__d_drop(dentry);
			spin_unlock(&dentry->d_lock);
			simple_unlink(dir->d_inode, dentry);
			spin_unlock(&dcache_lock);
			dput(dentry);
		} else {
			spin_unlock(&dentry->d_lock);
			spin_unlock(&dcache_lock);
		}
	}
	shrink_dcache_parent(dir);
	mutex_unlock(&dir->d_inode->i_mutex);
}

/* Caller must hold parent->i_mutex */
static int spufs_rmdir(struct inode *parent, struct dentry *dir)
{
	/* remove all entries */
	spufs_prune_dir(dir);

	return simple_rmdir(parent, dir);
}

static int spufs_fill_dir(struct dentry *dir, struct tree_descr *files,
			  int mode, struct spu_context *ctx)
{
	struct dentry *dentry;
	int ret;

	while (files->name && files->name[0]) {
		ret = -ENOMEM;
		dentry = d_alloc_name(dir, files->name);
		if (!dentry)
			goto out;
		ret = spufs_new_file(dir->d_sb, dentry, files->ops,
					files->mode & mode, ctx);
		if (ret)
			goto out;
		files++;
	}
	return 0;
out:
	spufs_prune_dir(dir);
	return ret;
}

static int spufs_dir_close(struct inode *inode, struct file *file)
{
	struct spu_context *ctx;
	struct inode *parent;
	struct dentry *dir;
	int ret;

	dir = file->f_dentry;
	parent = dir->d_parent->d_inode;
	ctx = SPUFS_I(dir->d_inode)->i_ctx;

	mutex_lock(&parent->i_mutex);
	ret = spufs_rmdir(parent, dir);
	mutex_unlock(&parent->i_mutex);
	WARN_ON(ret);

	/* We have to give up the mm_struct */
	spu_forget(ctx);

	return dcache_dir_close(inode, file);
}

struct inode_operations spufs_dir_inode_operations = {
	.lookup = simple_lookup,
};

struct file_operations spufs_context_fops = {
	.open		= dcache_dir_open,
	.release	= spufs_dir_close,
	.llseek		= dcache_dir_lseek,
	.read		= generic_read_dir,
	.readdir	= dcache_readdir,
	.fsync		= simple_sync_file,
};
EXPORT_SYMBOL_GPL(spufs_context_fops);

static int
spufs_mkdir(struct inode *dir, struct dentry *dentry, unsigned int flags,
		int mode)
{
	int ret;
	struct inode *inode;
	struct spu_context *ctx;

	ret = -ENOSPC;
	inode = spufs_new_inode(dir->i_sb, mode | S_IFDIR);
	if (!inode)
		goto out;

	if (dir->i_mode & S_ISGID) {
		inode->i_gid = dir->i_gid;
		inode->i_mode &= S_ISGID;
	}
	ctx = alloc_spu_context(SPUFS_I(dir)->i_gang); /* XXX gang */
	SPUFS_I(inode)->i_ctx = ctx;
	if (!ctx)
		goto out_iput;

	ctx->flags = flags;
	inode->i_op = &spufs_dir_inode_operations;
	inode->i_fop = &simple_dir_operations;
	if (flags & SPU_CREATE_NOSCHED)
		ret = spufs_fill_dir(dentry, spufs_dir_nosched_contents,
					 mode, ctx);
	else
		ret = spufs_fill_dir(dentry, spufs_dir_contents, mode, ctx);

	if (ret)
		goto out_free_ctx;

	d_instantiate(dentry, inode);
	dget(dentry);
	dir->i_nlink++;
	dentry->d_inode->i_nlink++;
	goto out;

out_free_ctx:
	put_spu_context(ctx);
out_iput:
	iput(inode);
out:
	return ret;
}

static int spufs_context_open(struct dentry *dentry, struct vfsmount *mnt)
{
	int ret;
	struct file *filp;

	ret = get_unused_fd();
	if (ret < 0) {
		dput(dentry);
		mntput(mnt);
		goto out;
	}

	filp = dentry_open(dentry, mnt, O_RDONLY);
	if (IS_ERR(filp)) {
		put_unused_fd(ret);
		ret = PTR_ERR(filp);
		goto out;
	}

	filp->f_op = &spufs_context_fops;
	fd_install(ret, filp);
out:
	return ret;
}

static int spufs_create_context(struct inode *inode,
			struct dentry *dentry,
			struct vfsmount *mnt, int flags, int mode)
{
	int ret;

	ret = -EPERM;
	if ((flags & SPU_CREATE_NOSCHED) &&
	    !capable(CAP_SYS_NICE))
		goto out_unlock;

	ret = -EINVAL;
	if ((flags & (SPU_CREATE_NOSCHED | SPU_CREATE_ISOLATE))
	    == SPU_CREATE_ISOLATE)
		goto out_unlock;

	ret = spufs_mkdir(inode, dentry, flags, mode & S_IRWXUGO);
	if (ret)
		goto out_unlock;

	/*
	 * get references for dget and mntget, will be released
	 * in error path of *_open().
	 */
	ret = spufs_context_open(dget(dentry), mntget(mnt));
	if (ret < 0) {
		WARN_ON(spufs_rmdir(inode, dentry));
		mutex_unlock(&inode->i_mutex);
		spu_forget(SPUFS_I(dentry->d_inode)->i_ctx);
		goto out;
	}

out_unlock:
	mutex_unlock(&inode->i_mutex);
out:
	dput(dentry);
	return ret;
}

static int spufs_rmgang(struct inode *root, struct dentry *dir)
{
	/* FIXME: this fails if the dir is not empty,
	          which causes a leak of gangs. */
	return simple_rmdir(root, dir);
}

static int spufs_gang_close(struct inode *inode, struct file *file)
{
	struct inode *parent;
	struct dentry *dir;
	int ret;

	dir = file->f_dentry;
	parent = dir->d_parent->d_inode;

	ret = spufs_rmgang(parent, dir);
	WARN_ON(ret);

	return dcache_dir_close(inode, file);
}

struct file_operations spufs_gang_fops = {
	.open		= dcache_dir_open,
	.release	= spufs_gang_close,
	.llseek		= dcache_dir_lseek,
	.read		= generic_read_dir,
	.readdir	= dcache_readdir,
	.fsync		= simple_sync_file,
};

static int
spufs_mkgang(struct inode *dir, struct dentry *dentry, int mode)
{
	int ret;
	struct inode *inode;
	struct spu_gang *gang;

	ret = -ENOSPC;
	inode = spufs_new_inode(dir->i_sb, mode | S_IFDIR);
	if (!inode)
		goto out;

	ret = 0;
	if (dir->i_mode & S_ISGID) {
		inode->i_gid = dir->i_gid;
		inode->i_mode &= S_ISGID;
	}
	gang = alloc_spu_gang();
	SPUFS_I(inode)->i_ctx = NULL;
	SPUFS_I(inode)->i_gang = gang;
	if (!gang)
		goto out_iput;

	inode->i_op = &spufs_dir_inode_operations;
	inode->i_fop = &simple_dir_operations;

	d_instantiate(dentry, inode);
	dget(dentry);
	dir->i_nlink++;
	dentry->d_inode->i_nlink++;
	return ret;

out_iput:
	iput(inode);
out:
	return ret;
}

static int spufs_gang_open(struct dentry *dentry, struct vfsmount *mnt)
{
	int ret;
	struct file *filp;

	ret = get_unused_fd();
	if (ret < 0) {
		dput(dentry);
		mntput(mnt);
		goto out;
	}

	filp = dentry_open(dentry, mnt, O_RDONLY);
	if (IS_ERR(filp)) {
		put_unused_fd(ret);
		ret = PTR_ERR(filp);
		goto out;
	}

	filp->f_op = &spufs_gang_fops;
	fd_install(ret, filp);
out:
	return ret;
}

static int spufs_create_gang(struct inode *inode,
			struct dentry *dentry,
			struct vfsmount *mnt, int mode)
{
	int ret;

	ret = spufs_mkgang(inode, dentry, mode & S_IRWXUGO);
	if (ret)
		goto out;

	/*
	 * get references for dget and mntget, will be released
	 * in error path of *_open().
	 */
	ret = spufs_gang_open(dget(dentry), mntget(mnt));
	if (ret < 0)
		WARN_ON(spufs_rmgang(inode, dentry));

out:
	mutex_unlock(&inode->i_mutex);
	dput(dentry);
	return ret;
}


static struct file_system_type spufs_type;

long spufs_create(struct nameidata *nd, unsigned int flags, mode_t mode)
{
	struct dentry *dentry;
	int ret;

	ret = -EINVAL;
	/* check if we are on spufs */
	if (nd->dentry->d_sb->s_type != &spufs_type)
		goto out;

	/* don't accept undefined flags */
	if (flags & (~SPU_CREATE_FLAG_ALL))
		goto out;

	/* only threads can be underneath a gang */
	if (nd->dentry != nd->dentry->d_sb->s_root) {
		if ((flags & SPU_CREATE_GANG) ||
		    !SPUFS_I(nd->dentry->d_inode)->i_gang)
			goto out;
	}

	dentry = lookup_create(nd, 1);
	ret = PTR_ERR(dentry);
	if (IS_ERR(dentry))
		goto out_dir;

	ret = -EEXIST;
	if (dentry->d_inode)
		goto out_dput;

	mode &= ~current->fs->umask;

	if (flags & SPU_CREATE_GANG)
		return spufs_create_gang(nd->dentry->d_inode,
					dentry, nd->mnt, mode);
	else
		return spufs_create_context(nd->dentry->d_inode,
					dentry, nd->mnt, flags, mode);

out_dput:
	dput(dentry);
out_dir:
	mutex_unlock(&nd->dentry->d_inode->i_mutex);
out:
	return ret;
}

/* File system initialization */
enum {
	Opt_uid, Opt_gid, Opt_err,
};

static match_table_t spufs_tokens = {
	{ Opt_uid, "uid=%d" },
	{ Opt_gid, "gid=%d" },
	{ Opt_err, NULL  },
};

static int
spufs_parse_options(char *options, struct inode *root)
{
	char *p;
	substring_t args[MAX_OPT_ARGS];

	while ((p = strsep(&options, ",")) != NULL) {
		int token, option;

		if (!*p)
			continue;

		token = match_token(p, spufs_tokens, args);
		switch (token) {
		case Opt_uid:
			if (match_int(&args[0], &option))
				return 0;
			root->i_uid = option;
			break;
		case Opt_gid:
			if (match_int(&args[0], &option))
				return 0;
			root->i_gid = option;
			break;
		default:
			return 0;
		}
	}
	return 1;
}

static void
spufs_init_isolated_loader(void)
{
	struct device_node *dn;
	const char *loader;
	int size;

	dn = of_find_node_by_path("/spu-isolation");
	if (!dn)
		return;

	loader = get_property(dn, "loader", &size);
	if (!loader)
		return;

	/* kmalloc should align on a 16 byte boundary..* */
	isolated_loader = kmalloc(size, GFP_KERNEL);
	if (!isolated_loader)
		return;

	memcpy(isolated_loader, loader, size);
	printk(KERN_INFO "spufs: SPU isolation mode enabled\n");
}

static int
spufs_create_root(struct super_block *sb, void *data)
{
	struct inode *inode;
	int ret;

	ret = -ENOMEM;
	inode = spufs_new_inode(sb, S_IFDIR | 0775);
	if (!inode)
		goto out;

	inode->i_op = &spufs_dir_inode_operations;
	inode->i_fop = &simple_dir_operations;
	SPUFS_I(inode)->i_ctx = NULL;

	ret = -EINVAL;
	if (!spufs_parse_options(data, inode))
		goto out_iput;

	ret = -ENOMEM;
	sb->s_root = d_alloc_root(inode);
	if (!sb->s_root)
		goto out_iput;

	return 0;
out_iput:
	iput(inode);
out:
	return ret;
}

static int
spufs_fill_super(struct super_block *sb, void *data, int silent)
{
	static struct super_operations s_ops = {
		.alloc_inode = spufs_alloc_inode,
		.destroy_inode = spufs_destroy_inode,
		.statfs = simple_statfs,
		.delete_inode = spufs_delete_inode,
		.drop_inode = generic_delete_inode,
	};

	sb->s_maxbytes = MAX_LFS_FILESIZE;
	sb->s_blocksize = PAGE_CACHE_SIZE;
	sb->s_blocksize_bits = PAGE_CACHE_SHIFT;
	sb->s_magic = SPUFS_MAGIC;
	sb->s_op = &s_ops;

	return spufs_create_root(sb, data);
}

static int
spufs_get_sb(struct file_system_type *fstype, int flags,
		const char *name, void *data, struct vfsmount *mnt)
{
	return get_sb_single(fstype, flags, data, spufs_fill_super, mnt);
}

static struct file_system_type spufs_type = {
	.owner = THIS_MODULE,
	.name = "spufs",
	.get_sb = spufs_get_sb,
	.kill_sb = kill_litter_super,
};

static int __init spufs_init(void)
{
	int ret;

	ret = -ENOMEM;
	spufs_inode_cache = kmem_cache_create("spufs_inode_cache",
			sizeof(struct spufs_inode_info), 0,
			SLAB_HWCACHE_ALIGN, spufs_init_once, NULL);

	if (!spufs_inode_cache)
		goto out;
	if (spu_sched_init() != 0) {
		kmem_cache_destroy(spufs_inode_cache);
		goto out;
	}
	ret = register_filesystem(&spufs_type);
	if (ret)
		goto out_cache;
	ret = register_spu_syscalls(&spufs_calls);
	if (ret)
		goto out_fs;
	ret = register_arch_coredump_calls(&spufs_coredump_calls);
	if (ret)
		goto out_fs;

	spufs_init_isolated_loader();

	return 0;
out_fs:
	unregister_filesystem(&spufs_type);
out_cache:
	kmem_cache_destroy(spufs_inode_cache);
out:
	return ret;
}
module_init(spufs_init);

static void __exit spufs_exit(void)
{
	spu_sched_exit();
	unregister_arch_coredump_calls(&spufs_coredump_calls);
	unregister_spu_syscalls(&spufs_calls);
	unregister_filesystem(&spufs_type);
	kmem_cache_destroy(spufs_inode_cache);
}
module_exit(spufs_exit);

MODULE_LICENSE("GPL");
MODULE_AUTHOR("Arnd Bergmann <arndb@de.ibm.com>");
Commit	Line	Data
67207b96 AB	1	/*
	2	* SPU file system
	3	*
	4	* (C) Copyright IBM Deutschland Entwicklung GmbH 2005
	5	*
	6	* Author: Arnd Bergmann <arndb@de.ibm.com>
	7	*
	8	* This program is free software; you can redistribute it and/or modify
	9	* it under the terms of the GNU General Public License as published by
	10	* the Free Software Foundation; either version 2, or (at your option)
	11	* any later version.
	12	*
	13	* This program is distributed in the hope that it will be useful,
	14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	16	* GNU General Public License for more details.
	17	*
	18	* You should have received a copy of the GNU General Public License
	19	* along with this program; if not, write to the Free Software
	20	* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
	21	*/
	22
	23	#include <linux/file.h>
	24	#include <linux/fs.h>
	25	#include <linux/backing-dev.h>
	26	#include <linux/init.h>
	27	#include <linux/ioctl.h>
	28	#include <linux/module.h>
346f4d3c	29	#include <linux/mount.h>
67207b96 AB	30	#include <linux/namei.h>
	31	#include <linux/pagemap.h>
	32	#include <linux/poll.h>
	33	#include <linux/slab.h>
	34	#include <linux/parser.h>
	35
0afacde3	36	#include <asm/prom.h>
67207b96 AB	37	#include <asm/semaphore.h>
	38	#include <asm/spu.h>
	39	#include <asm/uaccess.h>
	40
	41	#include "spufs.h"
	42
	43	static kmem_cache_t *spufs_inode_cache;
c6730ed4	44	char *isolated_loader;
67207b96	45
67207b96 AB	46	static struct inode *
	47	spufs_alloc_inode(struct super_block *sb)
	48	{
	49	struct spufs_inode_info *ei;
	50
	51	ei = kmem_cache_alloc(spufs_inode_cache, SLAB_KERNEL);
	52	if (!ei)
	53	return NULL;
6263203e AB	54
	55	ei->i_gang = NULL;
	56	ei->i_ctx = NULL;
	57
67207b96 AB	58	return &ei->vfs_inode;
	59	}
	60
	61	static void
	62	spufs_destroy_inode(struct inode *inode)
	63	{
	64	kmem_cache_free(spufs_inode_cache, SPUFS_I(inode));
	65	}
	66
	67	static void
	68	spufs_init_once(void p, kmem_cache_t cachep, unsigned long flags)
	69	{
	70	struct spufs_inode_info *ei = p;
	71
	72	if ((flags & (SLAB_CTOR_VERIFY\|SLAB_CTOR_CONSTRUCTOR)) ==
	73	SLAB_CTOR_CONSTRUCTOR) {
	74	inode_init_once(&ei->vfs_inode);
	75	}
	76	}
	77
	78	static struct inode *
	79	spufs_new_inode(struct super_block *sb, int mode)
	80	{
	81	struct inode *inode;
	82
	83	inode = new_inode(sb);
	84	if (!inode)
	85	goto out;
	86
	87	inode->i_mode = mode;
	88	inode->i_uid = current->fsuid;
	89	inode->i_gid = current->fsgid;
67207b96 AB	90	inode->i_blocks = 0;
	91	inode->i_atime = inode->i_mtime = inode->i_ctime = CURRENT_TIME;
	92	out:
	93	return inode;
	94	}
	95
	96	static int
	97	spufs_setattr(struct dentry dentry, struct iattr attr)
	98	{
	99	struct inode *inode = dentry->d_inode;
	100
67207b96 AB	101	if ((attr->ia_valid & ATTR_SIZE) &&
	102	(attr->ia_size != inode->i_size))
	103	return -EINVAL;
	104	return inode_setattr(inode, attr);
	105	}
	106
	107
	108	static int
	109	spufs_new_file(struct super_block sb, struct dentry dentry,
99ac48f5	110	const struct file_operations *fops, int mode,
67207b96 AB	111	struct spu_context *ctx)
	112	{
	113	static struct inode_operations spufs_file_iops = {
67207b96	114	.setattr = spufs_setattr,
67207b96 AB	115	};
	116	struct inode *inode;
	117	int ret;
	118
	119	ret = -ENOSPC;
	120	inode = spufs_new_inode(sb, S_IFREG \| mode);
	121	if (!inode)
	122	goto out;
	123
	124	ret = 0;
	125	inode->i_op = &spufs_file_iops;
	126	inode->i_fop = fops;
8e18e294	127	inode->i_private = SPUFS_I(inode)->i_ctx = get_spu_context(ctx);
67207b96 AB	128	d_add(dentry, inode);
	129	out:
	130	return ret;
	131	}
	132
	133	static void
	134	spufs_delete_inode(struct inode *inode)
	135	{
6263203e AB	136	struct spufs_inode_info *ei = SPUFS_I(inode);
	137
	138	if (ei->i_ctx)
	139	put_spu_context(ei->i_ctx);
	140	if (ei->i_gang)
	141	put_spu_gang(ei->i_gang);
67207b96 AB	142	clear_inode(inode);
	143	}
	144
3f51dd91	145	static void spufs_prune_dir(struct dentry *dir)
67207b96	146	{
8b3d6663	147	struct dentry dentry, tmp;
6263203e	148
1b1dcc1b	149	mutex_lock(&dir->d_inode->i_mutex);
c3a9aea7	150	list_for_each_entry_safe(dentry, tmp, &dir->d_subdirs, d_u.d_child) {
8b3d6663	151	spin_lock(&dcache_lock);
67207b96	152	spin_lock(&dentry->d_lock);
8b3d6663 AB	153	if (!(d_unhashed(dentry)) && dentry->d_inode) {
	154	dget_locked(dentry);
	155	__d_drop(dentry);
	156	spin_unlock(&dentry->d_lock);
3f51dd91	157	simple_unlink(dir->d_inode, dentry);
8b3d6663 AB	158	spin_unlock(&dcache_lock);
	159	dput(dentry);
	160	} else {
	161	spin_unlock(&dentry->d_lock);
	162	spin_unlock(&dcache_lock);
	163	}
67207b96	164	}
3f51dd91	165	shrink_dcache_parent(dir);
1b1dcc1b	166	mutex_unlock(&dir->d_inode->i_mutex);
3f51dd91 AB	167	}
3f51dd91 AB	168
6263203e AB	169	/* Caller must hold parent->i_mutex */
6263203e AB	170	static int spufs_rmdir(struct inode parent, struct dentry dir)
3f51dd91	171	{
3f51dd91	172	/* remove all entries */
6263203e	173	spufs_prune_dir(dir);
8b3d6663	174
6263203e	175	return simple_rmdir(parent, dir);
67207b96 AB	176	}
67207b96 AB	177
3f51dd91 AB	178	static int spufs_fill_dir(struct dentry dir, struct tree_descr files,
	179	int mode, struct spu_context *ctx)
	180	{
	181	struct dentry *dentry;
	182	int ret;
	183
	184	while (files->name && files->name[0]) {
	185	ret = -ENOMEM;
	186	dentry = d_alloc_name(dir, files->name);
	187	if (!dentry)
	188	goto out;
	189	ret = spufs_new_file(dir->d_sb, dentry, files->ops,
	190	files->mode & mode, ctx);
	191	if (ret)
	192	goto out;
	193	files++;
	194	}
	195	return 0;
	196	out:
	197	spufs_prune_dir(dir);
	198	return ret;
	199	}
	200
67207b96 AB	201	static int spufs_dir_close(struct inode inode, struct file file)
67207b96 AB	202	{
0309f02d	203	struct spu_context *ctx;
6263203e AB	204	struct inode *parent;
6263203e AB	205	struct dentry *dir;
67207b96 AB	206	int ret;
67207b96 AB	207
6263203e AB	208	dir = file->f_dentry;
	209	parent = dir->d_parent->d_inode;
	210	ctx = SPUFS_I(dir->d_inode)->i_ctx;
c8ca0633	211
6263203e AB	212	mutex_lock(&parent->i_mutex);
	213	ret = spufs_rmdir(parent, dir);
	214	mutex_unlock(&parent->i_mutex);
67207b96	215	WARN_ON(ret);
c8ca0633	216
0309f02d ME	217	/* We have to give up the mm_struct */
	218	spu_forget(ctx);
	219
67207b96 AB	220	return dcache_dir_close(inode, file);
	221	}
	222
	223	struct inode_operations spufs_dir_inode_operations = {
	224	.lookup = simple_lookup,
	225	};
	226
e80358ad	227	struct file_operations spufs_context_fops = {
67207b96 AB	228	.open = dcache_dir_open,
	229	.release = spufs_dir_close,
	230	.llseek = dcache_dir_lseek,
	231	.read = generic_read_dir,
	232	.readdir = dcache_readdir,
	233	.fsync = simple_sync_file,
	234	};
bf1ab978	235	EXPORT_SYMBOL_GPL(spufs_context_fops);
67207b96 AB	236
67207b96 AB	237	static int
9add11da AB	238	spufs_mkdir(struct inode dir, struct dentry dentry, unsigned int flags,
9add11da AB	239	int mode)
67207b96 AB	240	{
	241	int ret;
	242	struct inode *inode;
	243	struct spu_context *ctx;
	244
	245	ret = -ENOSPC;
	246	inode = spufs_new_inode(dir->i_sb, mode \| S_IFDIR);
	247	if (!inode)
	248	goto out;
	249
	250	if (dir->i_mode & S_ISGID) {
	251	inode->i_gid = dir->i_gid;
	252	inode->i_mode &= S_ISGID;
	253	}
6263203e	254	ctx = alloc_spu_context(SPUFS_I(dir)->i_gang); /* XXX gang */
67207b96 AB	255	SPUFS_I(inode)->i_ctx = ctx;
	256	if (!ctx)
	257	goto out_iput;
	258
9add11da	259	ctx->flags = flags;
67207b96 AB	260	inode->i_op = &spufs_dir_inode_operations;
67207b96 AB	261	inode->i_fop = &simple_dir_operations;
5737edd1 MN	262	if (flags & SPU_CREATE_NOSCHED)
	263	ret = spufs_fill_dir(dentry, spufs_dir_nosched_contents,
	264	mode, ctx);
	265	else
	266	ret = spufs_fill_dir(dentry, spufs_dir_contents, mode, ctx);
	267
67207b96 AB	268	if (ret)
	269	goto out_free_ctx;
	270
	271	d_instantiate(dentry, inode);
	272	dget(dentry);
	273	dir->i_nlink++;
346f4d3c	274	dentry->d_inode->i_nlink++;
67207b96 AB	275	goto out;
	276
	277	out_free_ctx:
	278	put_spu_context(ctx);
	279	out_iput:
	280	iput(inode);
	281	out:
	282	return ret;
	283	}
	284
346f4d3c AB	285	static int spufs_context_open(struct dentry dentry, struct vfsmount mnt)
	286	{
	287	int ret;
	288	struct file *filp;
	289
	290	ret = get_unused_fd();
	291	if (ret < 0) {
	292	dput(dentry);
	293	mntput(mnt);
	294	goto out;
	295	}
	296
	297	filp = dentry_open(dentry, mnt, O_RDONLY);
	298	if (IS_ERR(filp)) {
	299	put_unused_fd(ret);
	300	ret = PTR_ERR(filp);
	301	goto out;
	302	}
	303
	304	filp->f_op = &spufs_context_fops;
	305	fd_install(ret, filp);
	306	out:
	307	return ret;
	308	}
	309
6263203e AB	310	static int spufs_create_context(struct inode *inode,
	311	struct dentry *dentry,
	312	struct vfsmount *mnt, int flags, int mode)
	313	{
	314	int ret;
	315
5737edd1 MN	316	ret = -EPERM;
	317	if ((flags & SPU_CREATE_NOSCHED) &&
	318	!capable(CAP_SYS_NICE))
	319	goto out_unlock;
	320
	321	ret = -EINVAL;
	322	if ((flags & (SPU_CREATE_NOSCHED \| SPU_CREATE_ISOLATE))
	323	== SPU_CREATE_ISOLATE)
	324	goto out_unlock;
	325
6263203e AB	326	ret = spufs_mkdir(inode, dentry, flags, mode & S_IRWXUGO);
	327	if (ret)
	328	goto out_unlock;
	329
	330	/*
	331	* get references for dget and mntget, will be released
	332	* in error path of *_open().
	333	*/
	334	ret = spufs_context_open(dget(dentry), mntget(mnt));
	335	if (ret < 0) {
	336	WARN_ON(spufs_rmdir(inode, dentry));
	337	mutex_unlock(&inode->i_mutex);
	338	spu_forget(SPUFS_I(dentry->d_inode)->i_ctx);
	339	goto out;
	340	}
	341
	342	out_unlock:
	343	mutex_unlock(&inode->i_mutex);
	344	out:
	345	dput(dentry);
	346	return ret;
	347	}
	348
	349	static int spufs_rmgang(struct inode root, struct dentry dir)
	350	{
	351	/* FIXME: this fails if the dir is not empty,
	352	which causes a leak of gangs. */
	353	return simple_rmdir(root, dir);
	354	}
	355
	356	static int spufs_gang_close(struct inode inode, struct file file)
	357	{
	358	struct inode *parent;
	359	struct dentry *dir;
	360	int ret;
	361
	362	dir = file->f_dentry;
	363	parent = dir->d_parent->d_inode;
	364
	365	ret = spufs_rmgang(parent, dir);
	366	WARN_ON(ret);
	367
	368	return dcache_dir_close(inode, file);
	369	}
	370
	371	struct file_operations spufs_gang_fops = {
	372	.open = dcache_dir_open,
	373	.release = spufs_gang_close,
	374	.llseek = dcache_dir_lseek,
	375	.read = generic_read_dir,
	376	.readdir = dcache_readdir,
	377	.fsync = simple_sync_file,
	378	};
	379
	380	static int
	381	spufs_mkgang(struct inode dir, struct dentry dentry, int mode)
	382	{
	383	int ret;
	384	struct inode *inode;
	385	struct spu_gang *gang;
	386
	387	ret = -ENOSPC;
	388	inode = spufs_new_inode(dir->i_sb, mode \| S_IFDIR);
	389	if (!inode)
390	goto out;
391
392	ret = 0;
393	if (dir->i_mode & S_ISGID) {
394	inode->i_gid = dir->i_gid;
395	inode->i_mode &= S_ISGID;
396	}
397	gang = alloc_spu_gang();
398	SPUFS_I(inode)->i_ctx = NULL;
399	SPUFS_I(inode)->i_gang = gang;
400	if (!gang)
401	goto out_iput;
402
403	inode->i_op = &spufs_dir_inode_operations;
404	inode->i_fop = &simple_dir_operations;
405
406	d_instantiate(dentry, inode);
407	dget(dentry);
408	dir->i_nlink++;
409	dentry->d_inode->i_nlink++;
410	return ret;
411
412	out_iput:
413	iput(inode);
414	out:
415	return ret;
416	}
417
418	static int spufs_gang_open(struct dentry dentry, struct vfsmount mnt)
419	{
420	int ret;
421	struct file *filp;
422
423	ret = get_unused_fd();
424	if (ret < 0) {
425	dput(dentry);
426	mntput(mnt);
427	goto out;
428	}
429
430	filp = dentry_open(dentry, mnt, O_RDONLY);
431	if (IS_ERR(filp)) {
432	put_unused_fd(ret);
433	ret = PTR_ERR(filp);
434	goto out;
435	}
436
437	filp->f_op = &spufs_gang_fops;
438	fd_install(ret, filp);
439	out:
440	return ret;
441	}
442
443	static int spufs_create_gang(struct inode *inode,
444	struct dentry *dentry,
445	struct vfsmount *mnt, int mode)
446	{
447	int ret;
448
449	ret = spufs_mkgang(inode, dentry, mode & S_IRWXUGO);
450	if (ret)
451	goto out;
452
453	/*
454	* get references for dget and mntget, will be released
455	* in error path of *_open().
456	*/
457	ret = spufs_gang_open(dget(dentry), mntget(mnt));
458	if (ret < 0)
459	WARN_ON(spufs_rmgang(inode, dentry));
460
461	out:
462	mutex_unlock(&inode->i_mutex);
463	dput(dentry);
464	return ret;
465	}
466
467
346f4d3c AB	468	static struct file_system_type spufs_type;
346f4d3c AB	469
6263203e	470	long spufs_create(struct nameidata *nd, unsigned int flags, mode_t mode)
67207b96 AB	471	{
67207b96 AB	472	struct dentry *dentry;
67207b96 AB	473	int ret;
67207b96 AB	474
67207b96	475	ret = -EINVAL;
6263203e AB	476	/* check if we are on spufs */
6263203e AB	477	if (nd->dentry->d_sb->s_type != &spufs_type)
67207b96 AB	478	goto out;
67207b96 AB	479
6263203e	480	/* don't accept undefined flags */
9add11da	481	if (flags & (~SPU_CREATE_FLAG_ALL))
c9832948 AB	482	goto out;
c9832948 AB	483
6263203e AB	484	/* only threads can be underneath a gang */
	485	if (nd->dentry != nd->dentry->d_sb->s_root) {
	486	if ((flags & SPU_CREATE_GANG) \|\|
	487	!SPUFS_I(nd->dentry->d_inode)->i_gang)
	488	goto out;
	489	}
	490
67207b96 AB	491	dentry = lookup_create(nd, 1);
	492	ret = PTR_ERR(dentry);
	493	if (IS_ERR(dentry))
	494	goto out_dir;
	495
	496	ret = -EEXIST;
	497	if (dentry->d_inode)
	498	goto out_dput;
	499
	500	mode &= ~current->fs->umask;
67207b96	501
6263203e AB	502	if (flags & SPU_CREATE_GANG)
	503	return spufs_create_gang(nd->dentry->d_inode,
	504	dentry, nd->mnt, mode);
	505	else
	506	return spufs_create_context(nd->dentry->d_inode,
	507	dentry, nd->mnt, flags, mode);
67207b96 AB	508
	509	out_dput:
	510	dput(dentry);
	511	out_dir:
1b1dcc1b	512	mutex_unlock(&nd->dentry->d_inode->i_mutex);
67207b96 AB	513	out:
	514	return ret;
	515	}
	516
	517	/* File system initialization */
	518	enum {
	519	Opt_uid, Opt_gid, Opt_err,
	520	};
	521
	522	static match_table_t spufs_tokens = {
	523	{ Opt_uid, "uid=%d" },
	524	{ Opt_gid, "gid=%d" },
	525	{ Opt_err, NULL },
	526	};
	527
	528	static int
	529	spufs_parse_options(char options, struct inode root)
	530	{
	531	char *p;
	532	substring_t args[MAX_OPT_ARGS];
	533
	534	while ((p = strsep(&options, ",")) != NULL) {
	535	int token, option;
	536
	537	if (!*p)
	538	continue;
	539
	540	token = match_token(p, spufs_tokens, args);
	541	switch (token) {
	542	case Opt_uid:
	543	if (match_int(&args[0], &option))
	544	return 0;
	545	root->i_uid = option;
	546	break;
	547	case Opt_gid:
	548	if (match_int(&args[0], &option))
	549	return 0;
	550	root->i_gid = option;
	551	break;
	552	default:
	553	return 0;
	554	}
	555	}
	556	return 1;
	557	}
	558
0afacde3 AB	559	static void
	560	spufs_init_isolated_loader(void)
	561	{
	562	struct device_node *dn;
	563	const char *loader;
	564	int size;
	565
	566	dn = of_find_node_by_path("/spu-isolation");
	567	if (!dn)
	568	return;
	569
	570	loader = get_property(dn, "loader", &size);
	571	if (!loader)
	572	return;
	573
	574	/* kmalloc should align on a 16 byte boundary..* */
	575	isolated_loader = kmalloc(size, GFP_KERNEL);
	576	if (!isolated_loader)
	577	return;
	578
	579	memcpy(isolated_loader, loader, size);
	580	printk(KERN_INFO "spufs: SPU isolation mode enabled\n");
	581	}
	582
67207b96	583	static int
8b3d6663 AB	584	spufs_create_root(struct super_block sb, void data)
8b3d6663 AB	585	{
67207b96 AB	586	struct inode *inode;
	587	int ret;
	588
	589	ret = -ENOMEM;
	590	inode = spufs_new_inode(sb, S_IFDIR \| 0775);
	591	if (!inode)
	592	goto out;
	593
	594	inode->i_op = &spufs_dir_inode_operations;
	595	inode->i_fop = &simple_dir_operations;
	596	SPUFS_I(inode)->i_ctx = NULL;
	597
	598	ret = -EINVAL;
	599	if (!spufs_parse_options(data, inode))
	600	goto out_iput;
	601
	602	ret = -ENOMEM;
	603	sb->s_root = d_alloc_root(inode);
	604	if (!sb->s_root)
	605	goto out_iput;
	606
	607	return 0;
	608	out_iput:
	609	iput(inode);
	610	out:
	611	return ret;
	612	}
	613
	614	static int
	615	spufs_fill_super(struct super_block sb, void data, int silent)
	616	{
	617	static struct super_operations s_ops = {
	618	.alloc_inode = spufs_alloc_inode,
	619	.destroy_inode = spufs_destroy_inode,
	620	.statfs = simple_statfs,
	621	.delete_inode = spufs_delete_inode,
	622	.drop_inode = generic_delete_inode,
	623	};
	624
	625	sb->s_maxbytes = MAX_LFS_FILESIZE;
	626	sb->s_blocksize = PAGE_CACHE_SIZE;
	627	sb->s_blocksize_bits = PAGE_CACHE_SHIFT;
	628	sb->s_magic = SPUFS_MAGIC;
	629	sb->s_op = &s_ops;
	630
	631	return spufs_create_root(sb, data);
	632	}
	633
454e2398	634	static int
67207b96	635	spufs_get_sb(struct file_system_type *fstype, int flags,
454e2398	636	const char name, void data, struct vfsmount *mnt)
67207b96	637	{
454e2398	638	return get_sb_single(fstype, flags, data, spufs_fill_super, mnt);
67207b96 AB	639	}
	640
	641	static struct file_system_type spufs_type = {
	642	.owner = THIS_MODULE,
	643	.name = "spufs",
	644	.get_sb = spufs_get_sb,
	645	.kill_sb = kill_litter_super,
	646	};
	647
e78b47a5	648	static int __init spufs_init(void)
67207b96 AB	649	{
67207b96 AB	650	int ret;
bf1ab978	651
67207b96 AB	652	ret = -ENOMEM;
	653	spufs_inode_cache = kmem_cache_create("spufs_inode_cache",
	654	sizeof(struct spufs_inode_info), 0,
	655	SLAB_HWCACHE_ALIGN, spufs_init_once, NULL);
	656
	657	if (!spufs_inode_cache)
	658	goto out;
8b3d6663 AB	659	if (spu_sched_init() != 0) {
	660	kmem_cache_destroy(spufs_inode_cache);
	661	goto out;
	662	}
67207b96 AB	663	ret = register_filesystem(&spufs_type);
	664	if (ret)
	665	goto out_cache;
	666	ret = register_spu_syscalls(&spufs_calls);
bf1ab978 DGM	667	if (ret)
	668	goto out_fs;
	669	ret = register_arch_coredump_calls(&spufs_coredump_calls);
67207b96 AB	670	if (ret)
67207b96 AB	671	goto out_fs;
0afacde3 AB	672
0afacde3 AB	673	spufs_init_isolated_loader();
bf1ab978	674
67207b96 AB	675	return 0;
	676	out_fs:
	677	unregister_filesystem(&spufs_type);
	678	out_cache:
	679	kmem_cache_destroy(spufs_inode_cache);
	680	out:
	681	return ret;
	682	}
	683	module_init(spufs_init);
	684
e78b47a5	685	static void __exit spufs_exit(void)
67207b96	686	{
8b3d6663	687	spu_sched_exit();
bf1ab978	688	unregister_arch_coredump_calls(&spufs_coredump_calls);
67207b96 AB	689	unregister_spu_syscalls(&spufs_calls);
	690	unregister_filesystem(&spufs_type);
	691	kmem_cache_destroy(spufs_inode_cache);
	692	}
	693	module_exit(spufs_exit);
	694
	695	MODULE_LICENSE("GPL");
	696	MODULE_AUTHOR("Arnd Bergmann <arndb@de.ibm.com>");
	697