[GitHub/mt8127/android_kernel_alcatel_ttab.git] / fs / nfs / callback_proc.c

/*
 * linux/fs/nfs/callback_proc.c
 *
 * Copyright (C) 2004 Trond Myklebust
 *
 * NFSv4 callback procedures
 */
#include <linux/nfs4.h>
#include <linux/nfs_fs.h>
#include "nfs4_fs.h"
#include "callback.h"
#include "delegation.h"
#include "internal.h"

#ifdef NFS_DEBUG
#define NFSDBG_FACILITY NFSDBG_CALLBACK
#endif
 
__be32 nfs4_callback_getattr(struct cb_getattrargs *args, struct cb_getattrres *res)
{
	struct nfs_client *clp;
	struct nfs_delegation *delegation;
	struct nfs_inode *nfsi;
	struct inode *inode;

	res->bitmap[0] = res->bitmap[1] = 0;
	res->status = htonl(NFS4ERR_BADHANDLE);
	clp = nfs_find_client(args->addr, 4);
	if (clp == NULL)
		goto out;

	dprintk("NFS: GETATTR callback request from %s\n",
		rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_ADDR));

	inode = nfs_delegation_find_inode(clp, &args->fh);
	if (inode == NULL)
		goto out_putclient;
	nfsi = NFS_I(inode);
	down_read(&nfsi->rwsem);
	delegation = nfsi->delegation;
	if (delegation == NULL || (delegation->type & FMODE_WRITE) == 0)
		goto out_iput;
	res->size = i_size_read(inode);
	res->change_attr = delegation->change_attr;
	if (nfsi->npages != 0)
		res->change_attr++;
	res->ctime = inode->i_ctime;
	res->mtime = inode->i_mtime;
	res->bitmap[0] = (FATTR4_WORD0_CHANGE|FATTR4_WORD0_SIZE) &
		args->bitmap[0];
	res->bitmap[1] = (FATTR4_WORD1_TIME_METADATA|FATTR4_WORD1_TIME_MODIFY) &
		args->bitmap[1];
	res->status = 0;
out_iput:
	up_read(&nfsi->rwsem);
	iput(inode);
out_putclient:
	nfs_put_client(clp);
out:
	dprintk("%s: exit with status = %d\n", __func__, ntohl(res->status));
	return res->status;
}

static int (*nfs_validate_delegation_stateid(struct nfs_client *clp))(struct nfs_delegation *, const nfs4_stateid *)
{
#if defined(CONFIG_NFS_V4_1)
	if (clp->cl_minorversion > 0)
		return nfs41_validate_delegation_stateid;
#endif
	return nfs4_validate_delegation_stateid;
}


__be32 nfs4_callback_recall(struct cb_recallargs *args, void *dummy)
{
	struct nfs_client *clp;
	struct inode *inode;
	__be32 res;
	
	res = htonl(NFS4ERR_BADHANDLE);
	clp = nfs_find_client(args->addr, 4);
	if (clp == NULL)
		goto out;

	dprintk("NFS: RECALL callback request from %s\n",
		rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_ADDR));

	do {
		struct nfs_client *prev = clp;

		inode = nfs_delegation_find_inode(clp, &args->fh);
		if (inode != NULL) {
			/* Set up a helper thread to actually return the delegation */
			switch (nfs_async_inode_return_delegation(inode, &args->stateid,
								  nfs_validate_delegation_stateid(clp))) {
				case 0:
					res = 0;
					break;
				case -ENOENT:
					if (res != 0)
						res = htonl(NFS4ERR_BAD_STATEID);
					break;
				default:
					res = htonl(NFS4ERR_RESOURCE);
			}
			iput(inode);
		}
		clp = nfs_find_client_next(prev);
		nfs_put_client(prev);
	} while (clp != NULL);
out:
	dprintk("%s: exit with status = %d\n", __func__, ntohl(res));
	return res;
}

int nfs4_validate_delegation_stateid(struct nfs_delegation *delegation, const nfs4_stateid *stateid)
{
	if (delegation == NULL || memcmp(delegation->stateid.data, stateid->data,
					 sizeof(delegation->stateid.data)) != 0)
		return 0;
	return 1;
}

#if defined(CONFIG_NFS_V4_1)

int nfs41_validate_delegation_stateid(struct nfs_delegation *delegation, const nfs4_stateid *stateid)
{
	if (delegation == NULL)
		return 0;

	/* seqid is 4-bytes long */
	if (((u32 *) &stateid->data)[0] != 0)
		return 0;
	if (memcmp(&delegation->stateid.data[4], &stateid->data[4],
		   sizeof(stateid->data)-4))
		return 0;

	return 1;
}

