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