[mirror_ubuntu-bionic-kernel.git] / fs / nfs / nfs42proc.c

/*
 * Copyright (c) 2014 Anna Schumaker <Anna.Schumaker@Netapp.com>
 */
#include <linux/fs.h>
#include <linux/sunrpc/sched.h>
#include <linux/nfs.h>
#include <linux/nfs3.h>
#include <linux/nfs4.h>
#include <linux/nfs_xdr.h>
#include <linux/nfs_fs.h>
#include "nfs4_fs.h"
#include "nfs42.h"
#include "iostat.h"
#include "pnfs.h"
#include "internal.h"

#define NFSDBG_FACILITY NFSDBG_PROC

static int nfs42_set_rw_stateid(nfs4_stateid *dst, struct file *file,
				fmode_t fmode)
{
	struct nfs_open_context *open;
	struct nfs_lock_context *lock;
	int ret;

	open = get_nfs_open_context(nfs_file_open_context(file));
	lock = nfs_get_lock_context(open);
	if (IS_ERR(lock)) {
		put_nfs_open_context(open);
		return PTR_ERR(lock);
	}

	ret = nfs4_set_rw_stateid(dst, open, lock, fmode);

	nfs_put_lock_context(lock);
	put_nfs_open_context(open);
	return ret;
}

static int _nfs42_proc_fallocate(struct rpc_message *msg, struct file *filep,
				 loff_t offset, loff_t len)
{
	struct inode *inode = file_inode(filep);
	struct nfs_server *server = NFS_SERVER(inode);
	struct nfs42_falloc_args args = {
		.falloc_fh	= NFS_FH(inode),
		.falloc_offset	= offset,
		.falloc_length	= len,
		.falloc_bitmask	= server->cache_consistency_bitmask,
	};
	struct nfs42_falloc_res res = {
		.falloc_server	= server,
	};
	int status;

	msg->rpc_argp = &args;
	msg->rpc_resp = &res;

	status = nfs42_set_rw_stateid(&args.falloc_stateid, filep, FMODE_WRITE);
	if (status)
		return status;

	res.falloc_fattr = nfs_alloc_fattr();
	if (!res.falloc_fattr)
		return -ENOMEM;

	status = nfs4_call_sync(server->client, server, msg,
				&args.seq_args, &res.seq_res, 0);
	if (status == 0)
		status = nfs_post_op_update_inode(inode, res.falloc_fattr);

	kfree(res.falloc_fattr);
	return status;
}

static int nfs42_proc_fallocate(struct rpc_message *msg, struct file *filep,
				loff_t offset, loff_t len)
{
	struct nfs_server *server = NFS_SERVER(file_inode(filep));
	struct nfs4_exception exception = { };
	int err;

	do {
		err = _nfs42_proc_fallocate(msg, filep, offset, len);
		if (err == -ENOTSUPP)
			return -EOPNOTSUPP;
		err = nfs4_handle_exception(server, err, &exception);
	} while (exception.retry);

	return err;
}

int nfs42_proc_allocate(struct file *filep, loff_t offset, loff_t len)
{
	struct rpc_message msg = {
		.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_ALLOCATE],
	};
	struct inode *inode = file_inode(filep);
	int err;

	if (!nfs_server_capable(inode, NFS_CAP_ALLOCATE))
		return -EOPNOTSUPP;

	mutex_lock(&inode->i_mutex);

	err = nfs42_proc_fallocate(&msg, filep, offset, len);
	if (err == -EOPNOTSUPP)
		NFS_SERVER(inode)->caps &= ~NFS_CAP_ALLOCATE;

	mutex_unlock(&inode->i_mutex);
	return err;
}

int nfs42_proc_deallocate(struct file *filep, loff_t offset, loff_t len)
{
	struct rpc_message msg = {
		.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_DEALLOCATE],
	};
	struct inode *inode = file_inode(filep);
	int err;

	if (!nfs_server_capable(inode, NFS_CAP_DEALLOCATE))
		return -EOPNOTSUPP;

	nfs_wb_all(inode);
	mutex_lock(&inode->i_mutex);

	err = nfs42_proc_fallocate(&msg, filep, offset, len);
	if (err == 0)
		truncate_pagecache_range(inode, offset, (offset + len) -1);
	if (err == -EOPNOTSUPP)
		NFS_SERVER(inode)->caps &= ~NFS_CAP_DEALLOCATE;

	mutex_unlock(&inode->i_mutex);
	return err;
}

