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 35c1a2e93eSPhilippe Charnier static const 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 41c1a2e93eSPhilippe Charnier #if 0 42c1a2e93eSPhilippe Charnier static char sccsid[] = "@(#)from: inetd.c 8.4 (Berkeley) 4/13/94"; 43c1a2e93eSPhilippe Charnier #endif 44c1a2e93eSPhilippe Charnier static const char rcsid[] = 4534b32a7cSGuido van Rooij "$Id: inetd.c,v 1.30 1998/02/24 21:55:14 pst Exp $"; 46dea673e9SRodney W. Grimes #endif /* not lint */ 47dea673e9SRodney W. Grimes 48dea673e9SRodney W. Grimes /* 49dea673e9SRodney W. Grimes * Inetd - Internet super-server 50dea673e9SRodney W. Grimes * 51dea673e9SRodney W. Grimes * This program invokes all internet services as needed. Connection-oriented 52dea673e9SRodney W. Grimes * services are invoked each time a connection is made, by creating a process. 53dea673e9SRodney W. Grimes * This process is passed the connection as file descriptor 0 and is expected 54dea673e9SRodney W. Grimes * to do a getpeername to find out the source host and port. 55dea673e9SRodney W. Grimes * 56dea673e9SRodney W. Grimes * Datagram oriented services are invoked when a datagram 57dea673e9SRodney W. Grimes * arrives; a process is created and passed a pending message 58dea673e9SRodney W. Grimes * on file descriptor 0. Datagram servers may either connect 59dea673e9SRodney W. Grimes * to their peer, freeing up the original socket for inetd 60dea673e9SRodney W. Grimes * to receive further messages on, or ``take over the socket'', 61dea673e9SRodney W. Grimes * processing all arriving datagrams and, eventually, timing 62dea673e9SRodney W. Grimes * out. The first type of server is said to be ``multi-threaded''; 63dea673e9SRodney W. Grimes * the second type of server ``single-threaded''. 64dea673e9SRodney W. Grimes * 65dea673e9SRodney W. Grimes * Inetd uses a configuration file which is read at startup 66dea673e9SRodney W. Grimes * and, possibly, at some later time in response to a hangup signal. 67dea673e9SRodney W. Grimes * The configuration file is ``free format'' with fields given in the 68dea673e9SRodney W. Grimes * order shown below. Continuation lines for an entry must being with 69dea673e9SRodney W. Grimes * a space or tab. All fields must be present in each entry. 70dea673e9SRodney W. Grimes * 71dea673e9SRodney W. Grimes * service name must be in /etc/services or must 72dea673e9SRodney W. Grimes * name a tcpmux service 73dea673e9SRodney W. Grimes * socket type stream/dgram/raw/rdm/seqpacket 74dea673e9SRodney W. Grimes * protocol must be in /etc/protocols 75dea673e9SRodney W. Grimes * wait/nowait single-threaded/multi-threaded 76dea673e9SRodney W. Grimes * user user to run daemon as 77dea673e9SRodney W. Grimes * server program full path name 78dea673e9SRodney W. Grimes * server program arguments maximum of MAXARGS (20) 79dea673e9SRodney W. Grimes * 80dea673e9SRodney W. Grimes * TCP services without official port numbers are handled with the 81dea673e9SRodney W. Grimes * RFC1078-based tcpmux internal service. Tcpmux listens on port 1 for 82dea673e9SRodney W. Grimes * requests. When a connection is made from a foreign host, the service 83dea673e9SRodney W. Grimes * requested is passed to tcpmux, which looks it up in the servtab list 84dea673e9SRodney W. Grimes * and returns the proper entry for the service. Tcpmux returns a 85dea673e9SRodney W. Grimes * negative reply if the service doesn't exist, otherwise the invoked 86dea673e9SRodney W. Grimes * server is expected to return the positive reply if the service type in 87dea673e9SRodney W. Grimes * inetd.conf file has the prefix "tcpmux/". If the service type has the 88dea673e9SRodney W. Grimes * prefix "tcpmux/+", tcpmux will return the positive reply for the 89dea673e9SRodney W. Grimes * process; this is for compatibility with older server code, and also 90dea673e9SRodney W. Grimes * allows you to invoke programs that use stdin/stdout without putting any 91dea673e9SRodney W. Grimes * special server code in them. Services that use tcpmux are "nowait" 92dea673e9SRodney W. Grimes * because they do not have a well-known port and hence cannot listen 93dea673e9SRodney W. Grimes * for new requests. 94dea673e9SRodney W. Grimes * 9555b91f3aSGeoff Rehmet * For RPC services 9655b91f3aSGeoff Rehmet * service name/version must be in /etc/rpc 9755b91f3aSGeoff Rehmet * socket type stream/dgram/raw/rdm/seqpacket 9855b91f3aSGeoff Rehmet * protocol must be in /etc/protocols 9955b91f3aSGeoff Rehmet * wait/nowait single-threaded/multi-threaded 10055b91f3aSGeoff Rehmet * user user to run daemon as 10155b91f3aSGeoff Rehmet * server program full path name 10255b91f3aSGeoff Rehmet * server program arguments maximum of MAXARGS 10355b91f3aSGeoff Rehmet * 104dea673e9SRodney W. Grimes * Comment lines are indicated by a `#' in column 1. 105dea673e9SRodney W. Grimes */ 106dea673e9SRodney W. Grimes #include <sys/param.h> 107dea673e9SRodney W. Grimes #include <sys/stat.h> 108dea673e9SRodney W. Grimes #include <sys/ioctl.h> 109dea673e9SRodney W. Grimes #include <sys/socket.h> 110dea673e9SRodney W. Grimes #include <sys/wait.h> 111dea673e9SRodney W. Grimes #include <sys/time.h> 112dea673e9SRodney W. Grimes #include <sys/resource.h> 113dea673e9SRodney W. Grimes 114dea673e9SRodney W. Grimes #include <netinet/in.h> 115dea673e9SRodney W. Grimes #include <arpa/inet.h> 11655b91f3aSGeoff Rehmet #include <rpc/rpc.h> 1176467602bSJulian Elischer #include <rpc/pmap_clnt.h> 118dea673e9SRodney W. Grimes 119dea673e9SRodney W. Grimes #include <errno.h> 120c1a2e93eSPhilippe Charnier #include <err.h> 121dea673e9SRodney W. Grimes #include <fcntl.h> 122b34683caSAndrey A. Chernov #include <grp.h> 123dea673e9SRodney W. Grimes #include <netdb.h> 124dea673e9SRodney W. Grimes #include <pwd.h> 125dea673e9SRodney W. Grimes #include <signal.h> 126dea673e9SRodney W. Grimes #include <stdio.h> 127dea673e9SRodney W. Grimes #include <stdlib.h> 128dea673e9SRodney W. Grimes #include <string.h> 129dea673e9SRodney W. Grimes #include <syslog.h> 130dea673e9SRodney W. Grimes #include <unistd.h> 131c1283020SPeter Wemm #include <libutil.h> 1326467602bSJulian Elischer #include <sysexits.h> 133dea673e9SRodney W. Grimes 134fbc2342cSPeter Wemm #ifdef LOGIN_CAP 135fbc2342cSPeter Wemm #include <login_cap.h> 136186a5319SAndrey A. Chernov 137186a5319SAndrey A. Chernov /* see init.c */ 138186a5319SAndrey A. Chernov #define RESOURCE_RC "daemon" 139186a5319SAndrey A. Chernov 140fbc2342cSPeter Wemm #endif 141fbc2342cSPeter Wemm 142dea673e9SRodney W. Grimes #include "pathnames.h" 143dea673e9SRodney W. Grimes 144ffb7094eSPaul Traina #ifndef MAXCHILD 145ffb7094eSPaul Traina #define MAXCHILD -1 /* maximum number of this service 146ffb7094eSPaul Traina < 0 = no limit */ 147ffb7094eSPaul Traina #endif 148ffb7094eSPaul Traina 149ffb7094eSPaul Traina #ifndef MAXCPM 150ffb7094eSPaul Traina #define MAXCPM -1 /* rate limit invocations from a 151ffb7094eSPaul Traina single remote address, 152ffb7094eSPaul Traina < 0 = no limit */ 153ffb7094eSPaul Traina #endif 154ffb7094eSPaul Traina 155bee39b42SGeoff Rehmet #define TOOMANY 256 /* don't start more than TOOMANY */ 156dea673e9SRodney W. Grimes #define CNT_INTVL 60 /* servers in CNT_INTVL sec. */ 157dea673e9SRodney W. Grimes #define RETRYTIME (60*10) /* retry after bind or server fail */ 1580661be0bSJulian Elischer #define MAX_MAXCHLD 32767 /* max allowable max children */ 159dea673e9SRodney W. Grimes 160dea673e9SRodney W. Grimes #define SIGBLOCK (sigmask(SIGCHLD)|sigmask(SIGHUP)|sigmask(SIGALRM)) 161dea673e9SRodney W. Grimes 162dea673e9SRodney W. Grimes int debug = 0; 163bee39b42SGeoff Rehmet int log = 0; 164dea673e9SRodney W. Grimes int nsock, maxsock; 165dea673e9SRodney W. Grimes fd_set allsock; 166dea673e9SRodney W. Grimes int options; 167dea673e9SRodney W. Grimes int timingout; 168dea673e9SRodney W. Grimes int toomany = TOOMANY; 169ffb7094eSPaul Traina int maxchild = MAXCPM; 170ffb7094eSPaul Traina int maxcpm = MAXCHILD; 171dea673e9SRodney W. Grimes struct servent *sp; 17255b91f3aSGeoff Rehmet struct rpcent *rpc; 1737356460fSJulian Elischer struct in_addr bind_address; 174dea673e9SRodney W. Grimes 175dea673e9SRodney W. Grimes struct servtab { 176dea673e9SRodney W. Grimes char *se_service; /* name of service */ 177dea673e9SRodney W. Grimes int se_socktype; /* type of socket to use */ 178dea673e9SRodney W. Grimes char *se_proto; /* protocol used */ 1793e2e58f1SDima Ruban int se_maxchild; /* max number of children */ 1803e2e58f1SDima Ruban int se_maxcpm; /* max connects per IP per minute */ 1813e2e58f1SDima Ruban int se_numchild; /* current number of children */ 1820661be0bSJulian Elischer pid_t *se_pids; /* array of child pids */ 183dea673e9SRodney W. Grimes char *se_user; /* user name to run as */ 184b34683caSAndrey A. Chernov char *se_group; /* group name to run as */ 185186a5319SAndrey A. Chernov #ifdef LOGIN_CAP 186186a5319SAndrey A. Chernov char *se_class; /* login class name to run with */ 187186a5319SAndrey A. Chernov #endif 188dea673e9SRodney W. Grimes struct biltin *se_bi; /* if built-in, description */ 189dea673e9SRodney W. Grimes char *se_server; /* server program */ 190dea673e9SRodney W. Grimes #define MAXARGV 20 191dea673e9SRodney W. Grimes char *se_argv[MAXARGV+1]; /* program arguments */ 192dea673e9SRodney W. Grimes int se_fd; /* open descriptor */ 193dea673e9SRodney W. Grimes struct sockaddr_in se_ctrladdr;/* bound address */ 1940661be0bSJulian Elischer u_char se_type; /* type: normal, mux, or mux+ */ 1950661be0bSJulian Elischer u_char se_checked; /* looked at during merge */ 1960661be0bSJulian Elischer u_char se_accept; /* i.e., wait/nowait mode */ 1970661be0bSJulian Elischer u_char se_rpc; /* ==1 if RPC service */ 19855b91f3aSGeoff Rehmet int se_rpc_prog; /* RPC program number */ 19955b91f3aSGeoff Rehmet u_int se_rpc_lowvers; /* RPC low version */ 20055b91f3aSGeoff Rehmet u_int se_rpc_highvers; /* RPC high version */ 201dea673e9SRodney W. Grimes int se_count; /* number started since se_time */ 202dea673e9SRodney W. Grimes struct timeval se_time; /* start of se_count */ 203dea673e9SRodney W. Grimes struct servtab *se_next; 204dea673e9SRodney W. Grimes } *servtab; 205dea673e9SRodney W. Grimes 206dea673e9SRodney W. Grimes #define NORM_TYPE 0 207dea673e9SRodney W. Grimes #define MUX_TYPE 1 208dea673e9SRodney W. Grimes #define MUXPLUS_TYPE 2 209dea673e9SRodney W. Grimes #define ISMUX(sep) (((sep)->se_type == MUX_TYPE) || \ 210dea673e9SRodney W. Grimes ((sep)->se_type == MUXPLUS_TYPE)) 211dea673e9SRodney W. Grimes #define ISMUXPLUS(sep) ((sep)->se_type == MUXPLUS_TYPE) 212dea673e9SRodney W. Grimes 213dea673e9SRodney W. Grimes 214dea673e9SRodney W. Grimes void chargen_dg __P((int, struct servtab *)); 215dea673e9SRodney W. Grimes void chargen_stream __P((int, struct servtab *)); 216dea673e9SRodney W. Grimes void close_sep __P((struct servtab *)); 217dea673e9SRodney W. Grimes void config __P((int)); 218dea673e9SRodney W. Grimes void daytime_dg __P((int, struct servtab *)); 219dea673e9SRodney W. Grimes void daytime_stream __P((int, struct servtab *)); 220dea673e9SRodney W. Grimes void discard_dg __P((int, struct servtab *)); 221dea673e9SRodney W. Grimes void discard_stream __P((int, struct servtab *)); 222dea673e9SRodney W. Grimes void echo_dg __P((int, struct servtab *)); 223dea673e9SRodney W. Grimes void echo_stream __P((int, struct servtab *)); 224dea673e9SRodney W. Grimes void endconfig __P((void)); 225dea673e9SRodney W. Grimes struct servtab *enter __P((struct servtab *)); 226dea673e9SRodney W. Grimes void freeconfig __P((struct servtab *)); 227dea673e9SRodney W. Grimes struct servtab *getconfigent __P((void)); 228dea673e9SRodney W. Grimes void machtime_dg __P((int, struct servtab *)); 229dea673e9SRodney W. Grimes void machtime_stream __P((int, struct servtab *)); 230dea673e9SRodney W. Grimes char *newstr __P((char *)); 231dea673e9SRodney W. Grimes char *nextline __P((FILE *)); 232dea673e9SRodney W. Grimes void print_service __P((char *, struct servtab *)); 2330661be0bSJulian Elischer void addchild __P((struct servtab *, int)); 234dea673e9SRodney W. Grimes void reapchild __P((int)); 2350661be0bSJulian Elischer void enable __P((struct servtab *)); 2360661be0bSJulian Elischer void disable __P((struct servtab *)); 237dea673e9SRodney W. Grimes void retry __P((int)); 238dea673e9SRodney W. Grimes int setconfig __P((void)); 239dea673e9SRodney W. Grimes void setup __P((struct servtab *)); 240dea673e9SRodney W. Grimes char *sskip __P((char **)); 241dea673e9SRodney W. Grimes char *skip __P((char **)); 242dea673e9SRodney W. Grimes struct servtab *tcpmux __P((int)); 2433e2e58f1SDima Ruban int cpmip __P((struct servtab *, int)); 244dea673e9SRodney W. Grimes 24555b91f3aSGeoff Rehmet void unregisterrpc __P((register struct servtab *sep)); 24655b91f3aSGeoff Rehmet 247dea673e9SRodney W. Grimes struct biltin { 248dea673e9SRodney W. Grimes char *bi_service; /* internally provided service name */ 249dea673e9SRodney W. Grimes int bi_socktype; /* type of socket supported */ 250dea673e9SRodney W. Grimes short bi_fork; /* 1 if should fork before call */ 2513e2e58f1SDima Ruban int bi_maxchild; /* max number of children (default) */ 252dea673e9SRodney W. Grimes void (*bi_fn)(); /* function which performs it */ 253dea673e9SRodney W. Grimes } biltins[] = { 254dea673e9SRodney W. Grimes /* Echo received data */ 255dea673e9SRodney W. Grimes { "echo", SOCK_STREAM, 1, 0, echo_stream }, 256dea673e9SRodney W. Grimes { "echo", SOCK_DGRAM, 0, 0, echo_dg }, 257dea673e9SRodney W. Grimes 258dea673e9SRodney W. Grimes /* Internet /dev/null */ 259dea673e9SRodney W. Grimes { "discard", SOCK_STREAM, 1, 0, discard_stream }, 260dea673e9SRodney W. Grimes { "discard", SOCK_DGRAM, 0, 0, discard_dg }, 261dea673e9SRodney W. Grimes 262dea673e9SRodney W. Grimes /* Return 32 bit time since 1970 */ 263dea673e9SRodney W. Grimes { "time", SOCK_STREAM, 0, 0, machtime_stream }, 264dea673e9SRodney W. Grimes { "time", SOCK_DGRAM, 0, 0, machtime_dg }, 265dea673e9SRodney W. Grimes 266dea673e9SRodney W. Grimes /* Return human-readable time */ 267dea673e9SRodney W. Grimes { "daytime", SOCK_STREAM, 0, 0, daytime_stream }, 268dea673e9SRodney W. Grimes { "daytime", SOCK_DGRAM, 0, 0, daytime_dg }, 269dea673e9SRodney W. Grimes 270dea673e9SRodney W. Grimes /* Familiar character generator */ 271dea673e9SRodney W. Grimes { "chargen", SOCK_STREAM, 1, 0, chargen_stream }, 272dea673e9SRodney W. Grimes { "chargen", SOCK_DGRAM, 0, 0, chargen_dg }, 273dea673e9SRodney W. Grimes 274dea673e9SRodney W. Grimes { "tcpmux", SOCK_STREAM, 1, 0, (void (*)())tcpmux }, 275dea673e9SRodney W. Grimes 276dea673e9SRodney W. Grimes { NULL } 277dea673e9SRodney W. Grimes }; 278dea673e9SRodney W. Grimes 279dea673e9SRodney W. Grimes #define NUMINT (sizeof(intab) / sizeof(struct inent)) 280dea673e9SRodney W. Grimes char *CONFIG = _PATH_INETDCONF; 2817356460fSJulian Elischer char *pid_file = _PATH_INETDPID; 282c1283020SPeter Wemm 283c1283020SPeter Wemm #ifdef OLD_SETPROCTITLE 284dea673e9SRodney W. Grimes char **Argv; 285dea673e9SRodney W. Grimes char *LastArg; 286c1283020SPeter Wemm #endif 287dea673e9SRodney W. Grimes 288dea673e9SRodney W. Grimes int 289ffb7094eSPaul Traina getvalue(arg, value, whine) 290ffb7094eSPaul Traina char *arg, *whine; 291ffb7094eSPaul Traina int *value; 292ffb7094eSPaul Traina { 293ffb7094eSPaul Traina int tmp; 294ffb7094eSPaul Traina char *p; 295ffb7094eSPaul Traina 296ffb7094eSPaul Traina tmp = strtol(arg, &p, 0); 297ffb7094eSPaul Traina if (tmp < 1 || *p) { 298ffb7094eSPaul Traina syslog(LOG_ERR, whine, arg); 299ffb7094eSPaul Traina return 1; /* failure */ 300ffb7094eSPaul Traina } 301ffb7094eSPaul Traina *value = tmp; 302ffb7094eSPaul Traina return 0; /* success */ 303ffb7094eSPaul Traina } 304ffb7094eSPaul Traina 305ffb7094eSPaul Traina int 306dea673e9SRodney W. Grimes main(argc, argv, envp) 307dea673e9SRodney W. Grimes int argc; 308dea673e9SRodney W. Grimes char *argv[], *envp[]; 309dea673e9SRodney W. Grimes { 310dea673e9SRodney W. Grimes struct servtab *sep; 311dea673e9SRodney W. Grimes struct passwd *pwd; 312b34683caSAndrey A. Chernov struct group *grp; 313dea673e9SRodney W. Grimes struct sigvec sv; 314dea673e9SRodney W. Grimes int tmpint, ch, dofork; 315dea673e9SRodney W. Grimes pid_t pid; 316dea673e9SRodney W. Grimes char buf[50]; 317bee39b42SGeoff Rehmet struct sockaddr_in peer; 318bee39b42SGeoff Rehmet int i; 319fbc2342cSPeter Wemm #ifdef LOGIN_CAP 320fbc2342cSPeter Wemm login_cap_t *lc = NULL; 321fbc2342cSPeter Wemm #endif 322dea673e9SRodney W. Grimes 323c1283020SPeter Wemm 324c1283020SPeter Wemm #ifdef OLD_SETPROCTITLE 325dea673e9SRodney W. Grimes Argv = argv; 326dea673e9SRodney W. Grimes if (envp == 0 || *envp == 0) 327dea673e9SRodney W. Grimes envp = argv; 328dea673e9SRodney W. Grimes while (*envp) 329dea673e9SRodney W. Grimes envp++; 330dea673e9SRodney W. Grimes LastArg = envp[-1] + strlen(envp[-1]); 331c1283020SPeter Wemm #endif 332dea673e9SRodney W. Grimes 333dea673e9SRodney W. Grimes openlog("inetd", LOG_PID | LOG_NOWAIT, LOG_DAEMON); 334dea673e9SRodney W. Grimes 3357356460fSJulian Elischer bind_address.s_addr = htonl(INADDR_ANY); 336ffb7094eSPaul Traina while ((ch = getopt(argc, argv, "dlR:a:c:C:p:")) != -1) 337dea673e9SRodney W. Grimes switch(ch) { 338dea673e9SRodney W. Grimes case 'd': 339dea673e9SRodney W. Grimes debug = 1; 340dea673e9SRodney W. Grimes options |= SO_DEBUG; 341dea673e9SRodney W. Grimes break; 342bee39b42SGeoff Rehmet case 'l': 343bee39b42SGeoff Rehmet log = 1; 344bee39b42SGeoff Rehmet break; 345ffb7094eSPaul Traina case 'R': 346ffb7094eSPaul Traina getvalue(optarg, &toomany, 347ffb7094eSPaul Traina "-R %s: bad value for service invocation rate"); 348dea673e9SRodney W. Grimes break; 349ffb7094eSPaul Traina case 'c': 350ffb7094eSPaul Traina getvalue(optarg, &maxchild, 351ffb7094eSPaul Traina "-c %s: bad value for maximum children"); 352ffb7094eSPaul Traina break; 353ffb7094eSPaul Traina case 'C': 354ffb7094eSPaul Traina getvalue(optarg, &maxcpm, 355ffb7094eSPaul Traina "-C %s: bad value for maximum children/minute"); 356ffb7094eSPaul Traina break; 3577356460fSJulian Elischer case 'a': 3587356460fSJulian Elischer if (!inet_aton(optarg, &bind_address)) { 3597356460fSJulian Elischer syslog(LOG_ERR, 3607356460fSJulian Elischer "-a %s: invalid IP address", optarg); 3616467602bSJulian Elischer exit(EX_USAGE); 3627356460fSJulian Elischer } 3637356460fSJulian Elischer break; 3647356460fSJulian Elischer case 'p': 3657356460fSJulian Elischer pid_file = optarg; 3667356460fSJulian Elischer break; 367dea673e9SRodney W. Grimes case '?': 368dea673e9SRodney W. Grimes default: 369dea673e9SRodney W. Grimes syslog(LOG_ERR, 3707356460fSJulian Elischer "usage: inetd [-dl] [-a address] [-R rate]" 371ffb7094eSPaul Traina " [-c maximum] [-C rate]" 3727356460fSJulian Elischer " [-p pidfile] [conf-file]"); 3736467602bSJulian Elischer exit(EX_USAGE); 374dea673e9SRodney W. Grimes } 375dea673e9SRodney W. Grimes argc -= optind; 376dea673e9SRodney W. Grimes argv += optind; 377dea673e9SRodney W. Grimes 378dea673e9SRodney W. Grimes if (argc > 0) 379dea673e9SRodney W. Grimes CONFIG = argv[0]; 380dea673e9SRodney W. Grimes if (debug == 0) { 3819fe96cbbSGarrett Wollman FILE *fp; 38284c60f0dSPeter Wemm if (daemon(0, 0) < 0) { 38384c60f0dSPeter Wemm syslog(LOG_WARNING, "daemon(0,0) failed: %m"); 38484c60f0dSPeter Wemm } 38584c60f0dSPeter Wemm /* 38684c60f0dSPeter Wemm * In case somebody has started inetd manually, we need to 38784c60f0dSPeter Wemm * clear the logname, so that old servers run as root do not 38884c60f0dSPeter Wemm * get the user's logname.. 38984c60f0dSPeter Wemm */ 39084c60f0dSPeter Wemm if (setlogin("") < 0) { 39184c60f0dSPeter Wemm syslog(LOG_WARNING, "cannot clear logname: %m"); 39284c60f0dSPeter Wemm /* no big deal if it fails.. */ 39384c60f0dSPeter Wemm } 3949fe96cbbSGarrett Wollman pid = getpid(); 3957356460fSJulian Elischer fp = fopen(pid_file, "w"); 3969fe96cbbSGarrett Wollman if (fp) { 3979fe96cbbSGarrett Wollman fprintf(fp, "%ld\n", (long)pid); 3989fe96cbbSGarrett Wollman fclose(fp); 3999fe96cbbSGarrett Wollman } else { 4007356460fSJulian Elischer syslog(LOG_WARNING, "%s: %m", pid_file); 4019fe96cbbSGarrett Wollman } 402dea673e9SRodney W. Grimes } 403dea673e9SRodney W. Grimes memset(&sv, 0, sizeof(sv)); 404dea673e9SRodney W. Grimes sv.sv_mask = SIGBLOCK; 405dea673e9SRodney W. Grimes sv.sv_handler = retry; 406dea673e9SRodney W. Grimes sigvec(SIGALRM, &sv, (struct sigvec *)0); 407dea673e9SRodney W. Grimes config(SIGHUP); 408dea673e9SRodney W. Grimes sv.sv_handler = config; 409dea673e9SRodney W. Grimes sigvec(SIGHUP, &sv, (struct sigvec *)0); 410dea673e9SRodney W. Grimes sv.sv_handler = reapchild; 411dea673e9SRodney W. Grimes sigvec(SIGCHLD, &sv, (struct sigvec *)0); 41234b32a7cSGuido van Rooij sv.sv_handler = SIG_IGN; 41334b32a7cSGuido van Rooij sigvec(SIGPIPE, &sv, (struct sigvec *)0); 414dea673e9SRodney W. Grimes 415dea673e9SRodney W. Grimes { 416dea673e9SRodney W. Grimes /* space for daemons to overwrite environment for ps */ 417dea673e9SRodney W. Grimes #define DUMMYSIZE 100 418dea673e9SRodney W. Grimes char dummy[DUMMYSIZE]; 419dea673e9SRodney W. Grimes 4209e375707SAlexander Langer (void)memset(dummy, 'x', DUMMYSIZE - 1); 421dea673e9SRodney W. Grimes dummy[DUMMYSIZE - 1] = '\0'; 422dea673e9SRodney W. Grimes (void)setenv("inetd_dummy", dummy, 1); 423dea673e9SRodney W. Grimes } 424dea673e9SRodney W. Grimes 425dea673e9SRodney W. Grimes for (;;) { 426dea673e9SRodney W. Grimes int n, ctrl; 427dea673e9SRodney W. Grimes fd_set readable; 428dea673e9SRodney W. Grimes 429dea673e9SRodney W. Grimes if (nsock == 0) { 430dea673e9SRodney W. Grimes (void) sigblock(SIGBLOCK); 431dea673e9SRodney W. Grimes while (nsock == 0) 432dea673e9SRodney W. Grimes sigpause(0L); 433dea673e9SRodney W. Grimes (void) sigsetmask(0L); 434dea673e9SRodney W. Grimes } 435dea673e9SRodney W. Grimes readable = allsock; 436dea673e9SRodney W. Grimes if ((n = select(maxsock + 1, &readable, (fd_set *)0, 437dea673e9SRodney W. Grimes (fd_set *)0, (struct timeval *)0)) <= 0) { 43883eea896SWarner Losh if (n < 0 && errno != EINTR) { 439dea673e9SRodney W. Grimes syslog(LOG_WARNING, "select: %m"); 440dea673e9SRodney W. Grimes sleep(1); 44183eea896SWarner Losh } 442dea673e9SRodney W. Grimes continue; 443dea673e9SRodney W. Grimes } 444dea673e9SRodney W. Grimes for (sep = servtab; n && sep; sep = sep->se_next) 445dea673e9SRodney W. Grimes if (sep->se_fd != -1 && FD_ISSET(sep->se_fd, &readable)) { 446dea673e9SRodney W. Grimes n--; 447dea673e9SRodney W. Grimes if (debug) 448c1a2e93eSPhilippe Charnier warnx("someone wants %s", sep->se_service); 4490661be0bSJulian Elischer if (sep->se_accept && sep->se_socktype == SOCK_STREAM) { 450dea673e9SRodney W. Grimes ctrl = accept(sep->se_fd, (struct sockaddr *)0, 451dea673e9SRodney W. Grimes (int *)0); 452dea673e9SRodney W. Grimes if (debug) 453c1a2e93eSPhilippe Charnier warnx("accept, ctrl %d", ctrl); 454dea673e9SRodney W. Grimes if (ctrl < 0) { 455dea673e9SRodney W. Grimes if (errno != EINTR) 456dea673e9SRodney W. Grimes syslog(LOG_WARNING, 457dea673e9SRodney W. Grimes "accept (for %s): %m", 458dea673e9SRodney W. Grimes sep->se_service); 459dea673e9SRodney W. Grimes continue; 460dea673e9SRodney W. Grimes } 4613e2e58f1SDima Ruban if (cpmip(sep, ctrl) < 0) { 4623e2e58f1SDima Ruban close(ctrl); 4633e2e58f1SDima Ruban continue; 4643e2e58f1SDima Ruban } 465bee39b42SGeoff Rehmet if (log) { 466bee39b42SGeoff Rehmet i = sizeof peer; 467bee39b42SGeoff Rehmet if (getpeername(ctrl, (struct sockaddr *) 468bee39b42SGeoff Rehmet &peer, &i)) { 469bee39b42SGeoff Rehmet syslog(LOG_WARNING, 470bee39b42SGeoff Rehmet "getpeername(for %s): %m", 471bee39b42SGeoff Rehmet sep->se_service); 4723e2e58f1SDima Ruban close(ctrl); 473bee39b42SGeoff Rehmet continue; 474bee39b42SGeoff Rehmet } 475bee39b42SGeoff Rehmet syslog(LOG_INFO,"%s from %s", 476bee39b42SGeoff Rehmet sep->se_service, 477bee39b42SGeoff Rehmet inet_ntoa(peer.sin_addr)); 478bee39b42SGeoff Rehmet } 479dea673e9SRodney W. Grimes } else 480dea673e9SRodney W. Grimes ctrl = sep->se_fd; 481dea673e9SRodney W. Grimes (void) sigblock(SIGBLOCK); 482dea673e9SRodney W. Grimes pid = 0; 483dea673e9SRodney W. Grimes dofork = (sep->se_bi == 0 || sep->se_bi->bi_fork); 484dea673e9SRodney W. Grimes if (dofork) { 485dea673e9SRodney W. Grimes if (sep->se_count++ == 0) 486dea673e9SRodney W. Grimes (void)gettimeofday(&sep->se_time, 487dea673e9SRodney W. Grimes (struct timezone *)0); 488dea673e9SRodney W. Grimes else if (sep->se_count >= toomany) { 489dea673e9SRodney W. Grimes struct timeval now; 490dea673e9SRodney W. Grimes 491dea673e9SRodney W. Grimes (void)gettimeofday(&now, (struct timezone *)0); 492dea673e9SRodney W. Grimes if (now.tv_sec - sep->se_time.tv_sec > 493dea673e9SRodney W. Grimes CNT_INTVL) { 494dea673e9SRodney W. Grimes sep->se_time = now; 495dea673e9SRodney W. Grimes sep->se_count = 1; 496dea673e9SRodney W. Grimes } else { 497dea673e9SRodney W. Grimes syslog(LOG_ERR, 498dea673e9SRodney W. Grimes "%s/%s server failing (looping), service terminated", 499dea673e9SRodney W. Grimes sep->se_service, sep->se_proto); 500dea673e9SRodney W. Grimes close_sep(sep); 501dea673e9SRodney W. Grimes sigsetmask(0L); 502dea673e9SRodney W. Grimes if (!timingout) { 503dea673e9SRodney W. Grimes timingout = 1; 504dea673e9SRodney W. Grimes alarm(RETRYTIME); 505dea673e9SRodney W. Grimes } 506dea673e9SRodney W. Grimes continue; 507dea673e9SRodney W. Grimes } 508dea673e9SRodney W. Grimes } 509dea673e9SRodney W. Grimes pid = fork(); 510dea673e9SRodney W. Grimes } 511dea673e9SRodney W. Grimes if (pid < 0) { 512dea673e9SRodney W. Grimes syslog(LOG_ERR, "fork: %m"); 5130661be0bSJulian Elischer if (sep->se_accept && 514dea673e9SRodney W. Grimes sep->se_socktype == SOCK_STREAM) 515dea673e9SRodney W. Grimes close(ctrl); 516dea673e9SRodney W. Grimes sigsetmask(0L); 517dea673e9SRodney W. Grimes sleep(1); 518dea673e9SRodney W. Grimes continue; 519dea673e9SRodney W. Grimes } 5200661be0bSJulian Elischer if (pid) 5210661be0bSJulian Elischer addchild(sep, pid); 522dea673e9SRodney W. Grimes sigsetmask(0L); 523dea673e9SRodney W. Grimes if (pid == 0) { 524dea673e9SRodney W. Grimes if (dofork) { 525dea673e9SRodney W. Grimes if (debug) 526c1a2e93eSPhilippe Charnier warnx("+ closing from %d", maxsock); 527dea673e9SRodney W. Grimes for (tmpint = maxsock; tmpint > 2; tmpint--) 528dea673e9SRodney W. Grimes if (tmpint != ctrl) 5296467602bSJulian Elischer (void) close(tmpint); 530dea673e9SRodney W. Grimes } 53134b32a7cSGuido van Rooij /* 53234b32a7cSGuido van Rooij * Call tcpmux to find the real service to exec. 53334b32a7cSGuido van Rooij */ 53434b32a7cSGuido van Rooij if (sep->se_bi && 53534b32a7cSGuido van Rooij sep->se_bi->bi_fn == (void (*)()) tcpmux) { 53634b32a7cSGuido van Rooij sep = tcpmux(ctrl); 53734b32a7cSGuido van Rooij if (sep == NULL) { 53834b32a7cSGuido van Rooij close(ctrl); 53934b32a7cSGuido van Rooij _exit(0); 54034b32a7cSGuido van Rooij } 54134b32a7cSGuido van Rooij } 5426467602bSJulian Elischer if (sep->se_bi) { 543dea673e9SRodney W. Grimes (*sep->se_bi->bi_fn)(ctrl, sep); 5446467602bSJulian Elischer /* NOTREACHED */ 5456467602bSJulian Elischer } else { 546dea673e9SRodney W. Grimes if (debug) 547c1a2e93eSPhilippe Charnier warnx("%d execl %s", 548dea673e9SRodney W. Grimes getpid(), sep->se_server); 549dea673e9SRodney W. Grimes dup2(ctrl, 0); 550dea673e9SRodney W. Grimes close(ctrl); 551dea673e9SRodney W. Grimes dup2(0, 1); 552dea673e9SRodney W. Grimes dup2(0, 2); 553dea673e9SRodney W. Grimes if ((pwd = getpwnam(sep->se_user)) == NULL) { 554dea673e9SRodney W. Grimes syslog(LOG_ERR, 555dea673e9SRodney W. Grimes "%s/%s: %s: No such user", 556dea673e9SRodney W. Grimes sep->se_service, sep->se_proto, 557dea673e9SRodney W. Grimes sep->se_user); 558dea673e9SRodney W. Grimes if (sep->se_socktype != SOCK_STREAM) 559dea673e9SRodney W. Grimes recv(0, buf, sizeof (buf), 0); 5606467602bSJulian Elischer _exit(EX_NOUSER); 561dea673e9SRodney W. Grimes } 562b34683caSAndrey A. Chernov grp = NULL; 563b34683caSAndrey A. Chernov if ( sep->se_group != NULL 564b34683caSAndrey A. Chernov && (grp = getgrnam(sep->se_group)) == NULL 565b34683caSAndrey A. Chernov ) { 566b34683caSAndrey A. Chernov syslog(LOG_ERR, 567b34683caSAndrey A. Chernov "%s/%s: %s: No such group", 568b34683caSAndrey A. Chernov sep->se_service, sep->se_proto, 569b34683caSAndrey A. Chernov sep->se_group); 570b34683caSAndrey A. Chernov if (sep->se_socktype != SOCK_STREAM) 571b34683caSAndrey A. Chernov recv(0, buf, sizeof (buf), 0); 572b34683caSAndrey A. Chernov _exit(EX_NOUSER); 573b34683caSAndrey A. Chernov } 574b34683caSAndrey A. Chernov if (grp != NULL) 575b34683caSAndrey A. Chernov pwd->pw_gid = grp->gr_gid; 576fbc2342cSPeter Wemm #ifdef LOGIN_CAP 577186a5319SAndrey A. Chernov if ((lc = login_getclass(sep->se_class)) == NULL) { 578186a5319SAndrey A. Chernov /* error syslogged by getclass */ 579186a5319SAndrey A. Chernov syslog(LOG_ERR, 580186a5319SAndrey A. Chernov "%s/%s: %s: login class error", 581186a5319SAndrey A. Chernov sep->se_service, sep->se_proto); 582186a5319SAndrey A. Chernov if (sep->se_socktype != SOCK_STREAM) 583186a5319SAndrey A. Chernov recv(0, buf, sizeof (buf), 0); 584186a5319SAndrey A. Chernov _exit(EX_NOUSER); 585186a5319SAndrey A. Chernov } 586fbc2342cSPeter Wemm #endif 58784c60f0dSPeter Wemm if (setsid() < 0) { 58884c60f0dSPeter Wemm syslog(LOG_ERR, 58984c60f0dSPeter Wemm "%s: can't setsid(): %m", 59084c60f0dSPeter Wemm sep->se_service); 5916467602bSJulian Elischer /* _exit(EX_OSERR); not fatal yet */ 59284c60f0dSPeter Wemm } 593fbc2342cSPeter Wemm #ifdef LOGIN_CAP 594fbc2342cSPeter Wemm if (setusercontext(lc, pwd, pwd->pw_uid, 595fbc2342cSPeter Wemm LOGIN_SETALL) != 0) { 596fbc2342cSPeter Wemm syslog(LOG_ERR, 597fbc2342cSPeter Wemm "%s: can't setusercontext(..%s..): %m", 598fbc2342cSPeter Wemm sep->se_service, sep->se_user); 599fbc2342cSPeter Wemm _exit(EX_OSERR); 600fbc2342cSPeter Wemm } 601fbc2342cSPeter Wemm #else 602dea673e9SRodney W. Grimes if (pwd->pw_uid) { 60384c60f0dSPeter Wemm if (setlogin(sep->se_user) < 0) { 60484c60f0dSPeter Wemm syslog(LOG_ERR, 60584c60f0dSPeter Wemm "%s: can't setlogin(%s): %m", 60684c60f0dSPeter Wemm sep->se_service, sep->se_user); 6076467602bSJulian Elischer /* _exit(EX_OSERR); not yet */ 60884c60f0dSPeter Wemm } 609dea673e9SRodney W. Grimes if (setgid(pwd->pw_gid) < 0) { 610dea673e9SRodney W. Grimes syslog(LOG_ERR, 611dea673e9SRodney W. Grimes "%s: can't set gid %d: %m", 612dea673e9SRodney W. Grimes sep->se_service, pwd->pw_gid); 6136467602bSJulian Elischer _exit(EX_OSERR); 614dea673e9SRodney W. Grimes } 615dea673e9SRodney W. Grimes (void) initgroups(pwd->pw_name, 616dea673e9SRodney W. Grimes pwd->pw_gid); 617dea673e9SRodney W. Grimes if (setuid(pwd->pw_uid) < 0) { 618dea673e9SRodney W. Grimes syslog(LOG_ERR, 619dea673e9SRodney W. Grimes "%s: can't set uid %d: %m", 620dea673e9SRodney W. Grimes sep->se_service, pwd->pw_uid); 6216467602bSJulian Elischer _exit(EX_OSERR); 622dea673e9SRodney W. Grimes } 623dea673e9SRodney W. Grimes } 624fbc2342cSPeter Wemm #endif 625dea673e9SRodney W. Grimes execv(sep->se_server, sep->se_argv); 626dea673e9SRodney W. Grimes if (sep->se_socktype != SOCK_STREAM) 627dea673e9SRodney W. Grimes recv(0, buf, sizeof (buf), 0); 628dea673e9SRodney W. Grimes syslog(LOG_ERR, 629dea673e9SRodney W. Grimes "cannot execute %s: %m", sep->se_server); 6306467602bSJulian Elischer _exit(EX_OSERR); 631dea673e9SRodney W. Grimes } 632dea673e9SRodney W. Grimes } 6330661be0bSJulian Elischer if (sep->se_accept && sep->se_socktype == SOCK_STREAM) 634dea673e9SRodney W. Grimes close(ctrl); 635dea673e9SRodney W. Grimes } 636dea673e9SRodney W. Grimes } 637dea673e9SRodney W. Grimes } 638dea673e9SRodney W. Grimes 6390661be0bSJulian Elischer /* 6400661be0bSJulian Elischer * Record a new child pid for this service. If we've reached the 6410661be0bSJulian Elischer * limit on children, then stop accepting incoming requests. 6420661be0bSJulian Elischer */ 6430661be0bSJulian Elischer 6440661be0bSJulian Elischer void 6450661be0bSJulian Elischer addchild(struct servtab *sep, pid_t pid) 6460661be0bSJulian Elischer { 6470661be0bSJulian Elischer #ifdef SANITY_CHECK 6480661be0bSJulian Elischer if (sep->se_numchild >= sep->se_maxchild) { 6490661be0bSJulian Elischer syslog(LOG_ERR, "%s: %d >= %d", 6500661be0bSJulian Elischer __FUNCTION__, sep->se_numchild, sep->se_maxchild); 6510661be0bSJulian Elischer exit(EX_SOFTWARE); 6520661be0bSJulian Elischer } 6530661be0bSJulian Elischer #endif 6540661be0bSJulian Elischer if (sep->se_maxchild == 0) 6550661be0bSJulian Elischer return; 6560661be0bSJulian Elischer sep->se_pids[sep->se_numchild++] = pid; 6570661be0bSJulian Elischer if (sep->se_numchild == sep->se_maxchild) 6580661be0bSJulian Elischer disable(sep); 6590661be0bSJulian Elischer } 6600661be0bSJulian Elischer 6610661be0bSJulian Elischer /* 6620661be0bSJulian Elischer * Some child process has exited. See if it's on somebody's list. 6630661be0bSJulian Elischer */ 6640661be0bSJulian Elischer 665dea673e9SRodney W. Grimes void 666dea673e9SRodney W. Grimes reapchild(signo) 667dea673e9SRodney W. Grimes int signo; 668dea673e9SRodney W. Grimes { 6690661be0bSJulian Elischer int k, status; 670dea673e9SRodney W. Grimes pid_t pid; 671dea673e9SRodney W. Grimes struct servtab *sep; 672dea673e9SRodney W. Grimes 673dea673e9SRodney W. Grimes for (;;) { 674dea673e9SRodney W. Grimes pid = wait3(&status, WNOHANG, (struct rusage *)0); 675dea673e9SRodney W. Grimes if (pid <= 0) 676dea673e9SRodney W. Grimes break; 677dea673e9SRodney W. Grimes if (debug) 678c1a2e93eSPhilippe Charnier warnx("%d reaped, status %#x", pid, status); 6790661be0bSJulian Elischer for (sep = servtab; sep; sep = sep->se_next) { 6800661be0bSJulian Elischer for (k = 0; k < sep->se_numchild; k++) 6810661be0bSJulian Elischer if (sep->se_pids[k] == pid) 6820661be0bSJulian Elischer break; 6830661be0bSJulian Elischer if (k == sep->se_numchild) 6840661be0bSJulian Elischer continue; 6850661be0bSJulian Elischer if (sep->se_numchild == sep->se_maxchild) 6860661be0bSJulian Elischer enable(sep); 6870661be0bSJulian Elischer sep->se_pids[k] = sep->se_pids[--sep->se_numchild]; 688dea673e9SRodney W. Grimes if (status) 689dea673e9SRodney W. Grimes syslog(LOG_WARNING, 6900661be0bSJulian Elischer "%s[%d]: exit status 0x%x", 6910661be0bSJulian Elischer sep->se_server, pid, status); 6920661be0bSJulian Elischer break; 693dea673e9SRodney W. Grimes } 694dea673e9SRodney W. Grimes } 695dea673e9SRodney W. Grimes } 696dea673e9SRodney W. Grimes 697dea673e9SRodney W. Grimes void 698dea673e9SRodney W. Grimes config(signo) 699dea673e9SRodney W. Grimes int signo; 700dea673e9SRodney W. Grimes { 7010661be0bSJulian Elischer struct servtab *sep, *new, **sepp; 702dea673e9SRodney W. Grimes long omask; 703dea673e9SRodney W. Grimes 704dea673e9SRodney W. Grimes if (!setconfig()) { 705dea673e9SRodney W. Grimes syslog(LOG_ERR, "%s: %m", CONFIG); 706dea673e9SRodney W. Grimes return; 707dea673e9SRodney W. Grimes } 708dea673e9SRodney W. Grimes for (sep = servtab; sep; sep = sep->se_next) 709dea673e9SRodney W. Grimes sep->se_checked = 0; 7100661be0bSJulian Elischer while ((new = getconfigent())) { 711b34683caSAndrey A. Chernov if (getpwnam(new->se_user) == NULL) { 712dea673e9SRodney W. Grimes syslog(LOG_ERR, 713dea673e9SRodney W. Grimes "%s/%s: No such user '%s', service ignored", 7140661be0bSJulian Elischer new->se_service, new->se_proto, new->se_user); 715dea673e9SRodney W. Grimes continue; 716dea673e9SRodney W. Grimes } 717b34683caSAndrey A. Chernov if (new->se_group && getgrnam(new->se_group) == NULL) { 718b34683caSAndrey A. Chernov syslog(LOG_ERR, 719b34683caSAndrey A. Chernov "%s/%s: No such group '%s', service ignored", 720b34683caSAndrey A. Chernov new->se_service, new->se_proto, new->se_group); 721b34683caSAndrey A. Chernov continue; 722b34683caSAndrey A. Chernov } 723186a5319SAndrey A. Chernov #ifdef LOGIN_CAP 724186a5319SAndrey A. Chernov if (login_getclass(new->se_class) == NULL) { 725186a5319SAndrey A. Chernov /* error syslogged by getclass */ 726186a5319SAndrey A. Chernov syslog(LOG_ERR, 727186a5319SAndrey A. Chernov "%s/%s: login class error, service ignored", 728186a5319SAndrey A. Chernov new->se_service, new->se_proto); 729186a5319SAndrey A. Chernov continue; 730186a5319SAndrey A. Chernov } 731186a5319SAndrey A. Chernov #endif 732dea673e9SRodney W. Grimes for (sep = servtab; sep; sep = sep->se_next) 7330661be0bSJulian Elischer if (strcmp(sep->se_service, new->se_service) == 0 && 7340661be0bSJulian Elischer strcmp(sep->se_proto, new->se_proto) == 0) 735dea673e9SRodney W. Grimes break; 736dea673e9SRodney W. Grimes if (sep != 0) { 737dea673e9SRodney W. Grimes int i; 738dea673e9SRodney W. Grimes 7390661be0bSJulian Elischer #define SWAP(a, b) { typeof(a) c = a; a = b; b = c; } 740dea673e9SRodney W. Grimes omask = sigblock(SIGBLOCK); 7410661be0bSJulian Elischer /* copy over outstanding child pids */ 7420661be0bSJulian Elischer if (sep->se_maxchild && new->se_maxchild) { 7430661be0bSJulian Elischer new->se_numchild = sep->se_numchild; 7440661be0bSJulian Elischer if (new->se_numchild > new->se_maxchild) 7450661be0bSJulian Elischer new->se_numchild = new->se_maxchild; 7460661be0bSJulian Elischer memcpy(new->se_pids, sep->se_pids, 7470661be0bSJulian Elischer new->se_numchild * sizeof(*new->se_pids)); 7480661be0bSJulian Elischer } 7490661be0bSJulian Elischer SWAP(sep->se_pids, new->se_pids); 7500661be0bSJulian Elischer sep->se_maxchild = new->se_maxchild; 7510661be0bSJulian Elischer sep->se_numchild = new->se_numchild; 7523e2e58f1SDima Ruban sep->se_maxcpm = new->se_maxcpm; 7530661be0bSJulian Elischer /* might need to turn on or off service now */ 7540661be0bSJulian Elischer if (sep->se_fd >= 0) { 7550661be0bSJulian Elischer if (sep->se_maxchild 7560661be0bSJulian Elischer && sep->se_numchild == sep->se_maxchild) { 7570661be0bSJulian Elischer if (FD_ISSET(sep->se_fd, &allsock)) 7580661be0bSJulian Elischer disable(sep); 7590661be0bSJulian Elischer } else { 7600661be0bSJulian Elischer if (!FD_ISSET(sep->se_fd, &allsock)) 7610661be0bSJulian Elischer enable(sep); 7620661be0bSJulian Elischer } 7630661be0bSJulian Elischer } 7640661be0bSJulian Elischer sep->se_accept = new->se_accept; 7650661be0bSJulian Elischer SWAP(sep->se_user, new->se_user); 766b34683caSAndrey A. Chernov SWAP(sep->se_group, new->se_group); 767186a5319SAndrey A. Chernov #ifdef LOGIN_CAP 768186a5319SAndrey A. Chernov SWAP(sep->se_class, new->se_class); 769186a5319SAndrey A. Chernov #endif 7700661be0bSJulian Elischer SWAP(sep->se_server, new->se_server); 771dea673e9SRodney W. Grimes for (i = 0; i < MAXARGV; i++) 7720661be0bSJulian Elischer SWAP(sep->se_argv[i], new->se_argv[i]); 773dea673e9SRodney W. Grimes sigsetmask(omask); 7740661be0bSJulian Elischer freeconfig(new); 775dea673e9SRodney W. Grimes if (debug) 776dea673e9SRodney W. Grimes print_service("REDO", sep); 777dea673e9SRodney W. Grimes } else { 7780661be0bSJulian Elischer sep = enter(new); 779dea673e9SRodney W. Grimes if (debug) 780dea673e9SRodney W. Grimes print_service("ADD ", sep); 781dea673e9SRodney W. Grimes } 782dea673e9SRodney W. Grimes sep->se_checked = 1; 783dea673e9SRodney W. Grimes if (ISMUX(sep)) { 784dea673e9SRodney W. Grimes sep->se_fd = -1; 785dea673e9SRodney W. Grimes continue; 786dea673e9SRodney W. Grimes } 78755b91f3aSGeoff Rehmet if (!sep->se_rpc) { 788dea673e9SRodney W. Grimes sp = getservbyname(sep->se_service, sep->se_proto); 789dea673e9SRodney W. Grimes if (sp == 0) { 790dea673e9SRodney W. Grimes syslog(LOG_ERR, "%s/%s: unknown service", 791dea673e9SRodney W. Grimes sep->se_service, sep->se_proto); 792dea673e9SRodney W. Grimes sep->se_checked = 0; 793dea673e9SRodney W. Grimes continue; 794dea673e9SRodney W. Grimes } 795dea673e9SRodney W. Grimes if (sp->s_port != sep->se_ctrladdr.sin_port) { 796dea673e9SRodney W. Grimes sep->se_ctrladdr.sin_family = AF_INET; 797fb425165SJulian Elischer sep->se_ctrladdr.sin_addr = bind_address; 798dea673e9SRodney W. Grimes sep->se_ctrladdr.sin_port = sp->s_port; 799dea673e9SRodney W. Grimes if (sep->se_fd >= 0) 800dea673e9SRodney W. Grimes close_sep(sep); 801dea673e9SRodney W. Grimes } 80255b91f3aSGeoff Rehmet } else { 80355b91f3aSGeoff Rehmet rpc = getrpcbyname(sep->se_service); 80455b91f3aSGeoff Rehmet if (rpc == 0) { 80555b91f3aSGeoff Rehmet syslog(LOG_ERR, "%s/%s unknown RPC service.", 80655b91f3aSGeoff Rehmet sep->se_service, sep->se_proto); 80755b91f3aSGeoff Rehmet if (sep->se_fd != -1) 80855b91f3aSGeoff Rehmet (void) close(sep->se_fd); 80955b91f3aSGeoff Rehmet sep->se_fd = -1; 81055b91f3aSGeoff Rehmet continue; 81155b91f3aSGeoff Rehmet } 81255b91f3aSGeoff Rehmet if (rpc->r_number != sep->se_rpc_prog) { 81355b91f3aSGeoff Rehmet if (sep->se_rpc_prog) 81455b91f3aSGeoff Rehmet unregisterrpc(sep); 81555b91f3aSGeoff Rehmet sep->se_rpc_prog = rpc->r_number; 81655b91f3aSGeoff Rehmet if (sep->se_fd != -1) 81755b91f3aSGeoff Rehmet (void) close(sep->se_fd); 81855b91f3aSGeoff Rehmet sep->se_fd = -1; 81955b91f3aSGeoff Rehmet } 82055b91f3aSGeoff Rehmet } 821dea673e9SRodney W. Grimes if (sep->se_fd == -1) 822dea673e9SRodney W. Grimes setup(sep); 823dea673e9SRodney W. Grimes } 824dea673e9SRodney W. Grimes endconfig(); 825dea673e9SRodney W. Grimes /* 826dea673e9SRodney W. Grimes * Purge anything not looked at above. 827dea673e9SRodney W. Grimes */ 828dea673e9SRodney W. Grimes omask = sigblock(SIGBLOCK); 829dea673e9SRodney W. Grimes sepp = &servtab; 8306467602bSJulian Elischer while ((sep = *sepp)) { 831dea673e9SRodney W. Grimes if (sep->se_checked) { 832dea673e9SRodney W. Grimes sepp = &sep->se_next; 833dea673e9SRodney W. Grimes continue; 834dea673e9SRodney W. Grimes } 835dea673e9SRodney W. Grimes *sepp = sep->se_next; 836dea673e9SRodney W. Grimes if (sep->se_fd >= 0) 837dea673e9SRodney W. Grimes close_sep(sep); 838dea673e9SRodney W. Grimes if (debug) 839dea673e9SRodney W. Grimes print_service("FREE", sep); 84055b91f3aSGeoff Rehmet if (sep->se_rpc && sep->se_rpc_prog > 0) 84155b91f3aSGeoff Rehmet unregisterrpc(sep); 842dea673e9SRodney W. Grimes freeconfig(sep); 843dea673e9SRodney W. Grimes free((char *)sep); 844dea673e9SRodney W. Grimes } 845dea673e9SRodney W. Grimes (void) sigsetmask(omask); 846dea673e9SRodney W. Grimes } 847dea673e9SRodney W. Grimes 848dea673e9SRodney W. Grimes void 84955b91f3aSGeoff Rehmet unregisterrpc(sep) 85055b91f3aSGeoff Rehmet struct servtab *sep; 85155b91f3aSGeoff Rehmet { 85255b91f3aSGeoff Rehmet int i; 85355b91f3aSGeoff Rehmet struct servtab *sepp; 85455b91f3aSGeoff Rehmet long omask; 85555b91f3aSGeoff Rehmet 85655b91f3aSGeoff Rehmet omask = sigblock(SIGBLOCK); 85755b91f3aSGeoff Rehmet for (sepp = servtab; sepp; sepp = sepp->se_next) { 85855b91f3aSGeoff Rehmet if (sepp == sep) 85955b91f3aSGeoff Rehmet continue; 86055b91f3aSGeoff Rehmet if (sep->se_checked == 0 || 86155b91f3aSGeoff Rehmet !sepp->se_rpc || 86255b91f3aSGeoff Rehmet sep->se_rpc_prog != sepp->se_rpc_prog) 86355b91f3aSGeoff Rehmet continue; 86455b91f3aSGeoff Rehmet return; 86555b91f3aSGeoff Rehmet } 86655b91f3aSGeoff Rehmet if (debug) 86755b91f3aSGeoff Rehmet print_service("UNREG", sep); 86855b91f3aSGeoff Rehmet for (i = sep->se_rpc_lowvers; i <= sep->se_rpc_highvers; i++) 86955b91f3aSGeoff Rehmet pmap_unset(sep->se_rpc_prog, i); 87055b91f3aSGeoff Rehmet if (sep->se_fd != -1) 87155b91f3aSGeoff Rehmet (void) close(sep->se_fd); 87255b91f3aSGeoff Rehmet sep->se_fd = -1; 87355b91f3aSGeoff Rehmet (void) sigsetmask(omask); 87455b91f3aSGeoff Rehmet } 87555b91f3aSGeoff Rehmet 87655b91f3aSGeoff Rehmet void 877dea673e9SRodney W. Grimes retry(signo) 878dea673e9SRodney W. Grimes int signo; 879dea673e9SRodney W. Grimes { 880dea673e9SRodney W. Grimes struct servtab *sep; 881dea673e9SRodney W. Grimes 882dea673e9SRodney W. Grimes timingout = 0; 883dea673e9SRodney W. Grimes for (sep = servtab; sep; sep = sep->se_next) 8846467602bSJulian Elischer if (sep->se_fd == -1 && !ISMUX(sep)) 885dea673e9SRodney W. Grimes setup(sep); 886dea673e9SRodney W. Grimes } 887dea673e9SRodney W. Grimes 888dea673e9SRodney W. Grimes void 889dea673e9SRodney W. Grimes setup(sep) 890dea673e9SRodney W. Grimes struct servtab *sep; 891dea673e9SRodney W. Grimes { 892dea673e9SRodney W. Grimes int on = 1; 893dea673e9SRodney W. Grimes 894dea673e9SRodney W. Grimes if ((sep->se_fd = socket(AF_INET, sep->se_socktype, 0)) < 0) { 895dea673e9SRodney W. Grimes if (debug) 896c1a2e93eSPhilippe Charnier warn("socket failed on %s/%s", 897c1a2e93eSPhilippe Charnier sep->se_service, sep->se_proto); 898dea673e9SRodney W. Grimes syslog(LOG_ERR, "%s/%s: socket: %m", 899dea673e9SRodney W. Grimes sep->se_service, sep->se_proto); 900dea673e9SRodney W. Grimes return; 901dea673e9SRodney W. Grimes } 902dea673e9SRodney W. Grimes #define turnon(fd, opt) \ 903dea673e9SRodney W. Grimes setsockopt(fd, SOL_SOCKET, opt, (char *)&on, sizeof (on)) 904dea673e9SRodney W. Grimes if (strcmp(sep->se_proto, "tcp") == 0 && (options & SO_DEBUG) && 905dea673e9SRodney W. Grimes turnon(sep->se_fd, SO_DEBUG) < 0) 906dea673e9SRodney W. Grimes syslog(LOG_ERR, "setsockopt (SO_DEBUG): %m"); 907dea673e9SRodney W. Grimes if (turnon(sep->se_fd, SO_REUSEADDR) < 0) 908dea673e9SRodney W. Grimes syslog(LOG_ERR, "setsockopt (SO_REUSEADDR): %m"); 909aeb83a46SGarrett Wollman #ifdef SO_PRIVSTATE 910e50d7759SGarrett Wollman if (turnon(sep->se_fd, SO_PRIVSTATE) < 0) 911e50d7759SGarrett Wollman syslog(LOG_ERR, "setsockopt (SO_PRIVSTATE): %m"); 912aeb83a46SGarrett Wollman #endif 913dea673e9SRodney W. Grimes #undef turnon 914dea673e9SRodney W. Grimes if (bind(sep->se_fd, (struct sockaddr *)&sep->se_ctrladdr, 915dea673e9SRodney W. Grimes sizeof (sep->se_ctrladdr)) < 0) { 916dea673e9SRodney W. Grimes if (debug) 917c1a2e93eSPhilippe Charnier warn("bind failed on %s/%s", 918c1a2e93eSPhilippe Charnier sep->se_service, sep->se_proto); 919dea673e9SRodney W. Grimes syslog(LOG_ERR, "%s/%s: bind: %m", 920dea673e9SRodney W. Grimes sep->se_service, sep->se_proto); 921dea673e9SRodney W. Grimes (void) close(sep->se_fd); 922dea673e9SRodney W. Grimes sep->se_fd = -1; 923dea673e9SRodney W. Grimes if (!timingout) { 924dea673e9SRodney W. Grimes timingout = 1; 925dea673e9SRodney W. Grimes alarm(RETRYTIME); 926dea673e9SRodney W. Grimes } 927dea673e9SRodney W. Grimes return; 928dea673e9SRodney W. Grimes } 92955b91f3aSGeoff Rehmet if (sep->se_rpc) { 93055b91f3aSGeoff Rehmet int i, len = sizeof(struct sockaddr); 93155b91f3aSGeoff Rehmet 93255b91f3aSGeoff Rehmet if (getsockname(sep->se_fd, 93355b91f3aSGeoff Rehmet (struct sockaddr*)&sep->se_ctrladdr, &len) < 0){ 93455b91f3aSGeoff Rehmet syslog(LOG_ERR, "%s/%s: getsockname: %m", 93555b91f3aSGeoff Rehmet sep->se_service, sep->se_proto); 93655b91f3aSGeoff Rehmet (void) close(sep->se_fd); 93755b91f3aSGeoff Rehmet sep->se_fd = -1; 93855b91f3aSGeoff Rehmet return; 93955b91f3aSGeoff Rehmet } 94055b91f3aSGeoff Rehmet if (debug) 94155b91f3aSGeoff Rehmet print_service("REG ", sep); 94255b91f3aSGeoff Rehmet for (i = sep->se_rpc_lowvers; i <= sep->se_rpc_highvers; i++) { 94355b91f3aSGeoff Rehmet pmap_unset(sep->se_rpc_prog, i); 94455b91f3aSGeoff Rehmet pmap_set(sep->se_rpc_prog, i, 94555b91f3aSGeoff Rehmet (sep->se_socktype == SOCK_DGRAM) 94655b91f3aSGeoff Rehmet ? IPPROTO_UDP : IPPROTO_TCP, 94755b91f3aSGeoff Rehmet ntohs(sep->se_ctrladdr.sin_port)); 94855b91f3aSGeoff Rehmet } 94955b91f3aSGeoff Rehmet 95055b91f3aSGeoff Rehmet } 951dea673e9SRodney W. Grimes if (sep->se_socktype == SOCK_STREAM) 952e2894535SDavid Greenman listen(sep->se_fd, 64); 9530661be0bSJulian Elischer enable(sep); 954dea673e9SRodney W. Grimes if (debug) { 955c1a2e93eSPhilippe Charnier warnx("registered %s on %d", 956dea673e9SRodney W. Grimes sep->se_server, sep->se_fd); 957dea673e9SRodney W. Grimes } 958dea673e9SRodney W. Grimes } 959dea673e9SRodney W. Grimes 960dea673e9SRodney W. Grimes /* 961dea673e9SRodney W. Grimes * Finish with a service and its socket. 962dea673e9SRodney W. Grimes */ 963dea673e9SRodney W. Grimes void 964dea673e9SRodney W. Grimes close_sep(sep) 965dea673e9SRodney W. Grimes struct servtab *sep; 966dea673e9SRodney W. Grimes { 967dea673e9SRodney W. Grimes if (sep->se_fd >= 0) { 9680661be0bSJulian Elischer if (FD_ISSET(sep->se_fd, &allsock)) 9690661be0bSJulian Elischer disable(sep); 970dea673e9SRodney W. Grimes (void) close(sep->se_fd); 971dea673e9SRodney W. Grimes sep->se_fd = -1; 972dea673e9SRodney W. Grimes } 973dea673e9SRodney W. Grimes sep->se_count = 0; 9740661be0bSJulian Elischer sep->se_numchild = 0; /* forget about any existing children */ 975dea673e9SRodney W. Grimes } 976dea673e9SRodney W. Grimes 977dea673e9SRodney W. Grimes struct servtab * 978dea673e9SRodney W. Grimes enter(cp) 979dea673e9SRodney W. Grimes struct servtab *cp; 980dea673e9SRodney W. Grimes { 981dea673e9SRodney W. Grimes struct servtab *sep; 982dea673e9SRodney W. Grimes long omask; 983dea673e9SRodney W. Grimes 984dea673e9SRodney W. Grimes sep = (struct servtab *)malloc(sizeof (*sep)); 985dea673e9SRodney W. Grimes if (sep == (struct servtab *)0) { 986dea673e9SRodney W. Grimes syslog(LOG_ERR, "Out of memory."); 9876467602bSJulian Elischer exit(EX_OSERR); 988dea673e9SRodney W. Grimes } 989dea673e9SRodney W. Grimes *sep = *cp; 990dea673e9SRodney W. Grimes sep->se_fd = -1; 991dea673e9SRodney W. Grimes omask = sigblock(SIGBLOCK); 992dea673e9SRodney W. Grimes sep->se_next = servtab; 993dea673e9SRodney W. Grimes servtab = sep; 994dea673e9SRodney W. Grimes sigsetmask(omask); 995dea673e9SRodney W. Grimes return (sep); 996dea673e9SRodney W. Grimes } 997dea673e9SRodney W. Grimes 9980661be0bSJulian Elischer void 9990661be0bSJulian Elischer enable(struct servtab *sep) 10000661be0bSJulian Elischer { 10010661be0bSJulian Elischer if (debug) 1002c1a2e93eSPhilippe Charnier warnx( 10030661be0bSJulian Elischer "enabling %s, fd %d", sep->se_service, sep->se_fd); 10040661be0bSJulian Elischer #ifdef SANITY_CHECK 10050661be0bSJulian Elischer if (sep->se_fd < 0) { 10060661be0bSJulian Elischer syslog(LOG_ERR, 10070661be0bSJulian Elischer "%s: %s: bad fd", __FUNCTION__, sep->se_service); 10080661be0bSJulian Elischer exit(EX_SOFTWARE); 10090661be0bSJulian Elischer } 10100661be0bSJulian Elischer if (ISMUX(sep)) { 10110661be0bSJulian Elischer syslog(LOG_ERR, 10120661be0bSJulian Elischer "%s: %s: is mux", __FUNCTION__, sep->se_service); 10130661be0bSJulian Elischer exit(EX_SOFTWARE); 10140661be0bSJulian Elischer } 10150661be0bSJulian Elischer if (FD_ISSET(sep->se_fd, &allsock)) { 10160661be0bSJulian Elischer syslog(LOG_ERR, 10170661be0bSJulian Elischer "%s: %s: not off", __FUNCTION__, sep->se_service); 10180661be0bSJulian Elischer exit(EX_SOFTWARE); 10190661be0bSJulian Elischer } 10200661be0bSJulian Elischer #endif 10210661be0bSJulian Elischer FD_SET(sep->se_fd, &allsock); 10220661be0bSJulian Elischer nsock++; 10230661be0bSJulian Elischer if (sep->se_fd > maxsock) 10240661be0bSJulian Elischer maxsock = sep->se_fd; 10250661be0bSJulian Elischer } 10260661be0bSJulian Elischer 10270661be0bSJulian Elischer void 10280661be0bSJulian Elischer disable(struct servtab *sep) 10290661be0bSJulian Elischer { 10300661be0bSJulian Elischer if (debug) 1031c1a2e93eSPhilippe Charnier warnx( 10320661be0bSJulian Elischer "disabling %s, fd %d", sep->se_service, sep->se_fd); 10330661be0bSJulian Elischer #ifdef SANITY_CHECK 10340661be0bSJulian Elischer if (sep->se_fd < 0) { 10350661be0bSJulian Elischer syslog(LOG_ERR, 10360661be0bSJulian Elischer "%s: %s: bad fd", __FUNCTION__, sep->se_service); 10370661be0bSJulian Elischer exit(EX_SOFTWARE); 10380661be0bSJulian Elischer } 10390661be0bSJulian Elischer if (ISMUX(sep)) { 10400661be0bSJulian Elischer syslog(LOG_ERR, 10410661be0bSJulian Elischer "%s: %s: is mux", __FUNCTION__, sep->se_service); 10420661be0bSJulian Elischer exit(EX_SOFTWARE); 10430661be0bSJulian Elischer } 10440661be0bSJulian Elischer if (!FD_ISSET(sep->se_fd, &allsock)) { 10450661be0bSJulian Elischer syslog(LOG_ERR, 10460661be0bSJulian Elischer "%s: %s: not on", __FUNCTION__, sep->se_service); 10470661be0bSJulian Elischer exit(EX_SOFTWARE); 10480661be0bSJulian Elischer } 10490661be0bSJulian Elischer if (nsock == 0) { 10500661be0bSJulian Elischer syslog(LOG_ERR, "%s: nsock=0", __FUNCTION__); 10510661be0bSJulian Elischer exit(EX_SOFTWARE); 10520661be0bSJulian Elischer } 10530661be0bSJulian Elischer #endif 10540661be0bSJulian Elischer FD_CLR(sep->se_fd, &allsock); 10550661be0bSJulian Elischer nsock--; 10560661be0bSJulian Elischer if (sep->se_fd == maxsock) 10570661be0bSJulian Elischer maxsock--; 10580661be0bSJulian Elischer } 10590661be0bSJulian Elischer 1060dea673e9SRodney W. Grimes FILE *fconfig = NULL; 1061dea673e9SRodney W. Grimes struct servtab serv; 1062dea673e9SRodney W. Grimes char line[LINE_MAX]; 1063dea673e9SRodney W. Grimes 1064dea673e9SRodney W. Grimes int 1065dea673e9SRodney W. Grimes setconfig() 1066dea673e9SRodney W. Grimes { 1067dea673e9SRodney W. Grimes 1068dea673e9SRodney W. Grimes if (fconfig != NULL) { 1069dea673e9SRodney W. Grimes fseek(fconfig, 0L, SEEK_SET); 1070dea673e9SRodney W. Grimes return (1); 1071dea673e9SRodney W. Grimes } 1072dea673e9SRodney W. Grimes fconfig = fopen(CONFIG, "r"); 1073dea673e9SRodney W. Grimes return (fconfig != NULL); 1074dea673e9SRodney W. Grimes } 1075dea673e9SRodney W. Grimes 1076dea673e9SRodney W. Grimes void 1077dea673e9SRodney W. Grimes endconfig() 1078dea673e9SRodney W. Grimes { 1079dea673e9SRodney W. Grimes if (fconfig) { 1080dea673e9SRodney W. Grimes (void) fclose(fconfig); 1081dea673e9SRodney W. Grimes fconfig = NULL; 1082dea673e9SRodney W. Grimes } 1083dea673e9SRodney W. Grimes } 1084dea673e9SRodney W. Grimes 1085dea673e9SRodney W. Grimes struct servtab * 1086dea673e9SRodney W. Grimes getconfigent() 1087dea673e9SRodney W. Grimes { 1088dea673e9SRodney W. Grimes struct servtab *sep = &serv; 1089dea673e9SRodney W. Grimes int argc; 10900661be0bSJulian Elischer char *cp, *arg, *s; 109155b91f3aSGeoff Rehmet char *versp; 1092dea673e9SRodney W. Grimes static char TCPMUX_TOKEN[] = "tcpmux/"; 1093dea673e9SRodney W. Grimes #define MUX_LEN (sizeof(TCPMUX_TOKEN)-1) 1094dea673e9SRodney W. Grimes 1095dea673e9SRodney W. Grimes more: 1096dea673e9SRodney W. Grimes while ((cp = nextline(fconfig)) && (*cp == '#' || *cp == '\0')) 1097dea673e9SRodney W. Grimes ; 1098dea673e9SRodney W. Grimes if (cp == NULL) 1099dea673e9SRodney W. Grimes return ((struct servtab *)0); 1100dea673e9SRodney W. Grimes /* 1101dea673e9SRodney W. Grimes * clear the static buffer, since some fields (se_ctrladdr, 1102dea673e9SRodney W. Grimes * for example) don't get initialized here. 1103dea673e9SRodney W. Grimes */ 1104dea673e9SRodney W. Grimes memset((caddr_t)sep, 0, sizeof *sep); 1105dea673e9SRodney W. Grimes arg = skip(&cp); 1106dea673e9SRodney W. Grimes if (cp == NULL) { 1107dea673e9SRodney W. Grimes /* got an empty line containing just blanks/tabs. */ 1108dea673e9SRodney W. Grimes goto more; 1109dea673e9SRodney W. Grimes } 1110dea673e9SRodney W. Grimes if (strncmp(arg, TCPMUX_TOKEN, MUX_LEN) == 0) { 1111dea673e9SRodney W. Grimes char *c = arg + MUX_LEN; 1112dea673e9SRodney W. Grimes if (*c == '+') { 1113dea673e9SRodney W. Grimes sep->se_type = MUXPLUS_TYPE; 1114dea673e9SRodney W. Grimes c++; 1115dea673e9SRodney W. Grimes } else 1116dea673e9SRodney W. Grimes sep->se_type = MUX_TYPE; 1117dea673e9SRodney W. Grimes sep->se_service = newstr(c); 1118dea673e9SRodney W. Grimes } else { 1119dea673e9SRodney W. Grimes sep->se_service = newstr(arg); 1120dea673e9SRodney W. Grimes sep->se_type = NORM_TYPE; 1121dea673e9SRodney W. Grimes } 1122dea673e9SRodney W. Grimes arg = sskip(&cp); 1123dea673e9SRodney W. Grimes if (strcmp(arg, "stream") == 0) 1124dea673e9SRodney W. Grimes sep->se_socktype = SOCK_STREAM; 1125dea673e9SRodney W. Grimes else if (strcmp(arg, "dgram") == 0) 1126dea673e9SRodney W. Grimes sep->se_socktype = SOCK_DGRAM; 1127dea673e9SRodney W. Grimes else if (strcmp(arg, "rdm") == 0) 1128dea673e9SRodney W. Grimes sep->se_socktype = SOCK_RDM; 1129dea673e9SRodney W. Grimes else if (strcmp(arg, "seqpacket") == 0) 1130dea673e9SRodney W. Grimes sep->se_socktype = SOCK_SEQPACKET; 1131dea673e9SRodney W. Grimes else if (strcmp(arg, "raw") == 0) 1132dea673e9SRodney W. Grimes sep->se_socktype = SOCK_RAW; 1133dea673e9SRodney W. Grimes else 1134dea673e9SRodney W. Grimes sep->se_socktype = -1; 1135dea673e9SRodney W. Grimes sep->se_proto = newstr(sskip(&cp)); 113655b91f3aSGeoff Rehmet if (strncmp(sep->se_proto, "rpc/", 4) == 0) { 1137d4788da6SJoerg Wunsch memmove(sep->se_proto, sep->se_proto + 4, 1138d4788da6SJoerg Wunsch strlen(sep->se_proto) + 1 - 4); 113955b91f3aSGeoff Rehmet sep->se_rpc = 1; 114055b91f3aSGeoff Rehmet sep->se_rpc_prog = sep->se_rpc_lowvers = 114155b91f3aSGeoff Rehmet sep->se_rpc_lowvers = 0; 114255b91f3aSGeoff Rehmet sep->se_ctrladdr.sin_family = AF_INET; 114355b91f3aSGeoff Rehmet sep->se_ctrladdr.sin_port = 0; 11447356460fSJulian Elischer sep->se_ctrladdr.sin_addr = bind_address; 114555b91f3aSGeoff Rehmet if ((versp = rindex(sep->se_service, '/'))) { 114655b91f3aSGeoff Rehmet *versp++ = '\0'; 114755b91f3aSGeoff Rehmet switch (sscanf(versp, "%d-%d", 114855b91f3aSGeoff Rehmet &sep->se_rpc_lowvers, 114955b91f3aSGeoff Rehmet &sep->se_rpc_highvers)) { 115055b91f3aSGeoff Rehmet case 2: 115155b91f3aSGeoff Rehmet break; 115255b91f3aSGeoff Rehmet case 1: 115355b91f3aSGeoff Rehmet sep->se_rpc_highvers = 115455b91f3aSGeoff Rehmet sep->se_rpc_lowvers; 115555b91f3aSGeoff Rehmet break; 115655b91f3aSGeoff Rehmet default: 115755b91f3aSGeoff Rehmet syslog(LOG_ERR, 115855b91f3aSGeoff Rehmet "bad RPC version specifier; %s\n", 115955b91f3aSGeoff Rehmet sep->se_service); 116055b91f3aSGeoff Rehmet freeconfig(sep); 116155b91f3aSGeoff Rehmet goto more; 116255b91f3aSGeoff Rehmet } 116355b91f3aSGeoff Rehmet } 116455b91f3aSGeoff Rehmet else { 116555b91f3aSGeoff Rehmet sep->se_rpc_lowvers = 116655b91f3aSGeoff Rehmet sep->se_rpc_highvers = 1; 116755b91f3aSGeoff Rehmet } 116855b91f3aSGeoff Rehmet } 1169dea673e9SRodney W. Grimes arg = sskip(&cp); 11700661be0bSJulian Elischer if (!strncmp(arg, "wait", 4)) 11710661be0bSJulian Elischer sep->se_accept = 0; 11720661be0bSJulian Elischer else if (!strncmp(arg, "nowait", 6)) 11730661be0bSJulian Elischer sep->se_accept = 1; 11740661be0bSJulian Elischer else { 11750661be0bSJulian Elischer syslog(LOG_ERR, 11760661be0bSJulian Elischer "%s: bad wait/nowait for service %s", 11770661be0bSJulian Elischer CONFIG, sep->se_service); 11780661be0bSJulian Elischer goto more; 11790661be0bSJulian Elischer } 1180ffb7094eSPaul Traina sep->se_maxchild = maxchild; 1181ffb7094eSPaul Traina sep->se_maxcpm = maxcpm; 11820661be0bSJulian Elischer if ((s = strchr(arg, '/')) != NULL) { 11830661be0bSJulian Elischer char *eptr; 11840661be0bSJulian Elischer u_long val; 11850661be0bSJulian Elischer 11860661be0bSJulian Elischer val = strtoul(s + 1, &eptr, 10); 11873e2e58f1SDima Ruban if (eptr == s + 1 || val > MAX_MAXCHLD) { 11880661be0bSJulian Elischer syslog(LOG_ERR, 11890661be0bSJulian Elischer "%s: bad max-child for service %s", 11900661be0bSJulian Elischer CONFIG, sep->se_service); 11910661be0bSJulian Elischer goto more; 11920661be0bSJulian Elischer } 11930661be0bSJulian Elischer sep->se_maxchild = val; 11943e2e58f1SDima Ruban if (*eptr == '/') 11953e2e58f1SDima Ruban sep->se_maxcpm = strtol(eptr + 1, &eptr, 10); 11963e2e58f1SDima Ruban /* 11973e2e58f1SDima Ruban * explicitly do not check for \0 for future expansion / 11983e2e58f1SDima Ruban * backwards compatibility 11993e2e58f1SDima Ruban */ 12000661be0bSJulian Elischer } 1201dea673e9SRodney W. Grimes if (ISMUX(sep)) { 1202dea673e9SRodney W. Grimes /* 12030661be0bSJulian Elischer * Silently enforce "nowait" mode for TCPMUX services 12040661be0bSJulian Elischer * since they don't have an assigned port to listen on. 1205dea673e9SRodney W. Grimes */ 12060661be0bSJulian Elischer sep->se_accept = 1; 1207dea673e9SRodney W. Grimes if (strcmp(sep->se_proto, "tcp")) { 1208dea673e9SRodney W. Grimes syslog(LOG_ERR, 1209dea673e9SRodney W. Grimes "%s: bad protocol for tcpmux service %s", 1210dea673e9SRodney W. Grimes CONFIG, sep->se_service); 1211dea673e9SRodney W. Grimes goto more; 1212dea673e9SRodney W. Grimes } 1213dea673e9SRodney W. Grimes if (sep->se_socktype != SOCK_STREAM) { 1214dea673e9SRodney W. Grimes syslog(LOG_ERR, 1215dea673e9SRodney W. Grimes "%s: bad socket type for tcpmux service %s", 1216dea673e9SRodney W. Grimes CONFIG, sep->se_service); 1217dea673e9SRodney W. Grimes goto more; 1218dea673e9SRodney W. Grimes } 1219dea673e9SRodney W. Grimes } 1220dea673e9SRodney W. Grimes sep->se_user = newstr(sskip(&cp)); 1221186a5319SAndrey A. Chernov #ifdef LOGIN_CAP 1222186a5319SAndrey A. Chernov if ((s = strrchr(sep->se_user, '/')) != NULL) { 1223186a5319SAndrey A. Chernov *s = '\0'; 1224186a5319SAndrey A. Chernov sep->se_class = newstr(s + 1); 1225186a5319SAndrey A. Chernov } else 1226186a5319SAndrey A. Chernov sep->se_class = newstr(RESOURCE_RC); 1227186a5319SAndrey A. Chernov #endif 1228b34683caSAndrey A. Chernov if ((s = strrchr(sep->se_user, ':')) != NULL) { 1229b34683caSAndrey A. Chernov *s = '\0'; 1230b34683caSAndrey A. Chernov sep->se_group = newstr(s + 1); 1231b34683caSAndrey A. Chernov } else 1232b34683caSAndrey A. Chernov sep->se_group = NULL; 1233dea673e9SRodney W. Grimes sep->se_server = newstr(sskip(&cp)); 1234dea673e9SRodney W. Grimes if (strcmp(sep->se_server, "internal") == 0) { 1235dea673e9SRodney W. Grimes struct biltin *bi; 1236dea673e9SRodney W. Grimes 1237dea673e9SRodney W. Grimes for (bi = biltins; bi->bi_service; bi++) 1238dea673e9SRodney W. Grimes if (bi->bi_socktype == sep->se_socktype && 1239dea673e9SRodney W. Grimes strcmp(bi->bi_service, sep->se_service) == 0) 1240dea673e9SRodney W. Grimes break; 1241dea673e9SRodney W. Grimes if (bi->bi_service == 0) { 1242dea673e9SRodney W. Grimes syslog(LOG_ERR, "internal service %s unknown", 1243dea673e9SRodney W. Grimes sep->se_service); 1244dea673e9SRodney W. Grimes goto more; 1245dea673e9SRodney W. Grimes } 12460661be0bSJulian Elischer sep->se_accept = 1; /* force accept mode for built-ins */ 1247dea673e9SRodney W. Grimes sep->se_bi = bi; 1248dea673e9SRodney W. Grimes } else 1249dea673e9SRodney W. Grimes sep->se_bi = NULL; 12500661be0bSJulian Elischer if (sep->se_maxchild < 0) /* apply default max-children */ 12510661be0bSJulian Elischer if (sep->se_bi) 12520661be0bSJulian Elischer sep->se_maxchild = sep->se_bi->bi_maxchild; 12530661be0bSJulian Elischer else 12540661be0bSJulian Elischer sep->se_maxchild = sep->se_accept ? 0 : 1; 12550661be0bSJulian Elischer if (sep->se_maxchild) { 12560661be0bSJulian Elischer sep->se_pids = malloc(sep->se_maxchild * sizeof(*sep->se_pids)); 12570661be0bSJulian Elischer if (sep->se_pids == NULL) { 12580661be0bSJulian Elischer syslog(LOG_ERR, "Out of memory."); 12590661be0bSJulian Elischer exit(EX_OSERR); 12600661be0bSJulian Elischer } 12610661be0bSJulian Elischer } 1262dea673e9SRodney W. Grimes argc = 0; 1263dea673e9SRodney W. Grimes for (arg = skip(&cp); cp; arg = skip(&cp)) 12640661be0bSJulian Elischer if (argc < MAXARGV) { 1265dea673e9SRodney W. Grimes sep->se_argv[argc++] = newstr(arg); 12660661be0bSJulian Elischer } else { 12670661be0bSJulian Elischer syslog(LOG_ERR, 12680661be0bSJulian Elischer "%s: too many arguments for service %s", 12690661be0bSJulian Elischer CONFIG, sep->se_service); 12700661be0bSJulian Elischer goto more; 12710661be0bSJulian Elischer } 1272dea673e9SRodney W. Grimes while (argc <= MAXARGV) 1273dea673e9SRodney W. Grimes sep->se_argv[argc++] = NULL; 1274dea673e9SRodney W. Grimes return (sep); 1275dea673e9SRodney W. Grimes } 1276dea673e9SRodney W. Grimes 1277dea673e9SRodney W. Grimes void 1278dea673e9SRodney W. Grimes freeconfig(cp) 1279dea673e9SRodney W. Grimes struct servtab *cp; 1280dea673e9SRodney W. Grimes { 1281dea673e9SRodney W. Grimes int i; 1282dea673e9SRodney W. Grimes 1283dea673e9SRodney W. Grimes if (cp->se_service) 1284dea673e9SRodney W. Grimes free(cp->se_service); 1285dea673e9SRodney W. Grimes if (cp->se_proto) 1286dea673e9SRodney W. Grimes free(cp->se_proto); 1287dea673e9SRodney W. Grimes if (cp->se_user) 1288dea673e9SRodney W. Grimes free(cp->se_user); 1289b34683caSAndrey A. Chernov if (cp->se_group) 1290b34683caSAndrey A. Chernov free(cp->se_group); 1291186a5319SAndrey A. Chernov #ifdef LOGIN_CAP 1292186a5319SAndrey A. Chernov if (cp->se_class) 1293186a5319SAndrey A. Chernov free(cp->se_class); 1294186a5319SAndrey A. Chernov #endif 1295dea673e9SRodney W. Grimes if (cp->se_server) 1296dea673e9SRodney W. Grimes free(cp->se_server); 12970661be0bSJulian Elischer if (cp->se_pids) 12980661be0bSJulian Elischer free(cp->se_pids); 1299dea673e9SRodney W. Grimes for (i = 0; i < MAXARGV; i++) 1300dea673e9SRodney W. Grimes if (cp->se_argv[i]) 1301dea673e9SRodney W. Grimes free(cp->se_argv[i]); 1302dea673e9SRodney W. Grimes } 1303dea673e9SRodney W. Grimes 1304dea673e9SRodney W. Grimes 1305dea673e9SRodney W. Grimes /* 1306dea673e9SRodney W. Grimes * Safe skip - if skip returns null, log a syntax error in the 1307dea673e9SRodney W. Grimes * configuration file and exit. 1308dea673e9SRodney W. Grimes */ 1309dea673e9SRodney W. Grimes char * 1310dea673e9SRodney W. Grimes sskip(cpp) 1311dea673e9SRodney W. Grimes char **cpp; 1312dea673e9SRodney W. Grimes { 1313dea673e9SRodney W. Grimes char *cp; 1314dea673e9SRodney W. Grimes 1315dea673e9SRodney W. Grimes cp = skip(cpp); 1316dea673e9SRodney W. Grimes if (cp == NULL) { 1317dea673e9SRodney W. Grimes syslog(LOG_ERR, "%s: syntax error", CONFIG); 13186467602bSJulian Elischer exit(EX_DATAERR); 1319dea673e9SRodney W. Grimes } 1320dea673e9SRodney W. Grimes return (cp); 1321dea673e9SRodney W. Grimes } 1322dea673e9SRodney W. Grimes 1323dea673e9SRodney W. Grimes char * 1324dea673e9SRodney W. Grimes skip(cpp) 1325dea673e9SRodney W. Grimes char **cpp; 1326dea673e9SRodney W. Grimes { 1327dea673e9SRodney W. Grimes char *cp = *cpp; 1328dea673e9SRodney W. Grimes char *start; 132932b505b2SAdam David char quote = '\0'; 1330dea673e9SRodney W. Grimes 1331dea673e9SRodney W. Grimes again: 1332dea673e9SRodney W. Grimes while (*cp == ' ' || *cp == '\t') 1333dea673e9SRodney W. Grimes cp++; 1334dea673e9SRodney W. Grimes if (*cp == '\0') { 1335dea673e9SRodney W. Grimes int c; 1336dea673e9SRodney W. Grimes 1337dea673e9SRodney W. Grimes c = getc(fconfig); 1338dea673e9SRodney W. Grimes (void) ungetc(c, fconfig); 1339dea673e9SRodney W. Grimes if (c == ' ' || c == '\t') 13406467602bSJulian Elischer if ((cp = nextline(fconfig))) 1341dea673e9SRodney W. Grimes goto again; 1342dea673e9SRodney W. Grimes *cpp = (char *)0; 1343dea673e9SRodney W. Grimes return ((char *)0); 1344dea673e9SRodney W. Grimes } 134532b505b2SAdam David if (*cp == '"' || *cp == '\'') 134632b505b2SAdam David quote = *cp++; 1347dea673e9SRodney W. Grimes start = cp; 134832b505b2SAdam David if (quote) 134932b505b2SAdam David while (*cp && *cp != quote) 135032b505b2SAdam David cp++; 135132b505b2SAdam David else 1352dea673e9SRodney W. Grimes while (*cp && *cp != ' ' && *cp != '\t') 1353dea673e9SRodney W. Grimes cp++; 1354dea673e9SRodney W. Grimes if (*cp != '\0') 1355dea673e9SRodney W. Grimes *cp++ = '\0'; 1356dea673e9SRodney W. Grimes *cpp = cp; 1357dea673e9SRodney W. Grimes return (start); 1358dea673e9SRodney W. Grimes } 1359dea673e9SRodney W. Grimes 1360dea673e9SRodney W. Grimes char * 1361dea673e9SRodney W. Grimes nextline(fd) 1362dea673e9SRodney W. Grimes FILE *fd; 1363dea673e9SRodney W. Grimes { 1364dea673e9SRodney W. Grimes char *cp; 1365dea673e9SRodney W. Grimes 1366dea673e9SRodney W. Grimes if (fgets(line, sizeof (line), fd) == NULL) 1367dea673e9SRodney W. Grimes return ((char *)0); 1368dea673e9SRodney W. Grimes cp = strchr(line, '\n'); 1369dea673e9SRodney W. Grimes if (cp) 1370dea673e9SRodney W. Grimes *cp = '\0'; 1371dea673e9SRodney W. Grimes return (line); 1372dea673e9SRodney W. Grimes } 1373dea673e9SRodney W. Grimes 1374dea673e9SRodney W. Grimes char * 1375dea673e9SRodney W. Grimes newstr(cp) 1376dea673e9SRodney W. Grimes char *cp; 1377dea673e9SRodney W. Grimes { 13786467602bSJulian Elischer if ((cp = strdup(cp ? cp : ""))) 1379dea673e9SRodney W. Grimes return (cp); 1380dea673e9SRodney W. Grimes syslog(LOG_ERR, "strdup: %m"); 13816467602bSJulian Elischer exit(EX_OSERR); 1382dea673e9SRodney W. Grimes } 1383dea673e9SRodney W. Grimes 1384c1283020SPeter Wemm #ifdef OLD_SETPROCTITLE 1385dea673e9SRodney W. Grimes void 1386c1283020SPeter Wemm inetd_setproctitle(a, s) 1387dea673e9SRodney W. Grimes char *a; 1388dea673e9SRodney W. Grimes int s; 1389dea673e9SRodney W. Grimes { 1390dea673e9SRodney W. Grimes int size; 1391dea673e9SRodney W. Grimes char *cp; 1392dea673e9SRodney W. Grimes struct sockaddr_in sin; 1393dea673e9SRodney W. Grimes char buf[80]; 1394dea673e9SRodney W. Grimes 1395dea673e9SRodney W. Grimes cp = Argv[0]; 1396dea673e9SRodney W. Grimes size = sizeof(sin); 1397dea673e9SRodney W. Grimes if (getpeername(s, (struct sockaddr *)&sin, &size) == 0) 1398dea673e9SRodney W. Grimes (void) sprintf(buf, "-%s [%s]", a, inet_ntoa(sin.sin_addr)); 1399dea673e9SRodney W. Grimes else 1400dea673e9SRodney W. Grimes (void) sprintf(buf, "-%s", a); 1401dea673e9SRodney W. Grimes strncpy(cp, buf, LastArg - cp); 1402dea673e9SRodney W. Grimes cp += strlen(cp); 1403dea673e9SRodney W. Grimes while (cp < LastArg) 1404dea673e9SRodney W. Grimes *cp++ = ' '; 1405dea673e9SRodney W. Grimes } 1406c1283020SPeter Wemm #else 1407c1283020SPeter Wemm void 1408c1283020SPeter Wemm inetd_setproctitle(a, s) 1409c1283020SPeter Wemm char *a; 1410c1283020SPeter Wemm int s; 1411c1283020SPeter Wemm { 1412c1283020SPeter Wemm int size; 1413c1283020SPeter Wemm struct sockaddr_in sin; 1414c1283020SPeter Wemm char buf[80]; 1415c1283020SPeter Wemm 1416c1283020SPeter Wemm size = sizeof(sin); 1417c1283020SPeter Wemm if (getpeername(s, (struct sockaddr *)&sin, &size) == 0) 1418c1283020SPeter Wemm (void) sprintf(buf, "%s [%s]", a, inet_ntoa(sin.sin_addr)); 1419c1283020SPeter Wemm else 1420c1283020SPeter Wemm (void) sprintf(buf, "%s", a); 1421c1283020SPeter Wemm setproctitle("%s", buf); 1422c1283020SPeter Wemm } 1423c1283020SPeter Wemm #endif 1424c1283020SPeter Wemm 1425dea673e9SRodney W. Grimes 1426dea673e9SRodney W. Grimes /* 1427dea673e9SRodney W. Grimes * Internet services provided internally by inetd: 1428dea673e9SRodney W. Grimes */ 1429dea673e9SRodney W. Grimes #define BUFSIZE 8192 1430dea673e9SRodney W. Grimes 1431dea673e9SRodney W. Grimes /* ARGSUSED */ 1432dea673e9SRodney W. Grimes void 1433dea673e9SRodney W. Grimes echo_stream(s, sep) /* Echo service -- echo data back */ 1434dea673e9SRodney W. Grimes int s; 1435dea673e9SRodney W. Grimes struct servtab *sep; 1436dea673e9SRodney W. Grimes { 1437dea673e9SRodney W. Grimes char buffer[BUFSIZE]; 1438dea673e9SRodney W. Grimes int i; 1439dea673e9SRodney W. Grimes 1440c1283020SPeter Wemm inetd_setproctitle(sep->se_service, s); 1441dea673e9SRodney W. Grimes while ((i = read(s, buffer, sizeof(buffer))) > 0 && 1442dea673e9SRodney W. Grimes write(s, buffer, i) > 0) 1443dea673e9SRodney W. Grimes ; 1444dea673e9SRodney W. Grimes exit(0); 1445dea673e9SRodney W. Grimes } 1446dea673e9SRodney W. Grimes 144771704f34SGarrett Wollman int check_loop(sin, sep) 144871704f34SGarrett Wollman struct sockaddr_in *sin; 144971704f34SGarrett Wollman struct servtab *sep; 145071704f34SGarrett Wollman { 145171704f34SGarrett Wollman struct servtab *se2; 145271704f34SGarrett Wollman 145371704f34SGarrett Wollman for (se2 = servtab; se2; se2 = se2->se_next) { 145471704f34SGarrett Wollman if (!se2->se_bi || se2->se_socktype != SOCK_DGRAM) 145571704f34SGarrett Wollman continue; 145671704f34SGarrett Wollman 145771704f34SGarrett Wollman if (sin->sin_port == se2->se_ctrladdr.sin_port) { 145871704f34SGarrett Wollman syslog(LOG_WARNING, 145971704f34SGarrett Wollman "%s/%s:%s/%s loop request REFUSED from %s", 146071704f34SGarrett Wollman sep->se_service, sep->se_proto, 146171704f34SGarrett Wollman se2->se_service, se2->se_proto, 146271704f34SGarrett Wollman inet_ntoa(sin->sin_addr)); 146371704f34SGarrett Wollman return 1; 146471704f34SGarrett Wollman } 146571704f34SGarrett Wollman } 146671704f34SGarrett Wollman return 0; 146771704f34SGarrett Wollman } 146871704f34SGarrett Wollman 1469dea673e9SRodney W. Grimes /* ARGSUSED */ 1470dea673e9SRodney W. Grimes void 1471dea673e9SRodney W. Grimes echo_dg(s, sep) /* Echo service -- echo data back */ 1472dea673e9SRodney W. Grimes int s; 1473dea673e9SRodney W. Grimes struct servtab *sep; 1474dea673e9SRodney W. Grimes { 1475dea673e9SRodney W. Grimes char buffer[BUFSIZE]; 1476dea673e9SRodney W. Grimes int i, size; 147771704f34SGarrett Wollman struct sockaddr_in sin; 1478dea673e9SRodney W. Grimes 147971704f34SGarrett Wollman size = sizeof(sin); 148071704f34SGarrett Wollman if ((i = recvfrom(s, buffer, sizeof(buffer), 0, 148171704f34SGarrett Wollman (struct sockaddr *)&sin, &size)) < 0) 1482dea673e9SRodney W. Grimes return; 148371704f34SGarrett Wollman 148471704f34SGarrett Wollman if (check_loop(&sin, sep)) 148571704f34SGarrett Wollman return; 148671704f34SGarrett Wollman 148771704f34SGarrett Wollman (void) sendto(s, buffer, i, 0, (struct sockaddr *)&sin, 148871704f34SGarrett Wollman sizeof(sin)); 1489dea673e9SRodney W. Grimes } 1490dea673e9SRodney W. Grimes 1491dea673e9SRodney W. Grimes /* ARGSUSED */ 1492dea673e9SRodney W. Grimes void 1493dea673e9SRodney W. Grimes discard_stream(s, sep) /* Discard service -- ignore data */ 1494dea673e9SRodney W. Grimes int s; 1495dea673e9SRodney W. Grimes struct servtab *sep; 1496dea673e9SRodney W. Grimes { 1497dea673e9SRodney W. Grimes int ret; 1498dea673e9SRodney W. Grimes char buffer[BUFSIZE]; 1499dea673e9SRodney W. Grimes 1500c1283020SPeter Wemm inetd_setproctitle(sep->se_service, s); 1501dea673e9SRodney W. Grimes while (1) { 1502dea673e9SRodney W. Grimes while ((ret = read(s, buffer, sizeof(buffer))) > 0) 1503dea673e9SRodney W. Grimes ; 1504dea673e9SRodney W. Grimes if (ret == 0 || errno != EINTR) 1505dea673e9SRodney W. Grimes break; 1506dea673e9SRodney W. Grimes } 1507dea673e9SRodney W. Grimes exit(0); 1508dea673e9SRodney W. Grimes } 1509dea673e9SRodney W. Grimes 1510dea673e9SRodney W. Grimes /* ARGSUSED */ 1511dea673e9SRodney W. Grimes void 1512dea673e9SRodney W. Grimes discard_dg(s, sep) /* Discard service -- ignore data */ 1513dea673e9SRodney W. Grimes int s; 1514dea673e9SRodney W. Grimes struct servtab *sep; 1515dea673e9SRodney W. Grimes { 1516dea673e9SRodney W. Grimes char buffer[BUFSIZE]; 1517dea673e9SRodney W. Grimes 1518dea673e9SRodney W. Grimes (void) read(s, buffer, sizeof(buffer)); 1519dea673e9SRodney W. Grimes } 1520dea673e9SRodney W. Grimes 1521dea673e9SRodney W. Grimes #include <ctype.h> 1522dea673e9SRodney W. Grimes #define LINESIZ 72 1523dea673e9SRodney W. Grimes char ring[128]; 1524dea673e9SRodney W. Grimes char *endring; 1525dea673e9SRodney W. Grimes 1526dea673e9SRodney W. Grimes void 1527dea673e9SRodney W. Grimes initring() 1528dea673e9SRodney W. Grimes { 1529dea673e9SRodney W. Grimes int i; 1530dea673e9SRodney W. Grimes 1531dea673e9SRodney W. Grimes endring = ring; 1532dea673e9SRodney W. Grimes 1533dea673e9SRodney W. Grimes for (i = 0; i <= 128; ++i) 1534dea673e9SRodney W. Grimes if (isprint(i)) 1535dea673e9SRodney W. Grimes *endring++ = i; 1536dea673e9SRodney W. Grimes } 1537dea673e9SRodney W. Grimes 1538dea673e9SRodney W. Grimes /* ARGSUSED */ 1539dea673e9SRodney W. Grimes void 1540dea673e9SRodney W. Grimes chargen_stream(s, sep) /* Character generator */ 1541dea673e9SRodney W. Grimes int s; 1542dea673e9SRodney W. Grimes struct servtab *sep; 1543dea673e9SRodney W. Grimes { 1544dea673e9SRodney W. Grimes int len; 1545dea673e9SRodney W. Grimes char *rs, text[LINESIZ+2]; 1546dea673e9SRodney W. Grimes 1547c1283020SPeter Wemm inetd_setproctitle(sep->se_service, s); 1548dea673e9SRodney W. Grimes 1549dea673e9SRodney W. Grimes if (!endring) { 1550dea673e9SRodney W. Grimes initring(); 1551dea673e9SRodney W. Grimes rs = ring; 1552dea673e9SRodney W. Grimes } 1553dea673e9SRodney W. Grimes 1554dea673e9SRodney W. Grimes text[LINESIZ] = '\r'; 1555dea673e9SRodney W. Grimes text[LINESIZ + 1] = '\n'; 1556dea673e9SRodney W. Grimes for (rs = ring;;) { 1557dea673e9SRodney W. Grimes if ((len = endring - rs) >= LINESIZ) 1558dea673e9SRodney W. Grimes memmove(text, rs, LINESIZ); 1559dea673e9SRodney W. Grimes else { 1560dea673e9SRodney W. Grimes memmove(text, rs, len); 1561dea673e9SRodney W. Grimes memmove(text + len, ring, LINESIZ - len); 1562dea673e9SRodney W. Grimes } 1563dea673e9SRodney W. Grimes if (++rs == endring) 1564dea673e9SRodney W. Grimes rs = ring; 1565dea673e9SRodney W. Grimes if (write(s, text, sizeof(text)) != sizeof(text)) 1566dea673e9SRodney W. Grimes break; 1567dea673e9SRodney W. Grimes } 1568dea673e9SRodney W. Grimes exit(0); 1569dea673e9SRodney W. Grimes } 1570dea673e9SRodney W. Grimes 1571dea673e9SRodney W. Grimes /* ARGSUSED */ 1572dea673e9SRodney W. Grimes void 1573dea673e9SRodney W. Grimes chargen_dg(s, sep) /* Character generator */ 1574dea673e9SRodney W. Grimes int s; 1575dea673e9SRodney W. Grimes struct servtab *sep; 1576dea673e9SRodney W. Grimes { 157771704f34SGarrett Wollman struct sockaddr_in sin; 1578dea673e9SRodney W. Grimes static char *rs; 1579dea673e9SRodney W. Grimes int len, size; 1580dea673e9SRodney W. Grimes char text[LINESIZ+2]; 1581dea673e9SRodney W. Grimes 1582dea673e9SRodney W. Grimes if (endring == 0) { 1583dea673e9SRodney W. Grimes initring(); 1584dea673e9SRodney W. Grimes rs = ring; 1585dea673e9SRodney W. Grimes } 1586dea673e9SRodney W. Grimes 158771704f34SGarrett Wollman size = sizeof(sin); 158871704f34SGarrett Wollman if (recvfrom(s, text, sizeof(text), 0, 158971704f34SGarrett Wollman (struct sockaddr *)&sin, &size) < 0) 159071704f34SGarrett Wollman return; 159171704f34SGarrett Wollman 159271704f34SGarrett Wollman if (check_loop(&sin, sep)) 1593dea673e9SRodney W. Grimes return; 1594dea673e9SRodney W. Grimes 1595dea673e9SRodney W. Grimes if ((len = endring - rs) >= LINESIZ) 1596dea673e9SRodney W. Grimes memmove(text, rs, LINESIZ); 1597dea673e9SRodney W. Grimes else { 1598dea673e9SRodney W. Grimes memmove(text, rs, len); 1599dea673e9SRodney W. Grimes memmove(text + len, ring, LINESIZ - len); 1600dea673e9SRodney W. Grimes } 1601dea673e9SRodney W. Grimes if (++rs == endring) 1602dea673e9SRodney W. Grimes rs = ring; 1603dea673e9SRodney W. Grimes text[LINESIZ] = '\r'; 1604dea673e9SRodney W. Grimes text[LINESIZ + 1] = '\n'; 160571704f34SGarrett Wollman (void) sendto(s, text, sizeof(text), 0, 160671704f34SGarrett Wollman (struct sockaddr *)&sin, sizeof(sin)); 1607dea673e9SRodney W. Grimes } 1608dea673e9SRodney W. Grimes 1609dea673e9SRodney W. Grimes /* 1610dea673e9SRodney W. Grimes * Return a machine readable date and time, in the form of the 1611dea673e9SRodney W. Grimes * number of seconds since midnight, Jan 1, 1900. Since gettimeofday 1612dea673e9SRodney W. Grimes * returns the number of seconds since midnight, Jan 1, 1970, 1613dea673e9SRodney W. Grimes * we must add 2208988800 seconds to this figure to make up for 1614dea673e9SRodney W. Grimes * some seventy years Bell Labs was asleep. 1615dea673e9SRodney W. Grimes */ 1616dea673e9SRodney W. Grimes 1617dea673e9SRodney W. Grimes long 1618dea673e9SRodney W. Grimes machtime() 1619dea673e9SRodney W. Grimes { 1620dea673e9SRodney W. Grimes struct timeval tv; 1621dea673e9SRodney W. Grimes 1622dea673e9SRodney W. Grimes if (gettimeofday(&tv, (struct timezone *)0) < 0) { 1623dea673e9SRodney W. Grimes if (debug) 1624c1a2e93eSPhilippe Charnier warnx("unable to get time of day"); 1625dea673e9SRodney W. Grimes return (0L); 1626dea673e9SRodney W. Grimes } 1627dea673e9SRodney W. Grimes #define OFFSET ((u_long)25567 * 24*60*60) 1628dea673e9SRodney W. Grimes return (htonl((long)(tv.tv_sec + OFFSET))); 1629dea673e9SRodney W. Grimes #undef OFFSET 1630dea673e9SRodney W. Grimes } 1631dea673e9SRodney W. Grimes 1632dea673e9SRodney W. Grimes /* ARGSUSED */ 1633dea673e9SRodney W. Grimes void 1634dea673e9SRodney W. Grimes machtime_stream(s, sep) 1635dea673e9SRodney W. Grimes int s; 1636dea673e9SRodney W. Grimes struct servtab *sep; 1637dea673e9SRodney W. Grimes { 1638dea673e9SRodney W. Grimes long result; 1639dea673e9SRodney W. Grimes 1640dea673e9SRodney W. Grimes result = machtime(); 1641dea673e9SRodney W. Grimes (void) write(s, (char *) &result, sizeof(result)); 1642dea673e9SRodney W. Grimes } 1643dea673e9SRodney W. Grimes 1644dea673e9SRodney W. Grimes /* ARGSUSED */ 1645dea673e9SRodney W. Grimes void 1646dea673e9SRodney W. Grimes machtime_dg(s, sep) 1647dea673e9SRodney W. Grimes int s; 1648dea673e9SRodney W. Grimes struct servtab *sep; 1649dea673e9SRodney W. Grimes { 1650dea673e9SRodney W. Grimes long result; 165171704f34SGarrett Wollman struct sockaddr_in sin; 1652dea673e9SRodney W. Grimes int size; 1653dea673e9SRodney W. Grimes 165471704f34SGarrett Wollman size = sizeof(sin); 165571704f34SGarrett Wollman if (recvfrom(s, (char *)&result, sizeof(result), 0, 165671704f34SGarrett Wollman (struct sockaddr *)&sin, &size) < 0) 1657dea673e9SRodney W. Grimes return; 165871704f34SGarrett Wollman 165971704f34SGarrett Wollman if (check_loop(&sin, sep)) 166071704f34SGarrett Wollman return; 166171704f34SGarrett Wollman 1662dea673e9SRodney W. Grimes result = machtime(); 166371704f34SGarrett Wollman (void) sendto(s, (char *) &result, sizeof(result), 0, 166471704f34SGarrett Wollman (struct sockaddr *)&sin, sizeof(sin)); 1665dea673e9SRodney W. Grimes } 1666dea673e9SRodney W. Grimes 1667dea673e9SRodney W. Grimes /* ARGSUSED */ 1668dea673e9SRodney W. Grimes void 1669dea673e9SRodney W. Grimes daytime_stream(s, sep) /* Return human-readable time of day */ 1670dea673e9SRodney W. Grimes int s; 1671dea673e9SRodney W. Grimes struct servtab *sep; 1672dea673e9SRodney W. Grimes { 1673dea673e9SRodney W. Grimes char buffer[256]; 1674dea673e9SRodney W. Grimes time_t clock; 1675dea673e9SRodney W. Grimes 1676dea673e9SRodney W. Grimes clock = time((time_t *) 0); 1677dea673e9SRodney W. Grimes 1678dea673e9SRodney W. Grimes (void) sprintf(buffer, "%.24s\r\n", ctime(&clock)); 1679dea673e9SRodney W. Grimes (void) write(s, buffer, strlen(buffer)); 1680dea673e9SRodney W. Grimes } 1681dea673e9SRodney W. Grimes 1682dea673e9SRodney W. Grimes /* ARGSUSED */ 1683dea673e9SRodney W. Grimes void 1684dea673e9SRodney W. Grimes daytime_dg(s, sep) /* Return human-readable time of day */ 1685dea673e9SRodney W. Grimes int s; 1686dea673e9SRodney W. Grimes struct servtab *sep; 1687dea673e9SRodney W. Grimes { 1688dea673e9SRodney W. Grimes char buffer[256]; 1689dea673e9SRodney W. Grimes time_t clock; 169071704f34SGarrett Wollman struct sockaddr_in sin; 1691dea673e9SRodney W. Grimes int size; 1692dea673e9SRodney W. Grimes 1693dea673e9SRodney W. Grimes clock = time((time_t *) 0); 1694dea673e9SRodney W. Grimes 169571704f34SGarrett Wollman size = sizeof(sin); 169671704f34SGarrett Wollman if (recvfrom(s, buffer, sizeof(buffer), 0, 169771704f34SGarrett Wollman (struct sockaddr *)&sin, &size) < 0) 1698dea673e9SRodney W. Grimes return; 169971704f34SGarrett Wollman 170071704f34SGarrett Wollman if (check_loop(&sin, sep)) 170171704f34SGarrett Wollman return; 170271704f34SGarrett Wollman 1703dea673e9SRodney W. Grimes (void) sprintf(buffer, "%.24s\r\n", ctime(&clock)); 170471704f34SGarrett Wollman (void) sendto(s, buffer, strlen(buffer), 0, 170571704f34SGarrett Wollman (struct sockaddr *)&sin, sizeof(sin)); 1706dea673e9SRodney W. Grimes } 1707dea673e9SRodney W. Grimes 1708dea673e9SRodney W. Grimes /* 1709dea673e9SRodney W. Grimes * print_service: 1710dea673e9SRodney W. Grimes * Dump relevant information to stderr 1711dea673e9SRodney W. Grimes */ 1712dea673e9SRodney W. Grimes void 1713dea673e9SRodney W. Grimes print_service(action, sep) 1714dea673e9SRodney W. Grimes char *action; 1715dea673e9SRodney W. Grimes struct servtab *sep; 1716dea673e9SRodney W. Grimes { 1717dea673e9SRodney W. Grimes fprintf(stderr, 1718186a5319SAndrey A. Chernov #ifdef LOGIN_CAP 1719b34683caSAndrey A. Chernov "%s: %s proto=%s accept=%d max=%d user=%s group=%s class=%s builtin=%x server=%s\n", 1720186a5319SAndrey A. Chernov #else 1721b34683caSAndrey A. Chernov "%s: %s proto=%s accept=%d max=%d user=%s group=%s builtin=%x server=%s\n", 1722186a5319SAndrey A. Chernov #endif 1723dea673e9SRodney W. Grimes action, sep->se_service, sep->se_proto, 1724b34683caSAndrey A. Chernov sep->se_accept, sep->se_maxchild, sep->se_user, sep->se_group, 1725186a5319SAndrey A. Chernov #ifdef LOGIN_CAP 1726186a5319SAndrey A. Chernov sep->se_class, 1727186a5319SAndrey A. Chernov #endif 17286467602bSJulian Elischer (int)sep->se_bi, sep->se_server); 1729dea673e9SRodney W. Grimes } 1730dea673e9SRodney W. Grimes 1731dea673e9SRodney W. Grimes /* 1732dea673e9SRodney W. Grimes * Based on TCPMUX.C by Mark K. Lottor November 1988 1733dea673e9SRodney W. Grimes * sri-nic::ps:<mkl>tcpmux.c 1734dea673e9SRodney W. Grimes */ 1735dea673e9SRodney W. Grimes 1736dea673e9SRodney W. Grimes 1737dea673e9SRodney W. Grimes static int /* # of characters upto \r,\n or \0 */ 1738dea673e9SRodney W. Grimes getline(fd, buf, len) 1739dea673e9SRodney W. Grimes int fd; 1740dea673e9SRodney W. Grimes char *buf; 1741dea673e9SRodney W. Grimes int len; 1742dea673e9SRodney W. Grimes { 1743dea673e9SRodney W. Grimes int count = 0, n; 174434b32a7cSGuido van Rooij struct sigvec sv; 1745dea673e9SRodney W. Grimes 174634b32a7cSGuido van Rooij memset(&sv, 0, sizeof(sv)); 174734b32a7cSGuido van Rooij sv.sv_handler = SIG_DFL; 174834b32a7cSGuido van Rooij sigvec(SIGALRM, &sv, (struct sigvec *)0); 1749dea673e9SRodney W. Grimes do { 175034b32a7cSGuido van Rooij alarm(10); 1751dea673e9SRodney W. Grimes n = read(fd, buf, len-count); 175234b32a7cSGuido van Rooij alarm(0); 1753dea673e9SRodney W. Grimes if (n == 0) 1754dea673e9SRodney W. Grimes return (count); 1755dea673e9SRodney W. Grimes if (n < 0) 1756dea673e9SRodney W. Grimes return (-1); 1757dea673e9SRodney W. Grimes while (--n >= 0) { 1758dea673e9SRodney W. Grimes if (*buf == '\r' || *buf == '\n' || *buf == '\0') 1759dea673e9SRodney W. Grimes return (count); 1760dea673e9SRodney W. Grimes count++; 1761dea673e9SRodney W. Grimes buf++; 1762dea673e9SRodney W. Grimes } 1763dea673e9SRodney W. Grimes } while (count < len); 1764dea673e9SRodney W. Grimes return (count); 1765dea673e9SRodney W. Grimes } 1766dea673e9SRodney W. Grimes 1767dea673e9SRodney W. Grimes #define MAX_SERV_LEN (256+2) /* 2 bytes for \r\n */ 1768dea673e9SRodney W. Grimes 1769dea673e9SRodney W. Grimes #define strwrite(fd, buf) (void) write(fd, buf, sizeof(buf)-1) 1770dea673e9SRodney W. Grimes 1771dea673e9SRodney W. Grimes struct servtab * 1772dea673e9SRodney W. Grimes tcpmux(s) 1773dea673e9SRodney W. Grimes int s; 1774dea673e9SRodney W. Grimes { 1775dea673e9SRodney W. Grimes struct servtab *sep; 1776dea673e9SRodney W. Grimes char service[MAX_SERV_LEN+1]; 1777dea673e9SRodney W. Grimes int len; 1778dea673e9SRodney W. Grimes 1779dea673e9SRodney W. Grimes /* Get requested service name */ 1780dea673e9SRodney W. Grimes if ((len = getline(s, service, MAX_SERV_LEN)) < 0) { 1781dea673e9SRodney W. Grimes strwrite(s, "-Error reading service name\r\n"); 1782dea673e9SRodney W. Grimes return (NULL); 1783dea673e9SRodney W. Grimes } 1784dea673e9SRodney W. Grimes service[len] = '\0'; 1785dea673e9SRodney W. Grimes 1786dea673e9SRodney W. Grimes if (debug) 1787c1a2e93eSPhilippe Charnier warnx("tcpmux: someone wants %s", service); 1788dea673e9SRodney W. Grimes 1789dea673e9SRodney W. Grimes /* 1790dea673e9SRodney W. Grimes * Help is a required command, and lists available services, 1791dea673e9SRodney W. Grimes * one per line. 1792dea673e9SRodney W. Grimes */ 1793dea673e9SRodney W. Grimes if (!strcasecmp(service, "help")) { 1794dea673e9SRodney W. Grimes for (sep = servtab; sep; sep = sep->se_next) { 1795dea673e9SRodney W. Grimes if (!ISMUX(sep)) 1796dea673e9SRodney W. Grimes continue; 1797dea673e9SRodney W. Grimes (void)write(s,sep->se_service,strlen(sep->se_service)); 1798dea673e9SRodney W. Grimes strwrite(s, "\r\n"); 1799dea673e9SRodney W. Grimes } 1800dea673e9SRodney W. Grimes return (NULL); 1801dea673e9SRodney W. Grimes } 1802dea673e9SRodney W. Grimes 1803dea673e9SRodney W. Grimes /* Try matching a service in inetd.conf with the request */ 1804dea673e9SRodney W. Grimes for (sep = servtab; sep; sep = sep->se_next) { 1805dea673e9SRodney W. Grimes if (!ISMUX(sep)) 1806dea673e9SRodney W. Grimes continue; 1807dea673e9SRodney W. Grimes if (!strcasecmp(service, sep->se_service)) { 1808dea673e9SRodney W. Grimes if (ISMUXPLUS(sep)) { 1809dea673e9SRodney W. Grimes strwrite(s, "+Go\r\n"); 1810dea673e9SRodney W. Grimes } 1811dea673e9SRodney W. Grimes return (sep); 1812dea673e9SRodney W. Grimes } 1813dea673e9SRodney W. Grimes } 1814dea673e9SRodney W. Grimes strwrite(s, "-Service not available\r\n"); 1815dea673e9SRodney W. Grimes return (NULL); 1816dea673e9SRodney W. Grimes } 18173e2e58f1SDima Ruban 18183e2e58f1SDima Ruban #define CPMHSIZE 256 18193e2e58f1SDima Ruban #define CPMHMASK (CPMHSIZE-1) 18203e2e58f1SDima Ruban #define CHTGRAN 10 18213e2e58f1SDima Ruban #define CHTSIZE 6 18223e2e58f1SDima Ruban 18233e2e58f1SDima Ruban typedef struct CTime { 18243e2e58f1SDima Ruban unsigned long ct_Ticks; 18253e2e58f1SDima Ruban int ct_Count; 18263e2e58f1SDima Ruban } CTime; 18273e2e58f1SDima Ruban 18283e2e58f1SDima Ruban typedef struct CHash { 18293e2e58f1SDima Ruban struct in_addr ch_Addr; 18303e2e58f1SDima Ruban time_t ch_LTime; 18313e2e58f1SDima Ruban char *ch_Service; 18323e2e58f1SDima Ruban CTime ch_Times[CHTSIZE]; 18333e2e58f1SDima Ruban } CHash; 18343e2e58f1SDima Ruban 18353e2e58f1SDima Ruban CHash CHashAry[CPMHSIZE]; 18363e2e58f1SDima Ruban 18373e2e58f1SDima Ruban int 18383e2e58f1SDima Ruban cpmip(sep, ctrl) 18393e2e58f1SDima Ruban struct servtab *sep; 18403e2e58f1SDima Ruban int ctrl; 18413e2e58f1SDima Ruban { 18423e2e58f1SDima Ruban struct sockaddr_in rsin; 18433e2e58f1SDima Ruban int rsinLen = sizeof(rsin); 18443e2e58f1SDima Ruban int r = 0; 18453e2e58f1SDima Ruban 18463e2e58f1SDima Ruban /* 18473e2e58f1SDima Ruban * If getpeername() fails, just let it through (if logging is 18483e2e58f1SDima Ruban * enabled the condition is caught elsewhere) 18493e2e58f1SDima Ruban */ 18503e2e58f1SDima Ruban 18513e2e58f1SDima Ruban if (sep->se_maxcpm > 0 && 18523e2e58f1SDima Ruban getpeername(ctrl, (struct sockaddr *)&rsin, &rsinLen) == 0 ) { 18533e2e58f1SDima Ruban time_t t = time(NULL); 18543e2e58f1SDima Ruban int hv = 0xABC3D20F; 18553e2e58f1SDima Ruban int i; 18563e2e58f1SDima Ruban int cnt = 0; 18573e2e58f1SDima Ruban CHash *chBest = NULL; 18583e2e58f1SDima Ruban unsigned int ticks = t / CHTGRAN; 18593e2e58f1SDima Ruban 18603e2e58f1SDima Ruban { 18613e2e58f1SDima Ruban char *p; 18623e2e58f1SDima Ruban int i; 18633e2e58f1SDima Ruban 18643e2e58f1SDima Ruban for (i = 0, p = (char *)&rsin.sin_addr; 18653e2e58f1SDima Ruban i < sizeof(rsin.sin_addr); 18663e2e58f1SDima Ruban ++i, ++p) { 18673e2e58f1SDima Ruban hv = (hv << 5) ^ (hv >> 23) ^ *p; 18683e2e58f1SDima Ruban } 18693e2e58f1SDima Ruban hv = (hv ^ (hv >> 16)); 18703e2e58f1SDima Ruban } 18713e2e58f1SDima Ruban for (i = 0; i < 5; ++i) { 18723e2e58f1SDima Ruban CHash *ch = &CHashAry[(hv + i) & CPMHMASK]; 18733e2e58f1SDima Ruban 18743e2e58f1SDima Ruban if (rsin.sin_addr.s_addr == ch->ch_Addr.s_addr && 18753e2e58f1SDima Ruban ch->ch_Service && strcmp(sep->se_service, 18763e2e58f1SDima Ruban ch->ch_Service) == 0) { 18773e2e58f1SDima Ruban chBest = ch; 18783e2e58f1SDima Ruban break; 18793e2e58f1SDima Ruban } 18803e2e58f1SDima Ruban if (chBest == NULL || ch->ch_LTime == 0 || 18813e2e58f1SDima Ruban ch->ch_LTime < chBest->ch_LTime) { 18823e2e58f1SDima Ruban chBest = ch; 18833e2e58f1SDima Ruban } 18843e2e58f1SDima Ruban } 18853e2e58f1SDima Ruban if (rsin.sin_addr.s_addr != chBest->ch_Addr.s_addr || 18863e2e58f1SDima Ruban chBest->ch_Service == NULL || 18873e2e58f1SDima Ruban strcmp(sep->se_service, chBest->ch_Service) != 0) { 18883e2e58f1SDima Ruban chBest->ch_Addr = rsin.sin_addr; 18893e2e58f1SDima Ruban if (chBest->ch_Service) 18903e2e58f1SDima Ruban free(chBest->ch_Service); 18913e2e58f1SDima Ruban chBest->ch_Service = strdup(sep->se_service); 18923e2e58f1SDima Ruban bzero(chBest->ch_Times, sizeof(chBest->ch_Times)); 18933e2e58f1SDima Ruban } 18943e2e58f1SDima Ruban chBest->ch_LTime = t; 18953e2e58f1SDima Ruban { 18963e2e58f1SDima Ruban CTime *ct = &chBest->ch_Times[ticks % CHTSIZE]; 18973e2e58f1SDima Ruban if (ct->ct_Ticks != ticks) { 18983e2e58f1SDima Ruban ct->ct_Ticks = ticks; 18993e2e58f1SDima Ruban ct->ct_Count = 0; 19003e2e58f1SDima Ruban } 19013e2e58f1SDima Ruban ++ct->ct_Count; 19023e2e58f1SDima Ruban } 19033e2e58f1SDima Ruban for (i = 0; i < CHTSIZE; ++i) { 19043e2e58f1SDima Ruban CTime *ct = &chBest->ch_Times[i]; 19053e2e58f1SDima Ruban if (ct->ct_Ticks <= ticks && 19063e2e58f1SDima Ruban ct->ct_Ticks >= ticks - CHTSIZE) { 19073e2e58f1SDima Ruban cnt += ct->ct_Count; 19083e2e58f1SDima Ruban } 19093e2e58f1SDima Ruban } 19103e2e58f1SDima Ruban if (cnt * (CHTSIZE * CHTGRAN) / 60 > sep->se_maxcpm) { 19113e2e58f1SDima Ruban r = -1; 19123e2e58f1SDima Ruban syslog(LOG_ERR, 1913ffb7094eSPaul Traina "%s from %s exceeded counts/min (limit %d/min)", 1914ffb7094eSPaul Traina sep->se_service, inet_ntoa(rsin.sin_addr), 19153e2e58f1SDima Ruban sep->se_maxcpm); 19163e2e58f1SDima Ruban } 19173e2e58f1SDima Ruban } 19183e2e58f1SDima Ruban return(r); 19193e2e58f1SDima Ruban } 1920