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