[linux.git] / fs / lockd / mon.c

/*
 * linux/fs/lockd/mon.c
 *
 * The kernel statd client.
 *
 * Copyright (C) 1996, Olaf Kirch <[email protected]>
 */

#include <linux/types.h>
#include <linux/utsname.h>
#include <linux/kernel.h>
#include <linux/sunrpc/clnt.h>
#include <linux/sunrpc/xprtsock.h>
#include <linux/sunrpc/svc.h>
#include <linux/lockd/lockd.h>
#include <linux/lockd/sm_inter.h>


#define NLMDBG_FACILITY		NLMDBG_MONITOR

#define XDR_ADDRBUF_LEN		(20)

static struct rpc_clnt *	nsm_create(void);

static struct rpc_program	nsm_program;

/*
 * Local NSM state
 */
int				nsm_local_state;

/*
 * Common procedure for SM_MON/SM_UNMON calls
 */
static int
nsm_mon_unmon(struct nsm_handle *nsm, u32 proc, struct nsm_res *res)
{
	struct rpc_clnt	*clnt;
	int		status;
	struct nsm_args	args;
	struct rpc_message msg = {
		.rpc_argp	= &args,
		.rpc_resp	= res,
	};

	clnt = nsm_create();
	if (IS_ERR(clnt)) {
		status = PTR_ERR(clnt);
		goto out;
	}

	memset(&args, 0, sizeof(args));
	args.mon_name = nsm->sm_name;
	args.addr = nsm->sm_addr.sin_addr.s_addr;
	args.prog = NLM_PROGRAM;
	args.vers = 3;
	args.proc = NLMPROC_NSM_NOTIFY;
	memset(res, 0, sizeof(*res));

	msg.rpc_proc = &clnt->cl_procinfo[proc];
	status = rpc_call_sync(clnt, &msg, 0);
	if (status < 0)
		printk(KERN_DEBUG "nsm_mon_unmon: rpc failed, status=%d\n",
			status);
	else
		status = 0;
	rpc_shutdown_client(clnt);
 out:
	return status;
}

/*
 * Set up monitoring of a remote host
 */
int
nsm_monitor(struct nlm_host *host)
{
	struct nsm_handle *nsm = host->h_nsmhandle;
	struct nsm_res	res;
	int		status;

	dprintk("lockd: nsm_monitor(%s)\n", host->h_name);
	BUG_ON(nsm == NULL);

	if (nsm->sm_monitored)
		return 0;

	status = nsm_mon_unmon(nsm, SM_MON, &res);

	if (status < 0 || res.status != 0)
		printk(KERN_NOTICE "lockd: cannot monitor %s\n", host->h_name);
	else
		nsm->sm_monitored = 1;
	return status;
}

/*
 * Cease to monitor remote host
 */
int
nsm_unmonitor(struct nlm_host *host)
{
	struct nsm_handle *nsm = host->h_nsmhandle;
	struct nsm_res	res;
	int		status = 0;

	if (nsm == NULL)
		return 0;
	host->h_nsmhandle = NULL;

	if (atomic_read(&nsm->sm_count) == 1
	 && nsm->sm_monitored && !nsm->sm_sticky) {
		dprintk("lockd: nsm_unmonitor(%s)\n", host->h_name);

		status = nsm_mon_unmon(nsm, SM_UNMON, &res);
		if (status < 0)
			printk(KERN_NOTICE "lockd: cannot unmonitor %s\n",
					host->h_name);
		else
			nsm->sm_monitored = 0;
	}
	nsm_release(nsm);
	return status;
}

/*
 * Create NSM client for the local host
 */