/*
 * Validate the sequenceID sent by the server.
 * Return success if the sequenceID is one more than what we last saw on
 * this slot, accounting for wraparound.  Increments the slot's sequence.
 *
 * We don't yet implement a duplicate request cache, so at this time
 * we will log replays, and process them as if we had not seen them before,
 * but we don't bump the sequence in the slot.  Not too worried about it,
 * since we only currently implement idempotent callbacks anyway.
 *
 * We have a single slot backchannel at this time, so we don't bother
 * checking the used_slots bit array on the table.  The lower layer guarantees
 * a single outstanding callback request at a time.
 */
static int
validate_seqid(struct nfs4_slot_table *tbl, u32 slotid, u32 seqid)
{
	struct nfs4_slot *slot;

	dprintk("%s enter. slotid %d seqid %d\n",
		__func__, slotid, seqid);

	if (slotid > NFS41_BC_MAX_CALLBACKS)
		return htonl(NFS4ERR_BADSLOT);

	slot = tbl->slots + slotid;
	dprintk("%s slot table seqid: %d\n", __func__, slot->seq_nr);

	/* Normal */
	if (likely(seqid == slot->seq_nr + 1)) {
		slot->seq_nr++;
		return htonl(NFS4_OK);
	}

	/* Replay */
	if (seqid == slot->seq_nr) {
		dprintk("%s seqid %d is a replay - no DRC available\n",
			__func__, seqid);
		return htonl(NFS4_OK);
	}

	/* Wraparound */
	if (seqid == 1 && (slot->seq_nr + 1) == 0) {
		slot->seq_nr = 1;
		return htonl(NFS4_OK);
	}

	/* Misordered request */
	return htonl(NFS4ERR_SEQ_MISORDERED);
}

/*
 * Returns a pointer to a held 'struct nfs_client' that matches the server's
 * address, major version number, and session ID.  It is the caller's
 * responsibility to release the returned reference.
 *
 * Returns NULL if there are no connections with sessions, or if no session
 * matches the one of interest.
 */
 static struct nfs_client *find_client_with_session(
	const struct sockaddr *addr, u32 nfsversion,
	struct nfs4_sessionid *sessionid)
{
	struct nfs_client *clp;

	clp = nfs_find_client(addr, 4);
	if (clp == NULL)
		return NULL;

	do {
		struct nfs_client *prev = clp;

		if (clp->cl_session != NULL) {
			if (memcmp(clp->cl_session->sess_id.data,
					sessionid->data,
					NFS4_MAX_SESSIONID_LEN) == 0) {
				/* Returns a held reference to clp */
				return clp;
			}
		}
		clp = nfs_find_client_next(prev);
		nfs_put_client(prev);
	} while (clp != NULL);

	return NULL;
}

/* FIXME: referring calls should be processed */
unsigned nfs4_callback_sequence(struct cb_sequenceargs *args,
				struct cb_sequenceres *res)
{
	struct nfs_client *clp;
	int i, status;

	for (i = 0; i < args->csa_nrclists; i++)
		kfree(args->csa_rclists[i].rcl_refcalls);
	kfree(args->csa_rclists);

	status = htonl(NFS4ERR_BADSESSION);
	clp = find_client_with_session(args->csa_addr, 4, &args->csa_sessionid);
	if (clp == NULL)
		goto out;

	status = validate_seqid(&clp->cl_session->bc_slot_table,
				args->csa_slotid, args->csa_sequenceid);
	if (status)
		goto out_putclient;

	memcpy(&res->csr_sessionid, &args->csa_sessionid,
	       sizeof(res->csr_sessionid));
	res->csr_sequenceid = args->csa_sequenceid;
	res->csr_slotid = args->csa_slotid;
	res->csr_highestslotid = NFS41_BC_MAX_CALLBACKS - 1;
	res->csr_target_highestslotid = NFS41_BC_MAX_CALLBACKS - 1;

out_putclient:
	nfs_put_client(clp);
out:
	dprintk("%s: exit with status = %d\n", __func__, ntohl(status));
	res->csr_status = status;
	return res->csr_status;
}

