Imported Upstream version 1.2.3
[nfs-utils.git] / utils / mountd / mountd.c
index dc84404..d309950 100644 (file)
 #include "rpcmisc.h"
 #include "pseudoflavors.h"
 
-extern void    cache_open(void);
-extern struct nfs_fh_len *cache_get_filehandle(nfs_export *exp, int len, char *p);
-extern int cache_export(nfs_export *exp, char *path);
-
 extern void my_svc_run(void);
 
 static void            usage(const char *, int exitcode);
@@ -75,17 +71,40 @@ static struct option longopts[] =
        { NULL, 0, 0, 0 }
 };
 
-static int nfs_version = -1;
+#define NFSVERSBIT(vers)       (0x1 << (vers - 1))
+#define NFSVERSBIT_ALL         (NFSVERSBIT(2) | NFSVERSBIT(3) | NFSVERSBIT(4))
+
+static int nfs_version = NFSVERSBIT_ALL;
+
+static int version2(void)
+{
+       return nfs_version & NFSVERSBIT(2);
+}
+
+static int version3(void)
+{
+       return nfs_version & NFSVERSBIT(3);
+}
+
+static int version23(void)
+{
+       return nfs_version & (NFSVERSBIT(2) | NFSVERSBIT(3));
+}
+
+static int version_any(void)
+{
+       return nfs_version & NFSVERSBIT_ALL;
+}
 
 static void
 unregister_services (void)
 {
-       if (nfs_version & (0x1 << 1)) {
-               pmap_unset (MOUNTPROG, MOUNTVERS);
-               pmap_unset (MOUNTPROG, MOUNTVERS_POSIX);
+       if (version2()) {
+               nfs_svc_unregister(MOUNTPROG, MOUNTVERS);
+               nfs_svc_unregister(MOUNTPROG, MOUNTVERS_POSIX);
        }
-       if (nfs_version & (0x1 << 2))
-               pmap_unset (MOUNTPROG, MOUNTVERS_NFSV3);
+       if (version3())
+               nfs_svc_unregister(MOUNTPROG, MOUNTVERS_NFSV3);
 }
 
 static void
@@ -192,18 +211,28 @@ sig_hup (int sig)
 }
 
 bool_t
