[net-next-2.6.git] / fs / 9p / vfs_file.c

/*
 *  linux/fs/9p/vfs_file.c
 *
 * This file contians vfs file ops for 9P2000.
 *
 *  Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com>
 *  Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov>
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License version 2
 *  as published by the Free Software Foundation.
 *
 *  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:
 *  Free Software Foundation
 *  51 Franklin Street, Fifth Floor
 *  Boston, MA  02111-1301  USA
 *
 */

#include <linux/module.h>
#include <linux/errno.h>
#include <linux/fs.h>
#include <linux/sched.h>
#include <linux/file.h>
#include <linux/stat.h>
#include <linux/string.h>
#include <linux/inet.h>
#include <linux/list.h>
#include <linux/pagemap.h>
#include <linux/utsname.h>
#include <asm/uaccess.h>
#include <linux/idr.h>
#include <net/9p/9p.h>
#include <net/9p/client.h>

#include "v9fs.h"
#include "v9fs_vfs.h"
#include "fid.h"
#include "cache.h"

static const struct file_operations v9fs_cached_file_operations;
static const struct file_operations v9fs_cached_file_operations_dotl;

/**
 * v9fs_file_open - open a file (or directory)
 * @inode: inode to be opened
 * @file: file being opened
 *
 */

int v9fs_file_open(struct inode *inode, struct file *file)
{
	int err;
	struct v9fs_session_info *v9ses;
	struct p9_fid *fid;
	int omode;

	P9_DPRINTK(P9_DEBUG_VFS, "inode: %p file: %p\n", inode, file);
	v9ses = v9fs_inode2v9ses(inode);
	if (v9fs_proto_dotl(v9ses))
		omode = file->f_flags;
	else
		omode = v9fs_uflags2omode(file->f_flags,
					v9fs_proto_dotu(v9ses));
	fid = file->private_data;
	if (!fid) {
		fid = v9fs_fid_clone(file->f_path.dentry);
		if (IS_ERR(fid))
			return PTR_ERR(fid);

		err = p9_client_open(fid, omode);
		if (err < 0) {
			p9_client_clunk(fid);
			return err;
		}
		if (file->f_flags & O_TRUNC) {
			i_size_write(inode, 0);
			inode->i_blocks = 0;
		}
		if ((file->f_flags & O_APPEND) &&
			(!v9fs_proto_dotu(v9ses) && !v9fs_proto_dotl(v9ses)))
			generic_file_llseek(file, 0, SEEK_END);
	}

	file->private_data = fid;
	if ((fid->qid.version) && (v9ses->cache)) {
		P9_DPRINTK(P9_DEBUG_VFS, "cached");
		/* enable cached file options */
		if(file->f_op == &v9fs_file_operations)
			file->f_op = &v9fs_cached_file_operations;
		else if (file->f_op == &v9fs_file_operations_dotl)
			file->f_op = &v9fs_cached_file_operations_dotl;

#ifdef CONFIG_9P_FSCACHE
		v9fs_cache_inode_set_cookie(inode, file);
#endif
	}

	return 0;
}

/**
 * v9fs_file_lock - lock a file (or directory)
 * @filp: file to be locked
 * @cmd: lock command
 * @fl: file lock structure
 *
 * Bugs: this looks like a local only lock, we should extend into 9P
 *       by using open exclusive
 */

static int v9fs_file_lock(struct file *filp, int cmd, struct file_lock *fl)
{
	int res = 0;
	struct inode *inode = filp->f_path.dentry->d_inode;

	P9_DPRINTK(P9_DEBUG_VFS, "filp: %p lock: %p\n", filp, fl);

	/* No mandatory locks */
	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
		return -ENOLCK;

	if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
		filemap_write_and_wait(inode->i_mapping);
		invalidate_mapping_pages(&inode->i_data, 0, -1);
	}

	return res;
}