unsigned nfs4_callback_recallany(struct cb_recallanyargs *args, void *dummy)
{
	struct nfs_client *clp;
	int status;
	fmode_t flags = 0;

	status = htonl(NFS4ERR_OP_NOT_IN_SESSION);
	clp = nfs_find_client(args->craa_addr, 4);
	if (clp == NULL)
		goto out;

	dprintk("NFS: RECALL_ANY callback request from %s\n",
		rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_ADDR));

	if (test_bit(RCA4_TYPE_MASK_RDATA_DLG, (const unsigned long *)
		     &args->craa_type_mask))
		flags = FMODE_READ;
	if (test_bit(RCA4_TYPE_MASK_WDATA_DLG, (const unsigned long *)
		     &args->craa_type_mask))
		flags |= FMODE_WRITE;

	if (flags)
		nfs_expire_all_delegation_types(clp, flags);
	status = htonl(NFS4_OK);
out:
	dprintk("%s: exit with status = %d\n", __func__, ntohl(status));
	return status;
}
#endif /* CONFIG_NFS_V4_1 */
Commit	Line	Data
1da177e4 LT	1	/*
	2	* linux/fs/nfs/callback_proc.c
	3	*
	4	* Copyright (C) 2004 Trond Myklebust
	5	*
	6	* NFSv4 callback procedures
	7	*/
1da177e4 LT	8	#include <linux/nfs4.h>
1da177e4 LT	9	#include <linux/nfs_fs.h>
4ce79717	10	#include "nfs4_fs.h"
1da177e4 LT	11	#include "callback.h"
1da177e4 LT	12	#include "delegation.h"
24c8dbbb	13	#include "internal.h"
1da177e4	14
1d98fe67	15	#ifdef NFS_DEBUG
1da177e4	16	#define NFSDBG_FACILITY NFSDBG_CALLBACK
1d98fe67	17	#endif
1da177e4	18
e6f684f6	19	__be32 nfs4_callback_getattr(struct cb_getattrargs args, struct cb_getattrres res)
1da177e4	20	{
adfa6f98	21	struct nfs_client *clp;
1da177e4 LT	22	struct nfs_delegation *delegation;
	23	struct nfs_inode *nfsi;
	24	struct inode *inode;
1d98fe67	25
1da177e4 LT	26	res->bitmap[0] = res->bitmap[1] = 0;
1da177e4 LT	27	res->status = htonl(NFS4ERR_BADHANDLE);
ff052645	28	clp = nfs_find_client(args->addr, 4);
1da177e4 LT	29	if (clp == NULL)
1da177e4 LT	30	goto out;
1d98fe67 CL	31
	32	dprintk("NFS: GETATTR callback request from %s\n",
	33	rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_ADDR));
	34
1da177e4 LT	35	inode = nfs_delegation_find_inode(clp, &args->fh);
	36	if (inode == NULL)
	37	goto out_putclient;
	38	nfsi = NFS_I(inode);
	39	down_read(&nfsi->rwsem);
	40	delegation = nfsi->delegation;
	41	if (delegation == NULL \|\| (delegation->type & FMODE_WRITE) == 0)
	42	goto out_iput;
	43	res->size = i_size_read(inode);
beb2a5ec TM	44	res->change_attr = delegation->change_attr;
	45	if (nfsi->npages != 0)
	46	res->change_attr++;
1da177e4 LT	47	res->ctime = inode->i_ctime;
	48	res->mtime = inode->i_mtime;
	49	res->bitmap[0] = (FATTR4_WORD0_CHANGE\|FATTR4_WORD0_SIZE) &
	50	args->bitmap[0];
	51	res->bitmap[1] = (FATTR4_WORD1_TIME_METADATA\|FATTR4_WORD1_TIME_MODIFY) &
	52	args->bitmap[1];
	53	res->status = 0;
	54	out_iput:
	55	up_read(&nfsi->rwsem);
	56	iput(inode);
	57	out_putclient:
24c8dbbb	58	nfs_put_client(clp);
1da177e4	59	out:
3110ff80	60	dprintk("%s: exit with status = %d\n", __func__, ntohl(res->status));
1da177e4 LT	61	return res->status;
	62	}
	63
2597641d AB	64	static int (nfs_validate_delegation_stateid(struct nfs_client clp))(struct nfs_delegation , const nfs4_stateid )
	65	{
	66	#if defined(CONFIG_NFS_V4_1)
	67	if (clp->cl_minorversion > 0)
	68	return nfs41_validate_delegation_stateid;
	69	#endif
	70	return nfs4_validate_delegation_stateid;
	71	}
	72
	73