static struct rpc_clnt *
nsm_create(void)
{
	struct sockaddr_in	sin = {
		.sin_family	= AF_INET,
		.sin_addr.s_addr = htonl(INADDR_LOOPBACK),
		.sin_port	= 0,
	};
	struct rpc_create_args args = {
		.protocol	= XPRT_TRANSPORT_UDP,
		.address	= (struct sockaddr *)&sin,
		.addrsize	= sizeof(sin),
		.servername	= "localhost",
		.program	= &nsm_program,
		.version	= SM_VERSION,
		.authflavor	= RPC_AUTH_NULL,
	};

	return rpc_create(&args);
}

/*
 * XDR functions for NSM.
 */

static __be32 *xdr_encode_nsm_string(__be32 *p, char *string)
{
	size_t len = strlen(string);

	if (len > SM_MAXSTRLEN)
		len = SM_MAXSTRLEN;
	return xdr_encode_opaque(p, string, len);
}

/*
 * "mon_name" specifies the host to be monitored.
 *
 * Linux uses a text version of the IP address of the remote
 * host as the host identifier (the "mon_name" argument).
 *
 * Linux statd always looks up the canonical hostname first for
 * whatever remote hostname it receives, so this works alright.
 */
static __be32 *xdr_encode_mon_name(__be32 *p, struct nsm_args *argp)
{
	char	buffer[XDR_ADDRBUF_LEN + 1];
	char	*name = argp->mon_name;

	if (!nsm_use_hostnames) {
		snprintf(buffer, XDR_ADDRBUF_LEN,
			 NIPQUAD_FMT, NIPQUAD(argp->addr));
		name = buffer;
	}

	return xdr_encode_nsm_string(p, name);
}

/*
 * The "my_id" argument specifies the hostname and RPC procedure
 * to be called when the status manager receives notification
 * (via the SM_NOTIFY call) that the state of host "mon_name"
 * has changed.
 */
static __be32 *xdr_encode_my_id(__be32 *p, struct nsm_args *argp)
{
	p = xdr_encode_nsm_string(p, utsname()->nodename);
	if (!p)
		return ERR_PTR(-EIO);

	*p++ = htonl(argp->prog);
	*p++ = htonl(argp->vers);
	*p++ = htonl(argp->proc);

	return p;
}

static __be32 *
xdr_encode_common(struct rpc_rqst *rqstp, __be32 *p, struct nsm_args *argp)
{
	char	buffer[20], *name;

	/*
	 * Use the dotted-quad IP address of the remote host as
	 * identifier. Linux statd always looks up the canonical
	 * hostname first for whatever remote hostname it receives,
	 * so this works alright.
	 */
	if (nsm_use_hostnames) {
		name = argp->mon_name;
	} else {
		sprintf(buffer, "%u.%u.%u.%u", NIPQUAD(argp->addr));
		name = buffer;
	}
	if (!(p = xdr_encode_string(p, name))
	 || !(p = xdr_encode_string(p, utsname()->nodename)))
		return ERR_PTR(-EIO);
	*p++ = htonl(argp->prog);
	*p++ = htonl(argp->vers);
	*p++ = htonl(argp->proc);

	return p;
}

static int
xdr_encode_mon(struct rpc_rqst *rqstp, __be32 *p, struct nsm_args *argp)
{
	p = xdr_encode_common(rqstp, p, argp);
	if (IS_ERR(p))
		return PTR_ERR(p);

	/* Surprise - there may even be room for an IPv6 address now */
	*p++ = argp->addr;
	*p++ = 0;
	*p++ = 0;
	*p++ = 0;
	rqstp->rq_slen = xdr_adjust_iovec(rqstp->rq_svec, p);
	return 0;
}

static int
xdr_encode_unmon(struct rpc_rqst *rqstp, __be32 *p, struct nsm_args *argp)
{
	p = xdr_encode_common(rqstp, p, argp);
	if (IS_ERR(p))
		return PTR_ERR(p);
	rqstp->rq_slen = xdr_adjust_iovec(rqstp->rq_svec, p);
	return 0;
}

