[linux.git] / fs / afs / cmservice.c

/* AFS Cache Manager Service
 *
 * Copyright (C) 2002 Red Hat, Inc. All Rights Reserved.
 * Written by David Howells ([email protected])
 *
 * 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 of the License, or (at your option) any later version.
 */

#include <linux/module.h>
#include <linux/init.h>
#include <linux/slab.h>
#include <linux/sched.h>
#include <linux/ip.h>
#include "internal.h"
#include "afs_cm.h"

static int afs_deliver_cb_init_call_back_state(struct afs_call *);
static int afs_deliver_cb_init_call_back_state3(struct afs_call *);
static int afs_deliver_cb_probe(struct afs_call *);
static int afs_deliver_cb_callback(struct afs_call *);
static int afs_deliver_cb_probe_uuid(struct afs_call *);
static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *);
static void afs_cm_destructor(struct afs_call *);

/*
 * CB.CallBack operation type
 */
static const struct afs_call_type afs_SRXCBCallBack = {
	.name		= "CB.CallBack",
	.deliver	= afs_deliver_cb_callback,
	.abort_to_error	= afs_abort_to_error,
	.destructor	= afs_cm_destructor,
};

/*
 * CB.InitCallBackState operation type
 */
static const struct afs_call_type afs_SRXCBInitCallBackState = {
	.name		= "CB.InitCallBackState",
	.deliver	= afs_deliver_cb_init_call_back_state,
	.abort_to_error	= afs_abort_to_error,
	.destructor	= afs_cm_destructor,
};

/*
 * CB.InitCallBackState3 operation type
 */
static const struct afs_call_type afs_SRXCBInitCallBackState3 = {
	.name		= "CB.InitCallBackState3",
	.deliver	= afs_deliver_cb_init_call_back_state3,
	.abort_to_error	= afs_abort_to_error,
	.destructor	= afs_cm_destructor,
};

/*
 * CB.Probe operation type
 */
static const struct afs_call_type afs_SRXCBProbe = {
	.name		= "CB.Probe",
	.deliver	= afs_deliver_cb_probe,
	.abort_to_error	= afs_abort_to_error,
	.destructor	= afs_cm_destructor,
};

/*
 * CB.ProbeUuid operation type
 */
static const struct afs_call_type afs_SRXCBProbeUuid = {
	.name		= "CB.ProbeUuid",
	.deliver	= afs_deliver_cb_probe_uuid,
	.abort_to_error	= afs_abort_to_error,
	.destructor	= afs_cm_destructor,
};

/*
 * CB.TellMeAboutYourself operation type
 */
static const struct afs_call_type afs_SRXCBTellMeAboutYourself = {
	.name		= "CB.TellMeAboutYourself",
	.deliver	= afs_deliver_cb_tell_me_about_yourself,
	.abort_to_error	= afs_abort_to_error,
	.destructor	= afs_cm_destructor,
};

/*
 * route an incoming cache manager call
 * - return T if supported, F if not
 */
bool afs_cm_incoming_call(struct afs_call *call)
{
	_enter("{CB.OP %u}", call->operation_ID);

	switch (call->operation_ID) {
	case CBCallBack:
		call->type = &afs_SRXCBCallBack;
		return true;
	case CBInitCallBackState:
		call->type = &afs_SRXCBInitCallBackState;
		return true;
	case CBInitCallBackState3:
		call->type = &afs_SRXCBInitCallBackState3;
		return true;
	case CBProbe:
		call->type = &afs_SRXCBProbe;
		return true;
	case CBTellMeAboutYourself:
		call->type = &afs_SRXCBTellMeAboutYourself;
		return true;
	default:
		return false;
	}
}

/*
 * clean up a cache manager call
 */
static void afs_cm_destructor(struct afs_call *call)
{
	_enter("");

	/* Break the callbacks here so that we do it after the final ACK is
	 * received.  The step number here must match the final number in
	 * afs_deliver_cb_callback().
	 */
	if (call->unmarshall == 5) {
		ASSERT(call->server && call->count && call->request);
		afs_break_callbacks(call->server, call->count, call->request);
	}

	afs_put_server(call->server);
	call->server = NULL;
	kfree(call->buffer);
	call->buffer = NULL;
}

/*
 * allow the fileserver to see if the cache manager is still alive
 */
static void SRXAFSCB_CallBack(struct work_struct *work)
{
	struct afs_call *call = container_of(work, struct afs_call, work);

	_enter("");

	/* be sure to send the reply *before* attempting to spam the AFS server
	 * with FSFetchStatus requests on the vnodes with broken callbacks lest
	 * the AFS server get into a vicious cycle of trying to break further
	 * callbacks because it hadn't received completion of the CBCallBack op
	 * yet */
	afs_send_empty_reply(call);

	afs_break_callbacks(call->server, call->count, call->request);
	_leave("");
}

/*
 * deliver request data to a CB.CallBack call
 */