static loff_t _nfs42_proc_llseek(struct file *filep, loff_t offset, int whence)
{
	struct inode *inode = file_inode(filep);
	struct nfs42_seek_args args = {
		.sa_fh		= NFS_FH(inode),
		.sa_offset	= offset,
		.sa_what	= (whence == SEEK_HOLE) ?
					NFS4_CONTENT_HOLE : NFS4_CONTENT_DATA,
	};
	struct nfs42_seek_res res;
	struct rpc_message msg = {
		.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_SEEK],
		.rpc_argp = &args,
		.rpc_resp = &res,
	};
	struct nfs_server *server = NFS_SERVER(inode);
	int status;

	if (!nfs_server_capable(inode, NFS_CAP_SEEK))
		return -ENOTSUPP;

	status = nfs42_set_rw_stateid(&args.sa_stateid, filep, FMODE_READ);
	if (status)
		return status;

	nfs_wb_all(inode);
	status = nfs4_call_sync(server->client, server, &msg,
				&args.seq_args, &res.seq_res, 0);
	if (status == -ENOTSUPP)
		server->caps &= ~NFS_CAP_SEEK;
	if (status)
		return status;

	return vfs_setpos(filep, res.sr_offset, inode->i_sb->s_maxbytes);
}

loff_t nfs42_proc_llseek(struct file *filep, loff_t offset, int whence)
{
	struct nfs_server *server = NFS_SERVER(file_inode(filep));
	struct nfs4_exception exception = { };
	loff_t err;

	do {
		err = _nfs42_proc_llseek(filep, offset, whence);
		if (err >= 0)
			break;
		if (err == -ENOTSUPP)
			return -EOPNOTSUPP;
		err = nfs4_handle_exception(server, err, &exception);
	} while (exception.retry);

	return err;
}


static void
nfs42_layoutstat_prepare(struct rpc_task *task, void *calldata)
{
	struct nfs42_layoutstat_data *data = calldata;
	struct nfs_server *server = NFS_SERVER(data->args.inode);

	nfs41_setup_sequence(nfs4_get_session(server), &data->args.seq_args,
			     &data->res.seq_res, task);
}

static void
nfs42_layoutstat_done(struct rpc_task *task, void *calldata)
{
	struct nfs42_layoutstat_data *data = calldata;
	struct inode *inode = data->inode;
	struct pnfs_layout_hdr *lo;

	if (!nfs4_sequence_done(task, &data->res.seq_res))
		return;

	switch (task->tk_status) {
	case 0:
		break;
	case -NFS4ERR_EXPIRED:
	case -NFS4ERR_STALE_STATEID:
	case -NFS4ERR_OLD_STATEID:
	case -NFS4ERR_BAD_STATEID:
		spin_lock(&inode->i_lock);
		lo = NFS_I(inode)->layout;
		if (lo && nfs4_stateid_match(&data->args.stateid,
					     &lo->plh_stateid)) {
			LIST_HEAD(head);

			/*
			 * Mark the bad layout state as invalid, then retry
			 * with the current stateid.
			 */
			set_bit(NFS_LAYOUT_INVALID_STID, &lo->plh_flags);
			pnfs_mark_matching_lsegs_invalid(lo, &head, NULL);
			spin_unlock(&inode->i_lock);
			pnfs_free_lseg_list(&head);
		} else
			spin_unlock(&inode->i_lock);
		break;
	case -ENOTSUPP:
	case -EOPNOTSUPP:
		NFS_SERVER(inode)->caps &= ~NFS_CAP_LAYOUTSTATS;
	default:
		break;
	}

	dprintk("%s server returns %d\n", __func__, task->tk_status);
}

