[linux.git] / fs / nfs / nfs4file.c

/*
 *  linux/fs/nfs/file.c
 *
 *  Copyright (C) 1992  Rick Sladkey
 */
#include <linux/fs.h>
#include <linux/falloc.h>
#include <linux/nfs_fs.h>
#include "internal.h"
#include "fscache.h"
#include "pnfs.h"

#include "nfstrace.h"

#ifdef CONFIG_NFS_V4_2
#include "nfs42.h"
#endif

#define NFSDBG_FACILITY		NFSDBG_FILE

static int
nfs4_file_open(struct inode *inode, struct file *filp)
{
	struct nfs_open_context *ctx;
	struct dentry *dentry = filp->f_path.dentry;
	struct dentry *parent = NULL;
	struct inode *dir;
	unsigned openflags = filp->f_flags;
	struct iattr attr;
	int opened = 0;
	int err;

	/*
	 * If no cached dentry exists or if it's negative, NFSv4 handled the
	 * opens in ->lookup() or ->create().
	 *
	 * We only get this far for a cached positive dentry.  We skipped
	 * revalidation, so handle it here by dropping the dentry and returning
	 * -EOPENSTALE.  The VFS will retry the lookup/create/open.
	 */

	dprintk("NFS: open file(%pd2)\n", dentry);

	if ((openflags & O_ACCMODE) == 3)
		openflags--;

	/* We can't create new files here */
	openflags &= ~(O_CREAT|O_EXCL);

	parent = dget_parent(dentry);
	dir = parent->d_inode;

	ctx = alloc_nfs_open_context(filp->f_path.dentry, filp->f_mode);
	err = PTR_ERR(ctx);
	if (IS_ERR(ctx))
		goto out;

	attr.ia_valid = ATTR_OPEN;
	if (openflags & O_TRUNC) {
		attr.ia_valid |= ATTR_SIZE;
		attr.ia_size = 0;
		nfs_sync_inode(inode);
	}

	inode = NFS_PROTO(dir)->open_context(dir, ctx, openflags, &attr, &opened);
	if (IS_ERR(inode)) {
		err = PTR_ERR(inode);
		switch (err) {
		case -EPERM:
		case -EACCES:
		case -EDQUOT:
		case -ENOSPC:
		case -EROFS:
			goto out_put_ctx;
		default:
			goto out_drop;
		}
	}
	if (inode != dentry->d_inode)
		goto out_drop;

	nfs_set_verifier(dentry, nfs_save_change_attribute(dir));
	nfs_file_set_open_context(filp, ctx);
	nfs_fscache_open_file(inode, filp);
	err = 0;

out_put_ctx:
	put_nfs_open_context(ctx);
out:
	dput(parent);
	return err;

out_drop:
	d_drop(dentry);
	err = -EOPENSTALE;
	goto out_put_ctx;
}

static int
nfs4_file_fsync(struct file *file, loff_t start, loff_t end, int datasync)
{
	int ret;
	struct inode *inode = file_inode(file);

	trace_nfs_fsync_enter(inode);

	nfs_inode_dio_wait(inode);
	do {
		ret = filemap_write_and_wait_range(inode->i_mapping, start, end);
		if (ret != 0)
			break;
		mutex_lock(&inode->i_mutex);
		ret = nfs_file_fsync_commit(file, start, end, datasync);
		if (!ret)
			ret = pnfs_sync_inode(inode, !!datasync);
		mutex_unlock(&inode->i_mutex);
		/*
		 * If nfs_file_fsync_commit detected a server reboot, then
		 * resend all dirty pages that might have been covered by
		 * the NFS_CONTEXT_RESEND_WRITES flag
		 */
		start = 0;
		end = LLONG_MAX;
	} while (ret == -EAGAIN);

	trace_nfs_fsync_exit(inode, ret);
	return ret;
}

#ifdef CONFIG_NFS_V4_2
static loff_t nfs4_file_llseek(struct file *filep, loff_t offset, int whence)
{
	loff_t ret;

	switch (whence) {
	case SEEK_HOLE:
	case SEEK_DATA:
		ret = nfs42_proc_llseek(filep, offset, whence);
		if (ret != -ENOTSUPP)
			return ret;
	default:
		return nfs_file_llseek(filep, offset, whence);
	}
}

static long nfs42_fallocate(struct file *filep, int mode, loff_t offset, loff_t len)
{
	struct inode *inode = file_inode(filep);
	long ret;

	if (!S_ISREG(inode->i_mode))
		return -EOPNOTSUPP;

	if ((mode != 0) && (mode != (FALLOC_FL_PUNCH_HOLE | FALLOC_FL_KEEP_SIZE)))
		return -EOPNOTSUPP;

	ret = inode_newsize_ok(inode, offset + len);
	if (ret < 0)
		return ret;

	mutex_lock(&inode->i_mutex);
	if (mode & FALLOC_FL_PUNCH_HOLE)
		ret = nfs42_proc_deallocate(filep, offset, len);
	else
		ret = nfs42_proc_allocate(filep, offset, len);
	mutex_unlock(&inode->i_mutex);

	return ret;
}
#endif /* CONFIG_NFS_V4_2 */