e6f684f6	74	__be32 nfs4_callback_recall(struct cb_recallargs args, void dummy)
1da177e4	75	{
adfa6f98	76	struct nfs_client *clp;
1da177e4	77	struct inode *inode;
e6f684f6	78	__be32 res;
1da177e4 LT	79
1da177e4 LT	80	res = htonl(NFS4ERR_BADHANDLE);
ff052645	81	clp = nfs_find_client(args->addr, 4);
1da177e4 LT	82	if (clp == NULL)
1da177e4 LT	83	goto out;
1d98fe67 CL	84
	85	dprintk("NFS: RECALL callback request from %s\n",
	86	rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_ADDR));
	87
3fbd67ad TM	88	do {
	89	struct nfs_client *prev = clp;
	90
	91	inode = nfs_delegation_find_inode(clp, &args->fh);
	92	if (inode != NULL) {
	93	/* Set up a helper thread to actually return the delegation */
2597641d AB	94	switch (nfs_async_inode_return_delegation(inode, &args->stateid,
2597641d AB	95	nfs_validate_delegation_stateid(clp))) {
3fbd67ad TM	96	case 0:
	97	res = 0;
	98	break;
	99	case -ENOENT:
	100	if (res != 0)
	101	res = htonl(NFS4ERR_BAD_STATEID);
	102	break;
	103	default:
	104	res = htonl(NFS4ERR_RESOURCE);
	105	}
	106	iput(inode);
	107	}
	108	clp = nfs_find_client_next(prev);
	109	nfs_put_client(prev);
	110	} while (clp != NULL);
1da177e4	111	out:
3110ff80	112	dprintk("%s: exit with status = %d\n", __func__, ntohl(res));
1da177e4 LT	113	return res;
1da177e4 LT	114	}
d49433e1	115
2597641d AB	116	int nfs4_validate_delegation_stateid(struct nfs_delegation delegation, const nfs4_stateid stateid)
	117	{
	118	if (delegation == NULL \|\| memcmp(delegation->stateid.data, stateid->data,
	119	sizeof(delegation->stateid.data)) != 0)
	120	return 0;
	121	return 1;
	122	}
	123
d49433e1 BH	124	#if defined(CONFIG_NFS_V4_1)
d49433e1 BH	125
2597641d AB	126	int nfs41_validate_delegation_stateid(struct nfs_delegation delegation, const nfs4_stateid stateid)
	127	{
	128	if (delegation == NULL)
	129	return 0;
	130
	131	/* seqid is 4-bytes long */
	132	if (((u32 *) &stateid->data)[0] != 0)
	133	return 0;
	134	if (memcmp(&delegation->stateid.data[4], &stateid->data[4],
	135	sizeof(stateid->data)-4))
	136	return 0;
	137
	138	return 1;
	139	}
	140
68f3f901 RL	141	/*
	142	* Validate the sequenceID sent by the server.
	143	* Return success if the sequenceID is one more than what we last saw on
	144	* this slot, accounting for wraparound. Increments the slot's sequence.
	145	*
	146	* We don't yet implement a duplicate request cache, so at this time
	147	* we will log replays, and process them as if we had not seen them before,
	148	* but we don't bump the sequence in the slot. Not too worried about it,
	149	* since we only currently implement idempotent callbacks anyway.
	150	*
	151	* We have a single slot backchannel at this time, so we don't bother
	152	* checking the used_slots bit array on the table. The lower layer guarantees
	153	* a single outstanding callback request at a time.
	154	*/
	155	static int
	156	validate_seqid(struct nfs4_slot_table *tbl, u32 slotid, u32 seqid)
	157	{
	158	struct nfs4_slot *slot;
	159
	160	dprintk("%s enter. slotid %d seqid %d\n",
	161	__func__, slotid, seqid);
	162
	163	if (slotid > NFS41_BC_MAX_CALLBACKS)
	164	return htonl(NFS4ERR_BADSLOT);
	165
	166	slot = tbl->slots + slotid;
	167	dprintk("%s slot table seqid: %d\n", __func__, slot->seq_nr);
	168
	169	/* Normal */
	170	if (likely(seqid == slot->seq_nr + 1)) {
	171	slot->seq_nr++;
	172	return htonl(NFS4_OK);
	173	}
	174
	175	/* Replay */
	176	if (seqid == slot->seq_nr) {
	177	dprintk("%s seqid %d is a replay - no DRC available\n",
	178	__func__, seqid);
	179	return htonl(NFS4_OK);
	180	}
	181
	182	/* Wraparound */
	183	if (seqid == 1 && (slot->seq_nr + 1) == 0) {
	184	slot->seq_nr = 1;
	185	return htonl(NFS4_OK);
	186	}
	187
	188	/* Misordered request */
	189	return htonl(NFS4ERR_SEQ_MISORDERED);
	190	}
	191
