svc.c 18.7 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
/*
 * linux/fs/lockd/svc.c
 *
 * This is the central lockd service.
 *
 * FIXME: Separate the lockd NFS server functionality from the lockd NFS
 * 	  client functionality. Oh why didn't Sun create two separate
 *	  services in the first place?
 *
 * Authors:	Olaf Kirch (okir@monad.swb.de)
 *
 * Copyright (C) 1995, 1996 Olaf Kirch <okir@monad.swb.de>
 */

#include <linux/module.h>
#include <linux/init.h>
#include <linux/sysctl.h>
#include <linux/moduleparam.h>

20
#include <linux/sched/signal.h>
L
Linus Torvalds 已提交
21 22 23 24
#include <linux/errno.h>
#include <linux/in.h>
#include <linux/uio.h>
#include <linux/smp.h>
I
Ingo Molnar 已提交
25
#include <linux/mutex.h>
J
Jeff Layton 已提交
26
#include <linux/kthread.h>
27
#include <linux/freezer.h>
28
#include <linux/inetdevice.h>
L
Linus Torvalds 已提交
29 30 31 32 33 34

#include <linux/sunrpc/types.h>
#include <linux/sunrpc/stats.h>
#include <linux/sunrpc/clnt.h>
#include <linux/sunrpc/svc.h>
#include <linux/sunrpc/svcsock.h>
35
#include <linux/sunrpc/svc_xprt.h>
36
#include <net/ip.h>
37 38
#include <net/addrconf.h>
#include <net/ipv6.h>
L
Linus Torvalds 已提交
39 40 41
#include <linux/lockd/lockd.h>
#include <linux/nfs.h>

42
#include "netns.h"
43
#include "procfs.h"
44

L
Linus Torvalds 已提交
45 46 47 48 49 50
#define NLMDBG_FACILITY		NLMDBG_SVC
#define LOCKD_BUFSIZE		(1024 + NLMSVC_XDRSIZE)
#define ALLOWED_SIGS		(sigmask(SIGKILL))

static struct svc_program	nlmsvc_program;

51
const struct nlmsvc_binding	*nlmsvc_ops;
52
EXPORT_SYMBOL_GPL(nlmsvc_ops);
L
Linus Torvalds 已提交
53

I
Ingo Molnar 已提交
54
static DEFINE_MUTEX(nlmsvc_mutex);
L
Linus Torvalds 已提交
55
static unsigned int		nlmsvc_users;
J
Jeff Layton 已提交
56
static struct task_struct	*nlmsvc_task;
57
static struct svc_rqst		*nlmsvc_rqst;
L
Linus Torvalds 已提交
58 59
unsigned long			nlmsvc_timeout;

60
unsigned int lockd_net_id;
61

L
Linus Torvalds 已提交
62 63 64 65 66 67 68 69
/*
 * These can be set at insmod time (useful for NFS as root filesystem),
 * and also changed through the sysctl interface.  -- Jamie Lokier, Aug 2003
 */
static unsigned long		nlm_grace_period;
static unsigned long		nlm_timeout = LOCKD_DFLT_TIMEO;
static int			nlm_udpport, nlm_tcpport;

70 71 72
/* RLIM_NOFILE defaults to 1024. That seems like a reasonable default here. */
static unsigned int		nlm_max_connections = 1024;

L
Linus Torvalds 已提交
73 74 75 76 77 78 79 80 81
/*
 * Constants needed for the sysctl interface.
 */
static const unsigned long	nlm_grace_period_min = 0;
static const unsigned long	nlm_grace_period_max = 240;
static const unsigned long	nlm_timeout_min = 3;
static const unsigned long	nlm_timeout_max = 20;
static const int		nlm_port_min = 0, nlm_port_max = 65535;

82
#ifdef CONFIG_SYSCTL
L
Linus Torvalds 已提交
83
static struct ctl_table_header * nlm_sysctl_table;
84
#endif
L
Linus Torvalds 已提交
85

