/* $OpenBSD: mountd.c,v 1.85 2015/12/23 21:32:52 tim Exp $ */ /* $NetBSD: mountd.c,v 1.31 1996/02/18 11:57:53 fvdl Exp $ */ /* * Copyright (c) 1989, 1993 * The Regents of the University of California. All rights reserved. * * This code is derived from software contributed to Berkeley by * Herb Hasler and Rick Macklem at The University of Guelph. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * 3. Neither the name of the University nor the names of its contributors * may be used to endorse or promote products derived from this software * without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "pathnames.h" #include #define isterminated(str, size) (memchr((str), '\0', (size)) != NULL) /* * Structures for keeping the mount list and export list */ struct mountlist { struct mountlist *ml_next; char ml_host[RPCMNT_NAMELEN+1]; char ml_dirp[RPCMNT_PATHLEN+1]; }; struct dirlist { struct dirlist *dp_left; struct dirlist *dp_right; int dp_flag; struct hostlist *dp_hosts; /* List of hosts this dir exported to */ char dp_dirp[1]; /* Actually malloc'd to size of dir */ }; /* dp_flag bits */ #define DP_DEFSET 0x1 #define DP_HOSTSET 0x2 struct exportlist { struct exportlist *ex_next; struct dirlist *ex_dirl; struct dirlist *ex_defdir; int ex_flag; fsid_t ex_fs; char *ex_fsdir; }; /* ex_flag bits */ #define EX_LINKED 0x1 struct netmsk { in_addr_t nt_net; in_addr_t nt_mask; char *nt_name; }; union grouptypes { struct hostent *gt_hostent; struct netmsk gt_net; }; struct grouplist { int gr_type; union grouptypes gr_ptr; struct grouplist *gr_next; }; /* Group types */ #define GT_NULL 0x0 #define GT_HOST 0x1 #define GT_NET 0x2 #define GT_IGNORE 0x5 struct hostlist { int ht_flag; /* Uses DP_xx bits */ struct grouplist *ht_grp; struct hostlist *ht_next; }; struct fhreturn { int fhr_flag; int fhr_vers; nfsfh_t fhr_fh; }; #define IMSG_GETFH_REQ 0x0 #define IMSG_GETFH_RESP 0x1 #define IMSG_EXPORT_REQ 0x2 #define IMSG_EXPORT_RESP 0x3 #define IMSG_DELEXPORT 0x4 #define IMSG_MLIST_APPEND 0x5 #define IMSG_MLIST_OPEN 0x6 #define IMSG_MLIST_CLOSE 0x7 #define IMSG_MLIST_WRITE 0x8 struct getfh_resp { fhandle_t gr_fh; int gr_error; }; struct export_req { char er_path[MNAMELEN]; struct export_args er_args; struct sockaddr er_addr; struct sockaddr er_mask; }; /* Global defs */ char *add_expdir(struct dirlist **, char *, int); void add_dlist(struct dirlist **, struct dirlist *, struct grouplist *, int); void add_mlist(char *, char *); void check_child(int); int check_dirpath(char *); int check_options(struct dirlist *); int chk_host(struct dirlist *, in_addr_t, int *, int *); void del_mlist(char *, char *); struct dirlist *dirp_search(struct dirlist *, char *); int do_mount(struct exportlist *, struct grouplist *, int, struct xucred *, char *, int); int do_opt(char **, char **, struct exportlist *, struct grouplist *, int *, int *, struct xucred *); struct exportlist *ex_search(fsid_t *); struct exportlist *get_exp(void); void free_dir(struct dirlist *); void free_exp(struct exportlist *); void free_grp(struct grouplist *); void free_host(struct hostlist *); void new_exportlist(int signo); void get_exportlist(void); int get_host(char *, struct grouplist *, struct grouplist *); int get_num(char *); struct hostlist *get_ht(void); int get_line(void); void get_mountlist(void); int get_net(char *, struct netmsk *, int); void getexp_err(struct exportlist *, struct grouplist *); struct grouplist *get_grp(void); void hang_dirp(struct dirlist *, struct grouplist *, struct exportlist *, int); void mntsrv(struct svc_req *, SVCXPRT *); void nextfield(char **, char **); void out_of_mem(void); void parsecred(char *, struct xucred *); void privchild(int); int put_exlist(struct dirlist *, XDR *, struct dirlist *, int *); ssize_t recv_imsg(struct imsg *); int scan_tree(struct dirlist *, in_addr_t); int send_imsg(u_int32_t, void *, u_int16_t); void send_umntall(int signo); int umntall_each(caddr_t, struct sockaddr_in *); int xdr_dir(XDR *, char *); int xdr_explist(XDR *, caddr_t); int xdr_fhs(XDR *, caddr_t); int xdr_mlist(XDR *, caddr_t); void mountd_svc_run(void); struct exportlist *exphead; struct mountlist *mlhead; struct grouplist *grphead; char exname[PATH_MAX]; struct xucred def_anon = { .cr_uid = (uid_t) -2, .cr_gid = (gid_t) -2, .cr_ngroups = 0, .cr_groups = { 0, } }; int opt_flags; /* Bits for above */ #define OP_MAPROOT 0x01 #define OP_MAPALL 0x02 #define OP_MASK 0x08 #define OP_NET 0x10 #define OP_ALLDIRS 0x40 struct imsgbuf ibuf; int debug = 0; volatile sig_atomic_t gotchld; volatile sig_atomic_t gothup; volatile sig_atomic_t gotterm; /* * Mountd server for NFS mount protocol as described in: * NFS: Network File System Protocol Specification, RFC1094, Appendix A * The optional arguments are the exports file name * default: _PATH_EXPORTS * "-d" to enable debugging */ int main(int argc, char *argv[]) { SVCXPRT *udptransp, *tcptransp; FILE *pidfile; int c, socks[2]; while ((c = getopt(argc, argv, "dnr")) != -1) switch (c) { case 'd': debug = 1; break; case 'n': case 'r': /* Compatibility */ break; default: fprintf(stderr, "usage: mountd [-d] [exportsfile]\n"); exit(1); } argc -= optind; argv += optind; grphead = NULL; exphead = NULL; mlhead = NULL; strlcpy(exname, argc == 1? *argv : _PATH_EXPORTS, sizeof(exname)); openlog("mountd", LOG_PID, LOG_DAEMON); if (debug) fprintf(stderr, "Here we go.\n"); if (debug == 0) { daemon(0, 0); signal(SIGINT, SIG_IGN); signal(SIGQUIT, SIG_IGN); } /* Store pid in file unless mountd is already running */ pidfile = fopen(_PATH_MOUNTDPID, "r"); if (pidfile != NULL) { if (fscanf(pidfile, "%d\n", &c) > 0 && c > 0) { if (kill(c, 0) == 0) { syslog(LOG_ERR, "Already running (pid %d)", c); exit(1); } } pidfile = freopen(_PATH_MOUNTDPID, "w", pidfile); } else { pidfile = fopen(_PATH_MOUNTDPID, "w"); } if (pidfile) { fprintf(pidfile, "%ld\n", (long)getpid()); fclose(pidfile); } signal(SIGCHLD, (void (*)(int)) check_child); signal(SIGHUP, (void (*)(int)) new_exportlist); if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, socks) == -1) { syslog(LOG_ERR, "socketpair: %m"); exit(1); } switch (fork()) { case -1: syslog(LOG_ERR, "fork: %m"); exit(1); case 0: close(socks[0]); privchild(socks[1]); } close(socks[1]); if (pledge("stdio rpath inet dns getpw", NULL) == -1) { syslog(LOG_ERR, "pledge: %m"); exit(1); } signal(SIGTERM, (void (*)(int)) send_umntall); imsg_init(&ibuf, socks[0]); setproctitle("parent"); if (debug) fprintf(stderr, "Getting export list.\n"); get_exportlist(); if (debug) fprintf(stderr, "Getting mount list.\n"); get_mountlist(); if ((udptransp = svcudp_create(RPC_ANYSOCK)) == NULL || (tcptransp = svctcp_create(RPC_ANYSOCK, 0, 0)) == NULL) { syslog(LOG_ERR, "Can't create socket"); exit(1); } pmap_unset(RPCPROG_MNT, RPCMNT_VER1); pmap_unset(RPCPROG_MNT, RPCMNT_VER3); if (!svc_register(udptransp, RPCPROG_MNT, RPCMNT_VER1, mntsrv, IPPROTO_UDP) || !svc_register(udptransp, RPCPROG_MNT, RPCMNT_VER3, mntsrv, IPPROTO_UDP) || !svc_register(tcptransp, RPCPROG_MNT, RPCMNT_VER1, mntsrv, IPPROTO_TCP) || !svc_register(tcptransp, RPCPROG_MNT, RPCMNT_VER3, mntsrv, IPPROTO_TCP)) { syslog(LOG_ERR, "Can't register mount"); exit(1); } mountd_svc_run(); syslog(LOG_ERR, "Mountd died"); exit(1); } void check_child(int signo) { gotchld = 1; } void privchild(int sock) { struct imsg imsg; struct pollfd pfd[1]; struct ufs_args args; struct statfs sfb; struct getfh_resp resp; struct export_req *req; struct mountlist *ml; FILE *fp; char *path; int error, size; imsg_init(&ibuf, sock); setproctitle("[priv]"); fp = NULL; for (;;) { if (gothup) { kill(getppid(), SIGHUP); gothup = 0; } pfd[0].fd = ibuf.fd; pfd[0].events = POLLIN; switch (poll(pfd, 1, INFTIM)) { case -1: if (errno == EINTR) continue; syslog(LOG_ERR, "poll: %m"); _exit(1); case 0: continue; } if (pfd[0].revents & POLLHUP) { syslog(LOG_ERR, "Socket disconnected"); _exit(1); } if (!(pfd[0].revents & POLLIN)) continue; switch (imsg_read(&ibuf)) { case -1: syslog(LOG_ERR, "imsg_read: %m"); _exit(1); case 0: syslog(LOG_ERR, "Socket disconnected"); _exit(1); } while ((size = imsg_get(&ibuf, &imsg)) != 0) { if (size == -1) { syslog(LOG_ERR, "imsg_get: %m"); _exit(1); } size -= IMSG_HEADER_SIZE; switch (imsg.hdr.type) { case IMSG_GETFH_REQ: if (size != PATH_MAX) { syslog(LOG_ERR, "Invalid message size"); break; } path = imsg.data; if (getfh(path, &resp.gr_fh) == -1) resp.gr_error = errno; else resp.gr_error = 0; send_imsg(IMSG_GETFH_RESP, &resp, sizeof(resp)); break; case IMSG_EXPORT_REQ: if (size != sizeof(*req)) { syslog(LOG_ERR, "Invalid message size"); break; } req = imsg.data; if (statfs(req->er_path, &sfb) == -1) { error = errno; syslog(LOG_ERR, "statfs: %m"); send_imsg(IMSG_EXPORT_RESP, &error, sizeof(error)); break; } args.fspec = 0; args.export_info = req->er_args; args.export_info.ex_addr = &req->er_addr; args.export_info.ex_mask = &req->er_mask; if (mount(sfb.f_fstypename, sfb.f_mntonname, sfb.f_flags | MNT_UPDATE, &args) == -1) { error = errno; syslog(LOG_ERR, "mount: %m"); send_imsg(IMSG_EXPORT_RESP, &error, sizeof(error)); break; } error = 0; send_imsg(IMSG_EXPORT_RESP, &error, sizeof(error)); break; case IMSG_DELEXPORT: if (size != MNAMELEN) { syslog(LOG_ERR, "Invalid message size"); break; } path = imsg.data; if (statfs(path, &sfb) == -1) { syslog(LOG_ERR, "statfs: %m"); break; } memset(&args, 0, sizeof(args)); args.export_info.ex_flags = MNT_DELEXPORT; if (mount(sfb.f_fstypename, sfb.f_mntonname, sfb.f_flags | MNT_UPDATE, &args) == -1) syslog(LOG_ERR, "mount: %m"); break; case IMSG_MLIST_APPEND: if (size != sizeof(*ml)) { syslog(LOG_ERR, "Invalid message size"); break; } if (fp != NULL) break; ml = imsg.data; if (!isterminated(&ml->ml_host, sizeof(ml->ml_host)) || !isterminated(&ml->ml_dirp, sizeof(ml->ml_dirp))) break; fp = fopen(_PATH_RMOUNTLIST, "a"); if (fp == NULL) { syslog(LOG_ERR, "fopen: %s: %m", _PATH_RMOUNTLIST); break; } fprintf(fp, "%s %s\n", ml->ml_host, ml->ml_dirp); fclose(fp); fp = NULL; break; case IMSG_MLIST_OPEN: if (size != 0) { syslog(LOG_ERR, "Invalid message size"); break; } if (fp != NULL) break; fp = fopen(_PATH_RMOUNTLIST, "w"); if (fp == NULL) syslog(LOG_ERR, "fopen: %s: %m", _PATH_RMOUNTLIST); break; case IMSG_MLIST_WRITE: if (size != sizeof(*ml)) { syslog(LOG_ERR, "Invalid message size"); break; } if (fp == NULL) break; ml = imsg.data; if (!isterminated(&ml->ml_host, sizeof(ml->ml_host)) || !isterminated(&ml->ml_dirp, sizeof(ml->ml_host))) break; fprintf(fp, "%s %s\n", ml->ml_host, ml->ml_dirp); break; case IMSG_MLIST_CLOSE: if (size != 0) { syslog(LOG_ERR, "Invalid message size"); break; } if (fp != NULL) { fclose(fp); fp = NULL; } break; default: syslog(LOG_ERR, "Unexpected message type"); break; } imsg_free(&imsg); } } } int imsg_getfh(char *path, fhandle_t *fh) { struct imsg imsg; struct getfh_resp *resp; ssize_t size; if (send_imsg(IMSG_GETFH_REQ, path, PATH_MAX) == -1) return (-1); size = recv_imsg(&imsg); if (size == -1) return (-1); if (imsg.hdr.type != IMSG_GETFH_RESP || size != sizeof(*resp)) { syslog(LOG_ERR, "Invalid message"); imsg_free(&imsg); errno = EINVAL; return (-1); } resp = imsg.data; *fh = resp->gr_fh; if (resp->gr_error) { errno = resp->gr_error; imsg_free(&imsg); return (-1); } imsg_free(&imsg); return (0); } int imsg_export(const char *dir, struct export_args *args) { struct export_req req; struct imsg imsg; ssize_t size; if (strlcpy(req.er_path, dir, sizeof(req.er_path)) >= sizeof(req.er_path)) { syslog(LOG_ERR, "%s: mount dir too long", dir); errno = EINVAL; return (-1); } req.er_args = *args; if (args->ex_addrlen) req.er_addr = *args->ex_addr; if (args->ex_masklen) req.er_mask = *args->ex_mask; if (send_imsg(IMSG_EXPORT_REQ, &req, sizeof(req)) == -1) return (-1); size = recv_imsg(&imsg); if (size == -1) return (-1); if (imsg.hdr.type != IMSG_EXPORT_RESP || size != sizeof(int)) { syslog(LOG_ERR, "Invalid message"); imsg_free(&imsg); errno = EINVAL; return (-1); } if (*(int *)imsg.data != 0) { errno = *(int *)imsg.data; imsg_free(&imsg); return (-1); } imsg_free(&imsg); return (0); } ssize_t recv_imsg(struct imsg *imsg) { ssize_t n; n = imsg_read(&ibuf); if (n == -1) { syslog(LOG_ERR, "imsg_read: %m"); return (-1); } if (n == 0) { syslog(LOG_ERR, "Socket disconnected"); errno = EINVAL; return (-1); } n = imsg_get(&ibuf, imsg); if (n == -1) { syslog(LOG_ERR, "imsg_get: %m"); return (-1); } if (n == 0) { syslog(LOG_ERR, "No messages ready"); errno = EINVAL; return (-1); } return (n - IMSG_HEADER_SIZE); } int send_imsg(u_int32_t type, void *data, u_int16_t size) { if (imsg_compose(&ibuf, type, 0, 0, -1, data, size) == -1) { syslog(LOG_ERR, "imsg_compose: %m"); return (-1); } if (imsg_flush(&ibuf) == -1) { syslog(LOG_ERR, "imsg_flush: %m"); return (-1); } return (0); } void mountd_svc_run(void) { struct pollfd *pfd = NULL, *newp; nfds_t saved_max_pollfd = 0; int nready, status; for (;;) { if (gotchld) { if (waitpid(WAIT_ANY, &status, WNOHANG) == -1) { syslog(LOG_ERR, "waitpid: %m"); break; } if (WIFEXITED(status)) { syslog(LOG_ERR, "Child exited"); break; } if (WIFSIGNALED(status)) { syslog(LOG_ERR, "Child terminated by signal"); break; } gotchld = 0; } if (gothup) { get_exportlist(); gothup = 0; } if (gotterm) break; if (svc_max_pollfd > saved_max_pollfd) { newp = reallocarray(pfd, svc_max_pollfd, sizeof(*pfd)); if (!newp) { free(pfd); perror("mountd_svc_run: - realloc failed"); return; } pfd = newp; saved_max_pollfd = svc_max_pollfd; } memcpy(pfd, svc_pollfd, svc_max_pollfd * sizeof(*pfd)); nready = poll(pfd, svc_max_pollfd, INFTIM); switch (nready) { case -1: if (errno == EINTR) break; perror("mountd_svc_run: - poll failed"); free(pfd); return; case 0: break; default: svc_getreq_poll(pfd, nready); break; } } (void) clnt_broadcast(RPCPROG_MNT, RPCMNT_VER1, RPCMNT_UMNTALL, xdr_void, (caddr_t)0, xdr_void, (caddr_t)0, umntall_each); exit(0); } /* * The mount rpc service */ void mntsrv(struct svc_req *rqstp, SVCXPRT *transp) { char rpcpath[RPCMNT_PATHLEN+1], dirpath[PATH_MAX]; struct hostent *hp = NULL; struct exportlist *ep; sigset_t sighup_mask; int defset, hostset; struct fhreturn fhr; struct dirlist *dp; struct statfs fsb; struct stat stb; in_addr_t saddr; u_short sport; long bad = 0; sigemptyset(&sighup_mask); sigaddset(&sighup_mask, SIGHUP); saddr = transp->xp_raddr.sin_addr.s_addr; sport = ntohs(transp->xp_raddr.sin_port); switch (rqstp->rq_proc) { case NULLPROC: if (!svc_sendreply(transp, xdr_void, NULL)) syslog(LOG_ERR, "Can't send reply"); return; case RPCMNT_MOUNT: if (debug) fprintf(stderr, "Got mount request from %s\n", inet_ntoa(transp->xp_raddr.sin_addr)); if (sport >= IPPORT_RESERVED) { syslog(LOG_NOTICE, "Refused mount RPC from host %s port %d", inet_ntoa(transp->xp_raddr.sin_addr), sport); svcerr_weakauth(transp); return; } if (!svc_getargs(transp, xdr_dir, rpcpath)) { svcerr_decode(transp); return; } if (debug) fprintf(stderr, "rpcpath: %s\n", rpcpath); /* * Get the real pathname and make sure it is a file or * directory that exists. */ if (realpath(rpcpath, dirpath) == NULL) { bad = errno; if (debug) fprintf(stderr, "realpath failed on %s\n", rpcpath); strlcpy(dirpath, rpcpath, sizeof(dirpath)); } else if (stat(dirpath, &stb) < 0 || (!S_ISDIR(stb.st_mode) && !S_ISREG(stb.st_mode)) || statfs(dirpath, &fsb) < 0) { if (debug) fprintf(stderr, "stat failed on %s\n", dirpath); bad = ENOENT; /* We will send error reply later */ } /* Check in the exports list */ sigprocmask(SIG_BLOCK, &sighup_mask, NULL); ep = ex_search(&fsb.f_fsid); hostset = defset = 0; if (ep && (chk_host(ep->ex_defdir, saddr, &defset, &hostset) || ((dp = dirp_search(ep->ex_dirl, dirpath)) && chk_host(dp, saddr, &defset, &hostset)) || (defset && scan_tree(ep->ex_defdir, saddr) == 0 && scan_tree(ep->ex_dirl, saddr) == 0))) { if (bad) { if (!svc_sendreply(transp, xdr_long, (caddr_t)&bad)) syslog(LOG_ERR, "Can't send reply"); sigprocmask(SIG_UNBLOCK, &sighup_mask, NULL); return; } if (hostset & DP_HOSTSET) fhr.fhr_flag = hostset; else fhr.fhr_flag = defset; fhr.fhr_vers = rqstp->rq_vers; /* Get the file handle */ memset(&fhr.fhr_fh, 0, sizeof(nfsfh_t)); if (imsg_getfh(dirpath, (fhandle_t *)&fhr.fhr_fh) < 0) { bad = errno; syslog(LOG_ERR, "Can't get fh for %s", dirpath); if (!svc_sendreply(transp, xdr_long, (caddr_t)&bad)) syslog(LOG_ERR, "Can't send reply"); sigprocmask(SIG_UNBLOCK, &sighup_mask, NULL); return; } if (!svc_sendreply(transp, xdr_fhs, (caddr_t)&fhr)) syslog(LOG_ERR, "Can't send reply"); if (hp == NULL) hp = gethostbyaddr((caddr_t)&saddr, sizeof(saddr), AF_INET); if (hp) add_mlist(hp->h_name, dirpath); else add_mlist(inet_ntoa(transp->xp_raddr.sin_addr), dirpath); if (debug) { fprintf(stderr, "Mount successful for %s by %s.\n", dirpath, inet_ntoa(transp->xp_raddr.sin_addr)); } } else bad = EACCES; if (bad && !svc_sendreply(transp, xdr_long, (caddr_t)&bad)) syslog(LOG_ERR, "Can't send reply"); sigprocmask(SIG_UNBLOCK, &sighup_mask, NULL); return; case RPCMNT_DUMP: if (!svc_sendreply(transp, xdr_mlist, NULL)) syslog(LOG_ERR, "Can't send reply"); return; case RPCMNT_UMOUNT: if (sport >= IPPORT_RESERVED) { svcerr_weakauth(transp); return; } if (!svc_getargs(transp, xdr_dir, dirpath)) { svcerr_decode(transp); return; } if (!svc_sendreply(transp, xdr_void, NULL)) syslog(LOG_ERR, "Can't send reply"); hp = gethostbyaddr((caddr_t)&saddr, sizeof(saddr), AF_INET); if (hp) del_mlist(hp->h_name, dirpath); del_mlist(inet_ntoa(transp->xp_raddr.sin_addr), dirpath); return; case RPCMNT_UMNTALL: if (sport >= IPPORT_RESERVED) { svcerr_weakauth(transp); return; } if (!svc_sendreply(transp, xdr_void, NULL)) syslog(LOG_ERR, "Can't send reply"); hp = gethostbyaddr((caddr_t)&saddr, sizeof(saddr), AF_INET); if (hp) del_mlist(hp->h_name, NULL); del_mlist(inet_ntoa(transp->xp_raddr.sin_addr), NULL); return; case RPCMNT_EXPORT: if (!svc_sendreply(transp, xdr_explist, NULL)) syslog(LOG_ERR, "Can't send reply"); return; default: svcerr_noproc(transp); return; } } /* * Xdr conversion for a dirpath string */ int xdr_dir(XDR *xdrsp, char *dirp) { return (xdr_string(xdrsp, &dirp, RPCMNT_PATHLEN)); } /* * Xdr routine to generate file handle reply */ int xdr_fhs(XDR *xdrsp, caddr_t cp) { struct fhreturn *fhrp = (struct fhreturn *)cp; long ok = 0, len, auth; if (!xdr_long(xdrsp, &ok)) return (0); switch (fhrp->fhr_vers) { case 1: return (xdr_opaque(xdrsp, (caddr_t)&fhrp->fhr_fh, NFSX_V2FH)); case 3: len = NFSX_V3FH; if (!xdr_long(xdrsp, &len)) return (0); if (!xdr_opaque(xdrsp, (caddr_t)&fhrp->fhr_fh, len)) return (0); auth = RPCAUTH_UNIX; len = 1; if (!xdr_long(xdrsp, &len)) return (0); return (xdr_long(xdrsp, &auth)); } return (0); } int xdr_mlist(XDR *xdrsp, caddr_t cp) { int true = 1, false = 0; struct mountlist *mlp; char *strp; mlp = mlhead; while (mlp) { if (!xdr_bool(xdrsp, &true)) return (0); strp = &mlp->ml_host[0]; if (!xdr_string(xdrsp, &strp, RPCMNT_NAMELEN)) return (0); strp = &mlp->ml_dirp[0]; if (!xdr_string(xdrsp, &strp, RPCMNT_PATHLEN)) return (0); mlp = mlp->ml_next; } if (!xdr_bool(xdrsp, &false)) return (0); return (1); } /* * Xdr conversion for export list */ int xdr_explist(XDR *xdrsp, caddr_t cp) { struct exportlist *ep; int false = 0, putdef; sigset_t sighup_mask; sigemptyset(&sighup_mask); sigaddset(&sighup_mask, SIGHUP); sigprocmask(SIG_BLOCK, &sighup_mask, NULL); ep = exphead; while (ep) { putdef = 0; if (put_exlist(ep->ex_dirl, xdrsp, ep->ex_defdir, &putdef)) goto errout; if (ep->ex_defdir && putdef == 0 && put_exlist(ep->ex_defdir, xdrsp, NULL, &putdef)) goto errout; ep = ep->ex_next; } sigprocmask(SIG_UNBLOCK, &sighup_mask, NULL); if (!xdr_bool(xdrsp, &false)) return (0); return (1); errout: sigprocmask(SIG_UNBLOCK, &sighup_mask, NULL); return (0); } /* * Called from xdr_explist() to traverse the tree and export the * directory paths. */ int put_exlist(struct dirlist *dp, XDR *xdrsp, struct dirlist *adp, int *putdefp) { int true = 1, false = 0, gotalldir = 0; struct grouplist *grp; struct hostlist *hp; char *strp; if (dp) { if (put_exlist(dp->dp_left, xdrsp, adp, putdefp)) return (1); if (!xdr_bool(xdrsp, &true)) return (1); strp = dp->dp_dirp; if (!xdr_string(xdrsp, &strp, RPCMNT_PATHLEN)) return (1); if (adp && !strcmp(dp->dp_dirp, adp->dp_dirp)) { gotalldir = 1; *putdefp = 1; } if ((dp->dp_flag & DP_DEFSET) == 0 && (gotalldir == 0 || (adp->dp_flag & DP_DEFSET) == 0)) { hp = dp->dp_hosts; while (hp) { grp = hp->ht_grp; if (grp->gr_type == GT_HOST) { if (!xdr_bool(xdrsp, &true)) return (1); strp = grp->gr_ptr.gt_hostent->h_name; if (!xdr_string(xdrsp, &strp, RPCMNT_NAMELEN)) return (1); } else if (grp->gr_type == GT_NET) { if (!xdr_bool(xdrsp, &true)) return (1); strp = grp->gr_ptr.gt_net.nt_name; if (!xdr_string(xdrsp, &strp, RPCMNT_NAMELEN)) return (1); } hp = hp->ht_next; if (gotalldir && hp == NULL) { hp = adp->dp_hosts; gotalldir = 0; } } } if (!xdr_bool(xdrsp, &false)) return (1); if (put_exlist(dp->dp_right, xdrsp, adp, putdefp)) return (1); } return (0); } #define LINESIZ 10240 char line[LINESIZ]; FILE *exp_file; void new_exportlist(int signo) { gothup = 1; } /* * Get the export list */ void get_exportlist(void) { int len, has_host, exflags, got_nondir, dirplen = 0, num; int lookup_failed, num_hosts, i, netgrp; char *cp, *endcp, *dirp = NULL, *hst, *usr, *dom, savedc; struct exportlist *ep, *ep2; struct grouplist *grp, *tgrp; struct exportlist **epp; struct dirlist *dirhead; struct statfs fsb, *ofsp, *fsp; struct hostent *hpe; struct xucred anon; struct fsarray { int exflags; char *mntonname; } *fstbl; /* * First, get rid of the old list */ ep = exphead; while (ep) { ep2 = ep; ep = ep->ex_next; free_exp(ep2); } exphead = NULL; grp = grphead; while (grp) { tgrp = grp; grp = grp->gr_next; free_grp(tgrp); } grphead = NULL; /* * And delete exports that are in the kernel for all local * file systems. * XXX: Should know how to handle all local exportable file systems * instead of just MOUNT_FFS. */ num = getmntinfo(&ofsp, MNT_NOWAIT); if (num == 0 && errno) syslog(LOG_ERR, "getmntinfo: %s", strerror(errno)); fsp = ofsp; fstbl = calloc(num, sizeof (fstbl[0])); if (fstbl == NULL) out_of_mem(); for (i = 0; i < num; i++) { if (!strncmp(fsp->f_fstypename, MOUNT_MFS, MFSNAMELEN) || !strncmp(fsp->f_fstypename, MOUNT_FFS, MFSNAMELEN) || !strncmp(fsp->f_fstypename, MOUNT_EXT2FS, MFSNAMELEN) || !strncmp(fsp->f_fstypename, MOUNT_MSDOS, MFSNAMELEN) || !strncmp(fsp->f_fstypename, MOUNT_CD9660, MFSNAMELEN)) { fstbl[i].exflags = MNT_DELEXPORT; fstbl[i].mntonname = fsp->f_mntonname; } fsp++; } /* * Read in the exports file and build the list, calling mount() through * the privileged child as we go along to push the export rules into * the kernel. */ if ((exp_file = fopen(exname, "r")) == NULL) { syslog(LOG_ERR, "Can't open %s", exname); exit(2); } dirhead = NULL; while (get_line()) { if (debug) fprintf(stderr, "Got line %s\n",line); cp = line; nextfield(&cp, &endcp); if (*cp == '#') goto nextline; /* * Set defaults. */ has_host = FALSE; num_hosts = 0; lookup_failed = FALSE; anon = def_anon; exflags = MNT_EXPORTED; got_nondir = 0; opt_flags = 0; ep = NULL; /* * Create new exports list entry */ len = endcp-cp; tgrp = grp = get_grp(); while (len > 0) { if (len > RPCMNT_NAMELEN) { getexp_err(ep, tgrp); goto nextline; } if (*cp == '-') { if (ep == NULL) { getexp_err(ep, tgrp); goto nextline; } if (debug) fprintf(stderr, "doing opt %s\n", cp); got_nondir = 1; if (do_opt(&cp, &endcp, ep, grp, &has_host, &exflags, &anon)) { getexp_err(ep, tgrp); goto nextline; } } else if (*cp == '/') { savedc = *endcp; *endcp = '\0'; if (check_dirpath(cp) && statfs(cp, &fsb) >= 0) { if (got_nondir) { syslog(LOG_ERR, "Dirs must be first"); getexp_err(ep, tgrp); goto nextline; } if (ep) { if (ep->ex_fs.val[0] != fsb.f_fsid.val[0] || ep->ex_fs.val[1] != fsb.f_fsid.val[1]) { getexp_err(ep, tgrp); goto nextline; } } else { /* * See if this directory is already * in the list. */ ep = ex_search(&fsb.f_fsid); if (ep == NULL) { int len; ep = get_exp(); ep->ex_fs = fsb.f_fsid; len = strlen(fsb.f_mntonname) + 1; ep->ex_fsdir = malloc(len); if (ep->ex_fsdir) strlcpy(ep->ex_fsdir, fsb.f_mntonname, len); else out_of_mem(); if (debug) fprintf(stderr, "Making new ep fs=0x%x,0x%x\n", fsb.f_fsid.val[0], fsb.f_fsid.val[1]); } else if (debug) fprintf(stderr, "Found ep fs=0x%x,0x%x\n", fsb.f_fsid.val[0], fsb.f_fsid.val[1]); } /* * Add dirpath to export mount point. */ dirp = add_expdir(&dirhead, cp, len); dirplen = len; } else { getexp_err(ep, tgrp); goto nextline; } *endcp = savedc; } else { savedc = *endcp; *endcp = '\0'; got_nondir = 1; if (ep == NULL) { getexp_err(ep, tgrp); goto nextline; } /* * Get the host or netgroup. */ setnetgrent(cp); netgrp = getnetgrent((const char **)&hst, (const char **)&usr, (const char **)&dom); do { if (has_host) { grp->gr_next = get_grp(); grp = grp->gr_next; } else { memset(grp, 0, sizeof(*grp)); } if (netgrp) { if (hst == NULL) { syslog(LOG_ERR, "NULL hostname in netgroup %s, skipping", cp); grp->gr_type = GT_IGNORE; lookup_failed = TRUE; continue; } else if (get_host(hst, grp, tgrp)) { syslog(LOG_ERR, "Unknown host (%s) in netgroup %s", hst, cp); grp->gr_type = GT_IGNORE; lookup_failed = TRUE; continue; } } else if (get_host(cp, grp, tgrp)) { syslog(LOG_ERR, "Unknown host (%s) in line %s", cp, line); grp->gr_type = GT_IGNORE; lookup_failed = TRUE; continue; } has_host = TRUE; num_hosts++; } while (netgrp && getnetgrent((const char **)&hst, (const char **)&usr, (const char **)&dom)); endnetgrent(); *endcp = savedc; } cp = endcp; nextfield(&cp, &endcp); len = endcp - cp; } /* * If the exports list is empty due to unresolvable hostnames * we throw away the line. */ if (lookup_failed == TRUE && num_hosts == 0 && tgrp->gr_type == GT_IGNORE) { getexp_err(ep, tgrp); goto nextline; } if (check_options(dirhead)) { getexp_err(ep, tgrp); goto nextline; } if (!has_host) { grp->gr_type = GT_HOST; if (debug) fprintf(stderr, "Adding a default entry\n"); /* add a default group and make the grp list NULL */ hpe = malloc(sizeof(struct hostent)); if (hpe == NULL) out_of_mem(); hpe->h_name = strdup("Default"); if (hpe->h_name == NULL) out_of_mem(); hpe->h_addrtype = AF_INET; hpe->h_length = sizeof (u_int32_t); hpe->h_addr_list = NULL; grp->gr_ptr.gt_hostent = hpe; /* * Don't allow a network export coincide with a list of * host(s) on the same line. */ } else if ((opt_flags & OP_NET) && tgrp->gr_next) { getexp_err(ep, tgrp); goto nextline; } /* * Loop through hosts, pushing the exports into the kernel. * After loop, tgrp points to the start of the list and * grp points to the last entry in the list. */ grp = tgrp; do { /* * remove filesystem from unexport list * add MNT_DELEXPORT to exflags to clean up * any old addrlist in the kernel */ for (i = 0; i < num; i++) { if ((fstbl[i].mntonname != NULL) && (strcmp(fsb.f_mntonname, fstbl[i].mntonname) == 0) && (fstbl[i].exflags & MNT_DELEXPORT)) { exflags |= MNT_DELEXPORT; fstbl[i].exflags = 0; if (debug) fprintf(stderr, "removing %s %s from unexport list\n", dirp, fstbl[i].mntonname); } } if (debug) fprintf(stderr, "exporting %s\n", dirp); /* * Non-zero return indicates an error. Return * val of 1 means line is invalid (not just entry). */ i = do_mount(ep, grp, exflags, &anon, dirp, dirplen); exflags &= ~MNT_DELEXPORT; if (i == 1) { getexp_err(ep, tgrp); goto nextline; } else if (i == 2) { syslog(LOG_ERR, "Bad exports list entry (%s) in line %s", (grp->gr_type == GT_HOST) ? grp->gr_ptr.gt_hostent->h_name : (grp->gr_type == GT_NET) ? grp->gr_ptr.gt_net.nt_name : "Unknown", line); } } while (grp->gr_next && (grp = grp->gr_next)); /* * Success. Update the data structures. */ if (has_host) { hang_dirp(dirhead, tgrp, ep, opt_flags); grp->gr_next = grphead; grphead = tgrp; } else { hang_dirp(dirhead, NULL, ep, opt_flags); free_grp(grp); } dirhead = NULL; if ((ep->ex_flag & EX_LINKED) == 0) { ep2 = exphead; epp = &exphead; /* * Insert in the list in alphabetical order. */ while (ep2 && strcmp(ep2->ex_fsdir, ep->ex_fsdir) < 0) { epp = &ep2->ex_next; ep2 = ep2->ex_next; } if (ep2) ep->ex_next = ep2; *epp = ep; ep->ex_flag |= EX_LINKED; } nextline: if (dirhead) { free_dir(dirhead); dirhead = NULL; } } fsp = ofsp; for (i = 0; i < num; i++, fsp++) { if ((fstbl[i].exflags & MNT_DELEXPORT) == 0) continue; if (debug) fprintf(stderr, "unexporting %s %s\n", fsp->f_mntonname, fstbl[i].mntonname); send_imsg(IMSG_DELEXPORT, fsp->f_mntonname, sizeof(fsp->f_mntonname)); } free(fstbl); fclose(exp_file); } /* * Allocate an export list element */ struct exportlist * get_exp(void) { struct exportlist *ep; ep = calloc(1, sizeof (struct exportlist)); if (ep == NULL) out_of_mem(); return (ep); } /* * Allocate a group list element */ struct grouplist * get_grp(void) { struct grouplist *gp; gp = calloc(1, sizeof (struct grouplist)); if (gp == NULL) out_of_mem(); return (gp); } /* * Clean up upon an error in get_exportlist(). */ void getexp_err(struct exportlist *ep, struct grouplist *grp) { struct grouplist *tgrp; syslog(LOG_ERR, "Bad exports list line %s", line); if (ep && (ep->ex_flag & EX_LINKED) == 0) free_exp(ep); while (grp) { tgrp = grp; grp = grp->gr_next; free_grp(tgrp); } } /* * Search the export list for a matching fs. */ struct exportlist * ex_search(fsid_t *fsid) { struct exportlist *ep; ep = exphead; while (ep) { if (ep->ex_fs.val[0] == fsid->val[0] && ep->ex_fs.val[1] == fsid->val[1]) return (ep); ep = ep->ex_next; } return (ep); } /* * Add a directory path to the list. */ char * add_expdir(struct dirlist **dpp, char *cp, int len) { struct dirlist *dp; /* do not need +1 because of dp_dirp[1] */ dp = malloc(sizeof (struct dirlist) + len); if (dp == NULL) out_of_mem(); dp->dp_left = *dpp; dp->dp_right = NULL; dp->dp_flag = 0; dp->dp_hosts = NULL; strlcpy(dp->dp_dirp, cp, len + 1); *dpp = dp; return (dp->dp_dirp); } /* * Hang the dir list element off the dirpath binary tree as required * and update the entry for host. */ void hang_dirp(struct dirlist *dp, struct grouplist *grp, struct exportlist *ep, int flags) { struct hostlist *hp; struct dirlist *dp2; if (flags & OP_ALLDIRS) { if (ep->ex_defdir) free((caddr_t)dp); else ep->ex_defdir = dp; if (grp == NULL) { ep->ex_defdir->dp_flag |= DP_DEFSET; } else while (grp) { hp = get_ht(); hp->ht_grp = grp; hp->ht_next = ep->ex_defdir->dp_hosts; ep->ex_defdir->dp_hosts = hp; grp = grp->gr_next; } } else { /* * Loop through the directories adding them to the tree. */ while (dp) { dp2 = dp->dp_left; add_dlist(&ep->ex_dirl, dp, grp, flags); dp = dp2; } } } /* * Traverse the binary tree either updating a node that is already there * for the new directory or adding the new node. */ void add_dlist(struct dirlist **dpp, struct dirlist *newdp, struct grouplist *grp, int flags) { struct dirlist *dp; struct hostlist *hp; int cmp; dp = *dpp; if (dp) { cmp = strcmp(dp->dp_dirp, newdp->dp_dirp); if (cmp > 0) { add_dlist(&dp->dp_left, newdp, grp, flags); return; } else if (cmp < 0) { add_dlist(&dp->dp_right, newdp, grp, flags); return; } else free((caddr_t)newdp); } else { dp = newdp; dp->dp_left = NULL; *dpp = dp; } if (grp) { /* * Hang all of the host(s) off of the directory point. */ do { hp = get_ht(); hp->ht_grp = grp; hp->ht_next = dp->dp_hosts; dp->dp_hosts = hp; grp = grp->gr_next; } while (grp); } else { dp->dp_flag |= DP_DEFSET; } } /* * Search for a dirpath on the export point. */ struct dirlist * dirp_search(struct dirlist *dp, char *dirpath) { int cmp; if (dp) { cmp = strcmp(dp->dp_dirp, dirpath); if (cmp > 0) return (dirp_search(dp->dp_left, dirpath)); else if (cmp < 0) return (dirp_search(dp->dp_right, dirpath)); else return (dp); } return (dp); } /* * Scan for a host match in a directory tree. */ int chk_host(struct dirlist *dp, in_addr_t saddr, int *defsetp, int *hostsetp) { struct hostlist *hp; struct grouplist *grp; u_int32_t **addrp; if (dp) { if (dp->dp_flag & DP_DEFSET) *defsetp = dp->dp_flag; hp = dp->dp_hosts; while (hp) { grp = hp->ht_grp; switch (grp->gr_type) { case GT_HOST: addrp = (u_int32_t **) grp->gr_ptr.gt_hostent->h_addr_list; while (*addrp) { if (**addrp == saddr) { *hostsetp = (hp->ht_flag | DP_HOSTSET); return (1); } addrp++; } break; case GT_NET: if ((saddr & grp->gr_ptr.gt_net.nt_mask) == grp->gr_ptr.gt_net.nt_net) { *hostsetp = (hp->ht_flag | DP_HOSTSET); return (1); } break; } hp = hp->ht_next; } } return (0); } /* * Scan tree for a host that matches the address. */ int scan_tree(struct dirlist *dp, in_addr_t saddr) { int defset, hostset; if (dp) { if (scan_tree(dp->dp_left, saddr)) return (1); if (chk_host(dp, saddr, &defset, &hostset)) return (1); if (scan_tree(dp->dp_right, saddr)) return (1); } return (0); } /* * Traverse the dirlist tree and free it up. */ void free_dir(struct dirlist *dp) { if (dp) { free_dir(dp->dp_left); free_dir(dp->dp_right); free_host(dp->dp_hosts); free((caddr_t)dp); } } /* * Parse the option string and update fields. * Option arguments may either be -