static void
nfs42_layoutstat_release(void *calldata)
{
	struct nfs42_layoutstat_data *data = calldata;
	struct nfs_server *nfss = NFS_SERVER(data->args.inode);

	if (nfss->pnfs_curr_ld->cleanup_layoutstats)
		nfss->pnfs_curr_ld->cleanup_layoutstats(data);

	pnfs_put_layout_hdr(NFS_I(data->args.inode)->layout);
	smp_mb__before_atomic();
	clear_bit(NFS_INO_LAYOUTSTATS, &NFS_I(data->args.inode)->flags);
	smp_mb__after_atomic();
	nfs_iput_and_deactive(data->inode);
	kfree(data->args.devinfo);
	kfree(data);
}

static const struct rpc_call_ops nfs42_layoutstat_ops = {
	.rpc_call_prepare = nfs42_layoutstat_prepare,
	.rpc_call_done = nfs42_layoutstat_done,
	.rpc_release = nfs42_layoutstat_release,
};

int nfs42_proc_layoutstats_generic(struct nfs_server *server,
				   struct nfs42_layoutstat_data *data)
{
	struct rpc_message msg = {
		.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_LAYOUTSTATS],
		.rpc_argp = &data->args,
		.rpc_resp = &data->res,
	};
	struct rpc_task_setup task_setup = {
		.rpc_client = server->client,
		.rpc_message = &msg,
		.callback_ops = &nfs42_layoutstat_ops,
		.callback_data = data,
		.flags = RPC_TASK_ASYNC,
	};
	struct rpc_task *task;

	data->inode = nfs_igrab_and_active(data->args.inode);
	if (!data->inode) {
		nfs42_layoutstat_release(data);
		return -EAGAIN;
	}
	nfs4_init_sequence(&data->args.seq_args, &data->res.seq_res, 0);
	task = rpc_run_task(&task_setup);
	if (IS_ERR(task))
		return PTR_ERR(task);
	return 0;
}

static int _nfs42_proc_clone(struct rpc_message *msg, struct file *src_f,
			     struct file *dst_f, loff_t src_offset,
			     loff_t dst_offset, loff_t count)
{
	struct inode *src_inode = file_inode(src_f);
	struct inode *dst_inode = file_inode(dst_f);
	struct nfs_server *server = NFS_SERVER(dst_inode);
	struct nfs42_clone_args args = {
		.src_fh = NFS_FH(src_inode),
		.dst_fh = NFS_FH(dst_inode),
		.src_offset = src_offset,
		.dst_offset = dst_offset,
		.count = count,
		.dst_bitmask = server->cache_consistency_bitmask,
	};
	struct nfs42_clone_res res = {
		.server	= server,
	};
	int status;

	msg->rpc_argp = &args;
	msg->rpc_resp = &res;

	status = nfs42_set_rw_stateid(&args.src_stateid, src_f, FMODE_READ);
	if (status)
		return status;

	status = nfs42_set_rw_stateid(&args.dst_stateid, dst_f, FMODE_WRITE);
	if (status)
		return status;

	res.dst_fattr = nfs_alloc_fattr();
	if (!res.dst_fattr)
		return -ENOMEM;

	status = nfs4_call_sync(server->client, server, msg,
				&args.seq_args, &res.seq_res, 0);
	if (status == 0)
		status = nfs_post_op_update_inode(dst_inode, res.dst_fattr);

	kfree(res.dst_fattr);
	return status;
}