86
static unsigned long get_lockd_grace_period(void)
L
Linus Torvalds 已提交
87 88 89
{
	/* Note: nlm_timeout should always be nonzero */
	if (nlm_grace_period)
90
		return roundup(nlm_grace_period, nlm_timeout) * HZ;
L
Linus Torvalds 已提交
91
	else
92 93 94
		return nlm_timeout * 5 * HZ;
}

95
static void grace_ender(struct work_struct *grace)
96
{
G
Geliang Tang 已提交
97
	struct delayed_work *dwork = to_delayed_work(grace);
98 99 100 101
	struct lockd_net *ln = container_of(dwork, struct lockd_net,
					    grace_period_end);

	locks_end_grace(&ln->lockd_manager);
L
Linus Torvalds 已提交
102 103
}

104
static void set_grace_period(struct net *net)
L
Linus Torvalds 已提交
105
{
106
	unsigned long grace_period = get_lockd_grace_period();
107
	struct lockd_net *ln = net_generic(net, lockd_net_id);
108

109
	locks_start_grace(net, &ln->lockd_manager);
110 111
	cancel_delayed_work_sync(&ln->grace_period_end);
	schedule_delayed_work(&ln->grace_period_end, grace_period);
L
Linus Torvalds 已提交
112 113
}

114 115 116
static void restart_grace(void)
{
	if (nlmsvc_ops) {
117 118
		struct net *net = &init_net;
		struct lockd_net *ln = net_generic(net, lockd_net_id);
119 120

		cancel_delayed_work_sync(&ln->grace_period_end);
121
		locks_end_grace(&ln->lockd_manager);
122
		nlmsvc_invalidate_all();
123
		set_grace_period(net);
124 125 126
	}
}

L
Linus Torvalds 已提交
127 128 129
/*
 * This is the lockd kernel thread
 */
J
Jeff Layton 已提交
130 131
static int
lockd(void *vrqstp)
L
Linus Torvalds 已提交
132
{
133
	int		err = 0;
J
Jeff Layton 已提交
134
	struct svc_rqst *rqstp = vrqstp;
J
J. Bruce Fields 已提交
135 136
	struct net *net = &init_net;
	struct lockd_net *ln = net_generic(net, lockd_net_id);
L
Linus Torvalds 已提交
137

J
Jeff Layton 已提交
138
	/* try_to_freeze() is called from svc_recv() */
139
	set_freezable();
L
Linus Torvalds 已提交
140

J
Jeff Layton 已提交
141
	/* Allow SIGKILL to tell lockd to drop all of its locks */
L
Linus Torvalds 已提交
142 143 144 145 146 147
	allow_signal(SIGKILL);

	dprintk("NFS locking service started (ver " LOCKD_VERSION ").\n");

	/*
	 * The main request loop. We don't terminate until the last
J
Jeff Layton 已提交
148
	 * NFS mount or NFS daemon has gone away.
L
Linus Torvalds 已提交
149
	 */
J
Jeff Layton 已提交
150
	while (!kthread_should_stop()) {
L
Linus Torvalds 已提交
151
		long timeout = MAX_SCHEDULE_TIMEOUT;
152
		RPC_IFDEBUG(char buf[RPC_MAX_ADDRBUFLEN]);
L
Linus Torvalds 已提交
153

154 155 156
		/* update sv_maxconn if it has changed */
		rqstp->rq_server->sv_maxconn = nlm_max_connections;

L
Linus Torvalds 已提交
157 158
		if (signalled()) {
			flush_signals(current);
159
			restart_grace();
J
Jeff Layton 已提交
160
			continue;
L
Linus Torvalds 已提交
161 162
		}

163 164
		timeout = nlmsvc_retry_blocked();

L
Linus Torvalds 已提交
165 166 167 168
		/*
		 * Find a socket with data available and call its
		 * recvfrom routine.
		 */
169
		err = svc_recv(rqstp, timeout);
170
		if (err == -EAGAIN || err == -EINTR)
L
Linus Torvalds 已提交
171
			continue;
172 173
		dprintk("lockd: request from %s\n",
				svc_print_addr(rqstp, buf, sizeof(buf)));
L
Linus Torvalds 已提交
174

175
		svc_process(rqstp);
L
Linus Torvalds 已提交
176
	}
177
	flush_signals(current);
J
Jeff Layton 已提交
178 179 180
	if (nlmsvc_ops)
		nlmsvc_invalidate_all();
	nlm_shutdown_hosts();
J
J. Bruce Fields 已提交
181 182
	cancel_delayed_work_sync(&ln->grace_period_end);
	locks_end_grace(&ln->lockd_manager);
J
Jeff Layton 已提交
183
	return 0;
L
Linus Torvalds 已提交
184 185
}