static int afs_deliver_cb_callback(struct afs_call *call)
{
	struct sockaddr_rxrpc srx;
	struct afs_callback *cb;
	struct afs_server *server;
	__be32 *bp;
	u32 tmp;
	int ret, loop;

	_enter("{%u}", call->unmarshall);

	switch (call->unmarshall) {
	case 0:
		rxrpc_kernel_get_peer(afs_socket, call->rxcall, &srx);
		call->offset = 0;
		call->unmarshall++;

		/* extract the FID array and its count in two steps */
	case 1:
		_debug("extract FID count");
		ret = afs_extract_data(call, &call->tmp, 4, true);
		if (ret < 0)
			return ret;

		call->count = ntohl(call->tmp);
		_debug("FID count: %u", call->count);
		if (call->count > AFSCBMAX)
			return -EBADMSG;

		call->buffer = kmalloc(call->count * 3 * 4, GFP_KERNEL);
		if (!call->buffer)
			return -ENOMEM;
		call->offset = 0;
		call->unmarshall++;

	case 2:
		_debug("extract FID array");
		ret = afs_extract_data(call, call->buffer,
				       call->count * 3 * 4, true);
		if (ret < 0)
			return ret;

		_debug("unmarshall FID array");
		call->request = kcalloc(call->count,
					sizeof(struct afs_callback),
					GFP_KERNEL);
		if (!call->request)
			return -ENOMEM;

		cb = call->request;
		bp = call->buffer;
		for (loop = call->count; loop > 0; loop--, cb++) {
			cb->fid.vid	= ntohl(*bp++);
			cb->fid.vnode	= ntohl(*bp++);
			cb->fid.unique	= ntohl(*bp++);
			cb->type	= AFSCM_CB_UNTYPED;
		}

		call->offset = 0;
		call->unmarshall++;

		/* extract the callback array and its count in two steps */
	case 3:
		_debug("extract CB count");
		ret = afs_extract_data(call, &call->tmp, 4, true);
		if (ret < 0)
			return ret;

		tmp = ntohl(call->tmp);
		_debug("CB count: %u", tmp);
		if (tmp != call->count && tmp != 0)
			return -EBADMSG;
		call->offset = 0;
		call->unmarshall++;

	case 4:
		_debug("extract CB array");
		ret = afs_extract_data(call, call->buffer,
				       call->count * 3 * 4, false);
		if (ret < 0)
			return ret;

		_debug("unmarshall CB array");
		cb = call->request;
		bp = call->buffer;
		for (loop = call->count; loop > 0; loop--, cb++) {
			cb->version	= ntohl(*bp++);
			cb->expiry	= ntohl(*bp++);
			cb->type	= ntohl(*bp++);
		}

		call->offset = 0;
		call->unmarshall++;

		/* Record that the message was unmarshalled successfully so
		 * that the call destructor can know do the callback breaking
		 * work, even if the final ACK isn't received.
		 *
		 * If the step number changes, then afs_cm_destructor() must be
		 * updated also.
		 */
		call->unmarshall++;
	case 5:
		break;
	}

	call->state = AFS_CALL_REPLYING;

	/* we'll need the file server record as that tells us which set of
	 * vnodes to operate upon */
	server = afs_find_server(&srx);
	if (!server)
		return -ENOTCONN;
	call->server = server;

	INIT_WORK(&call->work, SRXAFSCB_CallBack);
	queue_work(afs_wq, &call->work);
	return 0;
}

/*
 * allow the fileserver to request callback state (re-)initialisation
 */
static void SRXAFSCB_InitCallBackState(struct work_struct *work)
{
	struct afs_call *call = container_of(work, struct afs_call, work);

	_enter("{%p}", call->server);

	afs_init_callback_state(call->server);
	afs_send_empty_reply(call);
	_leave("");
}

/*
 * deliver request data to a CB.InitCallBackState call
 */
static int afs_deliver_cb_init_call_back_state(struct afs_call *call)
{
	struct sockaddr_rxrpc srx;
	struct afs_server *server;
	int ret;

	_enter("");

	rxrpc_kernel_get_peer(afs_socket, call->rxcall, &srx);

	ret = afs_extract_data(call, NULL, 0, false);
	if (ret < 0)
		return ret;

	/* no unmarshalling required */
	call->state = AFS_CALL_REPLYING;

	/* we'll need the file server record as that tells us which set of
	 * vnodes to operate upon */
	server = afs_find_server(&srx);
	if (!server)
		return -ENOTCONN;
	call->server = server;

	INIT_WORK(&call->work, SRXAFSCB_InitCallBackState);
	queue_work(afs_wq, &call->work);
	return 0;
}

/*
 * deliver request data to a CB.InitCallBackState3 call
 */
