nfsd: pass net to nfsd_svc()
[deliverable/linux.git] / fs / nfsd / nfsctl.c
CommitLineData
1da177e4 1/*
1da177e4
LT
2 * Syscall interface to knfsd.
3 *
4 * Copyright (C) 1995, 1996 Olaf Kirch <okir@monad.swb.de>
5 */
6
5a0e3ad6 7#include <linux/slab.h>
3f8206d4 8#include <linux/namei.h>
b41b66d6 9#include <linux/ctype.h>
1da177e4 10
80212d59 11#include <linux/sunrpc/svcsock.h>
4373ea84 12#include <linux/lockd/lockd.h>
4116092b 13#include <linux/sunrpc/clnt.h>
b0b0c0a2 14#include <linux/sunrpc/gss_api.h>
b084f598 15#include <linux/sunrpc/gss_krb5_enctypes.h>
813fd320 16#include <linux/sunrpc/rpc_pipe_fs.h>
143cb494 17#include <linux/module.h>
1da177e4 18
2ca72e17 19#include "idmap.h"
9a74af21
BH
20#include "nfsd.h"
21#include "cache.h"
f3c7521f 22#include "state.h"
7ea34ac1 23#include "netns.h"
9a74af21 24
1da177e4 25/*
b0b0c0a2 26 * We have a single directory with several nodes in it.
1da177e4
LT
27 */
28enum {
29 NFSD_Root = 1,
1da177e4 30 NFSD_List,
e8e8753f 31 NFSD_Export_features,
1da177e4 32 NFSD_Fh,
4373ea84 33 NFSD_FO_UnlockIP,
17efa372 34 NFSD_FO_UnlockFS,
1da177e4 35 NFSD_Threads,
eed2965a 36 NFSD_Pool_Threads,
03cf6c9f 37 NFSD_Pool_Stats,
70c3b76c 38 NFSD_Versions,
80212d59 39 NFSD_Ports,
596bbe53 40 NFSD_MaxBlkSize,
b0b0c0a2 41 NFSD_SupportedEnctypes,
70c3b76c
N
42 /*
43 * The below MUST come last. Otherwise we leave a hole in nfsd_files[]
44 * with !CONFIG_NFSD_V4 and simple_fill_super() goes oops
45 */
46#ifdef CONFIG_NFSD_V4
1da177e4 47 NFSD_Leasetime,
efc4bb4f 48 NFSD_Gracetime,
0964a3d3 49 NFSD_RecoveryDir,
70c3b76c 50#endif
1da177e4
LT
51};
52
53/*
54 * write() for these nodes.
55 */
1da177e4 56static ssize_t write_filehandle(struct file *file, char *buf, size_t size);
b046ccdc
CL
57static ssize_t write_unlock_ip(struct file *file, char *buf, size_t size);
58static ssize_t write_unlock_fs(struct file *file, char *buf, size_t size);
1da177e4 59static ssize_t write_threads(struct file *file, char *buf, size_t size);
eed2965a 60static ssize_t write_pool_threads(struct file *file, char *buf, size_t size);
70c3b76c 61static ssize_t write_versions(struct file *file, char *buf, size_t size);
80212d59 62static ssize_t write_ports(struct file *file, char *buf, size_t size);
596bbe53 63static ssize_t write_maxblksize(struct file *file, char *buf, size_t size);
70c3b76c 64#ifdef CONFIG_NFSD_V4
1da177e4 65static ssize_t write_leasetime(struct file *file, char *buf, size_t size);
efc4bb4f 66static ssize_t write_gracetime(struct file *file, char *buf, size_t size);
0964a3d3 67static ssize_t write_recoverydir(struct file *file, char *buf, size_t size);
70c3b76c 68#endif
1da177e4
LT
69
70static ssize_t (*write_op[])(struct file *, char *, size_t) = {
1da177e4 71 [NFSD_Fh] = write_filehandle,
b046ccdc
CL
72 [NFSD_FO_UnlockIP] = write_unlock_ip,
73 [NFSD_FO_UnlockFS] = write_unlock_fs,
1da177e4 74 [NFSD_Threads] = write_threads,
eed2965a 75 [NFSD_Pool_Threads] = write_pool_threads,
70c3b76c 76 [NFSD_Versions] = write_versions,
80212d59 77 [NFSD_Ports] = write_ports,
596bbe53 78 [NFSD_MaxBlkSize] = write_maxblksize,
70c3b76c 79#ifdef CONFIG_NFSD_V4
1da177e4 80 [NFSD_Leasetime] = write_leasetime,
efc4bb4f 81 [NFSD_Gracetime] = write_gracetime,
0964a3d3 82 [NFSD_RecoveryDir] = write_recoverydir,
70c3b76c 83#endif
1da177e4
LT
84};
85
86static ssize_t nfsctl_transaction_write(struct file *file, const char __user *buf, size_t size, loff_t *pos)
87{
7eaa36e2 88 ino_t ino = file->f_path.dentry->d_inode->i_ino;
1da177e4
LT
89 char *data;
90 ssize_t rv;
91
e8c96f8c 92 if (ino >= ARRAY_SIZE(write_op) || !write_op[ino])
1da177e4
LT
93 return -EINVAL;
94
95 data = simple_transaction_get(file, buf, size);
96 if (IS_ERR(data))
97 return PTR_ERR(data);
98
99 rv = write_op[ino](file, data, size);
8971a101 100 if (rv >= 0) {
1da177e4
LT
101 simple_transaction_set(file, rv);
102 rv = size;
103 }
104 return rv;
105}
106
7390022d
N
107static ssize_t nfsctl_transaction_read(struct file *file, char __user *buf, size_t size, loff_t *pos)
108{
109 if (! file->private_data) {
110 /* An attempt to read a transaction file without writing
111 * causes a 0-byte write so that the file can return
112 * state information
113 */
114 ssize_t rv = nfsctl_transaction_write(file, buf, 0, pos);
115 if (rv < 0)
116 return rv;
117 }
118 return simple_transaction_read(file, buf, size, pos);
119}
120
4b6f5d20 121static const struct file_operations transaction_ops = {
1da177e4 122 .write = nfsctl_transaction_write,
7390022d 123 .read = nfsctl_transaction_read,
1da177e4 124 .release = simple_transaction_release,
6038f373 125 .llseek = default_llseek,
1da177e4
LT
126};
127
1da177e4
LT
128static int exports_open(struct inode *inode, struct file *file)
129{
f2c7ea10
SK
130 int err;
131 struct seq_file *seq;
e5f06f72 132 struct nfsd_net *nn = net_generic(&init_net, nfsd_net_id);
f2c7ea10
SK
133
134 err = seq_open(file, &nfs_exports_op);
135 if (err)
136 return err;
137
138 seq = file->private_data;
e5f06f72 139 seq->private = nn->svc_export_cache;
f2c7ea10 140 return 0;
1da177e4
LT
141}
142
4b6f5d20 143static const struct file_operations exports_operations = {
1da177e4
LT
144 .open = exports_open,
145 .read = seq_read,
146 .llseek = seq_lseek,
147 .release = seq_release,
9ef2db26 148 .owner = THIS_MODULE,
1da177e4
LT
149};
150
e8e8753f
BF
151static int export_features_show(struct seq_file *m, void *v)
152{
153 seq_printf(m, "0x%x 0x%x\n", NFSEXP_ALLFLAGS, NFSEXP_SECINFO_FLAGS);
154 return 0;
155}
156
157static int export_features_open(struct inode *inode, struct file *file)
158{
159 return single_open(file, export_features_show, NULL);
160}
161
162static struct file_operations export_features_operations = {
163 .open = export_features_open,
164 .read = seq_read,
165 .llseek = seq_lseek,
166 .release = single_release,
167};
168
b084f598 169#if defined(CONFIG_SUNRPC_GSS) || defined(CONFIG_SUNRPC_GSS_MODULE)
b0b0c0a2
KC
170static int supported_enctypes_show(struct seq_file *m, void *v)
171{
b084f598 172 seq_printf(m, KRB5_SUPPORTED_ENCTYPES);
b0b0c0a2
KC
173 return 0;
174}
175
176static int supported_enctypes_open(struct inode *inode, struct file *file)
177{
178 return single_open(file, supported_enctypes_show, NULL);
179}
180
181static struct file_operations supported_enctypes_ops = {
182 .open = supported_enctypes_open,
183 .read = seq_read,
184 .llseek = seq_lseek,
185 .release = single_release,
186};
b084f598 187#endif /* CONFIG_SUNRPC_GSS or CONFIG_SUNRPC_GSS_MODULE */
b0b0c0a2 188
828c0950 189static const struct file_operations pool_stats_operations = {
03cf6c9f
GB
190 .open = nfsd_pool_stats_open,
191 .read = seq_read,
192 .llseek = seq_lseek,
ed2d8aed 193 .release = nfsd_pool_stats_release,
03cf6c9f
GB
194 .owner = THIS_MODULE,
195};
196
1da177e4
LT
197/*----------------------------------------------------------------------------*/
198/*
199 * payload - write methods
1da177e4
LT
200 */
201
1da177e4 202
262a0982
CL
203/**
204 * write_unlock_ip - Release all locks used by a client
205 *
206 * Experimental.
207 *
208 * Input:
209 * buf: '\n'-terminated C string containing a
4116092b 210 * presentation format IP address
262a0982
CL
211 * size: length of C string in @buf
212 * Output:
213 * On success: returns zero if all specified locks were released;
214 * returns one if one or more locks were not released
215 * On error: return code is negative errno value
262a0982 216 */
b046ccdc 217static ssize_t write_unlock_ip(struct file *file, char *buf, size_t size)
4373ea84 218{
4116092b
CL
219 struct sockaddr_storage address;
220 struct sockaddr *sap = (struct sockaddr *)&address;
221 size_t salen = sizeof(address);
367c8c7b 222 char *fo_path;
4373ea84
WC
223
224 /* sanity check */
225 if (size == 0)
226 return -EINVAL;
227
228 if (buf[size-1] != '\n')
229 return -EINVAL;
230
231 fo_path = buf;
232 if (qword_get(&buf, fo_path, size) < 0)
233 return -EINVAL;
234
90100b17 235 if (rpc_pton(&init_net, fo_path, size, sap, salen) == 0)
4373ea84 236 return -EINVAL;
4373ea84 237
4116092b 238 return nlmsvc_unlock_all_by_ip(sap);
4373ea84
WC
239}
240
262a0982
CL
241/**
242 * write_unlock_fs - Release all locks on a local file system
243 *
244 * Experimental.
245 *
246 * Input:
247 * buf: '\n'-terminated C string containing the
248 * absolute pathname of a local file system
249 * size: length of C string in @buf
250 * Output:
251 * On success: returns zero if all specified locks were released;
252 * returns one if one or more locks were not released
253 * On error: return code is negative errno value
254 */
b046ccdc 255static ssize_t write_unlock_fs(struct file *file, char *buf, size_t size)
17efa372 256{
a63bb996 257 struct path path;
17efa372
WC
258 char *fo_path;
259 int error;
260
261 /* sanity check */
262 if (size == 0)
263 return -EINVAL;
264
265 if (buf[size-1] != '\n')
266 return -EINVAL;
267
268 fo_path = buf;
269 if (qword_get(&buf, fo_path, size) < 0)
270 return -EINVAL;
271
a63bb996 272 error = kern_path(fo_path, 0, &path);
17efa372
WC
273 if (error)
274 return error;
275
262a0982
CL
276 /*
277 * XXX: Needs better sanity checking. Otherwise we could end up
278 * releasing locks on the wrong file system.
279 *
280 * For example:
281 * 1. Does the path refer to a directory?
282 * 2. Is that directory a mount point, or
283 * 3. Is that directory the root of an exported file system?
284 */
d8c9584e 285 error = nlmsvc_unlock_all_by_sb(path.dentry->d_sb);
17efa372 286
a63bb996 287 path_put(&path);
17efa372
WC
288 return error;
289}
290
262a0982
CL
291/**
292 * write_filehandle - Get a variable-length NFS file handle by path
293 *
294 * On input, the buffer contains a '\n'-terminated C string comprised of
295 * three alphanumeric words separated by whitespace. The string may
296 * contain escape sequences.
297 *
298 * Input:
299 * buf:
300 * domain: client domain name
301 * path: export pathname
302 * maxsize: numeric maximum size of
303 * @buf
304 * size: length of C string in @buf
305 * Output:
306 * On success: passed-in buffer filled with '\n'-terminated C
307 * string containing a ASCII hex text version
308 * of the NFS file handle;
309 * return code is the size in bytes of the string
310 * On error: return code is negative errno value
311 */
1da177e4
LT
312static ssize_t write_filehandle(struct file *file, char *buf, size_t size)
313{
1da177e4 314 char *dname, *path;
246d95ba 315 int uninitialized_var(maxsize);
1da177e4
LT
316 char *mesg = buf;
317 int len;
318 struct auth_domain *dom;
319 struct knfsd_fh fh;
320
87d26ea7
BF
321 if (size == 0)
322 return -EINVAL;
323
1da177e4
LT
324 if (buf[size-1] != '\n')
325 return -EINVAL;
326 buf[size-1] = 0;
327
328 dname = mesg;
329 len = qword_get(&mesg, dname, size);
54224f04
CL
330 if (len <= 0)
331 return -EINVAL;
1da177e4
LT
332
333 path = dname+len+1;
334 len = qword_get(&mesg, path, size);
54224f04
CL
335 if (len <= 0)
336 return -EINVAL;
1da177e4
LT
337
338 len = get_int(&mesg, &maxsize);
339 if (len)
340 return len;
341
342 if (maxsize < NFS_FHSIZE)
343 return -EINVAL;
344 if (maxsize > NFS3_FHSIZE)
345 maxsize = NFS3_FHSIZE;
346
347 if (qword_get(&mesg, mesg, size)>0)
348 return -EINVAL;
349
350 /* we have all the words, they are in buf.. */
351 dom = unix_domain_find(dname);
352 if (!dom)
353 return -ENOMEM;
354
b3853e0e 355 len = exp_rootfh(&init_net, dom, path, &fh, maxsize);
1da177e4
LT
356 auth_domain_put(dom);
357 if (len)
358 return len;
359
54224f04
CL
360 mesg = buf;
361 len = SIMPLE_TRANSACTION_LIMIT;
1da177e4
LT
362 qword_addhex(&mesg, &len, (char*)&fh.fh_base, fh.fh_size);
363 mesg[-1] = '\n';
364 return mesg - buf;
365}
366
262a0982
CL
367/**
368 * write_threads - Start NFSD, or report the current number of running threads
369 *
370 * Input:
371 * buf: ignored
372 * size: zero
373 * Output:
374 * On success: passed-in buffer filled with '\n'-terminated C
375 * string numeric value representing the number of
376 * running NFSD threads;
377 * return code is the size in bytes of the string
378 * On error: return code is zero
379 *
380 * OR
381 *
382 * Input:
383 * buf: C string containing an unsigned
384 * integer value representing the
385 * number of NFSD threads to start
386 * size: non-zero length of C string in @buf
387 * Output:
388 * On success: NFS service is started;
389 * passed-in buffer filled with '\n'-terminated C
390 * string numeric value representing the number of
391 * running NFSD threads;
392 * return code is the size in bytes of the string
393 * On error: return code is zero or a negative errno value
394 */
1da177e4
LT
395static ssize_t write_threads(struct file *file, char *buf, size_t size)
396{
1da177e4
LT
397 char *mesg = buf;
398 int rv;
d41a9417
SK
399 struct net *net = &init_net;
400
1da177e4
LT
401 if (size > 0) {
402 int newthreads;
403 rv = get_int(&mesg, &newthreads);
404 if (rv)
405 return rv;
9e074856 406 if (newthreads < 0)
1da177e4 407 return -EINVAL;
d41a9417 408 rv = nfsd_svc(newthreads, net);
82e12fe9 409 if (rv < 0)
1da177e4 410 return rv;
82e12fe9
N
411 } else
412 rv = nfsd_nrthreads();
e06b6405 413
82e12fe9 414 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%d\n", rv);
1da177e4
LT
415}
416
262a0982
CL
417/**
418 * write_pool_threads - Set or report the current number of threads per pool
419 *
420 * Input:
421 * buf: ignored
422 * size: zero
423 *
424 * OR
425 *
426 * Input:
427 * buf: C string containing whitespace-
428 * separated unsigned integer values
429 * representing the number of NFSD
430 * threads to start in each pool
431 * size: non-zero length of C string in @buf
432 * Output:
433 * On success: passed-in buffer filled with '\n'-terminated C
434 * string containing integer values representing the
435 * number of NFSD threads in each pool;
436 * return code is the size in bytes of the string
437 * On error: return code is zero or a negative errno value
438 */
eed2965a
GB
439static ssize_t write_pool_threads(struct file *file, char *buf, size_t size)
440{
441 /* if size > 0, look for an array of number of threads per node
442 * and apply them then write out number of threads per node as reply
443 */
444 char *mesg = buf;
445 int i;
446 int rv;
447 int len;
bedbdd8b 448 int npools;
eed2965a
GB
449 int *nthreads;
450
bedbdd8b
NB
451 mutex_lock(&nfsd_mutex);
452 npools = nfsd_nrpools();
eed2965a
GB
453 if (npools == 0) {
454 /*
455 * NFS is shut down. The admin can start it by
456 * writing to the threads file but NOT the pool_threads
457 * file, sorry. Report zero threads.
458 */
bedbdd8b 459 mutex_unlock(&nfsd_mutex);
eed2965a
GB
460 strcpy(buf, "0\n");
461 return strlen(buf);
462 }
463
464 nthreads = kcalloc(npools, sizeof(int), GFP_KERNEL);
bedbdd8b 465 rv = -ENOMEM;
eed2965a 466 if (nthreads == NULL)
bedbdd8b 467 goto out_free;
eed2965a
GB
468
469 if (size > 0) {
470 for (i = 0; i < npools; i++) {
471 rv = get_int(&mesg, &nthreads[i]);
472 if (rv == -ENOENT)
473 break; /* fewer numbers than pools */
474 if (rv)
475 goto out_free; /* syntax error */
476 rv = -EINVAL;
477 if (nthreads[i] < 0)
478 goto out_free;
479 }
480 rv = nfsd_set_nrthreads(i, nthreads);
481 if (rv)
482 goto out_free;
483 }
484
485 rv = nfsd_get_nrthreads(npools, nthreads);
486 if (rv)
487 goto out_free;
488
489 mesg = buf;
490 size = SIMPLE_TRANSACTION_LIMIT;
491 for (i = 0; i < npools && size > 0; i++) {
492 snprintf(mesg, size, "%d%c", nthreads[i], (i == npools-1 ? '\n' : ' '));
493 len = strlen(mesg);
494 size -= len;
495 mesg += len;
496 }
413d63d7 497 rv = mesg - buf;
eed2965a
GB
498out_free:
499 kfree(nthreads);
bedbdd8b 500 mutex_unlock(&nfsd_mutex);
eed2965a
GB
501 return rv;
502}
503
3dd98a3b 504static ssize_t __write_versions(struct file *file, char *buf, size_t size)
70c3b76c 505{
70c3b76c 506 char *mesg = buf;
8daf220a 507 char *vers, *minorp, sign;
261758b5 508 int len, num, remaining;
8daf220a 509 unsigned minor;
70c3b76c
N
510 ssize_t tlen = 0;
511 char *sep;
512
513 if (size>0) {
514 if (nfsd_serv)
6658d3a7
N
515 /* Cannot change versions without updating
516 * nfsd_serv->sv_xdrsize, and reallocing
517 * rq_argp and rq_resp
518 */
70c3b76c
N
519 return -EBUSY;
520 if (buf[size-1] != '\n')
521 return -EINVAL;
522 buf[size-1] = 0;
523
524 vers = mesg;
525 len = qword_get(&mesg, vers, size);
526 if (len <= 0) return -EINVAL;
527 do {
528 sign = *vers;
529 if (sign == '+' || sign == '-')
8daf220a 530 num = simple_strtol((vers+1), &minorp, 0);
70c3b76c 531 else
8daf220a
BH
532 num = simple_strtol(vers, &minorp, 0);
533 if (*minorp == '.') {
534 if (num < 4)
535 return -EINVAL;
536 minor = simple_strtoul(minorp+1, NULL, 0);
537 if (minor == 0)
538 return -EINVAL;
539 if (nfsd_minorversion(minor, sign == '-' ?
540 NFSD_CLEAR : NFSD_SET) < 0)
541 return -EINVAL;
542 goto next;
543 }
70c3b76c
N
544 switch(num) {
545 case 2:
546 case 3:
547 case 4:
6658d3a7 548 nfsd_vers(num, sign == '-' ? NFSD_CLEAR : NFSD_SET);
70c3b76c
N
549 break;
550 default:
551 return -EINVAL;
552 }
8daf220a 553 next:
70c3b76c 554 vers += len + 1;
70c3b76c
N
555 } while ((len = qword_get(&mesg, vers, size)) > 0);
556 /* If all get turned off, turn them back on, as
557 * having no versions is BAD
558 */
6658d3a7 559 nfsd_reset_versions();
70c3b76c 560 }
261758b5 561
70c3b76c
N
562 /* Now write current state into reply buffer */
563 len = 0;
564 sep = "";
261758b5 565 remaining = SIMPLE_TRANSACTION_LIMIT;
70c3b76c 566 for (num=2 ; num <= 4 ; num++)
6658d3a7 567 if (nfsd_vers(num, NFSD_AVAIL)) {
261758b5 568 len = snprintf(buf, remaining, "%s%c%d", sep,
6658d3a7 569 nfsd_vers(num, NFSD_TEST)?'+':'-',
70c3b76c
N
570 num);
571 sep = " ";
261758b5
CL
572
573 if (len > remaining)
574 break;
575 remaining -= len;
576 buf += len;
577 tlen += len;
70c3b76c 578 }
8daf220a 579 if (nfsd_vers(4, NFSD_AVAIL))
261758b5
CL
580 for (minor = 1; minor <= NFSD_SUPPORTED_MINOR_VERSION;
581 minor++) {
582 len = snprintf(buf, remaining, " %c4.%u",
8daf220a
BH
583 (nfsd_vers(4, NFSD_TEST) &&
584 nfsd_minorversion(minor, NFSD_TEST)) ?
585 '+' : '-',
586 minor);
261758b5
CL
587
588 if (len > remaining)
589 break;
590 remaining -= len;
591 buf += len;
592 tlen += len;
593 }
594
595 len = snprintf(buf, remaining, "\n");
596 if (len > remaining)
597 return -EINVAL;
598 return tlen + len;
70c3b76c
N
599}
600
262a0982
CL
601/**
602 * write_versions - Set or report the available NFS protocol versions
603 *
604 * Input:
605 * buf: ignored
606 * size: zero
607 * Output:
608 * On success: passed-in buffer filled with '\n'-terminated C
609 * string containing positive or negative integer
610 * values representing the current status of each
611 * protocol version;
612 * return code is the size in bytes of the string
613 * On error: return code is zero or a negative errno value
614 *
615 * OR
616 *
617 * Input:
618 * buf: C string containing whitespace-
619 * separated positive or negative
620 * integer values representing NFS
621 * protocol versions to enable ("+n")
622 * or disable ("-n")
623 * size: non-zero length of C string in @buf
624 * Output:
625 * On success: status of zero or more protocol versions has
626 * been updated; passed-in buffer filled with
627 * '\n'-terminated C string containing positive
628 * or negative integer values representing the
629 * current status of each protocol version;
630 * return code is the size in bytes of the string
631 * On error: return code is zero or a negative errno value
632 */
3dd98a3b
JL
633static ssize_t write_versions(struct file *file, char *buf, size_t size)
634{
635 ssize_t rv;
636
637 mutex_lock(&nfsd_mutex);
638 rv = __write_versions(file, buf, size);
639 mutex_unlock(&nfsd_mutex);
640 return rv;
641}
642
0a5372d8
CL
643/*
644 * Zero-length write. Return a list of NFSD's current listener
645 * transports.
646 */
647static ssize_t __write_ports_names(char *buf)
648{
649 if (nfsd_serv == NULL)
650 return 0;
335c54bd 651 return svc_xprt_names(nfsd_serv, buf, SIMPLE_TRANSACTION_LIMIT);
0a5372d8
CL
652}
653
0b7c2f6f
CL
654/*
655 * A single 'fd' number was written, in which case it must be for
656 * a socket of a supported family/protocol, and we use it as an
657 * nfsd listener.
658 */
659static ssize_t __write_ports_addfd(char *buf)
660{
661 char *mesg = buf;
662 int fd, err;
786185b5 663 struct net *net = &init_net;
0b7c2f6f
CL
664
665 err = get_int(&mesg, &fd);
666 if (err != 0 || fd < 0)
667 return -EINVAL;
668
6777436b 669 err = nfsd_create_serv(net);
0b7c2f6f
CL
670 if (err != 0)
671 return err;
672
bfba9ab4 673 err = svc_addsock(nfsd_serv, fd, buf, SIMPLE_TRANSACTION_LIMIT);
78a8d7c8 674 if (err < 0) {
19f7e2ca 675 nfsd_destroy(net);
78a8d7c8
JL
676 return err;
677 }
0b7c2f6f 678
ea068bad
CL
679 /* Decrease the count, but don't shut down the service */
680 nfsd_serv->sv_nrthreads--;
681 return err;
0b7c2f6f
CL
682}
683
4eb68c26
CL
684/*
685 * A transport listener is added by writing it's transport name and
686 * a port number.
687 */
688static ssize_t __write_ports_addxprt(char *buf)
689{
690 char transport[16];
37498292 691 struct svc_xprt *xprt;
4eb68c26 692 int port, err;
786185b5 693 struct net *net = &init_net;
4eb68c26 694
a10fded1 695 if (sscanf(buf, "%15s %5u", transport, &port) != 2)
4eb68c26
CL
696 return -EINVAL;
697
4be929be 698 if (port < 1 || port > USHRT_MAX)
4eb68c26
CL
699 return -EINVAL;
700
6777436b 701 err = nfsd_create_serv(net);
4eb68c26
CL
702 if (err != 0)
703 return err;
704
786185b5 705 err = svc_create_xprt(nfsd_serv, transport, net,
4eb68c26 706 PF_INET, port, SVC_SOCK_ANONYMOUS);
68717908 707 if (err < 0)
37498292
CL
708 goto out_err;
709
786185b5 710 err = svc_create_xprt(nfsd_serv, transport, net,
37498292
CL
711 PF_INET6, port, SVC_SOCK_ANONYMOUS);
712 if (err < 0 && err != -EAFNOSUPPORT)
713 goto out_close;
0cd14a06
JL
714
715 /* Decrease the count, but don't shut down the service */
716 nfsd_serv->sv_nrthreads--;
4eb68c26 717 return 0;
37498292 718out_close:
786185b5 719 xprt = svc_find_xprt(nfsd_serv, transport, net, PF_INET, port);
37498292
CL
720 if (xprt != NULL) {
721 svc_close_xprt(xprt);
722 svc_xprt_put(xprt);
723 }
724out_err:
19f7e2ca 725 nfsd_destroy(net);
37498292 726 return err;
4eb68c26
CL
727}
728
bedbdd8b 729static ssize_t __write_ports(struct file *file, char *buf, size_t size)
80212d59 730{
0a5372d8
CL
731 if (size == 0)
732 return __write_ports_names(buf);
0b7c2f6f
CL
733
734 if (isdigit(buf[0]))
735 return __write_ports_addfd(buf);
82d56591 736
4eb68c26
CL
737 if (isalpha(buf[0]))
738 return __write_ports_addxprt(buf);
4cd5dc75 739
b41b66d6 740 return -EINVAL;
80212d59
N
741}
742
262a0982
CL
743/**
744 * write_ports - Pass a socket file descriptor or transport name to listen on
745 *
746 * Input:
747 * buf: ignored
748 * size: zero
749 * Output:
750 * On success: passed-in buffer filled with a '\n'-terminated C
751 * string containing a whitespace-separated list of
752 * named NFSD listeners;
753 * return code is the size in bytes of the string
754 * On error: return code is zero or a negative errno value
755 *
756 * OR
757 *
758 * Input:
759 * buf: C string containing an unsigned
760 * integer value representing a bound
761 * but unconnected socket that is to be
c71206a7
CL
762 * used as an NFSD listener; listen(3)
763 * must be called for a SOCK_STREAM
764 * socket, otherwise it is ignored
262a0982
CL
765 * size: non-zero length of C string in @buf
766 * Output:
767 * On success: NFS service is started;
768 * passed-in buffer filled with a '\n'-terminated C
769 * string containing a unique alphanumeric name of
770 * the listener;
771 * return code is the size in bytes of the string
772 * On error: return code is a negative errno value
773 *
774 * OR
775 *
776 * Input:
262a0982
CL
777 * buf: C string containing a transport
778 * name and an unsigned integer value
779 * representing the port to listen on,
780 * separated by whitespace
781 * size: non-zero length of C string in @buf
782 * Output:
783 * On success: returns zero; NFS service is started
784 * On error: return code is a negative errno value
262a0982 785 */
bedbdd8b
NB
786static ssize_t write_ports(struct file *file, char *buf, size_t size)
787{
788 ssize_t rv;
3dd98a3b 789
bedbdd8b
NB
790 mutex_lock(&nfsd_mutex);
791 rv = __write_ports(file, buf, size);
792 mutex_unlock(&nfsd_mutex);
793 return rv;
794}
795
796
596bbe53
N
797int nfsd_max_blksize;
798
262a0982
CL
799/**
800 * write_maxblksize - Set or report the current NFS blksize
801 *
802 * Input:
803 * buf: ignored
804 * size: zero
805 *
806 * OR
807 *
808 * Input:
809 * buf: C string containing an unsigned
810 * integer value representing the new
811 * NFS blksize
812 * size: non-zero length of C string in @buf
813 * Output:
814 * On success: passed-in buffer filled with '\n'-terminated C string
815 * containing numeric value of the current NFS blksize
816 * setting;
817 * return code is the size in bytes of the string
818 * On error: return code is zero or a negative errno value
819 */
596bbe53
N
820static ssize_t write_maxblksize(struct file *file, char *buf, size_t size)
821{
822 char *mesg = buf;
823 if (size > 0) {
824 int bsize;
825 int rv = get_int(&mesg, &bsize);
826 if (rv)
827 return rv;
828 /* force bsize into allowed range and
829 * required alignment.
830 */
831 if (bsize < 1024)
832 bsize = 1024;
833 if (bsize > NFSSVC_MAXBLKSIZE)
834 bsize = NFSSVC_MAXBLKSIZE;
835 bsize &= ~(1024-1);
bedbdd8b 836 mutex_lock(&nfsd_mutex);
7fa53cc8 837 if (nfsd_serv) {
bedbdd8b 838 mutex_unlock(&nfsd_mutex);
596bbe53
N
839 return -EBUSY;
840 }
841 nfsd_max_blksize = bsize;
bedbdd8b 842 mutex_unlock(&nfsd_mutex);
596bbe53 843 }
e06b6405
CL
844
845 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%d\n",
846 nfsd_max_blksize);
596bbe53
N
847}
848
70c3b76c 849#ifdef CONFIG_NFSD_V4
f0135740 850static ssize_t __nfsd4_write_time(struct file *file, char *buf, size_t size, time_t *time)
1da177e4 851{
1da177e4 852 char *mesg = buf;
f0135740 853 int rv, i;
1da177e4
LT
854
855 if (size > 0) {
3dd98a3b
JL
856 if (nfsd_serv)
857 return -EBUSY;
f0135740 858 rv = get_int(&mesg, &i);
1da177e4
LT
859 if (rv)
860 return rv;
e7b184f1
BF
861 /*
862 * Some sanity checking. We don't have a reason for
863 * these particular numbers, but problems with the
864 * extremes are:
865 * - Too short: the briefest network outage may
866 * cause clients to lose all their locks. Also,
867 * the frequent polling may be wasteful.
868 * - Too long: do you really want reboot recovery
869 * to take more than an hour? Or to make other
870 * clients wait an hour before being able to
871 * revoke a dead client's locks?
872 */
f0135740 873 if (i < 10 || i > 3600)
1da177e4 874 return -EINVAL;
f0135740 875 *time = i;
1da177e4 876 }
e06b6405 877
f0135740
BF
878 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%ld\n", *time);
879}
880
881static ssize_t nfsd4_write_time(struct file *file, char *buf, size_t size, time_t *time)
882{
883 ssize_t rv;
884
885 mutex_lock(&nfsd_mutex);
886 rv = __nfsd4_write_time(file, buf, size, time);
887 mutex_unlock(&nfsd_mutex);
888 return rv;
1da177e4
LT
889}
890
262a0982
CL
891/**
892 * write_leasetime - Set or report the current NFSv4 lease time
893 *
894 * Input:
895 * buf: ignored
896 * size: zero
897 *
898 * OR
899 *
900 * Input:
901 * buf: C string containing an unsigned
902 * integer value representing the new
903 * NFSv4 lease expiry time
904 * size: non-zero length of C string in @buf
905 * Output:
906 * On success: passed-in buffer filled with '\n'-terminated C
907 * string containing unsigned integer value of the
908 * current lease expiry time;
909 * return code is the size in bytes of the string
910 * On error: return code is zero or a negative errno value
911 */
3dd98a3b
JL
912static ssize_t write_leasetime(struct file *file, char *buf, size_t size)
913{
3d733711
SK
914 struct nfsd_net *nn = net_generic(&init_net, nfsd_net_id);
915 return nfsd4_write_time(file, buf, size, &nn->nfsd4_lease);
3dd98a3b
JL
916}
917
efc4bb4f
BF
918/**
919 * write_gracetime - Set or report current NFSv4 grace period time
920 *
921 * As above, but sets the time of the NFSv4 grace period.
922 *
923 * Note this should never be set to less than the *previous*
924 * lease-period time, but we don't try to enforce this. (In the common
925 * case (a new boot), we don't know what the previous lease time was
926 * anyway.)
927 */
928static ssize_t write_gracetime(struct file *file, char *buf, size_t size)
929{
5284b44e
SK
930 struct nfsd_net *nn = net_generic(&init_net, nfsd_net_id);
931 return nfsd4_write_time(file, buf, size, &nn->nfsd4_grace);
efc4bb4f
BF
932}
933
3dd98a3b 934static ssize_t __write_recoverydir(struct file *file, char *buf, size_t size)
0964a3d3
N
935{
936 char *mesg = buf;
937 char *recdir;
938 int len, status;
939
3dd98a3b
JL
940 if (size > 0) {
941 if (nfsd_serv)
942 return -EBUSY;
943 if (size > PATH_MAX || buf[size-1] != '\n')
944 return -EINVAL;
945 buf[size-1] = 0;
0964a3d3 946
3dd98a3b
JL
947 recdir = mesg;
948 len = qword_get(&mesg, recdir, size);
949 if (len <= 0)
950 return -EINVAL;
0964a3d3 951
3dd98a3b 952 status = nfs4_reset_recoverydir(recdir);
69049961
AK
953 if (status)
954 return status;
3dd98a3b 955 }
3d72ab8f
CL
956
957 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%s\n",
958 nfs4_recoverydir());
0964a3d3 959}
3dd98a3b 960
262a0982
CL
961/**
962 * write_recoverydir - Set or report the pathname of the recovery directory
963 *
964 * Input:
965 * buf: ignored
966 * size: zero
967 *
968 * OR
969 *
970 * Input:
971 * buf: C string containing the pathname
972 * of the directory on a local file
973 * system containing permanent NFSv4
974 * recovery data
975 * size: non-zero length of C string in @buf
976 * Output:
977 * On success: passed-in buffer filled with '\n'-terminated C string
978 * containing the current recovery pathname setting;
979 * return code is the size in bytes of the string
980 * On error: return code is zero or a negative errno value
981 */
3dd98a3b
JL
982static ssize_t write_recoverydir(struct file *file, char *buf, size_t size)
983{
984 ssize_t rv;
985
986 mutex_lock(&nfsd_mutex);
987 rv = __write_recoverydir(file, buf, size);
988 mutex_unlock(&nfsd_mutex);
989 return rv;
990}
991
70c3b76c 992#endif
0964a3d3 993
1da177e4
LT
994/*----------------------------------------------------------------------------*/
995/*
996 * populating the filesystem.
997 */
998
999static int nfsd_fill_super(struct super_block * sb, void * data, int silent)
1000{
1001 static struct tree_descr nfsd_files[] = {
1da177e4 1002 [NFSD_List] = {"exports", &exports_operations, S_IRUGO},
e8e8753f
BF
1003 [NFSD_Export_features] = {"export_features",
1004 &export_features_operations, S_IRUGO},
4373ea84
WC
1005 [NFSD_FO_UnlockIP] = {"unlock_ip",
1006 &transaction_ops, S_IWUSR|S_IRUSR},
17efa372
WC
1007 [NFSD_FO_UnlockFS] = {"unlock_filesystem",
1008 &transaction_ops, S_IWUSR|S_IRUSR},
1da177e4
LT
1009 [NFSD_Fh] = {"filehandle", &transaction_ops, S_IWUSR|S_IRUSR},
1010 [NFSD_Threads] = {"threads", &transaction_ops, S_IWUSR|S_IRUSR},
eed2965a 1011 [NFSD_Pool_Threads] = {"pool_threads", &transaction_ops, S_IWUSR|S_IRUSR},
03cf6c9f 1012 [NFSD_Pool_Stats] = {"pool_stats", &pool_stats_operations, S_IRUGO},
70c3b76c 1013 [NFSD_Versions] = {"versions", &transaction_ops, S_IWUSR|S_IRUSR},
80212d59 1014 [NFSD_Ports] = {"portlist", &transaction_ops, S_IWUSR|S_IRUGO},
596bbe53 1015 [NFSD_MaxBlkSize] = {"max_block_size", &transaction_ops, S_IWUSR|S_IRUGO},
b084f598 1016#if defined(CONFIG_SUNRPC_GSS) || defined(CONFIG_SUNRPC_GSS_MODULE)
b0b0c0a2 1017 [NFSD_SupportedEnctypes] = {"supported_krb5_enctypes", &supported_enctypes_ops, S_IRUGO},
b084f598 1018#endif /* CONFIG_SUNRPC_GSS or CONFIG_SUNRPC_GSS_MODULE */
1da177e4
LT
1019#ifdef CONFIG_NFSD_V4
1020 [NFSD_Leasetime] = {"nfsv4leasetime", &transaction_ops, S_IWUSR|S_IRUSR},
efc4bb4f 1021 [NFSD_Gracetime] = {"nfsv4gracetime", &transaction_ops, S_IWUSR|S_IRUSR},
0964a3d3 1022 [NFSD_RecoveryDir] = {"nfsv4recoverydir", &transaction_ops, S_IWUSR|S_IRUSR},
1da177e4
LT
1023#endif
1024 /* last one */ {""}
1025 };
1026 return simple_fill_super(sb, 0x6e667364, nfsd_files);
1027}
1028
fc14f2fe
AV
1029static struct dentry *nfsd_mount(struct file_system_type *fs_type,
1030 int flags, const char *dev_name, void *data)
1da177e4 1031{
fc14f2fe 1032 return mount_single(fs_type, flags, data, nfsd_fill_super);
1da177e4
LT
1033}
1034
1035static struct file_system_type nfsd_fs_type = {
1036 .owner = THIS_MODULE,
1037 .name = "nfsd",
fc14f2fe 1038 .mount = nfsd_mount,
1da177e4
LT
1039 .kill_sb = kill_litter_super,
1040};
1041
e331f606
BF
1042#ifdef CONFIG_PROC_FS
1043static int create_proc_exports_entry(void)
1044{
1045 struct proc_dir_entry *entry;
1046
1047 entry = proc_mkdir("fs/nfs", NULL);
1048 if (!entry)
1049 return -ENOMEM;
9ef2db26 1050 entry = proc_create("exports", 0, entry, &exports_operations);
e331f606
BF
1051 if (!entry)
1052 return -ENOMEM;
e331f606
BF
1053 return 0;
1054}
1055#else /* CONFIG_PROC_FS */
1056static int create_proc_exports_entry(void)
1057{
1058 return 0;
1059}
1060#endif
1061
7ea34ac1 1062int nfsd_net_id;
5717e012
SK
1063
1064static __net_init int nfsd_init_net(struct net *net)
1065{
1066 int retval;
3d733711 1067 struct nfsd_net *nn = net_generic(net, nfsd_net_id);
5717e012
SK
1068
1069 retval = nfsd_export_init(net);
1070 if (retval)
1071 goto out_export_error;
f69adb2f
SK
1072 retval = nfsd_idmap_init(net);
1073 if (retval)
1074 goto out_idmap_error;
3d733711 1075 nn->nfsd4_lease = 90; /* default lease time */
5284b44e 1076 nn->nfsd4_grace = 90;
5717e012
SK
1077 return 0;
1078
f69adb2f
SK
1079out_idmap_error:
1080 nfsd_export_shutdown(net);
5717e012
SK
1081out_export_error:
1082 return retval;
1083}
1084
1085static __net_exit void nfsd_exit_net(struct net *net)
1086{
f69adb2f 1087 nfsd_idmap_shutdown(net);
5717e012
SK
1088 nfsd_export_shutdown(net);
1089}
1090
7ea34ac1 1091static struct pernet_operations nfsd_net_ops = {
5717e012
SK
1092 .init = nfsd_init_net,
1093 .exit = nfsd_exit_net,
7ea34ac1
JL
1094 .id = &nfsd_net_id,
1095 .size = sizeof(struct nfsd_net),
1096};
1097
1da177e4
LT
1098static int __init init_nfsd(void)
1099{
1100 int retval;
1101 printk(KERN_INFO "Installing knfsd (copyright (C) 1996 okir@monad.swb.de).\n");
1102
797a9d79 1103 retval = register_cld_notifier();
813fd320
JL
1104 if (retval)
1105 return retval;
7ea34ac1
JL
1106 retval = register_pernet_subsys(&nfsd_net_ops);
1107 if (retval < 0)
813fd320 1108 goto out_unregister_notifier;
72083396 1109 retval = nfsd4_init_slabs();
e8ff2a84 1110 if (retval)
7ea34ac1 1111 goto out_unregister_pernet;
72083396 1112 nfs4_state_init();
65178db4
BS
1113 retval = nfsd_fault_inject_init(); /* nfsd fault injection controls */
1114 if (retval)
1115 goto out_free_slabs;
1da177e4 1116 nfsd_stat_init(); /* Statistics */
d5c3428b
BF
1117 retval = nfsd_reply_cache_init();
1118 if (retval)
1119 goto out_free_stat;
1da177e4 1120 nfsd_lockd_init(); /* lockd->nfsd callbacks */
e331f606
BF
1121 retval = create_proc_exports_entry();
1122 if (retval)
f69adb2f 1123 goto out_free_lockd;
1da177e4 1124 retval = register_filesystem(&nfsd_fs_type);
26808d3f
BF
1125 if (retval)
1126 goto out_free_all;
1127 return 0;
1128out_free_all:
26808d3f
BF
1129 remove_proc_entry("fs/nfs/exports", NULL);
1130 remove_proc_entry("fs/nfs", NULL);
dbf847ec 1131out_free_lockd:
26808d3f 1132 nfsd_lockd_shutdown();
e331f606 1133 nfsd_reply_cache_shutdown();
d5c3428b
BF
1134out_free_stat:
1135 nfsd_stat_shutdown();
65178db4
BS
1136 nfsd_fault_inject_cleanup();
1137out_free_slabs:
26808d3f 1138 nfsd4_free_slabs();
7ea34ac1
JL
1139out_unregister_pernet:
1140 unregister_pernet_subsys(&nfsd_net_ops);
813fd320 1141out_unregister_notifier:
797a9d79 1142 unregister_cld_notifier();
1da177e4
LT
1143 return retval;
1144}
1145
1146static void __exit exit_nfsd(void)
1147{
d5c3428b 1148 nfsd_reply_cache_shutdown();
1da177e4
LT
1149 remove_proc_entry("fs/nfs/exports", NULL);
1150 remove_proc_entry("fs/nfs", NULL);
1151 nfsd_stat_shutdown();
1152 nfsd_lockd_shutdown();
e8ff2a84 1153 nfsd4_free_slabs();
65178db4 1154 nfsd_fault_inject_cleanup();
1da177e4 1155 unregister_filesystem(&nfsd_fs_type);
7ea34ac1 1156 unregister_pernet_subsys(&nfsd_net_ops);
797a9d79 1157 unregister_cld_notifier();
1da177e4
LT
1158}
1159
1160MODULE_AUTHOR("Olaf Kirch <okir@monad.swb.de>");
1161MODULE_LICENSE("GPL");
1162module_init(init_nfsd)
1163module_exit(exit_nfsd)
This page took 0.6478 seconds and 5 git commands to generate.