static int
xdr_decode_stat_res(struct rpc_rqst *rqstp, __be32 *p, struct nsm_res *resp)
{
	resp->status = ntohl(*p++);
	resp->state = ntohl(*p++);
	dprintk("nsm: xdr_decode_stat_res status %d state %d\n",
			resp->status, resp->state);
	return 0;
}

static int
xdr_decode_stat(struct rpc_rqst *rqstp, __be32 *p, struct nsm_res *resp)
{
	resp->state = ntohl(*p++);
	return 0;
}

#define SM_my_name_sz	(1+XDR_QUADLEN(SM_MAXSTRLEN))
#define SM_my_id_sz	(3+1+SM_my_name_sz)
#define SM_mon_id_sz	(1+XDR_QUADLEN(20)+SM_my_id_sz)
#define SM_mon_sz	(SM_mon_id_sz+4)
#define SM_monres_sz	2
#define SM_unmonres_sz	1

static struct rpc_procinfo	nsm_procedures[] = {
[SM_MON] = {
		.p_proc		= SM_MON,
		.p_encode	= (kxdrproc_t) xdr_encode_mon,
		.p_decode	= (kxdrproc_t) xdr_decode_stat_res,
		.p_arglen	= SM_mon_sz,
		.p_replen	= SM_monres_sz,
		.p_statidx	= SM_MON,
		.p_name		= "MONITOR",
	},
[SM_UNMON] = {
		.p_proc		= SM_UNMON,
		.p_encode	= (kxdrproc_t) xdr_encode_unmon,
		.p_decode	= (kxdrproc_t) xdr_decode_stat,
		.p_arglen	= SM_mon_id_sz,
		.p_replen	= SM_unmonres_sz,
		.p_statidx	= SM_UNMON,
		.p_name		= "UNMONITOR",
	},
};

static struct rpc_version	nsm_version1 = {
		.number		= 1,
		.nrprocs	= ARRAY_SIZE(nsm_procedures),
		.procs		= nsm_procedures
};

static struct rpc_version *	nsm_version[] = {
	[1] = &nsm_version1,
};

static struct rpc_stat		nsm_stats;

static struct rpc_program	nsm_program = {
		.name		= "statd",
		.number		= SM_PROGRAM,
		.nrvers		= ARRAY_SIZE(nsm_version),
		.version	= nsm_version,
		.stats		= &nsm_stats
};
Commit	Line	Data
1da177e4 LT	1	/*
	2	* linux/fs/lockd/mon.c
	3	*
	4	* The kernel statd client.
	5	*
	6	* Copyright (C) 1996, Olaf Kirch <[email protected]>
	7	*/
	8
	9	#include <linux/types.h>
	10	#include <linux/utsname.h>
	11	#include <linux/kernel.h>
	12	#include <linux/sunrpc/clnt.h>
0896a725	13	#include <linux/sunrpc/xprtsock.h>
1da177e4 LT	14	#include <linux/sunrpc/svc.h>
	15	#include <linux/lockd/lockd.h>
	16	#include <linux/lockd/sm_inter.h>
	17
	18
	19	#define NLMDBG_FACILITY NLMDBG_MONITOR
	20
49695174 CL	21	#define XDR_ADDRBUF_LEN (20)
49695174 CL	22
1da177e4 LT	23	static struct rpc_clnt * nsm_create(void);
	24
	25	static struct rpc_program nsm_program;
	26
	27	/*
	28	* Local NSM state
	29	*/
460f5cac	30	int nsm_local_state;
1da177e4 LT	31
	32	/*
	33	* Common procedure for SM_MON/SM_UNMON calls
	34	*/
	35	static int