static int afs_deliver_cb_init_call_back_state3(struct afs_call *call)
{
	struct sockaddr_rxrpc srx;
	struct afs_server *server;
	struct afs_uuid *r;
	unsigned loop;
	__be32 *b;
	int ret;

	_enter("");

	rxrpc_kernel_get_peer(afs_socket, call->rxcall, &srx);

	_enter("{%u}", call->unmarshall);

	switch (call->unmarshall) {
	case 0:
		call->offset = 0;
		call->buffer = kmalloc(11 * sizeof(__be32), GFP_KERNEL);
		if (!call->buffer)
			return -ENOMEM;
		call->unmarshall++;

	case 1:
		_debug("extract UUID");
		ret = afs_extract_data(call, call->buffer,
				       11 * sizeof(__be32), false);
		switch (ret) {
		case 0:		break;
		case -EAGAIN:	return 0;
		default:	return ret;
		}

		_debug("unmarshall UUID");
		call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL);
		if (!call->request)
			return -ENOMEM;

		b = call->buffer;
		r = call->request;
		r->time_low			= ntohl(b[0]);
		r->time_mid			= ntohl(b[1]);
		r->time_hi_and_version		= ntohl(b[2]);
		r->clock_seq_hi_and_reserved 	= ntohl(b[3]);
		r->clock_seq_low		= ntohl(b[4]);

		for (loop = 0; loop < 6; loop++)
			r->node[loop] = ntohl(b[loop + 5]);

		call->offset = 0;
		call->unmarshall++;

	case 2:
		break;
	}

	/* no unmarshalling required */
	call->state = AFS_CALL_REPLYING;

	/* we'll need the file server record as that tells us which set of
	 * vnodes to operate upon */
	server = afs_find_server(&srx);
	if (!server)
		return -ENOTCONN;
	call->server = server;

	INIT_WORK(&call->work, SRXAFSCB_InitCallBackState);
	queue_work(afs_wq, &call->work);
	return 0;
}

/*
 * allow the fileserver to see if the cache manager is still alive
 */
static void SRXAFSCB_Probe(struct work_struct *work)
{
	struct afs_call *call = container_of(work, struct afs_call, work);

	_enter("");
	afs_send_empty_reply(call);
	_leave("");
}

/*
 * deliver request data to a CB.Probe call
 */
static int afs_deliver_cb_probe(struct afs_call *call)
{
	int ret;

	_enter("");

	ret = afs_extract_data(call, NULL, 0, false);
	if (ret < 0)
		return ret;

	/* no unmarshalling required */
	call->state = AFS_CALL_REPLYING;

	INIT_WORK(&call->work, SRXAFSCB_Probe);
	queue_work(afs_wq, &call->work);
	return 0;
}

/*
 * allow the fileserver to quickly find out if the fileserver has been rebooted
 */
static void SRXAFSCB_ProbeUuid(struct work_struct *work)
{
	struct afs_call *call = container_of(work, struct afs_call, work);
	struct afs_uuid *r = call->request;

	struct {
		__be32	match;
	} reply;

	_enter("");

	if (memcmp(r, &afs_uuid, sizeof(afs_uuid)) == 0)
		reply.match = htonl(0);
	else
		reply.match = htonl(1);

	afs_send_simple_reply(call, &reply, sizeof(reply));
	_leave("");
}

/*
 * deliver request data to a CB.ProbeUuid call
 */
static int afs_deliver_cb_probe_uuid(struct afs_call *call)
{
	struct afs_uuid *r;
	unsigned loop;
	__be32 *b;
	int ret;

	_enter("{%u}", call->unmarshall);

	switch (call->unmarshall) {
	case 0:
		call->offset = 0;
		call->buffer = kmalloc(11 * sizeof(__be32), GFP_KERNEL);
		if (!call->buffer)
			return -ENOMEM;
		call->unmarshall++;

	case 1:
		_debug("extract UUID");
		ret = afs_extract_data(call, call->buffer,
				       11 * sizeof(__be32), false);
		switch (ret) {
		case 0:		break;
		case -EAGAIN:	return 0;
		default:	return ret;
		}

		_debug("unmarshall UUID");
		call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL);
		if (!call->request)
			return -ENOMEM;

		b = call->buffer;
		r = call->request;
		r->time_low			= ntohl(b[0]);
		r->time_mid			= ntohl(b[1]);
		r->time_hi_and_version		= ntohl(b[2]);
		r->clock_seq_hi_and_reserved 	= ntohl(b[3]);
		r->clock_seq_low		= ntohl(b[4]);

		for (loop = 0; loop < 6; loop++)
			r->node[loop] = ntohl(b[loop + 5]);

		call->offset = 0;
		call->unmarshall++;

	case 2:
		break;
	}

	call->state = AFS_CALL_REPLYING;

	INIT_WORK(&call->work, SRXAFSCB_ProbeUuid);
	queue_work(afs_wq, &call->work);
	return 0;
}

/*
 * allow the fileserver to ask about the cache manager's capabilities
 */
static void SRXAFSCB_TellMeAboutYourself(struct work_struct *work)
{
	struct afs_interface *ifs;
	struct afs_call *call = container_of(work, struct afs_call, work);
	int loop, nifs;

	struct {
		struct /* InterfaceAddr */ {
			__be32 nifs;
			__be32 uuid[11];
			__be32 ifaddr[32];
			__be32 netmask[32];
			__be32 mtu[32];
		} ia;
		struct /* Capabilities */ {
			__be32 capcount;
			__be32 caps[1];
		} cap;
	} reply;

	_enter("");

	nifs = 0;
	ifs = kcalloc(32, sizeof(*ifs), GFP_KERNEL);
	if (ifs) {
		nifs = afs_get_ipv4_interfaces(ifs, 32, false);
		if (nifs < 0) {
			kfree(ifs);
			ifs = NULL;
			nifs = 0;
		}
	}

	memset(&reply, 0, sizeof(reply));
	reply.ia.nifs = htonl(nifs);

	reply.ia.uuid[0] = htonl(afs_uuid.time_low);
	reply.ia.uuid[1] = htonl(afs_uuid.time_mid);
	reply.ia.uuid[2] = htonl(afs_uuid.time_hi_and_version);
	reply.ia.uuid[3] = htonl((s8) afs_uuid.clock_seq_hi_and_reserved);
	reply.ia.uuid[4] = htonl((s8) afs_uuid.clock_seq_low);
	for (loop = 0; loop < 6; loop++)
		reply.ia.uuid[loop + 5] = htonl((s8) afs_uuid.node[loop]);

	if (ifs) {
		for (loop = 0; loop < nifs; loop++) {
			reply.ia.ifaddr[loop] = ifs[loop].address.s_addr;
			reply.ia.netmask[loop] = ifs[loop].netmask.s_addr;
			reply.ia.mtu[loop] = htonl(ifs[loop].mtu);
		}
		kfree(ifs);
	}

	reply.cap.capcount = htonl(1);
	reply.cap.caps[0] = htonl(AFS_CAP_ERROR_TRANSLATION);
	afs_send_simple_reply(call, &reply, sizeof(reply));

	_leave("");
}