static int v9fs_file_do_lock(struct file *filp, int cmd, struct file_lock *fl)
{
	struct p9_flock flock;
	struct p9_fid *fid;
	uint8_t status;
	int res = 0;
	unsigned char fl_type;

	fid = filp->private_data;
	BUG_ON(fid == NULL);

	if ((fl->fl_flags & FL_POSIX) != FL_POSIX)
		BUG();

	res = posix_lock_file_wait(filp, fl);
	if (res < 0)
		goto out;

	/* convert posix lock to p9 tlock args */
	memset(&flock, 0, sizeof(flock));
	flock.type = fl->fl_type;
	flock.start = fl->fl_start;
	if (fl->fl_end == OFFSET_MAX)
		flock.length = 0;
	else
		flock.length = fl->fl_end - fl->fl_start + 1;
	flock.proc_id = fl->fl_pid;
	flock.client_id = utsname()->nodename;
	if (IS_SETLKW(cmd))
		flock.flags = P9_LOCK_FLAGS_BLOCK;

	/*
	 * if its a blocked request and we get P9_LOCK_BLOCKED as the status
	 * for lock request, keep on trying
	 */
	for (;;) {
		res = p9_client_lock_dotl(fid, &flock, &status);
		if (res < 0)
			break;

		if (status != P9_LOCK_BLOCKED)
			break;
		if (status == P9_LOCK_BLOCKED && !IS_SETLKW(cmd))
			break;
		schedule_timeout_interruptible(P9_LOCK_TIMEOUT);
	}

	/* map 9p status to VFS status */
	switch (status) {
	case P9_LOCK_SUCCESS:
		res = 0;
		break;
	case P9_LOCK_BLOCKED:
		res = -EAGAIN;
		break;
	case P9_LOCK_ERROR:
	case P9_LOCK_GRACE:
		res = -ENOLCK;
		break;
	default:
		BUG();
	}

	/*
	 * incase server returned error for lock request, revert
	 * it locally
	 */
	if (res < 0 && fl->fl_type != F_UNLCK) {
		fl_type = fl->fl_type;
		fl->fl_type = F_UNLCK;
		res = posix_lock_file_wait(filp, fl);
		fl->fl_type = fl_type;
	}
out:
	return res;
}

static int v9fs_file_getlock(struct file *filp, struct file_lock *fl)
{
	struct p9_getlock glock;
	struct p9_fid *fid;
	int res = 0;

	fid = filp->private_data;
	BUG_ON(fid == NULL);

	posix_test_lock(filp, fl);
	/*
	 * if we have a conflicting lock locally, no need to validate
	 * with server
	 */
	if (fl->fl_type != F_UNLCK)
		return res;

	/* convert posix lock to p9 tgetlock args */
	memset(&glock, 0, sizeof(glock));
	glock.type = fl->fl_type;
	glock.start = fl->fl_start;
	if (fl->fl_end == OFFSET_MAX)
		glock.length = 0;
	else
		glock.length = fl->fl_end - fl->fl_start + 1;
	glock.proc_id = fl->fl_pid;
	glock.client_id = utsname()->nodename;

	res = p9_client_getlock_dotl(fid, &glock);
	if (res < 0)
		return res;
	if (glock.type != F_UNLCK) {
		fl->fl_type = glock.type;
		fl->fl_start = glock.start;
		if (glock.length == 0)
			fl->fl_end = OFFSET_MAX;
		else
			fl->fl_end = glock.start + glock.length - 1;
		fl->fl_pid = glock.proc_id;
	} else
		fl->fl_type = F_UNLCK;

	return res;
}

/**
 * v9fs_file_lock_dotl - lock a file (or directory)
 * @filp: file to be locked
 * @cmd: lock command
 * @fl: file lock structure
 *
 */

static int v9fs_file_lock_dotl(struct file *filp, int cmd, struct file_lock *fl)
{
	struct inode *inode = filp->f_path.dentry->d_inode;
	int ret = -ENOLCK;

	P9_DPRINTK(P9_DEBUG_VFS, "filp: %p cmd:%d lock: %p name: %s\n", filp,
				cmd, fl, filp->f_path.dentry->d_name.name);

	/* No mandatory locks */
	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
		goto out_err;

	if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
		filemap_write_and_wait(inode->i_mapping);
		invalidate_mapping_pages(&inode->i_data, 0, -1);
	}

	if (IS_SETLK(cmd) || IS_SETLKW(cmd))
		ret = v9fs_file_do_lock(filp, cmd, fl);
	else if (IS_GETLK(cmd))
		ret = v9fs_file_getlock(filp, fl);
	else
		ret = -EINVAL;
out_err:
	return ret;
}

/**
 * v9fs_file_flock_dotl - lock a file
 * @filp: file to be locked
 * @cmd: lock command
 * @fl: file lock structure
 *
 */

static int v9fs_file_flock_dotl(struct file *filp, int cmd,
	struct file_lock *fl)
{
	struct inode *inode = filp->f_path.dentry->d_inode;
	int ret = -ENOLCK;

	P9_DPRINTK(P9_DEBUG_VFS, "filp: %p cmd:%d lock: %p name: %s\n", filp,
				cmd, fl, filp->f_path.dentry->d_name.name);

	/* No mandatory locks */
	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
		goto out_err;

	if (!(fl->fl_flags & FL_FLOCK))
		goto out_err;

	if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
		filemap_write_and_wait(inode->i_mapping);
		invalidate_mapping_pages(&inode->i_data, 0, -1);
	}
	/* Convert flock to posix lock */
	fl->fl_owner = (fl_owner_t)filp;
	fl->fl_start = 0;
	fl->fl_end = OFFSET_MAX;
	fl->fl_flags |= FL_POSIX;
	fl->fl_flags ^= FL_FLOCK;

	if (IS_SETLK(cmd) | IS_SETLKW(cmd))
		ret = v9fs_file_do_lock(filp, cmd, fl);
	else
		ret = -EINVAL;