9502c522	36	nsm_mon_unmon(struct nsm_handle nsm, u32 proc, struct nsm_res res)
1da177e4 LT	37	{
	38	struct rpc_clnt *clnt;
	39	int status;
	40	struct nsm_args args;
dead28da CL	41	struct rpc_message msg = {
	42	.rpc_argp = &args,
	43	.rpc_resp = res,
	44	};
1da177e4 LT	45
	46	clnt = nsm_create();
	47	if (IS_ERR(clnt)) {
	48	status = PTR_ERR(clnt);
	49	goto out;
	50	}
	51
9502c522	52	memset(&args, 0, sizeof(args));
abd1f500	53	args.mon_name = nsm->sm_name;
9502c522	54	args.addr = nsm->sm_addr.sin_addr.s_addr;
1da177e4	55	args.prog = NLM_PROGRAM;
9502c522	56	args.vers = 3;
1da177e4 LT	57	args.proc = NLMPROC_NSM_NOTIFY;
	58	memset(res, 0, sizeof(*res));
	59
dead28da CL	60	msg.rpc_proc = &clnt->cl_procinfo[proc];
dead28da CL	61	status = rpc_call_sync(clnt, &msg, 0);
1da177e4 LT	62	if (status < 0)
	63	printk(KERN_DEBUG "nsm_mon_unmon: rpc failed, status=%d\n",
	64	status);
	65	else
	66	status = 0;
90c5755f	67	rpc_shutdown_client(clnt);
1da177e4 LT	68	out:
	69	return status;
	70	}
	71
	72	/*
	73	* Set up monitoring of a remote host
	74	*/
	75	int
	76	nsm_monitor(struct nlm_host *host)
	77	{
8dead0db	78	struct nsm_handle *nsm = host->h_nsmhandle;
1da177e4 LT	79	struct nsm_res res;
	80	int status;
	81
	82	dprintk("lockd: nsm_monitor(%s)\n", host->h_name);
8dead0db OK	83	BUG_ON(nsm == NULL);
	84
	85	if (nsm->sm_monitored)
977faf39	86	return 0;
1da177e4	87
9502c522	88	status = nsm_mon_unmon(nsm, SM_MON, &res);
1da177e4 LT	89
	90	if (status < 0 \|\| res.status != 0)
	91	printk(KERN_NOTICE "lockd: cannot monitor %s\n", host->h_name);
	92	else
8dead0db	93	nsm->sm_monitored = 1;
1da177e4 LT	94	return status;
	95	}
	96
	97	/*
	98	* Cease to monitor remote host
	99	*/
	100	int
	101	nsm_unmonitor(struct nlm_host *host)
	102	{
8dead0db	103	struct nsm_handle *nsm = host->h_nsmhandle;
1da177e4	104	struct nsm_res res;
977faf39	105	int status = 0;
1da177e4	106
8dead0db	107	if (nsm == NULL)
977faf39	108	return 0;
8dead0db	109	host->h_nsmhandle = NULL;
977faf39	110
9502c522 OK	111	if (atomic_read(&nsm->sm_count) == 1
	112	&& nsm->sm_monitored && !nsm->sm_sticky) {
	113	dprintk("lockd: nsm_unmonitor(%s)\n", host->h_name);
	114
	115	status = nsm_mon_unmon(nsm, SM_UNMON, &res);
977faf39	116	if (status < 0)
9502c522 OK	117	printk(KERN_NOTICE "lockd: cannot unmonitor %s\n",
	118	host->h_name);
	119	else
	120	nsm->sm_monitored = 0;
977faf39	121	}
8dead0db	122	nsm_release(nsm);
1da177e4 LT	123	return status;
	124	}
	125
	126	/*
	127	* Create NSM client for the local host
	128	*/
	129	static struct rpc_clnt *
	130	nsm_create(void)
	131	{
e1ec7892 CL	132	struct sockaddr_in sin = {
	133	.sin_family = AF_INET,
	134	.sin_addr.s_addr = htonl(INADDR_LOOPBACK),
	135	.sin_port = 0,
	136	};
	137	struct rpc_create_args args = {
0896a725	138	.protocol = XPRT_TRANSPORT_UDP,
e1ec7892 CL	139	.address = (struct sockaddr *)&sin,
	140	.addrsize = sizeof(sin),
	141	.servername = "localhost",
	142	.program = &nsm_program,
	143	.version = SM_VERSION,
	144	.authflavor = RPC_AUTH_NULL,
e1ec7892 CL	145	};
	146
	147	return rpc_create(&args);
1da177e4 LT	148	}
	149
	150	/*
	151	* XDR functions for NSM.
	152	*/
	153