/*
 * deliver request data to a CB.TellMeAboutYourself call
 */
static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *call)
{
	int ret;

	_enter("");

	ret = afs_extract_data(call, NULL, 0, false);
	if (ret < 0)
		return ret;

	/* no unmarshalling required */
	call->state = AFS_CALL_REPLYING;

	INIT_WORK(&call->work, SRXAFSCB_TellMeAboutYourself);
	queue_work(afs_wq, &call->work);
	return 0;
}
Commit	Line	Data
ec26815a	1	/* AFS Cache Manager Service
1da177e4 LT	2	*
	3	* Copyright (C) 2002 Red Hat, Inc. All Rights Reserved.
	4	* Written by David Howells ([email protected])
	5	*
	6	* This program is free software; you can redistribute it and/or
	7	* modify it under the terms of the GNU General Public License
	8	* as published by the Free Software Foundation; either version
	9	* 2 of the License, or (at your option) any later version.
	10	*/
	11
	12	#include <linux/module.h>
	13	#include <linux/init.h>
5a0e3ad6	14	#include <linux/slab.h>
1da177e4	15	#include <linux/sched.h>
08e0e7c8	16	#include <linux/ip.h>
1da177e4	17	#include "internal.h"
08e0e7c8	18	#include "afs_cm.h"
1da177e4	19
d001648e DH	20	static int afs_deliver_cb_init_call_back_state(struct afs_call *);
	21	static int afs_deliver_cb_init_call_back_state3(struct afs_call *);
	22	static int afs_deliver_cb_probe(struct afs_call *);
	23	static int afs_deliver_cb_callback(struct afs_call *);
	24	static int afs_deliver_cb_probe_uuid(struct afs_call *);
	25	static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *);
08e0e7c8	26	static void afs_cm_destructor(struct afs_call *);
1da177e4	27
1da177e4	28	/*
08e0e7c8	29	* CB.CallBack operation type
1da177e4	30	*/
08e0e7c8	31	static const struct afs_call_type afs_SRXCBCallBack = {
00d3b7a4	32	.name = "CB.CallBack",
08e0e7c8 DH	33	.deliver = afs_deliver_cb_callback,
	34	.abort_to_error = afs_abort_to_error,
	35	.destructor = afs_cm_destructor,
	36	};
1da177e4	37
1da177e4	38	/*
08e0e7c8	39	* CB.InitCallBackState operation type
1da177e4	40	*/
08e0e7c8	41	static const struct afs_call_type afs_SRXCBInitCallBackState = {
00d3b7a4	42	.name = "CB.InitCallBackState",
08e0e7c8 DH	43	.deliver = afs_deliver_cb_init_call_back_state,
	44	.abort_to_error = afs_abort_to_error,
	45	.destructor = afs_cm_destructor,
	46	};
1da177e4	47
c35eccb1 DH	48	/*
	49	* CB.InitCallBackState3 operation type
	50	*/
	51	static const struct afs_call_type afs_SRXCBInitCallBackState3 = {
	52	.name = "CB.InitCallBackState3",
	53	.deliver = afs_deliver_cb_init_call_back_state3,
	54	.abort_to_error = afs_abort_to_error,
	55	.destructor = afs_cm_destructor,
	56	};
	57
1da177e4	58	/*
08e0e7c8	59	* CB.Probe operation type
1da177e4	60	*/
08e0e7c8	61	static const struct afs_call_type afs_SRXCBProbe = {
00d3b7a4	62	.name = "CB.Probe",
08e0e7c8 DH	63	.deliver = afs_deliver_cb_probe,
	64	.abort_to_error = afs_abort_to_error,
	65	.destructor = afs_cm_destructor,
	66	};
1da177e4	67
9396d496 DH	68	/*
	69	* CB.ProbeUuid operation type
	70	*/
	71	static const struct afs_call_type afs_SRXCBProbeUuid = {
	72	.name = "CB.ProbeUuid",
	73	.deliver = afs_deliver_cb_probe_uuid,
	74	.abort_to_error = afs_abort_to_error,
	75	.destructor = afs_cm_destructor,
	76	};
	77
b908fe6b	78	/*
7c80bcce	79	* CB.TellMeAboutYourself operation type
b908fe6b	80	*/
7c80bcce DH	81	static const struct afs_call_type afs_SRXCBTellMeAboutYourself = {
	82	.name = "CB.TellMeAboutYourself",
	83	.deliver = afs_deliver_cb_tell_me_about_yourself,
b908fe6b DH	84	.abort_to_error = afs_abort_to_error,
	85	.destructor = afs_cm_destructor,
	86	};
	87
