tests/fs/nfs/nfsservice/nfsd.c

   1 /*      $NetBSD: nfsd.c,v 1.5 2015/08/21 14:19:10 christos Exp $        */
   2
   3 /*
   4  * Copyright (c) 1989, 1993, 1994
   5  *      The Regents of the University of California.  All rights reserved.
   6  *
   7  * This code is derived from software contributed to Berkeley by
   8  * Rick Macklem at The University of Guelph.
   9  *
  10  * Redistribution and use in source and binary forms, with or without
  11  * modification, are permitted provided that the following conditions
  12  * are met:
  13  * 1. Redistributions of source code must retain the above copyright
  14  *    notice, this list of conditions and the following disclaimer.
  15  * 2. Redistributions in binary form must reproduce the above copyright
  16  *    notice, this list of conditions and the following disclaimer in the
  17  *    documentation and/or other materials provided with the distribution.
  18  * 3. Neither the name of the University nor the names of its contributors
  19  *    may be used to endorse or promote products derived from this software
  20  *    without specific prior written permission.
  21  *
  22  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  23  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  24  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  25  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  26  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  27  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  28  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  29  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  30  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  31  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  32  * SUCH DAMAGE.
  33  */
  34
  35 #include <sys/cdefs.h>
  36 #ifndef lint
  37 __COPYRIGHT("@(#) Copyright (c) 1989, 1993, 1994\
  38  The Regents of the University of California.  All rights reserved.");
  39 #endif /* not lint */
  40
  41 #ifndef lint
  42 #if 0
  43 static char sccsid[] = "@(#)nfsd.c      8.9 (Berkeley) 3/29/95";
  44 #else
  45 __RCSID("$NetBSD: nfsd.c,v 1.5 2015/08/21 14:19:10 christos Exp $");
  46 #endif
  47 #endif /* not lint */
  48
  49 #include <sys/param.h>
  50 #include <sys/ioctl.h>
  51 #include <sys/stat.h>
  52 #include <sys/wait.h>
  53 #include <sys/uio.h>
  54 #include <sys/ucred.h>
  55 #include <sys/mount.h>
  56 #include <sys/socket.h>
  57 #include <sys/socketvar.h>
  58 #include <poll.h>
  59
  60 #include <rpc/rpc.h>
  61 #include <rpc/pmap_clnt.h>
  62 #include <rpc/pmap_prot.h>
  63
  64 #include <nfs/rpcv2.h>
  65 #include <nfs/nfsproto.h>
  66 #include <nfs/nfs.h>
  67
  68 #include <err.h>
  69 #include <errno.h>
  70 #include <fcntl.h>
  71 #include <grp.h>
  72 #include <pwd.h>
  73 #include <pthread.h>
  74 #include <signal.h>
  75 #include <stdio.h>
  76 #include <stdlib.h>
  77 #include <string.h>
  78 #include <syslog.h>
  79 #include <unistd.h>
  80 #include <netdb.h>
  81
  82 #include <rump/rump.h>
  83 #include <rump/rump_syscalls.h>
  84
  85 /* Global defs */
  86 #ifdef DEBUG
  87 #define syslog(e, s, args...)                                           \
  88 do {                                                                    \
  89     fprintf(stderr,(s), ## args);                                       \
  90     fprintf(stderr, "\n");                                              \
  91 } while (/*CONSTCOND*/0)
  92 int     debug = 1;
  93 #else
  94 int     debug = 0;
  95 #endif
  96
  97 void    nonfs(int);
  98 void    usage(void);
  99
 100 static void *
 101 child(void *arg)
 102 {
 103         struct  nfsd_srvargs nsd;
 104         int nfssvc_flag;
 105
 106         nfssvc_flag = NFSSVC_NFSD;
 107         memset(&nsd, 0, sizeof(nsd));
 108         while (rump_sys_nfssvc(nfssvc_flag, &nsd) < 0) {
 109                 if (errno != ENEEDAUTH) {
 110                         syslog(LOG_ERR, "nfssvc (%s)", strerror(errno));
 111                         exit(1);
 112                 }
 113                 nfssvc_flag = NFSSVC_NFSD | NFSSVC_AUTHINFAIL;
 114         }
 115
 116         return NULL;
 117 }
 118
 119 /*
 120  * Nfs server daemon mostly just a user context for nfssvc()
 121  *
 122  * 1 - do file descriptor and signal cleanup
 123  * 2 - create the nfsd thread(s)
 124  * 3 - create server socket(s)
 125  * 4 - register socket with portmap
 126  *
 127  * For connectionless protocols, just pass the socket into the kernel via
 128  * nfssvc().
 129  * For connection based sockets, loop doing accepts. When you get a new
 130  * socket from accept, pass the msgsock into the kernel via nfssvc().
 131  * The arguments are:
 132  *      -c - support iso cltp clients
 133  *      -r - reregister with portmapper
 134  *      -t - support tcp nfs clients
 135  *      -u - support udp nfs clients
 136  * followed by "n" which is the number of nfsd threads to create
 137  */
 138 int nfsd_main(int, char**);
 139 int
 140 nfsd_main(argc, argv)
 141         int argc;
 142         char *argv[];
 143 {
 144         struct nfsd_args nfsdargs;
 145         struct addrinfo *ai_udp, *ai_tcp, *ai_udp6, *ai_tcp6, hints;
 146         struct netconfig *nconf_udp, *nconf_tcp, *nconf_udp6, *nconf_tcp6;
 147         struct netbuf nb_udp, nb_tcp, nb_udp6, nb_tcp6;
 148         struct sockaddr_in inetpeer;
 149         struct pollfd set[4];
 150         socklen_t len;
 151         int ch, connect_type_cnt, i, msgsock;
 152         int nfsdcnt, on = 1, reregister, sock, tcpflag, tcpsock;
 153         int tcp6sock, ip6flag;
 154         int tp4cnt, tp4flag, tpipcnt, udpflag, ecode, s;
 155
 156 #define DEFNFSDCNT       4
 157         nfsdcnt = DEFNFSDCNT;
 158         reregister = tcpflag = tp4cnt = tp4flag = tpipcnt = 0;
 159         udpflag = ip6flag = 0;
 160         nconf_udp = nconf_tcp = nconf_udp6 = nconf_tcp6 = NULL;
 161         tcpsock = tcp6sock = -1;
 162 #define GETOPT  "6n:rtu"
 163 #define USAGE   "[-rtu] [-n num_servers]"
 164         while ((ch = getopt(argc, argv, GETOPT)) != -1) {
 165                 switch (ch) {
 166                 case '6':
 167                         ip6flag = 1;
 168                         s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_UDP);
 169                         if (s < 0 && (errno == EPROTONOSUPPORT ||
 170                             errno == EPFNOSUPPORT || errno == EAFNOSUPPORT))
 171                                 ip6flag = 0;
 172                         else
 173                                 close(s);
 174                         break;
 175                 case 'n':
 176                         nfsdcnt = atoi(optarg);
 177                         if (nfsdcnt < 1) {
 178                                 warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
 179                                 nfsdcnt = DEFNFSDCNT;
 180                         }
 181                         break;
 182                 case 'r':
 183                         reregister = 1;
 184                         break;
 185                 case 't':
 186                         tcpflag = 1;
 187                         break;
 188                 case 'u':
 189                         udpflag = 1;
 190                         break;
 191                 default:
 192                 case '?':
 193                         usage();
 194                 };
 195         }
 196         argv += optind;
 197         argc -= optind;
 198
 199         /*
 200          * XXX
 201          * Backward compatibility, trailing number is the count of daemons.
 202          */
 203         if (argc > 1)
 204                 usage();
 205         if (argc == 1) {
 206                 nfsdcnt = atoi(argv[0]);
 207                 if (nfsdcnt < 1) {
 208                         warnx("nfsd count %d; reset to %d", nfsdcnt, DEFNFSDCNT);
 209                         nfsdcnt = DEFNFSDCNT;
 210                 }
 211         }
 212
 213         /*
 214          * If none of TCP or UDP are specified, default to UDP only.
 215          */
 216         if (tcpflag == 0 && udpflag == 0)
 217                 udpflag = 1;
 218
 219         if (debug == 0) {
 220                 fprintf(stderr, "non-debug not supported here\n");
 221                 exit(1);
 222
 223 #ifdef not_the_debug_man
 224                 daemon(0, 0);
 225                 (void)signal(SIGHUP, SIG_IGN);
 226                 (void)signal(SIGINT, SIG_IGN);
 227                 (void)signal(SIGQUIT, SIG_IGN);
 228                 (void)signal(SIGSYS, nonfs);
 229 #endif
 230         }
 231
 232         if (udpflag) {
 233                 memset(&hints, 0, sizeof hints);
 234                 hints.ai_flags = AI_PASSIVE;
 235                 hints.ai_family = PF_INET;
 236                 hints.ai_socktype = SOCK_DGRAM;
 237                 hints.ai_protocol = IPPROTO_UDP;
 238
 239                 ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp);
 240                 if (ecode != 0) {
 241                         syslog(LOG_ERR, "getaddrinfo udp: %s",
 242                             gai_strerror(ecode));
 243                         exit(1);
 244                 }
 245
 246                 nconf_udp = getnetconfigent("udp");
 247
 248                 if (nconf_udp == NULL)
 249                         err(1, "getnetconfigent udp failed");
 250
 251                 nb_udp.buf = ai_udp->ai_addr;
 252                 nb_udp.len = nb_udp.maxlen = ai_udp->ai_addrlen;
 253                 if (reregister)
 254                         if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp))
 255                                 err(1, "rpcb_set udp failed");
 256         }
 257
 258         if (tcpflag) {
 259                 memset(&hints, 0, sizeof hints);
 260                 hints.ai_flags = AI_PASSIVE;
 261                 hints.ai_family = PF_INET;
 262                 hints.ai_socktype = SOCK_STREAM;
 263                 hints.ai_protocol = IPPROTO_TCP;
 264
 265                 ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp);
 266                 if (ecode != 0) {
 267                         syslog(LOG_ERR, "getaddrinfo tcp: %s",
 268                             gai_strerror(ecode));
 269                         exit(1);
 270                 }
 271
 272                 nconf_tcp = getnetconfigent("tcp");
 273
 274                 if (nconf_tcp == NULL)
 275                         err(1, "getnetconfigent tcp failed");
 276
 277                 nb_tcp.buf = ai_tcp->ai_addr;
 278                 nb_tcp.len = nb_tcp.maxlen = ai_tcp->ai_addrlen;
 279                 if (reregister)
 280                         if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp))
 281                                 err(1, "rpcb_set tcp failed");
 282         }
 283
 284         if (udpflag && ip6flag) {
 285                 memset(&hints, 0, sizeof hints);
 286                 hints.ai_flags = AI_PASSIVE;
 287                 hints.ai_family = PF_INET6;
 288                 hints.ai_socktype = SOCK_DGRAM;
 289                 hints.ai_protocol = IPPROTO_UDP;
 290
 291                 ecode = getaddrinfo(NULL, "nfs", &hints, &ai_udp6);
 292                 if (ecode != 0) {
 293                         syslog(LOG_ERR, "getaddrinfo udp: %s",
 294                             gai_strerror(ecode));
 295                         exit(1);
 296                 }
 297
 298                 nconf_udp6 = getnetconfigent("udp6");
 299
 300                 if (nconf_udp6 == NULL)
 301                         err(1, "getnetconfigent udp6 failed");
 302
 303                 nb_udp6.buf = ai_udp6->ai_addr;
 304                 nb_udp6.len = nb_udp6.maxlen = ai_udp6->ai_addrlen;
 305                 if (reregister)
 306                         if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6))
 307                                 err(1, "rpcb_set udp6 failed");
 308         }
 309
 310         if (tcpflag && ip6flag) {
 311                 memset(&hints, 0, sizeof hints);
 312                 hints.ai_flags = AI_PASSIVE;
 313                 hints.ai_family = PF_INET6;
 314                 hints.ai_socktype = SOCK_STREAM;
 315                 hints.ai_protocol = IPPROTO_TCP;
 316
 317                 ecode = getaddrinfo(NULL, "nfs", &hints, &ai_tcp6);
 318                 if (ecode != 0) {
 319                         syslog(LOG_ERR, "getaddrinfo tcp: %s",
 320                             gai_strerror(ecode));
 321                         exit(1);
 322                 }
 323
 324                 nconf_tcp6 = getnetconfigent("tcp6");
 325
 326                 if (nconf_tcp6 == NULL)
 327                         err(1, "getnetconfigent tcp6 failed");
 328
 329                 nb_tcp6.buf = ai_tcp6->ai_addr;
 330                 nb_tcp6.len = nb_tcp6.maxlen = ai_tcp6->ai_addrlen;
 331                 if (reregister)
 332                         if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6))
 333                                 err(1, "rpcb_set tcp6 failed");
 334         }
 335
 336         openlog("nfsd", LOG_PID, LOG_DAEMON);
 337
 338         for (i = 0; i < nfsdcnt; i++) {
 339                 pthread_t t;
 340                 pthread_create(&t, NULL, child, NULL);
 341         }
 342
 343         /* If we are serving udp, set up the socket. */
 344         if (udpflag) {
 345                 if ((sock = rump_sys_socket(ai_udp->ai_family, ai_udp->ai_socktype,
 346                     ai_udp->ai_protocol)) < 0) {
 347                         syslog(LOG_ERR, "can't create udp socket");
 348                         exit(1);
 349                 }
 350                 if (bind(sock, ai_udp->ai_addr, ai_udp->ai_addrlen) < 0) {
 351                         syslog(LOG_ERR, "can't bind udp addr");
 352                         exit(1);
 353                 }
 354                 if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp, &nb_udp) ||
 355                     !rpcb_set(RPCPROG_NFS, 3, nconf_udp, &nb_udp)) {
 356                         syslog(LOG_ERR, "can't register with udp portmap");
 357                         exit(1);
 358                 }
 359                 nfsdargs.sock = sock;
 360                 nfsdargs.name = NULL;
 361                 nfsdargs.namelen = 0;
 362                 if (rump_sys_nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
 363                         syslog(LOG_ERR, "can't add UDP socket");
 364                         exit(1);
 365                 }
 366                 (void)rump_sys_close(sock);
 367         }
 368
 369         if (udpflag &&ip6flag) {
 370                 if ((sock = rump_sys_socket(ai_udp6->ai_family, ai_udp6->ai_socktype,
 371                     ai_udp6->ai_protocol)) < 0) {
 372                         syslog(LOG_ERR, "can't create udp socket");
 373                         exit(1);
 374                 }
 375                 if (rump_sys_setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY,
 376                     &on, sizeof on) < 0) {
 377                         syslog(LOG_ERR, "can't set v6-only binding for udp6 "
 378                             "socket (%s)", strerror(errno));
 379                         exit(1);
 380                 }
 381                 if (rump_sys_bind(sock, ai_udp6->ai_addr, ai_udp6->ai_addrlen) < 0) {
 382                         syslog(LOG_ERR, "can't bind udp addr (%s)",
 383                             strerror(errno));
 384                         exit(1);
 385                 }
 386                 if (!rpcb_set(RPCPROG_NFS, 2, nconf_udp6, &nb_udp6) ||
 387                     !rpcb_set(RPCPROG_NFS, 3, nconf_udp6, &nb_udp6)) {
 388                         syslog(LOG_ERR, "can't register with udp portmap");
 389                         exit(1);
 390                 }
 391                 nfsdargs.sock = sock;
 392                 nfsdargs.name = NULL;
 393                 nfsdargs.namelen = 0;
 394                 if (rump_sys_nfssvc(NFSSVC_ADDSOCK, &nfsdargs) < 0) {
 395                         syslog(LOG_ERR, "can't add UDP6 socket (%s)",
 396                             strerror(errno));
 397                         exit(1);
 398                 }
 399                 (void)rump_sys_close(sock);
 400         }
 401
 402         /* Now set up the master server socket waiting for tcp connections. */
 403         on = 1;
 404         connect_type_cnt = 0;
 405         if (tcpflag) {
 406                 if ((tcpsock = rump_sys_socket(ai_tcp->ai_family, ai_tcp->ai_socktype,
 407                     ai_tcp->ai_protocol)) < 0) {
 408                         syslog(LOG_ERR, "can't create tcp socket");
 409                         exit(1);
 410                 }
 411                 if (setsockopt(tcpsock,
 412                     SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
 413                         syslog(LOG_ERR, "setsockopt SO_REUSEADDR (%s)",
 414                             strerror(errno));
 415                 if (bind(tcpsock, ai_tcp->ai_addr, ai_tcp->ai_addrlen) < 0) {
 416                         syslog(LOG_ERR, "can't bind tcp addr");
 417                         exit(1);
 418                 }
 419                 if (rump_sys_listen(tcpsock, 5) < 0) {
 420                         syslog(LOG_ERR, "listen failed");
 421                         exit(1);
 422                 }
 423                 if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp, &nb_tcp) ||
 424                     !rpcb_set(RPCPROG_NFS, 3, nconf_tcp, &nb_tcp)) {
 425                         syslog(LOG_ERR, "can't register tcp with rpcbind");
 426                         exit(1);
 427                 }
 428                 set[0].fd = tcpsock;
 429                 set[0].events = POLLIN;
 430                 connect_type_cnt++;
 431         } else
 432                 set[0].fd = -1;
 433
 434         if (tcpflag && ip6flag) {
 435                 if ((tcp6sock = socket(ai_tcp6->ai_family, ai_tcp6->ai_socktype,
 436                     ai_tcp6->ai_protocol)) < 0) {
 437                         syslog(LOG_ERR, "can't create tcp socket (%s)",
 438                             strerror(errno));
 439                         exit(1);
 440                 }
 441                 if (setsockopt(tcp6sock,
 442                     SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0)
 443                         syslog(LOG_ERR, "setsockopt SO_REUSEADDR (%s)",
 444                             strerror(errno));
 445                 if (setsockopt(tcp6sock, IPPROTO_IPV6, IPV6_V6ONLY,
 446                     &on, sizeof on) < 0) {
 447                         syslog(LOG_ERR, "can't set v6-only binding for tcp6 "
 448                             "socket (%s)", strerror(errno));
 449                         exit(1);
 450                 }
 451                 if (bind(tcp6sock, ai_tcp6->ai_addr, ai_tcp6->ai_addrlen) < 0) {
 452                         syslog(LOG_ERR, "can't bind tcp6 addr (%s)",
 453                             strerror(errno));
 454                         exit(1);
 455                 }
 456                 if (listen(tcp6sock, 5) < 0) {
 457                         syslog(LOG_ERR, "listen failed (%s)", strerror(errno));
 458                         exit(1);
 459                 }
 460                 if (!rpcb_set(RPCPROG_NFS, 2, nconf_tcp6, &nb_tcp6) ||
 461                     !rpcb_set(RPCPROG_NFS, 3, nconf_tcp6, &nb_tcp6)) {
 462                         syslog(LOG_ERR, "can't register tcp6 with rpcbind");
 463                         exit(1);
 464                 }
 465                 set[1].fd = tcp6sock;
 466                 set[1].events = POLLIN;
 467                 connect_type_cnt++;
 468         } else
 469                 set[1].fd = -1;
 470
 471         set[2].fd = -1;
 472         set[3].fd = -1;
 473
 474         if (connect_type_cnt == 0) {
 475                 pause();
 476                 exit(0);
 477         }
 478
 479         /*
 480          * Loop forever accepting connections and passing the sockets
 481          * into the kernel for the mounts.
 482          */
 483         for (;;) {
 484                 if (rump_sys_poll(set, 4, INFTIM) < 1) {
 485                         syslog(LOG_ERR, "poll failed (%s)", strerror(errno));
 486                         exit(1);
 487                 }
 488
 489                 len = sizeof(inetpeer);
 490                 if ((msgsock = accept(tcpsock,
 491                     (struct sockaddr *)&inetpeer, &len)) < 0) {
 492                         syslog(LOG_ERR, "accept failed (%s)",
 493                             strerror(errno));
 494                         exit(1);
 495                 }
 496                 memset(inetpeer.sin_zero, 0, sizeof(inetpeer.sin_zero));
 497                 if (setsockopt(msgsock, SOL_SOCKET,
 498                     SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
 499                         syslog(LOG_ERR, "setsockopt SO_KEEPALIVE (%s)",
 500                             strerror(errno));
 501                 nfsdargs.sock = msgsock;
 502                 nfsdargs.name = (caddr_t)&inetpeer;
 503                 nfsdargs.namelen = sizeof(inetpeer);
 504                 rump_sys_nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
 505                 (void)rump_sys_close(msgsock);
 506
 507 #ifdef notyet
 508                 int error = 0;
 509                 if (set[1].revents & POLLIN) {
 510                         len = sizeof(inet6peer);
 511                         if ((msgsock = rump_sys_accept(tcp6sock,
 512                             (struct sockaddr *)&inet6peer, &len, &error)) < 0) {
 513                                 syslog(LOG_ERR, "accept failed (%s)",
 514                                         strerror(error));
 515                                 exit(1);
 516                         }
 517                         if (rump_sys_setsockopt(msgsock, SOL_SOCKET,
 518                             SO_KEEPALIVE, (char *)&on, sizeof(on), &error) < 0)
 519                                 syslog(LOG_ERR,
 520                                     "setsockopt SO_KEEPALIVE (%s)",
 521                                         strerror(error));
 522                         nfsdargs.sock = msgsock;
 523                         nfsdargs.name = (caddr_t)&inet6peer;
 524                         nfsdargs.namelen = sizeof(inet6peer);
 525                         rump_sys_nfssvc(NFSSVC_ADDSOCK, &nfsdargs, &error);
 526                         (void)rump_sys_close(msgsock, &error);
 527                 }
 528
 529                 if (set[2].revents & POLLIN) {
 530                         len = sizeof(isopeer);
 531                         if ((msgsock = rump_sys_accept(tp4sock,
 532                             (struct sockaddr *)&isopeer, &len, &error)) < 0) {
 533                                 syslog(LOG_ERR, "accept failed (%s)",
 534                                     strerror(error));
 535                                 exit(1);
 536                         }
 537                         if (rump_sys_setsockopt(msgsock, SOL_SOCKET,
 538                             SO_KEEPALIVE, (char *)&on, sizeof(on), &error) < 0)
 539                                 syslog(LOG_ERR, "setsockopt SO_KEEPALIVE (%s)",
 540                                     strerror(error));
 541                         nfsdargs.sock = msgsock;
 542                         nfsdargs.name = (caddr_t)&isopeer;
 543                         nfsdargs.namelen = len;
 544                         rump_sys_nfssvc(NFSSVC_ADDSOCK, &nfsdargs, &error);
 545                         (void)rump_sys_close(msgsock, &error);
 546                 }
 547
 548                 if (set[3].revents & POLLIN) {
 549                         len = sizeof(inetpeer);
 550                         if ((msgsock = rump_sys_accept(tpipsock,
 551                             (struct sockaddr *)&inetpeer, &len)) < 0) {
 552                                 syslog(LOG_ERR, "accept failed (%s)",
 553                                     strerror(errno));
 554                                 exit(1);
 555                         }
 556                         if (setsockopt(msgsock, SOL_SOCKET,
 557                             SO_KEEPALIVE, (char *)&on, sizeof(on)) < 0)
 558                                 syslog(LOG_ERR, "setsockopt SO_KEEPALIVE (%s)",
 559                                     strerror(errno));
 560                         nfsdargs.sock = msgsock;
 561                         nfsdargs.name = (caddr_t)&inetpeer;
 562                         nfsdargs.namelen = len;
 563                         rump_sys_nfssvc(NFSSVC_ADDSOCK, &nfsdargs);
 564                         (void)rump_sys_close(msgsock);
 565                 }
 566 #endif /* notyet */
 567         }
 568 }
 569
 570 void
 571 usage()
 572 {
 573         (void)fprintf(stderr, "usage: nfsd %s\n", USAGE);
 574         exit(1);
 575 }
 576
 577 void
 578 nonfs(signo)
 579         int signo;
 580 {
 581         syslog(LOG_ERR, "missing system call: NFS not available.");
 582 }