186
static int create_lockd_listener(struct svc_serv *serv, const char *name,
187 188
				 struct net *net, const int family,
				 const unsigned short port)
189 190 191
{
	struct svc_xprt *xprt;

192
	xprt = svc_find_xprt(serv, name, net, family, 0);
193
	if (xprt == NULL)
194
		return svc_create_xprt(serv, name, net, family, port,
195
						SVC_SOCK_DEFAULTS);
196 197 198 199
	svc_xprt_put(xprt);
	return 0;
}

200 201
static int create_lockd_family(struct svc_serv *serv, struct net *net,
			       const int family)
202 203 204
{
	int err;

205
	err = create_lockd_listener(serv, "udp", net, family, nlm_udpport);
206 207 208
	if (err < 0)
		return err;

209
	return create_lockd_listener(serv, "tcp", net, family, nlm_tcpport);
210 211
}

212
/*
213 214 215 216 217 218 219 220
 * Ensure there are active UDP and TCP listeners for lockd.
 *
 * Even if we have only TCP NFS mounts and/or TCP NFSDs, some
 * local services (such as rpc.statd) still require UDP, and
 * some NFS servers do not yet support NLM over TCP.
 *
 * Returns zero if all listeners are available; otherwise a
 * negative errno value is returned.
221
 */
222
static int make_socks(struct svc_serv *serv, struct net *net)
223
{
224
	static int warned;
225
	int err;
226

227
	err = create_lockd_family(serv, net, PF_INET);
228 229 230
	if (err < 0)
		goto out_err;

231
	err = create_lockd_family(serv, net, PF_INET6);
232
	if (err < 0 && err != -EAFNOSUPPORT)
233 234 235 236 237 238 239
		goto out_err;

	warned = 0;
	return 0;

out_err:
	if (warned++ == 0)
240
		printk(KERN_WARNING
241
			"lockd_up: makesock failed, error=%d\n", err);
242
	svc_shutdown_net(serv, net);
243 244 245
	return err;
}

246
static int lockd_up_net(struct svc_serv *serv, struct net *net)
247 248 249 250
{
	struct lockd_net *ln = net_generic(net, lockd_net_id);
	int error;

251
	if (ln->nlmsvc_users++)
252 253
		return 0;

254
	error = svc_bind(serv, net);
255
	if (error)
256
		goto err_bind;
257 258 259

	error = make_socks(serv, net);
	if (error < 0)
260
		goto err_bind;
261
	set_grace_period(net);
262
	dprintk("%s: per-net data created; net=%x\n", __func__, net->ns.inum);
263 264
	return 0;

265
err_bind:
266
	ln->nlmsvc_users--;
267 268 269
	return error;
}

270
static void lockd_down_net(struct svc_serv *serv, struct net *net)
271 272 273 274
{
	struct lockd_net *ln = net_generic(net, lockd_net_id);

	if (ln->nlmsvc_users) {
275 276
		if (--ln->nlmsvc_users == 0) {
			nlm_shutdown_hosts_net(net);
277 278
			cancel_delayed_work_sync(&ln->grace_period_end);
			locks_end_grace(&ln->lockd_manager);
279
			svc_shutdown_net(serv, net);
280 281
			dprintk("%s: per-net data destroyed; net=%x\n",
				__func__, net->ns.inum);
282
		}
283
	} else {
284 285
		pr_err("%s: no users! task=%p, net=%x\n",
			__func__, nlmsvc_task, net->ns.inum);
286 287 288 289
		BUG();
	}
}