const struct file_operations nfs4_file_operations = {
#ifdef CONFIG_NFS_V4_2
	.llseek		= nfs4_file_llseek,
#else
	.llseek		= nfs_file_llseek,
#endif
	.read		= new_sync_read,
	.write		= new_sync_write,
	.read_iter	= nfs_file_read,
	.write_iter	= nfs_file_write,
	.mmap		= nfs_file_mmap,
	.open		= nfs4_file_open,
	.flush		= nfs_file_flush,
	.release	= nfs_file_release,
	.fsync		= nfs4_file_fsync,
	.lock		= nfs_lock,
	.flock		= nfs_flock,
	.splice_read	= nfs_file_splice_read,
	.splice_write	= iter_file_splice_write,
#ifdef CONFIG_NFS_V4_2
	.fallocate	= nfs42_fallocate,
#endif /* CONFIG_NFS_V4_2 */
	.check_flags	= nfs_check_flags,
	.setlease	= simple_nosetlease,
};
Commit	Line	Data
ce4ef7c0 BS	1	/*
	2	* linux/fs/nfs/file.c
	3	*
	4	* Copyright (C) 1992 Rick Sladkey
	5	*/
f4ac1674 AS	6	#include <linux/fs.h>
f4ac1674 AS	7	#include <linux/falloc.h>
ce4ef7c0 BS	8	#include <linux/nfs_fs.h>
ce4ef7c0 BS	9	#include "internal.h"
a4ff1468	10	#include "fscache.h"
ce4ef7c0 BS	11	#include "pnfs.h"
ce4ef7c0 BS	12
81b79afb TM	13	#include "nfstrace.h"
81b79afb TM	14
1c6dcbe5 AS	15	#ifdef CONFIG_NFS_V4_2
	16	#include "nfs42.h"
	17	#endif
	18
ce4ef7c0 BS	19	#define NFSDBG_FACILITY NFSDBG_FILE
	20
	21	static int
	22	nfs4_file_open(struct inode inode, struct file filp)
	23	{
	24	struct nfs_open_context *ctx;
	25	struct dentry *dentry = filp->f_path.dentry;
	26	struct dentry *parent = NULL;
	27	struct inode *dir;
	28	unsigned openflags = filp->f_flags;
	29	struct iattr attr;
5bc2afc2	30	int opened = 0;
ce4ef7c0 BS	31	int err;
ce4ef7c0 BS	32
ce4ef7c0 BS	33	/*
	34	* If no cached dentry exists or if it's negative, NFSv4 handled the
	35	* opens in ->lookup() or ->create().
	36	*
	37	* We only get this far for a cached positive dentry. We skipped
	38	* revalidation, so handle it here by dropping the dentry and returning
	39	* -EOPENSTALE. The VFS will retry the lookup/create/open.
	40	*/
	41
6de1472f	42	dprintk("NFS: open file(%pd2)\n", dentry);
ce4ef7c0 BS	43
	44	if ((openflags & O_ACCMODE) == 3)
	45	openflags--;
	46
	47	/* We can't create new files here */
	48	openflags &= ~(O_CREAT\|O_EXCL);
	49
	50	parent = dget_parent(dentry);
	51	dir = parent->d_inode;
	52
	53	ctx = alloc_nfs_open_context(filp->f_path.dentry, filp->f_mode);
	54	err = PTR_ERR(ctx);
	55	if (IS_ERR(ctx))
	56	goto out;
	57
	58	attr.ia_valid = ATTR_OPEN;
	59	if (openflags & O_TRUNC) {
	60	attr.ia_valid \|= ATTR_SIZE;
	61	attr.ia_size = 0;
9e1681c2	62	nfs_sync_inode(inode);
ce4ef7c0 BS	63	}
ce4ef7c0 BS	64
5bc2afc2	65	inode = NFS_PROTO(dir)->open_context(dir, ctx, openflags, &attr, &opened);
ce4ef7c0 BS	66	if (IS_ERR(inode)) {
	67	err = PTR_ERR(inode);
	68	switch (err) {
	69	case -EPERM:
	70	case -EACCES:
	71	case -EDQUOT:
	72	case -ENOSPC:
	73	case -EROFS:
	74	goto out_put_ctx;
	75	default:
	76	goto out_drop;
	77	}
	78	}
ce4ef7c0 BS	79	if (inode != dentry->d_inode)
	80	goto out_drop;
	81
	82	nfs_set_verifier(dentry, nfs_save_change_attribute(dir));
	83	nfs_file_set_open_context(filp, ctx);
f1fe29b4	84	nfs_fscache_open_file(inode, filp);
ce4ef7c0 BS	85	err = 0;
	86
	87	out_put_ctx:
	88	put_nfs_open_context(ctx);
	89	out:
	90	dput(parent);
	91	return err;
	92
	93	out_drop:
	94	d_drop(dentry);
	95	err = -EOPENSTALE;
	96	goto out_put_ctx;
	97	}
	98
	99	static int
	100	nfs4_file_fsync(struct file *file, loff_t start, loff_t end, int datasync)
	101	{
	102	int ret;
496ad9aa	103	struct inode *inode = file_inode(file);
ce4ef7c0	104
81b79afb TM	105	trace_nfs_fsync_enter(inode);
81b79afb TM	106
a0815d55	107	nfs_inode_dio_wait(inode);
05990d1b TM	108	do {
	109	ret = filemap_write_and_wait_range(inode->i_mapping, start, end);
	110	if (ret != 0)
	111	break;
	112	mutex_lock(&inode->i_mutex);
	113	ret = nfs_file_fsync_commit(file, start, end, datasync);
1b33809e	114	if (!ret)
5bb89b47	115	ret = pnfs_sync_inode(inode, !!datasync);
05990d1b	116	mutex_unlock(&inode->i_mutex);
dcfc4f25 TM	117	/*
	118	* If nfs_file_fsync_commit detected a server reboot, then
	119	* resend all dirty pages that might have been covered by
	120	* the NFS_CONTEXT_RESEND_WRITES flag
	121	*/
	122	start = 0;
	123	end = LLONG_MAX;
05990d1b TM	124	} while (ret == -EAGAIN);
05990d1b TM	125
81b79afb	126	trace_nfs_fsync_exit(inode, ret);
ce4ef7c0 BS	127	return ret;
	128	}
	129