out_err:
	return ret;
}

/**
 * v9fs_file_readn - read from a file
 * @filp: file pointer to read
 * @data: data buffer to read data into
 * @udata: user data buffer to read data into
 * @count: size of buffer
 * @offset: offset at which to read data
 *
 */

ssize_t
v9fs_file_readn(struct file *filp, char *data, char __user *udata, u32 count,
	       u64 offset)
{
	int n, total, size;
	struct p9_fid *fid = filp->private_data;

	P9_DPRINTK(P9_DEBUG_VFS, "fid %d offset %llu count %d\n", fid->fid,
					(long long unsigned) offset, count);

	n = 0;
	total = 0;
	size = fid->iounit ? fid->iounit : fid->clnt->msize - P9_IOHDRSZ;
	do {
		n = p9_client_read(fid, data, udata, offset, count);
		if (n <= 0)
			break;

		if (data)
			data += n;
		if (udata)
			udata += n;

		offset += n;
		count -= n;
		total += n;
	} while (count > 0 && n == size);

	if (n < 0)
		total = n;

	return total;
}

/**
 * v9fs_file_read - read from a file
 * @filp: file pointer to read
 * @udata: user data buffer to read data into
 * @count: size of buffer
 * @offset: offset at which to read data
 *
 */

static ssize_t
v9fs_file_read(struct file *filp, char __user *udata, size_t count,
	       loff_t * offset)
{
	int ret;
	struct p9_fid *fid;
	size_t size;

	P9_DPRINTK(P9_DEBUG_VFS, "count %zu offset %lld\n", count, *offset);
	fid = filp->private_data;

	size = fid->iounit ? fid->iounit : fid->clnt->msize - P9_IOHDRSZ;
	if (count > size)
		ret = v9fs_file_readn(filp, NULL, udata, count, *offset);
	else
		ret = p9_client_read(fid, NULL, udata, *offset, count);

	if (ret > 0)
		*offset += ret;

	return ret;
}

/**
 * v9fs_file_write - write to a file
 * @filp: file pointer to write
 * @data: data buffer to write data from
 * @count: size of buffer
 * @offset: offset at which to write data
 *
 */

static ssize_t
v9fs_file_write(struct file *filp, const char __user * data,
		size_t count, loff_t * offset)
{
	ssize_t retval;
	size_t total = 0;
	int n;
	struct p9_fid *fid;
	struct p9_client *clnt;
	struct inode *inode = filp->f_path.dentry->d_inode;
	loff_t origin = *offset;
	unsigned long pg_start, pg_end;

	P9_DPRINTK(P9_DEBUG_VFS, "data %p count %d offset %x\n", data,
		(int)count, (int)*offset);

	fid = filp->private_data;
	clnt = fid->clnt;

	retval = generic_write_checks(filp, &origin, &count, 0);
	if (retval)
		goto out;

	retval = -EINVAL;
	if ((ssize_t) count < 0)
		goto out;
	retval = 0;
	if (!count)
		goto out;

	do {
		n = p9_client_write(fid, NULL, data+total, origin+total, count);
		if (n <= 0)
			break;
		count -= n;
		total += n;
	} while (count > 0);

	if (total > 0) {
		pg_start = origin >> PAGE_CACHE_SHIFT;
		pg_end = (origin + total - 1) >> PAGE_CACHE_SHIFT;
		if (inode->i_mapping && inode->i_mapping->nrpages)
			invalidate_inode_pages2_range(inode->i_mapping,
						      pg_start, pg_end);
		*offset += total;
		i_size_write(inode, i_size_read(inode) + total);
		inode->i_blocks = (i_size_read(inode) + 512 - 1) >> 9;
	}

	if (n < 0)
		retval = n;
	else
		retval = total;
out:
	return retval;
}

static int v9fs_file_fsync(struct file *filp, int datasync)
{
	struct p9_fid *fid;
	struct p9_wstat wstat;
	int retval;

	P9_DPRINTK(P9_DEBUG_VFS, "filp %p datasync %x\n", filp, datasync);

	fid = filp->private_data;
	v9fs_blank_wstat(&wstat);

	retval = p9_client_wstat(fid, &wstat);
	return retval;
}

int v9fs_file_fsync_dotl(struct file *filp, int datasync)
{
	struct p9_fid *fid;
	int retval;

	P9_DPRINTK(P9_DEBUG_VFS, "v9fs_file_fsync_dotl: filp %p datasync %x\n",
			filp, datasync);

	fid = filp->private_data;

	retval = p9_client_fsync(fid, datasync);
	return retval;
}