1da177e4	88	/*
08e0e7c8 DH	89	* route an incoming cache manager call
08e0e7c8 DH	90	* - return T if supported, F if not
1da177e4	91	*/
08e0e7c8	92	bool afs_cm_incoming_call(struct afs_call *call)
1da177e4	93	{
50a2c953	94	_enter("{CB.OP %u}", call->operation_ID);
08e0e7c8	95
50a2c953	96	switch (call->operation_ID) {
08e0e7c8 DH	97	case CBCallBack:
	98	call->type = &afs_SRXCBCallBack;
	99	return true;
	100	case CBInitCallBackState:
	101	call->type = &afs_SRXCBInitCallBackState;
	102	return true;
c35eccb1 DH	103	case CBInitCallBackState3:
	104	call->type = &afs_SRXCBInitCallBackState3;
	105	return true;
08e0e7c8 DH	106	case CBProbe:
	107	call->type = &afs_SRXCBProbe;
	108	return true;
7c80bcce DH	109	case CBTellMeAboutYourself:
7c80bcce DH	110	call->type = &afs_SRXCBTellMeAboutYourself;
b908fe6b	111	return true;
08e0e7c8 DH	112	default:
08e0e7c8 DH	113	return false;
1da177e4	114	}
ec26815a	115	}
1da177e4	116
1da177e4	117	/*
08e0e7c8	118	* clean up a cache manager call
1da177e4	119	*/
08e0e7c8	120	static void afs_cm_destructor(struct afs_call *call)
1da177e4	121	{
08e0e7c8 DH	122	_enter("");
08e0e7c8 DH	123
6c67c7c3 DH	124	/* Break the callbacks here so that we do it after the final ACK is
	125	* received. The step number here must match the final number in
	126	* afs_deliver_cb_callback().
	127	*/
d001648e	128	if (call->unmarshall == 5) {
6c67c7c3 DH	129	ASSERT(call->server && call->count && call->request);
	130	afs_break_callbacks(call->server, call->count, call->request);
	131	}
	132
08e0e7c8 DH	133	afs_put_server(call->server);
	134	call->server = NULL;
	135	kfree(call->buffer);
	136	call->buffer = NULL;
ec26815a	137	}
1da177e4	138
1da177e4	139	/*
08e0e7c8	140	* allow the fileserver to see if the cache manager is still alive
1da177e4	141	*/
08e0e7c8	142	static void SRXAFSCB_CallBack(struct work_struct *work)
1da177e4	143	{
08e0e7c8	144	struct afs_call *call = container_of(work, struct afs_call, work);
1da177e4	145
08e0e7c8	146	_enter("");
1da177e4	147
08e0e7c8 DH	148	/* be sure to send the reply before attempting to spam the AFS server
	149	* with FSFetchStatus requests on the vnodes with broken callbacks lest
	150	* the AFS server get into a vicious cycle of trying to break further
	151	* callbacks because it hadn't received completion of the CBCallBack op
	152	* yet */
	153	afs_send_empty_reply(call);
1da177e4	154
08e0e7c8 DH	155	afs_break_callbacks(call->server, call->count, call->request);
08e0e7c8 DH	156	_leave("");
ec26815a	157	}
1da177e4	158
1da177e4	159	/*
08e0e7c8	160	* deliver request data to a CB.CallBack call
1da177e4	161	*/
d001648e	162	static int afs_deliver_cb_callback(struct afs_call *call)
1da177e4	163	{
8324f0bc	164	struct sockaddr_rxrpc srx;
08e0e7c8 DH	165	struct afs_callback *cb;
08e0e7c8 DH	166	struct afs_server *server;
08e0e7c8 DH	167	__be32 *bp;
	168	u32 tmp;
	169	int ret, loop;
	170
d001648e	171	_enter("{%u}", call->unmarshall);
08e0e7c8 DH	172
	173	switch (call->unmarshall) {
	174	case 0:
8324f0bc	175	rxrpc_kernel_get_peer(afs_socket, call->rxcall, &srx);
08e0e7c8 DH	176	call->offset = 0;
	177	call->unmarshall++;
	178
	179	/* extract the FID array and its count in two steps */
	180	case 1:
	181	_debug("extract FID count");
d001648e	182	ret = afs_extract_data(call, &call->tmp, 4, true);
372ee163 DH	183	if (ret < 0)
372ee163 DH	184	return ret;
1da177e4	185
08e0e7c8 DH	186	call->count = ntohl(call->tmp);
	187	_debug("FID count: %u", call->count);
	188	if (call->count > AFSCBMAX)
	189	return -EBADMSG;
	190
	191	call->buffer = kmalloc(call->count * 3 * 4, GFP_KERNEL);
	192	if (!call->buffer)
	193	return -ENOMEM;
	194	call->offset = 0;
	195	call->unmarshall++;
	196
	197	case 2:
	198	_debug("extract FID array");
d001648e DH	199	ret = afs_extract_data(call, call->buffer,
d001648e DH	200	call->count * 3 * 4, true);
372ee163 DH	201	if (ret < 0)
372ee163 DH	202	return ret;
1da177e4	203
08e0e7c8 DH	204	_debug("unmarshall FID array");
	205	call->request = kcalloc(call->count,
	206	sizeof(struct afs_callback),
	207	GFP_KERNEL);
	208	if (!call->request)
	209	return -ENOMEM;
	210
	211	cb = call->request;
	212	bp = call->buffer;
	213	for (loop = call->count; loop > 0; loop--, cb++) {
	214	cb->fid.vid = ntohl(*bp++);
	215	cb->fid.vnode = ntohl(*bp++);
	216	cb->fid.unique = ntohl(*bp++);
	217	cb->type = AFSCM_CB_UNTYPED;
1da177e4 LT	218	}
1da177e4 LT	219
08e0e7c8 DH	220	call->offset = 0;
	221	call->unmarshall++;
	222
	223	/* extract the callback array and its count in two steps */
	224	case 3:
	225	_debug("extract CB count");
d001648e	226	ret = afs_extract_data(call, &call->tmp, 4, true);
372ee163 DH	227	if (ret < 0)
372ee163 DH	228	return ret;
1da177e4	229
08e0e7c8 DH	230	tmp = ntohl(call->tmp);
	231	_debug("CB count: %u", tmp);
	232	if (tmp != call->count && tmp != 0)
	233	return -EBADMSG;
	234	call->offset = 0;
	235	call->unmarshall++;
08e0e7c8 DH	236
	237	case 4:
	238	_debug("extract CB array");
d001648e DH	239	ret = afs_extract_data(call, call->buffer,
d001648e DH	240	call->count * 3 * 4, false);
372ee163 DH	241	if (ret < 0)
372ee163 DH	242	return ret;
1da177e4	243
08e0e7c8 DH	244	_debug("unmarshall CB array");
	245	cb = call->request;
	246	bp = call->buffer;
	247	for (loop = call->count; loop > 0; loop--, cb++) {
	248	cb->version = ntohl(*bp++);
	249	cb->expiry = ntohl(*bp++);
	250	cb->type = ntohl(*bp++);
	251	}
1da177e4	252
08e0e7c8 DH	253	call->offset = 0;
08e0e7c8 DH	254	call->unmarshall++;
1da177e4	255
6c67c7c3 DH	256	/* Record that the message was unmarshalled successfully so
	257	* that the call destructor can know do the callback breaking
	258	* work, even if the final ACK isn't received.
	259	*
	260	* If the step number changes, then afs_cm_destructor() must be
	261	* updated also.
	262	*/
	263	call->unmarshall++;
d001648e	264	case 5:
1da177e4 LT	265	break;
	266	}
	267
08e0e7c8	268	call->state = AFS_CALL_REPLYING;
1da177e4	269
08e0e7c8 DH	270	/* we'll need the file server record as that tells us which set of
08e0e7c8 DH	271	* vnodes to operate upon */
8324f0bc	272	server = afs_find_server(&srx);
08e0e7c8 DH	273	if (!server)
	274	return -ENOTCONN;
	275	call->server = server;
	276
	277	INIT_WORK(&call->work, SRXAFSCB_CallBack);
0ad53eee	278	queue_work(afs_wq, &call->work);
08e0e7c8	279	return 0;
ec26815a	280	}
1da177e4	281
1da177e4	282	/*
08e0e7c8	283	* allow the fileserver to request callback state (re-)initialisation
1da177e4	284	*/
08e0e7c8	285	static void SRXAFSCB_InitCallBackState(struct work_struct *work)
1da177e4	286	{
08e0e7c8	287	struct afs_call *call = container_of(work, struct afs_call, work);
1da177e4	288
08e0e7c8	289	_enter("{%p}", call->server);
1da177e4	290
08e0e7c8 DH	291	afs_init_callback_state(call->server);
	292	afs_send_empty_reply(call);
	293	_leave("");
ec26815a	294	}
1da177e4	295
1da177e4	296	/*
08e0e7c8	297	* deliver request data to a CB.InitCallBackState call
1da177e4	298	*/
d001648e	299	static int afs_deliver_cb_init_call_back_state(struct afs_call *call)
1da177e4	300	{
8324f0bc	301	struct sockaddr_rxrpc srx;
1da177e4	302	struct afs_server *server;
372ee163	303	int ret;
1da177e4	304
d001648e	305	_enter("");
1da177e4	306
8324f0bc DH	307	rxrpc_kernel_get_peer(afs_socket, call->rxcall, &srx);
8324f0bc DH	308
d001648e	309	ret = afs_extract_data(call, NULL, 0, false);
372ee163 DH	310	if (ret < 0)
372ee163 DH	311	return ret;
1da177e4	312
08e0e7c8 DH	313	/* no unmarshalling required */
08e0e7c8 DH	314	call->state = AFS_CALL_REPLYING;
1da177e4	315
08e0e7c8 DH	316	/* we'll need the file server record as that tells us which set of
08e0e7c8 DH	317	* vnodes to operate upon */
8324f0bc	318	server = afs_find_server(&srx);
08e0e7c8 DH	319	if (!server)
	320	return -ENOTCONN;
	321	call->server = server;
1da177e4	322
08e0e7c8	323	INIT_WORK(&call->work, SRXAFSCB_InitCallBackState);
0ad53eee	324	queue_work(afs_wq, &call->work);
08e0e7c8 DH	325	return 0;
08e0e7c8 DH	326	}
1da177e4	327
c35eccb1 DH	328	/*
	329	* deliver request data to a CB.InitCallBackState3 call
	330	*/
