1 /*
2 * Sun RPC is a product of Sun Microsystems, Inc. and is provided for
3 * unrestricted use provided that this legend is included on all tape
4 * media and as a part of the software program in whole or part. Users
5 * may copy or modify Sun RPC without charge, but are not authorized
6 * to license or distribute it to anyone else except as part of a product or
7 * program developed by the user.
8 *
9 * SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
10 * WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
11 * PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
12 *
13 * Sun RPC is provided with no support and without any obligation on the
14 * part of Sun Microsystems, Inc. to assist in its use, correction,
15 * modification or enhancement.
16 *
17 * SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
18 * INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
19 * OR ANY PART THEREOF.
20 *
21 * In no event will Sun Microsystems, Inc. be liable for any lost revenue
22 * or profits or other special, indirect and consequential damages, even if
23 * Sun has been advised of the possibility of such damages.
24 *
25 * Sun Microsystems, Inc.
26 * 2550 Garcia Avenue
27 * Mountain View, California 94043
28 */
29 /*
30 * This is the rpc server side idle loop
31 * Wait for input, call server program.
32 */
33
34 #include <errno.h>
35 #include <unistd.h>
36 #include <sys/poll.h>
37 #include "rpc_private.h"
38
39 /* used by svc_[max_]pollfd */
40
41 /* This function can be used as a signal handler to terminate the
42 server loop. */
43 void
svc_exit(void)44 svc_exit (void)
45 {
46 free (svc_pollfd);
47 svc_pollfd = NULL;
48 svc_max_pollfd = 0;
49 }
50
51 void
svc_run(void)52 svc_run (void)
53 {
54 int i;
55
56 for (;;)
57 {
58 struct pollfd *my_pollfd;
59
60 if (svc_max_pollfd == 0 && svc_pollfd == NULL)
61 return;
62
63 my_pollfd = malloc (sizeof (struct pollfd) * svc_max_pollfd);
64 for (i = 0; i < svc_max_pollfd; ++i)
65 {
66 my_pollfd[i].fd = svc_pollfd[i].fd;
67 my_pollfd[i].events = svc_pollfd[i].events;
68 my_pollfd[i].revents = 0;
69 }
70
71 switch (i = poll (my_pollfd, svc_max_pollfd, -1))
72 {
73 case -1:
74 free (my_pollfd);
75 if (errno == EINTR)
76 continue;
77 perror (_("svc_run: - poll failed"));
78 return;
79 case 0:
80 free (my_pollfd);
81 continue;
82 default:
83 svc_getreq_poll (my_pollfd, i);
84 free (my_pollfd);
85 }
86 }
87 }
88