099bd05f CL	154	static __be32 xdr_encode_nsm_string(__be32 p, char *string)
	155	{
	156	size_t len = strlen(string);
	157
	158	if (len > SM_MAXSTRLEN)
	159	len = SM_MAXSTRLEN;
	160	return xdr_encode_opaque(p, string, len);
	161	}
	162
49695174 CL	163	/*
	164	* "mon_name" specifies the host to be monitored.
	165	*
	166	* Linux uses a text version of the IP address of the remote
	167	* host as the host identifier (the "mon_name" argument).
	168	*
	169	* Linux statd always looks up the canonical hostname first for
	170	* whatever remote hostname it receives, so this works alright.
	171	*/
	172	static __be32 xdr_encode_mon_name(__be32 p, struct nsm_args *argp)
	173	{
	174	char buffer[XDR_ADDRBUF_LEN + 1];
	175	char *name = argp->mon_name;
	176
	177	if (!nsm_use_hostnames) {
	178	snprintf(buffer, XDR_ADDRBUF_LEN,
	179	NIPQUAD_FMT, NIPQUAD(argp->addr));
	180	name = buffer;
	181	}
	182
	183	return xdr_encode_nsm_string(p, name);
	184	}
	185
850c95fd CL	186	/*
	187	* The "my_id" argument specifies the hostname and RPC procedure
	188	* to be called when the status manager receives notification
	189	* (via the SM_NOTIFY call) that the state of host "mon_name"
	190	* has changed.
	191	*/
	192	static __be32 xdr_encode_my_id(__be32 p, struct nsm_args *argp)
	193	{
	194	p = xdr_encode_nsm_string(p, utsname()->nodename);
	195	if (!p)
	196	return ERR_PTR(-EIO);
	197
	198	*p++ = htonl(argp->prog);
	199	*p++ = htonl(argp->vers);
	200	*p++ = htonl(argp->proc);
	201
	202	return p;
	203	}
	204
52921e02 AV	205	static __be32 *
52921e02 AV	206	xdr_encode_common(struct rpc_rqst rqstp, __be32 p, struct nsm_args *argp)
1da177e4	207	{
abd1f500	208	char buffer[20], *name;
1da177e4 LT	209
	210	/*
	211	* Use the dotted-quad IP address of the remote host as
	212	* identifier. Linux statd always looks up the canonical
	213	* hostname first for whatever remote hostname it receives,
	214	* so this works alright.
	215	*/
abd1f500 OK	216	if (nsm_use_hostnames) {
	217	name = argp->mon_name;
	218	} else {
	219	sprintf(buffer, "%u.%u.%u.%u", NIPQUAD(argp->addr));
	220	name = buffer;
	221	}
	222	if (!(p = xdr_encode_string(p, name))
e9ff3990	223	\|\| !(p = xdr_encode_string(p, utsname()->nodename)))
1da177e4 LT	224	return ERR_PTR(-EIO);
	225	*p++ = htonl(argp->prog);
	226	*p++ = htonl(argp->vers);
	227	*p++ = htonl(argp->proc);
	228
	229	return p;
	230	}
	231
	232	static int
52921e02	233	xdr_encode_mon(struct rpc_rqst rqstp, __be32 p, struct nsm_args *argp)
1da177e4 LT	234	{
	235	p = xdr_encode_common(rqstp, p, argp);
	236	if (IS_ERR(p))
	237	return PTR_ERR(p);
9502c522 OK	238
9502c522 OK	239	/* Surprise - there may even be room for an IPv6 address now */
1da177e4	240	*p++ = argp->addr;
9502c522 OK	241	*p++ = 0;
9502c522 OK	242	*p++ = 0;
1da177e4 LT	243	*p++ = 0;
	244	rqstp->rq_slen = xdr_adjust_iovec(rqstp->rq_svec, p);
	245	return 0;
	246	}
	247
	248	static int