static const struct file_operations v9fs_cached_file_operations = {
	.llseek = generic_file_llseek,
	.read = do_sync_read,
	.aio_read = generic_file_aio_read,
	.write = v9fs_file_write,
	.open = v9fs_file_open,
	.release = v9fs_dir_release,
	.lock = v9fs_file_lock,
	.mmap = generic_file_readonly_mmap,
	.fsync = v9fs_file_fsync,
};

static const struct file_operations v9fs_cached_file_operations_dotl = {
	.llseek = generic_file_llseek,
	.read = do_sync_read,
	.aio_read = generic_file_aio_read,
	.write = v9fs_file_write,
	.open = v9fs_file_open,
	.release = v9fs_dir_release,
	.lock = v9fs_file_lock_dotl,
	.flock = v9fs_file_flock_dotl,
	.mmap = generic_file_readonly_mmap,
	.fsync = v9fs_file_fsync_dotl,
};

const struct file_operations v9fs_file_operations = {
	.llseek = generic_file_llseek,
	.read = v9fs_file_read,
	.write = v9fs_file_write,
	.open = v9fs_file_open,
	.release = v9fs_dir_release,
	.lock = v9fs_file_lock,
	.mmap = generic_file_readonly_mmap,
	.fsync = v9fs_file_fsync,
};

const struct file_operations v9fs_file_operations_dotl = {
	.llseek = generic_file_llseek,
	.read = v9fs_file_read,
	.write = v9fs_file_write,
	.open = v9fs_file_open,
	.release = v9fs_dir_release,
	.lock = v9fs_file_lock_dotl,
	.flock = v9fs_file_flock_dotl,
	.mmap = generic_file_readonly_mmap,
	.fsync = v9fs_file_fsync_dotl,
};
Commit	Line	Data
e69e7fe5 EVH	1	/*
	2	* linux/fs/9p/vfs_file.c
	3	*
	4	* This file contians vfs file ops for 9P2000.
	5	*
	6	* Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com>
	7	* Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov>
	8	*
	9	* This program is free software; you can redistribute it and/or modify
42e8c509 EVH	10	* it under the terms of the GNU General Public License version 2
42e8c509 EVH	11	* as published by the Free Software Foundation.
e69e7fe5 EVH	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:
	20	* Free Software Foundation
	21	* 51 Franklin Street, Fifth Floor
	22	* Boston, MA 02111-1301 USA
	23	*
	24	*/
	25
	26	#include <linux/module.h>
	27	#include <linux/errno.h>
	28	#include <linux/fs.h>
914e2637	29	#include <linux/sched.h>
e69e7fe5 EVH	30	#include <linux/file.h>
	31	#include <linux/stat.h>
	32	#include <linux/string.h>
