1 // SPDX-License-Identifier: GPL-2.0-only
3 * Syscall interface to knfsd.
5 * Copyright (C) 1995, 1996 Olaf Kirch <okir@monad.swb.de>
8 #include <linux/slab.h>
9 #include <linux/namei.h>
10 #include <linux/ctype.h>
12 #include <linux/sunrpc/svcsock.h>
13 #include <linux/lockd/lockd.h>
14 #include <linux/sunrpc/addr.h>
15 #include <linux/sunrpc/gss_api.h>
16 #include <linux/sunrpc/gss_krb5_enctypes.h>
17 #include <linux/sunrpc/rpc_pipe_fs.h>
18 #include <linux/module.h>
19 #include <linux/fsnotify.h>
29 * We have a single directory with several nodes in it.
41 NFSD_Reply_Cache_Stats,
46 NFSD_SupportedEnctypes,
48 * The below MUST come last. Otherwise we leave a hole in nfsd_files[]
49 * with !CONFIG_NFSD_V4 and simple_fill_super() goes oops
61 * write() for these nodes.
63 static ssize_t write_filehandle(struct file *file, char *buf, size_t size);
64 static ssize_t write_unlock_ip(struct file *file, char *buf, size_t size);
65 static ssize_t write_unlock_fs(struct file *file, char *buf, size_t size);
66 static ssize_t write_threads(struct file *file, char *buf, size_t size);
67 static ssize_t write_pool_threads(struct file *file, char *buf, size_t size);
68 static ssize_t write_versions(struct file *file, char *buf, size_t size);
69 static ssize_t write_ports(struct file *file, char *buf, size_t size);
70 static ssize_t write_maxblksize(struct file *file, char *buf, size_t size);
71 static ssize_t write_maxconn(struct file *file, char *buf, size_t size);
73 static ssize_t write_leasetime(struct file *file, char *buf, size_t size);
74 static ssize_t write_gracetime(struct file *file, char *buf, size_t size);
75 static ssize_t write_recoverydir(struct file *file, char *buf, size_t size);
76 static ssize_t write_v4_end_grace(struct file *file, char *buf, size_t size);
79 static ssize_t (*const write_op[])(struct file *, char *, size_t) = {
80 [NFSD_Fh] = write_filehandle,
81 [NFSD_FO_UnlockIP] = write_unlock_ip,
82 [NFSD_FO_UnlockFS] = write_unlock_fs,
83 [NFSD_Threads] = write_threads,
84 [NFSD_Pool_Threads] = write_pool_threads,
85 [NFSD_Versions] = write_versions,
86 [NFSD_Ports] = write_ports,
87 [NFSD_MaxBlkSize] = write_maxblksize,
88 [NFSD_MaxConnections] = write_maxconn,
90 [NFSD_Leasetime] = write_leasetime,
91 [NFSD_Gracetime] = write_gracetime,
92 [NFSD_RecoveryDir] = write_recoverydir,
93 [NFSD_V4EndGrace] = write_v4_end_grace,
97 static ssize_t nfsctl_transaction_write(struct file *file, const char __user *buf, size_t size, loff_t *pos)
99 ino_t ino = file_inode(file)->i_ino;
103 if (ino >= ARRAY_SIZE(write_op) || !write_op[ino])
106 data = simple_transaction_get(file, buf, size);
108 return PTR_ERR(data);
110 rv = write_op[ino](file, data, size);
112 simple_transaction_set(file, rv);
118 static ssize_t nfsctl_transaction_read(struct file *file, char __user *buf, size_t size, loff_t *pos)
120 if (! file->private_data) {
121 /* An attempt to read a transaction file without writing
122 * causes a 0-byte write so that the file can return
125 ssize_t rv = nfsctl_transaction_write(file, buf, 0, pos);
129 return simple_transaction_read(file, buf, size, pos);
132 static const struct file_operations transaction_ops = {
133 .write = nfsctl_transaction_write,
134 .read = nfsctl_transaction_read,
135 .release = simple_transaction_release,
136 .llseek = default_llseek,
139 static int exports_net_open(struct net *net, struct file *file)
142 struct seq_file *seq;
143 struct nfsd_net *nn = net_generic(net, nfsd_net_id);
145 err = seq_open(file, &nfs_exports_op);
149 seq = file->private_data;
150 seq->private = nn->svc_export_cache;
154 static int exports_proc_open(struct inode *inode, struct file *file)
156 return exports_net_open(current->nsproxy->net_ns, file);
159 static const struct file_operations exports_proc_operations = {
160 .open = exports_proc_open,
163 .release = seq_release,
166 static int exports_nfsd_open(struct inode *inode, struct file *file)
168 return exports_net_open(inode->i_sb->s_fs_info, file);
171 static const struct file_operations exports_nfsd_operations = {
172 .open = exports_nfsd_open,
175 .release = seq_release,
178 static int export_features_show(struct seq_file *m, void *v)
180 seq_printf(m, "0x%x 0x%x\n", NFSEXP_ALLFLAGS, NFSEXP_SECINFO_FLAGS);
184 static int export_features_open(struct inode *inode, struct file *file)
186 return single_open(file, export_features_show, NULL);
189 static const struct file_operations export_features_operations = {
190 .open = export_features_open,
193 .release = single_release,
196 #if defined(CONFIG_SUNRPC_GSS) || defined(CONFIG_SUNRPC_GSS_MODULE)
197 static int supported_enctypes_show(struct seq_file *m, void *v)
199 seq_printf(m, KRB5_SUPPORTED_ENCTYPES);
203 static int supported_enctypes_open(struct inode *inode, struct file *file)
205 return single_open(file, supported_enctypes_show, NULL);
208 static const struct file_operations supported_enctypes_ops = {
209 .open = supported_enctypes_open,
212 .release = single_release,
214 #endif /* CONFIG_SUNRPC_GSS or CONFIG_SUNRPC_GSS_MODULE */
216 static const struct file_operations pool_stats_operations = {
217 .open = nfsd_pool_stats_open,
220 .release = nfsd_pool_stats_release,
223 static const struct file_operations reply_cache_stats_operations = {
224 .open = nfsd_reply_cache_stats_open,
227 .release = single_release,
230 /*----------------------------------------------------------------------------*/
232 * payload - write methods
235 static inline struct net *netns(struct file *file)
237 return file_inode(file)->i_sb->s_fs_info;
241 * write_unlock_ip - Release all locks used by a client
246 * buf: '\n'-terminated C string containing a
247 * presentation format IP address
248 * size: length of C string in @buf
250 * On success: returns zero if all specified locks were released;
251 * returns one if one or more locks were not released
252 * On error: return code is negative errno value
254 static ssize_t write_unlock_ip(struct file *file, char *buf, size_t size)
256 struct sockaddr_storage address;
257 struct sockaddr *sap = (struct sockaddr *)&address;
258 size_t salen = sizeof(address);
260 struct net *net = netns(file);
266 if (buf[size-1] != '\n')
270 if (qword_get(&buf, fo_path, size) < 0)
273 if (rpc_pton(net, fo_path, size, sap, salen) == 0)
276 return nlmsvc_unlock_all_by_ip(sap);
280 * write_unlock_fs - Release all locks on a local file system
285 * buf: '\n'-terminated C string containing the
286 * absolute pathname of a local file system
287 * size: length of C string in @buf
289 * On success: returns zero if all specified locks were released;
290 * returns one if one or more locks were not released
291 * On error: return code is negative errno value
293 static ssize_t write_unlock_fs(struct file *file, char *buf, size_t size)
303 if (buf[size-1] != '\n')
307 if (qword_get(&buf, fo_path, size) < 0)
310 error = kern_path(fo_path, 0, &path);
315 * XXX: Needs better sanity checking. Otherwise we could end up
316 * releasing locks on the wrong file system.
319 * 1. Does the path refer to a directory?
320 * 2. Is that directory a mount point, or
321 * 3. Is that directory the root of an exported file system?
323 error = nlmsvc_unlock_all_by_sb(path.dentry->d_sb);
330 * write_filehandle - Get a variable-length NFS file handle by path
332 * On input, the buffer contains a '\n'-terminated C string comprised of
333 * three alphanumeric words separated by whitespace. The string may
334 * contain escape sequences.
338 * domain: client domain name
339 * path: export pathname
340 * maxsize: numeric maximum size of
342 * size: length of C string in @buf
344 * On success: passed-in buffer filled with '\n'-terminated C
345 * string containing a ASCII hex text version
346 * of the NFS file handle;
347 * return code is the size in bytes of the string
348 * On error: return code is negative errno value
350 static ssize_t write_filehandle(struct file *file, char *buf, size_t size)
353 int uninitialized_var(maxsize);
356 struct auth_domain *dom;
362 if (buf[size-1] != '\n')
367 len = qword_get(&mesg, dname, size);
372 len = qword_get(&mesg, path, size);
376 len = get_int(&mesg, &maxsize);
380 if (maxsize < NFS_FHSIZE)
382 maxsize = min(maxsize, NFS3_FHSIZE);
384 if (qword_get(&mesg, mesg, size)>0)
387 /* we have all the words, they are in buf.. */
388 dom = unix_domain_find(dname);
392 len = exp_rootfh(netns(file), dom, path, &fh, maxsize);
393 auth_domain_put(dom);
398 len = SIMPLE_TRANSACTION_LIMIT;
399 qword_addhex(&mesg, &len, (char*)&fh.fh_base, fh.fh_size);
405 * write_threads - Start NFSD, or report the current number of running threads
411 * On success: passed-in buffer filled with '\n'-terminated C
412 * string numeric value representing the number of
413 * running NFSD threads;
414 * return code is the size in bytes of the string
415 * On error: return code is zero
420 * buf: C string containing an unsigned
421 * integer value representing the
422 * number of NFSD threads to start
423 * size: non-zero length of C string in @buf
425 * On success: NFS service is started;
426 * passed-in buffer filled with '\n'-terminated C
427 * string numeric value representing the number of
428 * running NFSD threads;
429 * return code is the size in bytes of the string
430 * On error: return code is zero or a negative errno value
432 static ssize_t write_threads(struct file *file, char *buf, size_t size)
436 struct net *net = netns(file);
440 rv = get_int(&mesg, &newthreads);
445 rv = nfsd_svc(newthreads, net, file->f_cred);
449 rv = nfsd_nrthreads(net);
451 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%d\n", rv);
455 * write_pool_threads - Set or report the current number of threads per pool
464 * buf: C string containing whitespace-
465 * separated unsigned integer values
466 * representing the number of NFSD
467 * threads to start in each pool
468 * size: non-zero length of C string in @buf
470 * On success: passed-in buffer filled with '\n'-terminated C
471 * string containing integer values representing the
472 * number of NFSD threads in each pool;
473 * return code is the size in bytes of the string
474 * On error: return code is zero or a negative errno value
476 static ssize_t write_pool_threads(struct file *file, char *buf, size_t size)
478 /* if size > 0, look for an array of number of threads per node
479 * and apply them then write out number of threads per node as reply
487 struct net *net = netns(file);
489 mutex_lock(&nfsd_mutex);
490 npools = nfsd_nrpools(net);
493 * NFS is shut down. The admin can start it by
494 * writing to the threads file but NOT the pool_threads
495 * file, sorry. Report zero threads.
497 mutex_unlock(&nfsd_mutex);
502 nthreads = kcalloc(npools, sizeof(int), GFP_KERNEL);
504 if (nthreads == NULL)
508 for (i = 0; i < npools; i++) {
509 rv = get_int(&mesg, &nthreads[i]);
511 break; /* fewer numbers than pools */
513 goto out_free; /* syntax error */
518 rv = nfsd_set_nrthreads(i, nthreads, net);
523 rv = nfsd_get_nrthreads(npools, nthreads, net);
528 size = SIMPLE_TRANSACTION_LIMIT;
529 for (i = 0; i < npools && size > 0; i++) {
530 snprintf(mesg, size, "%d%c", nthreads[i], (i == npools-1 ? '\n' : ' '));
538 mutex_unlock(&nfsd_mutex);
543 nfsd_print_version_support(struct nfsd_net *nn, char *buf, int remaining,
544 const char *sep, unsigned vers, int minor)
546 const char *format = minor < 0 ? "%s%c%u" : "%s%c%u.%u";
547 bool supported = !!nfsd_vers(nn, vers, NFSD_TEST);
549 if (vers == 4 && minor >= 0 &&
550 !nfsd_minorversion(nn, minor, NFSD_TEST))
552 if (minor == 0 && supported)
554 * special case for backward compatability.
555 * +4.0 is never reported, it is implied by
556 * +4, unless -4.0 is present.
559 return snprintf(buf, remaining, format, sep,
560 supported ? '+' : '-', vers, minor);
563 static ssize_t __write_versions(struct file *file, char *buf, size_t size)
566 char *vers, *minorp, sign;
567 int len, num, remaining;
570 struct nfsd_net *nn = net_generic(netns(file), nfsd_net_id);
574 /* Cannot change versions without updating
575 * nn->nfsd_serv->sv_xdrsize, and reallocing
576 * rq_argp and rq_resp
579 if (buf[size-1] != '\n')
584 len = qword_get(&mesg, vers, size);
585 if (len <= 0) return -EINVAL;
590 if (sign == '+' || sign == '-')
591 num = simple_strtol((vers+1), &minorp, 0);
593 num = simple_strtol(vers, &minorp, 0);
594 if (*minorp == '.') {
597 if (kstrtouint(minorp+1, 0, &minor) < 0)
601 cmd = sign == '-' ? NFSD_CLEAR : NFSD_SET;
605 nfsd_vers(nn, num, cmd);
608 if (*minorp == '.') {
609 if (nfsd_minorversion(nn, minor, cmd) < 0)
611 } else if ((cmd == NFSD_SET) != nfsd_vers(nn, num, NFSD_TEST)) {
613 * Either we have +4 and no minors are enabled,
614 * or we have -4 and at least one minor is enabled.
615 * In either case, propagate 'cmd' to all minors.
618 while (nfsd_minorversion(nn, minor, cmd) >= 0)
626 } while ((len = qword_get(&mesg, vers, size)) > 0);
627 /* If all get turned off, turn them back on, as
628 * having no versions is BAD
630 nfsd_reset_versions(nn);
633 /* Now write current state into reply buffer */
636 remaining = SIMPLE_TRANSACTION_LIMIT;
637 for (num=2 ; num <= 4 ; num++) {
639 if (!nfsd_vers(nn, num, NFSD_AVAIL))
644 len = nfsd_print_version_support(nn, buf, remaining,
646 if (len >= remaining)
654 } while (num == 4 && minor <= NFSD_SUPPORTED_MINOR_VERSION);
657 len = snprintf(buf, remaining, "\n");
658 if (len >= remaining)
664 * write_versions - Set or report the available NFS protocol versions
670 * On success: passed-in buffer filled with '\n'-terminated C
671 * string containing positive or negative integer
672 * values representing the current status of each
674 * return code is the size in bytes of the string
675 * On error: return code is zero or a negative errno value
680 * buf: C string containing whitespace-
681 * separated positive or negative
682 * integer values representing NFS
683 * protocol versions to enable ("+n")
685 * size: non-zero length of C string in @buf
687 * On success: status of zero or more protocol versions has
688 * been updated; passed-in buffer filled with
689 * '\n'-terminated C string containing positive
690 * or negative integer values representing the
691 * current status of each protocol version;
692 * return code is the size in bytes of the string
693 * On error: return code is zero or a negative errno value
695 static ssize_t write_versions(struct file *file, char *buf, size_t size)
699 mutex_lock(&nfsd_mutex);
700 rv = __write_versions(file, buf, size);
701 mutex_unlock(&nfsd_mutex);
706 * Zero-length write. Return a list of NFSD's current listener
709 static ssize_t __write_ports_names(char *buf, struct net *net)
711 struct nfsd_net *nn = net_generic(net, nfsd_net_id);
713 if (nn->nfsd_serv == NULL)
715 return svc_xprt_names(nn->nfsd_serv, buf, SIMPLE_TRANSACTION_LIMIT);
719 * A single 'fd' number was written, in which case it must be for
720 * a socket of a supported family/protocol, and we use it as an
723 static ssize_t __write_ports_addfd(char *buf, struct net *net, const struct cred *cred)
727 struct nfsd_net *nn = net_generic(net, nfsd_net_id);
729 err = get_int(&mesg, &fd);
730 if (err != 0 || fd < 0)
733 if (svc_alien_sock(net, fd)) {
734 printk(KERN_ERR "%s: socket net is different to NFSd's one\n", __func__);
738 err = nfsd_create_serv(net);
742 err = svc_addsock(nn->nfsd_serv, fd, buf, SIMPLE_TRANSACTION_LIMIT, cred);
748 /* Decrease the count, but don't shut down the service */
749 nn->nfsd_serv->sv_nrthreads--;
754 * A transport listener is added by writing it's transport name and
757 static ssize_t __write_ports_addxprt(char *buf, struct net *net, const struct cred *cred)
760 struct svc_xprt *xprt;
762 struct nfsd_net *nn = net_generic(net, nfsd_net_id);
764 if (sscanf(buf, "%15s %5u", transport, &port) != 2)
767 if (port < 1 || port > USHRT_MAX)
770 err = nfsd_create_serv(net);
774 err = svc_create_xprt(nn->nfsd_serv, transport, net,
775 PF_INET, port, SVC_SOCK_ANONYMOUS, cred);
779 err = svc_create_xprt(nn->nfsd_serv, transport, net,
780 PF_INET6, port, SVC_SOCK_ANONYMOUS, cred);
781 if (err < 0 && err != -EAFNOSUPPORT)
784 /* Decrease the count, but don't shut down the service */
785 nn->nfsd_serv->sv_nrthreads--;
788 xprt = svc_find_xprt(nn->nfsd_serv, transport, net, PF_INET, port);
790 svc_close_xprt(xprt);
798 static ssize_t __write_ports(struct file *file, char *buf, size_t size,
802 return __write_ports_names(buf, net);
805 return __write_ports_addfd(buf, net, file->f_cred);
808 return __write_ports_addxprt(buf, net, file->f_cred);
814 * write_ports - Pass a socket file descriptor or transport name to listen on
820 * On success: passed-in buffer filled with a '\n'-terminated C
821 * string containing a whitespace-separated list of
822 * named NFSD listeners;
823 * return code is the size in bytes of the string
824 * On error: return code is zero or a negative errno value
829 * buf: C string containing an unsigned
830 * integer value representing a bound
831 * but unconnected socket that is to be
832 * used as an NFSD listener; listen(3)
833 * must be called for a SOCK_STREAM
834 * socket, otherwise it is ignored
835 * size: non-zero length of C string in @buf
837 * On success: NFS service is started;
838 * passed-in buffer filled with a '\n'-terminated C
839 * string containing a unique alphanumeric name of
841 * return code is the size in bytes of the string
842 * On error: return code is a negative errno value
847 * buf: C string containing a transport
848 * name and an unsigned integer value
849 * representing the port to listen on,
850 * separated by whitespace
851 * size: non-zero length of C string in @buf
853 * On success: returns zero; NFS service is started
854 * On error: return code is a negative errno value
856 static ssize_t write_ports(struct file *file, char *buf, size_t size)
860 mutex_lock(&nfsd_mutex);
861 rv = __write_ports(file, buf, size, netns(file));
862 mutex_unlock(&nfsd_mutex);
867 int nfsd_max_blksize;
870 * write_maxblksize - Set or report the current NFS blksize
879 * buf: C string containing an unsigned
880 * integer value representing the new
882 * size: non-zero length of C string in @buf
884 * On success: passed-in buffer filled with '\n'-terminated C string
885 * containing numeric value of the current NFS blksize
887 * return code is the size in bytes of the string
888 * On error: return code is zero or a negative errno value
890 static ssize_t write_maxblksize(struct file *file, char *buf, size_t size)
893 struct nfsd_net *nn = net_generic(netns(file), nfsd_net_id);
897 int rv = get_int(&mesg, &bsize);
900 /* force bsize into allowed range and
901 * required alignment.
903 bsize = max_t(int, bsize, 1024);
904 bsize = min_t(int, bsize, NFSSVC_MAXBLKSIZE);
906 mutex_lock(&nfsd_mutex);
908 mutex_unlock(&nfsd_mutex);
911 nfsd_max_blksize = bsize;
912 mutex_unlock(&nfsd_mutex);
915 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%d\n",
920 * write_maxconn - Set or report the current max number of connections
928 * buf: C string containing an unsigned
929 * integer value representing the new
930 * number of max connections
931 * size: non-zero length of C string in @buf
933 * On success: passed-in buffer filled with '\n'-terminated C string
934 * containing numeric value of max_connections setting
935 * for this net namespace;
936 * return code is the size in bytes of the string
937 * On error: return code is zero or a negative errno value
939 static ssize_t write_maxconn(struct file *file, char *buf, size_t size)
942 struct nfsd_net *nn = net_generic(netns(file), nfsd_net_id);
943 unsigned int maxconn = nn->max_connections;
946 int rv = get_uint(&mesg, &maxconn);
950 nn->max_connections = maxconn;
953 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%u\n", maxconn);
956 #ifdef CONFIG_NFSD_V4
957 static ssize_t __nfsd4_write_time(struct file *file, char *buf, size_t size,
958 time_t *time, struct nfsd_net *nn)
966 rv = get_int(&mesg, &i);
970 * Some sanity checking. We don't have a reason for
971 * these particular numbers, but problems with the
973 * - Too short: the briefest network outage may
974 * cause clients to lose all their locks. Also,
975 * the frequent polling may be wasteful.
976 * - Too long: do you really want reboot recovery
977 * to take more than an hour? Or to make other
978 * clients wait an hour before being able to
979 * revoke a dead client's locks?
981 if (i < 10 || i > 3600)
986 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%ld\n", *time);
989 static ssize_t nfsd4_write_time(struct file *file, char *buf, size_t size,
990 time_t *time, struct nfsd_net *nn)
994 mutex_lock(&nfsd_mutex);
995 rv = __nfsd4_write_time(file, buf, size, time, nn);
996 mutex_unlock(&nfsd_mutex);
1001 * write_leasetime - Set or report the current NFSv4 lease time
1010 * buf: C string containing an unsigned
1011 * integer value representing the new
1012 * NFSv4 lease expiry time
1013 * size: non-zero length of C string in @buf
1015 * On success: passed-in buffer filled with '\n'-terminated C
1016 * string containing unsigned integer value of the
1017 * current lease expiry time;
1018 * return code is the size in bytes of the string
1019 * On error: return code is zero or a negative errno value
1021 static ssize_t write_leasetime(struct file *file, char *buf, size_t size)
1023 struct nfsd_net *nn = net_generic(netns(file), nfsd_net_id);
1024 return nfsd4_write_time(file, buf, size, &nn->nfsd4_lease, nn);
1028 * write_gracetime - Set or report current NFSv4 grace period time
1030 * As above, but sets the time of the NFSv4 grace period.
1032 * Note this should never be set to less than the *previous*
1033 * lease-period time, but we don't try to enforce this. (In the common
1034 * case (a new boot), we don't know what the previous lease time was
1037 static ssize_t write_gracetime(struct file *file, char *buf, size_t size)
1039 struct nfsd_net *nn = net_generic(netns(file), nfsd_net_id);
1040 return nfsd4_write_time(file, buf, size, &nn->nfsd4_grace, nn);
1043 static ssize_t __write_recoverydir(struct file *file, char *buf, size_t size,
1044 struct nfsd_net *nn)
1053 if (size > PATH_MAX || buf[size-1] != '\n')
1058 len = qword_get(&mesg, recdir, size);
1062 status = nfs4_reset_recoverydir(recdir);
1067 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%s\n",
1068 nfs4_recoverydir());
1072 * write_recoverydir - Set or report the pathname of the recovery directory
1081 * buf: C string containing the pathname
1082 * of the directory on a local file
1083 * system containing permanent NFSv4
1085 * size: non-zero length of C string in @buf
1087 * On success: passed-in buffer filled with '\n'-terminated C string
1088 * containing the current recovery pathname setting;
1089 * return code is the size in bytes of the string
1090 * On error: return code is zero or a negative errno value
1092 static ssize_t write_recoverydir(struct file *file, char *buf, size_t size)
1095 struct nfsd_net *nn = net_generic(netns(file), nfsd_net_id);
1097 mutex_lock(&nfsd_mutex);
1098 rv = __write_recoverydir(file, buf, size, nn);
1099 mutex_unlock(&nfsd_mutex);
1104 * write_v4_end_grace - release grace period for nfsd's v4.x lock manager
1113 * size: non-zero length of C string in @buf
1115 * passed-in buffer filled with "Y" or "N" with a newline
1116 * and NULL-terminated C string. This indicates whether
1117 * the grace period has ended in the current net
1118 * namespace. Return code is the size in bytes of the
1119 * string. Writing a string that starts with 'Y', 'y', or
1120 * '1' to the file will end the grace period for nfsd's v4
1123 static ssize_t write_v4_end_grace(struct file *file, char *buf, size_t size)
1125 struct nfsd_net *nn = net_generic(netns(file), nfsd_net_id);
1134 nfsd4_end_grace(nn);
1141 return scnprintf(buf, SIMPLE_TRANSACTION_LIMIT, "%c\n",
1142 nn->grace_ended ? 'Y' : 'N');
1147 /*----------------------------------------------------------------------------*/
1149 * populating the filesystem.
1152 /* Basically copying rpc_get_inode. */
1153 static struct inode *nfsd_get_inode(struct super_block *sb, umode_t mode)
1155 struct inode *inode = new_inode(sb);
1158 /* Following advice from simple_fill_super documentation: */
1159 inode->i_ino = iunique(sb, NFSD_MaxReserved);
1160 inode->i_mode = mode;
1161 inode->i_atime = inode->i_mtime = inode->i_ctime = current_time(inode);
1162 switch (mode & S_IFMT) {
1164 inode->i_fop = &simple_dir_operations;
1165 inode->i_op = &simple_dir_inode_operations;
1173 static int __nfsd_mkdir(struct inode *dir, struct dentry *dentry, umode_t mode)
1175 struct inode *inode;
1177 inode = nfsd_get_inode(dir->i_sb, mode);
1180 d_add(dentry, inode);
1182 fsnotify_mkdir(dir, dentry);
1186 static struct dentry *nfsd_mkdir(struct dentry *parent, struct nfsdfs_client *ncl, char *name)
1188 struct inode *dir = parent->d_inode;
1189 struct dentry *dentry;
1193 dentry = d_alloc_name(parent, name);
1196 ret = __nfsd_mkdir(d_inode(parent), dentry, S_IFDIR | 0600);
1200 d_inode(dentry)->i_private = ncl;
1201 kref_get(&ncl->cl_ref);
1207 dentry = ERR_PTR(ret);
1211 static void clear_ncl(struct inode *inode)
1213 struct nfsdfs_client *ncl = inode->i_private;
1215 inode->i_private = NULL;
1217 kref_put(&ncl->cl_ref, ncl->cl_release);
1221 static struct nfsdfs_client *__get_nfsdfs_client(struct inode *inode)
1223 struct nfsdfs_client *nc = inode->i_private;
1226 kref_get(&nc->cl_ref);
1230 struct nfsdfs_client *get_nfsdfs_client(struct inode *inode)
1232 struct nfsdfs_client *nc;
1235 nc = __get_nfsdfs_client(inode);
1239 /* from __rpc_unlink */
1240 static void nfsdfs_remove_file(struct inode *dir, struct dentry *dentry)
1244 clear_ncl(d_inode(dentry));
1246 ret = simple_unlink(dir, dentry);
1252 static void nfsdfs_remove_files(struct dentry *root)
1254 struct dentry *dentry, *tmp;
1256 list_for_each_entry_safe(dentry, tmp, &root->d_subdirs, d_child) {
1257 if (!simple_positive(dentry)) {
1258 WARN_ON_ONCE(1); /* I think this can't happen? */
1261 nfsdfs_remove_file(d_inode(root), dentry);
1265 /* XXX: cut'n'paste from simple_fill_super; figure out if we could share
1267 static int nfsdfs_create_files(struct dentry *root,
1268 const struct tree_descr *files)
1270 struct inode *dir = d_inode(root);
1271 struct inode *inode;
1272 struct dentry *dentry;
1276 for (i = 0; files->name && files->name[0]; i++, files++) {
1279 dentry = d_alloc_name(root, files->name);
1282 inode = nfsd_get_inode(d_inode(root)->i_sb,
1283 S_IFREG | files->mode);
1288 inode->i_fop = files->ops;
1289 inode->i_private = __get_nfsdfs_client(dir);
1290 d_add(dentry, inode);
1291 fsnotify_create(dir, dentry);
1296 nfsdfs_remove_files(root);
1301 /* on success, returns positive number unique to that client. */
1302 struct dentry *nfsd_client_mkdir(struct nfsd_net *nn,
1303 struct nfsdfs_client *ncl, u32 id,
1304 const struct tree_descr *files)
1306 struct dentry *dentry;
1310 sprintf(name, "%u", id);
1312 dentry = nfsd_mkdir(nn->nfsd_client_dir, ncl, name);
1313 if (IS_ERR(dentry)) /* XXX: tossing errors? */
1315 ret = nfsdfs_create_files(dentry, files);
1317 nfsd_client_rmdir(dentry);
1323 /* Taken from __rpc_rmdir: */
1324 void nfsd_client_rmdir(struct dentry *dentry)
1326 struct inode *dir = d_inode(dentry->d_parent);
1327 struct inode *inode = d_inode(dentry);
1331 nfsdfs_remove_files(dentry);
1334 ret = simple_rmdir(dir, dentry);
1340 static int nfsd_fill_super(struct super_block * sb, void * data, int silent)
1342 struct nfsd_net *nn = net_generic(current->nsproxy->net_ns,
1344 struct dentry *dentry;
1347 static const struct tree_descr nfsd_files[] = {
1348 [NFSD_List] = {"exports", &exports_nfsd_operations, S_IRUGO},
1349 [NFSD_Export_features] = {"export_features",
1350 &export_features_operations, S_IRUGO},
1351 [NFSD_FO_UnlockIP] = {"unlock_ip",
1352 &transaction_ops, S_IWUSR|S_IRUSR},
1353 [NFSD_FO_UnlockFS] = {"unlock_filesystem",
1354 &transaction_ops, S_IWUSR|S_IRUSR},
1355 [NFSD_Fh] = {"filehandle", &transaction_ops, S_IWUSR|S_IRUSR},
1356 [NFSD_Threads] = {"threads", &transaction_ops, S_IWUSR|S_IRUSR},
1357 [NFSD_Pool_Threads] = {"pool_threads", &transaction_ops, S_IWUSR|S_IRUSR},
1358 [NFSD_Pool_Stats] = {"pool_stats", &pool_stats_operations, S_IRUGO},
1359 [NFSD_Reply_Cache_Stats] = {"reply_cache_stats", &reply_cache_stats_operations, S_IRUGO},
1360 [NFSD_Versions] = {"versions", &transaction_ops, S_IWUSR|S_IRUSR},
1361 [NFSD_Ports] = {"portlist", &transaction_ops, S_IWUSR|S_IRUGO},
1362 [NFSD_MaxBlkSize] = {"max_block_size", &transaction_ops, S_IWUSR|S_IRUGO},
1363 [NFSD_MaxConnections] = {"max_connections", &transaction_ops, S_IWUSR|S_IRUGO},
1364 #if defined(CONFIG_SUNRPC_GSS) || defined(CONFIG_SUNRPC_GSS_MODULE)
1365 [NFSD_SupportedEnctypes] = {"supported_krb5_enctypes", &supported_enctypes_ops, S_IRUGO},
1366 #endif /* CONFIG_SUNRPC_GSS or CONFIG_SUNRPC_GSS_MODULE */
1367 #ifdef CONFIG_NFSD_V4
1368 [NFSD_Leasetime] = {"nfsv4leasetime", &transaction_ops, S_IWUSR|S_IRUSR},
1369 [NFSD_Gracetime] = {"nfsv4gracetime", &transaction_ops, S_IWUSR|S_IRUSR},
1370 [NFSD_RecoveryDir] = {"nfsv4recoverydir", &transaction_ops, S_IWUSR|S_IRUSR},
1371 [NFSD_V4EndGrace] = {"v4_end_grace", &transaction_ops, S_IWUSR|S_IRUGO},
1375 get_net(sb->s_fs_info);
1376 ret = simple_fill_super(sb, 0x6e667364, nfsd_files);
1379 dentry = nfsd_mkdir(sb->s_root, NULL, "clients");
1381 return PTR_ERR(dentry);
1382 nn->nfsd_client_dir = dentry;
1387 static struct dentry *nfsd_mount(struct file_system_type *fs_type,
1388 int flags, const char *dev_name, void *data)
1390 struct net *net = current->nsproxy->net_ns;
1391 return mount_ns(fs_type, flags, data, net, net->user_ns, nfsd_fill_super);
1394 static void nfsd_umount(struct super_block *sb)
1396 struct net *net = sb->s_fs_info;
1398 kill_litter_super(sb);
1402 static struct file_system_type nfsd_fs_type = {
1403 .owner = THIS_MODULE,
1405 .mount = nfsd_mount,
1406 .kill_sb = nfsd_umount,
1408 MODULE_ALIAS_FS("nfsd");
1410 #ifdef CONFIG_PROC_FS
1411 static int create_proc_exports_entry(void)
1413 struct proc_dir_entry *entry;
1415 entry = proc_mkdir("fs/nfs", NULL);
1418 entry = proc_create("exports", 0, entry,
1419 &exports_proc_operations);
1421 remove_proc_entry("fs/nfs", NULL);
1426 #else /* CONFIG_PROC_FS */
1427 static int create_proc_exports_entry(void)
1433 unsigned int nfsd_net_id;
1435 static __net_init int nfsd_init_net(struct net *net)
1438 struct vfsmount *mnt;
1439 struct nfsd_net *nn = net_generic(net, nfsd_net_id);
1441 retval = nfsd_export_init(net);
1443 goto out_export_error;
1444 retval = nfsd_idmap_init(net);
1446 goto out_idmap_error;
1447 nn->nfsd_versions = NULL;
1448 nn->nfsd4_minorversions = NULL;
1449 retval = nfsd_reply_cache_init(nn);
1452 nn->nfsd4_lease = 90; /* default lease time */
1453 nn->nfsd4_grace = 90;
1454 nn->somebody_reclaimed = false;
1455 nn->track_reclaim_completes = false;
1456 nn->clverifier_counter = prandom_u32();
1457 nn->clientid_base = prandom_u32();
1458 nn->clientid_counter = nn->clientid_base + 1;
1459 nn->s2s_cp_cl_id = nn->clientid_counter++;
1461 atomic_set(&nn->ntf_refcnt, 0);
1462 init_waitqueue_head(&nn->ntf_wq);
1464 mnt = vfs_kern_mount(&nfsd_fs_type, SB_KERNMOUNT, "nfsd", NULL);
1466 retval = PTR_ERR(mnt);
1473 nfsd_reply_cache_shutdown(nn);
1475 nfsd_idmap_shutdown(net);
1477 nfsd_export_shutdown(net);
1482 static __net_exit void nfsd_exit_net(struct net *net)
1484 struct nfsd_net *nn = net_generic(net, nfsd_net_id);
1486 mntput(nn->nfsd_mnt);
1487 nfsd_reply_cache_shutdown(nn);
1488 nfsd_idmap_shutdown(net);
1489 nfsd_export_shutdown(net);
1490 nfsd_netns_free_versions(net_generic(net, nfsd_net_id));
1493 static struct pernet_operations nfsd_net_ops = {
1494 .init = nfsd_init_net,
1495 .exit = nfsd_exit_net,
1497 .size = sizeof(struct nfsd_net),
1500 static int __init init_nfsd(void)
1503 printk(KERN_INFO "Installing knfsd (copyright (C) 1996 okir@monad.swb.de).\n");
1505 retval = register_pernet_subsys(&nfsd_net_ops);
1508 retval = register_cld_notifier();
1510 goto out_unregister_pernet;
1511 retval = nfsd4_init_slabs();
1513 goto out_unregister_notifier;
1514 retval = nfsd4_init_pnfs();
1516 goto out_free_slabs;
1517 retval = nfsd_fault_inject_init(); /* nfsd fault injection controls */
1520 nfsd_stat_init(); /* Statistics */
1521 nfsd_lockd_init(); /* lockd->nfsd callbacks */
1522 retval = create_proc_exports_entry();
1524 goto out_free_lockd;
1525 retval = register_filesystem(&nfsd_fs_type);
1530 remove_proc_entry("fs/nfs/exports", NULL);
1531 remove_proc_entry("fs/nfs", NULL);
1533 nfsd_lockd_shutdown();
1534 nfsd_stat_shutdown();
1535 nfsd_fault_inject_cleanup();
1540 out_unregister_notifier:
1541 unregister_cld_notifier();
1542 out_unregister_pernet:
1543 unregister_pernet_subsys(&nfsd_net_ops);
1547 static void __exit exit_nfsd(void)
1549 remove_proc_entry("fs/nfs/exports", NULL);
1550 remove_proc_entry("fs/nfs", NULL);
1551 nfsd_stat_shutdown();
1552 nfsd_lockd_shutdown();
1555 nfsd_fault_inject_cleanup();
1556 unregister_filesystem(&nfsd_fs_type);
1557 unregister_cld_notifier();
1558 unregister_pernet_subsys(&nfsd_net_ops);
1561 MODULE_AUTHOR("Olaf Kirch <okir@monad.swb.de>");
1562 MODULE_LICENSE("GPL");
1563 module_init(init_nfsd)
1564 module_exit(exit_nfsd)