290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329
static int lockd_inetaddr_event(struct notifier_block *this,
	unsigned long event, void *ptr)
{
	struct in_ifaddr *ifa = (struct in_ifaddr *)ptr;
	struct sockaddr_in sin;

	if (event != NETDEV_DOWN)
		goto out;

	if (nlmsvc_rqst) {
		dprintk("lockd_inetaddr_event: removed %pI4\n",
			&ifa->ifa_local);
		sin.sin_family = AF_INET;
		sin.sin_addr.s_addr = ifa->ifa_local;
		svc_age_temp_xprts_now(nlmsvc_rqst->rq_server,
			(struct sockaddr *)&sin);
	}

out:
	return NOTIFY_DONE;
}

static struct notifier_block lockd_inetaddr_notifier = {
	.notifier_call = lockd_inetaddr_event,
};

#if IS_ENABLED(CONFIG_IPV6)
static int lockd_inet6addr_event(struct notifier_block *this,
	unsigned long event, void *ptr)
{
	struct inet6_ifaddr *ifa = (struct inet6_ifaddr *)ptr;
	struct sockaddr_in6 sin6;

	if (event != NETDEV_DOWN)
		goto out;

	if (nlmsvc_rqst) {
		dprintk("lockd_inet6addr_event: removed %pI6\n", &ifa->addr);
		sin6.sin6_family = AF_INET6;
		sin6.sin6_addr = ifa->addr;
330 331
		if (ipv6_addr_type(&sin6.sin6_addr) & IPV6_ADDR_LINKLOCAL)
			sin6.sin6_scope_id = ifa->idev->dev->ifindex;
332 333 334 335 336 337 338 339 340 341 342 343 344
		svc_age_temp_xprts_now(nlmsvc_rqst->rq_server,
			(struct sockaddr *)&sin6);
	}

out:
	return NOTIFY_DONE;
}

static struct notifier_block lockd_inet6addr_notifier = {
	.notifier_call = lockd_inet6addr_event,
};
#endif

345
static void lockd_unregister_notifiers(void)
346 347 348 349 350
{
	unregister_inetaddr_notifier(&lockd_inetaddr_notifier);
#if IS_ENABLED(CONFIG_IPV6)
	unregister_inet6addr_notifier(&lockd_inet6addr_notifier);
#endif
351 352 353 354 355
}

static void lockd_svc_exit_thread(void)
{
	lockd_unregister_notifiers();
356 357 358
	svc_exit_thread(nlmsvc_rqst);
}

359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374
static int lockd_start_svc(struct svc_serv *serv)
{
	int error;

	if (nlmsvc_rqst)
		return 0;

	/*
	 * Create the kernel thread and wait for it to start.
	 */
	nlmsvc_rqst = svc_prepare_thread(serv, &serv->sv_pools[0], NUMA_NO_NODE);
	if (IS_ERR(nlmsvc_rqst)) {
		error = PTR_ERR(nlmsvc_rqst);
		printk(KERN_WARNING
			"lockd_up: svc_rqst allocation failed, error=%d\n",
			error);
375
		lockd_unregister_notifiers();
376 377 378 379 380 381
		goto out_rqst;
	}

	svc_sock_update_bufs(serv);
	serv->sv_maxconn = nlm_max_connections;

382
	nlmsvc_task = kthread_create(lockd, nlmsvc_rqst, "%s", serv->sv_name);
383 384 385 386 387 388
	if (IS_ERR(nlmsvc_task)) {
		error = PTR_ERR(nlmsvc_task);
		printk(KERN_WARNING
			"lockd_up: kthread_run failed, error=%d\n", error);
		goto out_task;
	}
389
	nlmsvc_rqst->rq_task = nlmsvc_task;
390
	wake_up_process(nlmsvc_task);
391

392 393 394 395
	dprintk("lockd_up: service started\n");
	return 0;

out_task:
396
	lockd_svc_exit_thread();
397 398 399 400 401 402
	nlmsvc_task = NULL;
out_rqst:
	nlmsvc_rqst = NULL;
	return error;
}

403
static const struct svc_serv_ops lockd_sv_ops = {
404 405
	.svo_shutdown		= svc_rpcb_cleanup,
	.svo_enqueue_xprt	= svc_xprt_do_enqueue,
406 407
};

