Home | History | Annotate | Line # | Download | only in nfsd
nfsd.c revision 1.51
      1  1.51      yamt /*	$NetBSD: nfsd.c,v 1.51 2007/07/11 04:59:19 yamt 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.51      yamt __RCSID("$NetBSD: nfsd.c,v 1.51 2007/07/11 04:59:19 yamt 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.50      yamt #include <pthread.h>
     77  1.11   mycroft #include <signal.h>
     78  1.11   mycroft #include <stdio.h>
     79  1.11   mycroft #include <stdlib.h>
     80  1.25     perry #include <string.h>
     81  1.19   mycroft #include <syslog.h>
     82  1.11   mycroft #include <unistd.h>
     83  1.32      fvdl #include <netdb.h>
     84   1.1       cgd 
     85   1.1       cgd /* Global defs */
     86   1.1       cgd #ifdef DEBUG
     87   1.1       cgd #define	syslog(e, s)	fprintf(stderr,(s))
     88   1.1       cgd int	debug = 1;
     89   1.1       cgd #else
     90   1.1       cgd int	debug = 0;
     91   1.1       cgd #endif
     92  1.11   mycroft 
     93  1.23     lukem int	main __P((int, char **));
     94  1.11   mycroft void	nonfs __P((int));
     95  1.11   mycroft void	usage __P((void));
     96   1.1       cgd 
     97  1.50      yamt static void *
     98  1.50      yamt child(void *dummy)
     99  1.50      yamt {
    100  1.50      yamt 	struct	nfsd_srvargs nsd;
    101  1.50      yamt 	int nfssvc_flag;
    102  1.50      yamt 
    103  1.51      yamt 	pthread_setname_np(pthread_self(), "slave", NULL);
    104  1.50      yamt 	nfssvc_flag = NFSSVC_NFSD;
    105  1.50      yamt 	memset(&nsd, 0, sizeof(nsd));
    106  1.50      yamt 	while (nfssvc(nfssvc_flag, &nsd) < 0) {
    107  1.50      yamt 		if (errno != ENEEDAUTH) {
    108  1.50      yamt 			syslog(LOG_ERR, "nfssvc: %m");
    109  1.50      yamt 			exit(1);
    110  1.50      yamt 		}
    111  1.50      yamt 		nfssvc_flag = NFSSVC_NFSD | NFSSVC_AUTHINFAIL;
    112  1.50      yamt 	}
    113  1.50      yamt 
    114  1.50      yamt 	return NULL;
    115  1.50      yamt }
    116  1.50      yamt 
    117   1.1       cgd /*
    118   1.1       cgd  * Nfs server daemon mostly just a user context for nfssvc()
    119  1.11   mycroft  *
    120   1.1       cgd  * 1 - do file descriptor and signal cleanup
    121  1.50      yamt  * 2 - create the nfsd thread(s)
    122  1.11   mycroft  * 3 - create server socket(s)
    123  1.11   mycroft  * 4 - register socket with portmap
    124  1.11   mycroft  *
    125  1.28     lukem  * For connectionless protocols, just pass the socket into the kernel via
    126  1.11   mycroft  * nfssvc().
    127  1.11   mycroft  * For connection based sockets, loop doing accepts. When you get a new
    128  1.28     lukem  * socket from accept, pass the msgsock into the kernel via nfssvc().
    129   1.1       cgd  * The arguments are:
    130  1.11   mycroft  *	-c - support iso cltp clients
    131  1.11   mycroft  *	-r - reregister with portmapper
    132  1.11   mycroft  *	-t - support tcp nfs clients
    133  1.11   mycroft  *	-u - support udp nfs clients
    134  1.50      yamt  * followed by "n" which is the number of nfsd threads to create
    135   1.1       cgd  */
    136  1.11   mycroft int
    137  1.23     lukem main(argc, argv)
    138   1.1       cgd 	int argc;
    139  1.23     lukem 	char *argv[];
    140   1.1       cgd {
    141  1.11   mycroft 	struct nfsd_args nfsdargs;
    142  1.32      fvdl 	struct addrinfo *ai_udp, *ai_tcp, *ai_udp6, *ai_tcp6, hints;
    143  1.32      fvdl 	struct netconfig *nconf_udp, *nconf_tcp, *nconf_udp6, *nconf_tcp6;
    144  1.32      fvdl 	struct netbuf nb_udp, nb_tcp, nb_udp6, nb_tcp6;
    145  1.32      fvdl 	struct sockaddr_in inetpeer;
    146  1.32      fvdl 	struct sockaddr_in6 inet6peer;
    147  1.11   mycroft #ifdef ISO
    148  1.11   mycroft 	struct sockaddr_iso isoaddr, isopeer;
    149  1.11   mycroft #endif
    150  1.37   mycroft 	struct pollfd set[4];
    151  1.47       mrg 	socklen_t len;
    152  1.47       mrg 	int ch, cltpflag, connect_type_cnt, i, maxsock, msgsock;
    153  1.50      yamt 	int nfsdcnt, on = 1, reregister, sock, tcpflag, tcpsock;
    154  1.32      fvdl 	int tcp6sock, ip6flag;
    155  1.32      fvdl 	int tp4cnt, tp4flag, tpipcnt, tpipflag, udpflag, ecode, s;
    156  1.11   mycroft 
    157  1.44  jonathan #define	MAXNFSDCNT	1024
    158  1.11   mycroft #define	DEFNFSDCNT	 4
    159  1.11   mycroft 	nfsdcnt = DEFNFSDCNT;
    160  1.11   mycroft 	cltpflag = reregister = tcpflag = tp4cnt = tp4flag = tpipcnt = 0;
    161  1.32      fvdl 	tpipflag = udpflag = ip6flag = 0;
    162  1.45     lukem 	nconf_udp = nconf_tcp = nconf_udp6 = nconf_tcp6 = NULL;
    163  1.45     lukem 	maxsock = 0;
    164  1.45     lukem 	tcpsock = tcp6sock = -1;
    165  1.11   mycroft #ifdef ISO
    166  1.32      fvdl #define	GETOPT	"6cn:rtu"
    167  1.11   mycroft #define	USAGE	"[-crtu] [-n num_servers]"
    168  1.11   mycroft #else
    169  1.32      fvdl #define	GETOPT	"6n:rtu"
    170  1.11   mycroft #define	USAGE	"[-rtu] [-n num_servers]"
    171  1.11   mycroft #endif
    172  1.30   thorpej 	while ((ch = getopt(argc, argv, GETOPT)) != -1) {
    173  1.11   mycroft 		switch (ch) {
    174  1.32      fvdl 		case '6':
    175  1.32      fvdl 			ip6flag = 1;
    176  1.32      fvdl 			s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_UDP);
    177  1.32      fvdl 			if (s < 0 && (errno == EPROTONOSUPPORT ||
    178  1.32      fvdl 			    errno == EPFNOSUPPORT || errno == EAFNOSUPPORT))
    179  1.32      fvdl 				ip6flag = 0;
    180  1.32      fvdl 			else
    181  1.32      fvdl 				close(s);
    182  1.32      fvdl 			break;
    183  1.11   mycroft 		case 'n':
    184  1.11   mycroft 			nfsdcnt = atoi(optarg);
    185  1.11   mycroft 			if (nfsdcnt < 1 || nfsdcnt > MAXNFSDCNT) {
    186  1.21      fvdl 				warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
    187  1.11   mycroft 				nfsdcnt = DEFNFSDCNT;
    188  1.11   mycroft 			}
    189  1.11   mycroft 			break;
    190   1.1       cgd 		case 'r':
    191  1.11   mycroft 			reregister = 1;
    192   1.1       cgd 			break;
    193   1.1       cgd 		case 't':
    194  1.11   mycroft 			tcpflag = 1;
    195   1.1       cgd 			break;
    196   1.1       cgd 		case 'u':
    197  1.11   mycroft 			udpflag = 1;
    198  1.11   mycroft 			break;
    199  1.11   mycroft #ifdef ISO
    200  1.11   mycroft 		case 'c':
    201  1.11   mycroft 			cltpflag = 1;
    202   1.1       cgd 			break;
    203  1.11   mycroft #ifdef notyet
    204  1.11   mycroft 		case 'i':
    205  1.11   mycroft 			tp4cnt = 1;
    206  1.11   mycroft 			break;
    207  1.11   mycroft 		case 'p':
    208  1.11   mycroft 			tpipcnt = 1;
    209  1.11   mycroft 			break;
    210  1.11   mycroft #endif /* notyet */
    211  1.11   mycroft #endif /* ISO */
    212   1.1       cgd 		default:
    213   1.1       cgd 		case '?':
    214   1.1       cgd 			usage();
    215  1.11   mycroft 		};
    216  1.30   thorpej 	}
    217  1.11   mycroft 	argv += optind;
    218  1.11   mycroft 	argc -= optind;
    219   1.1       cgd 
    220   1.1       cgd 	/*
    221  1.11   mycroft 	 * XXX
    222  1.11   mycroft 	 * Backward compatibility, trailing number is the count of daemons.
    223   1.1       cgd 	 */
    224  1.11   mycroft 	if (argc > 1)
    225  1.11   mycroft 		usage();
    226  1.11   mycroft 	if (argc == 1) {
    227  1.11   mycroft 		nfsdcnt = atoi(argv[0]);
    228  1.11   mycroft 		if (nfsdcnt < 1 || nfsdcnt > MAXNFSDCNT) {
    229  1.21      fvdl 			warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
    230  1.11   mycroft 			nfsdcnt = DEFNFSDCNT;
    231  1.11   mycroft 		}
    232   1.1       cgd 	}
    233  1.31     soren 
    234  1.31     soren 	/*
    235  1.31     soren 	 * If none of TCP or UDP are specified, default to UDP only.
    236  1.31     soren 	 */
    237  1.31     soren 	if (tcpflag == 0 && udpflag == 0)
    238  1.31     soren 		udpflag = 1;
    239   1.1       cgd 
    240   1.1       cgd 	if (debug == 0) {
    241   1.1       cgd 		daemon(0, 0);
    242  1.11   mycroft 		(void)signal(SIGHUP, SIG_IGN);
    243  1.11   mycroft 		(void)signal(SIGINT, SIG_IGN);
    244  1.11   mycroft 		(void)signal(SIGQUIT, SIG_IGN);
    245  1.11   mycroft 		(void)signal(SIGSYS, nonfs);
    246   1.1       cgd 	}
    247  1.11   mycroft 
    248  1.32      fvdl 	if (udpflag) {
    249  1.32      fvdl 		memset(&hints, 0, sizeof hints);
    250  1.32      fvdl 		hints.ai_flags = AI_PASSIVE;
    251  1.32      fvdl 		hints.ai_family = PF_INET;
    252  1.32      fvdl 		hints.ai_socktype = SOCK_DGRAM;
    253  1.32      fvdl 		hints.ai_protocol = IPPROTO_UDP;
    254  1.32      fvdl 
    255  1.32      fvdl 		ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp);
    256  1.32      fvdl 		if (ecode != 0) {
    257  1.32      fvdl 			syslog(LOG_ERR, "getaddrinfo udp: %s",
    258  1.32      fvdl 			    gai_strerror(ecode));
    259  1.32      fvdl 			exit(1);
    260  1.32      fvdl 		}
    261  1.32      fvdl 
    262  1.32      fvdl 		nconf_udp = getnetconfigent("udp");
    263  1.32      fvdl 
    264  1.32      fvdl 		if (nconf_udp == NULL)
    265  1.32      fvdl 			err(1, "getnetconfigent udp failed");
    266  1.32      fvdl 
    267  1.32      fvdl 		nb_udp.buf = ai_udp->ai_addr;
    268  1.32      fvdl 		nb_udp.len = nb_udp.maxlen = ai_udp->ai_addrlen;
    269  1.32      fvdl 		if (reregister)
    270  1.32      fvdl 			if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp))
    271  1.32      fvdl 				err(1, "rpcb_set udp failed");
    272  1.32      fvdl 	}
    273  1.32      fvdl 
    274  1.32      fvdl 	if (tcpflag) {
    275  1.32      fvdl 		memset(&hints, 0, sizeof hints);
    276  1.32      fvdl 		hints.ai_flags = AI_PASSIVE;
    277  1.32      fvdl 		hints.ai_family = PF_INET;
    278  1.32      fvdl 		hints.ai_socktype = SOCK_STREAM;
    279  1.32      fvdl 		hints.ai_protocol = IPPROTO_TCP;
    280  1.32      fvdl 
    281  1.32      fvdl 		ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp);
    282  1.32      fvdl 		if (ecode != 0) {
    283  1.48   hubertf 			syslog(LOG_ERR, "getaddrinfo tcp: %s",
    284  1.32      fvdl 			    gai_strerror(ecode));
    285  1.32      fvdl 			exit(1);
    286  1.32      fvdl 		}
    287  1.32      fvdl 
    288  1.32      fvdl 		nconf_tcp = getnetconfigent("tcp");
    289  1.32      fvdl 
    290  1.32      fvdl 		if (nconf_tcp == NULL)
    291  1.32      fvdl 			err(1, "getnetconfigent tcp failed");
    292  1.32      fvdl 
    293  1.32      fvdl 		nb_tcp.buf = ai_tcp->ai_addr;
    294  1.32      fvdl 		nb_tcp.len = nb_tcp.maxlen = ai_tcp->ai_addrlen;
    295  1.32      fvdl 		if (reregister)
    296  1.32      fvdl 			if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp))
    297  1.32      fvdl 				err(1, "rpcb_set tcp failed");
    298  1.32      fvdl 	}
    299  1.32      fvdl 
    300  1.32      fvdl 	if (udpflag && ip6flag) {
    301  1.32      fvdl 		memset(&hints, 0, sizeof hints);
    302  1.32      fvdl 		hints.ai_flags = AI_PASSIVE;
    303  1.32      fvdl 		hints.ai_family = PF_INET6;
    304  1.32      fvdl 		hints.ai_socktype = SOCK_DGRAM;
    305  1.32      fvdl 		hints.ai_protocol = IPPROTO_UDP;
    306  1.32      fvdl 
    307  1.32      fvdl 		ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp6);
    308  1.32      fvdl 		if (ecode != 0) {
    309  1.32      fvdl 			syslog(LOG_ERR, "getaddrinfo udp: %s",
    310  1.32      fvdl 			    gai_strerror(ecode));
    311  1.32      fvdl 			exit(1);
    312  1.32      fvdl 		}
    313  1.32      fvdl 
    314  1.32      fvdl 		nconf_udp6 = getnetconfigent("udp6");
    315  1.32      fvdl 
    316  1.32      fvdl 		if (nconf_udp6 == NULL)
    317  1.32      fvdl 			err(1, "getnetconfigent udp6 failed");
    318  1.32      fvdl 
    319  1.32      fvdl 		nb_udp6.buf = ai_udp6->ai_addr;
    320  1.32      fvdl 		nb_udp6.len = nb_udp6.maxlen = ai_udp6->ai_addrlen;
    321  1.32      fvdl 		if (reregister)
    322  1.32      fvdl 			if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6))
    323  1.32      fvdl 				err(1, "rpcb_set udp6 failed");
    324  1.32      fvdl 	}
    325  1.32      fvdl 
    326  1.32      fvdl 	if (tcpflag && ip6flag) {
    327  1.32      fvdl 		memset(&hints, 0, sizeof hints);
    328  1.32      fvdl 		hints.ai_flags = AI_PASSIVE;
    329  1.32      fvdl 		hints.ai_family = PF_INET6;
    330  1.32      fvdl 		hints.ai_socktype = SOCK_STREAM;
    331  1.32      fvdl 		hints.ai_protocol = IPPROTO_TCP;
    332  1.32      fvdl 
    333  1.32      fvdl 		ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp6);
    334  1.32      fvdl 		if (ecode != 0) {
    335  1.48   hubertf 			syslog(LOG_ERR, "getaddrinfo tcp: %s",
    336  1.32      fvdl 			    gai_strerror(ecode));
    337  1.32      fvdl 			exit(1);
    338  1.32      fvdl 		}
    339  1.32      fvdl 
    340  1.32      fvdl 		nconf_tcp6 = getnetconfigent("tcp6");
    341  1.32      fvdl 
    342  1.32      fvdl 		if (nconf_tcp6 == NULL)
    343  1.32      fvdl 			err(1, "getnetconfigent tcp6 failed");
    344  1.32      fvdl 
    345  1.32      fvdl 		nb_tcp6.buf = ai_tcp6->ai_addr;
    346  1.32      fvdl 		nb_tcp6.len = nb_tcp6.maxlen = ai_tcp6->ai_addrlen;
    347  1.32      fvdl 		if (reregister)
    348  1.32      fvdl 			if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6))
    349  1.32      fvdl 				err(1, "rpcb_set tcp6 failed");
    350   1.8       cgd 	}
    351  1.32      fvdl 
    352  1.33     lukem 	openlog("nfsd", LOG_PID, LOG_DAEMON);
    353  1.11   mycroft 
    354  1.11   mycroft 	for (i = 0; i < nfsdcnt; i++) {
    355  1.50      yamt 		pthread_t t;
    356  1.50      yamt 		int error;
    357  1.50      yamt 
    358  1.50      yamt 		error = pthread_create(&t, NULL, child, NULL);
    359  1.50      yamt 		if (error) {
    360  1.50      yamt 			errno = error;
    361  1.50      yamt 			syslog(LOG_ERR, "pthread_create: %m");
    362  1.11   mycroft 			exit (1);
    363   1.1       cgd 		}
    364   1.1       cgd 	}
    365  1.11   mycroft 
    366  1.11   mycroft 	/* If we are serving udp, set up the socket. */
    367   1.1       cgd 	if (udpflag) {
    368  1.32      fvdl 		if ((sock = socket(ai_udp->ai_family, ai_udp->ai_socktype,
    369  1.32      fvdl 		    ai_udp->ai_protocol)) < 0) {
    370  1.11   mycroft 			syslog(LOG_ERR, "can't create udp socket");
    371   1.1       cgd 			exit(1);
    372   1.1       cgd 		}
    373  1.32      fvdl 		if (bind(sock, ai_udp->ai_addr, ai_udp->ai_addrlen) < 0) {
    374  1.32      fvdl 			syslog(LOG_ERR, "can't bind udp addr");
    375  1.32      fvdl 			exit(1);
    376  1.32      fvdl 		}
    377  1.32      fvdl 		if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp) ||
    378  1.32      fvdl 		    !rpcb_set(RPCPROG_NFS, 3, nconf_udp, &nb_udp)) {
    379  1.32      fvdl 			syslog(LOG_ERR, "can't register with udp portmap");
    380  1.32      fvdl 			exit(1);
    381  1.32      fvdl 		}
    382  1.32      fvdl 		nfsdargs.sock = sock;
    383  1.32      fvdl 		nfsdargs.name = NULL;
    384  1.32      fvdl 		nfsdargs.namelen = 0;
    385  1.32      fvdl 		if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
    386  1.32      fvdl 			syslog(LOG_ERR, "can't add UDP socket");
    387  1.32      fvdl 			exit(1);
    388  1.32      fvdl 		}
    389  1.32      fvdl 		(void)close(sock);
    390  1.32      fvdl 	}
    391  1.32      fvdl 
    392  1.32      fvdl 	if (udpflag &&ip6flag) {
    393  1.32      fvdl 		if ((sock = socket(ai_udp6->ai_family, ai_udp6->ai_socktype,
    394  1.32      fvdl 		    ai_udp6->ai_protocol)) < 0) {
    395  1.32      fvdl 			syslog(LOG_ERR, "can't create udp socket");
    396  1.32      fvdl 			exit(1);
    397  1.32      fvdl 		}
    398  1.36    itojun 		if (setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY,
    399  1.32      fvdl 		    &on, sizeof on) < 0) {
    400  1.32      fvdl 			syslog(LOG_ERR, "can't set v6-only binding for udp6 "
    401  1.32      fvdl 					"socket: %m");
    402  1.32      fvdl 			exit(1);
    403  1.32      fvdl 		}
    404  1.32      fvdl 		if (bind(sock, ai_udp6->ai_addr, ai_udp6->ai_addrlen) < 0) {
    405  1.11   mycroft 			syslog(LOG_ERR, "can't bind udp addr");
    406   1.1       cgd 			exit(1);
    407   1.1       cgd 		}
    408  1.32      fvdl 		if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6) ||
    409  1.32      fvdl 		    !rpcb_set(RPCPROG_NFS, 3, nconf_udp6, &nb_udp6)) {
    410  1.11   mycroft 			syslog(LOG_ERR, "can't register with udp portmap");
    411  1.11   mycroft 			exit(1);
    412  1.11   mycroft 		}
    413  1.11   mycroft 		nfsdargs.sock = sock;
    414  1.11   mycroft 		nfsdargs.name = NULL;
    415  1.11   mycroft 		nfsdargs.namelen = 0;
    416  1.11   mycroft 		if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
    417  1.32      fvdl 			syslog(LOG_ERR, "can't add UDP6 socket");
    418  1.11   mycroft 			exit(1);
    419  1.11   mycroft 		}
    420  1.11   mycroft 		(void)close(sock);
    421  1.11   mycroft 	}
    422  1.11   mycroft 
    423  1.11   mycroft #ifdef ISO
    424  1.11   mycroft 	/* If we are serving cltp, set up the socket. */
    425  1.11   mycroft 	if (cltpflag) {
    426  1.11   mycroft 		if ((sock = socket(AF_ISO, SOCK_DGRAM, 0)) < 0) {
    427  1.11   mycroft 			syslog(LOG_ERR, "can't create cltp socket");
    428  1.11   mycroft 			exit(1);
    429  1.11   mycroft 		}
    430  1.11   mycroft 		memset(&isoaddr, 0, sizeof(isoaddr));
    431  1.11   mycroft 		isoaddr.siso_family = AF_ISO;
    432  1.11   mycroft 		isoaddr.siso_tlen = 2;
    433  1.11   mycroft 		cp = TSEL(&isoaddr);
    434  1.11   mycroft 		*cp++ = (NFS_PORT >> 8);
    435  1.11   mycroft 		*cp = (NFS_PORT & 0xff);
    436  1.11   mycroft 		isoaddr.siso_len = sizeof(isoaddr);
    437  1.11   mycroft 		if (bind(sock,
    438  1.11   mycroft 		    (struct sockaddr *)&isoaddr, sizeof(isoaddr)) < 0) {
    439  1.11   mycroft 			syslog(LOG_ERR, "can't bind cltp addr");
    440   1.1       cgd 			exit(1);
    441   1.1       cgd 		}
    442  1.11   mycroft #ifdef notyet
    443   1.1       cgd 		/*
    444  1.11   mycroft 		 * XXX
    445  1.11   mycroft 		 * Someday this should probably use "rpcbind", the son of
    446  1.11   mycroft 		 * portmap.
    447   1.1       cgd 		 */
    448  1.11   mycroft 		if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_UDP, NFS_PORT)) {
    449  1.11   mycroft 			syslog(LOG_ERR, "can't register with udp portmap");
    450  1.11   mycroft 			exit(1);
    451  1.11   mycroft 		}
    452  1.11   mycroft #endif /* notyet */
    453  1.11   mycroft 		nfsdargs.sock = sock;
    454  1.11   mycroft 		nfsdargs.name = NULL;
    455  1.11   mycroft 		nfsdargs.namelen = 0;
    456  1.11   mycroft 		if (nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
    457  1.11   mycroft 			syslog(LOG_ERR, "can't add UDP socket");
    458  1.11   mycroft 			exit(1);
    459  1.11   mycroft 		}
    460   1.1       cgd 		close(sock);
    461   1.1       cgd 	}
    462  1.11   mycroft #endif /* ISO */
    463   1.1       cgd 
    464  1.11   mycroft 	/* Now set up the master server socket waiting for tcp connections. */
    465  1.11   mycroft 	on = 1;
    466  1.11   mycroft 	connect_type_cnt = 0;
    467   1.1       cgd 	if (tcpflag) {
    468  1.32      fvdl 		if ((tcpsock = socket(ai_tcp->ai_family, ai_tcp->ai_socktype,
    469  1.32      fvdl 		    ai_tcp->ai_protocol)) < 0) {
    470  1.11   mycroft 			syslog(LOG_ERR, "can't create tcp socket");
    471  1.11   mycroft 			exit(1);
    472  1.11   mycroft 		}
    473  1.11   mycroft 		if (setsockopt(tcpsock,
    474  1.11   mycroft 		    SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
    475  1.11   mycroft 			syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
    476  1.32      fvdl 		if (bind(tcpsock, ai_tcp->ai_addr, ai_tcp->ai_addrlen) < 0) {
    477  1.11   mycroft 			syslog(LOG_ERR, "can't bind tcp addr");
    478  1.11   mycroft 			exit(1);
    479  1.11   mycroft 		}
    480  1.11   mycroft 		if (listen(tcpsock, 5) < 0) {
    481  1.11   mycroft 			syslog(LOG_ERR, "listen failed");
    482  1.11   mycroft 			exit(1);
    483  1.11   mycroft 		}
    484  1.32      fvdl 		if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp) ||
    485  1.32      fvdl 		    !rpcb_set(RPCPROG_NFS, 3, nconf_tcp, &nb_tcp)) {
    486  1.32      fvdl 			syslog(LOG_ERR, "can't register tcp with rpcbind");
    487  1.11   mycroft 			exit(1);
    488  1.11   mycroft 		}
    489  1.37   mycroft 		set[0].fd = tcpsock;
    490  1.37   mycroft 		set[0].events = POLLIN;
    491  1.11   mycroft 		connect_type_cnt++;
    492  1.37   mycroft 	} else
    493  1.38   mycroft 		set[0].fd = -1;
    494   1.1       cgd 
    495  1.32      fvdl 	if (tcpflag && ip6flag) {
    496  1.32      fvdl 		if ((tcp6sock = socket(ai_tcp6->ai_family, ai_tcp6->ai_socktype,
    497  1.32      fvdl 		    ai_tcp6->ai_protocol)) < 0) {
    498  1.32      fvdl 			syslog(LOG_ERR, "can't create tcp socket");
    499  1.32      fvdl 			exit(1);
    500  1.32      fvdl 		}
    501  1.32      fvdl 		if (setsockopt(tcp6sock,
    502  1.32      fvdl 		    SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
    503  1.32      fvdl 			syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
    504  1.36    itojun 		if (setsockopt(tcp6sock, IPPROTO_IPV6, IPV6_V6ONLY,
    505  1.32      fvdl 		    &on, sizeof on) < 0) {
    506  1.32      fvdl 			syslog(LOG_ERR, "can't set v6-only binding for tcp6 "
    507  1.32      fvdl 					"socket: %m");
    508  1.32      fvdl 			exit(1);
    509  1.32      fvdl 		}
    510  1.32      fvdl 		if (bind(tcp6sock, ai_tcp6->ai_addr, ai_tcp6->ai_addrlen) < 0) {
    511  1.32      fvdl 			syslog(LOG_ERR, "can't bind tcp6 addr");
    512  1.32      fvdl 			exit(1);
    513  1.32      fvdl 		}
    514  1.32      fvdl 		if (listen(tcp6sock, 5) < 0) {
    515  1.32      fvdl 			syslog(LOG_ERR, "listen failed");
    516  1.32      fvdl 			exit(1);
    517  1.32      fvdl 		}
    518  1.32      fvdl 		if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6) ||
    519  1.32      fvdl 		    !rpcb_set(RPCPROG_NFS, 3, nconf_tcp6, &nb_tcp6)) {
    520  1.32      fvdl 			syslog(LOG_ERR, "can't register tcp6 with rpcbind");
    521  1.32      fvdl 			exit(1);
    522  1.32      fvdl 		}
    523  1.37   mycroft 		set[1].fd = tcp6sock;
    524  1.37   mycroft 		set[1].events = POLLIN;
    525  1.32      fvdl 		connect_type_cnt++;
    526  1.37   mycroft 	} else
    527  1.38   mycroft 		set[1].fd = -1;
    528  1.32      fvdl 
    529  1.11   mycroft #ifdef notyet
    530  1.11   mycroft 	/* Now set up the master server socket waiting for tp4 connections. */
    531  1.11   mycroft 	if (tp4flag) {
    532  1.11   mycroft 		if ((tp4sock = socket(AF_ISO, SOCK_SEQPACKET, 0)) < 0) {
    533  1.11   mycroft 			syslog(LOG_ERR, "can't create tp4 socket");
    534   1.1       cgd 			exit(1);
    535   1.1       cgd 		}
    536  1.11   mycroft 		if (setsockopt(tp4sock,
    537  1.11   mycroft 		    SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
    538   1.1       cgd 			syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
    539  1.11   mycroft 		memset(&isoaddr, 0, sizeof(isoaddr));
    540  1.11   mycroft 		isoaddr.siso_family = AF_ISO;
    541  1.11   mycroft 		isoaddr.siso_tlen = 2;
    542  1.11   mycroft 		cp = TSEL(&isoaddr);
    543  1.11   mycroft 		*cp++ = (NFS_PORT >> 8);
    544  1.11   mycroft 		*cp = (NFS_PORT & 0xff);
    545  1.11   mycroft 		isoaddr.siso_len = sizeof(isoaddr);
    546  1.11   mycroft 		if (bind(tp4sock,
    547  1.12   mycroft 		    (struct sockaddr *)&isoaddr, sizeof(isoaddr)) < 0) {
    548  1.11   mycroft 			syslog(LOG_ERR, "can't bind tp4 addr");
    549   1.1       cgd 			exit(1);
    550   1.1       cgd 		}
    551  1.11   mycroft 		if (listen(tp4sock, 5) < 0) {
    552  1.11   mycroft 			syslog(LOG_ERR, "listen failed");
    553   1.1       cgd 			exit(1);
    554   1.1       cgd 		}
    555  1.11   mycroft 		/*
    556  1.11   mycroft 		 * XXX
    557  1.11   mycroft 		 * Someday this should probably use "rpcbind", the son of
    558  1.11   mycroft 		 * portmap.
    559  1.11   mycroft 		 */
    560   1.1       cgd 		if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_TCP, NFS_PORT)) {
    561  1.11   mycroft 			syslog(LOG_ERR, "can't register tcp with portmap");
    562  1.11   mycroft 			exit(1);
    563  1.11   mycroft 		}
    564  1.37   mycroft 		set[2].fd = tp4sock;
    565  1.37   mycroft 		set[2].events = POLLIN;
    566  1.11   mycroft 		connect_type_cnt++;
    567  1.37   mycroft 	} else
    568  1.38   mycroft 		set[2].fd = -1;
    569  1.11   mycroft 
    570  1.11   mycroft 	/* Now set up the master server socket waiting for tpip connections. */
    571  1.11   mycroft 	if (tpipflag) {
    572  1.11   mycroft 		if ((tpipsock = socket(AF_INET, SOCK_SEQPACKET, 0)) < 0) {
    573  1.11   mycroft 			syslog(LOG_ERR, "can't create tpip socket");
    574  1.11   mycroft 			exit(1);
    575  1.11   mycroft 		}
    576  1.11   mycroft 		if (setsockopt(tpipsock,
    577  1.11   mycroft 		    SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
    578  1.11   mycroft 			syslog(LOG_ERR, "setsockopt SO_REUSEADDR: %m");
    579  1.11   mycroft 		inetaddr.sin_family = AF_INET;
    580  1.11   mycroft 		inetaddr.sin_addr.s_addr = INADDR_ANY;
    581  1.11   mycroft 		inetaddr.sin_port = htons(NFS_PORT);
    582  1.11   mycroft 		inetaddr.sin_len = sizeof(inetaddr);
    583  1.20   mycroft 		memset(inetaddr.sin_zero, 0, sizeof(inetaddr.sin_zero));
    584  1.11   mycroft 		if (bind(tpipsock,
    585  1.11   mycroft 		    (struct sockaddr *)&inetaddr, sizeof (inetaddr)) < 0) {
    586  1.11   mycroft 			syslog(LOG_ERR, "can't bind tcp addr");
    587  1.11   mycroft 			exit(1);
    588  1.11   mycroft 		}
    589  1.11   mycroft 		if (listen(tpipsock, 5) < 0) {
    590  1.11   mycroft 			syslog(LOG_ERR, "listen failed");
    591   1.1       cgd 			exit(1);
    592   1.1       cgd 		}
    593   1.1       cgd 		/*
    594  1.11   mycroft 		 * XXX
    595  1.11   mycroft 		 * Someday this should probably use "rpcbind", the son of
    596  1.11   mycroft 		 * portmap.
    597   1.1       cgd 		 */
    598  1.11   mycroft 		if (!pmap_set(RPCPROG_NFS, NFS_VER2, IPPROTO_TCP, NFS_PORT)) {
    599  1.11   mycroft 			syslog(LOG_ERR, "can't register tcp with portmap");
    600  1.11   mycroft 			exit(1);
    601  1.11   mycroft 		}
    602  1.37   mycroft 		set[3].fd = tpipsock;
    603  1.37   mycroft 		set[3].events = POLLIN;
    604  1.11   mycroft 		connect_type_cnt++;
    605  1.37   mycroft 	} else
    606  1.38   mycroft 		set[3].fd = -1;
    607  1.37   mycroft #else
    608  1.38   mycroft 	set[2].fd = -1;
    609  1.38   mycroft 	set[3].fd = -1;
    610  1.11   mycroft #endif /* notyet */
    611  1.11   mycroft 
    612  1.11   mycroft 	if (connect_type_cnt == 0)
    613  1.11   mycroft 		exit(0);
    614  1.11   mycroft 
    615  1.51      yamt 	pthread_setname_np(pthread_self(), "master", NULL);
    616  1.11   mycroft 
    617  1.11   mycroft 	/*
    618  1.11   mycroft 	 * Loop forever accepting connections and passing the sockets
    619  1.11   mycroft 	 * into the kernel for the mounts.
    620  1.11   mycroft 	 */
    621  1.11   mycroft 	for (;;) {
    622  1.41   mycroft 		if (poll(set, 4, INFTIM) < 1) {
    623  1.49      elad 			syslog(LOG_ERR, "poll failed: %m");
    624  1.41   mycroft 			exit(1);
    625  1.11   mycroft 		}
    626  1.38   mycroft 
    627  1.37   mycroft 		if (set[0].revents & POLLIN) {
    628  1.11   mycroft 			len = sizeof(inetpeer);
    629  1.11   mycroft 			if ((msgsock = accept(tcpsock,
    630  1.11   mycroft 			    (struct sockaddr *)&inetpeer, &len)) < 0) {
    631  1.11   mycroft 				syslog(LOG_ERR, "accept failed: %m");
    632   1.1       cgd 				exit(1);
    633   1.1       cgd 			}
    634  1.11   mycroft 			memset(inetpeer.sin_zero, 0, sizeof(inetpeer.sin_zero));
    635  1.11   mycroft 			if (setsockopt(msgsock, SOL_SOCKET,
    636  1.11   mycroft 			    SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
    637  1.11   mycroft 				syslog(LOG_ERR,
    638  1.11   mycroft 				    "setsockopt SO_KEEPALIVE: %m");
    639  1.11   mycroft 			nfsdargs.sock = msgsock;
    640  1.11   mycroft 			nfsdargs.name = (caddr_t)&inetpeer;
    641  1.11   mycroft 			nfsdargs.namelen = sizeof(inetpeer);
    642  1.11   mycroft 			nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
    643  1.11   mycroft 			(void)close(msgsock);
    644  1.11   mycroft 		}
    645  1.32      fvdl 
    646  1.37   mycroft 		if (set[1].revents & POLLIN) {
    647  1.32      fvdl 			len = sizeof(inet6peer);
    648  1.32      fvdl 			if ((msgsock = accept(tcp6sock,
    649  1.32      fvdl 			    (struct sockaddr *)&inet6peer, &len)) < 0) {
    650  1.32      fvdl 				syslog(LOG_ERR, "accept failed: %m");
    651  1.32      fvdl 				exit(1);
    652  1.32      fvdl 			}
    653  1.32      fvdl 			if (setsockopt(msgsock, SOL_SOCKET,
    654  1.32      fvdl 			    SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
    655  1.32      fvdl 				syslog(LOG_ERR,
    656  1.32      fvdl 				    "setsockopt SO_KEEPALIVE: %m");
    657  1.32      fvdl 			nfsdargs.sock = msgsock;
    658  1.32      fvdl 			nfsdargs.name = (caddr_t)&inet6peer;
    659  1.32      fvdl 			nfsdargs.namelen = sizeof(inet6peer);
    660  1.32      fvdl 			nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
    661  1.32      fvdl 			(void)close(msgsock);
    662  1.32      fvdl 		}
    663  1.32      fvdl 
    664  1.11   mycroft #ifdef notyet
    665  1.37   mycroft 		if (set[2].revents & POLLIN) {
    666  1.11   mycroft 			len = sizeof(isopeer);
    667  1.11   mycroft 			if ((msgsock = accept(tp4sock,
    668  1.11   mycroft 			    (struct sockaddr *)&isopeer, &len)) < 0) {
    669  1.11   mycroft 				syslog(LOG_ERR, "accept failed: %m");
    670  1.11   mycroft 				exit(1);
    671   1.1       cgd 			}
    672  1.11   mycroft 			if (setsockopt(msgsock, SOL_SOCKET,
    673  1.11   mycroft 			    SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
    674  1.11   mycroft 				syslog(LOG_ERR,
    675  1.11   mycroft 				    "setsockopt SO_KEEPALIVE: %m");
    676  1.11   mycroft 			nfsdargs.sock = msgsock;
    677  1.11   mycroft 			nfsdargs.name = (caddr_t)&isopeer;
    678  1.11   mycroft 			nfsdargs.namelen = len;
    679  1.11   mycroft 			nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
    680  1.11   mycroft 			(void)close(msgsock);
    681  1.11   mycroft 		}
    682  1.38   mycroft 
    683  1.37   mycroft 		if (set[3].revents & POLLIN) {
    684  1.11   mycroft 			len = sizeof(inetpeer);
    685  1.11   mycroft 			if ((msgsock = accept(tpipsock,
    686  1.11   mycroft 			    (struct sockaddr *)&inetpeer, &len)) < 0) {
    687  1.41   mycroft 				syslog(LOG_ERR, "accept failed: %m");
    688   1.1       cgd 				exit(1);
    689   1.1       cgd 			}
    690  1.11   mycroft 			if (setsockopt(msgsock, SOL_SOCKET,
    691  1.11   mycroft 			    SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
    692  1.11   mycroft 				syslog(LOG_ERR, "setsockopt SO_KEEPALIVE: %m");
    693  1.11   mycroft 			nfsdargs.sock = msgsock;
    694  1.11   mycroft 			nfsdargs.name = (caddr_t)&inetpeer;
    695  1.11   mycroft 			nfsdargs.namelen = len;
    696  1.11   mycroft 			nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
    697  1.11   mycroft 			(void)close(msgsock);
    698   1.1       cgd 		}
    699  1.11   mycroft #endif /* notyet */
    700   1.1       cgd 	}
    701   1.1       cgd }
    702   1.1       cgd 
    703  1.11   mycroft void
    704   1.1       cgd usage()
    705   1.1       cgd {
    706  1.15   mycroft 	(void)fprintf(stderr, "usage: nfsd %s\n", USAGE);
    707   1.1       cgd 	exit(1);
    708   1.1       cgd }
    709   1.1       cgd 
    710   1.1       cgd void
    711  1.11   mycroft nonfs(signo)
    712  1.11   mycroft 	int signo;
    713   1.1       cgd {
    714  1.11   mycroft 	syslog(LOG_ERR, "missing system call: NFS not available.");
    715   1.1       cgd }
    716