d001648e	331	static int afs_deliver_cb_init_call_back_state3(struct afs_call *call)
c35eccb1	332	{
8324f0bc	333	struct sockaddr_rxrpc srx;
c35eccb1	334	struct afs_server *server;
d001648e DH	335	struct afs_uuid *r;
	336	unsigned loop;
	337	__be32 *b;
	338	int ret;
c35eccb1	339
d001648e	340	_enter("");
c35eccb1	341
8324f0bc DH	342	rxrpc_kernel_get_peer(afs_socket, call->rxcall, &srx);
8324f0bc DH	343
d001648e DH	344	_enter("{%u}", call->unmarshall);
	345
	346	switch (call->unmarshall) {
	347	case 0:
	348	call->offset = 0;
	349	call->buffer = kmalloc(11 * sizeof(__be32), GFP_KERNEL);
	350	if (!call->buffer)
	351	return -ENOMEM;
	352	call->unmarshall++;
	353
	354	case 1:
	355	_debug("extract UUID");
	356	ret = afs_extract_data(call, call->buffer,
	357	11 * sizeof(__be32), false);
	358	switch (ret) {
	359	case 0: break;
	360	case -EAGAIN: return 0;
	361	default: return ret;
	362	}
	363
	364	_debug("unmarshall UUID");
	365	call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL);
	366	if (!call->request)
	367	return -ENOMEM;
	368
	369	b = call->buffer;
	370	r = call->request;
	371	r->time_low = ntohl(b[0]);
	372	r->time_mid = ntohl(b[1]);
	373	r->time_hi_and_version = ntohl(b[2]);
	374	r->clock_seq_hi_and_reserved = ntohl(b[3]);
	375	r->clock_seq_low = ntohl(b[4]);
	376
	377	for (loop = 0; loop < 6; loop++)
	378	r->node[loop] = ntohl(b[loop + 5]);
	379
	380	call->offset = 0;
	381	call->unmarshall++;
	382
	383	case 2:
	384	break;
	385	}
