Linux Audio

Check our new training course

Loading...
v6.13.7
  1// SPDX-License-Identifier: GPL-2.0
  2/*
  3 * linux/fs/lockd/svcproc.c
  4 *
  5 * Lockd server procedures. We don't implement the NLM_*_RES 
  6 * procedures because we don't use the async procedures.
  7 *
  8 * Copyright (C) 1996, Olaf Kirch <okir@monad.swb.de>
  9 */
 10
 11#include <linux/types.h>
 12#include <linux/time.h>
 13#include <linux/lockd/lockd.h>
 14#include <linux/lockd/share.h>
 15#include <linux/sunrpc/svc_xprt.h>
 16
 17#define NLMDBG_FACILITY		NLMDBG_CLIENT
 18
 19#ifdef CONFIG_LOCKD_V4
 20static __be32
 21cast_to_nlm(__be32 status, u32 vers)
 22{
 23	/* Note: status is assumed to be in network byte order !!! */
 24	if (vers != 4){
 25		switch (status) {
 26		case nlm_granted:
 27		case nlm_lck_denied:
 28		case nlm_lck_denied_nolocks:
 29		case nlm_lck_blocked:
 30		case nlm_lck_denied_grace_period:
 31		case nlm_drop_reply:
 32			break;
 33		case nlm4_deadlock:
 34			status = nlm_lck_denied;
 35			break;
 36		default:
 37			status = nlm_lck_denied_nolocks;
 38		}
 39	}
 40
 41	return (status);
 42}
 43#define	cast_status(status) (cast_to_nlm(status, rqstp->rq_vers))
 44#else
 45#define cast_status(status) (status)
 46#endif
 47
 48/*
 49 * Obtain client and file from arguments
 50 */
 51static __be32
 52nlmsvc_retrieve_args(struct svc_rqst *rqstp, struct nlm_args *argp,
 53			struct nlm_host **hostp, struct nlm_file **filp)
 54{
 55	struct nlm_host		*host = NULL;
 56	struct nlm_file		*file = NULL;
 57	struct nlm_lock		*lock = &argp->lock;
 58	int			mode;
 59	__be32			error = 0;
 60
 61	/* nfsd callbacks must have been installed for this procedure */
 62	if (!nlmsvc_ops)
 63		return nlm_lck_denied_nolocks;
 64
 65	/* Obtain host handle */
 66	if (!(host = nlmsvc_lookup_host(rqstp, lock->caller, lock->len))
 67	 || (argp->monitor && nsm_monitor(host) < 0))
 68		goto no_locks;
 69	*hostp = host;
 70
 71	/* Obtain file pointer. Not used by FREE_ALL call. */
 72	if (filp != NULL) {
 73		error = cast_status(nlm_lookup_file(rqstp, &file, lock));
 74		if (error != 0)
 75			goto no_locks;
 76		*filp = file;
 77
 78		/* Set up the missing parts of the file_lock structure */
 79		mode = lock_to_openmode(&lock->fl);
 80		lock->fl.c.flc_flags = FL_POSIX;
 81		lock->fl.c.flc_file  = file->f_file[mode];
 82		lock->fl.c.flc_pid = current->tgid;
 83		lock->fl.fl_lmops = &nlmsvc_lock_operations;
 84		nlmsvc_locks_init_private(&lock->fl, host, (pid_t)lock->svid);
 85		if (!lock->fl.c.flc_owner) {
 86			/* lockowner allocation has failed */
 87			nlmsvc_release_host(host);
 88			return nlm_lck_denied_nolocks;
 89		}
 90	}
 91
 92	return 0;
 93
 94no_locks:
 95	nlmsvc_release_host(host);
 96	if (error)
 97		return error;
 98	return nlm_lck_denied_nolocks;
 99}
100
101/*
102 * NULL: Test for presence of service
103 */
104static __be32
105nlmsvc_proc_null(struct svc_rqst *rqstp)
106{
107	dprintk("lockd: NULL          called\n");
108	return rpc_success;
109}
110
111/*
112 * TEST: Check for conflicting lock
113 */
114static __be32
115__nlmsvc_proc_test(struct svc_rqst *rqstp, struct nlm_res *resp)
 
116{
117	struct nlm_args *argp = rqstp->rq_argp;
118	struct nlm_host	*host;
119	struct nlm_file	*file;
120	struct nlm_lockowner *test_owner;
121	__be32 rc = rpc_success;
122
123	dprintk("lockd: TEST          called\n");
124	resp->cookie = argp->cookie;
125
126	/* Obtain client and file */
127	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
128		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
129
130	test_owner = argp->lock.fl.c.flc_owner;
131
132	/* Now check for conflicting locks */
133	resp->status = cast_status(nlmsvc_testlock(rqstp, file, host,
134						   &argp->lock, &resp->lock));
135	if (resp->status == nlm_drop_reply)
136		rc = rpc_drop_reply;
137	else
138		dprintk("lockd: TEST          status %d vers %d\n",
139			ntohl(resp->status), rqstp->rq_vers);
140
141	nlmsvc_put_lockowner(test_owner);
142	nlmsvc_release_host(host);
143	nlm_release_file(file);
144	return rc;
145}
146
147static __be32
148nlmsvc_proc_test(struct svc_rqst *rqstp)
 