963891ac RL	192	/*
	193	* Returns a pointer to a held 'struct nfs_client' that matches the server's
	194	* address, major version number, and session ID. It is the caller's
	195	* responsibility to release the returned reference.
	196	*
	197	* Returns NULL if there are no connections with sessions, or if no session
	198	* matches the one of interest.
	199	*/
	200	static struct nfs_client *find_client_with_session(
	201	const struct sockaddr *addr, u32 nfsversion,
	202	struct nfs4_sessionid *sessionid)
	203	{
	204	struct nfs_client *clp;
	205
	206	clp = nfs_find_client(addr, 4);
	207	if (clp == NULL)
	208	return NULL;
	209
	210	do {
	211	struct nfs_client *prev = clp;
	212
	213	if (clp->cl_session != NULL) {
	214	if (memcmp(clp->cl_session->sess_id.data,
	215	sessionid->data,
	216	NFS4_MAX_SESSIONID_LEN) == 0) {
	217	/* Returns a held reference to clp */
	218	return clp;
	219	}
	220	}
	221	clp = nfs_find_client_next(prev);
	222	nfs_put_client(prev);
	223	} while (clp != NULL);
	224
	225	return NULL;
	226	}
	227
d49433e1 BH	228	/* FIXME: referring calls should be processed */
	229	unsigned nfs4_callback_sequence(struct cb_sequenceargs *args,
	230	struct cb_sequenceres *res)
	231	{
68f3f901 RL	232	struct nfs_client *clp;
68f3f901 RL	233	int i, status;
d49433e1 BH	234
	235	for (i = 0; i < args->csa_nrclists; i++)
	236	kfree(args->csa_rclists[i].rcl_refcalls);
	237	kfree(args->csa_rclists);
	238
68f3f901 RL	239	status = htonl(NFS4ERR_BADSESSION);
	240	clp = find_client_with_session(args->csa_addr, 4, &args->csa_sessionid);
	241	if (clp == NULL)
	242	goto out;
	243
	244	status = validate_seqid(&clp->cl_session->bc_slot_table,
	245	args->csa_slotid, args->csa_sequenceid);
	246	if (status)
	247	goto out_putclient;
	248
d49433e1 BH	249	memcpy(&res->csr_sessionid, &args->csa_sessionid,
	250	sizeof(res->csr_sessionid));
	251	res->csr_sequenceid = args->csa_sequenceid;
	252	res->csr_slotid = args->csa_slotid;
	253	res->csr_highestslotid = NFS41_BC_MAX_CALLBACKS - 1;
	254	res->csr_target_highestslotid = NFS41_BC_MAX_CALLBACKS - 1;
	255
68f3f901 RL	256	out_putclient:
	257	nfs_put_client(clp);
	258	out:
d49433e1 BH	259	dprintk("%s: exit with status = %d\n", __func__, ntohl(status));
d49433e1 BH	260	res->csr_status = status;
68f3f901	261	return res->csr_status;
d49433e1 BH	262	}
d49433e1 BH	263
31f09607 AB	264	unsigned nfs4_callback_recallany(struct cb_recallanyargs args, void dummy)
	265	{
	266	struct nfs_client *clp;
	267	int status;
	268	fmode_t flags = 0;
	269
	270	status = htonl(NFS4ERR_OP_NOT_IN_SESSION);
	271	clp = nfs_find_client(args->craa_addr, 4);
	272	if (clp == NULL)
	273	goto out;
	274
	275	dprintk("NFS: RECALL_ANY callback request from %s\n",
	276	rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_ADDR));
	277
	278	if (test_bit(RCA4_TYPE_MASK_RDATA_DLG, (const unsigned long *)
	279	&args->craa_type_mask))
	280	flags = FMODE_READ;
	281	if (test_bit(RCA4_TYPE_MASK_WDATA_DLG, (const unsigned long *)
	282	&args->craa_type_mask))
	283	flags \|= FMODE_WRITE;
	284
	285	if (flags)
	286	nfs_expire_all_delegation_types(clp, flags);
	287	status = htonl(NFS4_OK);
	288	out:
	289	dprintk("%s: exit with status = %d\n", __func__, ntohl(status));
	290	return status;
	291	}
d49433e1	292	#endif /* CONFIG_NFS_V4_1 */