xref: /freebsd/usr.sbin/inetd/inetd.c (revision 71704f34b12e0a03ff8639d25c895150483c4d58)
1dea673e9SRodney W. Grimes /*
2dea673e9SRodney W. Grimes  * Copyright (c) 1983, 1991, 1993, 1994
3dea673e9SRodney W. Grimes  *	The Regents of the University of California.  All rights reserved.
4dea673e9SRodney W. Grimes  *
5dea673e9SRodney W. Grimes  * Redistribution and use in source and binary forms, with or without
6dea673e9SRodney W. Grimes  * modification, are permitted provided that the following conditions
7dea673e9SRodney W. Grimes  * are met:
8dea673e9SRodney W. Grimes  * 1. Redistributions of source code must retain the above copyright
9dea673e9SRodney W. Grimes  *    notice, this list of conditions and the following disclaimer.
10dea673e9SRodney W. Grimes  * 2. Redistributions in binary form must reproduce the above copyright
11dea673e9SRodney W. Grimes  *    notice, this list of conditions and the following disclaimer in the
12dea673e9SRodney W. Grimes  *    documentation and/or other materials provided with the distribution.
13dea673e9SRodney W. Grimes  * 3. All advertising materials mentioning features or use of this software
14dea673e9SRodney W. Grimes  *    must display the following acknowledgement:
15dea673e9SRodney W. Grimes  *	This product includes software developed by the University of
16dea673e9SRodney W. Grimes  *	California, Berkeley and its contributors.
17dea673e9SRodney W. Grimes  * 4. Neither the name of the University nor the names of its contributors
18dea673e9SRodney W. Grimes  *    may be used to endorse or promote products derived from this software
19dea673e9SRodney W. Grimes  *    without specific prior written permission.
20dea673e9SRodney W. Grimes  *
21dea673e9SRodney W. Grimes  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
22dea673e9SRodney W. Grimes  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23dea673e9SRodney W. Grimes  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24dea673e9SRodney W. Grimes  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
25dea673e9SRodney W. Grimes  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26dea673e9SRodney W. Grimes  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27dea673e9SRodney W. Grimes  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28dea673e9SRodney W. Grimes  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29dea673e9SRodney W. Grimes  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30dea673e9SRodney W. Grimes  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31dea673e9SRodney W. Grimes  * SUCH DAMAGE.
32dea673e9SRodney W. Grimes  */
33dea673e9SRodney W. Grimes 
34dea673e9SRodney W. Grimes #ifndef lint
35dea673e9SRodney W. Grimes static char copyright[] =
36dea673e9SRodney W. Grimes "@(#) Copyright (c) 1983, 1991, 1993, 1994\n\
37dea673e9SRodney W. Grimes 	The Regents of the University of California.  All rights reserved.\n";
38dea673e9SRodney W. Grimes #endif /* not lint */
39dea673e9SRodney W. Grimes 
40dea673e9SRodney W. Grimes #ifndef lint
4155b91f3aSGeoff Rehmet /* from: @(#)inetd.c	8.4 (Berkeley) 4/13/94"; */
4271704f34SGarrett Wollman static char inetd_c_rcsid[] =
4371704f34SGarrett Wollman 	"$Id$";
44dea673e9SRodney W. Grimes #endif /* not lint */
45dea673e9SRodney W. Grimes 
46dea673e9SRodney W. Grimes /*
47dea673e9SRodney W. Grimes  * Inetd - Internet super-server
48dea673e9SRodney W. Grimes  *
49dea673e9SRodney W. Grimes  * This program invokes all internet services as needed.  Connection-oriented
50dea673e9SRodney W. Grimes  * services are invoked each time a connection is made, by creating a process.
51dea673e9SRodney W. Grimes  * This process is passed the connection as file descriptor 0 and is expected
52dea673e9SRodney W. Grimes  * to do a getpeername to find out the source host and port.
53dea673e9SRodney W. Grimes  *
54dea673e9SRodney W. Grimes  * Datagram oriented services are invoked when a datagram
55dea673e9SRodney W. Grimes  * arrives; a process is created and passed a pending message
56dea673e9SRodney W. Grimes  * on file descriptor 0.  Datagram servers may either connect
57dea673e9SRodney W. Grimes  * to their peer, freeing up the original socket for inetd
58dea673e9SRodney W. Grimes  * to receive further messages on, or ``take over the socket'',
59dea673e9SRodney W. Grimes  * processing all arriving datagrams and, eventually, timing
60dea673e9SRodney W. Grimes  * out.	 The first type of server is said to be ``multi-threaded'';
61dea673e9SRodney W. Grimes  * the second type of server ``single-threaded''.
62dea673e9SRodney W. Grimes  *
63dea673e9SRodney W. Grimes  * Inetd uses a configuration file which is read at startup
64dea673e9SRodney W. Grimes  * and, possibly, at some later time in response to a hangup signal.
65dea673e9SRodney W. Grimes  * The configuration file is ``free format'' with fields given in the
66dea673e9SRodney W. Grimes  * order shown below.  Continuation lines for an entry must being with
67dea673e9SRodney W. Grimes  * a space or tab.  All fields must be present in each entry.
68dea673e9SRodney W. Grimes  *
69dea673e9SRodney W. Grimes  *	service name			must be in /etc/services or must
70dea673e9SRodney W. Grimes  *					name a tcpmux service
71dea673e9SRodney W. Grimes  *	socket type			stream/dgram/raw/rdm/seqpacket
72dea673e9SRodney W. Grimes  *	protocol			must be in /etc/protocols
73dea673e9SRodney W. Grimes  *	wait/nowait			single-threaded/multi-threaded
74dea673e9SRodney W. Grimes  *	user				user to run daemon as
75dea673e9SRodney W. Grimes  *	server program			full path name
76dea673e9SRodney W. Grimes  *	server program arguments	maximum of MAXARGS (20)
77dea673e9SRodney W. Grimes  *
78dea673e9SRodney W. Grimes  * TCP services without official port numbers are handled with the
79dea673e9SRodney W. Grimes  * RFC1078-based tcpmux internal service. Tcpmux listens on port 1 for
80dea673e9SRodney W. Grimes  * requests. When a connection is made from a foreign host, the service
81dea673e9SRodney W. Grimes  * requested is passed to tcpmux, which looks it up in the servtab list
82dea673e9SRodney W. Grimes  * and returns the proper entry for the service. Tcpmux returns a
83dea673e9SRodney W. Grimes  * negative reply if the service doesn't exist, otherwise the invoked
84dea673e9SRodney W. Grimes  * server is expected to return the positive reply if the service type in
85dea673e9SRodney W. Grimes  * inetd.conf file has the prefix "tcpmux/". If the service type has the
86dea673e9SRodney W. Grimes  * prefix "tcpmux/+", tcpmux will return the positive reply for the
87dea673e9SRodney W. Grimes  * process; this is for compatibility with older server code, and also
88dea673e9SRodney W. Grimes  * allows you to invoke programs that use stdin/stdout without putting any
89dea673e9SRodney W. Grimes  * special server code in them. Services that use tcpmux are "nowait"
90dea673e9SRodney W. Grimes  * because they do not have a well-known port and hence cannot listen
91dea673e9SRodney W. Grimes  * for new requests.
92dea673e9SRodney W. Grimes  *
9355b91f3aSGeoff Rehmet  * For RPC services
9455b91f3aSGeoff Rehmet  *	service name/version		must be in /etc/rpc
9555b91f3aSGeoff Rehmet  *	socket type			stream/dgram/raw/rdm/seqpacket
9655b91f3aSGeoff Rehmet  *	protocol			must be in /etc/protocols
9755b91f3aSGeoff Rehmet  *	wait/nowait			single-threaded/multi-threaded
9855b91f3aSGeoff Rehmet  *	user				user to run daemon as
9955b91f3aSGeoff Rehmet  *	server program			full path name
10055b91f3aSGeoff Rehmet  *	server program arguments	maximum of MAXARGS
10155b91f3aSGeoff Rehmet  *
102dea673e9SRodney W. Grimes  * Comment lines are indicated by a `#' in column 1.
103dea673e9SRodney W. Grimes  */
104dea673e9SRodney W. Grimes #include <sys/param.h>
105dea673e9SRodney W. Grimes #include <sys/stat.h>
106dea673e9SRodney W. Grimes #include <sys/ioctl.h>
107dea673e9SRodney W. Grimes #include <sys/socket.h>
108dea673e9SRodney W. Grimes #include <sys/wait.h>
109dea673e9SRodney W. Grimes #include <sys/time.h>
110dea673e9SRodney W. Grimes #include <sys/resource.h>
111dea673e9SRodney W. Grimes 
112dea673e9SRodney W. Grimes #include <netinet/in.h>
113dea673e9SRodney W. Grimes #include <arpa/inet.h>
11455b91f3aSGeoff Rehmet #include <rpc/rpc.h>
115dea673e9SRodney W. Grimes 
116dea673e9SRodney W. Grimes #include <errno.h>
117dea673e9SRodney W. Grimes #include <fcntl.h>
118dea673e9SRodney W. Grimes #include <netdb.h>
119dea673e9SRodney W. Grimes #include <pwd.h>
120dea673e9SRodney W. Grimes #include <signal.h>
121dea673e9SRodney W. Grimes #include <stdio.h>
122dea673e9SRodney W. Grimes #include <stdlib.h>
123dea673e9SRodney W. Grimes #include <string.h>
124dea673e9SRodney W. Grimes #include <syslog.h>
125dea673e9SRodney W. Grimes #include <unistd.h>
126dea673e9SRodney W. Grimes 
127dea673e9SRodney W. Grimes #include "pathnames.h"
128dea673e9SRodney W. Grimes 
129bee39b42SGeoff Rehmet #define	TOOMANY		256		/* don't start more than TOOMANY */
130dea673e9SRodney W. Grimes #define	CNT_INTVL	60		/* servers in CNT_INTVL sec. */
131dea673e9SRodney W. Grimes #define	RETRYTIME	(60*10)		/* retry after bind or server fail */
132dea673e9SRodney W. Grimes 
133dea673e9SRodney W. Grimes #define	SIGBLOCK	(sigmask(SIGCHLD)|sigmask(SIGHUP)|sigmask(SIGALRM))
134dea673e9SRodney W. Grimes 
135dea673e9SRodney W. Grimes 
136dea673e9SRodney W. Grimes int	debug = 0;
137bee39b42SGeoff Rehmet int	log = 0;
138dea673e9SRodney W. Grimes int	nsock, maxsock;
139dea673e9SRodney W. Grimes fd_set	allsock;
140dea673e9SRodney W. Grimes int	options;
141dea673e9SRodney W. Grimes int	timingout;
142dea673e9SRodney W. Grimes int	toomany = TOOMANY;
143dea673e9SRodney W. Grimes struct	servent *sp;
14455b91f3aSGeoff Rehmet struct	rpcent *rpc;
145dea673e9SRodney W. Grimes 
146dea673e9SRodney W. Grimes struct	servtab {
147dea673e9SRodney W. Grimes 	char	*se_service;		/* name of service */
148dea673e9SRodney W. Grimes 	int	se_socktype;		/* type of socket to use */
149dea673e9SRodney W. Grimes 	char	*se_proto;		/* protocol used */
150dea673e9SRodney W. Grimes 	short	se_wait;		/* single threaded server */
151dea673e9SRodney W. Grimes 	short	se_checked;		/* looked at during merge */
152dea673e9SRodney W. Grimes 	char	*se_user;		/* user name to run as */
153dea673e9SRodney W. Grimes 	struct	biltin *se_bi;		/* if built-in, description */
154dea673e9SRodney W. Grimes 	char	*se_server;		/* server program */
155dea673e9SRodney W. Grimes #define	MAXARGV 20
156dea673e9SRodney W. Grimes 	char	*se_argv[MAXARGV+1];	/* program arguments */
157dea673e9SRodney W. Grimes 	int	se_fd;			/* open descriptor */
158dea673e9SRodney W. Grimes 	int	se_type;		/* type */
159dea673e9SRodney W. Grimes 	struct	sockaddr_in se_ctrladdr;/* bound address */
16055b91f3aSGeoff Rehmet 	int	se_rpc;			/* ==1 if RPC service */
16155b91f3aSGeoff Rehmet 	int	se_rpc_prog;		/* RPC program number */
16255b91f3aSGeoff Rehmet 	u_int	se_rpc_lowvers;		/* RPC low version */
16355b91f3aSGeoff Rehmet 	u_int	se_rpc_highvers;	/* RPC high version */
164dea673e9SRodney W. Grimes 	int	se_count;		/* number started since se_time */
165dea673e9SRodney W. Grimes 	struct	timeval se_time;	/* start of se_count */
166dea673e9SRodney W. Grimes 	struct	servtab *se_next;
167dea673e9SRodney W. Grimes } *servtab;
168dea673e9SRodney W. Grimes 
169dea673e9SRodney W. Grimes #define NORM_TYPE	0
170dea673e9SRodney W. Grimes #define MUX_TYPE	1
171dea673e9SRodney W. Grimes #define MUXPLUS_TYPE	2
172dea673e9SRodney W. Grimes #define ISMUX(sep)	(((sep)->se_type == MUX_TYPE) || \
173dea673e9SRodney W. Grimes 			 ((sep)->se_type == MUXPLUS_TYPE))
174dea673e9SRodney W. Grimes #define ISMUXPLUS(sep)	((sep)->se_type == MUXPLUS_TYPE)
175dea673e9SRodney W. Grimes 
176dea673e9SRodney W. Grimes 
177dea673e9SRodney W. Grimes void		chargen_dg __P((int, struct servtab *));
178dea673e9SRodney W. Grimes void		chargen_stream __P((int, struct servtab *));
179dea673e9SRodney W. Grimes void		close_sep __P((struct servtab *));
180dea673e9SRodney W. Grimes void		config __P((int));
181dea673e9SRodney W. Grimes void		daytime_dg __P((int, struct servtab *));
182dea673e9SRodney W. Grimes void		daytime_stream __P((int, struct servtab *));
183dea673e9SRodney W. Grimes void		discard_dg __P((int, struct servtab *));
184dea673e9SRodney W. Grimes void		discard_stream __P((int, struct servtab *));
185dea673e9SRodney W. Grimes void		echo_dg __P((int, struct servtab *));
186dea673e9SRodney W. Grimes void		echo_stream __P((int, struct servtab *));
187dea673e9SRodney W. Grimes void		endconfig __P((void));
188dea673e9SRodney W. Grimes struct servtab *enter __P((struct servtab *));
189dea673e9SRodney W. Grimes void		freeconfig __P((struct servtab *));
190dea673e9SRodney W. Grimes struct servtab *getconfigent __P((void));
191dea673e9SRodney W. Grimes void		machtime_dg __P((int, struct servtab *));
192dea673e9SRodney W. Grimes void		machtime_stream __P((int, struct servtab *));
193dea673e9SRodney W. Grimes char	       *newstr __P((char *));
194dea673e9SRodney W. Grimes char	       *nextline __P((FILE *));
195dea673e9SRodney W. Grimes void		print_service __P((char *, struct servtab *));
196dea673e9SRodney W. Grimes void		reapchild __P((int));
197dea673e9SRodney W. Grimes void		retry __P((int));
198dea673e9SRodney W. Grimes int		setconfig __P((void));
199dea673e9SRodney W. Grimes void		setup __P((struct servtab *));
200dea673e9SRodney W. Grimes char	       *sskip __P((char **));
201dea673e9SRodney W. Grimes char	       *skip __P((char **));
202dea673e9SRodney W. Grimes struct servtab *tcpmux __P((int));
203dea673e9SRodney W. Grimes 
20455b91f3aSGeoff Rehmet void		unregisterrpc __P((register struct servtab *sep));
20555b91f3aSGeoff Rehmet 
206dea673e9SRodney W. Grimes struct biltin {
207dea673e9SRodney W. Grimes 	char	*bi_service;		/* internally provided service name */
208dea673e9SRodney W. Grimes 	int	bi_socktype;		/* type of socket supported */
209dea673e9SRodney W. Grimes 	short	bi_fork;		/* 1 if should fork before call */
210dea673e9SRodney W. Grimes 	short	bi_wait;		/* 1 if should wait for child */
211dea673e9SRodney W. Grimes 	void	(*bi_fn)();		/* function which performs it */
212dea673e9SRodney W. Grimes } biltins[] = {
213dea673e9SRodney W. Grimes 	/* Echo received data */
214dea673e9SRodney W. Grimes 	{ "echo",	SOCK_STREAM,	1, 0,	echo_stream },
215dea673e9SRodney W. Grimes 	{ "echo",	SOCK_DGRAM,	0, 0,	echo_dg },
216dea673e9SRodney W. Grimes 
217dea673e9SRodney W. Grimes 	/* Internet /dev/null */
218dea673e9SRodney W. Grimes 	{ "discard",	SOCK_STREAM,	1, 0,	discard_stream },
219dea673e9SRodney W. Grimes 	{ "discard",	SOCK_DGRAM,	0, 0,	discard_dg },
220dea673e9SRodney W. Grimes 
221dea673e9SRodney W. Grimes 	/* Return 32 bit time since 1970 */
222dea673e9SRodney W. Grimes 	{ "time",	SOCK_STREAM,	0, 0,	machtime_stream },
223dea673e9SRodney W. Grimes 	{ "time",	SOCK_DGRAM,	0, 0,	machtime_dg },
224dea673e9SRodney W. Grimes 
225dea673e9SRodney W. Grimes 	/* Return human-readable time */
226dea673e9SRodney W. Grimes 	{ "daytime",	SOCK_STREAM,	0, 0,	daytime_stream },
227dea673e9SRodney W. Grimes 	{ "daytime",	SOCK_DGRAM,	0, 0,	daytime_dg },
228dea673e9SRodney W. Grimes 
229dea673e9SRodney W. Grimes 	/* Familiar character generator */
230dea673e9SRodney W. Grimes 	{ "chargen",	SOCK_STREAM,	1, 0,	chargen_stream },
231dea673e9SRodney W. Grimes 	{ "chargen",	SOCK_DGRAM,	0, 0,	chargen_dg },
232dea673e9SRodney W. Grimes 
233dea673e9SRodney W. Grimes 	{ "tcpmux",	SOCK_STREAM,	1, 0,	(void (*)())tcpmux },
234dea673e9SRodney W. Grimes 
235dea673e9SRodney W. Grimes 	{ NULL }
236dea673e9SRodney W. Grimes };
237dea673e9SRodney W. Grimes 
238dea673e9SRodney W. Grimes #define NUMINT	(sizeof(intab) / sizeof(struct inent))
239dea673e9SRodney W. Grimes char	*CONFIG = _PATH_INETDCONF;
240dea673e9SRodney W. Grimes char	**Argv;
241dea673e9SRodney W. Grimes char 	*LastArg;
242dea673e9SRodney W. Grimes 
243dea673e9SRodney W. Grimes int
244dea673e9SRodney W. Grimes main(argc, argv, envp)
245dea673e9SRodney W. Grimes 	int argc;
246dea673e9SRodney W. Grimes 	char *argv[], *envp[];
247dea673e9SRodney W. Grimes {
248dea673e9SRodney W. Grimes 	struct servtab *sep;
249dea673e9SRodney W. Grimes 	struct passwd *pwd;
250dea673e9SRodney W. Grimes 	struct sigvec sv;
251dea673e9SRodney W. Grimes 	int tmpint, ch, dofork;
252dea673e9SRodney W. Grimes 	pid_t pid;
253dea673e9SRodney W. Grimes 	char buf[50];
254bee39b42SGeoff Rehmet 	struct  sockaddr_in peer;
255bee39b42SGeoff Rehmet 	int i;
256dea673e9SRodney W. Grimes 
257dea673e9SRodney W. Grimes 	Argv = argv;
258dea673e9SRodney W. Grimes 	if (envp == 0 || *envp == 0)
259dea673e9SRodney W. Grimes 		envp = argv;
260dea673e9SRodney W. Grimes 	while (*envp)
261dea673e9SRodney W. Grimes 		envp++;
262dea673e9SRodney W. Grimes 	LastArg = envp[-1] + strlen(envp[-1]);
263dea673e9SRodney W. Grimes 
264dea673e9SRodney W. Grimes 	openlog("inetd", LOG_PID | LOG_NOWAIT, LOG_DAEMON);
265dea673e9SRodney W. Grimes 
266bee39b42SGeoff Rehmet 	while ((ch = getopt(argc, argv, "dlR:")) != EOF)
267dea673e9SRodney W. Grimes 		switch(ch) {
268dea673e9SRodney W. Grimes 		case 'd':
269dea673e9SRodney W. Grimes 			debug = 1;
270dea673e9SRodney W. Grimes 			options |= SO_DEBUG;
271dea673e9SRodney W. Grimes 			break;
272bee39b42SGeoff Rehmet 		case 'l':
273bee39b42SGeoff Rehmet 			log = 1;
274bee39b42SGeoff Rehmet 			break;
275dea673e9SRodney W. Grimes 		case 'R': {	/* invocation rate */
276dea673e9SRodney W. Grimes 			char *p;
277dea673e9SRodney W. Grimes 
278dea673e9SRodney W. Grimes 			tmpint = strtol(optarg, &p, 0);
279dea673e9SRodney W. Grimes 			if (tmpint < 1 || *p)
280dea673e9SRodney W. Grimes 				syslog(LOG_ERR,
281dea673e9SRodney W. Grimes 			         "-R %s: bad value for service invocation rate",
282dea673e9SRodney W. Grimes 					optarg);
283dea673e9SRodney W. Grimes 			else
284dea673e9SRodney W. Grimes 				toomany = tmpint;
285dea673e9SRodney W. Grimes 			break;
286dea673e9SRodney W. Grimes 		}
287dea673e9SRodney W. Grimes 		case '?':
288dea673e9SRodney W. Grimes 		default:
289dea673e9SRodney W. Grimes 			syslog(LOG_ERR,
290bee39b42SGeoff Rehmet 				"usage: inetd [-dl] [-R rate] [conf-file]");
291dea673e9SRodney W. Grimes 			exit(1);
292dea673e9SRodney W. Grimes 		}
293dea673e9SRodney W. Grimes 	argc -= optind;
294dea673e9SRodney W. Grimes 	argv += optind;
295dea673e9SRodney W. Grimes 
296dea673e9SRodney W. Grimes 	if (argc > 0)
297dea673e9SRodney W. Grimes 		CONFIG = argv[0];
298dea673e9SRodney W. Grimes 	if (debug == 0) {
299dea673e9SRodney W. Grimes 		daemon(0, 0);
300dea673e9SRodney W. Grimes 	}
301dea673e9SRodney W. Grimes 	memset(&sv, 0, sizeof(sv));
302dea673e9SRodney W. Grimes 	sv.sv_mask = SIGBLOCK;
303dea673e9SRodney W. Grimes 	sv.sv_handler = retry;
304dea673e9SRodney W. Grimes 	sigvec(SIGALRM, &sv, (struct sigvec *)0);
305dea673e9SRodney W. Grimes 	config(SIGHUP);
306dea673e9SRodney W. Grimes 	sv.sv_handler = config;
307dea673e9SRodney W. Grimes 	sigvec(SIGHUP, &sv, (struct sigvec *)0);
308dea673e9SRodney W. Grimes 	sv.sv_handler = reapchild;
309dea673e9SRodney W. Grimes 	sigvec(SIGCHLD, &sv, (struct sigvec *)0);
310dea673e9SRodney W. Grimes 
311dea673e9SRodney W. Grimes 	{
312dea673e9SRodney W. Grimes 		/* space for daemons to overwrite environment for ps */
313dea673e9SRodney W. Grimes #define	DUMMYSIZE	100
314dea673e9SRodney W. Grimes 		char dummy[DUMMYSIZE];
315dea673e9SRodney W. Grimes 
316dea673e9SRodney W. Grimes 		(void)memset(dummy, 'x', sizeof(DUMMYSIZE) - 1);
317dea673e9SRodney W. Grimes 		dummy[DUMMYSIZE - 1] = '\0';
318dea673e9SRodney W. Grimes 		(void)setenv("inetd_dummy", dummy, 1);
319dea673e9SRodney W. Grimes 	}
320dea673e9SRodney W. Grimes 
321dea673e9SRodney W. Grimes 	for (;;) {
322dea673e9SRodney W. Grimes 	    int n, ctrl;
323dea673e9SRodney W. Grimes 	    fd_set readable;
324dea673e9SRodney W. Grimes 
325dea673e9SRodney W. Grimes 	    if (nsock == 0) {
326dea673e9SRodney W. Grimes 		(void) sigblock(SIGBLOCK);
327dea673e9SRodney W. Grimes 		while (nsock == 0)
328dea673e9SRodney W. Grimes 		    sigpause(0L);
329dea673e9SRodney W. Grimes 		(void) sigsetmask(0L);
330dea673e9SRodney W. Grimes 	    }
331dea673e9SRodney W. Grimes 	    readable = allsock;
332dea673e9SRodney W. Grimes 	    if ((n = select(maxsock + 1, &readable, (fd_set *)0,
333dea673e9SRodney W. Grimes 		(fd_set *)0, (struct timeval *)0)) <= 0) {
334dea673e9SRodney W. Grimes 		    if (n < 0 && errno != EINTR)
335dea673e9SRodney W. Grimes 			syslog(LOG_WARNING, "select: %m");
336dea673e9SRodney W. Grimes 		    sleep(1);
337dea673e9SRodney W. Grimes 		    continue;
338dea673e9SRodney W. Grimes 	    }
339dea673e9SRodney W. Grimes 	    for (sep = servtab; n && sep; sep = sep->se_next)
340dea673e9SRodney W. Grimes 	        if (sep->se_fd != -1 && FD_ISSET(sep->se_fd, &readable)) {
341dea673e9SRodney W. Grimes 		    n--;
342dea673e9SRodney W. Grimes 		    if (debug)
343dea673e9SRodney W. Grimes 			    fprintf(stderr, "someone wants %s\n",
344dea673e9SRodney W. Grimes 				sep->se_service);
345dea673e9SRodney W. Grimes 		    if (!sep->se_wait && sep->se_socktype == SOCK_STREAM) {
346dea673e9SRodney W. Grimes 			    ctrl = accept(sep->se_fd, (struct sockaddr *)0,
347dea673e9SRodney W. Grimes 				(int *)0);
348dea673e9SRodney W. Grimes 			    if (debug)
349dea673e9SRodney W. Grimes 				    fprintf(stderr, "accept, ctrl %d\n", ctrl);
350dea673e9SRodney W. Grimes 			    if (ctrl < 0) {
351dea673e9SRodney W. Grimes 				    if (errno != EINTR)
352dea673e9SRodney W. Grimes 					    syslog(LOG_WARNING,
353dea673e9SRodney W. Grimes 						"accept (for %s): %m",
354dea673e9SRodney W. Grimes 						sep->se_service);
355dea673e9SRodney W. Grimes 				    continue;
356dea673e9SRodney W. Grimes 			    }
357bee39b42SGeoff Rehmet 			    if(log) {
358bee39b42SGeoff Rehmet 				i = sizeof peer;
359bee39b42SGeoff Rehmet 				if(getpeername(ctrl, (struct sockaddr *)
360bee39b42SGeoff Rehmet 						&peer, &i)) {
361bee39b42SGeoff Rehmet 					syslog(LOG_WARNING,
362bee39b42SGeoff Rehmet 						"getpeername(for %s): %m",
363bee39b42SGeoff Rehmet 						sep->se_service);
364bee39b42SGeoff Rehmet 					continue;
365bee39b42SGeoff Rehmet 				}
366bee39b42SGeoff Rehmet 				syslog(LOG_INFO,"%s from %s",
367bee39b42SGeoff Rehmet 					sep->se_service,
368bee39b42SGeoff Rehmet 					inet_ntoa(peer.sin_addr));
369bee39b42SGeoff Rehmet 			    }
370dea673e9SRodney W. Grimes 			    /*
371dea673e9SRodney W. Grimes 			     * Call tcpmux to find the real service to exec.
372dea673e9SRodney W. Grimes 			     */
373dea673e9SRodney W. Grimes 			    if (sep->se_bi &&
374dea673e9SRodney W. Grimes 				sep->se_bi->bi_fn == (void (*)()) tcpmux) {
375dea673e9SRodney W. Grimes 				    sep = tcpmux(ctrl);
376dea673e9SRodney W. Grimes 				    if (sep == NULL) {
377dea673e9SRodney W. Grimes 					    close(ctrl);
378dea673e9SRodney W. Grimes 					    continue;
379dea673e9SRodney W. Grimes 				    }
380dea673e9SRodney W. Grimes 			    }
381dea673e9SRodney W. Grimes 		    } else
382dea673e9SRodney W. Grimes 			    ctrl = sep->se_fd;
383dea673e9SRodney W. Grimes 		    (void) sigblock(SIGBLOCK);
384dea673e9SRodney W. Grimes 		    pid = 0;
385dea673e9SRodney W. Grimes 		    dofork = (sep->se_bi == 0 || sep->se_bi->bi_fork);
386dea673e9SRodney W. Grimes 		    if (dofork) {
387dea673e9SRodney W. Grimes 			    if (sep->se_count++ == 0)
388dea673e9SRodney W. Grimes 				(void)gettimeofday(&sep->se_time,
389dea673e9SRodney W. Grimes 				    (struct timezone *)0);
390dea673e9SRodney W. Grimes 			    else if (sep->se_count >= toomany) {
391dea673e9SRodney W. Grimes 				struct timeval now;
392dea673e9SRodney W. Grimes 
393dea673e9SRodney W. Grimes 				(void)gettimeofday(&now, (struct timezone *)0);
394dea673e9SRodney W. Grimes 				if (now.tv_sec - sep->se_time.tv_sec >
395dea673e9SRodney W. Grimes 				    CNT_INTVL) {
396dea673e9SRodney W. Grimes 					sep->se_time = now;
397dea673e9SRodney W. Grimes 					sep->se_count = 1;
398dea673e9SRodney W. Grimes 				} else {
399dea673e9SRodney W. Grimes 					syslog(LOG_ERR,
400dea673e9SRodney W. Grimes 			"%s/%s server failing (looping), service terminated",
401dea673e9SRodney W. Grimes 					    sep->se_service, sep->se_proto);
402dea673e9SRodney W. Grimes 					close_sep(sep);
403dea673e9SRodney W. Grimes 					sigsetmask(0L);
404dea673e9SRodney W. Grimes 					if (!timingout) {
405dea673e9SRodney W. Grimes 						timingout = 1;
406dea673e9SRodney W. Grimes 						alarm(RETRYTIME);
407dea673e9SRodney W. Grimes 					}
408dea673e9SRodney W. Grimes 					continue;
409dea673e9SRodney W. Grimes 				}
410dea673e9SRodney W. Grimes 			    }
411dea673e9SRodney W. Grimes 			    pid = fork();
412dea673e9SRodney W. Grimes 		    }
413dea673e9SRodney W. Grimes 		    if (pid < 0) {
414dea673e9SRodney W. Grimes 			    syslog(LOG_ERR, "fork: %m");
415dea673e9SRodney W. Grimes 			    if (!sep->se_wait &&
416dea673e9SRodney W. Grimes 				sep->se_socktype == SOCK_STREAM)
417dea673e9SRodney W. Grimes 				    close(ctrl);
418dea673e9SRodney W. Grimes 			    sigsetmask(0L);
419dea673e9SRodney W. Grimes 			    sleep(1);
420dea673e9SRodney W. Grimes 			    continue;
421dea673e9SRodney W. Grimes 		    }
422dea673e9SRodney W. Grimes 		    if (pid && sep->se_wait) {
423dea673e9SRodney W. Grimes 			    sep->se_wait = pid;
424dea673e9SRodney W. Grimes 			    if (sep->se_fd >= 0) {
425dea673e9SRodney W. Grimes 				FD_CLR(sep->se_fd, &allsock);
426dea673e9SRodney W. Grimes 			        nsock--;
427dea673e9SRodney W. Grimes 			    }
428dea673e9SRodney W. Grimes 		    }
429dea673e9SRodney W. Grimes 		    sigsetmask(0L);
430dea673e9SRodney W. Grimes 		    if (pid == 0) {
431dea673e9SRodney W. Grimes 			    if (debug && dofork)
432dea673e9SRodney W. Grimes 				setsid();
433dea673e9SRodney W. Grimes 			    if (dofork) {
434dea673e9SRodney W. Grimes 				if (debug)
435dea673e9SRodney W. Grimes 					fprintf(stderr, "+ Closing from %d\n",
436dea673e9SRodney W. Grimes 						maxsock);
437dea673e9SRodney W. Grimes 				for (tmpint = maxsock; tmpint > 2; tmpint--)
438dea673e9SRodney W. Grimes 					if (tmpint != ctrl)
439dea673e9SRodney W. Grimes 						close(tmpint);
440dea673e9SRodney W. Grimes 			    }
441dea673e9SRodney W. Grimes 			    if (sep->se_bi)
442dea673e9SRodney W. Grimes 				(*sep->se_bi->bi_fn)(ctrl, sep);
443dea673e9SRodney W. Grimes 			    else {
444dea673e9SRodney W. Grimes 				if (debug)
445dea673e9SRodney W. Grimes 					fprintf(stderr, "%d execl %s\n",
446dea673e9SRodney W. Grimes 					    getpid(), sep->se_server);
447dea673e9SRodney W. Grimes 				dup2(ctrl, 0);
448dea673e9SRodney W. Grimes 				close(ctrl);
449dea673e9SRodney W. Grimes 				dup2(0, 1);
450dea673e9SRodney W. Grimes 				dup2(0, 2);
451dea673e9SRodney W. Grimes 				if ((pwd = getpwnam(sep->se_user)) == NULL) {
452dea673e9SRodney W. Grimes 					syslog(LOG_ERR,
453dea673e9SRodney W. Grimes 					    "%s/%s: %s: No such user",
454dea673e9SRodney W. Grimes 						sep->se_service, sep->se_proto,
455dea673e9SRodney W. Grimes 						sep->se_user);
456dea673e9SRodney W. Grimes 					if (sep->se_socktype != SOCK_STREAM)
457dea673e9SRodney W. Grimes 						recv(0, buf, sizeof (buf), 0);
458dea673e9SRodney W. Grimes 					_exit(1);
459dea673e9SRodney W. Grimes 				}
460dea673e9SRodney W. Grimes 				if (pwd->pw_uid) {
461dea673e9SRodney W. Grimes 					if (setgid(pwd->pw_gid) < 0) {
462dea673e9SRodney W. Grimes 						syslog(LOG_ERR,
463dea673e9SRodney W. Grimes 						  "%s: can't set gid %d: %m",
464dea673e9SRodney W. Grimes 						  sep->se_service, pwd->pw_gid);
465dea673e9SRodney W. Grimes 						_exit(1);
466dea673e9SRodney W. Grimes 					}
467dea673e9SRodney W. Grimes 					(void) initgroups(pwd->pw_name,
468dea673e9SRodney W. Grimes 							pwd->pw_gid);
469dea673e9SRodney W. Grimes 					if (setuid(pwd->pw_uid) < 0) {
470dea673e9SRodney W. Grimes 						syslog(LOG_ERR,
471dea673e9SRodney W. Grimes 						  "%s: can't set uid %d: %m",
472dea673e9SRodney W. Grimes 						  sep->se_service, pwd->pw_uid);
473dea673e9SRodney W. Grimes 						_exit(1);
474dea673e9SRodney W. Grimes 					}
475dea673e9SRodney W. Grimes 				}
476dea673e9SRodney W. Grimes 				execv(sep->se_server, sep->se_argv);
477dea673e9SRodney W. Grimes 				if (sep->se_socktype != SOCK_STREAM)
478dea673e9SRodney W. Grimes 					recv(0, buf, sizeof (buf), 0);
479dea673e9SRodney W. Grimes 				syslog(LOG_ERR,
480dea673e9SRodney W. Grimes 				    "cannot execute %s: %m", sep->se_server);
481dea673e9SRodney W. Grimes 				_exit(1);
482dea673e9SRodney W. Grimes 			    }
483dea673e9SRodney W. Grimes 		    }
484dea673e9SRodney W. Grimes 		    if (!sep->se_wait && sep->se_socktype == SOCK_STREAM)
485dea673e9SRodney W. Grimes 			    close(ctrl);
486dea673e9SRodney W. Grimes 		}
487dea673e9SRodney W. Grimes 	}
488dea673e9SRodney W. Grimes }
489dea673e9SRodney W. Grimes 
490dea673e9SRodney W. Grimes void
491dea673e9SRodney W. Grimes reapchild(signo)
492dea673e9SRodney W. Grimes 	int signo;
493dea673e9SRodney W. Grimes {
494dea673e9SRodney W. Grimes 	int status;
495dea673e9SRodney W. Grimes 	pid_t pid;
496dea673e9SRodney W. Grimes 	struct servtab *sep;
497dea673e9SRodney W. Grimes 
498dea673e9SRodney W. Grimes 	for (;;) {
499dea673e9SRodney W. Grimes 		pid = wait3(&status, WNOHANG, (struct rusage *)0);
500dea673e9SRodney W. Grimes 		if (pid <= 0)
501dea673e9SRodney W. Grimes 			break;
502dea673e9SRodney W. Grimes 		if (debug)
503dea673e9SRodney W. Grimes 			fprintf(stderr, "%d reaped, status %#x\n",
504dea673e9SRodney W. Grimes 				pid, status);
505dea673e9SRodney W. Grimes 		for (sep = servtab; sep; sep = sep->se_next)
506dea673e9SRodney W. Grimes 			if (sep->se_wait == pid) {
507dea673e9SRodney W. Grimes 				if (status)
508dea673e9SRodney W. Grimes 					syslog(LOG_WARNING,
509dea673e9SRodney W. Grimes 					    "%s: exit status 0x%x",
510dea673e9SRodney W. Grimes 					    sep->se_server, status);
511dea673e9SRodney W. Grimes 				if (debug)
512dea673e9SRodney W. Grimes 					fprintf(stderr, "restored %s, fd %d\n",
513dea673e9SRodney W. Grimes 					    sep->se_service, sep->se_fd);
514dea673e9SRodney W. Grimes 				FD_SET(sep->se_fd, &allsock);
515dea673e9SRodney W. Grimes 				nsock++;
516dea673e9SRodney W. Grimes 				sep->se_wait = 1;
517dea673e9SRodney W. Grimes 			}
518dea673e9SRodney W. Grimes 	}
519dea673e9SRodney W. Grimes }
520dea673e9SRodney W. Grimes 
521dea673e9SRodney W. Grimes void
522dea673e9SRodney W. Grimes config(signo)
523dea673e9SRodney W. Grimes 	int signo;
524dea673e9SRodney W. Grimes {
525dea673e9SRodney W. Grimes 	struct servtab *sep, *cp, **sepp;
526dea673e9SRodney W. Grimes 	struct passwd *pwd;
527dea673e9SRodney W. Grimes 	long omask;
528dea673e9SRodney W. Grimes 
529dea673e9SRodney W. Grimes 	if (!setconfig()) {
530dea673e9SRodney W. Grimes 		syslog(LOG_ERR, "%s: %m", CONFIG);
531dea673e9SRodney W. Grimes 		return;
532dea673e9SRodney W. Grimes 	}
533dea673e9SRodney W. Grimes 	for (sep = servtab; sep; sep = sep->se_next)
534dea673e9SRodney W. Grimes 		sep->se_checked = 0;
535dea673e9SRodney W. Grimes 	while (cp = getconfigent()) {
536dea673e9SRodney W. Grimes 		if ((pwd = getpwnam(cp->se_user)) == NULL) {
537dea673e9SRodney W. Grimes 			syslog(LOG_ERR,
538dea673e9SRodney W. Grimes 				"%s/%s: No such user '%s', service ignored",
539dea673e9SRodney W. Grimes 				cp->se_service, cp->se_proto, cp->se_user);
540dea673e9SRodney W. Grimes 			continue;
541dea673e9SRodney W. Grimes 		}
542dea673e9SRodney W. Grimes 		for (sep = servtab; sep; sep = sep->se_next)
543dea673e9SRodney W. Grimes 			if (strcmp(sep->se_service, cp->se_service) == 0 &&
544dea673e9SRodney W. Grimes 			    strcmp(sep->se_proto, cp->se_proto) == 0)
545dea673e9SRodney W. Grimes 				break;
546dea673e9SRodney W. Grimes 		if (sep != 0) {
547dea673e9SRodney W. Grimes 			int i;
548dea673e9SRodney W. Grimes 
549dea673e9SRodney W. Grimes 			omask = sigblock(SIGBLOCK);
550dea673e9SRodney W. Grimes 			/*
551dea673e9SRodney W. Grimes 			 * sep->se_wait may be holding the pid of a daemon
552dea673e9SRodney W. Grimes 			 * that we're waiting for.  If so, don't overwrite
553dea673e9SRodney W. Grimes 			 * it unless the config file explicitly says don't
554dea673e9SRodney W. Grimes 			 * wait.
555dea673e9SRodney W. Grimes 			 */
556dea673e9SRodney W. Grimes 			if (cp->se_bi == 0 &&
557dea673e9SRodney W. Grimes 			    (sep->se_wait == 1 || cp->se_wait == 0))
558dea673e9SRodney W. Grimes 				sep->se_wait = cp->se_wait;
559dea673e9SRodney W. Grimes #define SWAP(a, b) { char *c = a; a = b; b = c; }
560dea673e9SRodney W. Grimes 			if (cp->se_user)
561dea673e9SRodney W. Grimes 				SWAP(sep->se_user, cp->se_user);
562dea673e9SRodney W. Grimes 			if (cp->se_server)
563dea673e9SRodney W. Grimes 				SWAP(sep->se_server, cp->se_server);
564dea673e9SRodney W. Grimes 			for (i = 0; i < MAXARGV; i++)
565dea673e9SRodney W. Grimes 				SWAP(sep->se_argv[i], cp->se_argv[i]);
566dea673e9SRodney W. Grimes 			sigsetmask(omask);
567dea673e9SRodney W. Grimes 			freeconfig(cp);
568dea673e9SRodney W. Grimes 			if (debug)
569dea673e9SRodney W. Grimes 				print_service("REDO", sep);
570dea673e9SRodney W. Grimes 		} else {
571dea673e9SRodney W. Grimes 			sep = enter(cp);
572dea673e9SRodney W. Grimes 			if (debug)
573dea673e9SRodney W. Grimes 				print_service("ADD ", sep);
574dea673e9SRodney W. Grimes 		}
575dea673e9SRodney W. Grimes 		sep->se_checked = 1;
576dea673e9SRodney W. Grimes 		if (ISMUX(sep)) {
577dea673e9SRodney W. Grimes 			sep->se_fd = -1;
578dea673e9SRodney W. Grimes 			continue;
579dea673e9SRodney W. Grimes 		}
58055b91f3aSGeoff Rehmet 		if (!sep->se_rpc) {
581dea673e9SRodney W. Grimes 			sp = getservbyname(sep->se_service, sep->se_proto);
582dea673e9SRodney W. Grimes 			if (sp == 0) {
583dea673e9SRodney W. Grimes 				syslog(LOG_ERR, "%s/%s: unknown service",
584dea673e9SRodney W. Grimes 			    	sep->se_service, sep->se_proto);
585dea673e9SRodney W. Grimes 				sep->se_checked = 0;
586dea673e9SRodney W. Grimes 				continue;
587dea673e9SRodney W. Grimes 			}
588dea673e9SRodney W. Grimes 			if (sp->s_port != sep->se_ctrladdr.sin_port) {
589dea673e9SRodney W. Grimes 				sep->se_ctrladdr.sin_family = AF_INET;
590dea673e9SRodney W. Grimes 				sep->se_ctrladdr.sin_port = sp->s_port;
591dea673e9SRodney W. Grimes 				if (sep->se_fd >= 0)
592dea673e9SRodney W. Grimes 					close_sep(sep);
593dea673e9SRodney W. Grimes 			}
59455b91f3aSGeoff Rehmet 		} else {
59555b91f3aSGeoff Rehmet 			rpc = getrpcbyname(sep->se_service);
59655b91f3aSGeoff Rehmet 			if (rpc == 0) {
59755b91f3aSGeoff Rehmet 				syslog(LOG_ERR, "%s/%s unknown RPC service.",
59855b91f3aSGeoff Rehmet 					sep->se_service, sep->se_proto);
59955b91f3aSGeoff Rehmet 				if (sep->se_fd != -1)
60055b91f3aSGeoff Rehmet 					(void) close(sep->se_fd);
60155b91f3aSGeoff Rehmet 				sep->se_fd = -1;
60255b91f3aSGeoff Rehmet 					continue;
60355b91f3aSGeoff Rehmet 			}
60455b91f3aSGeoff Rehmet 			if (rpc->r_number != sep->se_rpc_prog) {
60555b91f3aSGeoff Rehmet 				if (sep->se_rpc_prog)
60655b91f3aSGeoff Rehmet 					unregisterrpc(sep);
60755b91f3aSGeoff Rehmet 				sep->se_rpc_prog = rpc->r_number;
60855b91f3aSGeoff Rehmet 				if (sep->se_fd != -1)
60955b91f3aSGeoff Rehmet 					(void) close(sep->se_fd);
61055b91f3aSGeoff Rehmet 				sep->se_fd = -1;
61155b91f3aSGeoff Rehmet 			}
61255b91f3aSGeoff Rehmet 		}
613dea673e9SRodney W. Grimes 		if (sep->se_fd == -1)
614dea673e9SRodney W. Grimes 			setup(sep);
615dea673e9SRodney W. Grimes 	}
616dea673e9SRodney W. Grimes 	endconfig();
617dea673e9SRodney W. Grimes 	/*
618dea673e9SRodney W. Grimes 	 * Purge anything not looked at above.
619dea673e9SRodney W. Grimes 	 */
620dea673e9SRodney W. Grimes 	omask = sigblock(SIGBLOCK);
621dea673e9SRodney W. Grimes 	sepp = &servtab;
622dea673e9SRodney W. Grimes 	while (sep = *sepp) {
623dea673e9SRodney W. Grimes 		if (sep->se_checked) {
624dea673e9SRodney W. Grimes 			sepp = &sep->se_next;
625dea673e9SRodney W. Grimes 			continue;
626dea673e9SRodney W. Grimes 		}
627dea673e9SRodney W. Grimes 		*sepp = sep->se_next;
628dea673e9SRodney W. Grimes 		if (sep->se_fd >= 0)
629dea673e9SRodney W. Grimes 			close_sep(sep);
630dea673e9SRodney W. Grimes 		if (debug)
631dea673e9SRodney W. Grimes 			print_service("FREE", sep);
63255b91f3aSGeoff Rehmet 		if (sep->se_rpc && sep->se_rpc_prog > 0)
63355b91f3aSGeoff Rehmet 			unregisterrpc(sep);
634dea673e9SRodney W. Grimes 		freeconfig(sep);
635dea673e9SRodney W. Grimes 		free((char *)sep);
636dea673e9SRodney W. Grimes 	}
637dea673e9SRodney W. Grimes 	(void) sigsetmask(omask);
638dea673e9SRodney W. Grimes }
639dea673e9SRodney W. Grimes 
640dea673e9SRodney W. Grimes void
64155b91f3aSGeoff Rehmet unregisterrpc(sep)
64255b91f3aSGeoff Rehmet 	struct servtab *sep;
64355b91f3aSGeoff Rehmet {
64455b91f3aSGeoff Rehmet         int i;
64555b91f3aSGeoff Rehmet         struct servtab *sepp;
64655b91f3aSGeoff Rehmet 	long omask;
64755b91f3aSGeoff Rehmet 
64855b91f3aSGeoff Rehmet 	omask = sigblock(SIGBLOCK);
64955b91f3aSGeoff Rehmet         for (sepp = servtab; sepp; sepp = sepp->se_next) {
65055b91f3aSGeoff Rehmet                 if (sepp == sep)
65155b91f3aSGeoff Rehmet                         continue;
65255b91f3aSGeoff Rehmet 		if (sep->se_checked == 0 ||
65355b91f3aSGeoff Rehmet                     !sepp->se_rpc ||
65455b91f3aSGeoff Rehmet                     sep->se_rpc_prog != sepp->se_rpc_prog)
65555b91f3aSGeoff Rehmet 			continue;
65655b91f3aSGeoff Rehmet                 return;
65755b91f3aSGeoff Rehmet         }
65855b91f3aSGeoff Rehmet         if (debug)
65955b91f3aSGeoff Rehmet                 print_service("UNREG", sep);
66055b91f3aSGeoff Rehmet         for (i = sep->se_rpc_lowvers; i <= sep->se_rpc_highvers; i++)
66155b91f3aSGeoff Rehmet                 pmap_unset(sep->se_rpc_prog, i);
66255b91f3aSGeoff Rehmet         if (sep->se_fd != -1)
66355b91f3aSGeoff Rehmet                 (void) close(sep->se_fd);
66455b91f3aSGeoff Rehmet         sep->se_fd = -1;
66555b91f3aSGeoff Rehmet 	(void) sigsetmask(omask);
66655b91f3aSGeoff Rehmet }
66755b91f3aSGeoff Rehmet 
66855b91f3aSGeoff Rehmet void
669dea673e9SRodney W. Grimes retry(signo)
670dea673e9SRodney W. Grimes 	int signo;
671dea673e9SRodney W. Grimes {
672dea673e9SRodney W. Grimes 	struct servtab *sep;
673dea673e9SRodney W. Grimes 
674dea673e9SRodney W. Grimes 	timingout = 0;
675dea673e9SRodney W. Grimes 	for (sep = servtab; sep; sep = sep->se_next)
676dea673e9SRodney W. Grimes 		if (sep->se_fd == -1)
677dea673e9SRodney W. Grimes 			setup(sep);
678dea673e9SRodney W. Grimes }
679dea673e9SRodney W. Grimes 
680dea673e9SRodney W. Grimes void
681dea673e9SRodney W. Grimes setup(sep)
682dea673e9SRodney W. Grimes 	struct servtab *sep;
683dea673e9SRodney W. Grimes {
684dea673e9SRodney W. Grimes 	int on = 1;
685dea673e9SRodney W. Grimes 
686dea673e9SRodney W. Grimes 	if ((sep->se_fd = socket(AF_INET, sep->se_socktype, 0)) < 0) {
687dea673e9SRodney W. Grimes 		if (debug)
688dea673e9SRodney W. Grimes 			fprintf(stderr, "socket failed on %s/%s: %s\n",
689dea673e9SRodney W. Grimes 				sep->se_service, sep->se_proto,
690dea673e9SRodney W. Grimes 				strerror(errno));
691dea673e9SRodney W. Grimes 		syslog(LOG_ERR, "%s/%s: socket: %m",
692dea673e9SRodney W. Grimes 		    sep->se_service, sep->se_proto);
693dea673e9SRodney W. Grimes 		return;
694dea673e9SRodney W. Grimes 	}
695dea673e9SRodney W. Grimes #define	turnon(fd, opt) \
696dea673e9SRodney W. Grimes setsockopt(fd, SOL_SOCKET, opt, (char *)&on, sizeof (on))
697dea673e9SRodney W. Grimes 	if (strcmp(sep->se_proto, "tcp") == 0 && (options & SO_DEBUG) &&
698dea673e9SRodney W. Grimes 	    turnon(sep->se_fd, SO_DEBUG) < 0)
699dea673e9SRodney W. Grimes 		syslog(LOG_ERR, "setsockopt (SO_DEBUG): %m");
700dea673e9SRodney W. Grimes 	if (turnon(sep->se_fd, SO_REUSEADDR) < 0)
701dea673e9SRodney W. Grimes 		syslog(LOG_ERR, "setsockopt (SO_REUSEADDR): %m");
702dea673e9SRodney W. Grimes #undef turnon
703dea673e9SRodney W. Grimes 	if (bind(sep->se_fd, (struct sockaddr *)&sep->se_ctrladdr,
704dea673e9SRodney W. Grimes 	    sizeof (sep->se_ctrladdr)) < 0) {
705dea673e9SRodney W. Grimes 		if (debug)
706dea673e9SRodney W. Grimes 			fprintf(stderr, "bind failed on %s/%s: %s\n",
707dea673e9SRodney W. Grimes 				sep->se_service, sep->se_proto,
708dea673e9SRodney W. Grimes 				strerror(errno));
709dea673e9SRodney W. Grimes 		syslog(LOG_ERR, "%s/%s: bind: %m",
710dea673e9SRodney W. Grimes 		    sep->se_service, sep->se_proto);
711dea673e9SRodney W. Grimes 		(void) close(sep->se_fd);
712dea673e9SRodney W. Grimes 		sep->se_fd = -1;
713dea673e9SRodney W. Grimes 		if (!timingout) {
714dea673e9SRodney W. Grimes 			timingout = 1;
715dea673e9SRodney W. Grimes 			alarm(RETRYTIME);
716dea673e9SRodney W. Grimes 		}
717dea673e9SRodney W. Grimes 		return;
718dea673e9SRodney W. Grimes 	}
71955b91f3aSGeoff Rehmet         if (sep->se_rpc) {
72055b91f3aSGeoff Rehmet                 int i, len = sizeof(struct sockaddr);
72155b91f3aSGeoff Rehmet 
72255b91f3aSGeoff Rehmet                 if (getsockname(sep->se_fd,
72355b91f3aSGeoff Rehmet 				(struct sockaddr*)&sep->se_ctrladdr, &len) < 0){
72455b91f3aSGeoff Rehmet                         syslog(LOG_ERR, "%s/%s: getsockname: %m",
72555b91f3aSGeoff Rehmet                                sep->se_service, sep->se_proto);
72655b91f3aSGeoff Rehmet                         (void) close(sep->se_fd);
72755b91f3aSGeoff Rehmet                         sep->se_fd = -1;
72855b91f3aSGeoff Rehmet                         return;
72955b91f3aSGeoff Rehmet                 }
73055b91f3aSGeoff Rehmet                 if (debug)
73155b91f3aSGeoff Rehmet                         print_service("REG ", sep);
73255b91f3aSGeoff Rehmet                 for (i = sep->se_rpc_lowvers; i <= sep->se_rpc_highvers; i++) {
73355b91f3aSGeoff Rehmet                         pmap_unset(sep->se_rpc_prog, i);
73455b91f3aSGeoff Rehmet                         pmap_set(sep->se_rpc_prog, i,
73555b91f3aSGeoff Rehmet                                  (sep->se_socktype == SOCK_DGRAM)
73655b91f3aSGeoff Rehmet                                  ? IPPROTO_UDP : IPPROTO_TCP,
73755b91f3aSGeoff Rehmet                                  ntohs(sep->se_ctrladdr.sin_port));
73855b91f3aSGeoff Rehmet                 }
73955b91f3aSGeoff Rehmet 
74055b91f3aSGeoff Rehmet         }
741dea673e9SRodney W. Grimes 	if (sep->se_socktype == SOCK_STREAM)
742dea673e9SRodney W. Grimes 		listen(sep->se_fd, 10);
743dea673e9SRodney W. Grimes 	FD_SET(sep->se_fd, &allsock);
744dea673e9SRodney W. Grimes 	nsock++;
745dea673e9SRodney W. Grimes 	if (sep->se_fd > maxsock)
746dea673e9SRodney W. Grimes 		maxsock = sep->se_fd;
747dea673e9SRodney W. Grimes 	if (debug) {
748dea673e9SRodney W. Grimes 		fprintf(stderr, "registered %s on %d\n",
749dea673e9SRodney W. Grimes 			sep->se_server, sep->se_fd);
750dea673e9SRodney W. Grimes 	}
751dea673e9SRodney W. Grimes }
752dea673e9SRodney W. Grimes 
753dea673e9SRodney W. Grimes /*
754dea673e9SRodney W. Grimes  * Finish with a service and its socket.
755dea673e9SRodney W. Grimes  */
756dea673e9SRodney W. Grimes void
757dea673e9SRodney W. Grimes close_sep(sep)
758dea673e9SRodney W. Grimes 	struct servtab *sep;
759dea673e9SRodney W. Grimes {
760dea673e9SRodney W. Grimes 	if (sep->se_fd >= 0) {
761dea673e9SRodney W. Grimes 		nsock--;
762dea673e9SRodney W. Grimes 		FD_CLR(sep->se_fd, &allsock);
763dea673e9SRodney W. Grimes 		(void) close(sep->se_fd);
764dea673e9SRodney W. Grimes 		sep->se_fd = -1;
765dea673e9SRodney W. Grimes 	}
766dea673e9SRodney W. Grimes 	sep->se_count = 0;
767dea673e9SRodney W. Grimes 	/*
768dea673e9SRodney W. Grimes 	 * Don't keep the pid of this running deamon: when reapchild()
769dea673e9SRodney W. Grimes 	 * reaps this pid, it would erroneously increment nsock.
770dea673e9SRodney W. Grimes 	 */
771dea673e9SRodney W. Grimes 	if (sep->se_wait > 1)
772dea673e9SRodney W. Grimes 		sep->se_wait = 1;
773dea673e9SRodney W. Grimes }
774dea673e9SRodney W. Grimes 
775dea673e9SRodney W. Grimes struct servtab *
776dea673e9SRodney W. Grimes enter(cp)
777dea673e9SRodney W. Grimes 	struct servtab *cp;
778dea673e9SRodney W. Grimes {
779dea673e9SRodney W. Grimes 	struct servtab *sep;
780dea673e9SRodney W. Grimes 	long omask;
781dea673e9SRodney W. Grimes 
782dea673e9SRodney W. Grimes 	sep = (struct servtab *)malloc(sizeof (*sep));
783dea673e9SRodney W. Grimes 	if (sep == (struct servtab *)0) {
784dea673e9SRodney W. Grimes 		syslog(LOG_ERR, "Out of memory.");
785dea673e9SRodney W. Grimes 		exit(-1);
786dea673e9SRodney W. Grimes 	}
787dea673e9SRodney W. Grimes 	*sep = *cp;
788dea673e9SRodney W. Grimes 	sep->se_fd = -1;
789dea673e9SRodney W. Grimes 	omask = sigblock(SIGBLOCK);
790dea673e9SRodney W. Grimes 	sep->se_next = servtab;
791dea673e9SRodney W. Grimes 	servtab = sep;
792dea673e9SRodney W. Grimes 	sigsetmask(omask);
793dea673e9SRodney W. Grimes 	return (sep);
794dea673e9SRodney W. Grimes }
795dea673e9SRodney W. Grimes 
796dea673e9SRodney W. Grimes FILE	*fconfig = NULL;
797dea673e9SRodney W. Grimes struct	servtab serv;
798dea673e9SRodney W. Grimes char	line[LINE_MAX];
799dea673e9SRodney W. Grimes 
800dea673e9SRodney W. Grimes int
801dea673e9SRodney W. Grimes setconfig()
802dea673e9SRodney W. Grimes {
803dea673e9SRodney W. Grimes 
804dea673e9SRodney W. Grimes 	if (fconfig != NULL) {
805dea673e9SRodney W. Grimes 		fseek(fconfig, 0L, SEEK_SET);
806dea673e9SRodney W. Grimes 		return (1);
807dea673e9SRodney W. Grimes 	}
808dea673e9SRodney W. Grimes 	fconfig = fopen(CONFIG, "r");
809dea673e9SRodney W. Grimes 	return (fconfig != NULL);
810dea673e9SRodney W. Grimes }
811dea673e9SRodney W. Grimes 
812dea673e9SRodney W. Grimes void
813dea673e9SRodney W. Grimes endconfig()
814dea673e9SRodney W. Grimes {
815dea673e9SRodney W. Grimes 	if (fconfig) {
816dea673e9SRodney W. Grimes 		(void) fclose(fconfig);
817dea673e9SRodney W. Grimes 		fconfig = NULL;
818dea673e9SRodney W. Grimes 	}
819dea673e9SRodney W. Grimes }
820dea673e9SRodney W. Grimes 
821dea673e9SRodney W. Grimes struct servtab *
822dea673e9SRodney W. Grimes getconfigent()
823dea673e9SRodney W. Grimes {
824dea673e9SRodney W. Grimes 	struct servtab *sep = &serv;
825dea673e9SRodney W. Grimes 	int argc;
826dea673e9SRodney W. Grimes 	char *cp, *arg;
82755b91f3aSGeoff Rehmet 	char *versp;
828dea673e9SRodney W. Grimes 	static char TCPMUX_TOKEN[] = "tcpmux/";
829dea673e9SRodney W. Grimes #define MUX_LEN		(sizeof(TCPMUX_TOKEN)-1)
830dea673e9SRodney W. Grimes 
831dea673e9SRodney W. Grimes more:
832dea673e9SRodney W. Grimes 	while ((cp = nextline(fconfig)) && (*cp == '#' || *cp == '\0'))
833dea673e9SRodney W. Grimes 		;
834dea673e9SRodney W. Grimes 	if (cp == NULL)
835dea673e9SRodney W. Grimes 		return ((struct servtab *)0);
836dea673e9SRodney W. Grimes 	/*
837dea673e9SRodney W. Grimes 	 * clear the static buffer, since some fields (se_ctrladdr,
838dea673e9SRodney W. Grimes 	 * for example) don't get initialized here.
839dea673e9SRodney W. Grimes 	 */
840dea673e9SRodney W. Grimes 	memset((caddr_t)sep, 0, sizeof *sep);
841dea673e9SRodney W. Grimes 	arg = skip(&cp);
842dea673e9SRodney W. Grimes 	if (cp == NULL) {
843dea673e9SRodney W. Grimes 		/* got an empty line containing just blanks/tabs. */
844dea673e9SRodney W. Grimes 		goto more;
845dea673e9SRodney W. Grimes 	}
846dea673e9SRodney W. Grimes 	if (strncmp(arg, TCPMUX_TOKEN, MUX_LEN) == 0) {
847dea673e9SRodney W. Grimes 		char *c = arg + MUX_LEN;
848dea673e9SRodney W. Grimes 		if (*c == '+') {
849dea673e9SRodney W. Grimes 			sep->se_type = MUXPLUS_TYPE;
850dea673e9SRodney W. Grimes 			c++;
851dea673e9SRodney W. Grimes 		} else
852dea673e9SRodney W. Grimes 			sep->se_type = MUX_TYPE;
853dea673e9SRodney W. Grimes 		sep->se_service = newstr(c);
854dea673e9SRodney W. Grimes 	} else {
855dea673e9SRodney W. Grimes 		sep->se_service = newstr(arg);
856dea673e9SRodney W. Grimes 		sep->se_type = NORM_TYPE;
857dea673e9SRodney W. Grimes 	}
858dea673e9SRodney W. Grimes 	arg = sskip(&cp);
859dea673e9SRodney W. Grimes 	if (strcmp(arg, "stream") == 0)
860dea673e9SRodney W. Grimes 		sep->se_socktype = SOCK_STREAM;
861dea673e9SRodney W. Grimes 	else if (strcmp(arg, "dgram") == 0)
862dea673e9SRodney W. Grimes 		sep->se_socktype = SOCK_DGRAM;
863dea673e9SRodney W. Grimes 	else if (strcmp(arg, "rdm") == 0)
864dea673e9SRodney W. Grimes 		sep->se_socktype = SOCK_RDM;
865dea673e9SRodney W. Grimes 	else if (strcmp(arg, "seqpacket") == 0)
866dea673e9SRodney W. Grimes 		sep->se_socktype = SOCK_SEQPACKET;
867dea673e9SRodney W. Grimes 	else if (strcmp(arg, "raw") == 0)
868dea673e9SRodney W. Grimes 		sep->se_socktype = SOCK_RAW;
869dea673e9SRodney W. Grimes 	else
870dea673e9SRodney W. Grimes 		sep->se_socktype = -1;
871dea673e9SRodney W. Grimes 	sep->se_proto = newstr(sskip(&cp));
87255b91f3aSGeoff Rehmet         if (strncmp(sep->se_proto, "rpc/", 4) == 0) {
87355b91f3aSGeoff Rehmet                 sep->se_proto += 4;
87455b91f3aSGeoff Rehmet                 sep->se_rpc = 1;
87555b91f3aSGeoff Rehmet                 sep->se_rpc_prog = sep->se_rpc_lowvers =
87655b91f3aSGeoff Rehmet 			sep->se_rpc_lowvers = 0;
87755b91f3aSGeoff Rehmet                 sep->se_ctrladdr.sin_family = AF_INET;
87855b91f3aSGeoff Rehmet                 sep->se_ctrladdr.sin_port = 0;
87955b91f3aSGeoff Rehmet                 sep->se_ctrladdr.sin_addr.s_addr = htonl(INADDR_ANY);
88055b91f3aSGeoff Rehmet                 if ((versp = rindex(sep->se_service, '/'))) {
88155b91f3aSGeoff Rehmet                         *versp++ = '\0';
88255b91f3aSGeoff Rehmet                         switch (sscanf(versp, "%d-%d",
88355b91f3aSGeoff Rehmet                                        &sep->se_rpc_lowvers,
88455b91f3aSGeoff Rehmet                                        &sep->se_rpc_highvers)) {
88555b91f3aSGeoff Rehmet                         case 2:
88655b91f3aSGeoff Rehmet                                 break;
88755b91f3aSGeoff Rehmet                         case 1:
88855b91f3aSGeoff Rehmet                                 sep->se_rpc_highvers =
88955b91f3aSGeoff Rehmet                                         sep->se_rpc_lowvers;
89055b91f3aSGeoff Rehmet                                 break;
89155b91f3aSGeoff Rehmet                         default:
89255b91f3aSGeoff Rehmet                                 syslog(LOG_ERR,
89355b91f3aSGeoff Rehmet 					"bad RPC version specifier; %s\n",
89455b91f3aSGeoff Rehmet 					sep->se_service);
89555b91f3aSGeoff Rehmet                                 freeconfig(sep);
89655b91f3aSGeoff Rehmet                                 goto more;
89755b91f3aSGeoff Rehmet                         }
89855b91f3aSGeoff Rehmet                 }
89955b91f3aSGeoff Rehmet                 else {
90055b91f3aSGeoff Rehmet                         sep->se_rpc_lowvers =
90155b91f3aSGeoff Rehmet                                 sep->se_rpc_highvers = 1;
90255b91f3aSGeoff Rehmet                 }
90355b91f3aSGeoff Rehmet         }
904dea673e9SRodney W. Grimes 	arg = sskip(&cp);
905dea673e9SRodney W. Grimes 	sep->se_wait = strcmp(arg, "wait") == 0;
906dea673e9SRodney W. Grimes 	if (ISMUX(sep)) {
907dea673e9SRodney W. Grimes 		/*
908dea673e9SRodney W. Grimes 		 * Silently enforce "nowait" for TCPMUX services since
909dea673e9SRodney W. Grimes 		 * they don't have an assigned port to listen on.
910dea673e9SRodney W. Grimes 		 */
911dea673e9SRodney W. Grimes 		sep->se_wait = 0;
912dea673e9SRodney W. Grimes 
913dea673e9SRodney W. Grimes 		if (strcmp(sep->se_proto, "tcp")) {
914dea673e9SRodney W. Grimes 			syslog(LOG_ERR,
915dea673e9SRodney W. Grimes 				"%s: bad protocol for tcpmux service %s",
916dea673e9SRodney W. Grimes 				CONFIG, sep->se_service);
917dea673e9SRodney W. Grimes 			goto more;
918dea673e9SRodney W. Grimes 		}
919dea673e9SRodney W. Grimes 		if (sep->se_socktype != SOCK_STREAM) {
920dea673e9SRodney W. Grimes 			syslog(LOG_ERR,
921dea673e9SRodney W. Grimes 				"%s: bad socket type for tcpmux service %s",
922dea673e9SRodney W. Grimes 				CONFIG, sep->se_service);
923dea673e9SRodney W. Grimes 			goto more;
924dea673e9SRodney W. Grimes 		}
925dea673e9SRodney W. Grimes 	}
926dea673e9SRodney W. Grimes 	sep->se_user = newstr(sskip(&cp));
927dea673e9SRodney W. Grimes 	sep->se_server = newstr(sskip(&cp));
928dea673e9SRodney W. Grimes 	if (strcmp(sep->se_server, "internal") == 0) {
929dea673e9SRodney W. Grimes 		struct biltin *bi;
930dea673e9SRodney W. Grimes 
931dea673e9SRodney W. Grimes 		for (bi = biltins; bi->bi_service; bi++)
932dea673e9SRodney W. Grimes 			if (bi->bi_socktype == sep->se_socktype &&
933dea673e9SRodney W. Grimes 			    strcmp(bi->bi_service, sep->se_service) == 0)
934dea673e9SRodney W. Grimes 				break;
935dea673e9SRodney W. Grimes 		if (bi->bi_service == 0) {
936dea673e9SRodney W. Grimes 			syslog(LOG_ERR, "internal service %s unknown",
937dea673e9SRodney W. Grimes 				sep->se_service);
938dea673e9SRodney W. Grimes 			goto more;
939dea673e9SRodney W. Grimes 		}
940dea673e9SRodney W. Grimes 		sep->se_bi = bi;
941dea673e9SRodney W. Grimes 		sep->se_wait = bi->bi_wait;
942dea673e9SRodney W. Grimes 	} else
943dea673e9SRodney W. Grimes 		sep->se_bi = NULL;
944dea673e9SRodney W. Grimes 	argc = 0;
945dea673e9SRodney W. Grimes 	for (arg = skip(&cp); cp; arg = skip(&cp))
946dea673e9SRodney W. Grimes 		if (argc < MAXARGV)
947dea673e9SRodney W. Grimes 			sep->se_argv[argc++] = newstr(arg);
948dea673e9SRodney W. Grimes 	while (argc <= MAXARGV)
949dea673e9SRodney W. Grimes 		sep->se_argv[argc++] = NULL;
950dea673e9SRodney W. Grimes 	return (sep);
951dea673e9SRodney W. Grimes }
952dea673e9SRodney W. Grimes 
953dea673e9SRodney W. Grimes void
954dea673e9SRodney W. Grimes freeconfig(cp)
955dea673e9SRodney W. Grimes 	struct servtab *cp;
956dea673e9SRodney W. Grimes {
957dea673e9SRodney W. Grimes 	int i;
958dea673e9SRodney W. Grimes 
959dea673e9SRodney W. Grimes 	if (cp->se_service)
960dea673e9SRodney W. Grimes 		free(cp->se_service);
961dea673e9SRodney W. Grimes 	if (cp->se_proto)
962dea673e9SRodney W. Grimes 		free(cp->se_proto);
963dea673e9SRodney W. Grimes 	if (cp->se_user)
964dea673e9SRodney W. Grimes 		free(cp->se_user);
965dea673e9SRodney W. Grimes 	if (cp->se_server)
966dea673e9SRodney W. Grimes 		free(cp->se_server);
967dea673e9SRodney W. Grimes 	for (i = 0; i < MAXARGV; i++)
968dea673e9SRodney W. Grimes 		if (cp->se_argv[i])
969dea673e9SRodney W. Grimes 			free(cp->se_argv[i]);
970dea673e9SRodney W. Grimes }
971dea673e9SRodney W. Grimes 
972dea673e9SRodney W. Grimes 
973dea673e9SRodney W. Grimes /*
974dea673e9SRodney W. Grimes  * Safe skip - if skip returns null, log a syntax error in the
975dea673e9SRodney W. Grimes  * configuration file and exit.
976dea673e9SRodney W. Grimes  */
977dea673e9SRodney W. Grimes char *
978dea673e9SRodney W. Grimes sskip(cpp)
979dea673e9SRodney W. Grimes 	char **cpp;
980dea673e9SRodney W. Grimes {
981dea673e9SRodney W. Grimes 	char *cp;
982dea673e9SRodney W. Grimes 
983dea673e9SRodney W. Grimes 	cp = skip(cpp);
984dea673e9SRodney W. Grimes 	if (cp == NULL) {
985dea673e9SRodney W. Grimes 		syslog(LOG_ERR, "%s: syntax error", CONFIG);
986dea673e9SRodney W. Grimes 		exit(-1);
987dea673e9SRodney W. Grimes 	}
988dea673e9SRodney W. Grimes 	return (cp);
989dea673e9SRodney W. Grimes }
990dea673e9SRodney W. Grimes 
991dea673e9SRodney W. Grimes char *
992dea673e9SRodney W. Grimes skip(cpp)
993dea673e9SRodney W. Grimes 	char **cpp;
994dea673e9SRodney W. Grimes {
995dea673e9SRodney W. Grimes 	char *cp = *cpp;
996dea673e9SRodney W. Grimes 	char *start;
997dea673e9SRodney W. Grimes 
998dea673e9SRodney W. Grimes again:
999dea673e9SRodney W. Grimes 	while (*cp == ' ' || *cp == '\t')
1000dea673e9SRodney W. Grimes 		cp++;
1001dea673e9SRodney W. Grimes 	if (*cp == '\0') {
1002dea673e9SRodney W. Grimes 		int c;
1003dea673e9SRodney W. Grimes 
1004dea673e9SRodney W. Grimes 		c = getc(fconfig);
1005dea673e9SRodney W. Grimes 		(void) ungetc(c, fconfig);
1006dea673e9SRodney W. Grimes 		if (c == ' ' || c == '\t')
1007dea673e9SRodney W. Grimes 			if (cp = nextline(fconfig))
1008dea673e9SRodney W. Grimes 				goto again;
1009dea673e9SRodney W. Grimes 		*cpp = (char *)0;
1010dea673e9SRodney W. Grimes 		return ((char *)0);
1011dea673e9SRodney W. Grimes 	}
1012dea673e9SRodney W. Grimes 	start = cp;
1013dea673e9SRodney W. Grimes 	while (*cp && *cp != ' ' && *cp != '\t')
1014dea673e9SRodney W. Grimes 		cp++;
1015dea673e9SRodney W. Grimes 	if (*cp != '\0')
1016dea673e9SRodney W. Grimes 		*cp++ = '\0';
1017dea673e9SRodney W. Grimes 	*cpp = cp;
1018dea673e9SRodney W. Grimes 	return (start);
1019dea673e9SRodney W. Grimes }
1020dea673e9SRodney W. Grimes 
1021dea673e9SRodney W. Grimes char *
1022dea673e9SRodney W. Grimes nextline(fd)
1023dea673e9SRodney W. Grimes 	FILE *fd;
1024dea673e9SRodney W. Grimes {
1025dea673e9SRodney W. Grimes 	char *cp;
1026dea673e9SRodney W. Grimes 
1027dea673e9SRodney W. Grimes 	if (fgets(line, sizeof (line), fd) == NULL)
1028dea673e9SRodney W. Grimes 		return ((char *)0);
1029dea673e9SRodney W. Grimes 	cp = strchr(line, '\n');
1030dea673e9SRodney W. Grimes 	if (cp)
1031dea673e9SRodney W. Grimes 		*cp = '\0';
1032dea673e9SRodney W. Grimes 	return (line);
1033dea673e9SRodney W. Grimes }
1034dea673e9SRodney W. Grimes 
1035dea673e9SRodney W. Grimes char *
1036dea673e9SRodney W. Grimes newstr(cp)
1037dea673e9SRodney W. Grimes 	char *cp;
1038dea673e9SRodney W. Grimes {
1039dea673e9SRodney W. Grimes 	if (cp = strdup(cp ? cp : ""))
1040dea673e9SRodney W. Grimes 		return (cp);
1041dea673e9SRodney W. Grimes 	syslog(LOG_ERR, "strdup: %m");
1042dea673e9SRodney W. Grimes 	exit(-1);
1043dea673e9SRodney W. Grimes }
1044dea673e9SRodney W. Grimes 
1045dea673e9SRodney W. Grimes void
1046dea673e9SRodney W. Grimes setproctitle(a, s)
1047dea673e9SRodney W. Grimes 	char *a;
1048dea673e9SRodney W. Grimes 	int s;
1049dea673e9SRodney W. Grimes {
1050dea673e9SRodney W. Grimes 	int size;
1051dea673e9SRodney W. Grimes 	char *cp;
1052dea673e9SRodney W. Grimes 	struct sockaddr_in sin;
1053dea673e9SRodney W. Grimes 	char buf[80];
1054dea673e9SRodney W. Grimes 
1055dea673e9SRodney W. Grimes 	cp = Argv[0];
1056dea673e9SRodney W. Grimes 	size = sizeof(sin);
1057dea673e9SRodney W. Grimes 	if (getpeername(s, (struct sockaddr *)&sin, &size) == 0)
1058dea673e9SRodney W. Grimes 		(void) sprintf(buf, "-%s [%s]", a, inet_ntoa(sin.sin_addr));
1059dea673e9SRodney W. Grimes 	else
1060dea673e9SRodney W. Grimes 		(void) sprintf(buf, "-%s", a);
1061dea673e9SRodney W. Grimes 	strncpy(cp, buf, LastArg - cp);
1062dea673e9SRodney W. Grimes 	cp += strlen(cp);
1063dea673e9SRodney W. Grimes 	while (cp < LastArg)
1064dea673e9SRodney W. Grimes 		*cp++ = ' ';
1065dea673e9SRodney W. Grimes }
1066dea673e9SRodney W. Grimes 
1067dea673e9SRodney W. Grimes /*
1068dea673e9SRodney W. Grimes  * Internet services provided internally by inetd:
1069dea673e9SRodney W. Grimes  */
1070dea673e9SRodney W. Grimes #define	BUFSIZE	8192
1071dea673e9SRodney W. Grimes 
1072dea673e9SRodney W. Grimes /* ARGSUSED */
1073dea673e9SRodney W. Grimes void
1074dea673e9SRodney W. Grimes echo_stream(s, sep)		/* Echo service -- echo data back */
1075dea673e9SRodney W. Grimes 	int s;
1076dea673e9SRodney W. Grimes 	struct servtab *sep;
1077dea673e9SRodney W. Grimes {
1078dea673e9SRodney W. Grimes 	char buffer[BUFSIZE];
1079dea673e9SRodney W. Grimes 	int i;
1080dea673e9SRodney W. Grimes 
1081dea673e9SRodney W. Grimes 	setproctitle(sep->se_service, s);
1082dea673e9SRodney W. Grimes 	while ((i = read(s, buffer, sizeof(buffer))) > 0 &&
1083dea673e9SRodney W. Grimes 	    write(s, buffer, i) > 0)
1084dea673e9SRodney W. Grimes 		;
1085dea673e9SRodney W. Grimes 	exit(0);
1086dea673e9SRodney W. Grimes }
1087dea673e9SRodney W. Grimes 
108871704f34SGarrett Wollman int check_loop(sin, sep)
108971704f34SGarrett Wollman 	struct sockaddr_in *sin;
109071704f34SGarrett Wollman 	struct servtab *sep;
109171704f34SGarrett Wollman {
109271704f34SGarrett Wollman 	struct servtab *se2;
109371704f34SGarrett Wollman 
109471704f34SGarrett Wollman 	for (se2 = servtab; se2; se2 = se2->se_next) {
109571704f34SGarrett Wollman 		if (!se2->se_bi || se2->se_socktype != SOCK_DGRAM)
109671704f34SGarrett Wollman 			continue;
109771704f34SGarrett Wollman 
109871704f34SGarrett Wollman 		if (sin->sin_port == se2->se_ctrladdr.sin_port) {
109971704f34SGarrett Wollman 			syslog(LOG_WARNING,
110071704f34SGarrett Wollman 			       "%s/%s:%s/%s loop request REFUSED from %s",
110171704f34SGarrett Wollman 			       sep->se_service, sep->se_proto,
110271704f34SGarrett Wollman 			       se2->se_service, se2->se_proto,
110371704f34SGarrett Wollman 			       inet_ntoa(sin->sin_addr));
110471704f34SGarrett Wollman 			return 1;
110571704f34SGarrett Wollman 		}
110671704f34SGarrett Wollman 	}
110771704f34SGarrett Wollman 	return 0;
110871704f34SGarrett Wollman }
110971704f34SGarrett Wollman 
1110dea673e9SRodney W. Grimes /* ARGSUSED */
1111dea673e9SRodney W. Grimes void
1112dea673e9SRodney W. Grimes echo_dg(s, sep)			/* Echo service -- echo data back */
1113dea673e9SRodney W. Grimes 	int s;
1114dea673e9SRodney W. Grimes 	struct servtab *sep;
1115dea673e9SRodney W. Grimes {
1116dea673e9SRodney W. Grimes 	char buffer[BUFSIZE];
1117dea673e9SRodney W. Grimes 	int i, size;
111871704f34SGarrett Wollman 	struct sockaddr_in sin;
1119dea673e9SRodney W. Grimes 
112071704f34SGarrett Wollman 	size = sizeof(sin);
112171704f34SGarrett Wollman 	if ((i = recvfrom(s, buffer, sizeof(buffer), 0,
112271704f34SGarrett Wollman 			  (struct sockaddr *)&sin, &size)) < 0)
1123dea673e9SRodney W. Grimes 		return;
112471704f34SGarrett Wollman 
112571704f34SGarrett Wollman 	if (check_loop(&sin, sep))
112671704f34SGarrett Wollman 		return;
112771704f34SGarrett Wollman 
112871704f34SGarrett Wollman 	(void) sendto(s, buffer, i, 0, (struct sockaddr *)&sin,
112971704f34SGarrett Wollman 		      sizeof(sin));
1130dea673e9SRodney W. Grimes }
1131dea673e9SRodney W. Grimes 
1132dea673e9SRodney W. Grimes /* ARGSUSED */
1133dea673e9SRodney W. Grimes void
1134dea673e9SRodney W. Grimes discard_stream(s, sep)		/* Discard service -- ignore data */
1135dea673e9SRodney W. Grimes 	int s;
1136dea673e9SRodney W. Grimes 	struct servtab *sep;
1137dea673e9SRodney W. Grimes {
1138dea673e9SRodney W. Grimes 	int ret;
1139dea673e9SRodney W. Grimes 	char buffer[BUFSIZE];
1140dea673e9SRodney W. Grimes 
1141dea673e9SRodney W. Grimes 	setproctitle(sep->se_service, s);
1142dea673e9SRodney W. Grimes 	while (1) {
1143dea673e9SRodney W. Grimes 		while ((ret = read(s, buffer, sizeof(buffer))) > 0)
1144dea673e9SRodney W. Grimes 			;
1145dea673e9SRodney W. Grimes 		if (ret == 0 || errno != EINTR)
1146dea673e9SRodney W. Grimes 			break;
1147dea673e9SRodney W. Grimes 	}
1148dea673e9SRodney W. Grimes 	exit(0);
1149dea673e9SRodney W. Grimes }
1150dea673e9SRodney W. Grimes 
1151dea673e9SRodney W. Grimes /* ARGSUSED */
1152dea673e9SRodney W. Grimes void
1153dea673e9SRodney W. Grimes discard_dg(s, sep)		/* Discard service -- ignore data */
1154dea673e9SRodney W. Grimes 	int s;
1155dea673e9SRodney W. Grimes 	struct servtab *sep;
1156dea673e9SRodney W. Grimes {
1157dea673e9SRodney W. Grimes 	char buffer[BUFSIZE];
1158dea673e9SRodney W. Grimes 
1159dea673e9SRodney W. Grimes 	(void) read(s, buffer, sizeof(buffer));
1160dea673e9SRodney W. Grimes }
1161dea673e9SRodney W. Grimes 
1162dea673e9SRodney W. Grimes #include <ctype.h>
1163dea673e9SRodney W. Grimes #define LINESIZ 72
1164dea673e9SRodney W. Grimes char ring[128];
1165dea673e9SRodney W. Grimes char *endring;
1166dea673e9SRodney W. Grimes 
1167dea673e9SRodney W. Grimes void
1168dea673e9SRodney W. Grimes initring()
1169dea673e9SRodney W. Grimes {
1170dea673e9SRodney W. Grimes 	int i;
1171dea673e9SRodney W. Grimes 
1172dea673e9SRodney W. Grimes 	endring = ring;
1173dea673e9SRodney W. Grimes 
1174dea673e9SRodney W. Grimes 	for (i = 0; i <= 128; ++i)
1175dea673e9SRodney W. Grimes 		if (isprint(i))
1176dea673e9SRodney W. Grimes 			*endring++ = i;
1177dea673e9SRodney W. Grimes }
1178dea673e9SRodney W. Grimes 
1179dea673e9SRodney W. Grimes /* ARGSUSED */
1180dea673e9SRodney W. Grimes void
1181dea673e9SRodney W. Grimes chargen_stream(s, sep)		/* Character generator */
1182dea673e9SRodney W. Grimes 	int s;
1183dea673e9SRodney W. Grimes 	struct servtab *sep;
1184dea673e9SRodney W. Grimes {
1185dea673e9SRodney W. Grimes 	int len;
1186dea673e9SRodney W. Grimes 	char *rs, text[LINESIZ+2];
1187dea673e9SRodney W. Grimes 
1188dea673e9SRodney W. Grimes 	setproctitle(sep->se_service, s);
1189dea673e9SRodney W. Grimes 
1190dea673e9SRodney W. Grimes 	if (!endring) {
1191dea673e9SRodney W. Grimes 		initring();
1192dea673e9SRodney W. Grimes 		rs = ring;
1193dea673e9SRodney W. Grimes 	}
1194dea673e9SRodney W. Grimes 
1195dea673e9SRodney W. Grimes 	text[LINESIZ] = '\r';
1196dea673e9SRodney W. Grimes 	text[LINESIZ + 1] = '\n';
1197dea673e9SRodney W. Grimes 	for (rs = ring;;) {
1198dea673e9SRodney W. Grimes 		if ((len = endring - rs) >= LINESIZ)
1199dea673e9SRodney W. Grimes 			memmove(text, rs, LINESIZ);
1200dea673e9SRodney W. Grimes 		else {
1201dea673e9SRodney W. Grimes 			memmove(text, rs, len);
1202dea673e9SRodney W. Grimes 			memmove(text + len, ring, LINESIZ - len);
1203dea673e9SRodney W. Grimes 		}
1204dea673e9SRodney W. Grimes 		if (++rs == endring)
1205dea673e9SRodney W. Grimes 			rs = ring;
1206dea673e9SRodney W. Grimes 		if (write(s, text, sizeof(text)) != sizeof(text))
1207dea673e9SRodney W. Grimes 			break;
1208dea673e9SRodney W. Grimes 	}
1209dea673e9SRodney W. Grimes 	exit(0);
1210dea673e9SRodney W. Grimes }
1211dea673e9SRodney W. Grimes 
1212dea673e9SRodney W. Grimes /* ARGSUSED */
1213dea673e9SRodney W. Grimes void
1214dea673e9SRodney W. Grimes chargen_dg(s, sep)		/* Character generator */
1215dea673e9SRodney W. Grimes 	int s;
1216dea673e9SRodney W. Grimes 	struct servtab *sep;
1217dea673e9SRodney W. Grimes {
121871704f34SGarrett Wollman 	struct sockaddr_in sin;
1219dea673e9SRodney W. Grimes 	static char *rs;
1220dea673e9SRodney W. Grimes 	int len, size;
1221dea673e9SRodney W. Grimes 	char text[LINESIZ+2];
1222dea673e9SRodney W. Grimes 
1223dea673e9SRodney W. Grimes 	if (endring == 0) {
1224dea673e9SRodney W. Grimes 		initring();
1225dea673e9SRodney W. Grimes 		rs = ring;
1226dea673e9SRodney W. Grimes 	}
1227dea673e9SRodney W. Grimes 
122871704f34SGarrett Wollman 	size = sizeof(sin);
122971704f34SGarrett Wollman 	if (recvfrom(s, text, sizeof(text), 0,
123071704f34SGarrett Wollman 		     (struct sockaddr *)&sin, &size) < 0)
123171704f34SGarrett Wollman 		return;
123271704f34SGarrett Wollman 
123371704f34SGarrett Wollman 	if (check_loop(&sin, sep))
1234dea673e9SRodney W. Grimes 		return;
1235dea673e9SRodney W. Grimes 
1236dea673e9SRodney W. Grimes 	if ((len = endring - rs) >= LINESIZ)
1237dea673e9SRodney W. Grimes 		memmove(text, rs, LINESIZ);
1238dea673e9SRodney W. Grimes 	else {
1239dea673e9SRodney W. Grimes 		memmove(text, rs, len);
1240dea673e9SRodney W. Grimes 		memmove(text + len, ring, LINESIZ - len);
1241dea673e9SRodney W. Grimes 	}
1242dea673e9SRodney W. Grimes 	if (++rs == endring)
1243dea673e9SRodney W. Grimes 		rs = ring;
1244dea673e9SRodney W. Grimes 	text[LINESIZ] = '\r';
1245dea673e9SRodney W. Grimes 	text[LINESIZ + 1] = '\n';
124671704f34SGarrett Wollman 	(void) sendto(s, text, sizeof(text), 0,
124771704f34SGarrett Wollman 		      (struct sockaddr *)&sin, sizeof(sin));
1248dea673e9SRodney W. Grimes }
1249dea673e9SRodney W. Grimes 
1250dea673e9SRodney W. Grimes /*
1251dea673e9SRodney W. Grimes  * Return a machine readable date and time, in the form of the
1252dea673e9SRodney W. Grimes  * number of seconds since midnight, Jan 1, 1900.  Since gettimeofday
1253dea673e9SRodney W. Grimes  * returns the number of seconds since midnight, Jan 1, 1970,
1254dea673e9SRodney W. Grimes  * we must add 2208988800 seconds to this figure to make up for
1255dea673e9SRodney W. Grimes  * some seventy years Bell Labs was asleep.
1256dea673e9SRodney W. Grimes  */
1257dea673e9SRodney W. Grimes 
1258dea673e9SRodney W. Grimes long
1259dea673e9SRodney W. Grimes machtime()
1260dea673e9SRodney W. Grimes {
1261dea673e9SRodney W. Grimes 	struct timeval tv;
1262dea673e9SRodney W. Grimes 
1263dea673e9SRodney W. Grimes 	if (gettimeofday(&tv, (struct timezone *)0) < 0) {
1264dea673e9SRodney W. Grimes 		if (debug)
1265dea673e9SRodney W. Grimes 			fprintf(stderr, "Unable to get time of day\n");
1266dea673e9SRodney W. Grimes 		return (0L);
1267dea673e9SRodney W. Grimes 	}
1268dea673e9SRodney W. Grimes #define	OFFSET ((u_long)25567 * 24*60*60)
1269dea673e9SRodney W. Grimes 	return (htonl((long)(tv.tv_sec + OFFSET)));
1270dea673e9SRodney W. Grimes #undef OFFSET
1271dea673e9SRodney W. Grimes }
1272dea673e9SRodney W. Grimes 
1273dea673e9SRodney W. Grimes /* ARGSUSED */
1274dea673e9SRodney W. Grimes void
1275dea673e9SRodney W. Grimes machtime_stream(s, sep)
1276dea673e9SRodney W. Grimes 	int s;
1277dea673e9SRodney W. Grimes 	struct servtab *sep;
1278dea673e9SRodney W. Grimes {
1279dea673e9SRodney W. Grimes 	long result;
1280dea673e9SRodney W. Grimes 
1281dea673e9SRodney W. Grimes 	result = machtime();
1282dea673e9SRodney W. Grimes 	(void) write(s, (char *) &result, sizeof(result));
1283dea673e9SRodney W. Grimes }
1284dea673e9SRodney W. Grimes 
1285dea673e9SRodney W. Grimes /* ARGSUSED */
1286dea673e9SRodney W. Grimes void
1287dea673e9SRodney W. Grimes machtime_dg(s, sep)
1288dea673e9SRodney W. Grimes 	int s;
1289dea673e9SRodney W. Grimes 	struct servtab *sep;
1290dea673e9SRodney W. Grimes {
1291dea673e9SRodney W. Grimes 	long result;
129271704f34SGarrett Wollman 	struct sockaddr_in sin;
1293dea673e9SRodney W. Grimes 	int size;
1294dea673e9SRodney W. Grimes 
129571704f34SGarrett Wollman 	size = sizeof(sin);
129671704f34SGarrett Wollman 	if (recvfrom(s, (char *)&result, sizeof(result), 0,
129771704f34SGarrett Wollman 		     (struct sockaddr *)&sin, &size) < 0)
1298dea673e9SRodney W. Grimes 		return;
129971704f34SGarrett Wollman 
130071704f34SGarrett Wollman 	if (check_loop(&sin, sep))
130171704f34SGarrett Wollman 		return;
130271704f34SGarrett Wollman 
1303dea673e9SRodney W. Grimes 	result = machtime();
130471704f34SGarrett Wollman 	(void) sendto(s, (char *) &result, sizeof(result), 0,
130571704f34SGarrett Wollman 		      (struct sockaddr *)&sin, sizeof(sin));
1306dea673e9SRodney W. Grimes }
1307dea673e9SRodney W. Grimes 
1308dea673e9SRodney W. Grimes /* ARGSUSED */
1309dea673e9SRodney W. Grimes void
1310dea673e9SRodney W. Grimes daytime_stream(s, sep)		/* Return human-readable time of day */
1311dea673e9SRodney W. Grimes 	int s;
1312dea673e9SRodney W. Grimes 	struct servtab *sep;
1313dea673e9SRodney W. Grimes {
1314dea673e9SRodney W. Grimes 	char buffer[256];
1315dea673e9SRodney W. Grimes 	time_t clock;
1316dea673e9SRodney W. Grimes 
1317dea673e9SRodney W. Grimes 	clock = time((time_t *) 0);
1318dea673e9SRodney W. Grimes 
1319dea673e9SRodney W. Grimes 	(void) sprintf(buffer, "%.24s\r\n", ctime(&clock));
1320dea673e9SRodney W. Grimes 	(void) write(s, buffer, strlen(buffer));
1321dea673e9SRodney W. Grimes }
1322dea673e9SRodney W. Grimes 
1323dea673e9SRodney W. Grimes /* ARGSUSED */
1324dea673e9SRodney W. Grimes void
1325dea673e9SRodney W. Grimes daytime_dg(s, sep)		/* Return human-readable time of day */
1326dea673e9SRodney W. Grimes 	int s;
1327dea673e9SRodney W. Grimes 	struct servtab *sep;
1328dea673e9SRodney W. Grimes {
1329dea673e9SRodney W. Grimes 	char buffer[256];
1330dea673e9SRodney W. Grimes 	time_t clock;
133171704f34SGarrett Wollman 	struct sockaddr_in sin;
1332dea673e9SRodney W. Grimes 	int size;
1333dea673e9SRodney W. Grimes 
1334dea673e9SRodney W. Grimes 	clock = time((time_t *) 0);
1335dea673e9SRodney W. Grimes 
133671704f34SGarrett Wollman 	size = sizeof(sin);
133771704f34SGarrett Wollman 	if (recvfrom(s, buffer, sizeof(buffer), 0,
133871704f34SGarrett Wollman 		     (struct sockaddr *)&sin, &size) < 0)
1339dea673e9SRodney W. Grimes 		return;
134071704f34SGarrett Wollman 
134171704f34SGarrett Wollman 	if (check_loop(&sin, sep))
134271704f34SGarrett Wollman 		return;
134371704f34SGarrett Wollman 
1344dea673e9SRodney W. Grimes 	(void) sprintf(buffer, "%.24s\r\n", ctime(&clock));
134571704f34SGarrett Wollman 	(void) sendto(s, buffer, strlen(buffer), 0,
134671704f34SGarrett Wollman 		      (struct sockaddr *)&sin, sizeof(sin));
1347dea673e9SRodney W. Grimes }
1348dea673e9SRodney W. Grimes 
1349dea673e9SRodney W. Grimes /*
1350dea673e9SRodney W. Grimes  * print_service:
1351dea673e9SRodney W. Grimes  *	Dump relevant information to stderr
1352dea673e9SRodney W. Grimes  */
1353dea673e9SRodney W. Grimes void
1354dea673e9SRodney W. Grimes print_service(action, sep)
1355dea673e9SRodney W. Grimes 	char *action;
1356dea673e9SRodney W. Grimes 	struct servtab *sep;
1357dea673e9SRodney W. Grimes {
135855b91f3aSGeoff Rehmet 	if(sep->se_rpc)
1359dea673e9SRodney W. Grimes 		fprintf(stderr,
1360dea673e9SRodney W. Grimes 	    		"%s: %s proto=%s, wait=%d, user=%s builtin=%x server=%s\n",
1361dea673e9SRodney W. Grimes 	    		action, sep->se_service, sep->se_proto,
136255b91f3aSGeoff Rehmet 	    		sep->se_wait, sep->se_user, (int)sep->se_bi,
136355b91f3aSGeoff Rehmet 			sep->se_server);
136455b91f3aSGeoff Rehmet 	else
136555b91f3aSGeoff Rehmet 		fprintf(stderr,
136655b91f3aSGeoff Rehmet 			"%s: %s proto=%s, wait=%d, user=%s builtin=%x server=%s\n",
136755b91f3aSGeoff Rehmet 			action, sep->se_service, sep->se_proto,
136855b91f3aSGeoff Rehmet 			sep->se_wait, sep->se_user, (int)sep->se_bi,
136955b91f3aSGeoff Rehmet 			sep->se_server);
1370dea673e9SRodney W. Grimes }
1371dea673e9SRodney W. Grimes 
1372dea673e9SRodney W. Grimes /*
1373dea673e9SRodney W. Grimes  *  Based on TCPMUX.C by Mark K. Lottor November 1988
1374dea673e9SRodney W. Grimes  *  sri-nic::ps:<mkl>tcpmux.c
1375dea673e9SRodney W. Grimes  */
1376dea673e9SRodney W. Grimes 
1377dea673e9SRodney W. Grimes 
1378dea673e9SRodney W. Grimes static int		/* # of characters upto \r,\n or \0 */
1379dea673e9SRodney W. Grimes getline(fd, buf, len)
1380dea673e9SRodney W. Grimes 	int fd;
1381dea673e9SRodney W. Grimes 	char *buf;
1382dea673e9SRodney W. Grimes 	int len;
1383dea673e9SRodney W. Grimes {
1384dea673e9SRodney W. Grimes 	int count = 0, n;
1385dea673e9SRodney W. Grimes 
1386dea673e9SRodney W. Grimes 	do {
1387dea673e9SRodney W. Grimes 		n = read(fd, buf, len-count);
1388dea673e9SRodney W. Grimes 		if (n == 0)
1389dea673e9SRodney W. Grimes 			return (count);
1390dea673e9SRodney W. Grimes 		if (n < 0)
1391dea673e9SRodney W. Grimes 			return (-1);
1392dea673e9SRodney W. Grimes 		while (--n >= 0) {
1393dea673e9SRodney W. Grimes 			if (*buf == '\r' || *buf == '\n' || *buf == '\0')
1394dea673e9SRodney W. Grimes 				return (count);
1395dea673e9SRodney W. Grimes 			count++;
1396dea673e9SRodney W. Grimes 			buf++;
1397dea673e9SRodney W. Grimes 		}
1398dea673e9SRodney W. Grimes 	} while (count < len);
1399dea673e9SRodney W. Grimes 	return (count);
1400dea673e9SRodney W. Grimes }
1401dea673e9SRodney W. Grimes 
1402dea673e9SRodney W. Grimes #define MAX_SERV_LEN	(256+2)		/* 2 bytes for \r\n */
1403dea673e9SRodney W. Grimes 
1404dea673e9SRodney W. Grimes #define strwrite(fd, buf)	(void) write(fd, buf, sizeof(buf)-1)
1405dea673e9SRodney W. Grimes 
1406dea673e9SRodney W. Grimes struct servtab *
1407dea673e9SRodney W. Grimes tcpmux(s)
1408dea673e9SRodney W. Grimes 	int s;
1409dea673e9SRodney W. Grimes {
1410dea673e9SRodney W. Grimes 	struct servtab *sep;
1411dea673e9SRodney W. Grimes 	char service[MAX_SERV_LEN+1];
1412dea673e9SRodney W. Grimes 	int len;
1413dea673e9SRodney W. Grimes 
1414dea673e9SRodney W. Grimes 	/* Get requested service name */
1415dea673e9SRodney W. Grimes 	if ((len = getline(s, service, MAX_SERV_LEN)) < 0) {
1416dea673e9SRodney W. Grimes 		strwrite(s, "-Error reading service name\r\n");
1417dea673e9SRodney W. Grimes 		return (NULL);
1418dea673e9SRodney W. Grimes 	}
1419dea673e9SRodney W. Grimes 	service[len] = '\0';
1420dea673e9SRodney W. Grimes 
1421dea673e9SRodney W. Grimes 	if (debug)
1422dea673e9SRodney W. Grimes 		fprintf(stderr, "tcpmux: someone wants %s\n", service);
1423dea673e9SRodney W. Grimes 
1424dea673e9SRodney W. Grimes 	/*
1425dea673e9SRodney W. Grimes 	 * Help is a required command, and lists available services,
1426dea673e9SRodney W. Grimes 	 * one per line.
1427dea673e9SRodney W. Grimes 	 */
1428dea673e9SRodney W. Grimes 	if (!strcasecmp(service, "help")) {
1429dea673e9SRodney W. Grimes 		for (sep = servtab; sep; sep = sep->se_next) {
1430dea673e9SRodney W. Grimes 			if (!ISMUX(sep))
1431dea673e9SRodney W. Grimes 				continue;
1432dea673e9SRodney W. Grimes 			(void)write(s,sep->se_service,strlen(sep->se_service));
1433dea673e9SRodney W. Grimes 			strwrite(s, "\r\n");
1434dea673e9SRodney W. Grimes 		}
1435dea673e9SRodney W. Grimes 		return (NULL);
1436dea673e9SRodney W. Grimes 	}
1437dea673e9SRodney W. Grimes 
1438dea673e9SRodney W. Grimes 	/* Try matching a service in inetd.conf with the request */
1439dea673e9SRodney W. Grimes 	for (sep = servtab; sep; sep = sep->se_next) {
1440dea673e9SRodney W. Grimes 		if (!ISMUX(sep))
1441dea673e9SRodney W. Grimes 			continue;
1442dea673e9SRodney W. Grimes 		if (!strcasecmp(service, sep->se_service)) {
1443dea673e9SRodney W. Grimes 			if (ISMUXPLUS(sep)) {
1444dea673e9SRodney W. Grimes 				strwrite(s, "+Go\r\n");
1445dea673e9SRodney W. Grimes 			}
1446dea673e9SRodney W. Grimes 			return (sep);
1447dea673e9SRodney W. Grimes 		}
1448dea673e9SRodney W. Grimes 	}
1449dea673e9SRodney W. Grimes 	strwrite(s, "-Service not available\r\n");
1450dea673e9SRodney W. Grimes 	return (NULL);
1451dea673e9SRodney W. Grimes }
1452