408
static struct svc_serv *lockd_create_svc(void)
L
Linus Torvalds 已提交
409
{
J
Jeff Layton 已提交
410
	struct svc_serv *serv;
L
Linus Torvalds 已提交
411 412 413 414

	/*
	 * Check whether we're already up and running.
	 */
415
	if (nlmsvc_rqst) {
416 417 418 419 420 421
		/*
		 * Note: increase service usage, because later in case of error
		 * svc_destroy() will be called.
		 */
		svc_get(nlmsvc_rqst->rq_server);
		return nlmsvc_rqst->rq_server;
422
	}
L
Linus Torvalds 已提交
423 424 425 426 427

	/*
	 * Sanity check: if there's no pid,
	 * we should be the first user ...
	 */
428
	if (nlmsvc_users)
L
Linus Torvalds 已提交
429 430 431
		printk(KERN_WARNING
			"lockd_up: no pid, %d users??\n", nlmsvc_users);

432 433 434 435
	if (!nlm_timeout)
		nlm_timeout = LOCKD_DFLT_TIMEO;
	nlmsvc_timeout = nlm_timeout * HZ;

436
	serv = svc_create(&nlmsvc_program, LOCKD_BUFSIZE, &lockd_sv_ops);
L
Linus Torvalds 已提交
437 438
	if (!serv) {
		printk(KERN_WARNING "lockd_up: create service failed\n");
439 440
		return ERR_PTR(-ENOMEM);
	}
441 442 443 444
	register_inetaddr_notifier(&lockd_inetaddr_notifier);
#if IS_ENABLED(CONFIG_IPV6)
	register_inet6addr_notifier(&lockd_inet6addr_notifier);
#endif
445
	dprintk("lockd_up: service created\n");
446 447 448 449 450 451 452 453 454
	return serv;
}

/*
 * Bring up the lockd process if it's not already up.
 */
int lockd_up(struct net *net)
{
	struct svc_serv *serv;
455
	int error;
456 457 458 459 460 461 462

	mutex_lock(&nlmsvc_mutex);

	serv = lockd_create_svc();
	if (IS_ERR(serv)) {
		error = PTR_ERR(serv);
		goto err_create;
L
Linus Torvalds 已提交
463 464
	}

465
	error = lockd_up_net(serv, net);
466 467 468 469
	if (error < 0) {
		lockd_unregister_notifiers();
		goto err_put;
	}
L
Linus Torvalds 已提交
470

471
	error = lockd_start_svc(serv);
472 473 474 475
	if (error < 0) {
		lockd_down_net(serv, net);
		goto err_put;
	}
476
	nlmsvc_users++;
L
Linus Torvalds 已提交
477 478 479 480
	/*
	 * Note: svc_serv structures have an initial use count of 1,
	 * so we exit through here on both success and failure.
	 */
481
err_put:
L
Linus Torvalds 已提交
482
	svc_destroy(serv);
483
err_create:
I
Ingo Molnar 已提交
484
	mutex_unlock(&nlmsvc_mutex);
L
Linus Torvalds 已提交
485 486
	return error;
}
487
EXPORT_SYMBOL_GPL(lockd_up);
L
Linus Torvalds 已提交
488 489 490 491 492

/*
 * Decrement the user count and bring down lockd if we're the last.
 */
void
493
lockd_down(struct net *net)
L
Linus Torvalds 已提交
494
{
I
Ingo Molnar 已提交
495
	mutex_lock(&nlmsvc_mutex);
496
	lockd_down_net(nlmsvc_rqst->rq_server, net);
L
Linus Torvalds 已提交
497
	if (nlmsvc_users) {
498
		if (--nlmsvc_users)
L
Linus Torvalds 已提交
499
			goto out;
J
Jeff Layton 已提交
500 501 502 503
	} else {
		printk(KERN_ERR "lockd_down: no users! task=%p\n",
			nlmsvc_task);
		BUG();
L
Linus Torvalds 已提交
504 505
	}

J
Jeff Layton 已提交
506 507 508
	if (!nlmsvc_task) {
		printk(KERN_ERR "lockd_down: no lockd running.\n");
		BUG();
L
Linus Torvalds 已提交
509
	}
J
Jeff Layton 已提交
510
	kthread_stop(nlmsvc_task);
511
	dprintk("lockd_down: service stopped\n");
512
	lockd_svc_exit_thread();
513
	dprintk("lockd_down: service destroyed\n");
514 515
	nlmsvc_task = NULL;
	nlmsvc_rqst = NULL;
L
Linus Torvalds 已提交
516
out:
I
Ingo Molnar 已提交
517
	mutex_unlock(&nlmsvc_mutex);
L
Linus Torvalds 已提交
518
}
519
EXPORT_SYMBOL_GPL(lockd_down);
L
Linus Torvalds 已提交
520