-mount_null_1_svc(struct svc_req *UNUSED(rqstp), void *UNUSED(argp), 
+mount_null_1_svc(struct svc_req *rqstp, void *UNUSED(argp), 
        void *UNUSED(resp))
 {
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
+       char buf[INET6_ADDRSTRLEN];
+
+       xlog(D_CALL, "Received NULL request from %s",
+               host_ntop(sap, buf, sizeof(buf)));
+
        return 1;
 }
 
 bool_t
 mount_mnt_1_svc(struct svc_req *rqstp, dirpath *path, fhstatus *res)
 {
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
+       char buf[INET6_ADDRSTRLEN];
        struct nfs_fh_len *fh;
 
-       xlog(D_CALL, "MNT1(%s) called", *path);
+       xlog(D_CALL, "Received MNT1(%s) request from %s", *path,
+               host_ntop(sap, buf, sizeof(buf)));
+
        fh = get_rootfh(rqstp, path, NULL, &res->fhs_status, 0);
        if (fh)
                memcpy(&res->fhstatus_u.fhs_fhandle, fh->fh_handle, 32);
@@ -213,9 +242,12 @@ mount_mnt_1_svc(struct svc_req *rqstp, dirpath *path, fhstatus *res)
 bool_t
 mount_dump_1_svc(struct svc_req *rqstp, void *UNUSED(argp), mountlist *res)
 {
-       struct sockaddr_in *addr = nfs_getrpccaller_in(rqstp->rq_xprt);
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
+       char buf[INET6_ADDRSTRLEN];
+
+       xlog(D_CALL, "Received DUMP request from %s",
+               host_ntop(sap, buf, sizeof(buf)));
 
-       xlog(D_CALL, "dump request from %s.", inet_ntoa(addr->sin_addr));
        *res = mountlist_list();
 
        return 1;
@@ -224,10 +256,11 @@ mount_dump_1_svc(struct svc_req *rqstp, void *UNUSED(argp), mountlist *res)
 bool_t
 mount_umnt_1_svc(struct svc_req *rqstp, dirpath *argp, void *UNUSED(resp))
 {
-       struct sockaddr_in *sin = nfs_getrpccaller_in(rqstp->rq_xprt);
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
        nfs_export      *exp;
        char            *p = *argp;
        char            rpath[MAXPATHLEN+1];
+       char            buf[INET6_ADDRSTRLEN];
 
        if (*p == '\0')
                p = "/";
@@ -237,11 +270,14 @@ mount_umnt_1_svc(struct svc_req *rqstp, dirpath *argp, void *UNUSED(resp))
                p = rpath;
        }
 
-       if (!(exp = auth_authenticate("unmount", sin, p))) {
+       xlog(D_CALL, "Received UMNT(%s) request from %s", p,
+               host_ntop(sap, buf, sizeof(buf)));
+
+       exp = auth_authenticate("unmount", sap, p);
+       if (exp == NULL)
                return 1;
-       }
 
-       mountlist_del(inet_ntoa(sin->sin_addr), p);
+       mountlist_del(host_ntop(sap, buf, sizeof(buf)), p);
        return 1;
 }
 
@@ -249,19 +285,28 @@ bool_t
 mount_umntall_1_svc(struct svc_req *rqstp, void *UNUSED(argp), 
        void *UNUSED(resp))
 {
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
+       char            buf[INET6_ADDRSTRLEN];
+
+       xlog(D_CALL, "Received UMNTALL request from %s",
+               host_ntop(sap, buf, sizeof(buf)));
+
        /* Reload /etc/xtab if necessary */
        auth_reload();
 
-       mountlist_del_all(nfs_getrpccaller_in(rqstp->rq_xprt));
+       mountlist_del_all(nfs_getrpccaller(rqstp->rq_xprt));
        return 1;
 }
 
 bool_t
 mount_export_1_svc(struct svc_req *rqstp, void *UNUSED(argp), exports *resp)
 {
-       struct sockaddr_in *addr = nfs_getrpccaller_in(rqstp->rq_xprt);
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
+       char buf[INET6_ADDRSTRLEN];
+
+       xlog(D_CALL, "Received EXPORT request from %s.",
+               host_ntop(sap, buf, sizeof(buf)));
 
-       xlog(D_CALL, "export request from %s.", inet_ntoa(addr->sin_addr));
        *resp = get_exportlist();
                
        return 1;
@@ -270,9 +315,12 @@ mount_export_1_svc(struct svc_req *rqstp, void *UNUSED(argp), exports *resp)
 bool_t
 mount_exportall_1_svc(struct svc_req *rqstp, void *UNUSED(argp), exports *resp)
 {
-       struct sockaddr_in *addr = nfs_getrpccaller_in(rqstp->rq_xprt);
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
+       char buf[INET6_ADDRSTRLEN];
+
+       xlog(D_CALL, "Received EXPORTALL request from %s.",
+               host_ntop(sap, buf, sizeof(buf)));
 
-       xlog(D_CALL, "exportall request from %s.", inet_ntoa(addr->sin_addr));
        *resp = get_exportlist();
 
        return 1;
@@ -292,11 +340,12 @@ mount_exportall_1_svc(struct svc_req *rqstp, void *UNUSED(argp), exports *resp)
 bool_t
 mount_pathconf_2_svc(struct svc_req *rqstp, dirpath *path, ppathcnf *res)
 {
-       struct sockaddr_in *sin = nfs_getrpccaller_in(rqstp->rq_xprt);
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
        struct stat     stb;
        nfs_export      *exp;
        char            rpath[MAXPATHLEN+1];
        char            *p = *path;
+       char buf[INET6_ADDRSTRLEN];
 
        memset(res, 0, sizeof(*res));
 
@@ -312,11 +361,14 @@ mount_pathconf_2_svc(struct svc_req *rqstp, dirpath *path, ppathcnf *res)
                p = rpath;
        }
 
+       xlog(D_CALL, "Received PATHCONF(%s) request from %s", p,
+               host_ntop(sap, buf, sizeof(buf)));
+
        /* Now authenticate the intruder... */
-       exp = auth_authenticate("pathconf", sin, p);
-       if (!exp) {
+       exp = auth_authenticate("pathconf", sap, p);
+       if (exp == NULL)
                return 1;
-       else if (stat(p, &stb) < 0) {
+       else if (stat(p, &stb) < 0) {
                xlog(L_WARNING, "can't stat exported dir %s: %s",
                                p, strerror(errno));
                return 1;
@@ -376,11 +428,15 @@ static void set_authflavors(struct mountres3_ok *ok, nfs_export *exp)
 bool_t
 mount_mnt_3_svc(struct svc_req *rqstp, dirpath *path, mountres3 *res)
 {
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
        struct mountres3_ok *ok = &res->mountres3_u.mountinfo;
+       char buf[INET6_ADDRSTRLEN];
        nfs_export *exp;
        struct nfs_fh_len *fh;
 
-       xlog(D_CALL, "MNT3(%s) called", *path);
+       xlog(D_CALL, "Received MNT3(%s) request from %s", *path,
+               host_ntop(sap, buf, sizeof(buf)));
+
        fh = get_rootfh(rqstp, path, &exp, &res->fhs_status, 1);
        if (!fh)
                return 1;
@@ -395,12 +451,13 @@ static struct nfs_fh_len *
 get_rootfh(struct svc_req *rqstp, dirpath *path, nfs_export **expret,
                mountstat3 *error, int v3)
 {
-       struct sockaddr_in *sin = nfs_getrpccaller_in(rqstp->rq_xprt);
+       struct sockaddr *sap = nfs_getrpccaller(rqstp->rq_xprt);
        struct stat     stb, estb;
        nfs_export      *exp;
        struct nfs_fh_len *fh;
        char            rpath[MAXPATHLEN+1];
        char            *p = *path;
+       char            buf[INET6_ADDRSTRLEN];
 
        if (*p == '\0')
                p = "/";
@@ -415,29 +472,29 @@ get_rootfh(struct svc_req *rqstp, dirpath *path, nfs_export **expret,
        }
 
        /* Now authenticate the intruder... */
-       exp = auth_authenticate("mount", sin, p);
-       if (!exp) {
-               *error = NFSERR_ACCES;
+       exp = auth_authenticate("mount", sap, p);
+       if (exp == NULL) {
+               *error = MNT3ERR_ACCES;
                return NULL;
        }
        if (stat(p, &stb) < 0) {
                xlog(L_WARNING, "can't stat exported dir %s: %s",
                                p, strerror(errno));
                if (errno == ENOENT)
-                       *error = NFSERR_NOENT;
+                       *error = MNT3ERR_NOENT;
                else
-                       *error = NFSERR_ACCES;
+                       *error = MNT3ERR_ACCES;
                return NULL;
        }
        if (!S_ISDIR(stb.st_mode) && !S_ISREG(stb.st_mode)) {
                xlog(L_WARNING, "%s is not a directory or regular file", p);
-               *error = NFSERR_NOTDIR;
+               *error = MNT3ERR_NOTDIR;
                return NULL;
        }
        if (stat(exp->m_export.e_path, &estb) < 0) {
                xlog(L_WARNING, "can't stat export point %s: %s",
                     p, strerror(errno));
-               *error = NFSERR_NOENT;
+               *error = MNT3ERR_NOENT;
                return NULL;
        }
        if (estb.st_dev != stb.st_dev
@@ -445,7 +502,7 @@ get_rootfh(struct svc_req *rqstp, dirpath *path, nfs_export **expret,
                           || !(exp->m_export.e_flags & NFSEXP_CROSSMOUNT))) {
                xlog(L_WARNING, "request to export directory %s below nearest filesystem %s",
                     p, exp->m_export.e_path);
-               *error = NFSERR_ACCES;
+               *error = MNT3ERR_ACCES;
                return NULL;
        }
        if (exp->m_export.e_mountpoint &&
@@ -454,7 +511,7 @@ get_rootfh(struct svc_req *rqstp, dirpath *path, nfs_export **expret,
                                  exp->m_export.e_path)) {
                xlog(L_WARNING, "request to export an unmounted filesystem: %s",
                     p);
-               *error = NFSERR_NOENT;
+               *error = MNT3ERR_NOENT;
                return NULL;
        }
 
@@ -465,12 +522,12 @@ get_rootfh(struct svc_req *rqstp, dirpath *path, nfs_export **expret,
                 */
 
                if (cache_export(exp, p)) {
-                       *error = NFSERR_ACCES;
+                       *error = MNT3ERR_ACCES;
                        return NULL;
                }
                fh = cache_get_filehandle(exp, v3?64:32, p);
                if (fh == NULL) {
-                       *error = NFSERR_ACCES;
+                       *error = MNT3ERR_ACCES;
                        return NULL;
                }
        } else {
@@ -484,13 +541,13 @@ get_rootfh(struct svc_req *rqstp, dirpath *path, nfs_export **expret,
                        xtab_append(exp);
 
                if (v3)
-                       fh = getfh_size ((struct sockaddr *) sin, p, 64);
+                       fh = getfh_size((struct sockaddr_in *)sap, p, 64);
                if (!v3 || (fh == NULL && errno == EINVAL)) {
                        /* We first try the new nfs syscall. */
-                       fh = getfh ((struct sockaddr *) sin, p);
+                       fh = getfh((struct sockaddr_in *)sap, p);
                        if (fh == NULL && errno == EINVAL)
                                /* Let's try the old one. */
-                               fh = getfh_old ((struct sockaddr *) sin,
+                               fh = getfh_old((struct sockaddr_in *)sap,
                                                stb.st_dev, stb.st_ino);
                }
                if (fh == NULL && !did_export) {
@@ -500,12 +557,12 @@ get_rootfh(struct svc_req *rqstp, dirpath *path, nfs_export **expret,
 
                if (fh == NULL) {
                        xlog(L_WARNING, "getfh failed: %s", strerror(errno));
-                       *error = NFSERR_ACCES;
+                       *error = MNT3ERR_ACCES;
                        return NULL;
                }
        }
-       *error = NFS_OK;
-       mountlist_add(inet_ntoa(sin->sin_addr), p);
+       *error = MNT_OK;
+       mountlist_add(host_ntop(sap, buf, sizeof(buf)), p);
        if (expret)
                *expret = exp;
        return fh;
@@ -635,13 +692,22 @@ main(int argc, char **argv)
 {
        char    *export_file = _PATH_EXPORTS;
        char    *state_dir = NFS_STATEDIR;
+       char    *progname;
+       unsigned int listeners = 0;
        int     foreground = 0;
        int     port = 0;
        int     descriptors = 0;
        int     c;
+       int     vers;
        struct sigaction sa;
        struct rlimit rlim;
 
+       /* Set the basename */
+       if ((progname = strrchr(argv[0], '/')) != NULL)
+               progname++;
+       else
+               progname = argv[0];
+
        /* Parse the command line options and arguments. */
        opterr = 0;
        while ((c = getopt_long(argc, argv, "o:nFd:f:p:P:hH:N:V:vrs:t:g", longopts, NULL)) != EOF)
@@ -653,8 +719,8 @@ main(int argc, char **argv)
                        descriptors = atoi(optarg);
                        if (descriptors <= 0) {
                                fprintf(stderr, "%s: bad descriptors: %s\n",
-                                       argv [0], optarg);
-                               usage(argv [0], 1);
+                                       progname, optarg);
+                               usage(progname, 1);
                        }
                        break;
                case 'F':
@@ -670,19 +736,25 @@ main(int argc, char **argv)
                        ha_callout_prog = optarg;
                        break;
                case 'h':
-                       usage(argv [0], 0);
+                       usage(progname, 0);
                        break;
                case 'P':       /* XXX for nfs-server compatibility */
                case 'p':
                        port = atoi(optarg);
                        if (port <= 0 || port > 65535) {
                                fprintf(stderr, "%s: bad port number: %s\n",
-                                       argv [0], optarg);
-                               usage(argv [0], 1);
+                                       progname, optarg);
+                               usage(progname, 1);
                        }
                        break;
                case 'N':
-                       nfs_version &= ~(1 << (atoi (optarg) - 1));
+                       vers = atoi(optarg);
+                       if (vers < 2 || vers > 4) {
+                               fprintf(stderr, "%s: bad version number: %s\n",
+                                       argv[0], optarg);
+                               usage(argv[0], 1);
+                       }
+                       nfs_version &= ~NFSVERSBIT(vers);
                        break;
                case 'n':
                        _rpcfdtype = SOCK_DGRAM;
@@ -693,7 +765,7 @@ main(int argc, char **argv)
                case 's':
                        if ((state_dir = xstrdup(optarg)) == NULL) {
                                fprintf(stderr, "%s: xstrdup(%s) failed!\n",
-                                       argv[0], optarg);
+                                       progname, optarg);
                                exit(1);
                        }
                        break;
@@ -701,33 +773,37 @@ main(int argc, char **argv)
                        num_threads = atoi (optarg);
                        break;
                case 'V':
-                       nfs_version |= 1 << (atoi (optarg) - 1);
+                       vers = atoi(optarg);
+                       if (vers < 2 || vers > 4) {
+                               fprintf(stderr, "%s: bad version number: %s\n",
+                                       argv[0], optarg);
+                               usage(argv[0], 1);
+                       }
+                       nfs_version |= NFSVERSBIT(vers);
                        break;
                case 'v':
-                       printf("kmountd %s\n", VERSION);
+                       printf("%s version " VERSION "\n", progname);
                        exit(0);
                case 0:
                        break;
                case '?':
                default:
-                       usage(argv [0], 1);
+                       usage(progname, 1);
                }
 
-       /* No more arguments allowed.
-        * Require at least one valid version (2, 3, or 4)
-        */
-       if (optind != argc || !(nfs_version & 0xE))
-               usage(argv [0], 1);
+       /* No more arguments allowed. */
+       if (optind != argc || !version_any())
+               usage(progname, 1);
 
        if (chdir(state_dir)) {
                fprintf(stderr, "%s: chdir(%s) failed: %s\n",
-                       argv [0], state_dir, strerror(errno));
+                       progname, state_dir, strerror(errno));
                exit(1);
        }
 
        if (getrlimit (RLIMIT_NOFILE, &rlim) != 0)
                fprintf(stderr, "%s: getrlimit (RLIMIT_NOFILE) failed: %s\n",
-                               argv [0], strerror(errno));
+                               progname, strerror(errno));
        else {
                /* glibc sunrpc code dies if getdtablesize > FD_SETSIZE */
                if ((descriptors == 0 && rlim.rlim_cur > FD_SETSIZE) ||
@@ -737,14 +813,14 @@ main(int argc, char **argv)
                        rlim.rlim_cur = descriptors;
                        if (setrlimit (RLIMIT_NOFILE, &rlim) != 0) {
                                fprintf(stderr, "%s: setrlimit (RLIMIT_NOFILE) failed: %s\n",
-                                       argv [0], strerror(errno));
+                                       progname, strerror(errno));
                                exit(1);
                        }
                }
        }
        /* Initialize logging. */
        if (!foreground) xlog_stderr(0);
-       xlog_open("mountd");
+       xlog_open(progname);
 
        sa.sa_handler = SIG_IGN;
        sa.sa_flags = 0;
@@ -764,15 +840,17 @@ main(int argc, char **argv)
        if (new_cache)
                cache_open();
 
-       if (nfs_version & (0x1 << 1)) {
-               rpc_init("mountd", MOUNTPROG, MOUNTVERS,
-                        mount_dispatch, port);
-               rpc_init("mountd", MOUNTPROG, MOUNTVERS_POSIX,
-                        mount_dispatch, port);
+       if (version2()) {
+               listeners += nfs_svc_create("mountd", MOUNTPROG,
+                                       MOUNTVERS, mount_dispatch, port);
+               listeners += nfs_svc_create("mountd", MOUNTPROG,
+                                       MOUNTVERS_POSIX, mount_dispatch, port);
        }
-       if (nfs_version & (0x1 << 2))
-               rpc_init("mountd", MOUNTPROG, MOUNTVERS_NFSV3,
-                        mount_dispatch, port);
+       if (version3())
+               listeners += nfs_svc_create("mountd", MOUNTPROG,
+                                       MOUNTVERS_NFSV3, mount_dispatch, port);
+       if (version23() && listeners == 0)
+               xlog(L_FATAL, "mountd: could not create listeners\n");
 
        sa.sa_handler = killer;
        sigaction(SIGINT, &sa, NULL);
@@ -813,9 +891,11 @@ main(int argc, char **argv)
        if (num_threads > 1)
                fork_workers();
 
+       xlog(L_NOTICE, "Version " VERSION " starting");
        my_svc_run();
 
-       xlog(L_ERROR, "Ack! Gack! svc_run returned!\n");
+       xlog(L_ERROR, "RPC service loop terminated unexpectedly. Exiting...\n");
+       unregister_services();
        exit(1);
 }