inetd.c revision 1.62.2.4
1 /* $NetBSD: inetd.c,v 1.62.2.4 2000/07/26 23:13:31 mycroft Exp $ */ 2 3 /*- 4 * Copyright (c) 1998 The NetBSD Foundation, Inc. 5 * All rights reserved. 6 * 7 * This code is derived from software contributed to The NetBSD Foundation 8 * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility, 9 * NASA Ames Research Center. 10 * 11 * Redistribution and use in source and binary forms, with or without 12 * modification, are permitted provided that the following conditions 13 * are met: 14 * 1. Redistributions of source code must retain the above copyright 15 * notice, this list of conditions and the following disclaimer. 16 * 2. Redistributions in binary form must reproduce the above copyright 17 * notice, this list of conditions and the following disclaimer in the 18 * documentation and/or other materials provided with the distribution. 19 * 3. All advertising materials mentioning features or use of this software 20 * must display the following acknowledgement: 21 * This product includes software developed by the NetBSD 22 * Foundation, Inc. and its contributors. 23 * 4. Neither the name of The NetBSD Foundation nor the names of its 24 * contributors may be used to endorse or promote products derived 25 * from this software without specific prior written permission. 26 * 27 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS 28 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 29 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 30 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS 31 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 32 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 33 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 34 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 35 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 36 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 37 * POSSIBILITY OF SUCH DAMAGE. 38 */ 39 40 /* 41 * Copyright (c) 1983, 1991, 1993, 1994 42 * The Regents of the University of California. All rights reserved. 43 * 44 * Redistribution and use in source and binary forms, with or without 45 * modification, are permitted provided that the following conditions 46 * are met: 47 * 1. Redistributions of source code must retain the above copyright 48 * notice, this list of conditions and the following disclaimer. 49 * 2. Redistributions in binary form must reproduce the above copyright 50 * notice, this list of conditions and the following disclaimer in the 51 * documentation and/or other materials provided with the distribution. 52 * 3. All advertising materials mentioning features or use of this software 53 * must display the following acknowledgement: 54 * This product includes software developed by the University of 55 * California, Berkeley and its contributors. 56 * 4. Neither the name of the University nor the names of its contributors 57 * may be used to endorse or promote products derived from this software 58 * without specific prior written permission. 59 * 60 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 61 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 62 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 63 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 64 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 65 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 66 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 67 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 68 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 69 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 70 * SUCH DAMAGE. 71 */ 72 73 #include <sys/cdefs.h> 74 #ifndef lint 75 __COPYRIGHT("@(#) Copyright (c) 1983, 1991, 1993, 1994\n\ 76 The Regents of the University of California. All rights reserved.\n"); 77 #if 0 78 static char sccsid[] = "@(#)inetd.c 8.4 (Berkeley) 4/13/94"; 79 #else 80 __RCSID("$NetBSD: inetd.c,v 1.62.2.4 2000/07/26 23:13:31 mycroft Exp $"); 81 #endif 82 #endif /* not lint */ 83 84 /* 85 * Inetd - Internet super-server 86 * 87 * This program invokes all internet services as needed. Connection-oriented 88 * services are invoked each time a connection is made, by creating a process. 89 * This process is passed the connection as file descriptor 0 and is expected 90 * to do a getpeername to find out the source host and port. 91 * 92 * Datagram oriented services are invoked when a datagram 93 * arrives; a process is created and passed a pending message 94 * on file descriptor 0. Datagram servers may either connect 95 * to their peer, freeing up the original socket for inetd 96 * to receive further messages on, or ``take over the socket'', 97 * processing all arriving datagrams and, eventually, timing 98 * out. The first type of server is said to be ``multi-threaded''; 99 * the second type of server ``single-threaded''. 100 * 101 * Inetd uses a configuration file which is read at startup 102 * and, possibly, at some later time in response to a hangup signal. 103 * The configuration file is ``free format'' with fields given in the 104 * order shown below. Continuation lines for an entry must being with 105 * a space or tab. All fields must be present in each entry. 106 * 107 * service name must be in /etc/services or must 108 * name a tcpmux service 109 * socket type stream/dgram/raw/rdm/seqpacket 110 * protocol must be in /etc/protocols 111 * wait/nowait[:max] single-threaded/multi-threaded, max # 112 * user[:group] user/group to run daemon as 113 * server program full path name 114 * server program arguments maximum of MAXARGS (20) 115 * 116 * For RPC services 117 * service name/version must be in /etc/rpc 118 * socket type stream/dgram/raw/rdm/seqpacket 119 * protocol must be in /etc/protocols 120 * wait/nowait[:max] single-threaded/multi-threaded 121 * user[:group] user to run daemon as 122 * server program full path name 123 * server program arguments maximum of MAXARGS (20) 124 * 125 * For non-RPC services, the "service name" can be of the form 126 * hostaddress:servicename, in which case the hostaddress is used 127 * as the host portion of the address to listen on. If hostaddress 128 * consists of a single `*' character, INADDR_ANY is used. 129 * 130 * A line can also consist of just 131 * hostaddress: 132 * where hostaddress is as in the preceding paragraph. Such a line must 133 * have no further fields; the specified hostaddress is remembered and 134 * used for all further lines that have no hostaddress specified, 135 * until the next such line (or EOF). (This is why * is provided to 136 * allow explicit specification of INADDR_ANY.) A line 137 * *: 138 * is implicitly in effect at the beginning of the file. 139 * 140 * The hostaddress specifier may (and often will) contain dots; 141 * the service name must not. 142 * 143 * For RPC services, host-address specifiers are accepted and will 144 * work to some extent; however, because of limitations in the 145 * portmapper interface, it will not work to try to give more than 146 * one line for any given RPC service, even if the host-address 147 * specifiers are different. 148 * 149 * TCP services without official port numbers are handled with the 150 * RFC1078-based tcpmux internal service. Tcpmux listens on port 1 for 151 * requests. When a connection is made from a foreign host, the service 152 * requested is passed to tcpmux, which looks it up in the servtab list 153 * and returns the proper entry for the service. Tcpmux returns a 154 * negative reply if the service doesn't exist, otherwise the invoked 155 * server is expected to return the positive reply if the service type in 156 * inetd.conf file has the prefix "tcpmux/". If the service type has the 157 * prefix "tcpmux/+", tcpmux will return the positive reply for the 158 * process; this is for compatibility with older server code, and also 159 * allows you to invoke programs that use stdin/stdout without putting any 160 * special server code in them. Services that use tcpmux are "nowait" 161 * because they do not have a well-known port and hence cannot listen 162 * for new requests. 163 * 164 * Comment lines are indicated by a `#' in column 1. 165 * 166 * #ifdef IPSEC 167 * Comment lines that start with "#@" denote IPsec policy string, as described 168 * in ipsec_set_policy(3). This will affect all the following items in 169 * inetd.conf(8). To reset the policy, just use "#@" line. By default, 170 * there's no IPsec policy. 171 * #endif 172 */ 173 174 /* 175 * Here's the scoop concerning the user:group feature: 176 * 177 * 1) set-group-option off. 178 * 179 * a) user = root: NO setuid() or setgid() is done 180 * 181 * b) other: setuid() 182 * setgid(primary group as found in passwd) 183 * initgroups(name, primary group) 184 * 185 * 2) set-group-option on. 186 * 187 * a) user = root: NO setuid() 188 * setgid(specified group) 189 * NO initgroups() 190 * 191 * b) other: setuid() 192 * setgid(specified group) 193 * initgroups(name, specified group) 194 * 195 */ 196 197 #include <sys/param.h> 198 #include <sys/stat.h> 199 #include <sys/ioctl.h> 200 #include <sys/socket.h> 201 #include <sys/un.h> 202 #include <sys/wait.h> 203 #include <sys/time.h> 204 #include <sys/resource.h> 205 206 #ifndef RLIMIT_NOFILE 207 #define RLIMIT_NOFILE RLIMIT_OFILE 208 #endif 209 210 #ifndef NO_RPC 211 #define RPC 212 #endif 213 214 #include <netinet/in.h> 215 #include <arpa/inet.h> 216 #ifdef RPC 217 #include <rpc/rpc.h> 218 #include <rpc/rpcb_clnt.h> 219 #include <netconfig.h> 220 #endif 221 222 #include <ctype.h> 223 #include <errno.h> 224 #include <fcntl.h> 225 #include <grp.h> 226 #include <netdb.h> 227 #include <pwd.h> 228 #include <signal.h> 229 #include <stdio.h> 230 #include <stdlib.h> 231 #include <string.h> 232 #include <syslog.h> 233 #include <unistd.h> 234 #include <util.h> 235 236 #include "pathnames.h" 237 238 #ifdef IPSEC 239 #include <netinet6/ipsec.h> 240 #ifndef IPSEC_POLICY_IPSEC /* no ipsec support on old ipsec */ 241 #undef IPSEC 242 #endif 243 #include "ipsec.h" 244 #endif 245 246 #ifdef LIBWRAP 247 # include <tcpd.h> 248 #ifndef LIBWRAP_ALLOW_FACILITY 249 # define LIBWRAP_ALLOW_FACILITY LOG_AUTH 250 #endif 251 #ifndef LIBWRAP_ALLOW_SEVERITY 252 # define LIBWRAP_ALLOW_SEVERITY LOG_INFO 253 #endif 254 #ifndef LIBWRAP_DENY_FACILITY 255 # define LIBWRAP_DENY_FACILITY LOG_AUTH 256 #endif 257 #ifndef LIBWRAP_DENY_SEVERITY 258 # define LIBWRAP_DENY_SEVERITY LOG_WARNING 259 #endif 260 int allow_severity = LIBWRAP_ALLOW_FACILITY|LIBWRAP_ALLOW_SEVERITY; 261 int deny_severity = LIBWRAP_DENY_FACILITY|LIBWRAP_DENY_SEVERITY; 262 #endif 263 264 #define TOOMANY 40 /* don't start more than TOOMANY */ 265 #define CNT_INTVL 60 /* servers in CNT_INTVL sec. */ 266 #define RETRYTIME (60*10) /* retry after bind or server fail */ 267 268 #define SIGBLOCK (sigmask(SIGCHLD)|sigmask(SIGHUP)|sigmask(SIGALRM)) 269 270 int debug; 271 #ifdef LIBWRAP 272 int lflag; 273 #endif 274 int nsock, maxsock; 275 fd_set allsock; 276 int options; 277 int timingout; 278 struct servent *sp; 279 char *curdom; 280 #ifdef NI_WITHSCOPEID 281 const int niflags = NI_NUMERICHOST | NI_NUMERICSERV | NI_WITHSCOPEID; 282 #else 283 const int niflags = NI_NUMERICHOST | NI_NUMERICSERV; 284 #endif 285 286 #ifndef OPEN_MAX 287 #define OPEN_MAX 64 288 #endif 289 290 /* Reserve some descriptors, 3 stdio + at least: 1 log, 1 conf. file */ 291 #define FD_MARGIN (8) 292 rlim_t rlim_ofile_cur = OPEN_MAX; 293 294 #ifdef RLIMIT_NOFILE 295 struct rlimit rlim_ofile; 296 #endif 297 298 struct servtab { 299 char *se_hostaddr; /* host address to listen on */ 300 char *se_service; /* name of service */ 301 int se_socktype; /* type of socket to use */ 302 int se_family; /* address family */ 303 char *se_proto; /* protocol used */ 304 int se_sndbuf; /* sndbuf size */ 305 int se_rcvbuf; /* rcvbuf size */ 306 int se_rpcprog; /* rpc program number */ 307 int se_rpcversl; /* rpc program lowest version */ 308 int se_rpcversh; /* rpc program highest version */ 309 #define isrpcservice(sep) ((sep)->se_rpcversl != 0) 310 pid_t se_wait; /* single threaded server */ 311 short se_checked; /* looked at during merge */ 312 char *se_user; /* user name to run as */ 313 char *se_group; /* group name to run as */ 314 struct biltin *se_bi; /* if built-in, description */ 315 char *se_server; /* server program */ 316 #define MAXARGV 20 317 char *se_argv[MAXARGV+1]; /* program arguments */ 318 #ifdef IPSEC 319 char *se_policy; /* IPsec poilcy string */ 320 #endif 321 int se_fd; /* open descriptor */ 322 int se_type; /* type */ 323 union { 324 struct sockaddr se_un_ctrladdr; 325 struct sockaddr_in se_un_ctrladdr_in; 326 struct sockaddr_in6 se_un_ctrladdr_in6; 327 struct sockaddr_un se_un_ctrladdr_un; 328 } se_un; /* bound address */ 329 #define se_ctrladdr se_un.se_un_ctrladdr 330 #define se_ctrladdr_in se_un.se_un_ctrladdr_in 331 #define se_ctrladdr_un se_un.se_un_ctrladdr_un 332 int se_ctrladdr_size; 333 int se_max; /* max # of instances of this service */ 334 int se_count; /* number started since se_time */ 335 struct timeval se_time; /* start of se_count */ 336 #ifdef MULOG 337 int se_log; 338 #define MULOG_RFC931 0x40000000 339 #endif 340 struct servtab *se_next; 341 } *servtab; 342 343 #define NORM_TYPE 0 344 #define MUX_TYPE 1 345 #define MUXPLUS_TYPE 2 346 #define ISMUX(sep) (((sep)->se_type == MUX_TYPE) || \ 347 ((sep)->se_type == MUXPLUS_TYPE)) 348 #define ISMUXPLUS(sep) ((sep)->se_type == MUXPLUS_TYPE) 349 350 351 void chargen_dg __P((int, struct servtab *)); 352 void chargen_stream __P((int, struct servtab *)); 353 void close_sep __P((struct servtab *)); 354 void config __P((int)); 355 void daytime_dg __P((int, struct servtab *)); 356 void daytime_stream __P((int, struct servtab *)); 357 void discard_dg __P((int, struct servtab *)); 358 void discard_stream __P((int, struct servtab *)); 359 void echo_dg __P((int, struct servtab *)); 360 void echo_stream __P((int, struct servtab *)); 361 void endconfig __P((void)); 362 struct servtab *enter __P((struct servtab *)); 363 void freeconfig __P((struct servtab *)); 364 struct servtab *getconfigent __P((void)); 365 void goaway __P((int)); 366 void machtime_dg __P((int, struct servtab *)); 367 void machtime_stream __P((int, struct servtab *)); 368 char *newstr __P((char *)); 369 char *nextline __P((FILE *)); 370 void print_service __P((char *, struct servtab *)); 371 void reapchild __P((int)); 372 void retry __P((int)); 373 void run_service __P((int, struct servtab *)); 374 int setconfig __P((void)); 375 void setup __P((struct servtab *)); 376 char *sskip __P((char **)); 377 char *skip __P((char **)); 378 void tcpmux __P((int, struct servtab *)); 379 void usage __P((void)); 380 void register_rpc __P((struct servtab *sep)); 381 void unregister_rpc __P((struct servtab *sep)); 382 void bump_nofile __P((void)); 383 void inetd_setproctitle __P((char *, int)); 384 void initring __P((void)); 385 long machtime __P((void)); 386 int port_good_dg __P((struct sockaddr *sa)); 387 static int getline __P((int, char *, int)); 388 int main __P((int, char *[], char *[])); 389 390 struct biltin { 391 char *bi_service; /* internally provided service name */ 392 int bi_socktype; /* type of socket supported */ 393 short bi_fork; /* 1 if should fork before call */ 394 short bi_wait; /* 1 if should wait for child */ 395 void (*bi_fn) __P((int, struct servtab *)); 396 /* function which performs it */ 397 } biltins[] = { 398 /* Echo received data */ 399 { "echo", SOCK_STREAM, 1, 0, echo_stream }, 400 { "echo", SOCK_DGRAM, 0, 0, echo_dg }, 401 402 /* Internet /dev/null */ 403 { "discard", SOCK_STREAM, 1, 0, discard_stream }, 404 { "discard", SOCK_DGRAM, 0, 0, discard_dg }, 405 406 /* Return 32 bit time since 1970 */ 407 { "time", SOCK_STREAM, 0, 0, machtime_stream }, 408 { "time", SOCK_DGRAM, 0, 0, machtime_dg }, 409 410 /* Return human-readable time */ 411 { "daytime", SOCK_STREAM, 0, 0, daytime_stream }, 412 { "daytime", SOCK_DGRAM, 0, 0, daytime_dg }, 413 414 /* Familiar character generator */ 415 { "chargen", SOCK_STREAM, 1, 0, chargen_stream }, 416 { "chargen", SOCK_DGRAM, 0, 0, chargen_dg }, 417 418 { "tcpmux", SOCK_STREAM, 1, 0, tcpmux }, 419 420 { NULL } 421 }; 422 423 /* list of "bad" ports. I.e. ports that are most obviously used for 424 * "cycling packets" denial of service attacks. See /etc/services. 425 * List must end with port number "0". 426 */ 427 428 u_int16_t bad_ports[] = { 7, 9, 13, 19, 37, 0}; 429 430 431 #define NUMINT (sizeof(intab) / sizeof(struct inent)) 432 char *CONFIG = _PATH_INETDCONF; 433 char **Argv; 434 char *LastArg; 435 extern char *__progname; 436 437 int 438 main(argc, argv, envp) 439 int argc; 440 char *argv[], *envp[]; 441 { 442 struct servtab *sep, *nsep; 443 struct sigvec sv; 444 int ch, dofork; 445 pid_t pid; 446 447 Argv = argv; 448 if (envp == 0 || *envp == 0) 449 envp = argv; 450 while (*envp) 451 envp++; 452 LastArg = envp[-1] + strlen(envp[-1]); 453 454 while ((ch = getopt(argc, argv, 455 #ifdef LIBWRAP 456 "dl" 457 #else 458 "d" 459 #endif 460 )) != -1) 461 switch(ch) { 462 case 'd': 463 debug = 1; 464 options |= SO_DEBUG; 465 break; 466 #ifdef LIBWRAP 467 case 'l': 468 lflag = 1; 469 break; 470 #endif 471 case '?': 472 default: 473 usage(); 474 } 475 argc -= optind; 476 argv += optind; 477 478 if (argc > 0) 479 CONFIG = argv[0]; 480 481 if (debug == 0) 482 daemon(0, 0); 483 openlog(__progname, LOG_PID | LOG_NOWAIT, LOG_DAEMON); 484 pidfile(NULL); 485 486 #ifdef RLIMIT_NOFILE 487 if (getrlimit(RLIMIT_NOFILE, &rlim_ofile) < 0) { 488 syslog(LOG_ERR, "getrlimit: %m"); 489 } else { 490 rlim_ofile_cur = rlim_ofile.rlim_cur; 491 if (rlim_ofile_cur == RLIM_INFINITY) /* ! */ 492 rlim_ofile_cur = OPEN_MAX; 493 } 494 #endif 495 496 memset(&sv, 0, sizeof(sv)); 497 sv.sv_mask = SIGBLOCK; 498 sv.sv_handler = retry; 499 sigvec(SIGALRM, &sv, (struct sigvec *)0); 500 config(SIGHUP); 501 sv.sv_handler = config; 502 sigvec(SIGHUP, &sv, (struct sigvec *)0); 503 sv.sv_handler = reapchild; 504 sigvec(SIGCHLD, &sv, (struct sigvec *)0); 505 sv.sv_handler = goaway; 506 sigvec(SIGTERM, &sv, (struct sigvec *)0); 507 sv.sv_handler = goaway; 508 sigvec(SIGINT, &sv, (struct sigvec *)0); 509 sv.sv_mask = 0L; 510 sv.sv_handler = SIG_IGN; 511 sigvec(SIGPIPE, &sv, (struct sigvec *)0); 512 513 { 514 /* space for daemons to overwrite environment for ps */ 515 #define DUMMYSIZE 100 516 char dummy[DUMMYSIZE]; 517 518 (void)memset(dummy, 'x', DUMMYSIZE - 1); 519 dummy[DUMMYSIZE - 1] = '\0'; 520 521 (void)setenv("inetd_dummy", dummy, 1); 522 } 523 524 for (;;) { 525 int n, ctrl; 526 fd_set readable; 527 528 if (nsock == 0) { 529 (void) sigblock(SIGBLOCK); 530 while (nsock == 0) 531 sigpause(0L); 532 (void) sigsetmask(0L); 533 } 534 readable = allsock; 535 if ((n = select(maxsock + 1, &readable, (fd_set *)0, 536 (fd_set *)0, (struct timeval *)0)) <= 0) { 537 if (n == -1 && errno != EINTR) { 538 syslog(LOG_WARNING, "select: %m"); 539 sleep(1); 540 } 541 continue; 542 } 543 for (sep = servtab; n && sep; sep = nsep) { 544 nsep = sep->se_next; 545 if (sep->se_fd != -1 && FD_ISSET(sep->se_fd, &readable)) { 546 n--; 547 if (debug) 548 fprintf(stderr, "someone wants %s\n", sep->se_service); 549 if (!sep->se_wait && sep->se_socktype == SOCK_STREAM) { 550 /* XXX here do the libwrap check-before-accept */ 551 ctrl = accept(sep->se_fd, (struct sockaddr *)0, 552 (int *)0); 553 if (debug) 554 fprintf(stderr, "accept, ctrl %d\n", ctrl); 555 if (ctrl < 0) { 556 if (errno != EINTR) 557 syslog(LOG_WARNING, 558 "accept (for %s): %m", 559 sep->se_service); 560 continue; 561 } 562 } else 563 ctrl = sep->se_fd; 564 (void) sigblock(SIGBLOCK); 565 pid = 0; 566 #ifdef LIBWRAP_INTERNAL 567 dofork = 1; 568 #else 569 dofork = (sep->se_bi == 0 || sep->se_bi->bi_fork); 570 #endif 571 if (dofork) { 572 if (sep->se_count++ == 0) 573 (void)gettimeofday(&sep->se_time, 574 (struct timezone *)0); 575 else if (sep->se_count >= sep->se_max) { 576 struct timeval now; 577 578 (void)gettimeofday(&now, (struct timezone *)0); 579 if (now.tv_sec - sep->se_time.tv_sec > 580 CNT_INTVL) { 581 sep->se_time = now; 582 sep->se_count = 1; 583 } else { 584 syslog(LOG_ERR, 585 "%s/%s server failing (looping), service terminated\n", 586 sep->se_service, sep->se_proto); 587 if (!sep->se_wait && sep->se_socktype == SOCK_STREAM) 588 close(ctrl); 589 close_sep(sep); 590 sigsetmask(0L); 591 if (!timingout) { 592 timingout = 1; 593 alarm(RETRYTIME); 594 } 595 continue; 596 } 597 } 598 pid = fork(); 599 if (pid < 0) { 600 syslog(LOG_ERR, "fork: %m"); 601 if (!sep->se_wait && sep->se_socktype == SOCK_STREAM) 602 close(ctrl); 603 sigsetmask(0L); 604 sleep(1); 605 continue; 606 } 607 if (pid != 0 && sep->se_wait) { 608 sep->se_wait = pid; 609 FD_CLR(sep->se_fd, &allsock); 610 nsock--; 611 } 612 if (pid == 0) { 613 sv.sv_mask = 0L; 614 sv.sv_handler = SIG_DFL; 615 sigvec(SIGPIPE, &sv, (struct sigvec *)0); 616 if (debug) 617 setsid(); 618 } 619 } 620 sigsetmask(0L); 621 if (pid == 0) { 622 run_service(ctrl, sep); 623 if (dofork) 624 exit(0); 625 } 626 if (!sep->se_wait && sep->se_socktype == SOCK_STREAM) 627 close(ctrl); 628 } 629 } 630 } 631 } 632 633 void 634 run_service(ctrl, sep) 635 int ctrl; 636 struct servtab *sep; 637 { 638 struct passwd *pwd; 639 struct group *grp = NULL; /* XXX gcc */ 640 char buf[NI_MAXSERV]; 641 #ifdef LIBWRAP 642 struct request_info req; 643 int denied; 644 char *service = NULL; /* XXX gcc */ 645 #endif 646 647 #ifdef LIBWRAP 648 #ifndef LIBWRAP_INTERNAL 649 if (sep->se_bi == 0) 650 #endif 651 if (!sep->se_wait && sep->se_socktype == SOCK_STREAM) { 652 request_init(&req, RQ_DAEMON, sep->se_argv[0] ? 653 sep->se_argv[0] : sep->se_service, RQ_FILE, ctrl, NULL); 654 fromhost(&req); 655 denied = !hosts_access(&req); 656 if (denied || lflag) { 657 if (getnameinfo(&sep->se_ctrladdr, 658 sep->se_ctrladdr.sa_len, NULL, 0, 659 buf, sizeof(buf), 0) != 0) { 660 /* shouldn't happen */ 661 (void)snprintf(buf, sizeof buf, "%d", 662 ntohs(sep->se_ctrladdr_in.sin_port)); 663 } 664 service = buf; 665 } 666 if (denied) { 667 syslog(deny_severity, 668 "refused connection from %.500s, service %s (%s)", 669 eval_client(&req), service, sep->se_proto); 670 goto reject; 671 } 672 if (lflag) { 673 syslog(allow_severity, 674 "connection from %.500s, service %s (%s)", 675 eval_client(&req), service, sep->se_proto); 676 } 677 } 678 #endif /* LIBWRAP */ 679 680 if (sep->se_bi) { 681 (*sep->se_bi->bi_fn)(ctrl, sep); 682 } else { 683 if ((pwd = getpwnam(sep->se_user)) == NULL) { 684 syslog(LOG_ERR, "%s/%s: %s: No such user", 685 sep->se_service, sep->se_proto, sep->se_user); 686 goto reject; 687 } 688 if (sep->se_group && 689 (grp = getgrnam(sep->se_group)) == NULL) { 690 syslog(LOG_ERR, "%s/%s: %s: No such group", 691 sep->se_service, sep->se_proto, sep->se_group); 692 goto reject; 693 } 694 if (pwd->pw_uid) { 695 if (sep->se_group) 696 pwd->pw_gid = grp->gr_gid; 697 if (setgid(pwd->pw_gid) < 0) { 698 syslog(LOG_ERR, 699 "%s/%s: can't set gid %d: %m", sep->se_service, 700 sep->se_proto, pwd->pw_gid); 701 goto reject; 702 } 703 (void) initgroups(pwd->pw_name, 704 pwd->pw_gid); 705 if (setuid(pwd->pw_uid) < 0) { 706 syslog(LOG_ERR, 707 "%s/%s: can't set uid %d: %m", sep->se_service, 708 sep->se_proto, pwd->pw_uid); 709 goto reject; 710 } 711 } else if (sep->se_group) { 712 (void) setgid((gid_t)grp->gr_gid); 713 } 714 if (debug) 715 fprintf(stderr, "%d execl %s\n", 716 getpid(), sep->se_server); 717 #ifdef MULOG 718 if (sep->se_log) 719 dolog(sep, ctrl); 720 #endif 721 /* Set our control descriptor to not close-on-exec... */ 722 if (fcntl(ctrl, F_SETFD, 0) < 0) 723 syslog(LOG_ERR, "fcntl (F_SETFD, 0): %m"); 724 /* ...and dup it to stdin, stdout, and stderr. */ 725 if (ctrl != 0) { 726 dup2(ctrl, 0); 727 close(ctrl); 728 ctrl = 0; 729 } 730 dup2(0, 1); 731 dup2(0, 2); 732 #ifdef RLIMIT_NOFILE 733 if (rlim_ofile.rlim_cur != rlim_ofile_cur && 734 setrlimit(RLIMIT_NOFILE, &rlim_ofile) < 0) 735 syslog(LOG_ERR, "setrlimit: %m"); 736 #endif 737 execv(sep->se_server, sep->se_argv); 738 syslog(LOG_ERR, "cannot execute %s: %m", sep->se_server); 739 reject: 740 if (sep->se_socktype != SOCK_STREAM) 741 recv(ctrl, buf, sizeof (buf), 0); 742 _exit(1); 743 } 744 } 745 746 void 747 reapchild(signo) 748 int signo; 749 { 750 int status; 751 pid_t pid; 752 struct servtab *sep; 753 754 for (;;) { 755 pid = wait3(&status, WNOHANG, (struct rusage *)0); 756 if (pid <= 0) 757 break; 758 if (debug) 759 fprintf(stderr, "%d reaped, status %#x\n", 760 pid, status); 761 for (sep = servtab; sep; sep = sep->se_next) 762 if (sep->se_wait == pid) { 763 if (WIFEXITED(status) && WEXITSTATUS(status)) 764 syslog(LOG_WARNING, 765 "%s: exit status 0x%x", 766 sep->se_server, WEXITSTATUS(status)); 767 else if (WIFSIGNALED(status)) 768 syslog(LOG_WARNING, 769 "%s: exit signal 0x%x", 770 sep->se_server, WTERMSIG(status)); 771 sep->se_wait = 1; 772 FD_SET(sep->se_fd, &allsock); 773 nsock++; 774 if (debug) 775 fprintf(stderr, "restored %s, fd %d\n", 776 sep->se_service, sep->se_fd); 777 } 778 } 779 } 780 781 void 782 config(signo) 783 int signo; 784 { 785 struct servtab *sep, *cp, **sepp; 786 long omask; 787 int n; 788 789 if (!setconfig()) { 790 syslog(LOG_ERR, "%s: %m", CONFIG); 791 return; 792 } 793 for (sep = servtab; sep; sep = sep->se_next) 794 sep->se_checked = 0; 795 while ((cp = getconfigent())) { 796 for (sep = servtab; sep; sep = sep->se_next) 797 if (strcmp(sep->se_service, cp->se_service) == 0 && 798 strcmp(sep->se_hostaddr, cp->se_hostaddr) == 0 && 799 strcmp(sep->se_proto, cp->se_proto) == 0 && 800 ISMUX(sep) == ISMUX(cp)) 801 break; 802 if (sep != 0) { 803 int i; 804 805 #define SWAP(type, a, b) {type c=(type)a; (type)a=(type)b; (type)b=(type)c;} 806 807 omask = sigblock(SIGBLOCK); 808 /* 809 * sep->se_wait may be holding the pid of a daemon 810 * that we're waiting for. If so, don't overwrite 811 * it unless the config file explicitly says don't 812 * wait. 813 */ 814 if (cp->se_bi == 0 && 815 (sep->se_wait == 1 || cp->se_wait == 0)) 816 sep->se_wait = cp->se_wait; 817 SWAP(char *, sep->se_user, cp->se_user); 818 SWAP(char *, sep->se_group, cp->se_group); 819 SWAP(char *, sep->se_server, cp->se_server); 820 for (i = 0; i < MAXARGV; i++) 821 SWAP(char *, sep->se_argv[i], cp->se_argv[i]); 822 #ifdef IPSEC 823 SWAP(char *, sep->se_policy, cp->se_policy); 824 #endif 825 SWAP(int, cp->se_type, sep->se_type); 826 SWAP(int, cp->se_max, sep->se_max); 827 #undef SWAP 828 if (isrpcservice(sep)) 829 unregister_rpc(sep); 830 sep->se_rpcversl = cp->se_rpcversl; 831 sep->se_rpcversh = cp->se_rpcversh; 832 sigsetmask(omask); 833 freeconfig(cp); 834 if (debug) 835 print_service("REDO", sep); 836 } else { 837 sep = enter(cp); 838 if (debug) 839 print_service("ADD ", sep); 840 } 841 sep->se_checked = 1; 842 843 switch (sep->se_family) { 844 case AF_LOCAL: 845 if (sep->se_fd != -1) 846 break; 847 n = strlen(sep->se_service); 848 if (n > sizeof(sep->se_ctrladdr_un.sun_path)) { 849 syslog(LOG_ERR, "%s: address too long", 850 sep->se_service); 851 sep->se_checked = 0; 852 continue; 853 } 854 (void)unlink(sep->se_service); 855 strncpy(sep->se_ctrladdr_un.sun_path, 856 sep->se_service, n); 857 sep->se_ctrladdr_un.sun_family = AF_LOCAL; 858 sep->se_ctrladdr_size = n + 859 sizeof(sep->se_ctrladdr_un) - 860 sizeof(sep->se_ctrladdr_un.sun_path); 861 if (!ISMUX(sep)) 862 setup(sep); 863 break; 864 case AF_INET: 865 #ifdef INET6 866 case AF_INET6: 867 #endif 868 { 869 struct addrinfo hints, *res; 870 char *host, *port; 871 int error; 872 int s; 873 874 /* check if the family is supported */ 875 s = socket(sep->se_family, SOCK_DGRAM, 0); 876 if (s < 0) { 877 syslog(LOG_WARNING, 878 "%s/%s: %s: the address family is not supported by the kernel", 879 sep->se_service, sep->se_proto, 880 sep->se_hostaddr); 881 sep->se_checked = 0; 882 continue; 883 } 884 close(s); 885 886 memset(&hints, 0, sizeof(hints)); 887 hints.ai_family = sep->se_family; 888 hints.ai_socktype = sep->se_socktype; 889 hints.ai_flags = AI_PASSIVE; 890 if (!strcmp(sep->se_hostaddr, "*")) 891 host = NULL; 892 else 893 host = sep->se_hostaddr; 894 if (isrpcservice(sep) || ISMUX(sep)) 895 port = "0"; 896 else 897 port = sep->se_service; 898 error = getaddrinfo(host, port, &hints, &res); 899 if (error) { 900 if (error == EAI_SERVICE) { 901 /* gai_strerror not friendly enough */ 902 syslog(LOG_WARNING, "%s/%s: " 903 "unknown service", 904 sep->se_service, sep->se_proto); 905 } else { 906 syslog(LOG_ERR, "%s/%s: %s: %s", 907 sep->se_service, sep->se_proto, 908 sep->se_hostaddr, 909 gai_strerror(error)); 910 } 911 sep->se_checked = 0; 912 continue; 913 } 914 if (res->ai_next) { 915 syslog(LOG_ERR, 916 "%s/%s: %s: resolved to multiple addr", 917 sep->se_service, sep->se_proto, 918 sep->se_hostaddr); 919 sep->se_checked = 0; 920 freeaddrinfo(res); 921 continue; 922 } 923 memcpy(&sep->se_ctrladdr, res->ai_addr, 924 res->ai_addrlen); 925 if (ISMUX(sep)) { 926 sep->se_fd = -1; 927 freeaddrinfo(res); 928 continue; 929 } 930 sep->se_ctrladdr_size = res->ai_addrlen; 931 freeaddrinfo(res); 932 #ifdef RPC 933 if (isrpcservice(sep)) { 934 struct rpcent *rp; 935 936 sep->se_rpcprog = atoi(sep->se_service); 937 if (sep->se_rpcprog == 0) { 938 rp = getrpcbyname(sep->se_service); 939 if (rp == 0) { 940 syslog(LOG_ERR, 941 "%s/%s: unknown service", 942 sep->se_service, 943 sep->se_proto); 944 sep->se_checked = 0; 945 continue; 946 } 947 sep->se_rpcprog = rp->r_number; 948 } 949 if (sep->se_fd == -1 && !ISMUX(sep)) 950 setup(sep); 951 if (sep->se_fd != -1) 952 register_rpc(sep); 953 } else 954 #endif 955 { 956 if (sep->se_fd >= 0) 957 close_sep(sep); 958 if (sep->se_fd == -1 && !ISMUX(sep)) 959 setup(sep); 960 } 961 } 962 } 963 } 964 endconfig(); 965 /* 966 * Purge anything not looked at above. 967 */ 968 omask = sigblock(SIGBLOCK); 969 sepp = &servtab; 970 while ((sep = *sepp)) { 971 if (sep->se_checked) { 972 sepp = &sep->se_next; 973 continue; 974 } 975 *sepp = sep->se_next; 976 if (sep->se_fd >= 0) 977 close_sep(sep); 978 if (isrpcservice(sep)) 979 unregister_rpc(sep); 980 if (sep->se_family == AF_LOCAL) 981 (void)unlink(sep->se_service); 982 if (debug) 983 print_service("FREE", sep); 984 freeconfig(sep); 985 free((char *)sep); 986 } 987 (void) sigsetmask(omask); 988 } 989 990 void 991 retry(signo) 992 int signo; 993 { 994 struct servtab *sep; 995 996 timingout = 0; 997 for (sep = servtab; sep; sep = sep->se_next) { 998 if (sep->se_fd == -1 && !ISMUX(sep)) { 999 switch (sep->se_family) { 1000 case AF_LOCAL: 1001 case AF_INET: 1002 #ifdef INET6 1003 case AF_INET6: 1004 #endif 1005 setup(sep); 1006 if (sep->se_fd != -1 && isrpcservice(sep)) 1007 register_rpc(sep); 1008 break; 1009 } 1010 } 1011 } 1012 } 1013 1014 void 1015 goaway(signo) 1016 int signo; 1017 { 1018 struct servtab *sep; 1019 1020 for (sep = servtab; sep; sep = sep->se_next) { 1021 if (sep->se_fd == -1) 1022 continue; 1023 1024 switch (sep->se_family) { 1025 case AF_LOCAL: 1026 (void)unlink(sep->se_service); 1027 break; 1028 case AF_INET: 1029 #ifdef INET6 1030 case AF_INET6: 1031 #endif 1032 if (sep->se_wait == 1 && isrpcservice(sep)) 1033 unregister_rpc(sep); 1034 break; 1035 } 1036 (void)close(sep->se_fd); 1037 } 1038 exit(0); 1039 } 1040 1041 void 1042 setup(sep) 1043 struct servtab *sep; 1044 { 1045 int on = 1; 1046 1047 if ((sep->se_fd = socket(sep->se_family, sep->se_socktype, 0)) < 0) { 1048 if (debug) 1049 fprintf(stderr, "socket failed on %s/%s: %s\n", 1050 sep->se_service, sep->se_proto, strerror(errno)); 1051 syslog(LOG_ERR, "%s/%s: socket: %m", 1052 sep->se_service, sep->se_proto); 1053 return; 1054 } 1055 /* Set all listening sockets to close-on-exec. */ 1056 if (fcntl(sep->se_fd, F_SETFD, FD_CLOEXEC) < 0) 1057 syslog(LOG_ERR, "fcntl (F_SETFD, FD_CLOEXEC): %m"); 1058 1059 #define turnon(fd, opt) \ 1060 setsockopt(fd, SOL_SOCKET, opt, (char *)&on, sizeof (on)) 1061 if (strcmp(sep->se_proto, "tcp") == 0 && (options & SO_DEBUG) && 1062 turnon(sep->se_fd, SO_DEBUG) < 0) 1063 syslog(LOG_ERR, "setsockopt (SO_DEBUG): %m"); 1064 if (turnon(sep->se_fd, SO_REUSEADDR) < 0) 1065 syslog(LOG_ERR, "setsockopt (SO_REUSEADDR): %m"); 1066 #undef turnon 1067 1068 /* Set the socket buffer sizes, if specified. */ 1069 if (sep->se_sndbuf != 0 && setsockopt(sep->se_fd, SOL_SOCKET, 1070 SO_SNDBUF, (char *)&sep->se_sndbuf, sizeof(sep->se_sndbuf)) < 0) 1071 syslog(LOG_ERR, "setsockopt (SO_SNDBUF %d): %m", 1072 sep->se_sndbuf); 1073 if (sep->se_rcvbuf != 0 && setsockopt(sep->se_fd, SOL_SOCKET, 1074 SO_RCVBUF, (char *)&sep->se_rcvbuf, sizeof(sep->se_rcvbuf)) < 0) 1075 syslog(LOG_ERR, "setsockopt (SO_RCVBUF %d): %m", 1076 sep->se_rcvbuf); 1077 #ifdef IPSEC 1078 if (ipsecsetup(sep->se_family, sep->se_fd, sep->se_policy) < 0 && 1079 sep->se_policy) { 1080 syslog(LOG_ERR, "%s/%s: ipsec setup failed", 1081 sep->se_service, sep->se_proto); 1082 (void)close(sep->se_fd); 1083 sep->se_fd = -1; 1084 return; 1085 } 1086 #endif 1087 1088 if (bind(sep->se_fd, &sep->se_ctrladdr, sep->se_ctrladdr_size) < 0) { 1089 if (debug) 1090 fprintf(stderr, "bind failed on %s/%s: %s\n", 1091 sep->se_service, sep->se_proto, strerror(errno)); 1092 syslog(LOG_ERR, "%s/%s: bind: %m", 1093 sep->se_service, sep->se_proto); 1094 (void) close(sep->se_fd); 1095 sep->se_fd = -1; 1096 if (!timingout) { 1097 timingout = 1; 1098 alarm(RETRYTIME); 1099 } 1100 return; 1101 } 1102 if (sep->se_socktype == SOCK_STREAM) 1103 listen(sep->se_fd, 10); 1104 1105 FD_SET(sep->se_fd, &allsock); 1106 nsock++; 1107 if (sep->se_fd > maxsock) { 1108 maxsock = sep->se_fd; 1109 if (maxsock > rlim_ofile_cur - FD_MARGIN) 1110 bump_nofile(); 1111 } 1112 if (debug) 1113 fprintf(stderr, "registered %s on %d\n", 1114 sep->se_server, sep->se_fd); 1115 } 1116 1117 /* 1118 * Finish with a service and its socket. 1119 */ 1120 void 1121 close_sep(sep) 1122 struct servtab *sep; 1123 { 1124 if (sep->se_fd >= 0) { 1125 nsock--; 1126 FD_CLR(sep->se_fd, &allsock); 1127 (void) close(sep->se_fd); 1128 sep->se_fd = -1; 1129 } 1130 sep->se_count = 0; 1131 /* 1132 * Don't keep the pid of this running deamon: when reapchild() 1133 * reaps this pid, it would erroneously increment nsock. 1134 */ 1135 if (sep->se_wait > 1) 1136 sep->se_wait = 1; 1137 } 1138 1139 void 1140 register_rpc(sep) 1141 struct servtab *sep; 1142 { 1143 #ifdef RPC 1144 int n; 1145 struct netbuf nbuf; 1146 struct sockaddr_storage ss; 1147 struct netconfig *nconf; 1148 1149 if ((nconf = getnetconfigent(sep->se_proto+4)) == NULL) { 1150 syslog(LOG_ERR, "%s: getnetconfigent failed", 1151 sep->se_proto); 1152 return; 1153 } 1154 n = sizeof ss; 1155 if (getsockname(sep->se_fd, (struct sockaddr *)&ss, &n) < 0) { 1156 syslog(LOG_ERR, "%s/%s: getsockname: %m", 1157 sep->se_service, sep->se_proto); 1158 return; 1159 } 1160 1161 nbuf.buf = &ss; 1162 nbuf.len = ss.ss_len; 1163 nbuf.maxlen = sizeof (struct sockaddr_storage); 1164 for (n = sep->se_rpcversl; n <= sep->se_rpcversh; n++) { 1165 if (debug) 1166 fprintf(stderr, "rpcb_set: %u %d %s %s\n", 1167 sep->se_rpcprog, n, nconf->nc_netid, 1168 taddr2uaddr(nconf, &nbuf)); 1169 (void)rpcb_unset(sep->se_rpcprog, n, nconf); 1170 if (!rpcb_set(sep->se_rpcprog, n, nconf, &nbuf)) 1171 syslog(LOG_ERR, "rpcb_set: %u %d %s %s%s", 1172 sep->se_rpcprog, n, nconf->nc_netid, 1173 taddr2uaddr(nconf, &nbuf), clnt_spcreateerror("")); 1174 } 1175 #endif /* RPC */ 1176 } 1177 1178 void 1179 unregister_rpc(sep) 1180 struct servtab *sep; 1181 { 1182 #ifdef RPC 1183 int n; 1184 struct netconfig *nconf; 1185 1186 if ((nconf = getnetconfigent(sep->se_proto+4)) == NULL) { 1187 syslog(LOG_ERR, "%s: getnetconfigent failed", 1188 sep->se_proto); 1189 return; 1190 } 1191 1192 for (n = sep->se_rpcversl; n <= sep->se_rpcversh; n++) { 1193 if (debug) 1194 fprintf(stderr, "rpcb_unset(%u, %d, %s)\n", 1195 sep->se_rpcprog, n, nconf->nc_netid); 1196 if (!rpcb_unset(sep->se_rpcprog, n, nconf)) 1197 syslog(LOG_ERR, "rpcb_unset(%u, %d, %s) failed\n", 1198 sep->se_rpcprog, n, nconf->nc_netid); 1199 } 1200 #endif /* RPC */ 1201 } 1202 1203 1204 struct servtab * 1205 enter(cp) 1206 struct servtab *cp; 1207 { 1208 struct servtab *sep; 1209 long omask; 1210 1211 sep = (struct servtab *)malloc(sizeof (*sep)); 1212 if (sep == (struct servtab *)0) { 1213 syslog(LOG_ERR, "Out of memory."); 1214 exit(-1); 1215 } 1216 *sep = *cp; 1217 sep->se_fd = -1; 1218 sep->se_rpcprog = -1; 1219 omask = sigblock(SIGBLOCK); 1220 sep->se_next = servtab; 1221 servtab = sep; 1222 sigsetmask(omask); 1223 return (sep); 1224 } 1225 1226 FILE *fconfig = NULL; 1227 struct servtab serv; 1228 char line[LINE_MAX]; 1229 char *defhost; 1230 #ifdef IPSEC 1231 static char *policy = NULL; 1232 #endif 1233 1234 int 1235 setconfig() 1236 { 1237 if (defhost) 1238 free(defhost); 1239 defhost = newstr("*"); 1240 #ifdef IPSEC 1241 if (policy) 1242 free(policy); 1243 policy = NULL; 1244 #endif 1245 if (fconfig != NULL) { 1246 fseek(fconfig, 0L, SEEK_SET); 1247 return (1); 1248 } 1249 fconfig = fopen(CONFIG, "r"); 1250 return (fconfig != NULL); 1251 } 1252 1253 void 1254 endconfig() 1255 { 1256 if (fconfig) { 1257 (void) fclose(fconfig); 1258 fconfig = NULL; 1259 } 1260 if (defhost) { 1261 free(defhost); 1262 defhost = 0; 1263 } 1264 } 1265 1266 struct servtab * 1267 getconfigent() 1268 { 1269 struct servtab *sep = &serv; 1270 int argc, val; 1271 char *cp, *cp0, *arg, *buf0, *buf1, *sz0, *sz1; 1272 static char TCPMUX_TOKEN[] = "tcpmux/"; 1273 #define MUX_LEN (sizeof(TCPMUX_TOKEN)-1) 1274 char *hostdelim; 1275 1276 more: 1277 while ((cp = nextline(fconfig))) { 1278 #ifdef IPSEC 1279 /* lines starting with #@ is not a comment, but the policy */ 1280 if (cp[0] == '#' && cp[1] == '@') { 1281 char *p; 1282 for (p = cp + 2; p && *p && isspace(*p); p++) 1283 ; 1284 if (*p == '\0') { 1285 if (policy) 1286 free(policy); 1287 policy = NULL; 1288 } else { 1289 if (ipsecsetup_test(p) < 0) { 1290 syslog(LOG_ERR, 1291 "%s: invalid ipsec policy \"%s\"", 1292 CONFIG, p); 1293 exit(-1); 1294 } else { 1295 if (policy) 1296 free(policy); 1297 policy = newstr(p); 1298 } 1299 } 1300 } 1301 #endif 1302 if (*cp == '#' || *cp == '\0') 1303 continue; 1304 #ifdef MULOG 1305 /* Avoid use of `skip' if there is a danger of it looking 1306 * at continuation lines. 1307 */ 1308 do { 1309 cp++; 1310 } while (*cp == ' ' || *cp == '\t'); 1311 if (*cp == '\0') 1312 continue; 1313 if ((arg = skip(&cp)) == NULL) 1314 continue; 1315 if (strcmp(arg, "DOMAIN")) 1316 continue; 1317 if (curdom) 1318 free(curdom); 1319 curdom = NULL; 1320 while (*cp == ' ' || *cp == '\t') 1321 cp++; 1322 if (*cp == '\0') 1323 continue; 1324 arg = cp; 1325 while (*cp && *cp != ' ' && *cp != '\t') 1326 cp++; 1327 if (*cp != '\0') 1328 *cp++ = '\0'; 1329 curdom = newstr(arg); 1330 #endif 1331 break; 1332 } 1333 if (cp == NULL) 1334 return ((struct servtab *)0); 1335 /* 1336 * clear the static buffer, since some fields (se_ctrladdr, 1337 * for example) don't get initialized here. 1338 */ 1339 memset((caddr_t)sep, 0, sizeof *sep); 1340 arg = skip(&cp); 1341 if (cp == NULL) { 1342 /* got an empty line containing just blanks/tabs. */ 1343 goto more; 1344 } 1345 /* Check for a host name. */ 1346 hostdelim = strrchr(arg, ':'); 1347 if (hostdelim) { 1348 *hostdelim = '\0'; 1349 sep->se_hostaddr = newstr(arg); 1350 arg = hostdelim + 1; 1351 /* 1352 * If the line is of the form `host:', then just change the 1353 * default host for the following lines. 1354 */ 1355 if (*arg == '\0') { 1356 arg = skip(&cp); 1357 if (cp == NULL) { 1358 free(defhost); 1359 defhost = sep->se_hostaddr; 1360 goto more; 1361 } 1362 } 1363 } else 1364 sep->se_hostaddr = newstr(defhost); 1365 if (strncmp(arg, TCPMUX_TOKEN, MUX_LEN) == 0) { 1366 char *c = arg + MUX_LEN; 1367 if (*c == '+') { 1368 sep->se_type = MUXPLUS_TYPE; 1369 c++; 1370 } else 1371 sep->se_type = MUX_TYPE; 1372 sep->se_service = newstr(c); 1373 } else { 1374 sep->se_service = newstr(arg); 1375 sep->se_type = NORM_TYPE; 1376 } 1377 1378 arg = sskip(&cp); 1379 if (strcmp(arg, "stream") == 0) 1380 sep->se_socktype = SOCK_STREAM; 1381 else if (strcmp(arg, "dgram") == 0) 1382 sep->se_socktype = SOCK_DGRAM; 1383 else if (strcmp(arg, "rdm") == 0) 1384 sep->se_socktype = SOCK_RDM; 1385 else if (strcmp(arg, "seqpacket") == 0) 1386 sep->se_socktype = SOCK_SEQPACKET; 1387 else if (strcmp(arg, "raw") == 0) 1388 sep->se_socktype = SOCK_RAW; 1389 else 1390 sep->se_socktype = -1; 1391 1392 sep->se_proto = newstr(sskip(&cp)); 1393 1394 #define MALFORMED(arg) \ 1395 do { \ 1396 syslog(LOG_ERR, "%s: malformed buffer size option `%s'", \ 1397 sep->se_service, (arg)); \ 1398 goto more; \ 1399 } while (0) 1400 1401 #define GETVAL(arg) \ 1402 do { \ 1403 if (!isdigit(*(arg))) \ 1404 MALFORMED(arg); \ 1405 val = strtol((arg), &cp0, 10); \ 1406 if (cp0 != NULL) { \ 1407 if (cp0[1] != '\0') \ 1408 MALFORMED((arg)); \ 1409 if (cp0[0] == 'k') \ 1410 val *= 1024; \ 1411 if (cp0[0] == 'm') \ 1412 val *= 1024 * 1024; \ 1413 } \ 1414 if (val < 1) { \ 1415 syslog(LOG_ERR, "%s: invalid buffer size `%s'", \ 1416 sep->se_service, (arg)); \ 1417 goto more; \ 1418 } \ 1419 } while (0) 1420 1421 #define ASSIGN(arg) \ 1422 do { \ 1423 if (strcmp((arg), "sndbuf") == 0) \ 1424 sep->se_sndbuf = val; \ 1425 else if (strcmp((arg), "rcvbuf") == 0) \ 1426 sep->se_rcvbuf = val; \ 1427 else \ 1428 MALFORMED((arg)); \ 1429 } while (0) 1430 1431 /* 1432 * Extract the send and receive buffer sizes before parsing 1433 * the protocol. 1434 */ 1435 sep->se_sndbuf = sep->se_rcvbuf = 0; 1436 buf0 = buf1 = sz0 = sz1 = NULL; 1437 if ((buf0 = strchr(sep->se_proto, ',')) != NULL) { 1438 /* Not meaningful for Tcpmux services. */ 1439 if (ISMUX(sep)) { 1440 syslog(LOG_ERR, "%s: can't specify buffer sizes for " 1441 "tcpmux services", sep->se_service); 1442 goto more; 1443 } 1444 1445 /* Skip the , */ 1446 *buf0++ = '\0'; 1447 1448 /* Check to see if another socket buffer size was specified. */ 1449 if ((buf1 = strchr(buf0, ',')) != NULL) { 1450 /* Skip the , */ 1451 *buf1++ = '\0'; 1452 1453 /* Make sure a 3rd one wasn't specified. */ 1454 if (strchr(buf1, ',') != NULL) { 1455 syslog(LOG_ERR, "%s: too many buffer sizes", 1456 sep->se_service); 1457 goto more; 1458 } 1459 1460 /* Locate the size. */ 1461 if ((sz1 = strchr(buf1, '=')) == NULL) 1462 MALFORMED(buf1); 1463 1464 /* Skip the = */ 1465 *sz1++ = '\0'; 1466 } 1467 1468 /* Locate the size. */ 1469 if ((sz0 = strchr(buf0, '=')) == NULL) 1470 MALFORMED(buf0); 1471 1472 /* Skip the = */ 1473 *sz0++ = '\0'; 1474 1475 GETVAL(sz0); 1476 ASSIGN(buf0); 1477 1478 if (buf1 != NULL) { 1479 GETVAL(sz1); 1480 ASSIGN(buf1); 1481 } 1482 } 1483 1484 #undef ASSIGN 1485 #undef GETVAL 1486 #undef MALFORMED 1487 1488 if (strcmp(sep->se_proto, "unix") == 0) { 1489 sep->se_family = AF_LOCAL; 1490 } else { 1491 val = strlen(sep->se_proto); 1492 if (!val) { 1493 syslog(LOG_ERR, "%s: invalid protocol specified", 1494 sep->se_service); 1495 goto more; 1496 } 1497 val = sep->se_proto[val - 1]; 1498 switch (val) { 1499 case '4': /*tcp4 or udp4*/ 1500 sep->se_family = AF_INET; 1501 break; 1502 #ifdef INET6 1503 case '6': /*tcp6 or udp6*/ 1504 sep->se_family = AF_INET6; 1505 break; 1506 #endif 1507 default: 1508 sep->se_family = AF_INET; /*will become AF_INET6*/ 1509 break; 1510 } 1511 if (strncmp(sep->se_proto, "rpc/", 4) == 0) { 1512 #ifdef RPC 1513 char *cp, *ccp; 1514 cp = strchr(sep->se_service, '/'); 1515 if (cp == 0) { 1516 syslog(LOG_ERR, "%s: no rpc version", 1517 sep->se_service); 1518 goto more; 1519 } 1520 *cp++ = '\0'; 1521 sep->se_rpcversl = sep->se_rpcversh = 1522 strtol(cp, &ccp, 0); 1523 if (ccp == cp) { 1524 badafterall: 1525 syslog(LOG_ERR, "%s/%s: bad rpc version", 1526 sep->se_service, cp); 1527 goto more; 1528 } 1529 if (*ccp == '-') { 1530 cp = ccp + 1; 1531 sep->se_rpcversh = strtol(cp, &ccp, 0); 1532 if (ccp == cp) 1533 goto badafterall; 1534 } 1535 #else 1536 syslog(LOG_ERR, "%s: rpc services not suported", 1537 sep->se_service); 1538 goto more; 1539 #endif /* RPC */ 1540 } 1541 } 1542 arg = sskip(&cp); 1543 { 1544 char *cp; 1545 if ((cp = strchr(arg, ':')) == NULL) 1546 cp = strchr(arg, '.'); 1547 if (cp != NULL) { 1548 *cp++ = '\0'; 1549 sep->se_max = atoi(cp); 1550 } else 1551 sep->se_max = TOOMANY; 1552 } 1553 sep->se_wait = strcmp(arg, "wait") == 0; 1554 if (ISMUX(sep)) { 1555 /* 1556 * Silently enforce "nowait" for TCPMUX services since 1557 * they don't have an assigned port to listen on. 1558 */ 1559 sep->se_wait = 0; 1560 1561 if (strncmp(sep->se_proto, "tcp", 3)) { 1562 syslog(LOG_ERR, 1563 "%s: bad protocol for tcpmux service %s", 1564 CONFIG, sep->se_service); 1565 goto more; 1566 } 1567 if (sep->se_socktype != SOCK_STREAM) { 1568 syslog(LOG_ERR, 1569 "%s: bad socket type for tcpmux service %s", 1570 CONFIG, sep->se_service); 1571 goto more; 1572 } 1573 } 1574 sep->se_user = newstr(sskip(&cp)); 1575 if ((sep->se_group = strchr(sep->se_user, ':')) != NULL) 1576 *sep->se_group++ = '\0'; 1577 else if ((sep->se_group = strchr(sep->se_user, '.')) != NULL) 1578 *sep->se_group++ = '\0'; 1579 1580 sep->se_server = newstr(sskip(&cp)); 1581 if (strcmp(sep->se_server, "internal") == 0) { 1582 struct biltin *bi; 1583 1584 for (bi = biltins; bi->bi_service; bi++) 1585 if (bi->bi_socktype == sep->se_socktype && 1586 strcmp(bi->bi_service, sep->se_service) == 0) 1587 break; 1588 if (bi->bi_service == 0) { 1589 syslog(LOG_ERR, "internal service %s unknown", 1590 sep->se_service); 1591 goto more; 1592 } 1593 sep->se_bi = bi; 1594 sep->se_wait = bi->bi_wait; 1595 } else 1596 sep->se_bi = NULL; 1597 argc = 0; 1598 for (arg = skip(&cp); cp; arg = skip(&cp)) { 1599 #if MULOG 1600 char *colon; 1601 1602 if (argc == 0 && (colon = strrchr(arg, ':'))) { 1603 while (arg < colon) { 1604 int x; 1605 char *ccp; 1606 1607 switch (*arg++) { 1608 case 'l': 1609 x = 1; 1610 if (isdigit(*arg)) { 1611 x = strtol(arg, &ccp, 0); 1612 if (ccp == arg) 1613 break; 1614 arg = ccp; 1615 } 1616 sep->se_log &= ~MULOG_RFC931; 1617 sep->se_log |= x; 1618 break; 1619 case 'a': 1620 sep->se_log |= MULOG_RFC931; 1621 break; 1622 default: 1623 break; 1624 } 1625 } 1626 arg = colon + 1; 1627 } 1628 #endif 1629 if (argc < MAXARGV) 1630 sep->se_argv[argc++] = newstr(arg); 1631 } 1632 while (argc <= MAXARGV) 1633 sep->se_argv[argc++] = NULL; 1634 #ifdef IPSEC 1635 sep->se_policy = policy ? newstr(policy) : NULL; 1636 #endif 1637 return (sep); 1638 } 1639 1640 void 1641 freeconfig(cp) 1642 struct servtab *cp; 1643 { 1644 int i; 1645 1646 if (cp->se_hostaddr) 1647 free(cp->se_hostaddr); 1648 if (cp->se_service) 1649 free(cp->se_service); 1650 if (cp->se_proto) 1651 free(cp->se_proto); 1652 if (cp->se_user) 1653 free(cp->se_user); 1654 /* Note: se_group is part of the newstr'ed se_user */ 1655 if (cp->se_server) 1656 free(cp->se_server); 1657 for (i = 0; i < MAXARGV; i++) 1658 if (cp->se_argv[i]) 1659 free(cp->se_argv[i]); 1660 #ifdef IPSEC 1661 if (cp->se_policy) 1662 free(cp->se_policy); 1663 #endif 1664 } 1665 1666 1667 /* 1668 * Safe skip - if skip returns null, log a syntax error in the 1669 * configuration file and exit. 1670 */ 1671 char * 1672 sskip(cpp) 1673 char **cpp; 1674 { 1675 char *cp; 1676 1677 cp = skip(cpp); 1678 if (cp == NULL) { 1679 syslog(LOG_ERR, "%s: syntax error", CONFIG); 1680 exit(-1); 1681 } 1682 return (cp); 1683 } 1684 1685 char * 1686 skip(cpp) 1687 char **cpp; 1688 { 1689 char *cp = *cpp; 1690 char *start; 1691 1692 if (*cpp == NULL) 1693 return ((char *)0); 1694 1695 again: 1696 while (*cp == ' ' || *cp == '\t') 1697 cp++; 1698 if (*cp == '\0') { 1699 int c; 1700 1701 c = getc(fconfig); 1702 (void) ungetc(c, fconfig); 1703 if (c == ' ' || c == '\t') 1704 if ((cp = nextline(fconfig))) 1705 goto again; 1706 *cpp = (char *)0; 1707 return ((char *)0); 1708 } 1709 start = cp; 1710 while (*cp && *cp != ' ' && *cp != '\t') 1711 cp++; 1712 if (*cp != '\0') 1713 *cp++ = '\0'; 1714 *cpp = cp; 1715 return (start); 1716 } 1717 1718 char * 1719 nextline(fd) 1720 FILE *fd; 1721 { 1722 char *cp; 1723 1724 if (fgets(line, sizeof (line), fd) == NULL) 1725 return ((char *)0); 1726 cp = strchr(line, '\n'); 1727 if (cp) 1728 *cp = '\0'; 1729 return (line); 1730 } 1731 1732 char * 1733 newstr(cp) 1734 char *cp; 1735 { 1736 if ((cp = strdup(cp ? cp : ""))) 1737 return (cp); 1738 syslog(LOG_ERR, "strdup: %m"); 1739 exit(-1); 1740 } 1741 1742 void 1743 inetd_setproctitle(a, s) 1744 char *a; 1745 int s; 1746 { 1747 int size; 1748 char *cp; 1749 struct sockaddr_storage ss; 1750 char buf[80]; 1751 char hbuf[NI_MAXHOST]; 1752 1753 cp = Argv[0]; 1754 size = sizeof(ss); 1755 if (getpeername(s, (struct sockaddr *)&ss, &size) == 0) { 1756 if (getnameinfo((struct sockaddr *)&ss, ss.ss_len, 1757 hbuf, sizeof(hbuf), NULL, 0, niflags) != 0) 1758 strcpy(hbuf, "?"); 1759 (void)snprintf(buf, sizeof buf, "-%s [%s]", a, hbuf); 1760 } else 1761 (void)snprintf(buf, sizeof buf, "-%s", a); 1762 strncpy(cp, buf, LastArg - cp); 1763 cp += strlen(cp); 1764 while (cp < LastArg) 1765 *cp++ = ' '; 1766 } 1767 1768 void 1769 bump_nofile() 1770 { 1771 #ifdef RLIMIT_NOFILE 1772 1773 #define FD_CHUNK 32 1774 1775 struct rlimit rl; 1776 1777 if (getrlimit(RLIMIT_NOFILE, &rl) < 0) { 1778 syslog(LOG_ERR, "getrlimit: %m"); 1779 return; 1780 } 1781 rl.rlim_cur = MIN(rl.rlim_max, rl.rlim_cur + FD_CHUNK); 1782 if (rl.rlim_cur <= rlim_ofile_cur) { 1783 syslog(LOG_ERR, 1784 "bump_nofile: cannot extend file limit, max = %d", 1785 (int)rl.rlim_cur); 1786 return; 1787 } 1788 1789 if (setrlimit(RLIMIT_NOFILE, &rl) < 0) { 1790 syslog(LOG_ERR, "setrlimit: %m"); 1791 return; 1792 } 1793 1794 rlim_ofile_cur = rl.rlim_cur; 1795 return; 1796 1797 #else 1798 syslog(LOG_ERR, "bump_nofile: cannot extend file limit"); 1799 return; 1800 #endif 1801 } 1802 1803 /* 1804 * Internet services provided internally by inetd: 1805 */ 1806 #define BUFSIZE 4096 1807 1808 /* ARGSUSED */ 1809 void 1810 echo_stream(s, sep) /* Echo service -- echo data back */ 1811 int s; 1812 struct servtab *sep; 1813 { 1814 char buffer[BUFSIZE]; 1815 int i; 1816 1817 inetd_setproctitle(sep->se_service, s); 1818 while ((i = read(s, buffer, sizeof(buffer))) > 0 && 1819 write(s, buffer, i) > 0) 1820 ; 1821 } 1822 1823 /* ARGSUSED */ 1824 void 1825 echo_dg(s, sep) /* Echo service -- echo data back */ 1826 int s; 1827 struct servtab *sep; 1828 { 1829 char buffer[BUFSIZE]; 1830 int i, size; 1831 struct sockaddr_storage ss; 1832 struct sockaddr *sa; 1833 1834 sa = (struct sockaddr *)&ss; 1835 size = sizeof(ss); 1836 if ((i = recvfrom(s, buffer, sizeof(buffer), 0, sa, &size)) < 0) 1837 return; 1838 if (port_good_dg(sa)) 1839 (void) sendto(s, buffer, i, 0, sa, size); 1840 } 1841 1842 /* ARGSUSED */ 1843 void 1844 discard_stream(s, sep) /* Discard service -- ignore data */ 1845 int s; 1846 struct servtab *sep; 1847 { 1848 char buffer[BUFSIZE]; 1849 1850 inetd_setproctitle(sep->se_service, s); 1851 while ((errno = 0, read(s, buffer, sizeof(buffer)) > 0) || 1852 errno == EINTR) 1853 ; 1854 } 1855 1856 /* ARGSUSED */ 1857 void 1858 discard_dg(s, sep) /* Discard service -- ignore data */ 1859 int s; 1860 struct servtab *sep; 1861 { 1862 char buffer[BUFSIZE]; 1863 1864 (void) read(s, buffer, sizeof(buffer)); 1865 } 1866 1867 #include <ctype.h> 1868 #define LINESIZ 72 1869 char ring[128]; 1870 char *endring; 1871 1872 void 1873 initring() 1874 { 1875 int i; 1876 1877 endring = ring; 1878 1879 for (i = 0; i <= 128; ++i) 1880 if (isprint(i)) 1881 *endring++ = i; 1882 } 1883 1884 /* ARGSUSED */ 1885 void 1886 chargen_stream(s, sep) /* Character generator */ 1887 int s; 1888 struct servtab *sep; 1889 { 1890 int len; 1891 char *rs, text[LINESIZ+2]; 1892 1893 inetd_setproctitle(sep->se_service, s); 1894 1895 if (!endring) { 1896 initring(); 1897 rs = ring; 1898 } 1899 1900 text[LINESIZ] = '\r'; 1901 text[LINESIZ + 1] = '\n'; 1902 for (rs = ring;;) { 1903 if ((len = endring - rs) >= LINESIZ) 1904 memmove(text, rs, LINESIZ); 1905 else { 1906 memmove(text, rs, len); 1907 memmove(text + len, ring, LINESIZ - len); 1908 } 1909 if (++rs == endring) 1910 rs = ring; 1911 if (write(s, text, sizeof(text)) != sizeof(text)) 1912 break; 1913 } 1914 } 1915 1916 /* ARGSUSED */ 1917 void 1918 chargen_dg(s, sep) /* Character generator */ 1919 int s; 1920 struct servtab *sep; 1921 { 1922 struct sockaddr_storage ss; 1923 struct sockaddr *sa; 1924 static char *rs; 1925 int len, size; 1926 char text[LINESIZ+2]; 1927 1928 if (endring == 0) { 1929 initring(); 1930 rs = ring; 1931 } 1932 1933 sa = (struct sockaddr *)&ss; 1934 size = sizeof(ss); 1935 if (recvfrom(s, text, sizeof(text), 0, sa, &size) < 0) 1936 return; 1937 1938 if (!port_good_dg(sa)) 1939 return; 1940 1941 if ((len = endring - rs) >= LINESIZ) 1942 memmove(text, rs, LINESIZ); 1943 else { 1944 memmove(text, rs, len); 1945 memmove(text + len, ring, LINESIZ - len); 1946 } 1947 if (++rs == endring) 1948 rs = ring; 1949 text[LINESIZ] = '\r'; 1950 text[LINESIZ + 1] = '\n'; 1951 (void) sendto(s, text, sizeof(text), 0, sa, size); 1952 } 1953 1954 /* 1955 * Return a machine readable date and time, in the form of the 1956 * number of seconds since midnight, Jan 1, 1900. Since gettimeofday 1957 * returns the number of seconds since midnight, Jan 1, 1970, 1958 * we must add 2208988800 seconds to this figure to make up for 1959 * some seventy years Bell Labs was asleep. 1960 */ 1961 1962 long 1963 machtime() 1964 { 1965 struct timeval tv; 1966 1967 if (gettimeofday(&tv, (struct timezone *)0) < 0) { 1968 if (debug) 1969 fprintf(stderr, "Unable to get time of day\n"); 1970 return (0L); 1971 } 1972 #define OFFSET ((u_long)25567 * 24*60*60) 1973 return (htonl((long)(tv.tv_sec + OFFSET))); 1974 #undef OFFSET 1975 } 1976 1977 /* ARGSUSED */ 1978 void 1979 machtime_stream(s, sep) 1980 int s; 1981 struct servtab *sep; 1982 { 1983 long result; 1984 1985 result = machtime(); 1986 (void) write(s, (char *) &result, sizeof(result)); 1987 } 1988 1989 /* ARGSUSED */ 1990 void 1991 machtime_dg(s, sep) 1992 int s; 1993 struct servtab *sep; 1994 { 1995 long result; 1996 struct sockaddr_storage ss; 1997 struct sockaddr *sa; 1998 int size; 1999 2000 sa = (struct sockaddr *)&ss; 2001 size = sizeof(ss); 2002 if (recvfrom(s, (char *)&result, sizeof(result), 0, sa, &size) < 0) 2003 return; 2004 if (!port_good_dg(sa)) 2005 return; 2006 result = machtime(); 2007 (void) sendto(s, (char *) &result, sizeof(result), 0, sa, size); 2008 } 2009 2010 /* ARGSUSED */ 2011 void 2012 daytime_stream(s, sep) /* Return human-readable time of day */ 2013 int s; 2014 struct servtab *sep; 2015 { 2016 char buffer[256]; 2017 time_t clock; 2018 int len; 2019 2020 clock = time((time_t *) 0); 2021 2022 len = snprintf(buffer, sizeof buffer, "%.24s\r\n", ctime(&clock)); 2023 (void) write(s, buffer, len); 2024 } 2025 2026 /* ARGSUSED */ 2027 void 2028 daytime_dg(s, sep) /* Return human-readable time of day */ 2029 int s; 2030 struct servtab *sep; 2031 { 2032 char buffer[256]; 2033 time_t clock; 2034 struct sockaddr_storage ss; 2035 struct sockaddr *sa; 2036 int size, len; 2037 2038 clock = time((time_t *) 0); 2039 2040 sa = (struct sockaddr *)&ss; 2041 size = sizeof(ss); 2042 if (recvfrom(s, buffer, sizeof(buffer), 0, sa, &size) < 0) 2043 return; 2044 if (!port_good_dg(sa)) 2045 return; 2046 len = snprintf(buffer, sizeof buffer, "%.24s\r\n", ctime(&clock)); 2047 (void) sendto(s, buffer, len, 0, sa, size); 2048 } 2049 2050 /* 2051 * print_service: 2052 * Dump relevant information to stderr 2053 */ 2054 void 2055 print_service(action, sep) 2056 char *action; 2057 struct servtab *sep; 2058 { 2059 if (isrpcservice(sep)) 2060 fprintf(stderr, 2061 "%s: %s rpcprog=%d, rpcvers = %d/%d, proto=%s, wait:max=%d.%d, user:group=%s.%s builtin=%lx server=%s" 2062 #ifdef IPSEC 2063 " policy=\"%s\"" 2064 #endif 2065 "\n", 2066 action, sep->se_service, 2067 sep->se_rpcprog, sep->se_rpcversh, sep->se_rpcversl, sep->se_proto, 2068 sep->se_wait, sep->se_max, sep->se_user, sep->se_group, 2069 (long)sep->se_bi, sep->se_server 2070 #ifdef IPSEC 2071 , (sep->se_policy ? sep->se_policy : "") 2072 #endif 2073 ); 2074 else 2075 fprintf(stderr, 2076 "%s: %s proto=%s, wait:max=%d.%d, user:group=%s.%s builtin=%lx server=%s" 2077 #ifdef IPSEC 2078 " policy=%s" 2079 #endif 2080 "\n", 2081 action, sep->se_service, sep->se_proto, 2082 sep->se_wait, sep->se_max, sep->se_user, sep->se_group, 2083 (long)sep->se_bi, sep->se_server 2084 #ifdef IPSEC 2085 , (sep->se_policy ? sep->se_policy : "") 2086 #endif 2087 ); 2088 } 2089 2090 void 2091 usage() 2092 { 2093 2094 #ifdef LIBWRAP 2095 (void)fprintf(stderr, "usage: %s [-dl] [conf]\n", __progname); 2096 #else 2097 (void)fprintf(stderr, "usage: %s [-d] [conf]\n", __progname); 2098 #endif 2099 exit(1); 2100 } 2101 2102 2103 /* 2104 * Based on TCPMUX.C by Mark K. Lottor November 1988 2105 * sri-nic::ps:<mkl>tcpmux.c 2106 */ 2107 2108 static int /* # of characters upto \r,\n or \0 */ 2109 getline(fd, buf, len) 2110 int fd; 2111 char *buf; 2112 int len; 2113 { 2114 int count = 0, n; 2115 2116 do { 2117 n = read(fd, buf, len-count); 2118 if (n == 0) 2119 return (count); 2120 if (n < 0) 2121 return (-1); 2122 while (--n >= 0) { 2123 if (*buf == '\r' || *buf == '\n' || *buf == '\0') 2124 return (count); 2125 count++; 2126 buf++; 2127 } 2128 } while (count < len); 2129 return (count); 2130 } 2131 2132 #define MAX_SERV_LEN (256+2) /* 2 bytes for \r\n */ 2133 2134 #define strwrite(fd, buf) (void) write(fd, buf, sizeof(buf)-1) 2135 2136 void 2137 tcpmux(ctrl, sep) 2138 int ctrl; 2139 struct servtab *sep; 2140 { 2141 char service[MAX_SERV_LEN+1]; 2142 int len; 2143 2144 /* Get requested service name */ 2145 if ((len = getline(ctrl, service, MAX_SERV_LEN)) < 0) { 2146 strwrite(ctrl, "-Error reading service name\r\n"); 2147 goto reject; 2148 } 2149 service[len] = '\0'; 2150 2151 if (debug) 2152 fprintf(stderr, "tcpmux: someone wants %s\n", service); 2153 2154 /* 2155 * Help is a required command, and lists available services, 2156 * one per line. 2157 */ 2158 if (!strcasecmp(service, "help")) { 2159 strwrite(ctrl, "+Available services:\r\n"); 2160 strwrite(ctrl, "help\r\n"); 2161 for (sep = servtab; sep; sep = sep->se_next) { 2162 if (!ISMUX(sep)) 2163 continue; 2164 (void)write(ctrl, sep->se_service, 2165 strlen(sep->se_service)); 2166 strwrite(ctrl, "\r\n"); 2167 } 2168 goto reject; 2169 } 2170 2171 /* Try matching a service in inetd.conf with the request */ 2172 for (sep = servtab; sep; sep = sep->se_next) { 2173 if (!ISMUX(sep)) 2174 continue; 2175 if (!strcasecmp(service, sep->se_service)) { 2176 if (ISMUXPLUS(sep)) 2177 strwrite(ctrl, "+Go\r\n"); 2178 run_service(ctrl, sep); 2179 return; 2180 } 2181 } 2182 strwrite(ctrl, "-Service not available\r\n"); 2183 reject: 2184 _exit(1); 2185 } 2186 2187 2188 #ifdef MULOG 2189 dolog(sep, ctrl) 2190 struct servtab *sep; 2191 int ctrl; 2192 { 2193 struct sockaddr_storage ss; 2194 struct sockaddr *sa = (struct sockaddr *)&ss; 2195 struct sockaddr_in *sin = (struct sockaddr_in *)&ss; 2196 int len = sizeof(ss); 2197 struct hostent *hp; 2198 char *host, *dp, buf[BUFSIZ], *rfc931_name(); 2199 int connected = 1; 2200 2201 switch (sep->se_family) { 2202 case AF_INET: 2203 #ifdef INET6 2204 case AF_INET6: 2205 #endif 2206 break; 2207 default; 2208 return; 2209 } 2210 2211 if (getpeername(ctrl, sa, &len) < 0) { 2212 if (errno != ENOTCONN) { 2213 syslog(LOG_ERR, "getpeername: %m"); 2214 return; 2215 } 2216 if (recvfrom(ctrl, buf, sizeof(buf), MSG_PEEK, sa, &len) < 0) { 2217 syslog(LOG_ERR, "recvfrom: %m"); 2218 return; 2219 } 2220 connected = 0; 2221 } 2222 switch (sa->sa_family) { 2223 case AF_INET: 2224 #ifdef INET6 2225 case AF_INET6: 2226 #endif 2227 break; 2228 default; 2229 syslog(LOG_ERR, "unexpected address family %u", sa->sa_family); 2230 return; 2231 } 2232 2233 if (getnameinfo(sa, sa->sa_len, buf, sizeof(buf), NULL, 0, 0) != 0) 2234 strcpy(buf, "?"); 2235 host = buf; 2236 2237 switch (sep->se_log & ~MULOG_RFC931) { 2238 case 0: 2239 return; 2240 case 1: 2241 if (curdom == NULL || *curdom == '\0') 2242 break; 2243 dp = host + strlen(host) - strlen(curdom); 2244 if (dp < host) 2245 break; 2246 if (debug) 2247 fprintf(stderr, "check \"%s\" against curdom \"%s\"\n", 2248 host, curdom); 2249 if (strcasecmp(dp, curdom) == 0) 2250 return; 2251 break; 2252 case 2: 2253 default: 2254 break; 2255 } 2256 2257 openlog("", LOG_NOWAIT, MULOG); 2258 2259 if (connected && (sep->se_log & MULOG_RFC931)) 2260 syslog(LOG_INFO, "%s@%s wants %s", 2261 rfc931_name(sa, ctrl), host, sep->se_service); 2262 else 2263 syslog(LOG_INFO, "%s wants %s", 2264 host, sep->se_service); 2265 } 2266 2267 /* 2268 * From tcp_log by 2269 * Wietse Venema, Eindhoven University of Technology, The Netherlands. 2270 */ 2271 #if 0 2272 static char sccsid[] = "@(#) rfc931.c 1.3 92/08/31 22:54:46"; 2273 #endif 2274 2275 #include <setjmp.h> 2276 2277 #define RFC931_PORT 113 /* Semi-well-known port */ 2278 #define TIMEOUT 4 2279 #define TIMEOUT2 10 2280 2281 static jmp_buf timebuf; 2282 2283 /* timeout - handle timeouts */ 2284 2285 static void timeout(sig) 2286 int sig; 2287 { 2288 longjmp(timebuf, sig); 2289 } 2290 2291 /* rfc931_name - return remote user name */ 2292 2293 char * 2294 rfc931_name(there, ctrl) 2295 struct sockaddr *there; /* remote link information */ 2296 int ctrl; 2297 { 2298 struct sockaddr_storage here; /* local link information */ 2299 struct sockaddr_storage sin; /* for talking to RFC931 daemon */ 2300 int length; 2301 int s; 2302 unsigned remote; 2303 unsigned local; 2304 static char user[256]; /* XXX */ 2305 char buf[256]; 2306 char *cp; 2307 char *result = "USER_UNKNOWN"; 2308 int len; 2309 u_int16_t myport, hisport; 2310 2311 /* Find out local port number of our stdin. */ 2312 2313 length = sizeof(here); 2314 if (getsockname(ctrl, (struct sockaddr *) &here, &length) == -1) { 2315 syslog(LOG_ERR, "getsockname: %m"); 2316 return (result); 2317 } 2318 switch (here.ss_family) { 2319 case AF_INET: 2320 myport = ((struct sockaddr_in *)&here)->sin_port; 2321 break; 2322 #ifdef INET6 2323 case AF_INET6: 2324 myport = ((struct sockaddr_in6 *)&here)->sin6_port; 2325 break; 2326 #endif 2327 } 2328 switch (there->sa_family) { 2329 case AF_INET: 2330 hisport = ((struct sockaddr_in *)sa)->sin_port; 2331 break; 2332 #ifdef INET6 2333 case AF_INET6: 2334 hisport = ((struct sockaddr_in6 *)sa)->sin6_port; 2335 break; 2336 #endif 2337 } 2338 /* Set up timer so we won't get stuck. */ 2339 2340 if ((s = socket(here.ss_family, SOCK_STREAM, 0)) == -1) { 2341 syslog(LOG_ERR, "socket: %m"); 2342 return (result); 2343 } 2344 2345 sin = here; 2346 switch (sin.ss_family) { 2347 case AF_INET: 2348 ((struct sockaddr_in *)&sin)->sin_port = htons(0); 2349 break; 2350 #ifdef INET6 2351 case AF_INET6: 2352 ((struct sockaddr_in6 *)&sin)->sin6_port = htons(0); 2353 break; 2354 #endif 2355 } 2356 if (bind(s, (struct sockaddr *) &sin, sin.ss_len) == -1) { 2357 syslog(LOG_ERR, "bind: %m"); 2358 return (result); 2359 } 2360 2361 signal(SIGALRM, timeout); 2362 if (setjmp(timebuf)) { 2363 close(s); /* not: fclose(fp) */ 2364 return (result); 2365 } 2366 alarm(TIMEOUT); 2367 2368 /* Connect to the RFC931 daemon. */ 2369 2370 memcpy(&sin, there, there->sa_len); 2371 switch (sin.ss_family) { 2372 case AF_INET: 2373 ((struct sockaddr_in *)&sin)->sin_port = htons(RFC931_PORT); 2374 break; 2375 #ifdef INET6 2376 case AF_INET6: 2377 ((struct sockaddr_in6 *)&sin)->sin6_port = htons(RFC931_PORT); 2378 break; 2379 #endif 2380 } 2381 if (connect(s, (struct sockaddr *) &sin, sin.ss_len) == -1) { 2382 close(s); 2383 alarm(0); 2384 return (result); 2385 } 2386 2387 /* Query the RFC 931 server. Would 13-byte writes ever be broken up? */ 2388 (void)snprintf(buf, sizeof buf, "%u,%u\r\n", ntohs(hisport), 2389 ntohs(myport)); 2390 2391 2392 for (len = 0, cp = buf; len < strlen(buf); ) { 2393 int n; 2394 2395 if ((n = write(s, cp, strlen(buf) - len)) == -1) { 2396 close(s); 2397 alarm(0); 2398 return (result); 2399 } 2400 cp += n; 2401 len += n; 2402 } 2403 2404 /* Read response */ 2405 for (cp = buf; cp < buf + sizeof(buf) - 1; ) { 2406 char c; 2407 if (read(s, &c, 1) != 1) { 2408 close(s); 2409 alarm(0); 2410 return (result); 2411 } 2412 if (c == '\n') 2413 break; 2414 *cp++ = c; 2415 } 2416 *cp = '\0'; 2417 2418 if (sscanf(buf, "%u , %u : USERID :%*[^:]:%255s", &remote, &local, user) == 3 2419 && ntohs(hisport) == remote 2420 && ntohs(myport) == local) { 2421 2422 /* Strip trailing carriage return. */ 2423 if (cp = strchr(user, '\r')) 2424 *cp = 0; 2425 result = user; 2426 } 2427 2428 alarm(0); 2429 close(s); 2430 return (result); 2431 } 2432 #endif 2433 2434 /* 2435 * check if the port where send data to is one of the obvious ports 2436 * that are used for denial of service attacks like two echo ports 2437 * just echoing data between them 2438 */ 2439 int 2440 port_good_dg(sa) 2441 struct sockaddr *sa; 2442 { 2443 u_int16_t port; 2444 int i, bad; 2445 char hbuf[NI_MAXHOST]; 2446 2447 bad = 0; 2448 2449 switch (sa->sa_family) { 2450 case AF_INET: 2451 port = ntohs(((struct sockaddr_in *)sa)->sin_port); 2452 break; 2453 #ifdef INET6 2454 case AF_INET6: 2455 port = ntohs(((struct sockaddr_in6 *)sa)->sin6_port); 2456 break; 2457 #endif 2458 default: 2459 /* XXX unsupported af, is it safe to assume it to be safe? */ 2460 return 1; 2461 } 2462 2463 for (i = 0; bad_ports[i] != 0; i++) 2464 if (port == bad_ports[i]) { 2465 bad = 1; 2466 break; 2467 } 2468 2469 if (bad) { 2470 if (getnameinfo(sa, sa->sa_len, hbuf, sizeof(hbuf), 2471 NULL, 0, niflags) != 0) 2472 strcpy(hbuf, "?"); 2473 syslog(LOG_WARNING,"Possible DoS attack from %s, Port %d", 2474 hbuf, port); 2475 return (0); 2476 } else 2477 return (1); 2478 } 2479 2480
Indexes created Sat Oct 18 08:10:09 GMT 2025