121996Sdist /* 234566Skarels * Copyright (c) 1983, 1988 Regents of the University of California. 333489Sbostic * All rights reserved. 433489Sbostic * 533489Sbostic * Redistribution and use in source and binary forms are permitted 634771Sbostic * provided that the above copyright notice and this paragraph are 734771Sbostic * duplicated in all such forms and that any documentation, 834771Sbostic * advertising materials, and other materials related to such 934771Sbostic * distribution and use acknowledge that the software was developed 1034771Sbostic * by the University of California, Berkeley. The name of the 1134771Sbostic * University may not be used to endorse or promote products derived 1234771Sbostic * from this software without specific prior written permission. 1334771Sbostic * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR 1434771Sbostic * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED 1534771Sbostic * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE. 1621996Sdist */ 1721996Sdist 189017Ssam #ifndef lint 1921996Sdist char copyright[] = 2034566Skarels "@(#) Copyright (c) 1983, 1988 Regents of the University of California.\n\ 2121996Sdist All rights reserved.\n"; 2233489Sbostic #endif /* not lint */ 239017Ssam 2421996Sdist #ifndef lint 25*37970Sbostic static char sccsid[] = "@(#)main.c 5.18 (Berkeley) 05/11/89"; 2633489Sbostic #endif /* not lint */ 2721996Sdist 289017Ssam /* 299017Ssam * Routing Table Management Daemon 309017Ssam */ 3110245Ssam #include "defs.h" 329017Ssam #include <sys/ioctl.h> 3336831Skarels #include <sys/file.h> 3413602Ssam 359017Ssam #include <net/if.h> 3613602Ssam 3734566Skarels #include <sys/errno.h> 3834566Skarels #include <sys/signal.h> 3934566Skarels #include <sys/syslog.h> 40*37970Sbostic #include "pathnames.h" 419017Ssam 429017Ssam int supplier = -1; /* process should supply updates */ 4321847Skarels int gateway = 0; /* 1 if we are a gateway to parts beyond */ 4431220Skarels int debug = 0; 4536831Skarels int bufspace = 127*1024; /* max. input buffer size to request */ 469017Ssam 479017Ssam struct rip *msg = (struct rip *)packet; 4834566Skarels int hup(), rtdeleteall(), sigtrace(); 499017Ssam 509017Ssam main(argc, argv) 519017Ssam int argc; 529017Ssam char *argv[]; 539017Ssam { 5436831Skarels int n, cc, nfd, omask, tflags = 0; 559017Ssam struct sockaddr from; 5636831Skarels struct timeval *tvp, waittime; 5736831Skarels struct itimerval itval; 5836831Skarels fd_set ibits; 5910245Ssam u_char retry; 609017Ssam 619017Ssam argv0 = argv; 6234845Skarels #if BSD >= 43 6324848Seric openlog("routed", LOG_PID | LOG_ODELAY, LOG_DAEMON); 6430930Skarels setlogmask(LOG_UPTO(LOG_WARNING)); 6534845Skarels #else 6634845Skarels openlog("routed", LOG_PID); 6734845Skarels #define LOG_UPTO(x) (x) 6834845Skarels #define setlogmask(x) (x) 6934845Skarels #endif 709017Ssam sp = getservbyname("router", "udp"); 7110245Ssam if (sp == NULL) { 7210245Ssam fprintf(stderr, "routed: router/udp: unknown service\n"); 739017Ssam exit(1); 749017Ssam } 7510245Ssam addr.sin_family = AF_INET; 7610245Ssam addr.sin_port = sp->s_port; 7710245Ssam s = getsocket(AF_INET, SOCK_DGRAM, &addr); 7810245Ssam if (s < 0) 7910245Ssam exit(1); 809017Ssam argv++, argc--; 819017Ssam while (argc > 0 && **argv == '-') { 8210636Ssam if (strcmp(*argv, "-s") == 0) { 839017Ssam supplier = 1; 849017Ssam argv++, argc--; 859017Ssam continue; 869017Ssam } 8710636Ssam if (strcmp(*argv, "-q") == 0) { 889017Ssam supplier = 0; 899017Ssam argv++, argc--; 909017Ssam continue; 919017Ssam } 9210636Ssam if (strcmp(*argv, "-t") == 0) { 9336831Skarels tflags++; 9430930Skarels setlogmask(LOG_UPTO(LOG_DEBUG)); 9510636Ssam argv++, argc--; 9610636Ssam continue; 9710636Ssam } 9826341Skarels if (strcmp(*argv, "-d") == 0) { 9931220Skarels debug++; 10030930Skarels setlogmask(LOG_UPTO(LOG_DEBUG)); 10126341Skarels argv++, argc--; 10226341Skarels continue; 10326341Skarels } 10416326Skarels if (strcmp(*argv, "-g") == 0) { 10516326Skarels gateway = 1; 10616326Skarels argv++, argc--; 10716326Skarels continue; 10816326Skarels } 10916326Skarels fprintf(stderr, 11021847Skarels "usage: routed [ -s ] [ -q ] [ -t ] [ -g ]\n"); 1119017Ssam exit(1); 1129017Ssam } 11336831Skarels 11436831Skarels if (debug == 0) { 11510636Ssam int t; 11610636Ssam 11710636Ssam if (fork()) 11810636Ssam exit(0); 11910637Ssam for (t = 0; t < 20; t++) 12010637Ssam if (t != s) 12124761Ssklower (void) close(t); 12210636Ssam (void) open("/", 0); 12310636Ssam (void) dup2(0, 1); 12410636Ssam (void) dup2(0, 2); 125*37970Sbostic t = open(_PATH_TTY, 2); 12610636Ssam if (t >= 0) { 12710636Ssam ioctl(t, TIOCNOTTY, (char *)0); 12810636Ssam (void) close(t); 12910636Ssam } 13010636Ssam } 1319017Ssam /* 13210245Ssam * Any extra argument is considered 13310245Ssam * a tracing log file. 13410245Ssam */ 13510245Ssam if (argc > 0) 13610245Ssam traceon(*argv); 13736831Skarels while (tflags-- > 0) 13836831Skarels bumploglevel(); 13936831Skarels 14036831Skarels (void) gettimeofday(&now, (struct timezone *)NULL); 14110245Ssam /* 1429017Ssam * Collect an initial view of the world by 14321847Skarels * checking the interface configuration and the gateway kludge 1449017Ssam * file. Then, send a request packet on all 1459017Ssam * directly connected networks to find out what 1469017Ssam * everyone else thinks. 1479017Ssam */ 1489017Ssam rtinit(); 14930927Skarels ifinit(); 1509017Ssam gwkludge(); 15121847Skarels if (gateway > 0) 15221847Skarels rtdefault(); 1539017Ssam if (supplier < 0) 1549017Ssam supplier = 0; 1559017Ssam msg->rip_cmd = RIPCMD_REQUEST; 15612726Ssam msg->rip_vers = RIPVERSION; 15736831Skarels if (sizeof(msg->rip_nets[0].rip_dst.sa_family) > 1) /* XXX */ 15836831Skarels msg->rip_nets[0].rip_dst.sa_family = htons((u_short)AF_UNSPEC); 15936831Skarels else 16036831Skarels msg->rip_nets[0].rip_dst.sa_family = AF_UNSPEC; 16136831Skarels msg->rip_nets[0].rip_metric = htonl((u_long)HOPCNT_INFINITY); 1629017Ssam toall(sendmsg); 16313036Ssam signal(SIGALRM, timer); 16416314Skarels signal(SIGHUP, hup); 16517570Skarels signal(SIGTERM, hup); 16631220Skarels signal(SIGINT, rtdeleteall); 16734566Skarels signal(SIGUSR1, sigtrace); 16834566Skarels signal(SIGUSR2, sigtrace); 16936831Skarels itval.it_interval.tv_sec = TIMER_RATE; 17036831Skarels itval.it_value.tv_sec = TIMER_RATE; 17136831Skarels itval.it_interval.tv_usec = 0; 17236831Skarels itval.it_value.tv_usec = 0; 17336831Skarels srandom(getpid()); 17436831Skarels if (setitimer(ITIMER_REAL, &itval, (struct itimerval *)NULL) < 0) 17536831Skarels syslog(LOG_ERR, "setitimer: %m\n"); 1769017Ssam 17736831Skarels FD_ZERO(&ibits); 17836831Skarels nfd = s + 1; /* 1 + max(fd's) */ 1799017Ssam for (;;) { 18036831Skarels FD_SET(s, &ibits); 18136831Skarels /* 18236831Skarels * If we need a dynamic update that was held off, 18336831Skarels * needupdate will be set, and nextbcast is the time 18436831Skarels * by which we want select to return. Compute time 18536831Skarels * until dynamic update should be sent, and select only 18636831Skarels * until then. If we have already passed nextbcast, 18736831Skarels * just poll. 18836831Skarels */ 18936831Skarels if (needupdate) { 19036831Skarels waittime = nextbcast; 19136831Skarels timevalsub(&waittime, &now); 19236831Skarels if (waittime.tv_sec < 0) { 19336831Skarels waittime.tv_sec = 0; 19436831Skarels waittime.tv_usec = 0; 19536831Skarels } 19636831Skarels if (traceactions) 19736831Skarels fprintf(ftrace, 19836831Skarels "select until dynamic update %d/%d sec/usec\n", 19936831Skarels waittime.tv_sec, waittime.tv_usec); 20036831Skarels tvp = &waittime; 20136831Skarels } else 20236831Skarels tvp = (struct timeval *)NULL; 20336831Skarels n = select(nfd, &ibits, 0, 0, tvp); 20436831Skarels if (n <= 0) { 20536831Skarels /* 20636831Skarels * Need delayed dynamic update if select returned 20736831Skarels * nothing and we timed out. Otherwise, ignore 20836831Skarels * errors (e.g. EINTR). 20936831Skarels */ 21036831Skarels if (n < 0) { 21136831Skarels if (errno == EINTR) 21236831Skarels continue; 21336831Skarels syslog(LOG_ERR, "select: %m"); 21436831Skarels } 21536831Skarels omask = sigblock(sigmask(SIGALRM)); 21636831Skarels if (n == 0 && needupdate) { 21736831Skarels if (traceactions) 21836831Skarels fprintf(ftrace, 21936831Skarels "send delayed dynamic update\n"); 22036831Skarels (void) gettimeofday(&now, 22136831Skarels (struct timezone *)NULL); 22236831Skarels toall(supply, RTS_CHANGED, 22336831Skarels (struct interface *)NULL); 22436831Skarels lastbcast = now; 22536831Skarels needupdate = 0; 22636831Skarels nextbcast.tv_sec = 0; 22736831Skarels } 22836831Skarels sigsetmask(omask); 2299017Ssam continue; 23036831Skarels } 23136831Skarels (void) gettimeofday(&now, (struct timezone *)NULL); 23236846Skarels omask = sigblock(sigmask(SIGALRM)); 23336831Skarels #ifdef doesntwork 23436831Skarels /* 23536831Skarels printf("s %d, ibits %x index %d, mod %d, sh %x, or %x &ibits %x\n", 23636831Skarels s, 23736831Skarels ibits.fds_bits[0], 23836831Skarels (s)/(sizeof(fd_mask) * 8), 23936831Skarels ((s) % (sizeof(fd_mask) * 8)), 24036831Skarels (1 << ((s) % (sizeof(fd_mask) * 8))), 24136831Skarels ibits.fds_bits[(s)/(sizeof(fd_mask) * 8)] & (1 << ((s) % (sizeof(fd_mask) * 8))), 24236831Skarels &ibits 24336831Skarels ); 24436831Skarels */ 24536831Skarels if (FD_ISSET(s, &ibits)) 24636831Skarels #else 24736831Skarels if (ibits.fds_bits[s/32] & (1 << s)) 24836831Skarels #endif 2499017Ssam process(s); 25010245Ssam /* handle ICMP redirects */ 25136846Skarels sigsetmask(omask); 2529017Ssam } 2539017Ssam } 2549017Ssam 25536831Skarels timevaladd(t1, t2) 25636831Skarels struct timeval *t1, *t2; 25736831Skarels { 25836831Skarels 25936831Skarels t1->tv_sec += t2->tv_sec; 26036831Skarels if ((t1->tv_usec += t2->tv_usec) > 1000000) { 26136831Skarels t1->tv_sec++; 26236831Skarels t1->tv_usec -= 1000000; 26336831Skarels } 26436831Skarels } 26536831Skarels 26636831Skarels timevalsub(t1, t2) 26736831Skarels struct timeval *t1, *t2; 26836831Skarels { 26936831Skarels 27036831Skarels t1->tv_sec -= t2->tv_sec; 27136831Skarels if ((t1->tv_usec -= t2->tv_usec) < 0) { 27236831Skarels t1->tv_sec--; 27336831Skarels t1->tv_usec += 1000000; 27436831Skarels } 27536831Skarels } 27636831Skarels 2779017Ssam process(fd) 2789017Ssam int fd; 2799017Ssam { 2809017Ssam struct sockaddr from; 28136846Skarels int fromlen, cc; 28236846Skarels union { 28336846Skarels char buf[MAXPACKETSIZE+1]; 28436846Skarels struct rip rip; 28536846Skarels } inbuf; 2869017Ssam 28736831Skarels for (;;) { 28836831Skarels fromlen = sizeof (from); 28936846Skarels cc = recvfrom(fd, &inbuf, sizeof (inbuf), 0, &from, &fromlen); 29036831Skarels if (cc <= 0) { 29136831Skarels if (cc < 0 && errno != EWOULDBLOCK) 29236831Skarels perror("recvfrom"); 29336831Skarels break; 29436831Skarels } 29536831Skarels if (fromlen != sizeof (struct sockaddr_in)) 29636831Skarels break; 29736846Skarels rip_input(&from, &inbuf.rip, cc); 2989017Ssam } 2999017Ssam } 30010245Ssam 30110245Ssam getsocket(domain, type, sin) 30210245Ssam int domain, type; 30310245Ssam struct sockaddr_in *sin; 30410245Ssam { 30536831Skarels int sock, on = 1; 30610245Ssam 30736831Skarels if ((sock = socket(domain, type, 0)) < 0) { 30810245Ssam perror("socket"); 30917570Skarels syslog(LOG_ERR, "socket: %m"); 31010245Ssam return (-1); 31117570Skarels } 31234845Skarels #ifdef SO_BROADCAST 31336831Skarels if (setsockopt(sock, SOL_SOCKET, SO_BROADCAST, &on, sizeof (on)) < 0) { 31417570Skarels syslog(LOG_ERR, "setsockopt SO_BROADCAST: %m"); 31536831Skarels close(sock); 31625516Skarels return (-1); 31717570Skarels } 31834845Skarels #endif 31934845Skarels #ifdef SO_RCVBUF 32036831Skarels for (on = bufspace; ; on -= 1024) { 32136831Skarels if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, 32236831Skarels &on, sizeof (on)) == 0) 32336831Skarels break; 32436831Skarels if (on <= 8*1024) { 32536831Skarels syslog(LOG_ERR, "setsockopt SO_RCVBUF: %m"); 32636831Skarels break; 32736831Skarels } 32836831Skarels } 32936831Skarels if (traceactions) 33036831Skarels fprintf(ftrace, "recv buf %d\n", on); 33134845Skarels #endif 33236831Skarels if (bind(sock, sin, sizeof (*sin), 0) < 0) { 33310245Ssam perror("bind"); 33417570Skarels syslog(LOG_ERR, "bind: %m"); 33536831Skarels close(sock); 33610245Ssam return (-1); 33717570Skarels } 33836831Skarels if (fcntl(sock, F_SETFL, FNDELAY) == -1) 33936831Skarels syslog(LOG_ERR, "fcntl FNDELAY: %m\n"); 34036831Skarels return (sock); 34110245Ssam } 342