149{
150	return __nlmsvc_proc_test(rqstp, rqstp->rq_resp);
151}
152
153static __be32
154__nlmsvc_proc_lock(struct svc_rqst *rqstp, struct nlm_res *resp)
155{
156	struct nlm_args *argp = rqstp->rq_argp;
157	struct nlm_host	*host;
158	struct nlm_file	*file;
159	__be32 rc = rpc_success;
160
161	dprintk("lockd: LOCK          called\n");
162
163	resp->cookie = argp->cookie;
164
165	/* Obtain client and file */
166	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
167		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
168
 
 
 
 
 
 
 
 
 
 
 
 
169	/* Now try to lock the file */
170	resp->status = cast_status(nlmsvc_lock(rqstp, file, host, &argp->lock,
171					       argp->block, &argp->cookie,
172					       argp->reclaim));
173	if (resp->status == nlm_drop_reply)
174		rc = rpc_drop_reply;
175	else
176		dprintk("lockd: LOCK         status %d\n", ntohl(resp->status));
177
178	nlmsvc_release_lockowner(&argp->lock);
179	nlmsvc_release_host(host);
180	nlm_release_file(file);
181	return rc;
182}
183
184static __be32
185nlmsvc_proc_lock(struct svc_rqst *rqstp)
186{
187	return __nlmsvc_proc_lock(rqstp, rqstp->rq_resp);
188}
189
190static __be32
191__nlmsvc_proc_cancel(struct svc_rqst *rqstp, struct nlm_res *resp)
192{
193	struct nlm_args *argp = rqstp->rq_argp;
194	struct nlm_host	*host;
195	struct nlm_file	*file;
196	struct net *net = SVC_NET(rqstp);
197
198	dprintk("lockd: CANCEL        called\n");
199
200	resp->cookie = argp->cookie;
201
202	/* Don't accept requests during grace period */
203	if (locks_in_grace(net)) {
204		resp->status = nlm_lck_denied_grace_period;
205		return rpc_success;
206	}
207
208	/* Obtain client and file */
209	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
210		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
211
212	/* Try to cancel request. */
213	resp->status = cast_status(nlmsvc_cancel_blocked(net, file, &argp->lock));
214
215	dprintk("lockd: CANCEL        status %d\n", ntohl(resp->status));
216	nlmsvc_release_lockowner(&argp->lock);
217	nlmsvc_release_host(host);
218	nlm_release_file(file);
219	return rpc_success;
220}
221
222static __be32
223nlmsvc_proc_cancel(struct svc_rqst *rqstp)
224{
225	return __nlmsvc_proc_cancel(rqstp, rqstp->rq_resp);
226}
227
228/*
229 * UNLOCK: release a lock
230 */
231static __be32
232__nlmsvc_proc_unlock(struct svc_rqst *rqstp, struct nlm_res *resp)
 
233{
234	struct nlm_args *argp = rqstp->rq_argp;
235	struct nlm_host	*host;
236	struct nlm_file	*file;
237	struct net *net = SVC_NET(rqstp);
238
239	dprintk("lockd: UNLOCK        called\n");
240
241	resp->cookie = argp->cookie;
242
243	/* Don't accept new lock requests during grace period */
244	if (locks_in_grace(net)) {
245		resp->status = nlm_lck_denied_grace_period;
246		return rpc_success;
247	}
248
249	/* Obtain client and file */
250	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
251		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
252
253	/* Now try to remove the lock */
254	resp->status = cast_status(nlmsvc_unlock(net, file, &argp->lock));
255
256	dprintk("lockd: UNLOCK        status %d\n", ntohl(resp->status));
257	nlmsvc_release_lockowner(&argp->lock);
258	nlmsvc_release_host(host);
259	nlm_release_file(file);
260	return rpc_success;
261}
262
263static __be32
264nlmsvc_proc_unlock(struct svc_rqst *rqstp)
265{
266	return __nlmsvc_proc_unlock(rqstp, rqstp->rq_resp);
267}
268
269/*
270 * GRANTED: A server calls us to tell that a process' lock request
271 * was granted
272 */
273static __be32
274__nlmsvc_proc_granted(struct svc_rqst *rqstp, struct nlm_res *resp)
 
275{
276	struct nlm_args *argp = rqstp->rq_argp;
277
278	resp->cookie = argp->cookie;
279
280	dprintk("lockd: GRANTED       called\n");
281	resp->status = nlmclnt_grant(svc_addr(rqstp), &argp->lock);
282	dprintk("lockd: GRANTED       status %d\n", ntohl(resp->status));
283	return rpc_success;
284}
285
286static __be32
287nlmsvc_proc_granted(struct svc_rqst *rqstp)
288{
289	return __nlmsvc_proc_granted(rqstp, rqstp->rq_resp);
290}
291
292/*
293 * This is the generic lockd callback for async RPC calls
294 */
295static void nlmsvc_callback_exit(struct rpc_task *task, void *data)
296{
 
 
297}
298
299void nlmsvc_release_call(struct nlm_rqst *call)
300{
301	if (!refcount_dec_and_test(&call->a_count))
302		return;
303	nlmsvc_release_host(call->a_host);
304	kfree(call);
305}
306
307static void nlmsvc_callback_release(void *data)
308{
309	nlmsvc_release_call(data);
310}
311
312static const struct rpc_call_ops nlmsvc_callback_ops = {
313	.rpc_call_done = nlmsvc_callback_exit,
314	.rpc_release = nlmsvc_callback_release,
315};
316
317/*
318 * `Async' versions of the above service routines. They aren't really,
319 * because we send the callback before the reply proper. I hope this
320 * doesn't break any clients.
321 */
322static __be32 nlmsvc_callback(struct svc_rqst *rqstp, u32 proc,
323		__be32 (*func)(struct svc_rqst *, struct nlm_res *))
324{
325	struct nlm_args *argp = rqstp->rq_argp;
326	struct nlm_host	*host;
327	struct nlm_rqst	*call;
328	__be32 stat;
329
330	host = nlmsvc_lookup_host(rqstp,
331				  argp->lock.caller,
332				  argp->lock.len);
333	if (host == NULL)
334		return rpc_system_err;
335
336	call = nlm_alloc_call(host);
337	nlmsvc_release_host(host);
338	if (call == NULL)
339		return rpc_system_err;
340
341	stat = func(rqstp, &call->a_res);
342	if (stat != 0) {
343		nlmsvc_release_call(call);
344		return stat;
345	}
346
347	call->a_flags = RPC_TASK_ASYNC;
348	if (nlm_async_reply(call, proc, &nlmsvc_callback_ops) < 0)
349		return rpc_system_err;
350	return rpc_success;
351}
352
353static __be32 nlmsvc_proc_test_msg(struct svc_rqst *rqstp)
 
354{
355	dprintk("lockd: TEST_MSG      called\n");
356	return nlmsvc_callback(rqstp, NLMPROC_TEST_RES, __nlmsvc_proc_test);
357}
358
359static __be32 nlmsvc_proc_lock_msg(struct svc_rqst *rqstp)
 
360{
361	dprintk("lockd: LOCK_MSG      called\n");
362	return nlmsvc_callback(rqstp, NLMPROC_LOCK_RES, __nlmsvc_proc_lock);
363}
364
365static __be32 nlmsvc_proc_cancel_msg(struct svc_rqst *rqstp)
 
366{
367	dprintk("lockd: CANCEL_MSG    called\n");
368	return nlmsvc_callback(rqstp, NLMPROC_CANCEL_RES, __nlmsvc_proc_cancel);
369}
370
371static __be32
372nlmsvc_proc_unlock_msg(struct svc_rqst *rqstp)
 