int nfs42_proc_clone(struct file *src_f, struct file *dst_f,
		     loff_t src_offset, loff_t dst_offset, loff_t count)
{
	struct rpc_message msg = {
		.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_CLONE],
	};
	struct inode *inode = file_inode(src_f);
	struct nfs_server *server = NFS_SERVER(file_inode(src_f));
	struct nfs4_exception exception = { };
	int err;

	if (!nfs_server_capable(inode, NFS_CAP_CLONE))
		return -EOPNOTSUPP;

	do {
		err = _nfs42_proc_clone(&msg, src_f, dst_f, src_offset,
					dst_offset, count);
		if (err == -ENOTSUPP || err == -EOPNOTSUPP) {
			NFS_SERVER(inode)->caps &= ~NFS_CAP_CLONE;
			return -EOPNOTSUPP;
		}
		err = nfs4_handle_exception(server, err, &exception);
	} while (exception.retry);

	return err;

}
Commit	Line	Data
1c6dcbe5 AS	1	/*
	2	* Copyright (c) 2014 Anna Schumaker <Anna.Schumaker@Netapp.com>
	3	*/
	4	#include <linux/fs.h>
	5	#include <linux/sunrpc/sched.h>
	6	#include <linux/nfs.h>
	7	#include <linux/nfs3.h>
	8	#include <linux/nfs4.h>
	9	#include <linux/nfs_xdr.h>
	10	#include <linux/nfs_fs.h>
	11	#include "nfs4_fs.h"
	12	#include "nfs42.h"
1b4a4bd8 PT	13	#include "iostat.h"
	14	#include "pnfs.h"
	15	#include "internal.h"
	16
291e1b94	17	#define NFSDBG_FACILITY NFSDBG_PROC
1c6dcbe5 AS	18
	19	static int nfs42_set_rw_stateid(nfs4_stateid dst, struct file file,
	20	fmode_t fmode)
	21	{
	22	struct nfs_open_context *open;
	23	struct nfs_lock_context *lock;
	24	int ret;
	25
	26	open = get_nfs_open_context(nfs_file_open_context(file));
	27	lock = nfs_get_lock_context(open);
	28	if (IS_ERR(lock)) {
	29	put_nfs_open_context(open);
	30	return PTR_ERR(lock);
	31	}
	32
	33	ret = nfs4_set_rw_stateid(dst, open, lock, fmode);
	34
	35	nfs_put_lock_context(lock);
	36	put_nfs_open_context(open);
	37	return ret;
	38	}
	39
f4ac1674 AS	40	static int _nfs42_proc_fallocate(struct rpc_message msg, struct file filep,
	41	loff_t offset, loff_t len)
	42	{
	43	struct inode *inode = file_inode(filep);
9a51940b	44	struct nfs_server *server = NFS_SERVER(inode);
f4ac1674 AS	45	struct nfs42_falloc_args args = {
	46	.falloc_fh = NFS_FH(inode),
	47	.falloc_offset = offset,
	48	.falloc_length = len,
9a51940b AS	49	.falloc_bitmask = server->cache_consistency_bitmask,
	50	};
	51	struct nfs42_falloc_res res = {
	52	.falloc_server = server,
f4ac1674	53	};
f4ac1674 AS	54	int status;
	55
	56	msg->rpc_argp = &args;
	57	msg->rpc_resp = &res;
	58
	59	status = nfs42_set_rw_stateid(&args.falloc_stateid, filep, FMODE_WRITE);
	60	if (status)
	61	return status;
	62
9a51940b AS	63	res.falloc_fattr = nfs_alloc_fattr();
	64	if (!res.falloc_fattr)
	65	return -ENOMEM;
	66
	67	status = nfs4_call_sync(server->client, server, msg,
	68	&args.seq_args, &res.seq_res, 0);
	69	if (status == 0)
	70	status = nfs_post_op_update_inode(inode, res.falloc_fattr);
	71
	72	kfree(res.falloc_fattr);
	73	return status;
f4ac1674 AS	74	}
	75
	76	static int nfs42_proc_fallocate(struct rpc_message msg, struct file filep,
	77	loff_t offset, loff_t len)
	78	{
	79	struct nfs_server *server = NFS_SERVER(file_inode(filep));
	80	struct nfs4_exception exception = { };
	81	int err;
	82
	83	do {
	84	err = _nfs42_proc_fallocate(msg, filep, offset, len);
	85	if (err == -ENOTSUPP)
	86	return -EOPNOTSUPP;
	87	err = nfs4_handle_exception(server, err, &exception);
	88	} while (exception.retry);
	89
	90	return err;
	91	}
	92
	93	int nfs42_proc_allocate(struct file *filep, loff_t offset, loff_t len)
	94	{
	95	struct rpc_message msg = {
	96	.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_ALLOCATE],
	97	};
	98	struct inode *inode = file_inode(filep);
	99	int err;
	100
	101	if (!nfs_server_capable(inode, NFS_CAP_ALLOCATE))
	102	return -EOPNOTSUPP;
	103
