3 * A.R. Gordon (andrew.gordon@net-tel.co.uk). All rights reserved.
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
13 * 3. All advertising materials mentioning features or use of this software
14 * must display the following acknowledgement:
15 * This product includes software developed for the FreeBSD project
16 * 4. Neither the name of the author nor the names of any co-contributors
17 * may be used to endorse or promote products derived from this software
18 * without specific prior written permission.
20 * THIS SOFTWARE IS PROVIDED BY ANDREW GORDON AND CONTRIBUTORS ``AS IS'' AND
21 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23 * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
24 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
34 /* main() function for status monitor daemon. Some of the code in this */
35 /* file was generated by running rpcgen /usr/include/rpcsvc/sm_inter.x */
36 /* The actual program logic is in the file procs.c */
38 #include <sys/cdefs.h>
39 __FBSDID("$FreeBSD$");
45 #include <rpc/rpc_com.h>
48 #include <sys/types.h>
54 int debug = 0; /* Controls syslog() calls for debug messages */
56 static void handle_sigchld(int sig);
57 static void usage(void);
59 const char *transports[] = { "udp", "tcp", "udp6", "tcp6" };
62 main(int argc, char **argv)
66 struct netconfig *nconf;
67 struct sockaddr_in sin;
68 struct sockaddr_in6 sin6;
69 int ch, i, maxindex, r, s, sock;
71 int maxrec = RPC_MAXDATASIZE;
72 in_port_t svcport = 0;
74 while ((ch = getopt(argc, argv, "dp:")) != -1)
81 svcport = (in_port_t)strtoul(optarg, &endptr, 10);
82 if (endptr == NULL || *endptr != '\0' || svcport == 0 ||
83 svcport >= IPPORT_MAX)
92 (void)rpcb_unset(SM_PROG, SM_VERS, NULL);
95 * Check if IPv6 support is present.
97 s = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
106 bzero(&sin, sizeof(struct sockaddr_in));
107 sin.sin_len = sizeof(struct sockaddr_in);
108 sin.sin_family = AF_INET;
109 sin.sin_port = htons(svcport);
111 bzero(&sin6, sizeof(struct sockaddr_in6));
112 sin6.sin6_len = sizeof(struct sockaddr_in6);
113 sin6.sin6_family = AF_INET6;
114 sin6.sin6_port = htons(svcport);
117 rpc_control(RPC_SVC_CONNMAXREC_SET, &maxrec);
119 for (i = 0; i < maxindex; i++) {
120 nconf = getnetconfigent(transports[i]);
122 errx(1, "cannot get %s netconf: %s.", transports[i],
126 if (strcmp(nconf->nc_netid, "udp6") == 0) {
127 sock = socket(AF_INET6, SOCK_DGRAM,
130 r = bindresvport_sa(sock,
131 (struct sockaddr *)&sin6);
133 syslog(LOG_ERR, "bindresvport: %m");
137 } else if (strcmp(nconf->nc_netid, "udp") == 0) {
138 sock = socket(AF_INET, SOCK_DGRAM,
141 r = bindresvport(sock, &sin);
143 syslog(LOG_ERR, "bindresvport: %m");
147 } else if (strcmp(nconf->nc_netid, "tcp6") == 0) {
148 sock = socket(AF_INET6, SOCK_STREAM,
151 r = bindresvport_sa(sock,
152 (struct sockaddr *)&sin6);
154 syslog(LOG_ERR, "bindresvport: %m");
158 } else if (strcmp(nconf->nc_netid, "tcp") == 0) {
159 sock = socket(AF_INET, SOCK_STREAM,
162 r = bindresvport(sock, &sin);
164 syslog(LOG_ERR, "bindresvport: %m");
170 if (nconf->nc_semantics != NC_TPI_CLTS)
171 listen(sock, SOMAXCONN);
173 transp = svc_tli_create(sock, nconf, NULL,
174 RPC_MAXDATASIZE, RPC_MAXDATASIZE);
176 transp = svc_tli_create(RPC_ANYFD, nconf, NULL,
177 RPC_MAXDATASIZE, RPC_MAXDATASIZE);
180 if (transp == NULL) {
181 errx(1, "cannot create %s service.", transports[i]);
184 if (!svc_reg(transp, SM_PROG, SM_VERS, sm_prog_1, nconf)) {
185 errx(1, "unable to register (SM_PROG, NLM_SM, %s)",
189 freenetconfigent(nconf);
191 init_file("/var/db/statd.status");
193 /* Note that it is NOT sensible to run this program from inetd - the */
194 /* protocol assumes that it will run immediately at boot time. */
196 openlog("rpc.statd", 0, LOG_DAEMON);
197 if (debug) syslog(LOG_INFO, "Starting - debug enabled");
198 else syslog(LOG_INFO, "Starting");
200 /* Install signal handler to collect exit status of child processes */
201 sa.sa_handler = handle_sigchld;
202 sigemptyset(&sa.sa_mask);
203 sigaddset(&sa.sa_mask, SIGCHLD);
204 sa.sa_flags = SA_RESTART;
205 sigaction(SIGCHLD, &sa, NULL);
207 /* Initialisation now complete - start operating */
208 notify_hosts(); /* Forks a process (if necessary) to do the */
209 /* SM_NOTIFY calls, which may be slow. */
211 svc_run(); /* Should never return */
218 fprintf(stderr, "usage: rpc.statd [-d] [-p <port>]\n");
222 /* handle_sigchld ---------------------------------------------------------- */
224 Purpose: Catch SIGCHLD and collect process status
226 Notes: No special action required, other than to collect the
227 process status and hence allow the child to die:
228 we only use child processes for asynchronous transmission
229 of SM_NOTIFY to other systems, so it is normal for the
230 children to exit when they have done their work.
233 static void handle_sigchld(int sig __unused)
236 pid = wait4(-1, &status, WNOHANG, (struct rusage*)0);
237 if (!pid) syslog(LOG_ERR, "Phantom SIGCHLD??");
238 else if (status == 0)
240 if (debug) syslog(LOG_DEBUG, "Child %d exited OK", pid);
242 else syslog(LOG_ERR, "Child %d failed with status %d", pid,
243 WEXITSTATUS(status));