373{
374	dprintk("lockd: UNLOCK_MSG    called\n");
375	return nlmsvc_callback(rqstp, NLMPROC_UNLOCK_RES, __nlmsvc_proc_unlock);
376}
377
378static __be32
379nlmsvc_proc_granted_msg(struct svc_rqst *rqstp)
 
380{
381	dprintk("lockd: GRANTED_MSG   called\n");
382	return nlmsvc_callback(rqstp, NLMPROC_GRANTED_RES, __nlmsvc_proc_granted);
383}
384
385/*
386 * SHARE: create a DOS share or alter existing share.
387 */
388static __be32
389nlmsvc_proc_share(struct svc_rqst *rqstp)
 
390{
391	struct nlm_args *argp = rqstp->rq_argp;
392	struct nlm_res *resp = rqstp->rq_resp;
393	struct nlm_host	*host;
394	struct nlm_file	*file;
395
396	dprintk("lockd: SHARE         called\n");
397
398	resp->cookie = argp->cookie;
399
400	/* Don't accept new lock requests during grace period */
401	if (locks_in_grace(SVC_NET(rqstp)) && !argp->reclaim) {
402		resp->status = nlm_lck_denied_grace_period;
403		return rpc_success;
404	}
405
406	/* Obtain client and file */
407	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
408		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
409
410	/* Now try to create the share */
411	resp->status = cast_status(nlmsvc_share_file(host, file, argp));
412
413	dprintk("lockd: SHARE         status %d\n", ntohl(resp->status));
414	nlmsvc_release_lockowner(&argp->lock);
415	nlmsvc_release_host(host);
416	nlm_release_file(file);
417	return rpc_success;
418}
419
420/*
421 * UNSHARE: Release a DOS share.
422 */
423static __be32
424nlmsvc_proc_unshare(struct svc_rqst *rqstp)
 
425{
426	struct nlm_args *argp = rqstp->rq_argp;
427	struct nlm_res *resp = rqstp->rq_resp;
428	struct nlm_host	*host;
429	struct nlm_file	*file;
430
431	dprintk("lockd: UNSHARE       called\n");
432
433	resp->cookie = argp->cookie;
434
435	/* Don't accept requests during grace period */
436	if (locks_in_grace(SVC_NET(rqstp))) {
437		resp->status = nlm_lck_denied_grace_period;
438		return rpc_success;
439	}
440
441	/* Obtain client and file */
442	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
443		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
444
445	/* Now try to unshare the file */
446	resp->status = cast_status(nlmsvc_unshare_file(host, file, argp));
447
448	dprintk("lockd: UNSHARE       status %d\n", ntohl(resp->status));
449	nlmsvc_release_lockowner(&argp->lock);
450	nlmsvc_release_host(host);
451	nlm_release_file(file);
452	return rpc_success;
453}
454
455/*
456 * NM_LOCK: Create an unmonitored lock
457 */
458static __be32
459nlmsvc_proc_nm_lock(struct svc_rqst *rqstp)
 
460{
461	struct nlm_args *argp = rqstp->rq_argp;
462
463	dprintk("lockd: NM_LOCK       called\n");
464
465	argp->monitor = 0;		/* just clean the monitor flag */
466	return nlmsvc_proc_lock(rqstp);
467}
468
469/*
470 * FREE_ALL: Release all locks and shares held by client
471 */
472static __be32
473nlmsvc_proc_free_all(struct svc_rqst *rqstp)
 
474{
475	struct nlm_args *argp = rqstp->rq_argp;
476	struct nlm_host	*host;
477
478	/* Obtain client */
479	if (nlmsvc_retrieve_args(rqstp, argp, &host, NULL))
480		return rpc_success;
481
482	nlmsvc_free_host_resources(host);
483	nlmsvc_release_host(host);
484	return rpc_success;
485}
486
487/*
488 * SM_NOTIFY: private callback from statd (not part of official NLM proto)
489 */
490static __be32
491nlmsvc_proc_sm_notify(struct svc_rqst *rqstp)
 
492{
493	struct nlm_reboot *argp = rqstp->rq_argp;
494
495	dprintk("lockd: SM_NOTIFY     called\n");
496
497	if (!nlm_privileged_requester(rqstp)) {
498		char buf[RPC_MAX_ADDRBUFLEN];
499		printk(KERN_WARNING "lockd: rejected NSM callback from %s\n",
500				svc_print_addr(rqstp, buf, sizeof(buf)));
501		return rpc_system_err;
502	}
503
504	nlm_host_rebooted(SVC_NET(rqstp), argp);
505	return rpc_success;
506}
507
508/*
509 * client sent a GRANTED_RES, let's remove the associated block
510 */
511static __be32
512nlmsvc_proc_granted_res(struct svc_rqst *rqstp)
 