f830f7dd AS	104	mutex_lock(&inode->i_mutex);
f830f7dd AS	105
f4ac1674 AS	106	err = nfs42_proc_fallocate(&msg, filep, offset, len);
	107	if (err == -EOPNOTSUPP)
	108	NFS_SERVER(inode)->caps &= ~NFS_CAP_ALLOCATE;
f830f7dd AS	109
f830f7dd AS	110	mutex_unlock(&inode->i_mutex);
f4ac1674 AS	111	return err;
	112	}
	113
624bd5b7 AS	114	int nfs42_proc_deallocate(struct file *filep, loff_t offset, loff_t len)
	115	{
	116	struct rpc_message msg = {
	117	.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_DEALLOCATE],
	118	};
	119	struct inode *inode = file_inode(filep);
	120	int err;
	121
	122	if (!nfs_server_capable(inode, NFS_CAP_DEALLOCATE))
	123	return -EOPNOTSUPP;
	124
9a51940b	125	nfs_wb_all(inode);
f830f7dd AS	126	mutex_lock(&inode->i_mutex);
f830f7dd AS	127
624bd5b7	128	err = nfs42_proc_fallocate(&msg, filep, offset, len);
9a51940b AS	129	if (err == 0)
9a51940b AS	130	truncate_pagecache_range(inode, offset, (offset + len) -1);
624bd5b7 AS	131	if (err == -EOPNOTSUPP)
624bd5b7 AS	132	NFS_SERVER(inode)->caps &= ~NFS_CAP_DEALLOCATE;
f830f7dd AS	133
f830f7dd AS	134	mutex_unlock(&inode->i_mutex);
624bd5b7 AS	135	return err;
	136	}
	137
bdcc2cd1	138	static loff_t _nfs42_proc_llseek(struct file *filep, loff_t offset, int whence)
1c6dcbe5 AS	139	{
	140	struct inode *inode = file_inode(filep);
	141	struct nfs42_seek_args args = {
	142	.sa_fh = NFS_FH(inode),
	143	.sa_offset = offset,
	144	.sa_what = (whence == SEEK_HOLE) ?
	145	NFS4_CONTENT_HOLE : NFS4_CONTENT_DATA,
	146	};
	147	struct nfs42_seek_res res;
	148	struct rpc_message msg = {
	149	.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_SEEK],
	150	.rpc_argp = &args,
	151	.rpc_resp = &res,
	152	};
	153	struct nfs_server *server = NFS_SERVER(inode);
	154	int status;
	155
878ffa9f	156	if (!nfs_server_capable(inode, NFS_CAP_SEEK))
1c6dcbe5 AS	157	return -ENOTSUPP;
	158
	159	status = nfs42_set_rw_stateid(&args.sa_stateid, filep, FMODE_READ);
	160	if (status)
	161	return status;
	162
	163	nfs_wb_all(inode);
	164	status = nfs4_call_sync(server->client, server, &msg,
	165	&args.seq_args, &res.seq_res, 0);
	166	if (status == -ENOTSUPP)
	167	server->caps &= ~NFS_CAP_SEEK;
	168	if (status)
	169	return status;
	170
	171	return vfs_setpos(filep, res.sr_offset, inode->i_sb->s_maxbytes);
	172	}
be3a5d23	173
bdcc2cd1 BF	174	loff_t nfs42_proc_llseek(struct file *filep, loff_t offset, int whence)
	175	{
	176	struct nfs_server *server = NFS_SERVER(file_inode(filep));
	177	struct nfs4_exception exception = { };
306a5549	178	loff_t err;
bdcc2cd1 BF	179
	180	do {
	181	err = _nfs42_proc_llseek(filep, offset, whence);
306a5549 BF	182	if (err >= 0)
306a5549 BF	183	break;
bdcc2cd1 BF	184	if (err == -ENOTSUPP)
	185	return -EOPNOTSUPP;
	186	err = nfs4_handle_exception(server, err, &exception);
	187	} while (exception.retry);
	188
	189	return err;
	190	}
	191
	192