c35eccb1 DH	386
	387	/* no unmarshalling required */
	388	call->state = AFS_CALL_REPLYING;
	389
	390	/* we'll need the file server record as that tells us which set of
	391	* vnodes to operate upon */
8324f0bc	392	server = afs_find_server(&srx);
c35eccb1 DH	393	if (!server)
	394	return -ENOTCONN;
	395	call->server = server;
	396
	397	INIT_WORK(&call->work, SRXAFSCB_InitCallBackState);
0ad53eee	398	queue_work(afs_wq, &call->work);
c35eccb1 DH	399	return 0;
	400	}
	401
08e0e7c8 DH	402	/*
	403	* allow the fileserver to see if the cache manager is still alive
	404	*/
	405	static void SRXAFSCB_Probe(struct work_struct *work)
	406	{
	407	struct afs_call *call = container_of(work, struct afs_call, work);
1da177e4	408
08e0e7c8 DH	409	_enter("");
	410	afs_send_empty_reply(call);
	411	_leave("");
	412	}
1da177e4	413
08e0e7c8 DH	414	/*
	415	* deliver request data to a CB.Probe call
	416	*/
d001648e	417	static int afs_deliver_cb_probe(struct afs_call *call)
08e0e7c8	418	{
372ee163 DH	419	int ret;
372ee163 DH	420
d001648e	421	_enter("");
1da177e4	422
d001648e	423	ret = afs_extract_data(call, NULL, 0, false);
372ee163 DH	424	if (ret < 0)
372ee163 DH	425	return ret;
1da177e4	426
08e0e7c8 DH	427	/* no unmarshalling required */
08e0e7c8 DH	428	call->state = AFS_CALL_REPLYING;
1da177e4	429
08e0e7c8	430	INIT_WORK(&call->work, SRXAFSCB_Probe);
0ad53eee	431	queue_work(afs_wq, &call->work);
08e0e7c8	432	return 0;
ec26815a	433	}
b908fe6b	434
9396d496 DH	435	/*
	436	* allow the fileserver to quickly find out if the fileserver has been rebooted
	437	*/
	438	static void SRXAFSCB_ProbeUuid(struct work_struct *work)
	439	{
	440	struct afs_call *call = container_of(work, struct afs_call, work);
	441	struct afs_uuid *r = call->request;
	442
	443	struct {
	444	__be32 match;
	445	} reply;
	446
	447	_enter("");
	448
9396d496 DH	449	if (memcmp(r, &afs_uuid, sizeof(afs_uuid)) == 0)
	450	reply.match = htonl(0);
	451	else
	452	reply.match = htonl(1);
	453
	454	afs_send_simple_reply(call, &reply, sizeof(reply));
	455	_leave("");
	456	}
	457
	458	/*
	459	* deliver request data to a CB.ProbeUuid call
	460	*/