52921e02	249	xdr_encode_unmon(struct rpc_rqst rqstp, __be32 p, struct nsm_args *argp)
1da177e4 LT	250	{
	251	p = xdr_encode_common(rqstp, p, argp);
	252	if (IS_ERR(p))
	253	return PTR_ERR(p);
	254	rqstp->rq_slen = xdr_adjust_iovec(rqstp->rq_svec, p);
	255	return 0;
	256	}
	257
	258	static int
52921e02	259	xdr_decode_stat_res(struct rpc_rqst rqstp, __be32 p, struct nsm_res *resp)
1da177e4 LT	260	{
	261	resp->status = ntohl(*p++);
	262	resp->state = ntohl(*p++);
	263	dprintk("nsm: xdr_decode_stat_res status %d state %d\n",
	264	resp->status, resp->state);
	265	return 0;
	266	}
	267
	268	static int
52921e02	269	xdr_decode_stat(struct rpc_rqst rqstp, __be32 p, struct nsm_res *resp)
1da177e4 LT	270	{
	271	resp->state = ntohl(*p++);
	272	return 0;
	273	}
	274
	275	#define SM_my_name_sz (1+XDR_QUADLEN(SM_MAXSTRLEN))
	276	#define SM_my_id_sz (3+1+SM_my_name_sz)
	277	#define SM_mon_id_sz (1+XDR_QUADLEN(20)+SM_my_id_sz)
	278	#define SM_mon_sz (SM_mon_id_sz+4)
	279	#define SM_monres_sz 2
	280	#define SM_unmonres_sz 1
	281
1da177e4 LT	282	static struct rpc_procinfo nsm_procedures[] = {
	283	[SM_MON] = {
	284	.p_proc = SM_MON,
	285	.p_encode = (kxdrproc_t) xdr_encode_mon,
	286	.p_decode = (kxdrproc_t) xdr_decode_stat_res,
2bea90d4 CL	287	.p_arglen = SM_mon_sz,
2bea90d4 CL	288	.p_replen = SM_monres_sz,
cc0175c1 CL	289	.p_statidx = SM_MON,
cc0175c1 CL	290	.p_name = "MONITOR",
1da177e4 LT	291	},
	292	[SM_UNMON] = {
	293	.p_proc = SM_UNMON,
	294	.p_encode = (kxdrproc_t) xdr_encode_unmon,
	295	.p_decode = (kxdrproc_t) xdr_decode_stat,
2bea90d4 CL	296	.p_arglen = SM_mon_id_sz,
2bea90d4 CL	297	.p_replen = SM_unmonres_sz,
cc0175c1 CL	298	.p_statidx = SM_UNMON,
cc0175c1 CL	299	.p_name = "UNMONITOR",
1da177e4 LT	300	},
	301	};
	302
	303	static struct rpc_version nsm_version1 = {
e8c96f8c TK	304	.number = 1,
e8c96f8c TK	305	.nrprocs = ARRAY_SIZE(nsm_procedures),
1da177e4 LT	306	.procs = nsm_procedures
	307	};
	308
	309	static struct rpc_version * nsm_version[] = {
	310	[1] = &nsm_version1,
	311	};
	312
	313	static struct rpc_stat nsm_stats;
	314
	315	static struct rpc_program nsm_program = {
	316	.name = "statd",
	317	.number = SM_PROGRAM,
e8c96f8c	318	.nrvers = ARRAY_SIZE(nsm_version),
1da177e4 LT	319	.version = nsm_version,
	320	.stats = &nsm_stats
	321	};