1b4a4bd8 PT	193	static void
	194	nfs42_layoutstat_prepare(struct rpc_task task, void calldata)
	195	{
	196	struct nfs42_layoutstat_data *data = calldata;
	197	struct nfs_server *server = NFS_SERVER(data->args.inode);
	198
	199	nfs41_setup_sequence(nfs4_get_session(server), &data->args.seq_args,
	200	&data->res.seq_res, task);
	201	}
	202
	203	static void
	204	nfs42_layoutstat_done(struct rpc_task task, void calldata)
	205	{
	206	struct nfs42_layoutstat_data *data = calldata;
68d264cf PT	207	struct inode *inode = data->inode;
68d264cf PT	208	struct pnfs_layout_hdr *lo;
1b4a4bd8 PT	209
	210	if (!nfs4_sequence_done(task, &data->res.seq_res))
	211	return;
	212
6c5a0d89 TM	213	switch (task->tk_status) {
	214	case 0:
	215	break;
68d264cf PT	216	case -NFS4ERR_EXPIRED:
	217	case -NFS4ERR_STALE_STATEID:
	218	case -NFS4ERR_OLD_STATEID:
	219	case -NFS4ERR_BAD_STATEID:
	220	spin_lock(&inode->i_lock);
	221	lo = NFS_I(inode)->layout;
	222	if (lo && nfs4_stateid_match(&data->args.stateid,
	223	&lo->plh_stateid)) {
	224	LIST_HEAD(head);
	225
	226	/*
	227	* Mark the bad layout state as invalid, then retry
	228	* with the current stateid.
	229	*/
	230	set_bit(NFS_LAYOUT_INVALID_STID, &lo->plh_flags);
	231	pnfs_mark_matching_lsegs_invalid(lo, &head, NULL);
	232	spin_unlock(&inode->i_lock);
	233	pnfs_free_lseg_list(&head);
	234	} else
	235	spin_unlock(&inode->i_lock);
	236	break;
6c5a0d89 TM	237	case -ENOTSUPP:
6c5a0d89 TM	238	case -EOPNOTSUPP:
68d264cf	239	NFS_SERVER(inode)->caps &= ~NFS_CAP_LAYOUTSTATS;
6c5a0d89	240	default:
68d264cf	241	break;
6c5a0d89	242	}
68d264cf PT	243
68d264cf PT	244	dprintk("%s server returns %d\n", __func__, task->tk_status);
1b4a4bd8 PT	245	}
	246
	247	static void
	248	nfs42_layoutstat_release(void *calldata)
	249	{
	250	struct nfs42_layoutstat_data *data = calldata;
8733408d PT	251	struct nfs_server *nfss = NFS_SERVER(data->args.inode);
	252
	253	if (nfss->pnfs_curr_ld->cleanup_layoutstats)
	254	nfss->pnfs_curr_ld->cleanup_layoutstats(data);
1b4a4bd8 PT	255
1b4a4bd8 PT	256	pnfs_put_layout_hdr(NFS_I(data->args.inode)->layout);
1bfe3b25 PT	257	smp_mb__before_atomic();
	258	clear_bit(NFS_INO_LAYOUTSTATS, &NFS_I(data->args.inode)->flags);
	259	smp_mb__after_atomic();
1b4a4bd8 PT	260	nfs_iput_and_deactive(data->inode);
	261	kfree(data->args.devinfo);
	262	kfree(data);
	263	}
	264
