Home | History | Annotate | Line # | Download | only in nfsd
nfsd.c revision 1.49
      1  1.49      elad /*	$NetBSD: nfsd.c,v 1.49 2006/10/07 17:27:57 elad Exp $	*/
      2  1.16       cgd 
      3   1.1       cgd /*
      4  1.11   mycroft  * Copyright (c) 1989, 1993, 1994
      5  1.11   mycroft  *	The Regents of the University of California.  All rights reserved.
      6   1.1       cgd  *
      7   1.1       cgd  * This code is derived from software contributed to Berkeley by
      8   1.1       cgd  * Rick Macklem at The University of Guelph.
      9   1.1       cgd  *
     10   1.1       cgd  * Redistribution and use in source and binary forms, with or without
     11   1.1       cgd  * modification, are permitted provided that the following conditions
     12   1.1       cgd  * are met:
     13   1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     14   1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     15   1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     16   1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     17   1.1       cgd  *    documentation and/or other materials provided with the distribution.
     18  1.43       agc  * 3. Neither the name of the University nor the names of its contributors
     19   1.1       cgd  *    may be used to endorse or promote products derived from this software
     20   1.1       cgd  *    without specific prior written permission.
     21   1.1       cgd  *
     22   1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     23   1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     24   1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     25   1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     26   1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     27   1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     28   1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     29   1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     30   1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     31   1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     32   1.1       cgd  * SUCH DAMAGE.
     33   1.1       cgd  */
     34   1.1       cgd 
     35  1.23     lukem #include <sys/cdefs.h>
     36   1.1       cgd #ifndef lint
     37  1.23     lukem __COPYRIGHT("@(#) Copyright (c) 1989, 1993, 1994\n\
     38  1.23     lukem 	The Regents of the University of California.  All rights reserved.\n");
     39  1.35       cgd #endif /* not lint */
     40   1.1       cgd 
     41   1.1       cgd #ifndef lint
     42  1.16       cgd #if 0
     43  1.18      fvdl static char sccsid[] = "@(#)nfsd.c	8.9 (Berkeley) 3/29/95";
     44  1.16       cgd #else
     45  1.49      elad __RCSID("$NetBSD: nfsd.c,v 1.49 2006/10/07 17:27:57 elad Exp $");
     46  1.16       cgd #endif
     47  1.18      fvdl #endif /* not lint */
     48   1.1       cgd 
     49  1.11   mycroft #include <sys/param.h>
     50   1.1       cgd #include <sys/ioctl.h>
     51   1.1       cgd #include <sys/stat.h>
     52   1.1       cgd #include <sys/wait.h>
     53  1.11   mycroft #include <sys/uio.h>
     54  1.11   mycroft #include <sys/ucred.h>
     55   1.1       cgd #include <sys/mount.h>
     56   1.1       cgd #include <sys/socket.h>
     57   1.1       cgd #include <sys/socketvar.h>
     58  1.39    itojun #include <poll.h>
     59  1.11   mycroft 
     60   1.1       cgd #include <rpc/rpc.h>
     61   1.1       cgd #include <rpc/pmap_clnt.h>
     62   1.1       cgd #include <rpc/pmap_prot.h>
     63  1.11   mycroft 
     64  1.11   mycroft #ifdef ISO
     65  1.11   mycroft #include <netiso/iso.h>
     66  1.11   mycroft #endif
     67   1.1       cgd #include <nfs/rpcv2.h>
     68  1.18      fvdl #include <nfs/nfsproto.h>
     69  1.11   mycroft #include <nfs/nfs.h>
     70  1.11   mycroft 
     71  1.11   mycroft #include <err.h>
     72  1.11   mycroft #include <errno.h>
     73  1.11   mycroft #include <fcntl.h>
     74  1.11   mycroft #include <grp.h>
     75  1.11   mycroft #include <pwd.h>
     76  1.11   mycroft #include <signal.h>
     77  1.11   mycroft #include <stdio.h>
     78  1.11   mycroft #include <stdlib.h>
     79  1.25     perry #include <string.h>
     80  1.19   mycroft #include <syslog.h>
     81  1.11   mycroft #include <unistd.h>
     82  1.32      fvdl #include <netdb.h>
     83   1.1       cgd 
     84   1.1       cgd /* Global defs */
     85   1.1       cgd #ifdef DEBUG
     86   1.1       cgd #define	syslog(e, s)	fprintf(stderr,(s))
     87   1.1       cgd int	debug = 1;
     88   1.1       cgd #else
     89   1.1       cgd int	debug = 0;
     90   1.1       cgd #endif
     91  1.11   mycroft 
     92  1.11   mycroft struct	nfsd_srvargs nsd;
     93  1.11   mycroft 
     94  1.23     lukem int	main __P((int, char **));
     95  1.11   mycroft void	nonfs __P((int));
     96  1.11   mycroft void	reapchild __P((int));
     97  1.11   mycroft void	usage __P((void));
     98   1.1       cgd 
     99   1.1       cgd /*
    100   1.1       cgd  * Nfs server daemon mostly just a user context for nfssvc()
    101  1.11   mycroft  *
    102   1.1       cgd  * 1 - do file descriptor and signal cleanup
    103  1.11   mycroft  * 2 - fork the nfsd(s)
    104  1.11   mycroft  * 3 - create server socket(s)
    105  1.11   mycroft  * 4 - register socket with portmap
    106  1.11   mycroft  *
    107  1.28     lukem  * For connectionless protocols, just pass the socket into the kernel via
    108  1.11   mycroft  * nfssvc().
    109  1.11   mycroft  * For connection based sockets, loop doing accepts. When you get a new
    110  1.28     lukem  * socket from accept, pass the msgsock into the kernel via nfssvc().
    111   1.1       cgd  * The arguments are:
    112  1.11   mycroft  *	-c - support iso cltp clients
    113  1.11   mycroft  *	-r - reregister with portmapper
    114  1.11   mycroft  *	-t - support tcp nfs clients
    115  1.11   mycroft  *	-u - support udp nfs clients
    116  1.11   mycroft  * followed by "n" which is the number of nfsds' to fork off
    117   1.1       cgd  */
    118  1.11   mycroft int
    119  1.23     lukem main(argc, argv)
    120   1.1       cgd 	int argc;
    121  1.23     lukem 	char *argv[];
    122   1.1       cgd {
    123  1.11   mycroft 	struct nfsd_args nfsdargs;
    124  1.32      fvdl 	struct addrinfo *ai_udp, *ai_tcp, *ai_udp6, *ai_tcp6, hints;
    125  1.32      fvdl 	struct netconfig *nconf_udp, *nconf_tcp, *nconf_udp6, *nconf_tcp6;
    126  1.32      fvdl 	struct netbuf nb_udp, nb_tcp, nb_udp6, nb_tcp6;
    127  1.32      fvdl 	struct sockaddr_in inetpeer;
    128  1.32      fvdl 	struct sockaddr_in6 inet6peer;
    129  1.11   mycroft #ifdef ISO
    130  1.11   mycroft 	struct sockaddr_iso isoaddr, isopeer;
    131  1.11   mycroft #endif
    132  1.37   mycroft 	struct pollfd set[4];
    133  1.47       mrg 	socklen_t len;
    134  1.47       mrg 	int ch, cltpflag, connect_type_cnt, i, maxsock, msgsock;
    135  1.32      fvdl 	int nfsdcnt, nfssvc_flag, on = 1, reregister, sock, tcpflag, tcpsock;
    136  1.32      fvdl 	int tcp6sock, ip6flag;
    137  1.32      fvdl 	int tp4cnt, tp4flag, tpipcnt, tpipflag, udpflag, ecode, s;
    138  1.11   mycroft 
    139  1.44  jonathan #define	MAXNFSDCNT	1024
    140  1.11   mycroft #define	DEFNFSDCNT	 4
    141  1.11   mycroft 	nfsdcnt = DEFNFSDCNT;
    142  1.11   mycroft 	cltpflag = reregister = tcpflag = tp4cnt = tp4flag = tpipcnt = 0;
    143  1.32      fvdl 	tpipflag = udpflag = ip6flag = 0;
    144  1.45     lukem 	nconf_udp = nconf_tcp = nconf_udp6 = nconf_tcp6 = NULL;
    145  1.45     lukem 	maxsock = 0;
    146  1.45     lukem 	tcpsock = tcp6sock = -1;
    147  1.11   mycroft #ifdef ISO
    148  1.32      fvdl #define	GETOPT	"6cn:rtu"
    149  1.11   mycroft #define	USAGE	"[-crtu] [-n num_servers]"
    150  1.11   mycroft #else
    151  1.32      fvdl #define	GETOPT	"6n:rtu"
    152  1.11   mycroft #define	USAGE	"[-rtu] [-n num_servers]"
    153  1.11   mycroft #endif
    154  1.30   thorpej 	while ((ch = getopt(argc, argv, GETOPT)) != -1) {
    155  1.11   mycroft 		switch (ch) {
    156  1.32      fvdl 		case '6':
    157  1.32      fvdl 			ip6flag = 1;
    158  1.32      fvdl 			s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_UDP);
    159  1.32      fvdl 			if (s < 0 && (errno == EPROTONOSUPPORT ||
    160  1.32      fvdl 			    errno == EPFNOSUPPORT || errno == EAFNOSUPPORT))
    161  1.32      fvdl 				ip6flag = 0;
    162  1.32      fvdl 			else
    163  1.32      fvdl 				close(s);
    164  1.32      fvdl 			break;
    165  1.11   mycroft 		case 'n':
    166  1.11   mycroft 			nfsdcnt = atoi(optarg);
    167  1.11   mycroft 			if (nfsdcnt < 1 || nfsdcnt > MAXNFSDCNT) {
    168  1.21      fvdl 				warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
    169  1.11   mycroft 				nfsdcnt = DEFNFSDCNT;
    170  1.11   mycroft 			}
    171  1.11   mycroft 			break;
    172   1.1       cgd 		case 'r':
    173  1.11   mycroft 			reregister = 1;
    174   1.1       cgd 			break;
    175   1.1       cgd 		case 't':
    176  1.11   mycroft 			tcpflag = 1;
    177   1.1       cgd 			break;
    178   1.1       cgd 		case 'u':
    179  1.11   mycroft 			udpflag = 1;
    180  1.11   mycroft 			break;
    181  1.11   mycroft #ifdef ISO
    182  1.11   mycroft 		case 'c':
    183  1.11   mycroft 			cltpflag = 1;
    184   1.1       cgd 			break;
    185  1.11   mycroft #ifdef notyet
    186  1.11   mycroft 		case 'i':
    187  1.11   mycroft 			tp4cnt = 1;
    188  1.11   mycroft 			break;
    189  1.11   mycroft 		case 'p':
    190  1.11   mycroft 			tpipcnt = 1;
    191  1.11   mycroft 			break;
    192  1.11   mycroft #endif /* notyet */
    193  1.11   mycroft #endif /* ISO */
    194   1.1       cgd 		default:
    195   1.1       cgd 		case '?':
    196   1.1       cgd 			usage();
    197  1.11   mycroft 		};
    198  1.30   thorpej 	}
    199  1.11   mycroft 	argv += optind;
    200  1.11   mycroft 	argc -= optind;
    201   1.1       cgd 
    202   1.1       cgd 	/*
    203  1.11   mycroft 	 * XXX
    204  1.11   mycroft 	 * Backward compatibility, trailing number is the count of daemons.
    205   1.1       cgd 	 */
    206  1.11   mycroft 	if (argc > 1)
    207  1.11   mycroft 		usage();
    208  1.11   mycroft 	if (argc == 1) {
    209  1.11   mycroft 		nfsdcnt = atoi(argv[0]);
    210  1.11   mycroft 		if (nfsdcnt < 1 || nfsdcnt > MAXNFSDCNT) {
    211  1.21      fvdl 			warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
    212  1.11   mycroft 			nfsdcnt = DEFNFSDCNT;
    213  1.11   mycroft 		}
    214   1.1       cgd 	}
    215  1.31     soren 
    216  1.31     soren 	/*
    217  1.31     soren 	 * If none of TCP or UDP are specified, default to UDP only.
    218  1.31     soren 	 */
    219  1.31     soren 	if (tcpflag == 0 && udpflag == 0)
    220  1.31     soren 		udpflag = 1;
    221   1.1       cgd 
    222   1.1       cgd 	if (debug == 0) {
    223   1.1       cgd 		daemon(0, 0);
    224  1.11   mycroft 		(void)signal(SIGHUP, SIG_IGN);
    225  1.11   mycroft 		(void)signal(SIGINT, SIG_IGN);
    226  1.11   mycroft 		(void)signal(SIGQUIT, SIG_IGN);
    227  1.11   mycroft 		(void)signal(SIGSYS, nonfs);
    228   1.1       cgd 	}
    229  1.11   mycroft 	(void)signal(SIGCHLD, reapchild);
    230  1.11   mycroft 
    231  1.32      fvdl 	if (udpflag) {
    232  1.32      fvdl 		memset(&hints, 0, sizeof hints);
    233  1.32      fvdl 		hints.ai_flags = AI_PASSIVE;
    234  1.32      fvdl 		hints.ai_family = PF_INET;
    235  1.32      fvdl 		hints.ai_socktype = SOCK_DGRAM;
    236  1.32      fvdl 		hints.ai_protocol = IPPROTO_UDP;
    237  1.32      fvdl 
    238  1.32      fvdl 		ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp);
    239  1.32      fvdl 		if (ecode != 0) {
    240  1.32      fvdl 			syslog(LOG_ERR, "getaddrinfo udp: %s",
    241  1.32      fvdl 			    gai_strerror(ecode));
    242  1.32      fvdl 			exit(1);
    243  1.32      fvdl 		}
    244  1.32      fvdl 
    245  1.32      fvdl 		nconf_udp = getnetconfigent("udp");
    246  1.32      fvdl 
    247  1.32      fvdl 		if (nconf_udp == NULL)
    248  1.32      fvdl 			err(1, "getnetconfigent udp failed");
    249  1.32      fvdl 
    250  1.32      fvdl 		nb_udp.buf = ai_udp->ai_addr;
    251  1.32      fvdl 		nb_udp.len = nb_udp.maxlen = ai_udp->ai_addrlen;
    252  1.32      fvdl 		if (reregister)
    253  1.32      fvdl 			if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp))
    254  1.32      fvdl 				err(1, "rpcb_set udp failed");
    255  1.32      fvdl 	}
    256  1.32      fvdl 
    257  1.32      fvdl 	if (tcpflag) {
    258  1.32      fvdl 		memset(&hints, 0, sizeof hints);
    259  1.32      fvdl 		hints.ai_flags = AI_PASSIVE;
    260  1.32      fvdl 		hints.ai_family = PF_INET;
    261  1.32      fvdl 		hints.ai_socktype = SOCK_STREAM;
    262  1.32      fvdl 		hints.ai_protocol = IPPROTO_TCP;
    263  1.32      fvdl 
    264  1.32      fvdl 		ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp);
    265  1.32      fvdl 		if (ecode != 0) {
    266  1.48   hubertf 			syslog(LOG_ERR, "getaddrinfo tcp: %s",
    267  1.32      fvdl 			    gai_strerror(ecode));
    268  1.32      fvdl 			exit(1);
    269  1.32      fvdl 		}
    270  1.32      fvdl 
    271  1.32      fvdl 		nconf_tcp = getnetconfigent("tcp");
    272  1.32      fvdl 
    273  1.32      fvdl 		if (nconf_tcp == NULL)
    274  1.32      fvdl 			err(1, "getnetconfigent tcp failed");
    275  1.32      fvdl 
    276  1.32      fvdl 		nb_tcp.buf = ai_tcp->ai_addr;
    277  1.32      fvdl 		nb_tcp.len = nb_tcp.maxlen = ai_tcp->ai_addrlen;
    278  1.32      fvdl 		if (reregister)
    279  1.32      fvdl 			if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp))
    280  1.32      fvdl 				err(1, "rpcb_set tcp failed");
    281  1.32      fvdl 	}
    282  1.32      fvdl 
    283  1.32      fvdl 	if (udpflag && ip6flag) {
    284  1.32      fvdl 		memset(&hints, 0, sizeof hints);
    285  1.32      fvdl 		hints.ai_flags = AI_PASSIVE;
    286  1.32      fvdl 		hints.ai_family = PF_INET6;
    287  1.32      fvdl 		hints.ai_socktype = SOCK_DGRAM;
    288  1.32      fvdl 		hints.ai_protocol = IPPROTO_UDP;
    289  1.32      fvdl 
    290  1.32      fvdl 		ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp6);
    291  1.32      fvdl 		if (ecode != 0) {
    292  1.32      fvdl 			syslog(LOG_ERR, "getaddrinfo udp: %s",
    293  1.32      fvdl 			    gai_strerror(ecode));
    294  1.32      fvdl 			exit(1);
    295  1.32      fvdl 		}
    296  1.32      fvdl 
    297  1.32      fvdl 		nconf_udp6 = getnetconfigent("udp6");
    298  1.32      fvdl 
    299  1.32      fvdl 		if (nconf_udp6 == NULL)
    300  1.32      fvdl 			err(1, "getnetconfigent udp6 failed");
    301  1.32      fvdl 
    302  1.32      fvdl 		nb_udp6.buf = ai_udp6->ai_addr;
    303  1.32      fvdl 		nb_udp6.len = nb_udp6.maxlen = ai_udp6->ai_addrlen;
    304  1.32      fvdl 		if (reregister)
    305  1.32      fvdl 			if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6))
    306  1.32      fvdl 				err(1, "rpcb_set udp6 failed");
    307  1.32      fvdl 	}
    308  1.32      fvdl 
    309  1.32      fvdl 	if (tcpflag && ip6flag) {
    310  1.32      fvdl 		memset(&hints, 0, sizeof hints);
    311  1.32      fvdl 		hints.ai_flags = AI_PASSIVE;
    312  1.32      fvdl 		hints.ai_family = PF_INET6;
    313  1.32      fvdl 		hints.ai_socktype = SOCK_STREAM;
    314  1.32      fvdl 		hints.ai_protocol = IPPROTO_TCP;
    315  1.32      fvdl 
    316  1.32      fvdl 		ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp6);
    317  1.32      fvdl 		if (ecode != 0) {
    318  1.48   hubertf 			syslog(LOG_ERR, "getaddrinfo tcp: %s",
    319  1.32      fvdl 			    gai_strerror(ecode));
    320  1.32      fvdl 			exit(1);
    321  1.32      fvdl 		}
    322  1.32      fvdl 
    323  1.32      fvdl 		nconf_tcp6 = getnetconfigent("tcp6");
    324  1.32      fvdl 
    325  1.32      fvdl 		if (nconf_tcp6 == NULL)
    326  1.32      fvdl 			err(1, "getnetconfigent tcp6 failed");
    327  1.32      fvdl 
    328  1.32      fvdl 		nb_tcp6.buf = ai_tcp6->ai_addr;
    329  1.32      fvdl 		nb_tcp6.len = nb_tcp6.maxlen = ai_tcp6->ai_addrlen;
    330  1.32      fvdl 		if (reregister)
    331  1.32      fvdl 			if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6))
    332  1.32      fvdl 				err(1, "rpcb_set tcp6 failed");
    333   1.8       cgd 	}
    334  1.32      fvdl 
    335  1.33     lukem 	openlog("nfsd", LOG_PID, LOG_DAEMON);
    336  1.11   mycroft 
    337  1.11   mycroft 	for (i = 0; i < nfsdcnt; i++) {
    338  1.11   mycroft 		switch (fork()) {
    339  1.11   mycroft 		case -1:
    340  1.11   mycroft 			syslog(LOG_ERR, "fork: %m");
    341  1.11   mycroft 			exit (1);
    342  1.11   mycroft 		case 0:
    343  1.11   mycroft 			break;
    344  1.11   mycroft 		default:
    345  1.11   mycroft 			continue;
    346   1.1       cgd 		}
    347  1.11   mycroft 
    348  1.13   mycroft 		setproctitle("server");
    349  1.11   mycroft 		nfssvc_flag = NFSSVC_NFSD;
    350  1.11   mycroft 		nsd.nsd_nfsd = NULL;
    351  1.11   mycroft 		while (nfssvc(nfssvc_flag, &nsd) < 0) {
    352  1.11   mycroft 			if (errno != ENEEDAUTH) {
    353  1.11   mycroft 				syslog(LOG_ERR, "nfssvc: %m");
    354  1.11   mycroft 				exit(1);
    355  1.11   mycroft 			}
    356  1.11   mycroft 			nfssvc_flag = NFSSVC_NFSD | NFSSVC_AUTHINFAIL;
    357   1.1       cgd 		}
    358   1.1       cgd 		exit(0);
    359   1.1       cgd 	}
    360  1.11   mycroft 
    361  1.11   mycroft 	/* If we are serving udp, set up the socket. */
    362   1.1       cgd 	if (udpflag) {
    363  1.32      fvdl 		if ((sock = socket(ai_udp->ai_family, ai_udp->ai_socktype,
    364  1.32      fvdl 		    ai_udp->ai_protocol)) < 0) {
    365  1.11   mycroft 			syslog(LOG_ERR, "can't create udp socket");
    366   1.1       cgd 			exit(1);
    367   1.1       cgd 		}
    368  1.32      fvdl 		if (bind(sock, ai_udp->ai_addr, ai_udp->ai_addrlen) < 0) {
    369  1.32      fvdl 			syslog(LOG_ERR, "can't bind udp addr");
    370  1.32      fvdl 			exit(1);
    371  1.32      fvdl 		}
    372  1.32      fvdl 		if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp) ||
    373  1.32      fvdl 		    !rpcb_set(RPCPROG_NFS, 3, nconf_udp, &nb_udp)) {
    374  1.32      fvdl 			syslog(LOG_ERR, "can't register with udp portmap");
    375  1.32      fvdl 			exit(1);
    376  1.32      fvdl 		}
    377  1.32      fvdl 		nfsdargs.sock = sock;
    378  1.32      fvdl 		nfsdargs.name = NULL;
    379  1.32      fvdl 		nfsdargs.namelen = 0;
    380  1.32      fvdl 		if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
    381  1.32      fvdl 			syslog(LOG_ERR, "can't add UDP socket");
    382  1.32      fvdl 			exit(1);
    383  1.32      fvdl 		}
    384  1.32      fvdl 		(void)close(sock);
    385  1.32      fvdl 	}
    386  1.32      fvdl 
    387  1.32      fvdl 	if (udpflag &&ip6flag) {
    388  1.32      fvdl 		if ((sock = socket(ai_udp6->ai_family, ai_udp6->ai_socktype,
    389  1.32      fvdl 		    ai_udp6->ai_protocol)) < 0) {
    390  1.32      fvdl 			syslog(LOG_ERR, "can't create udp socket");
    391  1.32      fvdl 			exit(1);
    392  1.32      fvdl 		}
    393  1.36    itojun 		if (setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY,
    394  1.32      fvdl 		    &on, sizeof on) < 0) {
    395  1.32      fvdl 			syslog(LOG_ERR, "can't set v6-only binding for udp6 "
    396  1.32      fvdl 					"socket: %m");
    397  1.32      fvdl 			exit(1);
    398  1.32      fvdl 		}
    399  1.32      fvdl 		if (bind(sock, ai_udp6->ai_addr, ai_udp6->ai_addrlen) < 0) {
    400  1.11   mycroft 			syslog(LOG_ERR, "can't bind udp addr");
    401   1.1       cgd 			exit(1);
    402   1.1       cgd 		}
    403  1.32      fvdl 		if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6) ||
    404  1.32      fvdl 		    !rpcb_set(RPCPROG_NFS, 3, nconf_udp6, &nb_udp6)) {
    405  1.11   mycroft 			syslog(LOG_ERR, "can't register with udp portmap");
    406  1.11   mycroft 			exit(1);
    407  1.11   mycroft 		}
    408  1.11   mycroft 		nfsdargs.sock = sock;
    409  1.11   mycroft 		nfsdargs.name = NULL;
    410  1.11   mycroft 		nfsdargs.namelen = 0;
    411  1.11   mycroft 		if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
    412  1.32      fvdl 			syslog(LOG_ERR, "can't add UDP6 socket");
    413  1.11   mycroft 			exit(1);
    414  1.11   mycroft 		}
    415  1.11   mycroft 		(void)close(sock);
    416  1.11   mycroft 	}
    417  1.11   mycroft 
    418  1.11   mycroft #ifdef ISO
    419  1.11   mycroft 	/* If we are serving cltp, set up the socket. */
    420  1.11   mycroft 	if (cltpflag) {
    421  1.11   mycroft 		if ((sock = socket(AF_ISO, SOCK_DGRAM, 0)) < 0) {
    422  1.11   mycroft 			syslog(LOG_ERR, "can't create cltp socket");
    423  1.11   mycroft 			exit(1);
    424  1.11   mycroft 		}
    425  1.11   mycroft 		memset(&isoaddr, 0, sizeof(isoaddr));
    426  1.11   mycroft 		isoaddr.siso_family = AF_ISO;
    427  1.11   mycroft 		isoaddr.siso_tlen = 2;
    428  1.11   mycroft 		cp = TSEL(&isoaddr);
    429  1.11   mycroft 		*cp++ = (NFS_PORT >> 8);
    430  1.11   mycroft 		*cp = (NFS_PORT & 0xff);
    431  1.11   mycroft 		isoaddr.siso_len = sizeof(isoaddr);
    432  1.11   mycroft 		if (bind(sock,
    433  1.11   mycroft 		    (struct sockaddr *)&isoaddr, sizeof(isoaddr)) < 0) {
    434  1.11   mycroft 			syslog(LOG_ERR, "can't bind cltp addr");
    435   1.1       cgd 			exit(1);
    436   1.1       cgd 		}
    437  1.11   mycroft #ifdef notyet
    438   1.1       cgd 		/*
    439  1.11   mycroft 		 * XXX
    440  1.11   mycroft 		 * Someday this should probably use "rpcbind", the son of
    441  1.11   mycroft 		 * portmap.
    442   1.1       cgd 		 */
    443  1.11   mycroft 		if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_UDP, NFS_PORT)) {
    444  1.11   mycroft 			syslog(LOG_ERR, "can't register with udp portmap");
    445  1.11   mycroft 			exit(1);
    446  1.11   mycroft 		}
    447  1.11   mycroft #endif /* notyet */
    448  1.11   mycroft 		nfsdargs.sock = sock;
    449  1.11   mycroft 		nfsdargs.name = NULL;
    450  1.11   mycroft 		nfsdargs.namelen = 0;
    451  1.11   mycroft 		if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
    452  1.11   mycroft 			syslog(LOG_ERR, "can't add UDP socket");
    453  1.11   mycroft 			exit(1);
    454  1.11   mycroft 		}
    455   1.1       cgd 		close(sock);
    456   1.1       cgd 	}
    457  1.11   mycroft #endif /* ISO */
    458   1.1       cgd 
    459  1.11   mycroft 	/* Now set up the master server socket waiting for tcp connections. */
    460  1.11   mycroft 	on = 1;
    461  1.11   mycroft 	connect_type_cnt = 0;
    462   1.1       cgd 	if (tcpflag) {
    463  1.32      fvdl 		if ((tcpsock = socket(ai_tcp->ai_family, ai_tcp->ai_socktype,
    464  1.32      fvdl 		    ai_tcp->ai_protocol)) < 0) {
    465  1.11   mycroft 			syslog(LOG_ERR, "can't create tcp socket");
    466  1.11   mycroft 			exit(1);
    467  1.11   mycroft 		}
    468  1.11   mycroft 		if (setsockopt(tcpsock,
    469  1.11   mycroft 		    SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
    470  1.11   mycroft 			syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
    471  1.32      fvdl 		if (bind(tcpsock, ai_tcp->ai_addr, ai_tcp->ai_addrlen) < 0) {
    472  1.11   mycroft 			syslog(LOG_ERR, "can't bind tcp addr");
    473  1.11   mycroft 			exit(1);
    474  1.11   mycroft 		}
    475  1.11   mycroft 		if (listen(tcpsock, 5) < 0) {
    476  1.11   mycroft 			syslog(LOG_ERR, "listen failed");
    477  1.11   mycroft 			exit(1);
    478  1.11   mycroft 		}
    479  1.32      fvdl 		if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp) ||
    480  1.32      fvdl 		    !rpcb_set(RPCPROG_NFS, 3, nconf_tcp, &nb_tcp)) {
    481  1.32      fvdl 			syslog(LOG_ERR, "can't register tcp with rpcbind");
    482  1.11   mycroft 			exit(1);
    483  1.11   mycroft 		}
    484  1.37   mycroft 		set[0].fd = tcpsock;
    485  1.37   mycroft 		set[0].events = POLLIN;
    486  1.11   mycroft 		connect_type_cnt++;
    487  1.37   mycroft 	} else
    488  1.38   mycroft 		set[0].fd = -1;
    489   1.1       cgd 
    490  1.32      fvdl 	if (tcpflag && ip6flag) {
    491  1.32      fvdl 		if ((tcp6sock = socket(ai_tcp6->ai_family, ai_tcp6->ai_socktype,
    492  1.32      fvdl 		    ai_tcp6->ai_protocol)) < 0) {
    493  1.32      fvdl 			syslog(LOG_ERR, "can't create tcp socket");
    494  1.32      fvdl 			exit(1);
    495  1.32      fvdl 		}
    496  1.32      fvdl 		if (setsockopt(tcp6sock,
    497  1.32      fvdl 		    SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
    498  1.32      fvdl 			syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
    499  1.36    itojun 		if (setsockopt(tcp6sock, IPPROTO_IPV6, IPV6_V6ONLY,
    500  1.32      fvdl 		    &on, sizeof on) < 0) {
    501  1.32      fvdl 			syslog(LOG_ERR, "can't set v6-only binding for tcp6 "
    502  1.32      fvdl 					"socket: %m");
    503  1.32      fvdl 			exit(1);
    504  1.32      fvdl 		}
    505  1.32      fvdl 		if (bind(tcp6sock, ai_tcp6->ai_addr, ai_tcp6->ai_addrlen) < 0) {
    506  1.32      fvdl 			syslog(LOG_ERR, "can't bind tcp6 addr");
    507  1.32      fvdl 			exit(1);
    508  1.32      fvdl 		}
    509  1.32      fvdl 		if (listen(tcp6sock, 5) < 0) {
    510  1.32      fvdl 			syslog(LOG_ERR, "listen failed");
    511  1.32      fvdl 			exit(1);
    512  1.32      fvdl 		}
    513  1.32      fvdl 		if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6) ||
    514  1.32      fvdl 		    !rpcb_set(RPCPROG_NFS, 3, nconf_tcp6, &nb_tcp6)) {
    515  1.32      fvdl 			syslog(LOG_ERR, "can't register tcp6 with rpcbind");
    516  1.32      fvdl 			exit(1);
    517  1.32      fvdl 		}
    518  1.37   mycroft 		set[1].fd = tcp6sock;
    519  1.37   mycroft 		set[1].events = POLLIN;
    520  1.32      fvdl 		connect_type_cnt++;
    521  1.37   mycroft 	} else
    522  1.38   mycroft 		set[1].fd = -1;
    523  1.32      fvdl 
    524  1.11   mycroft #ifdef notyet
    525  1.11   mycroft 	/* Now set up the master server socket waiting for tp4 connections. */
    526  1.11   mycroft 	if (tp4flag) {
    527  1.11   mycroft 		if ((tp4sock = socket(AF_ISO, SOCK_SEQPACKET, 0)) < 0) {
    528  1.11   mycroft 			syslog(LOG_ERR, "can't create tp4 socket");
    529   1.1       cgd 			exit(1);
    530   1.1       cgd 		}
    531  1.11   mycroft 		if (setsockopt(tp4sock,
    532  1.11   mycroft 		    SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
    533   1.1       cgd 			syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
    534  1.11   mycroft 		memset(&isoaddr, 0, sizeof(isoaddr));
    535  1.11   mycroft 		isoaddr.siso_family = AF_ISO;
    536  1.11   mycroft 		isoaddr.siso_tlen = 2;
    537  1.11   mycroft 		cp = TSEL(&isoaddr);
    538  1.11   mycroft 		*cp++ = (NFS_PORT >> 8);
    539  1.11   mycroft 		*cp = (NFS_PORT & 0xff);
    540  1.11   mycroft 		isoaddr.siso_len = sizeof(isoaddr);
    541  1.11   mycroft 		if (bind(tp4sock,
    542  1.12   mycroft 		    (struct sockaddr *)&isoaddr, sizeof(isoaddr)) < 0) {
    543  1.11   mycroft 			syslog(LOG_ERR, "can't bind tp4 addr");
    544   1.1       cgd 			exit(1);
    545   1.1       cgd 		}
    546  1.11   mycroft 		if (listen(tp4sock, 5) < 0) {
    547  1.11   mycroft 			syslog(LOG_ERR, "listen failed");
    548   1.1       cgd 			exit(1);
    549   1.1       cgd 		}
    550  1.11   mycroft 		/*
    551  1.11   mycroft 		 * XXX
    552  1.11   mycroft 		 * Someday this should probably use "rpcbind", the son of
    553  1.11   mycroft 		 * portmap.
    554  1.11   mycroft 		 */
    555   1.1       cgd 		if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_TCP, NFS_PORT)) {
    556  1.11   mycroft 			syslog(LOG_ERR, "can't register tcp with portmap");
    557  1.11   mycroft 			exit(1);
    558  1.11   mycroft 		}
    559  1.37   mycroft 		set[2].fd = tp4sock;
    560  1.37   mycroft 		set[2].events = POLLIN;
    561  1.11   mycroft 		connect_type_cnt++;
    562  1.37   mycroft 	} else
    563  1.38   mycroft 		set[2].fd = -1;
    564  1.11   mycroft 
    565  1.11   mycroft 	/* Now set up the master server socket waiting for tpip connections. */
    566  1.11   mycroft 	if (tpipflag) {
    567  1.11   mycroft 		if ((tpipsock = socket(AF_INET, SOCK_SEQPACKET, 0)) < 0) {
    568  1.11   mycroft 			syslog(LOG_ERR, "can't create tpip socket");
    569  1.11   mycroft 			exit(1);
    570  1.11   mycroft 		}
    571  1.11   mycroft 		if (setsockopt(tpipsock,
    572  1.11   mycroft 		    SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
    573  1.11   mycroft 			syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
    574  1.11   mycroft 		inetaddr.sin_family = AF_INET;
    575  1.11   mycroft 		inetaddr.sin_addr.s_addr = INADDR_ANY;
    576  1.11   mycroft 		inetaddr.sin_port = htons(NFS_PORT);
    577  1.11   mycroft 		inetaddr.sin_len = sizeof(inetaddr);
    578  1.20   mycroft 		memset(inetaddr.sin_zero, 0, sizeof(inetaddr.sin_zero));
    579  1.11   mycroft 		if (bind(tpipsock,
    580  1.11   mycroft 		    (struct sockaddr *)&inetaddr, sizeof (inetaddr)) < 0) {
    581  1.11   mycroft 			syslog(LOG_ERR, "can't bind tcp addr");
    582  1.11   mycroft 			exit(1);
    583  1.11   mycroft 		}
    584  1.11   mycroft 		if (listen(tpipsock, 5) < 0) {
    585  1.11   mycroft 			syslog(LOG_ERR, "listen failed");
    586   1.1       cgd 			exit(1);
    587   1.1       cgd 		}
    588   1.1       cgd 		/*
    589  1.11   mycroft 		 * XXX
    590  1.11   mycroft 		 * Someday this should probably use "rpcbind", the son of
    591  1.11   mycroft 		 * portmap.
    592   1.1       cgd 		 */
    593  1.11   mycroft 		if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_TCP, NFS_PORT)) {
    594  1.11   mycroft 			syslog(LOG_ERR, "can't register tcp with portmap");
    595  1.11   mycroft 			exit(1);
    596  1.11   mycroft 		}
    597  1.37   mycroft 		set[3].fd = tpipsock;
    598  1.37   mycroft 		set[3].events = POLLIN;
    599  1.11   mycroft 		connect_type_cnt++;
    600  1.37   mycroft 	} else
    601  1.38   mycroft 		set[3].fd = -1;
    602  1.37   mycroft #else
    603  1.38   mycroft 	set[2].fd = -1;
    604  1.38   mycroft 	set[3].fd = -1;
    605  1.11   mycroft #endif /* notyet */
    606  1.11   mycroft 
    607  1.11   mycroft 	if (connect_type_cnt == 0)
    608  1.11   mycroft 		exit(0);
    609  1.11   mycroft 
    610  1.13   mycroft 	setproctitle("master");
    611  1.11   mycroft 
    612  1.11   mycroft 	/*
    613  1.11   mycroft 	 * Loop forever accepting connections and passing the sockets
    614  1.11   mycroft 	 * into the kernel for the mounts.
    615  1.11   mycroft 	 */
    616  1.11   mycroft 	for (;;) {
    617  1.41   mycroft 		if (poll(set, 4, INFTIM) < 1) {
    618  1.49      elad 			syslog(LOG_ERR, "poll failed: %m");
    619  1.41   mycroft 			exit(1);
    620  1.11   mycroft 		}
    621  1.38   mycroft 
    622  1.37   mycroft 		if (set[0].revents & POLLIN) {
    623  1.11   mycroft 			len = sizeof(inetpeer);
    624  1.11   mycroft 			if ((msgsock = accept(tcpsock,
    625  1.11   mycroft 			    (struct sockaddr *)&inetpeer, &len)) < 0) {
    626  1.11   mycroft 				syslog(LOG_ERR, "accept failed: %m");
    627   1.1       cgd 				exit(1);
    628   1.1       cgd 			}
    629  1.11   mycroft 			memset(inetpeer.sin_zero, 0, sizeof(inetpeer.sin_zero));
    630  1.11   mycroft 			if (setsockopt(msgsock, SOL_SOCKET,
    631  1.11   mycroft 			    SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
    632  1.11   mycroft 				syslog(LOG_ERR,
    633  1.11   mycroft 				    "setsockopt SO_KEEPALIVE: %m");
    634  1.11   mycroft 			nfsdargs.sock = msgsock;
    635  1.11   mycroft 			nfsdargs.name = (caddr_t)&inetpeer;
    636  1.11   mycroft 			nfsdargs.namelen = sizeof(inetpeer);
    637  1.11   mycroft 			nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
    638  1.11   mycroft 			(void)close(msgsock);
    639  1.11   mycroft 		}
    640  1.32      fvdl 
    641  1.37   mycroft 		if (set[1].revents & POLLIN) {
    642  1.32      fvdl 			len = sizeof(inet6peer);
    643  1.32      fvdl 			if ((msgsock = accept(tcp6sock,
    644  1.32      fvdl 			    (struct sockaddr *)&inet6peer, &len)) < 0) {
    645  1.32      fvdl 				syslog(LOG_ERR, "accept failed: %m");
    646  1.32      fvdl 				exit(1);
    647  1.32      fvdl 			}
    648  1.32      fvdl 			if (setsockopt(msgsock, SOL_SOCKET,
    649  1.32      fvdl 			    SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
    650  1.32      fvdl 				syslog(LOG_ERR,
    651  1.32      fvdl 				    "setsockopt SO_KEEPALIVE: %m");
    652  1.32      fvdl 			nfsdargs.sock = msgsock;
    653  1.32      fvdl 			nfsdargs.name = (caddr_t)&inet6peer;
    654  1.32      fvdl 			nfsdargs.namelen = sizeof(inet6peer);
    655  1.32      fvdl 			nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
    656  1.32      fvdl 			(void)close(msgsock);
    657  1.32      fvdl 		}
    658  1.32      fvdl 
    659  1.11   mycroft #ifdef notyet
    660  1.37   mycroft 		if (set[2].revents & POLLIN) {
    661  1.11   mycroft 			len = sizeof(isopeer);
    662  1.11   mycroft 			if ((msgsock = accept(tp4sock,
    663  1.11   mycroft 			    (struct sockaddr *)&isopeer, &len)) < 0) {
    664  1.11   mycroft 				syslog(LOG_ERR, "accept failed: %m");
    665  1.11   mycroft 				exit(1);
    666   1.1       cgd 			}
    667  1.11   mycroft 			if (setsockopt(msgsock, SOL_SOCKET,
    668  1.11   mycroft 			    SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
    669  1.11   mycroft 				syslog(LOG_ERR,
    670  1.11   mycroft 				    "setsockopt SO_KEEPALIVE: %m");
    671  1.11   mycroft 			nfsdargs.sock = msgsock;
    672  1.11   mycroft 			nfsdargs.name = (caddr_t)&isopeer;
    673  1.11   mycroft 			nfsdargs.namelen = len;
    674  1.11   mycroft 			nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
    675  1.11   mycroft 			(void)close(msgsock);
    676  1.11   mycroft 		}
    677  1.38   mycroft 
    678  1.37   mycroft 		if (set[3].revents & POLLIN) {
    679  1.11   mycroft 			len = sizeof(inetpeer);
    680  1.11   mycroft 			if ((msgsock = accept(tpipsock,
    681  1.11   mycroft 			    (struct sockaddr *)&inetpeer, &len)) < 0) {
    682  1.41   mycroft 				syslog(LOG_ERR, "accept failed: %m");
    683   1.1       cgd 				exit(1);
    684   1.1       cgd 			}
    685  1.11   mycroft 			if (setsockopt(msgsock, SOL_SOCKET,
    686  1.11   mycroft 			    SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
    687  1.11   mycroft 				syslog(LOG_ERR, "setsockopt SO_KEEPALIVE: %m");
    688  1.11   mycroft 			nfsdargs.sock = msgsock;
    689  1.11   mycroft 			nfsdargs.name = (caddr_t)&inetpeer;
    690  1.11   mycroft 			nfsdargs.namelen = len;
    691  1.11   mycroft 			nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
    692  1.11   mycroft 			(void)close(msgsock);
    693   1.1       cgd 		}
    694  1.11   mycroft #endif /* notyet */
    695   1.1       cgd 	}
    696   1.1       cgd }
    697   1.1       cgd 
    698  1.11   mycroft void
    699   1.1       cgd usage()
    700   1.1       cgd {
    701  1.15   mycroft 	(void)fprintf(stderr, "usage: nfsd %s\n", USAGE);
    702   1.1       cgd 	exit(1);
    703   1.1       cgd }
    704   1.1       cgd 
    705   1.1       cgd void
    706  1.11   mycroft nonfs(signo)
    707  1.11   mycroft 	int signo;
    708   1.1       cgd {
    709  1.11   mycroft 	syslog(LOG_ERR, "missing system call: NFS not available.");
    710   1.1       cgd }
    711   1.4     glass 
    712  1.11   mycroft void
    713  1.11   mycroft reapchild(signo)
    714  1.11   mycroft 	int signo;
    715   1.4     glass {
    716  1.18      fvdl 	while (wait3(NULL, WNOHANG, NULL) > 0);
    717   1.4     glass }
    718