513{
514	struct nlm_res *argp = rqstp->rq_argp;
515
516	if (!nlmsvc_ops)
517		return rpc_success;
518
519	dprintk("lockd: GRANTED_RES   called\n");
520
521	nlmsvc_grant_reply(&argp->cookie, argp->status);
522	return rpc_success;
523}
524
525static __be32
526nlmsvc_proc_unused(struct svc_rqst *rqstp)
527{
528	return rpc_proc_unavail;
529}
530
531/*
532 * NLM Server procedures.
533 */
534
 
 
 
 
 
 
 
 
 
 
 
 
 
 
535struct nlm_void			{ int dummy; };
536
 
 
 
 
 
 
 
 
 
 
537#define	Ck	(1+XDR_QUADLEN(NLM_MAXCOOKIELEN))	/* cookie */
538#define	St	1				/* status */
539#define	No	(1+1024/4)			/* Net Obj */
540#define	Rg	2				/* range - offset + size */
541
542const struct svc_procedure nlmsvc_procedures[24] = {
543	[NLMPROC_NULL] = {
544		.pc_func = nlmsvc_proc_null,
545		.pc_decode = nlmsvc_decode_void,
546		.pc_encode = nlmsvc_encode_void,
547		.pc_argsize = sizeof(struct nlm_void),
548		.pc_argzero = sizeof(struct nlm_void),
549		.pc_ressize = sizeof(struct nlm_void),
550		.pc_xdrressize = St,
551		.pc_name = "NULL",
552	},
553	[NLMPROC_TEST] = {
554		.pc_func = nlmsvc_proc_test,
555		.pc_decode = nlmsvc_decode_testargs,
556		.pc_encode = nlmsvc_encode_testres,
557		.pc_argsize = sizeof(struct nlm_args),
558		.pc_argzero = sizeof(struct nlm_args),
559		.pc_ressize = sizeof(struct nlm_res),
560		.pc_xdrressize = Ck+St+2+No+Rg,
561		.pc_name = "TEST",
562	},
563	[NLMPROC_LOCK] = {
564		.pc_func = nlmsvc_proc_lock,
565		.pc_decode = nlmsvc_decode_lockargs,
566		.pc_encode = nlmsvc_encode_res,
567		.pc_argsize = sizeof(struct nlm_args),
568		.pc_argzero = sizeof(struct nlm_args),
569		.pc_ressize = sizeof(struct nlm_res),
570		.pc_xdrressize = Ck+St,
571		.pc_name = "LOCK",
572	},
573	[NLMPROC_CANCEL] = {
574		.pc_func = nlmsvc_proc_cancel,
575		.pc_decode = nlmsvc_decode_cancargs,
576		.pc_encode = nlmsvc_encode_res,
577		.pc_argsize = sizeof(struct nlm_args),
578		.pc_argzero = sizeof(struct nlm_args),
579		.pc_ressize = sizeof(struct nlm_res),
580		.pc_xdrressize = Ck+St,
581		.pc_name = "CANCEL",
582	},
583	[NLMPROC_UNLOCK] = {
584		.pc_func = nlmsvc_proc_unlock,
585		.pc_decode = nlmsvc_decode_unlockargs,
586		.pc_encode = nlmsvc_encode_res,
587		.pc_argsize = sizeof(struct nlm_args),
588		.pc_argzero = sizeof(struct nlm_args),
589		.pc_ressize = sizeof(struct nlm_res),
590		.pc_xdrressize = Ck+St,
591		.pc_name = "UNLOCK",
592	},
593	[NLMPROC_GRANTED] = {
594		.pc_func = nlmsvc_proc_granted,
595		.pc_decode = nlmsvc_decode_testargs,
596		.pc_encode = nlmsvc_encode_res,
597		.pc_argsize = sizeof(struct nlm_args),
598		.pc_argzero = sizeof(struct nlm_args),
599		.pc_ressize = sizeof(struct nlm_res),
600		.pc_xdrressize = Ck+St,
601		.pc_name = "GRANTED",
602	},
603	[NLMPROC_TEST_MSG] = {
604		.pc_func = nlmsvc_proc_test_msg,
605		.pc_decode = nlmsvc_decode_testargs,
606		.pc_encode = nlmsvc_encode_void,
607		.pc_argsize = sizeof(struct nlm_args),
608		.pc_argzero = sizeof(struct nlm_args),
609		.pc_ressize = sizeof(struct nlm_void),
610		.pc_xdrressize = St,
611		.pc_name = "TEST_MSG",
612	},
613	[NLMPROC_LOCK_MSG] = {
614		.pc_func = nlmsvc_proc_lock_msg,
615		.pc_decode = nlmsvc_decode_lockargs,
616		.pc_encode = nlmsvc_encode_void,
617		.pc_argsize = sizeof(struct nlm_args),
618		.pc_argzero = sizeof(struct nlm_args),
619		.pc_ressize = sizeof(struct nlm_void),
620		.pc_xdrressize = St,
621		.pc_name = "LOCK_MSG",
622	},
623	[NLMPROC_CANCEL_MSG] = {
624		.pc_func = nlmsvc_proc_cancel_msg,
625		.pc_decode = nlmsvc_decode_cancargs,
626		.pc_encode = nlmsvc_encode_void,
627		.pc_argsize = sizeof(struct nlm_args),
628		.pc_argzero = sizeof(struct nlm_args),
629		.pc_ressize = sizeof(struct nlm_void),
630		.pc_xdrressize = St,
631		.pc_name = "CANCEL_MSG",
632	},
633	[NLMPROC_UNLOCK_MSG] = {
634		.pc_func = nlmsvc_proc_unlock_msg,
635		.pc_decode = nlmsvc_decode_unlockargs,
636		.pc_encode = nlmsvc_encode_void,
637		.pc_argsize = sizeof(struct nlm_args),
638		.pc_argzero = sizeof(struct nlm_args),
639		.pc_ressize = sizeof(struct nlm_void),
640		.pc_xdrressize = St,
641		.pc_name = "UNLOCK_MSG",
642	},
643	[NLMPROC_GRANTED_MSG] = {
644		.pc_func = nlmsvc_proc_granted_msg,
645		.pc_decode = nlmsvc_decode_testargs,
646		.pc_encode = nlmsvc_encode_void,
647		.pc_argsize = sizeof(struct nlm_args),
648		.pc_argzero = sizeof(struct nlm_args),
649		.pc_ressize = sizeof(struct nlm_void),
650		.pc_xdrressize = St,
651		.pc_name = "GRANTED_MSG",
652	},
653	[NLMPROC_TEST_RES] = {
654		.pc_func = nlmsvc_proc_null,
655		.pc_decode = nlmsvc_decode_void,
656		.pc_encode = nlmsvc_encode_void,
657		.pc_argsize = sizeof(struct nlm_res),
658		.pc_argzero = sizeof(struct nlm_res),
659		.pc_ressize = sizeof(struct nlm_void),
660		.pc_xdrressize = St,
661		.pc_name = "TEST_RES",
662	},
663	[NLMPROC_LOCK_RES] = {
664		.pc_func = nlmsvc_proc_null,
665		.pc_decode = nlmsvc_decode_void,
666		.pc_encode = nlmsvc_encode_void,
667		.pc_argsize = sizeof(struct nlm_res),
668		.pc_argzero = sizeof(struct nlm_res),
669		.pc_ressize = sizeof(struct nlm_void),
670		.pc_xdrressize = St,
671		.pc_name = "LOCK_RES",
672	},
673	[NLMPROC_CANCEL_RES] = {
674		.pc_func = nlmsvc_proc_null,
675		.pc_decode = nlmsvc_decode_void,
676		.pc_encode = nlmsvc_encode_void,
677		.pc_argsize = sizeof(struct nlm_res),
678		.pc_argzero = sizeof(struct nlm_res),
679		.pc_ressize = sizeof(struct nlm_void),
680		.pc_xdrressize = St,
681		.pc_name = "CANCEL_RES",
682	},
683	[NLMPROC_UNLOCK_RES] = {
684		.pc_func = nlmsvc_proc_null,
685		.pc_decode = nlmsvc_decode_void,
686		.pc_encode = nlmsvc_encode_void,
687		.pc_argsize = sizeof(struct nlm_res),
688		.pc_argzero = sizeof(struct nlm_res),
689		.pc_ressize = sizeof(struct nlm_void),
690		.pc_xdrressize = St,
691		.pc_name = "UNLOCK_RES",
692	},
693	[NLMPROC_GRANTED_RES] = {
694		.pc_func = nlmsvc_proc_granted_res,
695		.pc_decode = nlmsvc_decode_res,
696		.pc_encode = nlmsvc_encode_void,
697		.pc_argsize = sizeof(struct nlm_res),
698		.pc_argzero = sizeof(struct nlm_res),
699		.pc_ressize = sizeof(struct nlm_void),
700		.pc_xdrressize = St,
701		.pc_name = "GRANTED_RES",
702	},
703	[NLMPROC_NSM_NOTIFY] = {
704		.pc_func = nlmsvc_proc_sm_notify,
705		.pc_decode = nlmsvc_decode_reboot,
706		.pc_encode = nlmsvc_encode_void,
707		.pc_argsize = sizeof(struct nlm_reboot),
708		.pc_argzero = sizeof(struct nlm_reboot),
709		.pc_ressize = sizeof(struct nlm_void),
710		.pc_xdrressize = St,
711		.pc_name = "SM_NOTIFY",
712	},
713	[17] = {
714		.pc_func = nlmsvc_proc_unused,
715		.pc_decode = nlmsvc_decode_void,
716		.pc_encode = nlmsvc_encode_void,
717		.pc_argsize = sizeof(struct nlm_void),
718		.pc_argzero = sizeof(struct nlm_void),
719		.pc_ressize = sizeof(struct nlm_void),
720		.pc_xdrressize = St,
721		.pc_name = "UNUSED",
722	},
723	[18] = {
724		.pc_func = nlmsvc_proc_unused,
725		.pc_decode = nlmsvc_decode_void,
726		.pc_encode = nlmsvc_encode_void,
727		.pc_argsize = sizeof(struct nlm_void),
728		.pc_argzero = sizeof(struct nlm_void),
729		.pc_ressize = sizeof(struct nlm_void),
730		.pc_xdrressize = St,
731		.pc_name = "UNUSED",
732	},
733	[19] = {
734		.pc_func = nlmsvc_proc_unused,
735		.pc_decode = nlmsvc_decode_void,
736		.pc_encode = nlmsvc_encode_void,
737		.pc_argsize = sizeof(struct nlm_void),
738		.pc_argzero = sizeof(struct nlm_void),
739		.pc_ressize = sizeof(struct nlm_void),
740		.pc_xdrressize = St,
741		.pc_name = "UNUSED",
742	},
743	[NLMPROC_SHARE] = {
744		.pc_func = nlmsvc_proc_share,
745		.pc_decode = nlmsvc_decode_shareargs,
746		.pc_encode = nlmsvc_encode_shareres,
747		.pc_argsize = sizeof(struct nlm_args),
748		.pc_argzero = sizeof(struct nlm_args),
749		.pc_ressize = sizeof(struct nlm_res),
750		.pc_xdrressize = Ck+St+1,
751		.pc_name = "SHARE",
752	},
753	[NLMPROC_UNSHARE] = {
754		.pc_func = nlmsvc_proc_unshare,
755		.pc_decode = nlmsvc_decode_shareargs,
756		.pc_encode = nlmsvc_encode_shareres,
757		.pc_argsize = sizeof(struct nlm_args),
758		.pc_argzero = sizeof(struct nlm_args),
759		.pc_ressize = sizeof(struct nlm_res),
760		.pc_xdrressize = Ck+St+1,
761		.pc_name = "UNSHARE",
762	},
763	[NLMPROC_NM_LOCK] = {
764		.pc_func = nlmsvc_proc_nm_lock,
765		.pc_decode = nlmsvc_decode_lockargs,
766		.pc_encode = nlmsvc_encode_res,
767		.pc_argsize = sizeof(struct nlm_args),
768		.pc_argzero = sizeof(struct nlm_args),
769		.pc_ressize = sizeof(struct nlm_res),
770		.pc_xdrressize = Ck+St,
771		.pc_name = "NM_LOCK",
772	},
773	[NLMPROC_FREE_ALL] = {
774		.pc_func = nlmsvc_proc_free_all,
775		.pc_decode = nlmsvc_decode_notify,
776		.pc_encode = nlmsvc_encode_void,
777		.pc_argsize = sizeof(struct nlm_args),
778		.pc_argzero = sizeof(struct nlm_args),
779		.pc_ressize = sizeof(struct nlm_void),
780		.pc_xdrressize = 0,
781		.pc_name = "FREE_ALL",
782	},
783};
v3.15
 
  1/*
  2 * linux/fs/lockd/svcproc.c
  3 *
  4 * Lockd server procedures. We don't implement the NLM_*_RES 
  5 * procedures because we don't use the async procedures.
  6 *
  7 * Copyright (C) 1996, Olaf Kirch <okir@monad.swb.de>
  8 */
  9
 10#include <linux/types.h>
 11#include <linux/time.h>
 12#include <linux/lockd/lockd.h>
 13#include <linux/lockd/share.h>
 14#include <linux/sunrpc/svc_xprt.h>
 15
 16#define NLMDBG_FACILITY		NLMDBG_CLIENT
 17
 18#ifdef CONFIG_LOCKD_V4
 19static __be32
 20cast_to_nlm(__be32 status, u32 vers)
 21{
 22	/* Note: status is assumed to be in network byte order !!! */
 23	if (vers != 4){
 24		switch (status) {
 25		case nlm_granted:
 26		case nlm_lck_denied:
 27		case nlm_lck_denied_nolocks:
 28		case nlm_lck_blocked:
 29		case nlm_lck_denied_grace_period:
 30		case nlm_drop_reply:
 31			break;
 32		case nlm4_deadlock:
 33			status = nlm_lck_denied;
 34			break;
 35		default:
 36			status = nlm_lck_denied_nolocks;
 37		}
 38	}
 39
 40	return (status);
 41}
 42#define	cast_status(status) (cast_to_nlm(status, rqstp->rq_vers))
 43#else
 44#define cast_status(status) (status)
 45#endif
 46
 47/*
 48 * Obtain client and file from arguments
 49 */
 50static __be32
 51nlmsvc_retrieve_args(struct svc_rqst *rqstp, struct nlm_args *argp,
 52			struct nlm_host **hostp, struct nlm_file **filp)
 53{
 54	struct nlm_host		*host = NULL;
 55	struct nlm_file		*file = NULL;
 56	struct nlm_lock		*lock = &argp->lock;
 
 57	__be32			error = 0;
 58
 59	/* nfsd callbacks must have been installed for this procedure */
 60	if (!nlmsvc_ops)
 61		return nlm_lck_denied_nolocks;
 62
 63	/* Obtain host handle */
 64	if (!(host = nlmsvc_lookup_host(rqstp, lock->caller, lock->len))
 65	 || (argp->monitor && nsm_monitor(host) < 0))
 66		goto no_locks;
 67	*hostp = host;
 68
 69	/* Obtain file pointer. Not used by FREE_ALL call. */
 70	if (filp != NULL) {
 71		error = cast_status(nlm_lookup_file(rqstp, &file, &lock->fh));
 72		if (error != 0)
 73			goto no_locks;
 74		*filp = file;
 75
 76		/* Set up the missing parts of the file_lock structure */
 77		lock->fl.fl_file  = file->f_file;
 78		lock->fl.fl_owner = (fl_owner_t) host;
 
 
 79		lock->fl.fl_lmops = &nlmsvc_lock_operations;
 
 
 
 
 
 
 80	}
 81
 82	return 0;
 83
 84no_locks:
 85	nlmsvc_release_host(host);
 86	if (error)
 87		return error;
 88	return nlm_lck_denied_nolocks;
 89}
 90
 91/*
 92 * NULL: Test for presence of service
 93 */
 94static __be32
 95nlmsvc_proc_null(struct svc_rqst *rqstp, void *argp, void *resp)
 96{
 97	dprintk("lockd: NULL          called\n");
 98	return rpc_success;
 99}