1c6dcbe5 AS	130	#ifdef CONFIG_NFS_V4_2
	131	static loff_t nfs4_file_llseek(struct file *filep, loff_t offset, int whence)
	132	{
	133	loff_t ret;
	134
	135	switch (whence) {
	136	case SEEK_HOLE:
	137	case SEEK_DATA:
	138	ret = nfs42_proc_llseek(filep, offset, whence);
	139	if (ret != -ENOTSUPP)
	140	return ret;
	141	default:
	142	return nfs_file_llseek(filep, offset, whence);
	143	}
	144	}
f4ac1674 AS	145
	146	static long nfs42_fallocate(struct file *filep, int mode, loff_t offset, loff_t len)
	147	{
	148	struct inode *inode = file_inode(filep);
	149	long ret;
	150
	151	if (!S_ISREG(inode->i_mode))
	152	return -EOPNOTSUPP;
	153
624bd5b7	154	if ((mode != 0) && (mode != (FALLOC_FL_PUNCH_HOLE \| FALLOC_FL_KEEP_SIZE)))
f4ac1674 AS	155	return -EOPNOTSUPP;
	156
	157	ret = inode_newsize_ok(inode, offset + len);
	158	if (ret < 0)
	159	return ret;
	160
	161	mutex_lock(&inode->i_mutex);
624bd5b7 AS	162	if (mode & FALLOC_FL_PUNCH_HOLE)
	163	ret = nfs42_proc_deallocate(filep, offset, len);
	164	else
	165	ret = nfs42_proc_allocate(filep, offset, len);
f4ac1674 AS	166	mutex_unlock(&inode->i_mutex);
f4ac1674 AS	167
f4ac1674 AS	168	return ret;
f4ac1674 AS	169	}
1c6dcbe5 AS	170	#endif /* CONFIG_NFS_V4_2 */
1c6dcbe5 AS	171
ce4ef7c0	172	const struct file_operations nfs4_file_operations = {
1c6dcbe5 AS	173	#ifdef CONFIG_NFS_V4_2
	174	.llseek = nfs4_file_llseek,
	175	#else
ce4ef7c0	176	.llseek = nfs_file_llseek,
1c6dcbe5	177	#endif
3aa2d199	178	.read = new_sync_read,
edaf4369	179	.write = new_sync_write,
3aa2d199	180	.read_iter = nfs_file_read,
edaf4369	181	.write_iter = nfs_file_write,
ce4ef7c0 BS	182	.mmap = nfs_file_mmap,
	183	.open = nfs4_file_open,
	184	.flush = nfs_file_flush,
	185	.release = nfs_file_release,
	186	.fsync = nfs4_file_fsync,
	187	.lock = nfs_lock,
	188	.flock = nfs_flock,
	189	.splice_read = nfs_file_splice_read,
4da54c21	190	.splice_write = iter_file_splice_write,
f4ac1674 AS	191	#ifdef CONFIG_NFS_V4_2
	192	.fallocate = nfs42_fallocate,
	193	#endif /* CONFIG_NFS_V4_2 */
ce4ef7c0	194	.check_flags = nfs_check_flags,
1c994a09	195	.setlease = simple_nosetlease,
ce4ef7c0	196	};