521 522
#ifdef CONFIG_SYSCTL

L
Linus Torvalds 已提交
523 524 525 526
/*
 * Sysctl parameters (same as module parameters, different interface).
 */

527
static struct ctl_table nlm_sysctls[] = {
L
Linus Torvalds 已提交
528 529 530
	{
		.procname	= "nlm_grace_period",
		.data		= &nlm_grace_period,
531
		.maxlen		= sizeof(unsigned long),
L
Linus Torvalds 已提交
532
		.mode		= 0644,
533
		.proc_handler	= proc_doulongvec_minmax,
L
Linus Torvalds 已提交
534 535 536 537 538 539
		.extra1		= (unsigned long *) &nlm_grace_period_min,
		.extra2		= (unsigned long *) &nlm_grace_period_max,
	},
	{
		.procname	= "nlm_timeout",
		.data		= &nlm_timeout,
540
		.maxlen		= sizeof(unsigned long),
L
Linus Torvalds 已提交
541
		.mode		= 0644,
542
		.proc_handler	= proc_doulongvec_minmax,
L
Linus Torvalds 已提交
543 544 545 546 547 548 549 550
		.extra1		= (unsigned long *) &nlm_timeout_min,
		.extra2		= (unsigned long *) &nlm_timeout_max,
	},
	{
		.procname	= "nlm_udpport",
		.data		= &nlm_udpport,
		.maxlen		= sizeof(int),
		.mode		= 0644,
551
		.proc_handler	= proc_dointvec_minmax,
L
Linus Torvalds 已提交
552 553 554 555 556 557 558 559
		.extra1		= (int *) &nlm_port_min,
		.extra2		= (int *) &nlm_port_max,
	},
	{
		.procname	= "nlm_tcpport",
		.data		= &nlm_tcpport,
		.maxlen		= sizeof(int),
		.mode		= 0644,
560
		.proc_handler	= proc_dointvec_minmax,
L
Linus Torvalds 已提交
561 562 563
		.extra1		= (int *) &nlm_port_min,
		.extra2		= (int *) &nlm_port_max,
	},
564 565 566 567 568
	{
		.procname	= "nsm_use_hostnames",
		.data		= &nsm_use_hostnames,
		.maxlen		= sizeof(int),
		.mode		= 0644,
569
		.proc_handler	= proc_dointvec,
570
	},
571 572 573 574 575
	{
		.procname	= "nsm_local_state",
		.data		= &nsm_local_state,
		.maxlen		= sizeof(int),
		.mode		= 0644,
576
		.proc_handler	= proc_dointvec,
577
	},
578
	{ }
L
Linus Torvalds 已提交
579 580
};

581
static struct ctl_table nlm_sysctl_dir[] = {
L
Linus Torvalds 已提交
582 583 584 585 586
	{
		.procname	= "nfs",
		.mode		= 0555,
		.child		= nlm_sysctls,
	},
587
	{ }
L
Linus Torvalds 已提交
588 589
};

590
static struct ctl_table nlm_sysctl_root[] = {
L
Linus Torvalds 已提交
591 592 593 594 595
	{
		.procname	= "fs",
		.mode		= 0555,
		.child		= nlm_sysctl_dir,
	},
596
	{ }
L
Linus Torvalds 已提交
597 598
};

599 600
#endif	/* CONFIG_SYSCTL */

L
Linus Torvalds 已提交
601
/*
602
 * Module (and sysfs) parameters.
L
Linus Torvalds 已提交
603 604 605
 */