100
101/*
102 * TEST: Check for conflicting lock
103 */
104static __be32
105nlmsvc_proc_test(struct svc_rqst *rqstp, struct nlm_args *argp,
106				         struct nlm_res  *resp)
107{
 
108	struct nlm_host	*host;
109	struct nlm_file	*file;
 
110	__be32 rc = rpc_success;
111
112	dprintk("lockd: TEST          called\n");
113	resp->cookie = argp->cookie;
114
115	/* Obtain client and file */
116	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
117		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
118
 
 
119	/* Now check for conflicting locks */
120	resp->status = cast_status(nlmsvc_testlock(rqstp, file, host, &argp->lock, &resp->lock, &resp->cookie));
 
121	if (resp->status == nlm_drop_reply)
122		rc = rpc_drop_reply;
123	else
124		dprintk("lockd: TEST          status %d vers %d\n",
125			ntohl(resp->status), rqstp->rq_vers);
126
 
127	nlmsvc_release_host(host);
128	nlm_release_file(file);
129	return rc;
130}
131
132static __be32
133nlmsvc_proc_lock(struct svc_rqst *rqstp, struct nlm_args *argp,
134				         struct nlm_res  *resp)
135{
 
 
 
 
 
 
 
136	struct nlm_host	*host;
137	struct nlm_file	*file;
138	__be32 rc = rpc_success;
139
140	dprintk("lockd: LOCK          called\n");
141
142	resp->cookie = argp->cookie;
143
144	/* Obtain client and file */
145	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
146		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
147
148#if 0
149	/* If supplied state doesn't match current state, we assume it's
150	 * an old request that time-warped somehow. Any error return would
151	 * do in this case because it's irrelevant anyway.
152	 *
153	 * NB: We don't retrieve the remote host's state yet.
154	 */
155	if (host->h_nsmstate && host->h_nsmstate != argp->state) {
156		resp->status = nlm_lck_denied_nolocks;
157	} else
158#endif
159
160	/* Now try to lock the file */
161	resp->status = cast_status(nlmsvc_lock(rqstp, file, host, &argp->lock,
162					       argp->block, &argp->cookie,
163					       argp->reclaim));
164	if (resp->status == nlm_drop_reply)
165		rc = rpc_drop_reply;
166	else
167		dprintk("lockd: LOCK         status %d\n", ntohl(resp->status));
168
 
169	nlmsvc_release_host(host);
170	nlm_release_file(file);
171	return rc;
172}
173
174static __be32
175nlmsvc_proc_cancel(struct svc_rqst *rqstp, struct nlm_args *argp,
176				           struct nlm_res  *resp)
 
 
 
 
 
