lib/libc/rpc/svc_run.c

   1 /*      $NetBSD: svc_run.c,v 1.17 2000/07/06 03:10:35 christos Exp $    */
   2
   3 /*-
   4  * Copyright (c) 2009, Sun Microsystems, Inc.
   5  * All rights reserved.
   6  *
   7  * Redistribution and use in source and binary forms, with or without
   8  * modification, are permitted provided that the following conditions are met:
   9  * - Redistributions of source code must retain the above copyright notice,
  10  *   this list of conditions and the following disclaimer.
  11  * - Redistributions in binary form must reproduce the above copyright notice,
  12  *   this list of conditions and the following disclaimer in the documentation
  13  *   and/or other materials provided with the distribution.
  14  * - Neither the name of Sun Microsystems, Inc. nor the names of its
  15  *   contributors may be used to endorse or promote products derived
  16  *   from this software without specific prior written permission.
  17  *
  18  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  19  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  20  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  21  * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
  22  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  23  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  24  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  25  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  26  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  27  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  28  * POSSIBILITY OF SUCH DAMAGE.
  29  */
  30
  31 #if defined(LIBC_SCCS) && !defined(lint)
  32 static char *sccsid2 = "from: @(#)svc_run.c 1.1 87/10/13 Copyr 1984 Sun Micro";
  33 static char *sccsid = "from: @(#)svc_run.c      2.1 88/07/29 4.0 RPCSRC";
  34 #endif
  35 #include <sys/cdefs.h>
  36 __FBSDID("$FreeBSD$");
  37
  38 /*
  39  * This is the rpc server side idle loop
  40  * Wait for input, call server program.
  41  */
  42 #include "namespace.h"
  43 #include "reentrant.h"
  44 #include <err.h>
  45 #include <errno.h>
  46 #include <rpc/rpc.h>
  47 #include <stdio.h>
  48 #include <string.h>
  49 #include <unistd.h>
  50 #include "un-namespace.h"
  51
  52 #include <rpc/rpc.h>
  53 #include "rpc_com.h"
  54 #include "mt_misc.h"
  55
  56 void
  57 svc_run()
  58 {
  59         fd_set readfds, cleanfds;
  60         struct timeval timeout;
  61
  62         timeout.tv_sec = 30;
  63         timeout.tv_usec = 0;
  64
  65         for (;;) {
  66                 rwlock_rdlock(&svc_fd_lock);
  67                 readfds = svc_fdset;
  68                 cleanfds = svc_fdset;
  69                 rwlock_unlock(&svc_fd_lock);
  70                 switch (_select(svc_maxfd+1, &readfds, NULL, NULL, &timeout)) {
  71                 case -1:
  72                         FD_ZERO(&readfds);
  73                         if (errno == EINTR) {
  74                                 continue;
  75                         }
  76                         _warn("svc_run: - select failed");
  77                         return;
  78                 case 0:
  79                         __svc_clean_idle(&cleanfds, 30, FALSE);
  80                         continue;
  81                 default:
  82                         svc_getreqset(&readfds);
  83                 }
  84         }
  85 }
  86
  87 /*
  88  *      This function causes svc_run() to exit by telling it that it has no
  89  *      more work to do.
  90  */
  91 void
  92 svc_exit()
  93 {
  94         rwlock_wrlock(&svc_fd_lock);
  95         FD_ZERO(&svc_fdset);
  96         rwlock_unlock(&svc_fd_lock);
  97 }