#define param_set_min_max(name, type, which_strtol, min, max)		\
606
static int param_set_##name(const char *val, const struct kernel_param *kp) \
L
Linus Torvalds 已提交
607 608 609 610 611
{									\
	char *endp;							\
	__typeof__(type) num = which_strtol(val, &endp, 0);		\
	if (endp == val || *endp || num < (min) || num > (max))		\
		return -EINVAL;						\
612
	*((type *) kp->arg) = num;					\
L
Linus Torvalds 已提交
613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665
	return 0;							\
}

static inline int is_callback(u32 proc)
{
	return proc == NLMPROC_GRANTED
		|| proc == NLMPROC_GRANTED_MSG
		|| proc == NLMPROC_TEST_RES
		|| proc == NLMPROC_LOCK_RES
		|| proc == NLMPROC_CANCEL_RES
		|| proc == NLMPROC_UNLOCK_RES
		|| proc == NLMPROC_NSM_NOTIFY;
}


static int lockd_authenticate(struct svc_rqst *rqstp)
{
	rqstp->rq_client = NULL;
	switch (rqstp->rq_authop->flavour) {
		case RPC_AUTH_NULL:
		case RPC_AUTH_UNIX:
			if (rqstp->rq_proc == 0)
				return SVC_OK;
			if (is_callback(rqstp->rq_proc)) {
				/* Leave it to individual procedures to
				 * call nlmsvc_lookup_host(rqstp)
				 */
				return SVC_OK;
			}
			return svc_set_client(rqstp);
	}
	return SVC_DENIED;
}


param_set_min_max(port, int, simple_strtol, 0, 65535)
param_set_min_max(grace_period, unsigned long, simple_strtoul,
		  nlm_grace_period_min, nlm_grace_period_max)
param_set_min_max(timeout, unsigned long, simple_strtoul,
		  nlm_timeout_min, nlm_timeout_max)

MODULE_AUTHOR("Olaf Kirch <okir@monad.swb.de>");
MODULE_DESCRIPTION("NFS file locking service version " LOCKD_VERSION ".");
MODULE_LICENSE("GPL");

module_param_call(nlm_grace_period, param_set_grace_period, param_get_ulong,
		  &nlm_grace_period, 0644);
module_param_call(nlm_timeout, param_set_timeout, param_get_ulong,
		  &nlm_timeout, 0644);
module_param_call(nlm_udpport, param_set_port, param_get_int,
		  &nlm_udpport, 0644);
module_param_call(nlm_tcpport, param_set_port, param_get_int,
		  &nlm_tcpport, 0644);
666
module_param(nsm_use_hostnames, bool, 0644);
667
module_param(nlm_max_connections, uint, 0644);
L
Linus Torvalds 已提交
668

669 670
static int lockd_init_net(struct net *net)
{
671 672 673
	struct lockd_net *ln = net_generic(net, lockd_net_id);

	INIT_DELAYED_WORK(&ln->grace_period_end, grace_ender);
674
	INIT_LIST_HEAD(&ln->lockd_manager.list);
675
	ln->lockd_manager.block_opens = false;
676
	INIT_LIST_HEAD(&ln->nsm_handles);
677 678 679 680 681
	return 0;
}

static void lockd_exit_net(struct net *net)
{
682 683 684 685 686 687 688 689 690 691 692
	struct lockd_net *ln = net_generic(net, lockd_net_id);

	WARN_ONCE(!list_empty(&ln->lockd_manager.list),
		  "net %x %s: lockd_manager.list is not empty\n",
		  net->ns.inum, __func__);
	WARN_ONCE(!list_empty(&ln->nsm_handles),
		  "net %x %s: nsm_handles list is not empty\n",
		  net->ns.inum, __func__);
	WARN_ONCE(delayed_work_pending(&ln->grace_period_end),
		  "net %x %s: grace_period_end was not cancelled\n",
		  net->ns.inum, __func__);
693 694 695 696 697 698 699 700 701 702
}

static struct pernet_operations lockd_net_ops = {
	.init = lockd_init_net,
	.exit = lockd_exit_net,
	.id = &lockd_net_id,
	.size = sizeof(struct lockd_net),
};