177{
 
178	struct nlm_host	*host;
179	struct nlm_file	*file;
180	struct net *net = SVC_NET(rqstp);
181
182	dprintk("lockd: CANCEL        called\n");
183
184	resp->cookie = argp->cookie;
185
186	/* Don't accept requests during grace period */
187	if (locks_in_grace(net)) {
188		resp->status = nlm_lck_denied_grace_period;
189		return rpc_success;
190	}
191
192	/* Obtain client and file */
193	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
194		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
195
196	/* Try to cancel request. */
197	resp->status = cast_status(nlmsvc_cancel_blocked(net, file, &argp->lock));
198
199	dprintk("lockd: CANCEL        status %d\n", ntohl(resp->status));
 
200	nlmsvc_release_host(host);
201	nlm_release_file(file);
202	return rpc_success;
203}
204
 
 
 
 
 
 
205/*
206 * UNLOCK: release a lock
207 */
208static __be32
209nlmsvc_proc_unlock(struct svc_rqst *rqstp, struct nlm_args *argp,
210				           struct nlm_res  *resp)
211{
 
212	struct nlm_host	*host;
213	struct nlm_file	*file;
214	struct net *net = SVC_NET(rqstp);
215
216	dprintk("lockd: UNLOCK        called\n");
217
218	resp->cookie = argp->cookie;
219
220	/* Don't accept new lock requests during grace period */
221	if (locks_in_grace(net)) {
222		resp->status = nlm_lck_denied_grace_period;
223		return rpc_success;
224	}
225
226	/* Obtain client and file */
227	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
228		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
229
230	/* Now try to remove the lock */
231	resp->status = cast_status(nlmsvc_unlock(net, file, &argp->lock));
232
233	dprintk("lockd: UNLOCK        status %d\n", ntohl(resp->status));
 
234	nlmsvc_release_host(host);
235	nlm_release_file(file);
236	return rpc_success;
237}
238
 
 
 
 
 
 
239/*
240 * GRANTED: A server calls us to tell that a process' lock request
241 * was granted
242 */
243static __be32
244nlmsvc_proc_granted(struct svc_rqst *rqstp, struct nlm_args *argp,
245				            struct nlm_res  *resp)
246{
 
 
247	resp->cookie = argp->cookie;
248
249	dprintk("lockd: GRANTED       called\n");
250	resp->status = nlmclnt_grant(svc_addr(rqstp), &argp->lock);
251	dprintk("lockd: GRANTED       status %d\n", ntohl(resp->status));
252	return rpc_success;
253}
254
 
 
 
 
 
 
255/*
256 * This is the generic lockd callback for async RPC calls
257 */
258static void nlmsvc_callback_exit(struct rpc_task *task, void *data)
259{
260	dprintk("lockd: %5u callback returned %d\n", task->tk_pid,
261			-task->tk_status);
262}
263
264void nlmsvc_release_call(struct nlm_rqst *call)
265{
266	if (!atomic_dec_and_test(&call->a_count))
267		return;
268	nlmsvc_release_host(call->a_host);
269	kfree(call);
270}
271
272static void nlmsvc_callback_release(void *data)
273{
274	nlmsvc_release_call(data);
275}
276
277static const struct rpc_call_ops nlmsvc_callback_ops = {
278	.rpc_call_done = nlmsvc_callback_exit,
279	.rpc_release = nlmsvc_callback_release,
280};
281
282/*
283 * `Async' versions of the above service routines. They aren't really,
284 * because we send the callback before the reply proper. I hope this
285 * doesn't break any clients.
286 */
287static __be32 nlmsvc_callback(struct svc_rqst *rqstp, u32 proc, struct nlm_args *argp,
288		__be32 (*func)(struct svc_rqst *, struct nlm_args *, struct nlm_res  *))
289{
 
290	struct nlm_host	*host;
291	struct nlm_rqst	*call;
292	__be32 stat;
293
294	host = nlmsvc_lookup_host(rqstp,
295				  argp->lock.caller,
296				  argp->lock.len);
297	if (host == NULL)
298		return rpc_system_err;
299
300	call = nlm_alloc_call(host);
301	nlmsvc_release_host(host);
302	if (call == NULL)
303		return rpc_system_err;
304
305	stat = func(rqstp, argp, &call->a_res);
306	if (stat != 0) {
307		nlmsvc_release_call(call);
308		return stat;
309	}
310
311	call->a_flags = RPC_TASK_ASYNC;
312	if (nlm_async_reply(call, proc, &nlmsvc_callback_ops) < 0)
313		return rpc_system_err;
314	return rpc_success;
315}
316
317static __be32 nlmsvc_proc_test_msg(struct svc_rqst *rqstp, struct nlm_args *argp,
318					     void	     *resp)
319{
320	dprintk("lockd: TEST_MSG      called\n");
321	return nlmsvc_callback(rqstp, NLMPROC_TEST_RES, argp, nlmsvc_proc_test);
322}
323
324static __be32 nlmsvc_proc_lock_msg(struct svc_rqst *rqstp, struct nlm_args *argp,
325					     void	     *resp)
326{
327	dprintk("lockd: LOCK_MSG      called\n");
328	return nlmsvc_callback(rqstp, NLMPROC_LOCK_RES, argp, nlmsvc_proc_lock);
329}
330
331static __be32 nlmsvc_proc_cancel_msg(struct svc_rqst *rqstp, struct nlm_args *argp,
332					       void	       *resp)
333{
334	dprintk("lockd: CANCEL_MSG    called\n");
335	return nlmsvc_callback(rqstp, NLMPROC_CANCEL_RES, argp, nlmsvc_proc_cancel);
336}
337
338static __be32
339nlmsvc_proc_unlock_msg(struct svc_rqst *rqstp, struct nlm_args *argp,
340                                               void            *resp)
341{
342	dprintk("lockd: UNLOCK_MSG    called\n");
343	return nlmsvc_callback(rqstp, NLMPROC_UNLOCK_RES, argp, nlmsvc_proc_unlock);
344}
345
346static __be32
347nlmsvc_proc_granted_msg(struct svc_rqst *rqstp, struct nlm_args *argp,
348                                                void            *resp)
349{
350	dprintk("lockd: GRANTED_MSG   called\n");
351	return nlmsvc_callback(rqstp, NLMPROC_GRANTED_RES, argp, nlmsvc_proc_granted);
352}
353
354/*
355 * SHARE: create a DOS share or alter existing share.
356 */
357static __be32
358nlmsvc_proc_share(struct svc_rqst *rqstp, struct nlm_args *argp,
359				          struct nlm_res  *resp)
360{
 
 
361	struct nlm_host	*host;
362	struct nlm_file	*file;
363
364	dprintk("lockd: SHARE         called\n");
365
366	resp->cookie = argp->cookie;
367
368	/* Don't accept new lock requests during grace period */
369	if (locks_in_grace(SVC_NET(rqstp)) && !argp->reclaim) {
370		resp->status = nlm_lck_denied_grace_period;
371		return rpc_success;
372	}
373
374	/* Obtain client and file */
375	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
376		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
377
378	/* Now try to create the share */
379	resp->status = cast_status(nlmsvc_share_file(host, file, argp));
380
381	dprintk("lockd: SHARE         status %d\n", ntohl(resp->status));
 
382	nlmsvc_release_host(host);
383	nlm_release_file(file);
384	return rpc_success;
385}
386
387/*
388 * UNSHARE: Release a DOS share.
389 */
390static __be32
391nlmsvc_proc_unshare(struct svc_rqst *rqstp, struct nlm_args *argp,
392				            struct nlm_res  *resp)
393{
 
 
394	struct nlm_host	*host;
395	struct nlm_file	*file;
396
397	dprintk("lockd: UNSHARE       called\n");
398
399	resp->cookie = argp->cookie;
400
401	/* Don't accept requests during grace period */
402	if (locks_in_grace(SVC_NET(rqstp))) {
403		resp->status = nlm_lck_denied_grace_period;
404		return rpc_success;
405	}
406
407	/* Obtain client and file */
408	if ((resp->status = nlmsvc_retrieve_args(rqstp, argp, &host, &file)))
409		return resp->status == nlm_drop_reply ? rpc_drop_reply :rpc_success;
410
411	/* Now try to unshare the file */
412	resp->status = cast_status(nlmsvc_unshare_file(host, file, argp));
413
414	dprintk("lockd: UNSHARE       status %d\n", ntohl(resp->status));
 
415	nlmsvc_release_host(host);
416	nlm_release_file(file);
417	return rpc_success;
418}
419
420/*
421 * NM_LOCK: Create an unmonitored lock
422 */
423static __be32
424nlmsvc_proc_nm_lock(struct svc_rqst *rqstp, struct nlm_args *argp,
425				            struct nlm_res  *resp)
426{
 
 
427	dprintk("lockd: NM_LOCK       called\n");
428
429	argp->monitor = 0;		/* just clean the monitor flag */
430	return nlmsvc_proc_lock(rqstp, argp, resp);
431}
432
433/*
434 * FREE_ALL: Release all locks and shares held by client
435 */
436static __be32
437nlmsvc_proc_free_all(struct svc_rqst *rqstp, struct nlm_args *argp,
438					     void            *resp)
439{
 
440	struct nlm_host	*host;
441
442	/* Obtain client */
443	if (nlmsvc_retrieve_args(rqstp, argp, &host, NULL))
444		return rpc_success;
445
446	nlmsvc_free_host_resources(host);
447	nlmsvc_release_host(host);
448	return rpc_success;
449}
450
451/*
452 * SM_NOTIFY: private callback from statd (not part of official NLM proto)
453 */
454static __be32
455nlmsvc_proc_sm_notify(struct svc_rqst *rqstp, struct nlm_reboot *argp,
456					      void	        *resp)
457{
 
 
458	dprintk("lockd: SM_NOTIFY     called\n");
459
460	if (!nlm_privileged_requester(rqstp)) {
461		char buf[RPC_MAX_ADDRBUFLEN];
462		printk(KERN_WARNING "lockd: rejected NSM callback from %s\n",
463				svc_print_addr(rqstp, buf, sizeof(buf)));
464		return rpc_system_err;
465	}
466
467	nlm_host_rebooted(argp);
468	return rpc_success;
469}
470
471/*
472 * client sent a GRANTED_RES, let's remove the associated block
473 */
474static __be32
475nlmsvc_proc_granted_res(struct svc_rqst *rqstp, struct nlm_res  *argp,
476                                                void            *resp)
477{
 
 
478	if (!nlmsvc_ops)
479		return rpc_success;
480
481	dprintk("lockd: GRANTED_RES   called\n");
482
483	nlmsvc_grant_reply(&argp->cookie, argp->status);
484	return rpc_success;
485}
486
 
 
 
 
 
 
487/*
488 * NLM Server procedures.
489 */
490
491#define nlmsvc_encode_norep	nlmsvc_encode_void
492#define nlmsvc_decode_norep	nlmsvc_decode_void
493#define nlmsvc_decode_testres	nlmsvc_decode_void
494#define nlmsvc_decode_lockres	nlmsvc_decode_void
495#define nlmsvc_decode_unlockres	nlmsvc_decode_void
496#define nlmsvc_decode_cancelres	nlmsvc_decode_void
497#define nlmsvc_decode_grantedres	nlmsvc_decode_void
498
499#define nlmsvc_proc_none	nlmsvc_proc_null
500#define nlmsvc_proc_test_res	nlmsvc_proc_null
501#define nlmsvc_proc_lock_res	nlmsvc_proc_null
502#define nlmsvc_proc_cancel_res	nlmsvc_proc_null
503#define nlmsvc_proc_unlock_res	nlmsvc_proc_null
504
505struct nlm_void			{ int dummy; };
506
507#define PROC(name, xargt, xrest, argt, rest, respsize)	\
508 { .pc_func	= (svc_procfunc) nlmsvc_proc_##name,	\
509   .pc_decode	= (kxdrproc_t) nlmsvc_decode_##xargt,	\
510   .pc_encode	= (kxdrproc_t) nlmsvc_encode_##xrest,	\
511   .pc_release	= NULL,					\
512   .pc_argsize	= sizeof(struct nlm_##argt),		\
513   .pc_ressize	= sizeof(struct nlm_##rest),		\
514   .pc_xdrressize = respsize,				\
515 }
516
517#define	Ck	(1+XDR_QUADLEN(NLM_MAXCOOKIELEN))	/* cookie */
518#define	St	1				/* status */
519#define	No	(1+1024/4)			/* Net Obj */
520#define	Rg	2				/* range - offset + size */
521
522struct svc_procedure		nlmsvc_procedures[] = {
523  PROC(null,		void,		void,		void,	void, 1),
524  PROC(test,		testargs,	testres,	args,	res, Ck+St+2+No+Rg),
525  PROC(lock,		lockargs,	res,		args,	res, Ck+St),
526  PROC(cancel,		cancargs,	res,		args,	res, Ck+St),
527  PROC(unlock,		unlockargs,	res,		args,	res, Ck+St),
528  PROC(granted,		testargs,	res,		args,	res, Ck+St),
529  PROC(test_msg,	testargs,	norep,		args,	void, 1),
530  PROC(lock_msg,	lockargs,	norep,		args,	void, 1),
531  PROC(cancel_msg,	cancargs,	norep,		args,	void, 1),
532  PROC(unlock_msg,	unlockargs,	norep,		args,	void, 1),
533  PROC(granted_msg,	testargs,	norep,		args,	void, 1),
534  PROC(test_res,	testres,	norep,		res,	void, 1),
535  PROC(lock_res,	lockres,	norep,		res,	void, 1),
536  PROC(cancel_res,	cancelres,	norep,		res,	void, 1),
537  PROC(unlock_res,	unlockres,	norep,		res,	void, 1),
538  PROC(granted_res,	res,		norep,		res,	void, 1),
539  /* statd callback */
540  PROC(sm_notify,	reboot,		void,		reboot,	void, 1),
541  PROC(none,		void,		void,		void,	void, 1),
542  PROC(none,		void,		void,		void,	void, 1),
543  PROC(none,		void,		void,		void,	void, 1),
544  PROC(share,		shareargs,	shareres,	args,	res, Ck+St+1),
545  PROC(unshare,		shareargs,	shareres,	args,	res, Ck+St+1),
546  PROC(nm_lock,		lockargs,	res,		args,	res, Ck+St),
547  PROC(free_all,	notify,		void,		args,	void, 0),
548
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
549};