e69e7fe5	33	#include <linux/inet.h>
e69e7fe5	34	#include <linux/list.h>
637d020a	35	#include <linux/pagemap.h>
a099027c	36	#include <linux/utsname.h>
e69e7fe5 EVH	37	#include <asm/uaccess.h>
e69e7fe5 EVH	38	#include <linux/idr.h>
bd238fb4 LI	39	#include <net/9p/9p.h>
bd238fb4 LI	40	#include <net/9p/client.h>
e69e7fe5	41
e69e7fe5	42	#include "v9fs.h"
e69e7fe5 EVH	43	#include "v9fs_vfs.h"
e69e7fe5 EVH	44	#include "fid.h"
60e78d2c	45	#include "cache.h"
e69e7fe5	46
d32b687e	47	static const struct file_operations v9fs_cached_file_operations;
b04faaf3	48	static const struct file_operations v9fs_cached_file_operations_dotl;
d32b687e	49
e69e7fe5 EVH	50	/**
	51	* v9fs_file_open - open a file (or directory)
	52	* @inode: inode to be opened
	53	* @file: file being opened
	54	*
	55	*/
	56
	57	int v9fs_file_open(struct inode inode, struct file file)
	58	{
6a3124a3	59	int err;
bd238fb4 LI	60	struct v9fs_session_info *v9ses;
	61	struct p9_fid *fid;
	62	int omode;
e69e7fe5	63
ef56547e	64	P9_DPRINTK(P9_DEBUG_VFS, "inode: %p file: %p\n", inode, file);
bd238fb4	65	v9ses = v9fs_inode2v9ses(inode);
ef56547e MK	66	if (v9fs_proto_dotl(v9ses))
	67	omode = file->f_flags;
	68	else
	69	omode = v9fs_uflags2omode(file->f_flags,
	70	v9fs_proto_dotu(v9ses));
bd238fb4 LI	71	fid = file->private_data;
	72	if (!fid) {
	73	fid = v9fs_fid_clone(file->f_path.dentry);
	74	if (IS_ERR(fid))
	75	return PTR_ERR(fid);
	76
	77	err = p9_client_open(fid, omode);
9523a841	78	if (err < 0) {
bd238fb4 LI	79	p9_client_clunk(fid);
	80	return err;
	81	}
ef56547e	82	if (file->f_flags & O_TRUNC) {
7549ae3e	83	i_size_write(inode, 0);
9523a841 EVH	84	inode->i_blocks = 0;
9523a841 EVH	85	}
ef56547e MK	86	if ((file->f_flags & O_APPEND) &&
ef56547e MK	87	(!v9fs_proto_dotu(v9ses) && !v9fs_proto_dotl(v9ses)))
2e4bef41	88	generic_file_llseek(file, 0, SEEK_END);
6a3124a3	89	}
e69e7fe5	90
bd238fb4 LI	91	file->private_data = fid;
	92	if ((fid->qid.version) && (v9ses->cache)) {
	93	P9_DPRINTK(P9_DEBUG_VFS, "cached");
e03abc0c EVH	94	/* enable cached file options */
	95	if(file->f_op == &v9fs_file_operations)
	96	file->f_op = &v9fs_cached_file_operations;
b04faaf3 VJJ	97	else if (file->f_op == &v9fs_file_operations_dotl)
b04faaf3 VJJ	98	file->f_op = &v9fs_cached_file_operations_dotl;
60e78d2c AK	99
	100	#ifdef CONFIG_9P_FSCACHE
	101	v9fs_cache_inode_set_cookie(inode, file);
	102	#endif
e03abc0c EVH	103	}
e03abc0c EVH	104
6a3124a3	105	return 0;
e69e7fe5 EVH	106	}
	107
	108	/**
	109	* v9fs_file_lock - lock a file (or directory)
ee443996 EVH	110	* @filp: file to be locked
	111	* @cmd: lock command
	112	* @fl: file lock structure
e69e7fe5	113	*
ee443996	114	* Bugs: this looks like a local only lock, we should extend into 9P
e69e7fe5 EVH	115	* by using open exclusive
	116	*/
	117
	118	static int v9fs_file_lock(struct file filp, int cmd, struct file_lock fl)
	119	{
	120	int res = 0;
d6f787bc	121	struct inode *inode = filp->f_path.dentry->d_inode;
e69e7fe5	122
bd238fb4	123	P9_DPRINTK(P9_DEBUG_VFS, "filp: %p lock: %p\n", filp, fl);
e69e7fe5 EVH	124
e69e7fe5 EVH	125	/* No mandatory locks */
f78233dd	126	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
e69e7fe5 EVH	127	return -ENOLCK;
	128
	129	if ((IS_SETLK(cmd) \|\| IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
28fd1298	130	filemap_write_and_wait(inode->i_mapping);
fc0ecff6	131	invalidate_mapping_pages(&inode->i_data, 0, -1);
e69e7fe5 EVH	132	}
	133
	134	return res;
	135	}
	136
a099027c MK	137	static int v9fs_file_do_lock(struct file filp, int cmd, struct file_lock fl)
	138	{
	139	struct p9_flock flock;
	140	struct p9_fid *fid;
	141	uint8_t status;
	142	int res = 0;
	143	unsigned char fl_type;
	144
	145	fid = filp->private_data;
	146	BUG_ON(fid == NULL);
	147
	148	if ((fl->fl_flags & FL_POSIX) != FL_POSIX)
	149	BUG();
	150
	151	res = posix_lock_file_wait(filp, fl);
	152	if (res < 0)
	153	goto out;
	154
	155	/* convert posix lock to p9 tlock args */
	156	memset(&flock, 0, sizeof(flock));
	157	flock.type = fl->fl_type;
	158	flock.start = fl->fl_start;
	159	if (fl->fl_end == OFFSET_MAX)
	160	flock.length = 0;
	161	else
	162	flock.length = fl->fl_end - fl->fl_start + 1;
	163	flock.proc_id = fl->fl_pid;
	164	flock.client_id = utsname()->nodename;
	165	if (IS_SETLKW(cmd))
	166	flock.flags = P9_LOCK_FLAGS_BLOCK;
	167
	168	/*
	169	* if its a blocked request and we get P9_LOCK_BLOCKED as the status
	170	* for lock request, keep on trying
	171	*/
	172	for (;;) {
	173	res = p9_client_lock_dotl(fid, &flock, &status);
	174	if (res < 0)
	175	break;
	176
	177	if (status != P9_LOCK_BLOCKED)
	178	break;
	179	if (status == P9_LOCK_BLOCKED && !IS_SETLKW(cmd))
	180	break;
	181	schedule_timeout_interruptible(P9_LOCK_TIMEOUT);
	182	}
	183
	184	/* map 9p status to VFS status */
	185	switch (status) {
	186	case P9_LOCK_SUCCESS:
	187	res = 0;
	188	break;
	189	case P9_LOCK_BLOCKED:
	190	res = -EAGAIN;
	191	break;
	192	case P9_LOCK_ERROR:
	193	case P9_LOCK_GRACE:
	194	res = -ENOLCK;
	195	break;
	196	default:
	197	BUG();
	198	}
	199
	200	/*
201	* incase server returned error for lock request, revert
202	* it locally
203	*/
204	if (res < 0 && fl->fl_type != F_UNLCK) {
205	fl_type = fl->fl_type;
206	fl->fl_type = F_UNLCK;
207	res = posix_lock_file_wait(filp, fl);
208	fl->fl_type = fl_type;
209	}
210	out:
211	return res;
212	}
213
1d769cd1 MK	214	static int v9fs_file_getlock(struct file filp, struct file_lock fl)
	215	{
	216	struct p9_getlock glock;
	217	struct p9_fid *fid;
	218	int res = 0;
	219
	220	fid = filp->private_data;
	221	BUG_ON(fid == NULL);
	222
	223	posix_test_lock(filp, fl);
	224	/*
	225	* if we have a conflicting lock locally, no need to validate
	226	* with server
	227	*/
	228	if (fl->fl_type != F_UNLCK)
	229	return res;
	230
	231	/* convert posix lock to p9 tgetlock args */
	232	memset(&glock, 0, sizeof(glock));
	233	glock.type = fl->fl_type;
	234	glock.start = fl->fl_start;
	235	if (fl->fl_end == OFFSET_MAX)
	236	glock.length = 0;
	237	else
	238	glock.length = fl->fl_end - fl->fl_start + 1;
	239	glock.proc_id = fl->fl_pid;
	240	glock.client_id = utsname()->nodename;
	241
	242	res = p9_client_getlock_dotl(fid, &glock);
	243	if (res < 0)
	244	return res;
	245	if (glock.type != F_UNLCK) {
	246	fl->fl_type = glock.type;
	247	fl->fl_start = glock.start;
	248	if (glock.length == 0)
	249	fl->fl_end = OFFSET_MAX;
	250	else
	251	fl->fl_end = glock.start + glock.length - 1;
	252	fl->fl_pid = glock.proc_id;
	253	} else
	254	fl->fl_type = F_UNLCK;
	255
	256	return res;
	257	}
	258
a099027c MK	259	/**
	260	* v9fs_file_lock_dotl - lock a file (or directory)
	261	* @filp: file to be locked
	262	* @cmd: lock command
	263	* @fl: file lock structure
	264	*
	265	*/
	266
	267	static int v9fs_file_lock_dotl(struct file filp, int cmd, struct file_lock fl)
	268	{
	269	struct inode *inode = filp->f_path.dentry->d_inode;
	270	int ret = -ENOLCK;
	271
	272	P9_DPRINTK(P9_DEBUG_VFS, "filp: %p cmd:%d lock: %p name: %s\n", filp,
	273	cmd, fl, filp->f_path.dentry->d_name.name);
	274
	275	/* No mandatory locks */
	276	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
	277	goto out_err;
	278
	279	if ((IS_SETLK(cmd) \|\| IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
	280	filemap_write_and_wait(inode->i_mapping);
	281	invalidate_mapping_pages(&inode->i_data, 0, -1);
	282	}
	283
	284	if (IS_SETLK(cmd) \|\| IS_SETLKW(cmd))
	285	ret = v9fs_file_do_lock(filp, cmd, fl);
1d769cd1 MK	286	else if (IS_GETLK(cmd))
1d769cd1 MK	287	ret = v9fs_file_getlock(filp, fl);
a099027c MK	288	else
	289	ret = -EINVAL;
	290	out_err:
	291	return ret;
	292	}
	293
	294	/**
	295	* v9fs_file_flock_dotl - lock a file
	296	* @filp: file to be locked
	297	* @cmd: lock command
	298	* @fl: file lock structure
	299	*
	300	*/
	301
	302	static int v9fs_file_flock_dotl(struct file *filp, int cmd,
	303	struct file_lock *fl)
	304	{
	305	struct inode *inode = filp->f_path.dentry->d_inode;
	306	int ret = -ENOLCK;
	307
	308	P9_DPRINTK(P9_DEBUG_VFS, "filp: %p cmd:%d lock: %p name: %s\n", filp,
	309	cmd, fl, filp->f_path.dentry->d_name.name);
	310
	311	/* No mandatory locks */
	312	if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
	313	goto out_err;
	314
	315	if (!(fl->fl_flags & FL_FLOCK))
	316	goto out_err;
	317
	318	if ((IS_SETLK(cmd) \|\| IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
	319	filemap_write_and_wait(inode->i_mapping);
	320	invalidate_mapping_pages(&inode->i_data, 0, -1);
	321	}
	322	/* Convert flock to posix lock */
	323	fl->fl_owner = (fl_owner_t)filp;
	324	fl->fl_start = 0;
	325	fl->fl_end = OFFSET_MAX;
	326	fl->fl_flags \|= FL_POSIX;
	327	fl->fl_flags ^= FL_FLOCK;
	328
	329	if (IS_SETLK(cmd) \| IS_SETLKW(cmd))
	330	ret = v9fs_file_do_lock(filp, cmd, fl);
	331	else
	332	ret = -EINVAL;
	333	out_err:
	334	return ret;
	335	}
	336
e69e7fe5	337	/**
fbedadc1	338	* v9fs_file_readn - read from a file
ee443996	339	* @filp: file pointer to read
e69e7fe5	340	* @data: data buffer to read data into
fbedadc1	341	* @udata: user data buffer to read data into
e69e7fe5 EVH	342	* @count: size of buffer
	343	* @offset: offset at which to read data
	344	*
	345	*/
fbedadc1 EVH	346
	347	ssize_t
	348	v9fs_file_readn(struct file filp, char data, char __user *udata, u32 count,
	349	u64 offset)
	350	{
97e8442b	351	int n, total, size;
fbedadc1 EVH	352	struct p9_fid *fid = filp->private_data;
fbedadc1 EVH	353
51a87c55	354	P9_DPRINTK(P9_DEBUG_VFS, "fid %d offset %llu count %d\n", fid->fid,
fbedadc1 EVH	355	(long long unsigned) offset, count);
	356
	357	n = 0;
	358	total = 0;
97e8442b	359	size = fid->iounit ? fid->iounit : fid->clnt->msize - P9_IOHDRSZ;
fbedadc1 EVH	360	do {
	361	n = p9_client_read(fid, data, udata, offset, count);
	362	if (n <= 0)
	363	break;
	364
	365	if (data)
	366	data += n;
	367	if (udata)
	368	udata += n;
	369
	370	offset += n;
	371	count -= n;
	372	total += n;
97e8442b	373	} while (count > 0 && n == size);
fbedadc1 EVH	374
	375	if (n < 0)
	376	total = n;
	377
	378	return total;
	379	}
	380
	381	/**
	382	* v9fs_file_read - read from a file
	383	* @filp: file pointer to read
	384	* @udata: user data buffer to read data into
	385	* @count: size of buffer
	386	* @offset: offset at which to read data
	387	*
	388	*/
	389
e69e7fe5	390	static ssize_t
fbedadc1	391	v9fs_file_read(struct file filp, char __user udata, size_t count,
19cba8ab	392	loff_t * offset)
e69e7fe5	393	{
bd238fb4 LI	394	int ret;
bd238fb4 LI	395	struct p9_fid *fid;
97e8442b	396	size_t size;
e69e7fe5	397
ea2e7996	398	P9_DPRINTK(P9_DEBUG_VFS, "count %zu offset %lld\n", count, *offset);
bd238fb4	399	fid = filp->private_data;
fbedadc1	400
97e8442b MK	401	size = fid->iounit ? fid->iounit : fid->clnt->msize - P9_IOHDRSZ;
97e8442b MK	402	if (count > size)
fbedadc1 EVH	403	ret = v9fs_file_readn(filp, NULL, udata, count, *offset);
	404	else
	405	ret = p9_client_read(fid, NULL, udata, *offset, count);
	406
bd238fb4 LI	407	if (ret > 0)
bd238fb4 LI	408	*offset += ret;
e69e7fe5	409
bd238fb4	410	return ret;
e69e7fe5 EVH	411	}
	412
	413	/**
19cba8ab	414	* v9fs_file_write - write to a file
ee443996	415	* @filp: file pointer to write
e69e7fe5 EVH	416	* @data: data buffer to write data from
	417	* @count: size of buffer
	418	* @offset: offset at which to write data
	419	*
	420	*/
	421
	422	static ssize_t
19cba8ab LI	423	v9fs_file_write(struct file filp, const char __user data,
19cba8ab LI	424	size_t count, loff_t * offset)
e69e7fe5	425	{
3834b12a HPB	426	ssize_t retval;
3834b12a HPB	427	size_t total = 0;
8d40fa24	428	int n;
bd238fb4	429	struct p9_fid *fid;
dfb0ec2e	430	struct p9_client *clnt;
9523a841	431	struct inode *inode = filp->f_path.dentry->d_inode;
fc0f2961	432	loff_t origin = *offset;
637d020a	433	unsigned long pg_start, pg_end;
e69e7fe5	434
bd238fb4 LI	435	P9_DPRINTK(P9_DEBUG_VFS, "data %p count %d offset %x\n", data,
bd238fb4 LI	436	(int)count, (int)*offset);
e69e7fe5	437
bd238fb4	438	fid = filp->private_data;
dfb0ec2e EVH	439	clnt = fid->clnt;
dfb0ec2e EVH	440
3834b12a HPB	441	retval = generic_write_checks(filp, &origin, &count, 0);
	442	if (retval)
	443	goto out;
	444
	445	retval = -EINVAL;
	446	if ((ssize_t) count < 0)
	447	goto out;
	448	retval = 0;
	449	if (!count)
	450	goto out;
	451
dfb0ec2e	452	do {
8d40fa24	453	n = p9_client_write(fid, NULL, data+total, origin+total, count);
dfb0ec2e EVH	454	if (n <= 0)
	455	break;
	456	count -= n;
	457	total += n;
	458	} while (count > 0);
	459
	460	if (total > 0) {
637d020a AK	461	pg_start = origin >> PAGE_CACHE_SHIFT;
637d020a AK	462	pg_end = (origin + total - 1) >> PAGE_CACHE_SHIFT;
60e78d2c AK	463	if (inode->i_mapping && inode->i_mapping->nrpages)
	464	invalidate_inode_pages2_range(inode->i_mapping,
	465	pg_start, pg_end);
dfb0ec2e	466	*offset += total;
637d020a	467	i_size_write(inode, i_size_read(inode) + total);
7549ae3e	468	inode->i_blocks = (i_size_read(inode) + 512 - 1) >> 9;
9523a841 EVH	469	}
9523a841 EVH	470
dfb0ec2e	471	if (n < 0)
3834b12a HPB	472	retval = n;
	473	else
	474	retval = total;
	475	out:
	476	return retval;
e69e7fe5 EVH	477	}
e69e7fe5 EVH	478
7ea80859	479	static int v9fs_file_fsync(struct file *filp, int datasync)
7a4439c4 MK	480	{
	481	struct p9_fid *fid;
	482	struct p9_wstat wstat;
	483	int retval;
	484
7ea80859	485	P9_DPRINTK(P9_DEBUG_VFS, "filp %p datasync %x\n", filp, datasync);
7a4439c4 MK	486
	487	fid = filp->private_data;
	488	v9fs_blank_wstat(&wstat);
	489
	490	retval = p9_client_wstat(fid, &wstat);
	491	return retval;
	492	}
	493
b165d601	494	int v9fs_file_fsync_dotl(struct file *filp, int datasync)
920e65dc VJJ	495	{
	496	struct p9_fid *fid;
	497	int retval;
	498
	499	P9_DPRINTK(P9_DEBUG_VFS, "v9fs_file_fsync_dotl: filp %p datasync %x\n",
	500	filp, datasync);
	501
	502	fid = filp->private_data;
	503
b165d601	504	retval = p9_client_fsync(fid, datasync);
920e65dc VJJ	505	return retval;
	506	}
	507
d32b687e	508	static const struct file_operations v9fs_cached_file_operations = {
e03abc0c EVH	509	.llseek = generic_file_llseek,
	510	.read = do_sync_read,
	511	.aio_read = generic_file_aio_read,
	512	.write = v9fs_file_write,
	513	.open = v9fs_file_open,
	514	.release = v9fs_dir_release,
	515	.lock = v9fs_file_lock,
14b8869f	516	.mmap = generic_file_readonly_mmap,
7a4439c4	517	.fsync = v9fs_file_fsync,
e03abc0c EVH	518	};
e03abc0c EVH	519
b04faaf3 VJJ	520	static const struct file_operations v9fs_cached_file_operations_dotl = {
	521	.llseek = generic_file_llseek,
	522	.read = do_sync_read,
	523	.aio_read = generic_file_aio_read,
	524	.write = v9fs_file_write,
	525	.open = v9fs_file_open,
	526	.release = v9fs_dir_release,
a099027c MK	527	.lock = v9fs_file_lock_dotl,
a099027c MK	528	.flock = v9fs_file_flock_dotl,
b04faaf3	529	.mmap = generic_file_readonly_mmap,
920e65dc	530	.fsync = v9fs_file_fsync_dotl,
b04faaf3 VJJ	531	};
b04faaf3 VJJ	532
4b6f5d20	533	const struct file_operations v9fs_file_operations = {
e69e7fe5 EVH	534	.llseek = generic_file_llseek,
	535	.read = v9fs_file_read,
	536	.write = v9fs_file_write,
	537	.open = v9fs_file_open,
	538	.release = v9fs_dir_release,
	539	.lock = v9fs_file_lock,
14b8869f	540	.mmap = generic_file_readonly_mmap,
7a4439c4	541	.fsync = v9fs_file_fsync,
e69e7fe5	542	};
9b6533c9 SK	543
	544	const struct file_operations v9fs_file_operations_dotl = {
	545	.llseek = generic_file_llseek,
	546	.read = v9fs_file_read,
	547	.write = v9fs_file_write,
	548	.open = v9fs_file_open,
	549	.release = v9fs_dir_release,
a099027c MK	550	.lock = v9fs_file_lock_dotl,
a099027c MK	551	.flock = v9fs_file_flock_dotl,
9b6533c9	552	.mmap = generic_file_readonly_mmap,
920e65dc	553	.fsync = v9fs_file_fsync_dotl,
9b6533c9	554	};