knfsd: add file to export stats about nfsd pools
[safe/jmp/linux-2.6] / fs / nfsd / nfsctl.c
1 /*
2  * linux/fs/nfsd/nfsctl.c
3  *
4  * Syscall interface to knfsd.
5  *
6  * Copyright (C) 1995, 1996 Olaf Kirch <okir@monad.swb.de>
7  */
8
9 #include <linux/module.h>
10
11 #include <linux/linkage.h>
12 #include <linux/time.h>
13 #include <linux/errno.h>
14 #include <linux/fs.h>
15 #include <linux/namei.h>
16 #include <linux/fcntl.h>
17 #include <linux/net.h>
18 #include <linux/in.h>
19 #include <linux/syscalls.h>
20 #include <linux/unistd.h>
21 #include <linux/slab.h>
22 #include <linux/proc_fs.h>
23 #include <linux/seq_file.h>
24 #include <linux/pagemap.h>
25 #include <linux/init.h>
26 #include <linux/inet.h>
27 #include <linux/string.h>
28 #include <linux/smp_lock.h>
29 #include <linux/ctype.h>
30
31 #include <linux/nfs.h>
32 #include <linux/nfsd_idmap.h>
33 #include <linux/lockd/bind.h>
34 #include <linux/sunrpc/svc.h>
35 #include <linux/sunrpc/svcsock.h>
36 #include <linux/nfsd/nfsd.h>
37 #include <linux/nfsd/cache.h>
38 #include <linux/nfsd/xdr.h>
39 #include <linux/nfsd/syscall.h>
40 #include <linux/lockd/lockd.h>
41
42 #include <asm/uaccess.h>
43 #include <net/ipv6.h>
44
45 /*
46  *      We have a single directory with 9 nodes in it.
47  */
48 enum {
49         NFSD_Root = 1,
50         NFSD_Svc,
51         NFSD_Add,
52         NFSD_Del,
53         NFSD_Export,
54         NFSD_Unexport,
55         NFSD_Getfd,
56         NFSD_Getfs,
57         NFSD_List,
58         NFSD_Fh,
59         NFSD_FO_UnlockIP,
60         NFSD_FO_UnlockFS,
61         NFSD_Threads,
62         NFSD_Pool_Threads,
63         NFSD_Pool_Stats,
64         NFSD_Versions,
65         NFSD_Ports,
66         NFSD_MaxBlkSize,
67         /*
68          * The below MUST come last.  Otherwise we leave a hole in nfsd_files[]
69          * with !CONFIG_NFSD_V4 and simple_fill_super() goes oops
70          */
71 #ifdef CONFIG_NFSD_V4
72         NFSD_Leasetime,
73         NFSD_RecoveryDir,
74 #endif
75 };
76
77 /*
78  * write() for these nodes.
79  */
80 static ssize_t write_svc(struct file *file, char *buf, size_t size);
81 static ssize_t write_add(struct file *file, char *buf, size_t size);
82 static ssize_t write_del(struct file *file, char *buf, size_t size);
83 static ssize_t write_export(struct file *file, char *buf, size_t size);
84 static ssize_t write_unexport(struct file *file, char *buf, size_t size);
85 static ssize_t write_getfd(struct file *file, char *buf, size_t size);
86 static ssize_t write_getfs(struct file *file, char *buf, size_t size);
87 static ssize_t write_filehandle(struct file *file, char *buf, size_t size);
88 static ssize_t write_unlock_ip(struct file *file, char *buf, size_t size);
89 static ssize_t write_unlock_fs(struct file *file, char *buf, size_t size);
90 static ssize_t write_threads(struct file *file, char *buf, size_t size);
91 static ssize_t write_pool_threads(struct file *file, char *buf, size_t size);
92 static ssize_t write_versions(struct file *file, char *buf, size_t size);
93 static ssize_t write_ports(struct file *file, char *buf, size_t size);
94 static ssize_t write_maxblksize(struct file *file, char *buf, size_t size);
95 #ifdef CONFIG_NFSD_V4
96 static ssize_t write_leasetime(struct file *file, char *buf, size_t size);
97 static ssize_t write_recoverydir(struct file *file, char *buf, size_t size);
98 #endif
99
100 static ssize_t (*write_op[])(struct file *, char *, size_t) = {
101         [NFSD_Svc] = write_svc,
102         [NFSD_Add] = write_add,
103         [NFSD_Del] = write_del,
104         [NFSD_Export] = write_export,
105         [NFSD_Unexport] = write_unexport,
106         [NFSD_Getfd] = write_getfd,
107         [NFSD_Getfs] = write_getfs,
108         [NFSD_Fh] = write_filehandle,
109         [NFSD_FO_UnlockIP] = write_unlock_ip,
110         [NFSD_FO_UnlockFS] = write_unlock_fs,
111         [NFSD_Threads] = write_threads,
112         [NFSD_Pool_Threads] = write_pool_threads,
113         [NFSD_Versions] = write_versions,
114         [NFSD_Ports] = write_ports,
115         [NFSD_MaxBlkSize] = write_maxblksize,
116 #ifdef CONFIG_NFSD_V4
117         [NFSD_Leasetime] = write_leasetime,
118         [NFSD_RecoveryDir] = write_recoverydir,
119 #endif
120 };
121
122 static ssize_t nfsctl_transaction_write(struct file *file, const char __user *buf, size_t size, loff_t *pos)
123 {
124         ino_t ino =  file->f_path.dentry->d_inode->i_ino;
125         char *data;
126         ssize_t rv;
127
128         if (ino >= ARRAY_SIZE(write_op) || !write_op[ino])
129                 return -EINVAL;
130
131         data = simple_transaction_get(file, buf, size);
132         if (IS_ERR(data))
133                 return PTR_ERR(data);
134
135         rv =  write_op[ino](file, data, size);
136         if (rv >= 0) {
137                 simple_transaction_set(file, rv);
138                 rv = size;
139         }
140         return rv;
141 }
142
143 static ssize_t nfsctl_transaction_read(struct file *file, char __user *buf, size_t size, loff_t *pos)
144 {
145         if (! file->private_data) {
146                 /* An attempt to read a transaction file without writing
147                  * causes a 0-byte write so that the file can return
148                  * state information
149                  */
150                 ssize_t rv = nfsctl_transaction_write(file, buf, 0, pos);
151                 if (rv < 0)
152                         return rv;
153         }
154         return simple_transaction_read(file, buf, size, pos);
155 }
156
157 static const struct file_operations transaction_ops = {
158         .write          = nfsctl_transaction_write,
159         .read           = nfsctl_transaction_read,
160         .release        = simple_transaction_release,
161 };
162
163 static int exports_open(struct inode *inode, struct file *file)
164 {
165         return seq_open(file, &nfs_exports_op);
166 }
167
168 static const struct file_operations exports_operations = {
169         .open           = exports_open,
170         .read           = seq_read,
171         .llseek         = seq_lseek,
172         .release        = seq_release,
173         .owner          = THIS_MODULE,
174 };
175
176 extern int nfsd_pool_stats_open(struct inode *inode, struct file *file);
177
178 static struct file_operations pool_stats_operations = {
179         .open           = nfsd_pool_stats_open,
180         .read           = seq_read,
181         .llseek         = seq_lseek,
182         .release        = seq_release,
183         .owner          = THIS_MODULE,
184 };
185
186 /*----------------------------------------------------------------------------*/
187 /*
188  * payload - write methods
189  */
190
191 /**
192  * write_svc - Start kernel's NFSD server
193  *
194  * Deprecated.  /proc/fs/nfsd/threads is preferred.
195  * Function remains to support old versions of nfs-utils.
196  *
197  * Input:
198  *                      buf:    struct nfsctl_svc
199  *                              svc_port:       port number of this
200  *                                              server's listener
201  *                              svc_nthreads:   number of threads to start
202  *                      size:   size in bytes of passed in nfsctl_svc
203  * Output:
204  *      On success:     returns zero
205  *      On error:       return code is negative errno value
206  */
207 static ssize_t write_svc(struct file *file, char *buf, size_t size)
208 {
209         struct nfsctl_svc *data;
210         if (size < sizeof(*data))
211                 return -EINVAL;
212         data = (struct nfsctl_svc*) buf;
213         return nfsd_svc(data->svc_port, data->svc_nthreads);
214 }
215
216 /**
217  * write_add - Add or modify client entry in auth unix cache
218  *
219  * Deprecated.  /proc/net/rpc/auth.unix.ip is preferred.
220  * Function remains to support old versions of nfs-utils.
221  *
222  * Input:
223  *                      buf:    struct nfsctl_client
224  *                              cl_ident:       '\0'-terminated C string
225  *                                              containing domain name
226  *                                              of client
227  *                              cl_naddr:       no. of items in cl_addrlist
228  *                              cl_addrlist:    array of client addresses
229  *                              cl_fhkeytype:   ignored
230  *                              cl_fhkeylen:    ignored
231  *                              cl_fhkey:       ignored
232  *                      size:   size in bytes of passed in nfsctl_client
233  * Output:
234  *      On success:     returns zero
235  *      On error:       return code is negative errno value
236  *
237  * Note: Only AF_INET client addresses are passed in, since
238  * nfsctl_client.cl_addrlist contains only in_addr fields for addresses.
239  */
240 static ssize_t write_add(struct file *file, char *buf, size_t size)
241 {
242         struct nfsctl_client *data;
243         if (size < sizeof(*data))
244                 return -EINVAL;
245         data = (struct nfsctl_client *)buf;
246         return exp_addclient(data);
247 }
248
249 /**
250  * write_del - Remove client from auth unix cache
251  *
252  * Deprecated.  /proc/net/rpc/auth.unix.ip is preferred.
253  * Function remains to support old versions of nfs-utils.
254  *
255  * Input:
256  *                      buf:    struct nfsctl_client
257  *                              cl_ident:       '\0'-terminated C string
258  *                                              containing domain name
259  *                                              of client
260  *                              cl_naddr:       ignored
261  *                              cl_addrlist:    ignored
262  *                              cl_fhkeytype:   ignored
263  *                              cl_fhkeylen:    ignored
264  *                              cl_fhkey:       ignored
265  *                      size:   size in bytes of passed in nfsctl_client
266  * Output:
267  *      On success:     returns zero
268  *      On error:       return code is negative errno value
269  *
270  * Note: Only AF_INET client addresses are passed in, since
271  * nfsctl_client.cl_addrlist contains only in_addr fields for addresses.
272  */
273 static ssize_t write_del(struct file *file, char *buf, size_t size)
274 {
275         struct nfsctl_client *data;
276         if (size < sizeof(*data))
277                 return -EINVAL;
278         data = (struct nfsctl_client *)buf;
279         return exp_delclient(data);
280 }
281
282 /**
283  * write_export - Export part or all of a local file system
284  *
285  * Deprecated.  /proc/net/rpc/{nfsd.export,nfsd.fh} are preferred.
286  * Function remains to support old versions of nfs-utils.
287  *
288  * Input:
289  *                      buf:    struct nfsctl_export
290  *                              ex_client:      '\0'-terminated C string
291  *                                              containing domain name
292  *                                              of client allowed to access
293  *                                              this export
294  *                              ex_path:        '\0'-terminated C string
295  *                                              containing pathname of
296  *                                              directory in local file system
297  *                              ex_dev:         fsid to use for this export
298  *                              ex_ino:         ignored
299  *                              ex_flags:       export flags for this export
300  *                              ex_anon_uid:    UID to use for anonymous
301  *                                              requests
302  *                              ex_anon_gid:    GID to use for anonymous
303  *                                              requests
304  *                      size:   size in bytes of passed in nfsctl_export
305  * Output:
306  *      On success:     returns zero
307  *      On error:       return code is negative errno value
308  */
309 static ssize_t write_export(struct file *file, char *buf, size_t size)
310 {
311         struct nfsctl_export *data;
312         if (size < sizeof(*data))
313                 return -EINVAL;
314         data = (struct nfsctl_export*)buf;
315         return exp_export(data);
316 }
317
318 /**
319  * write_unexport - Unexport a previously exported file system
320  *
321  * Deprecated.  /proc/net/rpc/{nfsd.export,nfsd.fh} are preferred.
322  * Function remains to support old versions of nfs-utils.
323  *
324  * Input:
325  *                      buf:    struct nfsctl_export
326  *                              ex_client:      '\0'-terminated C string
327  *                                              containing domain name
328  *                                              of client no longer allowed
329  *                                              to access this export
330  *                              ex_path:        '\0'-terminated C string
331  *                                              containing pathname of
332  *                                              directory in local file system
333  *                              ex_dev:         ignored
334  *                              ex_ino:         ignored
335  *                              ex_flags:       ignored
336  *                              ex_anon_uid:    ignored
337  *                              ex_anon_gid:    ignored
338  *                      size:   size in bytes of passed in nfsctl_export
339  * Output:
340  *      On success:     returns zero
341  *      On error:       return code is negative errno value
342  */
343 static ssize_t write_unexport(struct file *file, char *buf, size_t size)
344 {
345         struct nfsctl_export *data;
346
347         if (size < sizeof(*data))
348                 return -EINVAL;
349         data = (struct nfsctl_export*)buf;
350         return exp_unexport(data);
351 }
352
353 /**
354  * write_getfs - Get a variable-length NFS file handle by path
355  *
356  * Deprecated.  /proc/fs/nfsd/filehandle is preferred.
357  * Function remains to support old versions of nfs-utils.
358  *
359  * Input:
360  *                      buf:    struct nfsctl_fsparm
361  *                              gd_addr:        socket address of client
362  *                              gd_path:        '\0'-terminated C string
363  *                                              containing pathname of
364  *                                              directory in local file system
365  *                              gd_maxlen:      maximum size of returned file
366  *                                              handle
367  *                      size:   size in bytes of passed in nfsctl_fsparm
368  * Output:
369  *      On success:     passed-in buffer filled with a knfsd_fh structure
370  *                      (a variable-length raw NFS file handle);
371  *                      return code is the size in bytes of the file handle
372  *      On error:       return code is negative errno value
373  *
374  * Note: Only AF_INET client addresses are passed in, since gd_addr
375  * is the same size as a struct sockaddr_in.
376  */
377 static ssize_t write_getfs(struct file *file, char *buf, size_t size)
378 {
379         struct nfsctl_fsparm *data;
380         struct sockaddr_in *sin;
381         struct auth_domain *clp;
382         int err = 0;
383         struct knfsd_fh *res;
384         struct in6_addr in6;
385
386         if (size < sizeof(*data))
387                 return -EINVAL;
388         data = (struct nfsctl_fsparm*)buf;
389         err = -EPROTONOSUPPORT;
390         if (data->gd_addr.sa_family != AF_INET)
391                 goto out;
392         sin = (struct sockaddr_in *)&data->gd_addr;
393         if (data->gd_maxlen > NFS3_FHSIZE)
394                 data->gd_maxlen = NFS3_FHSIZE;
395
396         res = (struct knfsd_fh*)buf;
397
398         exp_readlock();
399
400         ipv6_addr_set_v4mapped(sin->sin_addr.s_addr, &in6);
401
402         clp = auth_unix_lookup(&in6);
403         if (!clp)
404                 err = -EPERM;
405         else {
406                 err = exp_rootfh(clp, data->gd_path, res, data->gd_maxlen);
407                 auth_domain_put(clp);
408         }
409         exp_readunlock();
410         if (err == 0)
411                 err = res->fh_size + offsetof(struct knfsd_fh, fh_base);
412  out:
413         return err;
414 }
415
416 /**
417  * write_getfd - Get a fixed-length NFS file handle by path (used by mountd)
418  *
419  * Deprecated.  /proc/fs/nfsd/filehandle is preferred.
420  * Function remains to support old versions of nfs-utils.
421  *
422  * Input:
423  *                      buf:    struct nfsctl_fdparm
424  *                              gd_addr:        socket address of client
425  *                              gd_path:        '\0'-terminated C string
426  *                                              containing pathname of
427  *                                              directory in local file system
428  *                              gd_version:     fdparm structure version
429  *                      size:   size in bytes of passed in nfsctl_fdparm
430  * Output:
431  *      On success:     passed-in buffer filled with nfsctl_res
432  *                      (a fixed-length raw NFS file handle);
433  *                      return code is the size in bytes of the file handle
434  *      On error:       return code is negative errno value
435  *
436  * Note: Only AF_INET client addresses are passed in, since gd_addr
437  * is the same size as a struct sockaddr_in.
438  */
439 static ssize_t write_getfd(struct file *file, char *buf, size_t size)
440 {
441         struct nfsctl_fdparm *data;
442         struct sockaddr_in *sin;
443         struct auth_domain *clp;
444         int err = 0;
445         struct knfsd_fh fh;
446         char *res;
447         struct in6_addr in6;
448
449         if (size < sizeof(*data))
450                 return -EINVAL;
451         data = (struct nfsctl_fdparm*)buf;
452         err = -EPROTONOSUPPORT;
453         if (data->gd_addr.sa_family != AF_INET)
454                 goto out;
455         err = -EINVAL;
456         if (data->gd_version < 2 || data->gd_version > NFSSVC_MAXVERS)
457                 goto out;
458
459         res = buf;
460         sin = (struct sockaddr_in *)&data->gd_addr;
461         exp_readlock();
462
463         ipv6_addr_set_v4mapped(sin->sin_addr.s_addr, &in6);
464
465         clp = auth_unix_lookup(&in6);
466         if (!clp)
467                 err = -EPERM;
468         else {
469                 err = exp_rootfh(clp, data->gd_path, &fh, NFS_FHSIZE);
470                 auth_domain_put(clp);
471         }
472         exp_readunlock();
473
474         if (err == 0) {
475                 memset(res,0, NFS_FHSIZE);
476                 memcpy(res, &fh.fh_base, fh.fh_size);
477                 err = NFS_FHSIZE;
478         }
479  out:
480         return err;
481 }
482
483 /**
484  * write_unlock_ip - Release all locks used by a client
485  *
486  * Experimental.
487  *
488  * Input:
489  *                      buf:    '\n'-terminated C string containing a
490  *                              presentation format IPv4 address
491  *                      size:   length of C string in @buf
492  * Output:
493  *      On success:     returns zero if all specified locks were released;
494  *                      returns one if one or more locks were not released
495  *      On error:       return code is negative errno value
496  *
497  * Note: Only AF_INET client addresses are passed in
498  */
499 static ssize_t write_unlock_ip(struct file *file, char *buf, size_t size)
500 {
501         struct sockaddr_in sin = {
502                 .sin_family     = AF_INET,
503         };
504         int b1, b2, b3, b4;
505         char c;
506         char *fo_path;
507
508         /* sanity check */
509         if (size == 0)
510                 return -EINVAL;
511
512         if (buf[size-1] != '\n')
513                 return -EINVAL;
514
515         fo_path = buf;
516         if (qword_get(&buf, fo_path, size) < 0)
517                 return -EINVAL;
518
519         /* get ipv4 address */
520         if (sscanf(fo_path, "%u.%u.%u.%u%c", &b1, &b2, &b3, &b4, &c) != 4)
521                 return -EINVAL;
522         if (b1 > 255 || b2 > 255 || b3 > 255 || b4 > 255)
523                 return -EINVAL;
524         sin.sin_addr.s_addr = htonl((b1 << 24) | (b2 << 16) | (b3 << 8) | b4);
525
526         return nlmsvc_unlock_all_by_ip((struct sockaddr *)&sin);
527 }
528
529 /**
530  * write_unlock_fs - Release all locks on a local file system
531  *
532  * Experimental.
533  *
534  * Input:
535  *                      buf:    '\n'-terminated C string containing the
536  *                              absolute pathname of a local file system
537  *                      size:   length of C string in @buf
538  * Output:
539  *      On success:     returns zero if all specified locks were released;
540  *                      returns one if one or more locks were not released
541  *      On error:       return code is negative errno value
542  */
543 static ssize_t write_unlock_fs(struct file *file, char *buf, size_t size)
544 {
545         struct path path;
546         char *fo_path;
547         int error;
548
549         /* sanity check */
550         if (size == 0)
551                 return -EINVAL;
552
553         if (buf[size-1] != '\n')
554                 return -EINVAL;
555
556         fo_path = buf;
557         if (qword_get(&buf, fo_path, size) < 0)
558                 return -EINVAL;
559
560         error = kern_path(fo_path, 0, &path);
561         if (error)
562                 return error;
563
564         /*
565          * XXX: Needs better sanity checking.  Otherwise we could end up
566          * releasing locks on the wrong file system.
567          *
568          * For example:
569          * 1.  Does the path refer to a directory?
570          * 2.  Is that directory a mount point, or
571          * 3.  Is that directory the root of an exported file system?
572          */
573         error = nlmsvc_unlock_all_by_sb(path.mnt->mnt_sb);
574
575         path_put(&path);
576         return error;
577 }
578
579 /**
580  * write_filehandle - Get a variable-length NFS file handle by path
581  *
582  * On input, the buffer contains a '\n'-terminated C string comprised of
583  * three alphanumeric words separated by whitespace.  The string may
584  * contain escape sequences.
585  *
586  * Input:
587  *                      buf:
588  *                              domain:         client domain name
589  *                              path:           export pathname
590  *                              maxsize:        numeric maximum size of
591  *                                              @buf
592  *                      size:   length of C string in @buf
593  * Output:
594  *      On success:     passed-in buffer filled with '\n'-terminated C
595  *                      string containing a ASCII hex text version
596  *                      of the NFS file handle;
597  *                      return code is the size in bytes of the string
598  *      On error:       return code is negative errno value
599  */
600 static ssize_t write_filehandle(struct file *file, char *buf, size_t size)
601 {
602         char *dname, *path;
603         int uninitialized_var(maxsize);
604         char *mesg = buf;
605         int len;
606         struct auth_domain *dom;
607         struct knfsd_fh fh;
608
609         if (size == 0)
610                 return -EINVAL;
611
612         if (buf[size-1] != '\n')
613                 return -EINVAL;
614         buf[size-1] = 0;
615
616         dname = mesg;
617         len = qword_get(&mesg, dname, size);
618         if (len <= 0)
619                 return -EINVAL;
620         
621         path = dname+len+1;
622         len = qword_get(&mesg, path, size);
623         if (len <= 0)
624                 return -EINVAL;
625
626         len = get_int(&mesg, &maxsize);
627         if (len)
628                 return len;
629
630         if (maxsize < NFS_FHSIZE)
631                 return -EINVAL;
632         if (maxsize > NFS3_FHSIZE)
633                 maxsize = NFS3_FHSIZE;
634
635         if (qword_get(&mesg, mesg, size)>0)
636                 return -EINVAL;
637
638         /* we have all the words, they are in buf.. */
639         dom = unix_domain_find(dname);
640         if (!dom)
641                 return -ENOMEM;
642
643         len = exp_rootfh(dom, path, &fh,  maxsize);
644         auth_domain_put(dom);
645         if (len)
646                 return len;
647         
648         mesg = buf;
649         len = SIMPLE_TRANSACTION_LIMIT;
650         qword_addhex(&mesg, &len, (char*)&fh.fh_base, fh.fh_size);
651         mesg[-1] = '\n';
652         return mesg - buf;      
653 }
654
655 /**
656  * write_threads - Start NFSD, or report the current number of running threads
657  *
658  * Input:
659  *                      buf:            ignored
660  *                      size:           zero
661  * Output:
662  *      On success:     passed-in buffer filled with '\n'-terminated C
663  *                      string numeric value representing the number of
664  *                      running NFSD threads;
665  *                      return code is the size in bytes of the string
666  *      On error:       return code is zero
667  *
668  * OR
669  *
670  * Input:
671  *                      buf:            C string containing an unsigned
672  *                                      integer value representing the
673  *                                      number of NFSD threads to start
674  *                      size:           non-zero length of C string in @buf
675  * Output:
676  *      On success:     NFS service is started;
677  *                      passed-in buffer filled with '\n'-terminated C
678  *                      string numeric value representing the number of
679  *                      running NFSD threads;
680  *                      return code is the size in bytes of the string
681  *      On error:       return code is zero or a negative errno value
682  */
683 static ssize_t write_threads(struct file *file, char *buf, size_t size)
684 {
685         char *mesg = buf;
686         int rv;
687         if (size > 0) {
688                 int newthreads;
689                 rv = get_int(&mesg, &newthreads);
690                 if (rv)
691                         return rv;
692                 if (newthreads < 0)
693                         return -EINVAL;
694                 rv = nfsd_svc(NFS_PORT, newthreads);
695                 if (rv)
696                         return rv;
697         }
698         sprintf(buf, "%d\n", nfsd_nrthreads());
699         return strlen(buf);
700 }
701
702 /**
703  * write_pool_threads - Set or report the current number of threads per pool
704  *
705  * Input:
706  *                      buf:            ignored
707  *                      size:           zero
708  *
709  * OR
710  *
711  * Input:
712  *                      buf:            C string containing whitespace-
713  *                                      separated unsigned integer values
714  *                                      representing the number of NFSD
715  *                                      threads to start in each pool
716  *                      size:           non-zero length of C string in @buf
717  * Output:
718  *      On success:     passed-in buffer filled with '\n'-terminated C
719  *                      string containing integer values representing the
720  *                      number of NFSD threads in each pool;
721  *                      return code is the size in bytes of the string
722  *      On error:       return code is zero or a negative errno value
723  */
724 static ssize_t write_pool_threads(struct file *file, char *buf, size_t size)
725 {
726         /* if size > 0, look for an array of number of threads per node
727          * and apply them  then write out number of threads per node as reply
728          */
729         char *mesg = buf;
730         int i;
731         int rv;
732         int len;
733         int npools;
734         int *nthreads;
735
736         mutex_lock(&nfsd_mutex);
737         npools = nfsd_nrpools();
738         if (npools == 0) {
739                 /*
740                  * NFS is shut down.  The admin can start it by
741                  * writing to the threads file but NOT the pool_threads
742                  * file, sorry.  Report zero threads.
743                  */
744                 mutex_unlock(&nfsd_mutex);
745                 strcpy(buf, "0\n");
746                 return strlen(buf);
747         }
748
749         nthreads = kcalloc(npools, sizeof(int), GFP_KERNEL);
750         rv = -ENOMEM;
751         if (nthreads == NULL)
752                 goto out_free;
753
754         if (size > 0) {
755                 for (i = 0; i < npools; i++) {
756                         rv = get_int(&mesg, &nthreads[i]);
757                         if (rv == -ENOENT)
758                                 break;          /* fewer numbers than pools */
759                         if (rv)
760                                 goto out_free;  /* syntax error */
761                         rv = -EINVAL;
762                         if (nthreads[i] < 0)
763                                 goto out_free;
764                 }
765                 rv = nfsd_set_nrthreads(i, nthreads);
766                 if (rv)
767                         goto out_free;
768         }
769
770         rv = nfsd_get_nrthreads(npools, nthreads);
771         if (rv)
772                 goto out_free;
773
774         mesg = buf;
775         size = SIMPLE_TRANSACTION_LIMIT;
776         for (i = 0; i < npools && size > 0; i++) {
777                 snprintf(mesg, size, "%d%c", nthreads[i], (i == npools-1 ? '\n' : ' '));
778                 len = strlen(mesg);
779                 size -= len;
780                 mesg += len;
781         }
782
783         mutex_unlock(&nfsd_mutex);
784         return (mesg-buf);
785
786 out_free:
787         kfree(nthreads);
788         mutex_unlock(&nfsd_mutex);
789         return rv;
790 }
791
792 static ssize_t __write_versions(struct file *file, char *buf, size_t size)
793 {
794         char *mesg = buf;
795         char *vers, sign;
796         int len, num;
797         ssize_t tlen = 0;
798         char *sep;
799
800         if (size>0) {
801                 if (nfsd_serv)
802                         /* Cannot change versions without updating
803                          * nfsd_serv->sv_xdrsize, and reallocing
804                          * rq_argp and rq_resp
805                          */
806                         return -EBUSY;
807                 if (buf[size-1] != '\n')
808                         return -EINVAL;
809                 buf[size-1] = 0;
810
811                 vers = mesg;
812                 len = qword_get(&mesg, vers, size);
813                 if (len <= 0) return -EINVAL;
814                 do {
815                         sign = *vers;
816                         if (sign == '+' || sign == '-')
817                                 num = simple_strtol((vers+1), NULL, 0);
818                         else
819                                 num = simple_strtol(vers, NULL, 0);
820                         switch(num) {
821                         case 2:
822                         case 3:
823                         case 4:
824                                 nfsd_vers(num, sign == '-' ? NFSD_CLEAR : NFSD_SET);
825                                 break;
826                         default:
827                                 return -EINVAL;
828                         }
829                         vers += len + 1;
830                         tlen += len;
831                 } while ((len = qword_get(&mesg, vers, size)) > 0);
832                 /* If all get turned off, turn them back on, as
833                  * having no versions is BAD
834                  */
835                 nfsd_reset_versions();
836         }
837         /* Now write current state into reply buffer */
838         len = 0;
839         sep = "";
840         for (num=2 ; num <= 4 ; num++)
841                 if (nfsd_vers(num, NFSD_AVAIL)) {
842                         len += sprintf(buf+len, "%s%c%d", sep,
843                                        nfsd_vers(num, NFSD_TEST)?'+':'-',
844                                        num);
845                         sep = " ";
846                 }
847         len += sprintf(buf+len, "\n");
848         return len;
849 }
850
851 /**
852  * write_versions - Set or report the available NFS protocol versions
853  *
854  * Input:
855  *                      buf:            ignored
856  *                      size:           zero
857  * Output:
858  *      On success:     passed-in buffer filled with '\n'-terminated C
859  *                      string containing positive or negative integer
860  *                      values representing the current status of each
861  *                      protocol version;
862  *                      return code is the size in bytes of the string
863  *      On error:       return code is zero or a negative errno value
864  *
865  * OR
866  *
867  * Input:
868  *                      buf:            C string containing whitespace-
869  *                                      separated positive or negative
870  *                                      integer values representing NFS
871  *                                      protocol versions to enable ("+n")
872  *                                      or disable ("-n")
873  *                      size:           non-zero length of C string in @buf
874  * Output:
875  *      On success:     status of zero or more protocol versions has
876  *                      been updated; passed-in buffer filled with
877  *                      '\n'-terminated C string containing positive
878  *                      or negative integer values representing the
879  *                      current status of each protocol version;
880  *                      return code is the size in bytes of the string
881  *      On error:       return code is zero or a negative errno value
882  */
883 static ssize_t write_versions(struct file *file, char *buf, size_t size)
884 {
885         ssize_t rv;
886
887         mutex_lock(&nfsd_mutex);
888         rv = __write_versions(file, buf, size);
889         mutex_unlock(&nfsd_mutex);
890         return rv;
891 }
892
893 static ssize_t __write_ports(struct file *file, char *buf, size_t size)
894 {
895         if (size == 0) {
896                 int len = 0;
897
898                 if (nfsd_serv)
899                         len = svc_xprt_names(nfsd_serv, buf, 0);
900                 return len;
901         }
902         /* Either a single 'fd' number is written, in which
903          * case it must be for a socket of a supported family/protocol,
904          * and we use it as an nfsd socket, or
905          * A '-' followed by the 'name' of a socket in which case
906          * we close the socket.
907          */
908         if (isdigit(buf[0])) {
909                 char *mesg = buf;
910                 int fd;
911                 int err;
912                 err = get_int(&mesg, &fd);
913                 if (err)
914                         return -EINVAL;
915                 if (fd < 0)
916                         return -EINVAL;
917                 err = nfsd_create_serv();
918                 if (!err) {
919                         err = svc_addsock(nfsd_serv, fd, buf);
920                         if (err >= 0) {
921                                 err = lockd_up();
922                                 if (err < 0)
923                                         svc_sock_names(buf+strlen(buf)+1, nfsd_serv, buf);
924                         }
925                         /* Decrease the count, but don't shutdown the
926                          * the service
927                          */
928                         nfsd_serv->sv_nrthreads--;
929                 }
930                 return err < 0 ? err : 0;
931         }
932         if (buf[0] == '-' && isdigit(buf[1])) {
933                 char *toclose = kstrdup(buf+1, GFP_KERNEL);
934                 int len = 0;
935                 if (!toclose)
936                         return -ENOMEM;
937                 if (nfsd_serv)
938                         len = svc_sock_names(buf, nfsd_serv, toclose);
939                 if (len >= 0)
940                         lockd_down();
941                 kfree(toclose);
942                 return len;
943         }
944         /*
945          * Add a transport listener by writing it's transport name
946          */
947         if (isalpha(buf[0])) {
948                 int err;
949                 char transport[16];
950                 int port;
951                 if (sscanf(buf, "%15s %4d", transport, &port) == 2) {
952                         err = nfsd_create_serv();
953                         if (!err) {
954                                 err = svc_create_xprt(nfsd_serv,
955                                                       transport, port,
956                                                       SVC_SOCK_ANONYMOUS);
957                                 if (err == -ENOENT)
958                                         /* Give a reasonable perror msg for
959                                          * bad transport string */
960                                         err = -EPROTONOSUPPORT;
961                         }
962                         return err < 0 ? err : 0;
963                 }
964         }
965         /*
966          * Remove a transport by writing it's transport name and port number
967          */
968         if (buf[0] == '-' && isalpha(buf[1])) {
969                 struct svc_xprt *xprt;
970                 int err = -EINVAL;
971                 char transport[16];
972                 int port;
973                 if (sscanf(&buf[1], "%15s %4d", transport, &port) == 2) {
974                         if (port == 0)
975                                 return -EINVAL;
976                         if (nfsd_serv) {
977                                 xprt = svc_find_xprt(nfsd_serv, transport,
978                                                      AF_UNSPEC, port);
979                                 if (xprt) {
980                                         svc_close_xprt(xprt);
981                                         svc_xprt_put(xprt);
982                                         err = 0;
983                                 } else
984                                         err = -ENOTCONN;
985                         }
986                         return err < 0 ? err : 0;
987                 }
988         }
989         return -EINVAL;
990 }
991
992 /**
993  * write_ports - Pass a socket file descriptor or transport name to listen on
994  *
995  * Input:
996  *                      buf:            ignored
997  *                      size:           zero
998  * Output:
999  *      On success:     passed-in buffer filled with a '\n'-terminated C
1000  *                      string containing a whitespace-separated list of
1001  *                      named NFSD listeners;
1002  *                      return code is the size in bytes of the string
1003  *      On error:       return code is zero or a negative errno value
1004  *
1005  * OR
1006  *
1007  * Input:
1008  *                      buf:            C string containing an unsigned
1009  *                                      integer value representing a bound
1010  *                                      but unconnected socket that is to be
1011  *                                      used as an NFSD listener
1012  *                      size:           non-zero length of C string in @buf
1013  * Output:
1014  *      On success:     NFS service is started;
1015  *                      passed-in buffer filled with a '\n'-terminated C
1016  *                      string containing a unique alphanumeric name of
1017  *                      the listener;
1018  *                      return code is the size in bytes of the string
1019  *      On error:       return code is a negative errno value
1020  *
1021  * OR
1022  *
1023  * Input:
1024  *                      buf:            C string containing a "-" followed
1025  *                                      by an integer value representing a
1026  *                                      previously passed in socket file
1027  *                                      descriptor
1028  *                      size:           non-zero length of C string in @buf
1029  * Output:
1030  *      On success:     NFS service no longer listens on that socket;
1031  *                      passed-in buffer filled with a '\n'-terminated C
1032  *                      string containing a unique name of the listener;
1033  *                      return code is the size in bytes of the string
1034  *      On error:       return code is a negative errno value
1035  *
1036  * OR
1037  *
1038  * Input:
1039  *                      buf:            C string containing a transport
1040  *                                      name and an unsigned integer value
1041  *                                      representing the port to listen on,
1042  *                                      separated by whitespace
1043  *                      size:           non-zero length of C string in @buf
1044  * Output:
1045  *      On success:     returns zero; NFS service is started
1046  *      On error:       return code is a negative errno value
1047  *
1048  * OR
1049  *
1050  * Input:
1051  *                      buf:            C string containing a "-" followed
1052  *                                      by a transport name and an unsigned
1053  *                                      integer value representing the port
1054  *                                      to listen on, separated by whitespace
1055  *                      size:           non-zero length of C string in @buf
1056  * Output:
1057  *      On success:     returns zero; NFS service no longer listens
1058  *                      on that transport
1059  *      On error:       return code is a negative errno value
1060  */
1061 static ssize_t write_ports(struct file *file, char *buf, size_t size)
1062 {
1063         ssize_t rv;
1064
1065         mutex_lock(&nfsd_mutex);
1066         rv = __write_ports(file, buf, size);
1067         mutex_unlock(&nfsd_mutex);
1068         return rv;
1069 }
1070
1071
1072 int nfsd_max_blksize;
1073
1074 /**
1075  * write_maxblksize - Set or report the current NFS blksize
1076  *
1077  * Input:
1078  *                      buf:            ignored
1079  *                      size:           zero
1080  *
1081  * OR
1082  *
1083  * Input:
1084  *                      buf:            C string containing an unsigned
1085  *                                      integer value representing the new
1086  *                                      NFS blksize
1087  *                      size:           non-zero length of C string in @buf
1088  * Output:
1089  *      On success:     passed-in buffer filled with '\n'-terminated C string
1090  *                      containing numeric value of the current NFS blksize
1091  *                      setting;
1092  *                      return code is the size in bytes of the string
1093  *      On error:       return code is zero or a negative errno value
1094  */
1095 static ssize_t write_maxblksize(struct file *file, char *buf, size_t size)
1096 {
1097         char *mesg = buf;
1098         if (size > 0) {
1099                 int bsize;
1100                 int rv = get_int(&mesg, &bsize);
1101                 if (rv)
1102                         return rv;
1103                 /* force bsize into allowed range and
1104                  * required alignment.
1105                  */
1106                 if (bsize < 1024)
1107                         bsize = 1024;
1108                 if (bsize > NFSSVC_MAXBLKSIZE)
1109                         bsize = NFSSVC_MAXBLKSIZE;
1110                 bsize &= ~(1024-1);
1111                 mutex_lock(&nfsd_mutex);
1112                 if (nfsd_serv && nfsd_serv->sv_nrthreads) {
1113                         mutex_unlock(&nfsd_mutex);
1114                         return -EBUSY;
1115                 }
1116                 nfsd_max_blksize = bsize;
1117                 mutex_unlock(&nfsd_mutex);
1118         }
1119         return sprintf(buf, "%d\n", nfsd_max_blksize);
1120 }
1121
1122 #ifdef CONFIG_NFSD_V4
1123 extern time_t nfs4_leasetime(void);
1124
1125 static ssize_t __write_leasetime(struct file *file, char *buf, size_t size)
1126 {
1127         /* if size > 10 seconds, call
1128          * nfs4_reset_lease() then write out the new lease (seconds) as reply
1129          */
1130         char *mesg = buf;
1131         int rv, lease;
1132
1133         if (size > 0) {
1134                 if (nfsd_serv)
1135                         return -EBUSY;
1136                 rv = get_int(&mesg, &lease);
1137                 if (rv)
1138                         return rv;
1139                 if (lease < 10 || lease > 3600)
1140                         return -EINVAL;
1141                 nfs4_reset_lease(lease);
1142         }
1143         sprintf(buf, "%ld\n", nfs4_lease_time());
1144         return strlen(buf);
1145 }
1146
1147 /**
1148  * write_leasetime - Set or report the current NFSv4 lease time
1149  *
1150  * Input:
1151  *                      buf:            ignored
1152  *                      size:           zero
1153  *
1154  * OR
1155  *
1156  * Input:
1157  *                      buf:            C string containing an unsigned
1158  *                                      integer value representing the new
1159  *                                      NFSv4 lease expiry time
1160  *                      size:           non-zero length of C string in @buf
1161  * Output:
1162  *      On success:     passed-in buffer filled with '\n'-terminated C
1163  *                      string containing unsigned integer value of the
1164  *                      current lease expiry time;
1165  *                      return code is the size in bytes of the string
1166  *      On error:       return code is zero or a negative errno value
1167  */
1168 static ssize_t write_leasetime(struct file *file, char *buf, size_t size)
1169 {
1170         ssize_t rv;
1171
1172         mutex_lock(&nfsd_mutex);
1173         rv = __write_leasetime(file, buf, size);
1174         mutex_unlock(&nfsd_mutex);
1175         return rv;
1176 }
1177
1178 extern char *nfs4_recoverydir(void);
1179
1180 static ssize_t __write_recoverydir(struct file *file, char *buf, size_t size)
1181 {
1182         char *mesg = buf;
1183         char *recdir;
1184         int len, status;
1185
1186         if (size > 0) {
1187                 if (nfsd_serv)
1188                         return -EBUSY;
1189                 if (size > PATH_MAX || buf[size-1] != '\n')
1190                         return -EINVAL;
1191                 buf[size-1] = 0;
1192
1193                 recdir = mesg;
1194                 len = qword_get(&mesg, recdir, size);
1195                 if (len <= 0)
1196                         return -EINVAL;
1197
1198                 status = nfs4_reset_recoverydir(recdir);
1199         }
1200         sprintf(buf, "%s\n", nfs4_recoverydir());
1201         return strlen(buf);
1202 }
1203
1204 /**
1205  * write_recoverydir - Set or report the pathname of the recovery directory
1206  *
1207  * Input:
1208  *                      buf:            ignored
1209  *                      size:           zero
1210  *
1211  * OR
1212  *
1213  * Input:
1214  *                      buf:            C string containing the pathname
1215  *                                      of the directory on a local file
1216  *                                      system containing permanent NFSv4
1217  *                                      recovery data
1218  *                      size:           non-zero length of C string in @buf
1219  * Output:
1220  *      On success:     passed-in buffer filled with '\n'-terminated C string
1221  *                      containing the current recovery pathname setting;
1222  *                      return code is the size in bytes of the string
1223  *      On error:       return code is zero or a negative errno value
1224  */
1225 static ssize_t write_recoverydir(struct file *file, char *buf, size_t size)
1226 {
1227         ssize_t rv;
1228
1229         mutex_lock(&nfsd_mutex);
1230         rv = __write_recoverydir(file, buf, size);
1231         mutex_unlock(&nfsd_mutex);
1232         return rv;
1233 }
1234
1235 #endif
1236
1237 /*----------------------------------------------------------------------------*/
1238 /*
1239  *      populating the filesystem.
1240  */
1241
1242 static int nfsd_fill_super(struct super_block * sb, void * data, int silent)
1243 {
1244         static struct tree_descr nfsd_files[] = {
1245                 [NFSD_Svc] = {".svc", &transaction_ops, S_IWUSR},
1246                 [NFSD_Add] = {".add", &transaction_ops, S_IWUSR},
1247                 [NFSD_Del] = {".del", &transaction_ops, S_IWUSR},
1248                 [NFSD_Export] = {".export", &transaction_ops, S_IWUSR},
1249                 [NFSD_Unexport] = {".unexport", &transaction_ops, S_IWUSR},
1250                 [NFSD_Getfd] = {".getfd", &transaction_ops, S_IWUSR|S_IRUSR},
1251                 [NFSD_Getfs] = {".getfs", &transaction_ops, S_IWUSR|S_IRUSR},
1252                 [NFSD_List] = {"exports", &exports_operations, S_IRUGO},
1253                 [NFSD_FO_UnlockIP] = {"unlock_ip",
1254                                         &transaction_ops, S_IWUSR|S_IRUSR},
1255                 [NFSD_FO_UnlockFS] = {"unlock_filesystem",
1256                                         &transaction_ops, S_IWUSR|S_IRUSR},
1257                 [NFSD_Fh] = {"filehandle", &transaction_ops, S_IWUSR|S_IRUSR},
1258                 [NFSD_Threads] = {"threads", &transaction_ops, S_IWUSR|S_IRUSR},
1259                 [NFSD_Pool_Threads] = {"pool_threads", &transaction_ops, S_IWUSR|S_IRUSR},
1260                 [NFSD_Pool_Stats] = {"pool_stats", &pool_stats_operations, S_IRUGO},
1261                 [NFSD_Versions] = {"versions", &transaction_ops, S_IWUSR|S_IRUSR},
1262                 [NFSD_Ports] = {"portlist", &transaction_ops, S_IWUSR|S_IRUGO},
1263                 [NFSD_MaxBlkSize] = {"max_block_size", &transaction_ops, S_IWUSR|S_IRUGO},
1264 #ifdef CONFIG_NFSD_V4
1265                 [NFSD_Leasetime] = {"nfsv4leasetime", &transaction_ops, S_IWUSR|S_IRUSR},
1266                 [NFSD_RecoveryDir] = {"nfsv4recoverydir", &transaction_ops, S_IWUSR|S_IRUSR},
1267 #endif
1268                 /* last one */ {""}
1269         };
1270         return simple_fill_super(sb, 0x6e667364, nfsd_files);
1271 }
1272
1273 static int nfsd_get_sb(struct file_system_type *fs_type,
1274         int flags, const char *dev_name, void *data, struct vfsmount *mnt)
1275 {
1276         return get_sb_single(fs_type, flags, data, nfsd_fill_super, mnt);
1277 }
1278
1279 static struct file_system_type nfsd_fs_type = {
1280         .owner          = THIS_MODULE,
1281         .name           = "nfsd",
1282         .get_sb         = nfsd_get_sb,
1283         .kill_sb        = kill_litter_super,
1284 };
1285
1286 #ifdef CONFIG_PROC_FS
1287 static int create_proc_exports_entry(void)
1288 {
1289         struct proc_dir_entry *entry;
1290
1291         entry = proc_mkdir("fs/nfs", NULL);
1292         if (!entry)
1293                 return -ENOMEM;
1294         entry = proc_create("exports", 0, entry, &exports_operations);
1295         if (!entry)
1296                 return -ENOMEM;
1297         return 0;
1298 }
1299 #else /* CONFIG_PROC_FS */
1300 static int create_proc_exports_entry(void)
1301 {
1302         return 0;
1303 }
1304 #endif
1305
1306 static int __init init_nfsd(void)
1307 {
1308         int retval;
1309         printk(KERN_INFO "Installing knfsd (copyright (C) 1996 okir@monad.swb.de).\n");
1310
1311         retval = nfs4_state_init(); /* nfs4 locking state */
1312         if (retval)
1313                 return retval;
1314         nfsd_stat_init();       /* Statistics */
1315         retval = nfsd_reply_cache_init();
1316         if (retval)
1317                 goto out_free_stat;
1318         retval = nfsd_export_init();
1319         if (retval)
1320                 goto out_free_cache;
1321         nfsd_lockd_init();      /* lockd->nfsd callbacks */
1322         retval = nfsd_idmap_init();
1323         if (retval)
1324                 goto out_free_lockd;
1325         retval = create_proc_exports_entry();
1326         if (retval)
1327                 goto out_free_idmap;
1328         retval = register_filesystem(&nfsd_fs_type);
1329         if (retval)
1330                 goto out_free_all;
1331         return 0;
1332 out_free_all:
1333         remove_proc_entry("fs/nfs/exports", NULL);
1334         remove_proc_entry("fs/nfs", NULL);
1335 out_free_idmap:
1336         nfsd_idmap_shutdown();
1337 out_free_lockd:
1338         nfsd_lockd_shutdown();
1339         nfsd_export_shutdown();
1340 out_free_cache:
1341         nfsd_reply_cache_shutdown();
1342 out_free_stat:
1343         nfsd_stat_shutdown();
1344         nfsd4_free_slabs();
1345         return retval;
1346 }
1347
1348 static void __exit exit_nfsd(void)
1349 {
1350         nfsd_export_shutdown();
1351         nfsd_reply_cache_shutdown();
1352         remove_proc_entry("fs/nfs/exports", NULL);
1353         remove_proc_entry("fs/nfs", NULL);
1354         nfsd_stat_shutdown();
1355         nfsd_lockd_shutdown();
1356         nfsd_idmap_shutdown();
1357         nfsd4_free_slabs();
1358         unregister_filesystem(&nfsd_fs_type);
1359 }
1360
1361 MODULE_AUTHOR("Olaf Kirch <okir@monad.swb.de>");
1362 MODULE_LICENSE("GPL");
1363 module_init(init_nfsd)
1364 module_exit(exit_nfsd)