L
Linus Torvalds 已提交
703 704 705 706 707 708
/*
 * Initialising and terminating the module.
 */

static int __init init_nlm(void)
{
709 710
	int err;

711
#ifdef CONFIG_SYSCTL
712
	err = -ENOMEM;
713
	nlm_sysctl_table = register_sysctl_table(nlm_sysctl_root);
714 715 716 717 718 719
	if (nlm_sysctl_table == NULL)
		goto err_sysctl;
#endif
	err = register_pernet_subsys(&lockd_net_ops);
	if (err)
		goto err_pernet;
720 721 722 723 724

	err = lockd_create_procfs();
	if (err)
		goto err_procfs;

725
	return 0;
726

727 728
err_procfs:
	unregister_pernet_subsys(&lockd_net_ops);
729 730 731 732
err_pernet:
#ifdef CONFIG_SYSCTL
	unregister_sysctl_table(nlm_sysctl_table);
err_sysctl:
733
#endif
734
	return err;
L
Linus Torvalds 已提交
735 736 737 738 739 740
}

static void __exit exit_nlm(void)
{
	/* FIXME: delete all NLM clients */
	nlm_shutdown_hosts();
741
	lockd_remove_procfs();
742
	unregister_pernet_subsys(&lockd_net_ops);
743
#ifdef CONFIG_SYSCTL
L
Linus Torvalds 已提交
744
	unregister_sysctl_table(nlm_sysctl_table);
745
#endif
L
Linus Torvalds 已提交
746 747 748 749 750 751 752 753
}

module_init(init_nlm);
module_exit(exit_nlm);

/*
 * Define NLM program and procedures
 */
754
static unsigned int nlmsvc_version1_count[17];
755 756 757 758 759 760
static const struct svc_version	nlmsvc_version1 = {
	.vs_vers	= 1,
	.vs_nproc	= 17,
	.vs_proc	= nlmsvc_procedures,
	.vs_count	= nlmsvc_version1_count,
	.vs_xdrsize	= NLMSVC_XDRSIZE,
L
Linus Torvalds 已提交
761
};
762
static unsigned int nlmsvc_version3_count[24];
763 764 765 766 767 768
static const struct svc_version	nlmsvc_version3 = {
	.vs_vers	= 3,
	.vs_nproc	= 24,
	.vs_proc	= nlmsvc_procedures,
	.vs_count	= nlmsvc_version3_count,
	.vs_xdrsize	= NLMSVC_XDRSIZE,
L
Linus Torvalds 已提交
769 770
};
#ifdef CONFIG_LOCKD_V4
771
static unsigned int nlmsvc_version4_count[24];
772 773 774 775 776 777
static const struct svc_version	nlmsvc_version4 = {
	.vs_vers	= 4,
	.vs_nproc	= 24,
	.vs_proc	= nlmsvc_procedures4,
	.vs_count	= nlmsvc_version4_count,
	.vs_xdrsize	= NLMSVC_XDRSIZE,
L
Linus Torvalds 已提交
778 779
};
#endif
780
static const struct svc_version *nlmsvc_version[] = {
L
Linus Torvalds 已提交
781 782 783 784 785 786 787 788 789
	[1] = &nlmsvc_version1,
	[3] = &nlmsvc_version3,
#ifdef CONFIG_LOCKD_V4
	[4] = &nlmsvc_version4,
#endif
};

static struct svc_stat		nlmsvc_stats;

790
#define NLM_NRVERS	ARRAY_SIZE(nlmsvc_version)
L
Linus Torvalds 已提交
791 792 793 794 795 796 797 798 799
static struct svc_program	nlmsvc_program = {
	.pg_prog		= NLM_PROGRAM,		/* program number */
	.pg_nvers		= NLM_NRVERS,		/* number of entries in nlmsvc_version */
	.pg_vers		= nlmsvc_version,	/* version table */
	.pg_name		= "lockd",		/* service name */
	.pg_class		= "nfsd",		/* share authentication with nfsd */
	.pg_stats		= &nlmsvc_stats,	/* stats table */
	.pg_authenticate = &lockd_authenticate	/* export authentication */
};