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