d001648e	461	static int afs_deliver_cb_probe_uuid(struct afs_call *call)
9396d496 DH	462	{
	463	struct afs_uuid *r;
	464	unsigned loop;
	465	__be32 *b;
	466	int ret;
	467
d001648e	468	_enter("{%u}", call->unmarshall);
9396d496 DH	469
	470	switch (call->unmarshall) {
	471	case 0:
	472	call->offset = 0;
	473	call->buffer = kmalloc(11 * sizeof(__be32), GFP_KERNEL);
	474	if (!call->buffer)
	475	return -ENOMEM;
	476	call->unmarshall++;
	477
	478	case 1:
	479	_debug("extract UUID");
d001648e DH	480	ret = afs_extract_data(call, call->buffer,
d001648e DH	481	11 * sizeof(__be32), false);
9396d496 DH	482	switch (ret) {
	483	case 0: break;
	484	case -EAGAIN: return 0;
	485	default: return ret;
	486	}
	487
	488	_debug("unmarshall UUID");
	489	call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL);
	490	if (!call->request)
	491	return -ENOMEM;
	492
	493	b = call->buffer;
	494	r = call->request;
	495	r->time_low = ntohl(b[0]);
	496	r->time_mid = ntohl(b[1]);
	497	r->time_hi_and_version = ntohl(b[2]);
	498	r->clock_seq_hi_and_reserved = ntohl(b[3]);
	499	r->clock_seq_low = ntohl(b[4]);
	500
	501	for (loop = 0; loop < 6; loop++)
	502	r->node[loop] = ntohl(b[loop + 5]);
	503
	504	call->offset = 0;
	505	call->unmarshall++;
	506
	507	case 2:
9396d496 DH	508	break;
	509	}
	510
9396d496 DH	511	call->state = AFS_CALL_REPLYING;
	512
	513	INIT_WORK(&call->work, SRXAFSCB_ProbeUuid);
0ad53eee	514	queue_work(afs_wq, &call->work);
9396d496 DH	515	return 0;
	516	}
	517
b908fe6b DH	518	/*
	519	* allow the fileserver to ask about the cache manager's capabilities
	520	*/
7c80bcce	521	static void SRXAFSCB_TellMeAboutYourself(struct work_struct *work)
b908fe6b DH	522	{
	523	struct afs_interface *ifs;
	524	struct afs_call *call = container_of(work, struct afs_call, work);
	525	int loop, nifs;
	526
	527	struct {
	528	struct /* InterfaceAddr */ {
	529	__be32 nifs;
	530	__be32 uuid[11];
	531	__be32 ifaddr[32];
	532	__be32 netmask[32];
	533	__be32 mtu[32];
	534	} ia;
	535	struct /* Capabilities */ {
	536	__be32 capcount;
	537	__be32 caps[1];
	538	} cap;
	539	} reply;
	540
	541	_enter("");
	542
	543	nifs = 0;
	544	ifs = kcalloc(32, sizeof(*ifs), GFP_KERNEL);
	545	if (ifs) {
	546	nifs = afs_get_ipv4_interfaces(ifs, 32, false);
	547	if (nifs < 0) {
	548	kfree(ifs);
	549	ifs = NULL;
	550	nifs = 0;
	551	}
	552	}
	553
	554	memset(&reply, 0, sizeof(reply));
	555	reply.ia.nifs = htonl(nifs);
	556
	557	reply.ia.uuid[0] = htonl(afs_uuid.time_low);
	558	reply.ia.uuid[1] = htonl(afs_uuid.time_mid);
	559	reply.ia.uuid[2] = htonl(afs_uuid.time_hi_and_version);
	560	reply.ia.uuid[3] = htonl((s8) afs_uuid.clock_seq_hi_and_reserved);
	561	reply.ia.uuid[4] = htonl((s8) afs_uuid.clock_seq_low);
	562	for (loop = 0; loop < 6; loop++)
	563	reply.ia.uuid[loop + 5] = htonl((s8) afs_uuid.node[loop]);
	564
	565	if (ifs) {
	566	for (loop = 0; loop < nifs; loop++) {
	567	reply.ia.ifaddr[loop] = ifs[loop].address.s_addr;
	568	reply.ia.netmask[loop] = ifs[loop].netmask.s_addr;
	569	reply.ia.mtu[loop] = htonl(ifs[loop].mtu);
	570	}
5b35fad9	571	kfree(ifs);
b908fe6b DH	572	}
	573
	574	reply.cap.capcount = htonl(1);
	575	reply.cap.caps[0] = htonl(AFS_CAP_ERROR_TRANSLATION);
	576	afs_send_simple_reply(call, &reply, sizeof(reply));
	577
	578	_leave("");
	579	}
	580
	581	/*
7c80bcce	582	* deliver request data to a CB.TellMeAboutYourself call
b908fe6b	583	*/
d001648e	584	static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *call)
b908fe6b	585	{
372ee163 DH	586	int ret;
372ee163 DH	587
d001648e	588	_enter("");
b908fe6b	589
d001648e	590	ret = afs_extract_data(call, NULL, 0, false);
372ee163 DH	591	if (ret < 0)
372ee163 DH	592	return ret;
b908fe6b DH	593
	594	/* no unmarshalling required */
	595	call->state = AFS_CALL_REPLYING;
	596
7c80bcce	597	INIT_WORK(&call->work, SRXAFSCB_TellMeAboutYourself);
0ad53eee	598	queue_work(afs_wq, &call->work);
b908fe6b DH	599	return 0;
b908fe6b DH	600	}