be3a5d23	265	static const struct rpc_call_ops nfs42_layoutstat_ops = {
1b4a4bd8 PT	266	.rpc_call_prepare = nfs42_layoutstat_prepare,
	267	.rpc_call_done = nfs42_layoutstat_done,
	268	.rpc_release = nfs42_layoutstat_release,
be3a5d23 TM	269	};
	270
	271	int nfs42_proc_layoutstats_generic(struct nfs_server *server,
	272	struct nfs42_layoutstat_data *data)
	273	{
	274	struct rpc_message msg = {
	275	.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_LAYOUTSTATS],
	276	.rpc_argp = &data->args,
	277	.rpc_resp = &data->res,
	278	};
	279	struct rpc_task_setup task_setup = {
	280	.rpc_client = server->client,
	281	.rpc_message = &msg,
	282	.callback_ops = &nfs42_layoutstat_ops,
	283	.callback_data = data,
	284	.flags = RPC_TASK_ASYNC,
	285	};
	286	struct rpc_task *task;
	287
1b4a4bd8 PT	288	data->inode = nfs_igrab_and_active(data->args.inode);
	289	if (!data->inode) {
	290	nfs42_layoutstat_release(data);
	291	return -EAGAIN;
	292	}
be3a5d23 TM	293	nfs4_init_sequence(&data->args.seq_args, &data->res.seq_res, 0);
	294	task = rpc_run_task(&task_setup);
	295	if (IS_ERR(task))
	296	return PTR_ERR(task);
	297	return 0;
	298	}
e5341f3a PT	299
	300	static int _nfs42_proc_clone(struct rpc_message msg, struct file src_f,
	301	struct file *dst_f, loff_t src_offset,
	302	loff_t dst_offset, loff_t count)
	303	{
	304	struct inode *src_inode = file_inode(src_f);
	305	struct inode *dst_inode = file_inode(dst_f);
	306	struct nfs_server *server = NFS_SERVER(dst_inode);
	307	struct nfs42_clone_args args = {
	308	.src_fh = NFS_FH(src_inode),
	309	.dst_fh = NFS_FH(dst_inode),
	310	.src_offset = src_offset,
	311	.dst_offset = dst_offset,
9494b2ce	312	.count = count,
e5341f3a PT	313	.dst_bitmask = server->cache_consistency_bitmask,
	314	};
	315	struct nfs42_clone_res res = {
	316	.server = server,
	317	};
	318	int status;
	319
	320	msg->rpc_argp = &args;
	321	msg->rpc_resp = &res;
	322
	323	status = nfs42_set_rw_stateid(&args.src_stateid, src_f, FMODE_READ);
	324	if (status)
	325	return status;
	326
	327	status = nfs42_set_rw_stateid(&args.dst_stateid, dst_f, FMODE_WRITE);
	328	if (status)
	329	return status;
	330
	331	res.dst_fattr = nfs_alloc_fattr();
	332	if (!res.dst_fattr)
	333	return -ENOMEM;
	334
	335	status = nfs4_call_sync(server->client, server, msg,
	336	&args.seq_args, &res.seq_res, 0);
	337	if (status == 0)
	338	status = nfs_post_op_update_inode(dst_inode, res.dst_fattr);
	339
	340	kfree(res.dst_fattr);
	341	return status;
	342	}
	343
	344	int nfs42_proc_clone(struct file src_f, struct file dst_f,
	345	loff_t src_offset, loff_t dst_offset, loff_t count)
	346	{
	347	struct rpc_message msg = {
	348	.rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_CLONE],
	349	};
	350	struct inode *inode = file_inode(src_f);
	351	struct nfs_server *server = NFS_SERVER(file_inode(src_f));
	352	struct nfs4_exception exception = { };
	353	int err;
	354
	355	if (!nfs_server_capable(inode, NFS_CAP_CLONE))
	356	return -EOPNOTSUPP;
	357
	358	do {
	359	err = _nfs42_proc_clone(&msg, src_f, dst_f, src_offset,
	360	dst_offset, count);
	361	if (err == -ENOTSUPP \|\| err == -EOPNOTSUPP) {
	362	NFS_SERVER(inode)->caps &= ~NFS_CAP_CLONE;
	363	return -EOPNOTSUPP;
	364	}
	365	err = nfs4_handle_exception(server, err, &exception);
	366	} while (exception.retry);
	367
	368	return err;
	369
	370	}