17b6ab19dSGarrett Wollman /* 27b6ab19dSGarrett Wollman * Copyright (c) 1983, 1988, 1993 37b6ab19dSGarrett Wollman * The Regents of the University of California. All rights reserved. 47b6ab19dSGarrett Wollman * 57b6ab19dSGarrett Wollman * Redistribution and use in source and binary forms, with or without 67b6ab19dSGarrett Wollman * modification, are permitted provided that the following conditions 77b6ab19dSGarrett Wollman * are met: 87b6ab19dSGarrett Wollman * 1. Redistributions of source code must retain the above copyright 97b6ab19dSGarrett Wollman * notice, this list of conditions and the following disclaimer. 107b6ab19dSGarrett Wollman * 2. Redistributions in binary form must reproduce the above copyright 117b6ab19dSGarrett Wollman * notice, this list of conditions and the following disclaimer in the 127b6ab19dSGarrett Wollman * documentation and/or other materials provided with the distribution. 137b6ab19dSGarrett Wollman * 4. Neither the name of the University nor the names of its contributors 147b6ab19dSGarrett Wollman * may be used to endorse or promote products derived from this software 157b6ab19dSGarrett Wollman * without specific prior written permission. 167b6ab19dSGarrett Wollman * 177b6ab19dSGarrett Wollman * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 187b6ab19dSGarrett Wollman * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 197b6ab19dSGarrett Wollman * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 207b6ab19dSGarrett Wollman * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 217b6ab19dSGarrett Wollman * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 227b6ab19dSGarrett Wollman * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 237b6ab19dSGarrett Wollman * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 247b6ab19dSGarrett Wollman * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 257b6ab19dSGarrett Wollman * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 267b6ab19dSGarrett Wollman * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 277b6ab19dSGarrett Wollman * SUCH DAMAGE. 28c90fe7dcSMark Murray * 297f3dea24SPeter Wemm * $FreeBSD$ 307b6ab19dSGarrett Wollman */ 317b6ab19dSGarrett Wollman 327b6ab19dSGarrett Wollman #include "defs.h" 337b6ab19dSGarrett Wollman #include "pathnames.h" 347b6ab19dSGarrett Wollman #ifdef sgi 357b6ab19dSGarrett Wollman #include "math.h" 367b6ab19dSGarrett Wollman #endif 377b6ab19dSGarrett Wollman #include <signal.h> 387b6ab19dSGarrett Wollman #include <fcntl.h> 397b6ab19dSGarrett Wollman #include <sys/file.h> 407b6ab19dSGarrett Wollman 41caa79e36SBruce M Simpson __COPYRIGHT("@(#) Copyright (c) 1983, 1988, 1993\n" 42caa79e36SBruce M Simpson "The Regents of the University of California." 43caa79e36SBruce M Simpson " All rights reserved.\n"); 44caa79e36SBruce M Simpson #ifdef __NetBSD__ 452c7a9781SMark Murray __RCSID("$NetBSD$"); 46caa79e36SBruce M Simpson #include <util.h> 47caa79e36SBruce M Simpson #elif defined(__FreeBSD__) 48caa79e36SBruce M Simpson __RCSID("$FreeBSD$"); 49caa79e36SBruce M Simpson #else 50a4fff644STom Rhodes __RCSID("$Revision: 2.31 $"); 51a4fff644STom Rhodes #ident "$Revision: 2.31 $" 522c7a9781SMark Murray #endif 532c7a9781SMark Murray 547b6ab19dSGarrett Wollman pid_t mypid; 557b6ab19dSGarrett Wollman 567b6ab19dSGarrett Wollman naddr myaddr; /* system address */ 577b6ab19dSGarrett Wollman char myname[MAXHOSTNAMELEN+1]; 587b6ab19dSGarrett Wollman 592c7a9781SMark Murray int verbose; 602c7a9781SMark Murray 617b6ab19dSGarrett Wollman int supplier; /* supply or broadcast updates */ 627b6ab19dSGarrett Wollman int supplier_set; 637b6ab19dSGarrett Wollman int ipforwarding = 1; /* kernel forwarding on */ 647b6ab19dSGarrett Wollman 657b6ab19dSGarrett Wollman int default_gateway; /* 1=advertise default */ 667b6ab19dSGarrett Wollman int background = 1; 677b6ab19dSGarrett Wollman int ridhosts; /* 1=reduce host routes */ 687b6ab19dSGarrett Wollman int mhome; /* 1=want multi-homed host route */ 6990100551SPhilippe Charnier int advertise_mhome; /* 1=must continue advertising it */ 707b6ab19dSGarrett Wollman int auth_ok = 1; /* 1=ignore auth if we do not care */ 717b6ab19dSGarrett Wollman 727b6ab19dSGarrett Wollman struct timeval epoch; /* when started */ 737b6ab19dSGarrett Wollman struct timeval clk, prev_clk; 742c7a9781SMark Murray static int usec_fudge; 757b6ab19dSGarrett Wollman struct timeval now; /* current idea of time */ 767b6ab19dSGarrett Wollman time_t now_stale; 777b6ab19dSGarrett Wollman time_t now_expire; 787b6ab19dSGarrett Wollman time_t now_garbage; 797b6ab19dSGarrett Wollman 807b6ab19dSGarrett Wollman struct timeval next_bcast; /* next general broadcast */ 81f7434bbdSSheldon Hearn struct timeval no_flash = { /* inhibit flash update */ 82f7434bbdSSheldon Hearn EPOCH+SUPPLY_INTERVAL, 0 83f7434bbdSSheldon Hearn }; 847b6ab19dSGarrett Wollman 852c7a9781SMark Murray struct timeval flush_kern_timer; 862c7a9781SMark Murray 877b6ab19dSGarrett Wollman fd_set fdbits; 887b6ab19dSGarrett Wollman int sock_max; 897b6ab19dSGarrett Wollman int rip_sock = -1; /* RIP socket */ 907b6ab19dSGarrett Wollman struct interface *rip_sock_mcast; /* current multicast interface */ 917b6ab19dSGarrett Wollman int rt_sock; /* routing socket */ 927b6ab19dSGarrett Wollman int rt_sock_seqno; 937b6ab19dSGarrett Wollman 947b6ab19dSGarrett Wollman 957b6ab19dSGarrett Wollman static int get_rip_sock(naddr, int); 967b6ab19dSGarrett Wollman static void timevalsub(struct timeval *, struct timeval *, struct timeval *); 977b6ab19dSGarrett Wollman 987b6ab19dSGarrett Wollman int 997b6ab19dSGarrett Wollman main(int argc, 1007b6ab19dSGarrett Wollman char *argv[]) 1017b6ab19dSGarrett Wollman { 1027b6ab19dSGarrett Wollman int n, mib[4], off; 1037b6ab19dSGarrett Wollman size_t len; 1047b6ab19dSGarrett Wollman char *p, *q; 1052c7a9781SMark Murray const char *cp; 1067b6ab19dSGarrett Wollman struct timeval wtime, t2; 1077b6ab19dSGarrett Wollman time_t dt; 1087b6ab19dSGarrett Wollman fd_set ibits; 1091608c04fSGarrett Wollman naddr p_net, p_mask; 1107b6ab19dSGarrett Wollman struct interface *ifp; 1117b6ab19dSGarrett Wollman struct parm parm; 1127b6ab19dSGarrett Wollman char *tracename = 0; 1137b6ab19dSGarrett Wollman 1147b6ab19dSGarrett Wollman 1151608c04fSGarrett Wollman /* Some shells are badly broken and send SIGHUP to backgrounded 1161608c04fSGarrett Wollman * processes. 1171608c04fSGarrett Wollman */ 1181608c04fSGarrett Wollman signal(SIGHUP, SIG_IGN); 1191608c04fSGarrett Wollman 120caa79e36SBruce M Simpson openlog("routed", LOG_PID, LOG_DAEMON); 1217b6ab19dSGarrett Wollman ftrace = stdout; 1227b6ab19dSGarrett Wollman 1237b6ab19dSGarrett Wollman gettimeofday(&clk, 0); 1247b6ab19dSGarrett Wollman prev_clk = clk; 1257b6ab19dSGarrett Wollman epoch = clk; 1267b6ab19dSGarrett Wollman epoch.tv_sec -= EPOCH; 1277b6ab19dSGarrett Wollman now.tv_sec = EPOCH; 1287b6ab19dSGarrett Wollman now_stale = EPOCH - STALE_TIME; 1297b6ab19dSGarrett Wollman now_expire = EPOCH - EXPIRE_TIME; 1307b6ab19dSGarrett Wollman now_garbage = EPOCH - GARBAGE_TIME; 1317b6ab19dSGarrett Wollman wtime.tv_sec = 0; 1327b6ab19dSGarrett Wollman 1337b6ab19dSGarrett Wollman (void)gethostname(myname, sizeof(myname)-1); 1347b6ab19dSGarrett Wollman (void)gethost(myname, &myaddr); 1357b6ab19dSGarrett Wollman 136a4fff644STom Rhodes while ((n = getopt(argc, argv, "sqdghmAtvT:F:P:")) != -1) { 1377b6ab19dSGarrett Wollman switch (n) { 1387b6ab19dSGarrett Wollman case 's': 1397b6ab19dSGarrett Wollman supplier = 1; 1407b6ab19dSGarrett Wollman supplier_set = 1; 1417b6ab19dSGarrett Wollman break; 1427b6ab19dSGarrett Wollman 1437b6ab19dSGarrett Wollman case 'q': 1447b6ab19dSGarrett Wollman supplier = 0; 1457b6ab19dSGarrett Wollman supplier_set = 1; 1467b6ab19dSGarrett Wollman break; 1477b6ab19dSGarrett Wollman 1487b6ab19dSGarrett Wollman case 'd': 1497b6ab19dSGarrett Wollman background = 0; 1507b6ab19dSGarrett Wollman break; 1517b6ab19dSGarrett Wollman 1527b6ab19dSGarrett Wollman case 'g': 1532c7a9781SMark Murray memset(&parm, 0, sizeof(parm)); 1547b6ab19dSGarrett Wollman parm.parm_d_metric = 1; 1552c7a9781SMark Murray cp = check_parms(&parm); 1562c7a9781SMark Murray if (cp != 0) 1572c7a9781SMark Murray msglog("bad -g: %s", cp); 1587b6ab19dSGarrett Wollman else 1597b6ab19dSGarrett Wollman default_gateway = 1; 1607b6ab19dSGarrett Wollman break; 1617b6ab19dSGarrett Wollman 1627b6ab19dSGarrett Wollman case 'h': /* suppress extra host routes */ 1637b6ab19dSGarrett Wollman ridhosts = 1; 1647b6ab19dSGarrett Wollman break; 1657b6ab19dSGarrett Wollman 1667b6ab19dSGarrett Wollman case 'm': /* advertise host route */ 1677b6ab19dSGarrett Wollman mhome = 1; /* on multi-homed hosts */ 1687b6ab19dSGarrett Wollman break; 1697b6ab19dSGarrett Wollman 1707b6ab19dSGarrett Wollman case 'A': 1717b6ab19dSGarrett Wollman /* Ignore authentication if we do not care. 1727b6ab19dSGarrett Wollman * Crazy as it is, that is what RFC 1723 requires. 1737b6ab19dSGarrett Wollman */ 1747b6ab19dSGarrett Wollman auth_ok = 0; 1757b6ab19dSGarrett Wollman break; 1767b6ab19dSGarrett Wollman 1777b6ab19dSGarrett Wollman case 't': 1787b6ab19dSGarrett Wollman new_tracelevel++; 1797b6ab19dSGarrett Wollman break; 1807b6ab19dSGarrett Wollman 1817b6ab19dSGarrett Wollman case 'T': 1827b6ab19dSGarrett Wollman tracename = optarg; 1837b6ab19dSGarrett Wollman break; 1847b6ab19dSGarrett Wollman 1857b6ab19dSGarrett Wollman case 'F': /* minimal routes for SLIP */ 1861608c04fSGarrett Wollman n = FAKE_METRIC; 1877b6ab19dSGarrett Wollman p = strchr(optarg,','); 1887b6ab19dSGarrett Wollman if (p && *p != '\0') { 1897b6ab19dSGarrett Wollman n = (int)strtoul(p+1, &q, 0); 1907b6ab19dSGarrett Wollman if (*q == '\0' 1917b6ab19dSGarrett Wollman && n <= HOPCNT_INFINITY-1 1927b6ab19dSGarrett Wollman && n >= 1) 1937b6ab19dSGarrett Wollman *p = '\0'; 1947b6ab19dSGarrett Wollman } 1951608c04fSGarrett Wollman if (!getnet(optarg, &p_net, &p_mask)) { 1967b6ab19dSGarrett Wollman msglog("bad network; \"-F %s\"", 1977b6ab19dSGarrett Wollman optarg); 1987b6ab19dSGarrett Wollman break; 1997b6ab19dSGarrett Wollman } 2002c7a9781SMark Murray memset(&parm, 0, sizeof(parm)); 2011608c04fSGarrett Wollman parm.parm_net = p_net; 2027b6ab19dSGarrett Wollman parm.parm_mask = p_mask; 2037b6ab19dSGarrett Wollman parm.parm_d_metric = n; 2042c7a9781SMark Murray cp = check_parms(&parm); 2052c7a9781SMark Murray if (cp != 0) 2062c7a9781SMark Murray msglog("bad -F: %s", cp); 2077b6ab19dSGarrett Wollman break; 2087b6ab19dSGarrett Wollman 2097b6ab19dSGarrett Wollman case 'P': 2102c7a9781SMark Murray /* handle arbitrary parameters. 2117b6ab19dSGarrett Wollman */ 2122c7a9781SMark Murray q = strdup(optarg); 2132c7a9781SMark Murray cp = parse_parms(q, 0); 2142c7a9781SMark Murray if (cp != 0) 2152c7a9781SMark Murray msglog("%s in \"-P %s\"", cp, optarg); 2162c7a9781SMark Murray free(q); 2172c7a9781SMark Murray break; 2182c7a9781SMark Murray 2192c7a9781SMark Murray case 'v': 2202c7a9781SMark Murray /* display version */ 2212c7a9781SMark Murray verbose++; 222a4fff644STom Rhodes msglog("version 2.31"); 2237b6ab19dSGarrett Wollman break; 2247b6ab19dSGarrett Wollman 2257b6ab19dSGarrett Wollman default: 2267b6ab19dSGarrett Wollman goto usage; 2277b6ab19dSGarrett Wollman } 2287b6ab19dSGarrett Wollman } 2297b6ab19dSGarrett Wollman argc -= optind; 2307b6ab19dSGarrett Wollman argv += optind; 2317b6ab19dSGarrett Wollman 2327b6ab19dSGarrett Wollman if (tracename == 0 && argc >= 1) { 2337b6ab19dSGarrett Wollman tracename = *argv++; 2347b6ab19dSGarrett Wollman argc--; 2357b6ab19dSGarrett Wollman } 236a30febecSGarrett Wollman if (tracename != 0 && tracename[0] == '\0') 237a30febecSGarrett Wollman goto usage; 2387b6ab19dSGarrett Wollman if (argc != 0) { 2397b6ab19dSGarrett Wollman usage: 240a4fff644STom Rhodes logbad(0, "usage: routed [-sqdghmAtv] [-T tracefile]" 2417b6ab19dSGarrett Wollman " [-F net[,metric]] [-P parms]"); 2427b6ab19dSGarrett Wollman } 2432c7a9781SMark Murray if (geteuid() != 0) { 2442c7a9781SMark Murray if (verbose) 2452c7a9781SMark Murray exit(0); 2467b6ab19dSGarrett Wollman logbad(0, "requires UID 0"); 2472c7a9781SMark Murray } 2487b6ab19dSGarrett Wollman 2497b6ab19dSGarrett Wollman mib[0] = CTL_NET; 2507b6ab19dSGarrett Wollman mib[1] = PF_INET; 2517b6ab19dSGarrett Wollman mib[2] = IPPROTO_IP; 2527b6ab19dSGarrett Wollman mib[3] = IPCTL_FORWARDING; 2537b6ab19dSGarrett Wollman len = sizeof(ipforwarding); 2547b6ab19dSGarrett Wollman if (sysctl(mib, 4, &ipforwarding, &len, 0, 0) < 0) 2557b6ab19dSGarrett Wollman LOGERR("sysctl(IPCTL_FORWARDING)"); 2567b6ab19dSGarrett Wollman 2577b6ab19dSGarrett Wollman if (!ipforwarding) { 2587b6ab19dSGarrett Wollman if (supplier) 2597b6ab19dSGarrett Wollman msglog("-s incompatible with ipforwarding=0"); 2607b6ab19dSGarrett Wollman if (default_gateway) { 2617b6ab19dSGarrett Wollman msglog("-g incompatible with ipforwarding=0"); 2627b6ab19dSGarrett Wollman default_gateway = 0; 2637b6ab19dSGarrett Wollman } 2647b6ab19dSGarrett Wollman supplier = 0; 2657b6ab19dSGarrett Wollman supplier_set = 1; 2667b6ab19dSGarrett Wollman } 2677b6ab19dSGarrett Wollman if (default_gateway) { 2687b6ab19dSGarrett Wollman if (supplier_set && !supplier) { 2697b6ab19dSGarrett Wollman msglog("-g and -q incompatible"); 2707b6ab19dSGarrett Wollman } else { 2717b6ab19dSGarrett Wollman supplier = 1; 2727b6ab19dSGarrett Wollman supplier_set = 1; 2737b6ab19dSGarrett Wollman } 2747b6ab19dSGarrett Wollman } 2757b6ab19dSGarrett Wollman 2767b6ab19dSGarrett Wollman 2777b6ab19dSGarrett Wollman signal(SIGALRM, sigalrm); 2787b6ab19dSGarrett Wollman if (!background) 2797b6ab19dSGarrett Wollman signal(SIGHUP, sigterm); /* SIGHUP fatal during debugging */ 2807b6ab19dSGarrett Wollman signal(SIGTERM, sigterm); 2817b6ab19dSGarrett Wollman signal(SIGINT, sigterm); 2827b6ab19dSGarrett Wollman signal(SIGUSR1, sigtrace_on); 2837b6ab19dSGarrett Wollman signal(SIGUSR2, sigtrace_off); 2847b6ab19dSGarrett Wollman 2857b6ab19dSGarrett Wollman /* get into the background */ 2867b6ab19dSGarrett Wollman #ifdef sgi 287a30febecSGarrett Wollman if (0 > _daemonize(background ? 0 : (_DF_NOCHDIR|_DF_NOFORK), 2882c7a9781SMark Murray STDIN_FILENO, STDOUT_FILENO, STDERR_FILENO)) 2897b6ab19dSGarrett Wollman BADERR(0, "_daemonize()"); 2907b6ab19dSGarrett Wollman #else 2912c7a9781SMark Murray if (background && daemon(0, 1) < 0) 2927b6ab19dSGarrett Wollman BADERR(0,"daemon()"); 2937b6ab19dSGarrett Wollman #endif 2947b6ab19dSGarrett Wollman 295caa79e36SBruce M Simpson #if defined(__NetBSD__) 296caa79e36SBruce M Simpson pidfile(0); 297caa79e36SBruce M Simpson #endif 2987b6ab19dSGarrett Wollman mypid = getpid(); 299ae4ce2c1SAndrey A. Chernov #ifdef __FreeBSD__ 300ae4ce2c1SAndrey A. Chernov srandomdev(); 301ae4ce2c1SAndrey A. Chernov #else 3027b6ab19dSGarrett Wollman srandom((int)(clk.tv_sec ^ clk.tv_usec ^ mypid)); 303ae4ce2c1SAndrey A. Chernov #endif 3047b6ab19dSGarrett Wollman 3057b6ab19dSGarrett Wollman /* prepare socket connected to the kernel. 3067b6ab19dSGarrett Wollman */ 3077b6ab19dSGarrett Wollman rt_sock = socket(AF_ROUTE, SOCK_RAW, 0); 3087b6ab19dSGarrett Wollman if (rt_sock < 0) 3097b6ab19dSGarrett Wollman BADERR(1,"rt_sock = socket()"); 3107b6ab19dSGarrett Wollman if (fcntl(rt_sock, F_SETFL, O_NONBLOCK) == -1) 3117b6ab19dSGarrett Wollman logbad(1, "fcntl(rt_sock) O_NONBLOCK: %s", strerror(errno)); 3127b6ab19dSGarrett Wollman off = 0; 3137b6ab19dSGarrett Wollman if (setsockopt(rt_sock, SOL_SOCKET,SO_USELOOPBACK, 3147b6ab19dSGarrett Wollman &off,sizeof(off)) < 0) 3157b6ab19dSGarrett Wollman LOGERR("setsockopt(SO_USELOOPBACK,0)"); 3167b6ab19dSGarrett Wollman 3177b6ab19dSGarrett Wollman fix_select(); 3187b6ab19dSGarrett Wollman 3197b6ab19dSGarrett Wollman 3207b6ab19dSGarrett Wollman if (tracename != 0) { 321a30febecSGarrett Wollman strncpy(inittracename, tracename, sizeof(inittracename)-1); 3222c7a9781SMark Murray set_tracefile(inittracename, "%s", -1); 323a30febecSGarrett Wollman } else { 3242c7a9781SMark Murray tracelevel_msg("%s", -1); /* turn on tracing to stdio */ 3257b6ab19dSGarrett Wollman } 3261608c04fSGarrett Wollman 3271608c04fSGarrett Wollman bufinit(); 3287b6ab19dSGarrett Wollman 3297b6ab19dSGarrett Wollman /* initialize radix tree */ 3307b6ab19dSGarrett Wollman rtinit(); 3317b6ab19dSGarrett Wollman 3327b6ab19dSGarrett Wollman /* Pick a random part of the second for our output to minimize 3337b6ab19dSGarrett Wollman * collisions. 3347b6ab19dSGarrett Wollman * 3357b6ab19dSGarrett Wollman * Start broadcasting after hearing from other routers, and 3367b6ab19dSGarrett Wollman * at a random time so a bunch of systems do not get synchronized 3377b6ab19dSGarrett Wollman * after a power failure. 3387b6ab19dSGarrett Wollman */ 3397b6ab19dSGarrett Wollman intvl_random(&next_bcast, EPOCH+MIN_WAITTIME, EPOCH+SUPPLY_INTERVAL); 3407b6ab19dSGarrett Wollman age_timer.tv_usec = next_bcast.tv_usec; 3417b6ab19dSGarrett Wollman age_timer.tv_sec = EPOCH+MIN_WAITTIME; 3427b6ab19dSGarrett Wollman rdisc_timer = next_bcast; 3437b6ab19dSGarrett Wollman ifinit_timer.tv_usec = next_bcast.tv_usec; 3447b6ab19dSGarrett Wollman 3457b6ab19dSGarrett Wollman /* Collect an initial view of the world by checking the interface 3467b6ab19dSGarrett Wollman * configuration and the kludge file. 3477b6ab19dSGarrett Wollman */ 3487b6ab19dSGarrett Wollman gwkludge(); 3497b6ab19dSGarrett Wollman ifinit(); 3507b6ab19dSGarrett Wollman 3517b6ab19dSGarrett Wollman /* Ask for routes */ 3527b6ab19dSGarrett Wollman rip_query(); 3537b6ab19dSGarrett Wollman rdisc_sol(); 3547b6ab19dSGarrett Wollman 3552c7a9781SMark Murray /* Now turn off stdio if not tracing */ 3562c7a9781SMark Murray if (new_tracelevel == 0) 3572c7a9781SMark Murray trace_close(background); 3582c7a9781SMark Murray 3597b6ab19dSGarrett Wollman /* Loop forever, listening and broadcasting. 3607b6ab19dSGarrett Wollman */ 3617b6ab19dSGarrett Wollman for (;;) { 3627b6ab19dSGarrett Wollman prev_clk = clk; 3637b6ab19dSGarrett Wollman gettimeofday(&clk, 0); 3642c7a9781SMark Murray if (prev_clk.tv_sec == clk.tv_sec 3652c7a9781SMark Murray && prev_clk.tv_usec == clk.tv_usec+usec_fudge) { 3662c7a9781SMark Murray /* Much of `routed` depends on time always advancing. 3672c7a9781SMark Murray * On systems that do not guarantee that gettimeofday() 3682c7a9781SMark Murray * produces unique timestamps even if called within 3692c7a9781SMark Murray * a single tick, use trickery like that in classic 3702c7a9781SMark Murray * BSD kernels. 3712c7a9781SMark Murray */ 3722c7a9781SMark Murray clk.tv_usec += ++usec_fudge; 3732c7a9781SMark Murray 3742c7a9781SMark Murray } else { 3752c7a9781SMark Murray usec_fudge = 0; 3762c7a9781SMark Murray 3777b6ab19dSGarrett Wollman timevalsub(&t2, &clk, &prev_clk); 3787b6ab19dSGarrett Wollman if (t2.tv_sec < 0 3797b6ab19dSGarrett Wollman || t2.tv_sec > wtime.tv_sec + 5) { 3802c7a9781SMark Murray /* Deal with time changes before other 3812c7a9781SMark Murray * housekeeping to keep everything straight. 3827b6ab19dSGarrett Wollman */ 3837b6ab19dSGarrett Wollman dt = t2.tv_sec; 3847b6ab19dSGarrett Wollman if (dt > 0) 3857b6ab19dSGarrett Wollman dt -= wtime.tv_sec; 3862c7a9781SMark Murray trace_act("time changed by %d sec", (int)dt); 3877b6ab19dSGarrett Wollman epoch.tv_sec += dt; 3887b6ab19dSGarrett Wollman } 3892c7a9781SMark Murray } 3907b6ab19dSGarrett Wollman timevalsub(&now, &clk, &epoch); 3917b6ab19dSGarrett Wollman now_stale = now.tv_sec - STALE_TIME; 3927b6ab19dSGarrett Wollman now_expire = now.tv_sec - EXPIRE_TIME; 3937b6ab19dSGarrett Wollman now_garbage = now.tv_sec - GARBAGE_TIME; 3947b6ab19dSGarrett Wollman 395a30febecSGarrett Wollman /* deal with signals that should affect tracing */ 396a30febecSGarrett Wollman set_tracelevel(); 3977b6ab19dSGarrett Wollman 3987b6ab19dSGarrett Wollman if (stopint != 0) { 3997b6ab19dSGarrett Wollman rip_bcast(0); 4007b6ab19dSGarrett Wollman rdisc_adv(); 4012c7a9781SMark Murray trace_off("exiting with signal %d", stopint); 4027b6ab19dSGarrett Wollman exit(stopint | 128); 4037b6ab19dSGarrett Wollman } 4047b6ab19dSGarrett Wollman 4057b6ab19dSGarrett Wollman /* look for new or dead interfaces */ 4067b6ab19dSGarrett Wollman timevalsub(&wtime, &ifinit_timer, &now); 4077b6ab19dSGarrett Wollman if (wtime.tv_sec <= 0) { 4087b6ab19dSGarrett Wollman wtime.tv_sec = 0; 4097b6ab19dSGarrett Wollman ifinit(); 4107b6ab19dSGarrett Wollman rip_query(); 4117b6ab19dSGarrett Wollman continue; 4127b6ab19dSGarrett Wollman } 4137b6ab19dSGarrett Wollman 4142c7a9781SMark Murray /* Check the kernel table occassionally for mysteriously 4152c7a9781SMark Murray * evaporated routes 4162c7a9781SMark Murray */ 4172c7a9781SMark Murray timevalsub(&t2, &flush_kern_timer, &now); 4182c7a9781SMark Murray if (t2.tv_sec <= 0) { 4192c7a9781SMark Murray flush_kern(); 4202c7a9781SMark Murray flush_kern_timer.tv_sec = (now.tv_sec 4212c7a9781SMark Murray + CHECK_QUIET_INTERVAL); 4222c7a9781SMark Murray continue; 4232c7a9781SMark Murray } 4242c7a9781SMark Murray if (timercmp(&t2, &wtime, <)) 4252c7a9781SMark Murray wtime = t2; 4262c7a9781SMark Murray 4277b6ab19dSGarrett Wollman /* If it is time, then broadcast our routes. 4287b6ab19dSGarrett Wollman */ 4297b6ab19dSGarrett Wollman if (supplier || advertise_mhome) { 4307b6ab19dSGarrett Wollman timevalsub(&t2, &next_bcast, &now); 4317b6ab19dSGarrett Wollman if (t2.tv_sec <= 0) { 4327b6ab19dSGarrett Wollman /* Synchronize the aging and broadcast 4337b6ab19dSGarrett Wollman * timers to minimize awakenings 4347b6ab19dSGarrett Wollman */ 4357b6ab19dSGarrett Wollman age(0); 4367b6ab19dSGarrett Wollman 4377b6ab19dSGarrett Wollman rip_bcast(0); 4387b6ab19dSGarrett Wollman 4397b6ab19dSGarrett Wollman /* It is desirable to send routing updates 4407b6ab19dSGarrett Wollman * regularly. So schedule the next update 4417b6ab19dSGarrett Wollman * 30 seconds after the previous one was 4426f1edd29SDaniel O'Callaghan * scheduled, instead of 30 seconds after 4437b6ab19dSGarrett Wollman * the previous update was finished. 4447b6ab19dSGarrett Wollman * Even if we just started after discovering 4457b6ab19dSGarrett Wollman * a 2nd interface or were otherwise delayed, 4467b6ab19dSGarrett Wollman * pick a 30-second aniversary of the 4477b6ab19dSGarrett Wollman * original broadcast time. 4487b6ab19dSGarrett Wollman */ 4497b6ab19dSGarrett Wollman n = 1 + (0-t2.tv_sec)/SUPPLY_INTERVAL; 4507b6ab19dSGarrett Wollman next_bcast.tv_sec += n*SUPPLY_INTERVAL; 4517b6ab19dSGarrett Wollman 4527b6ab19dSGarrett Wollman continue; 4537b6ab19dSGarrett Wollman } 4547b6ab19dSGarrett Wollman 4557b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4567b6ab19dSGarrett Wollman wtime = t2; 4577b6ab19dSGarrett Wollman } 4587b6ab19dSGarrett Wollman 4597b6ab19dSGarrett Wollman /* If we need a flash update, either do it now or 4607b6ab19dSGarrett Wollman * set the delay to end when it is time. 4617b6ab19dSGarrett Wollman * 4627b6ab19dSGarrett Wollman * If we are within MIN_WAITTIME seconds of a full update, 4637b6ab19dSGarrett Wollman * do not bother. 4647b6ab19dSGarrett Wollman */ 4657b6ab19dSGarrett Wollman if (need_flash 4667b6ab19dSGarrett Wollman && supplier 4677b6ab19dSGarrett Wollman && no_flash.tv_sec+MIN_WAITTIME < next_bcast.tv_sec) { 4687b6ab19dSGarrett Wollman /* accurate to the millisecond */ 4697b6ab19dSGarrett Wollman if (!timercmp(&no_flash, &now, >)) 4707b6ab19dSGarrett Wollman rip_bcast(1); 4717b6ab19dSGarrett Wollman timevalsub(&t2, &no_flash, &now); 4727b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4737b6ab19dSGarrett Wollman wtime = t2; 4747b6ab19dSGarrett Wollman } 4757b6ab19dSGarrett Wollman 4767b6ab19dSGarrett Wollman /* trigger the main aging timer. 4777b6ab19dSGarrett Wollman */ 4787b6ab19dSGarrett Wollman timevalsub(&t2, &age_timer, &now); 4797b6ab19dSGarrett Wollman if (t2.tv_sec <= 0) { 4807b6ab19dSGarrett Wollman age(0); 4817b6ab19dSGarrett Wollman continue; 4827b6ab19dSGarrett Wollman } 4837b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4847b6ab19dSGarrett Wollman wtime = t2; 4857b6ab19dSGarrett Wollman 4867b6ab19dSGarrett Wollman /* update the kernel routing table 4877b6ab19dSGarrett Wollman */ 4887b6ab19dSGarrett Wollman timevalsub(&t2, &need_kern, &now); 4897b6ab19dSGarrett Wollman if (t2.tv_sec <= 0) { 4907b6ab19dSGarrett Wollman age(0); 4917b6ab19dSGarrett Wollman continue; 4927b6ab19dSGarrett Wollman } 4937b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4947b6ab19dSGarrett Wollman wtime = t2; 4957b6ab19dSGarrett Wollman 4967b6ab19dSGarrett Wollman /* take care of router discovery, 4972c7a9781SMark Murray * but do it in the correct the millisecond 4987b6ab19dSGarrett Wollman */ 4997b6ab19dSGarrett Wollman if (!timercmp(&rdisc_timer, &now, >)) { 5007b6ab19dSGarrett Wollman rdisc_age(0); 5017b6ab19dSGarrett Wollman continue; 5027b6ab19dSGarrett Wollman } 5037b6ab19dSGarrett Wollman timevalsub(&t2, &rdisc_timer, &now); 5047b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 5057b6ab19dSGarrett Wollman wtime = t2; 5067b6ab19dSGarrett Wollman 5077b6ab19dSGarrett Wollman 5087b6ab19dSGarrett Wollman /* wait for input or a timer to expire. 5097b6ab19dSGarrett Wollman */ 5107b6ab19dSGarrett Wollman trace_flush(); 5117b6ab19dSGarrett Wollman ibits = fdbits; 5127b6ab19dSGarrett Wollman n = select(sock_max, &ibits, 0, 0, &wtime); 5137b6ab19dSGarrett Wollman if (n <= 0) { 5147b6ab19dSGarrett Wollman if (n < 0 && errno != EINTR && errno != EAGAIN) 5157b6ab19dSGarrett Wollman BADERR(1,"select"); 5167b6ab19dSGarrett Wollman continue; 5177b6ab19dSGarrett Wollman } 5187b6ab19dSGarrett Wollman 5197b6ab19dSGarrett Wollman if (FD_ISSET(rt_sock, &ibits)) { 5207b6ab19dSGarrett Wollman read_rt(); 5217b6ab19dSGarrett Wollman n--; 5227b6ab19dSGarrett Wollman } 5237b6ab19dSGarrett Wollman if (rdisc_sock >= 0 && FD_ISSET(rdisc_sock, &ibits)) { 5247b6ab19dSGarrett Wollman read_d(); 5257b6ab19dSGarrett Wollman n--; 5267b6ab19dSGarrett Wollman } 5277b6ab19dSGarrett Wollman if (rip_sock >= 0 && FD_ISSET(rip_sock, &ibits)) { 5287b6ab19dSGarrett Wollman read_rip(rip_sock, 0); 5297b6ab19dSGarrett Wollman n--; 5307b6ab19dSGarrett Wollman } 5317b6ab19dSGarrett Wollman 5327b6ab19dSGarrett Wollman for (ifp = ifnet; n > 0 && 0 != ifp; ifp = ifp->int_next) { 5337b6ab19dSGarrett Wollman if (ifp->int_rip_sock >= 0 5347b6ab19dSGarrett Wollman && FD_ISSET(ifp->int_rip_sock, &ibits)) { 5357b6ab19dSGarrett Wollman read_rip(ifp->int_rip_sock, ifp); 5367b6ab19dSGarrett Wollman n--; 5377b6ab19dSGarrett Wollman } 5387b6ab19dSGarrett Wollman } 5397b6ab19dSGarrett Wollman } 5407b6ab19dSGarrett Wollman } 5417b6ab19dSGarrett Wollman 5427b6ab19dSGarrett Wollman 5437b6ab19dSGarrett Wollman /* ARGSUSED */ 5447b6ab19dSGarrett Wollman void 5452c7a9781SMark Murray sigalrm(int s UNUSED) 5467b6ab19dSGarrett Wollman { 5477b6ab19dSGarrett Wollman /* Historically, SIGALRM would cause the daemon to check for 5487b6ab19dSGarrett Wollman * new and broken interfaces. 5497b6ab19dSGarrett Wollman */ 5507b6ab19dSGarrett Wollman ifinit_timer.tv_sec = now.tv_sec; 5511608c04fSGarrett Wollman trace_act("SIGALRM"); 5527b6ab19dSGarrett Wollman } 5537b6ab19dSGarrett Wollman 5547b6ab19dSGarrett Wollman 5557b6ab19dSGarrett Wollman /* watch for fatal signals */ 5567b6ab19dSGarrett Wollman void 5577b6ab19dSGarrett Wollman sigterm(int sig) 5587b6ab19dSGarrett Wollman { 5597b6ab19dSGarrett Wollman stopint = sig; 5607b6ab19dSGarrett Wollman (void)signal(sig, SIG_DFL); /* catch it only once */ 5617b6ab19dSGarrett Wollman } 5627b6ab19dSGarrett Wollman 5637b6ab19dSGarrett Wollman 5647b6ab19dSGarrett Wollman void 5657b6ab19dSGarrett Wollman fix_select(void) 5667b6ab19dSGarrett Wollman { 5677b6ab19dSGarrett Wollman struct interface *ifp; 5687b6ab19dSGarrett Wollman 5697b6ab19dSGarrett Wollman 5707b6ab19dSGarrett Wollman FD_ZERO(&fdbits); 5717b6ab19dSGarrett Wollman sock_max = 0; 5727b6ab19dSGarrett Wollman 5737b6ab19dSGarrett Wollman FD_SET(rt_sock, &fdbits); 5747b6ab19dSGarrett Wollman if (sock_max <= rt_sock) 5757b6ab19dSGarrett Wollman sock_max = rt_sock+1; 5767b6ab19dSGarrett Wollman if (rip_sock >= 0) { 5777b6ab19dSGarrett Wollman FD_SET(rip_sock, &fdbits); 5787b6ab19dSGarrett Wollman if (sock_max <= rip_sock) 5797b6ab19dSGarrett Wollman sock_max = rip_sock+1; 5807b6ab19dSGarrett Wollman } 5817b6ab19dSGarrett Wollman for (ifp = ifnet; 0 != ifp; ifp = ifp->int_next) { 5827b6ab19dSGarrett Wollman if (ifp->int_rip_sock >= 0) { 5837b6ab19dSGarrett Wollman FD_SET(ifp->int_rip_sock, &fdbits); 5847b6ab19dSGarrett Wollman if (sock_max <= ifp->int_rip_sock) 5857b6ab19dSGarrett Wollman sock_max = ifp->int_rip_sock+1; 5867b6ab19dSGarrett Wollman } 5877b6ab19dSGarrett Wollman } 5887b6ab19dSGarrett Wollman if (rdisc_sock >= 0) { 5897b6ab19dSGarrett Wollman FD_SET(rdisc_sock, &fdbits); 5907b6ab19dSGarrett Wollman if (sock_max <= rdisc_sock) 5917b6ab19dSGarrett Wollman sock_max = rdisc_sock+1; 5927b6ab19dSGarrett Wollman } 5937b6ab19dSGarrett Wollman } 5947b6ab19dSGarrett Wollman 5957b6ab19dSGarrett Wollman 5967b6ab19dSGarrett Wollman void 5977b6ab19dSGarrett Wollman fix_sock(int sock, 5982c7a9781SMark Murray const char *name) 5997b6ab19dSGarrett Wollman { 6007b6ab19dSGarrett Wollman int on; 6017b6ab19dSGarrett Wollman #define MIN_SOCKBUF (4*1024) 6027b6ab19dSGarrett Wollman static int rbuf; 6037b6ab19dSGarrett Wollman 6047b6ab19dSGarrett Wollman if (fcntl(sock, F_SETFL, O_NONBLOCK) == -1) 6057b6ab19dSGarrett Wollman logbad(1, "fcntl(%s) O_NONBLOCK: %s", 6067b6ab19dSGarrett Wollman name, strerror(errno)); 6077b6ab19dSGarrett Wollman on = 1; 6081608c04fSGarrett Wollman if (setsockopt(sock, SOL_SOCKET,SO_BROADCAST, &on,sizeof(on)) < 0) 6097b6ab19dSGarrett Wollman msglog("setsockopt(%s,SO_BROADCAST): %s", 6107b6ab19dSGarrett Wollman name, strerror(errno)); 6111608c04fSGarrett Wollman #ifdef USE_PASSIFNAME 6121608c04fSGarrett Wollman on = 1; 6131608c04fSGarrett Wollman if (setsockopt(sock, SOL_SOCKET, SO_PASSIFNAME, &on,sizeof(on)) < 0) 6141608c04fSGarrett Wollman msglog("setsockopt(%s,SO_PASSIFNAME): %s", 6151608c04fSGarrett Wollman name, strerror(errno)); 6161608c04fSGarrett Wollman #endif 6171608c04fSGarrett Wollman 6187b6ab19dSGarrett Wollman if (rbuf >= MIN_SOCKBUF) { 6197b6ab19dSGarrett Wollman if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, 6207b6ab19dSGarrett Wollman &rbuf, sizeof(rbuf)) < 0) 6217b6ab19dSGarrett Wollman msglog("setsockopt(%s,SO_RCVBUF=%d): %s", 6227b6ab19dSGarrett Wollman name, rbuf, strerror(errno)); 6237b6ab19dSGarrett Wollman } else { 6247b6ab19dSGarrett Wollman for (rbuf = 60*1024; ; rbuf -= 4096) { 6257b6ab19dSGarrett Wollman if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, 6267b6ab19dSGarrett Wollman &rbuf, sizeof(rbuf)) == 0) { 6271608c04fSGarrett Wollman trace_act("RCVBUF=%d", rbuf); 6287b6ab19dSGarrett Wollman break; 6297b6ab19dSGarrett Wollman } 6307b6ab19dSGarrett Wollman if (rbuf < MIN_SOCKBUF) { 6317b6ab19dSGarrett Wollman msglog("setsockopt(%s,SO_RCVBUF = %d): %s", 6327b6ab19dSGarrett Wollman name, rbuf, strerror(errno)); 6337b6ab19dSGarrett Wollman break; 6347b6ab19dSGarrett Wollman } 6357b6ab19dSGarrett Wollman } 6367b6ab19dSGarrett Wollman } 6377b6ab19dSGarrett Wollman } 6387b6ab19dSGarrett Wollman 6397b6ab19dSGarrett Wollman 6407b6ab19dSGarrett Wollman /* get a rip socket 6417b6ab19dSGarrett Wollman */ 6427b6ab19dSGarrett Wollman static int /* <0 or file descriptor */ 6437b6ab19dSGarrett Wollman get_rip_sock(naddr addr, 6447b6ab19dSGarrett Wollman int serious) /* 1=failure to bind is serious */ 6457b6ab19dSGarrett Wollman { 646caa79e36SBruce M Simpson struct sockaddr_in rsin; 6477b6ab19dSGarrett Wollman unsigned char ttl; 6487b6ab19dSGarrett Wollman int s; 6497b6ab19dSGarrett Wollman 6507b6ab19dSGarrett Wollman 6517b6ab19dSGarrett Wollman if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) 6527b6ab19dSGarrett Wollman BADERR(1,"rip_sock = socket()"); 6537b6ab19dSGarrett Wollman 654caa79e36SBruce M Simpson memset(&rsin, 0, sizeof(rsin)); 6557b6ab19dSGarrett Wollman #ifdef _HAVE_SIN_LEN 656caa79e36SBruce M Simpson rsin.sin_len = sizeof(rsin); 6577b6ab19dSGarrett Wollman #endif 658caa79e36SBruce M Simpson rsin.sin_family = AF_INET; 659caa79e36SBruce M Simpson rsin.sin_port = htons(RIP_PORT); 660caa79e36SBruce M Simpson rsin.sin_addr.s_addr = addr; 661caa79e36SBruce M Simpson if (bind(s, (struct sockaddr *)&rsin, sizeof(rsin)) < 0) { 6627b6ab19dSGarrett Wollman if (serious) 6637b6ab19dSGarrett Wollman BADERR(errno != EADDRINUSE, "bind(rip_sock)"); 6647b6ab19dSGarrett Wollman return -1; 6657b6ab19dSGarrett Wollman } 6667b6ab19dSGarrett Wollman fix_sock(s,"rip_sock"); 6677b6ab19dSGarrett Wollman 6687b6ab19dSGarrett Wollman ttl = 1; 6697b6ab19dSGarrett Wollman if (setsockopt(s, IPPROTO_IP, IP_MULTICAST_TTL, 6707b6ab19dSGarrett Wollman &ttl, sizeof(ttl)) < 0) 6717b6ab19dSGarrett Wollman DBGERR(1,"rip_sock setsockopt(IP_MULTICAST_TTL)"); 6727b6ab19dSGarrett Wollman 6737b6ab19dSGarrett Wollman return s; 6747b6ab19dSGarrett Wollman } 6757b6ab19dSGarrett Wollman 6767b6ab19dSGarrett Wollman 6777b6ab19dSGarrett Wollman /* turn off main RIP socket */ 6787b6ab19dSGarrett Wollman void 6797b6ab19dSGarrett Wollman rip_off(void) 6807b6ab19dSGarrett Wollman { 6817b6ab19dSGarrett Wollman struct interface *ifp; 6822c7a9781SMark Murray naddr addr; 6837b6ab19dSGarrett Wollman 6847b6ab19dSGarrett Wollman 6857b6ab19dSGarrett Wollman if (rip_sock >= 0 && !mhome) { 6861608c04fSGarrett Wollman trace_act("turn off RIP"); 6877b6ab19dSGarrett Wollman 6887b6ab19dSGarrett Wollman (void)close(rip_sock); 6897b6ab19dSGarrett Wollman rip_sock = -1; 6907b6ab19dSGarrett Wollman 6917b6ab19dSGarrett Wollman /* get non-broadcast sockets to listen to queries. 6927b6ab19dSGarrett Wollman */ 6937b6ab19dSGarrett Wollman for (ifp = ifnet; ifp != 0; ifp = ifp->int_next) { 6941608c04fSGarrett Wollman if (ifp->int_state & IS_REMOTE) 6951608c04fSGarrett Wollman continue; 6961608c04fSGarrett Wollman if (ifp->int_rip_sock < 0) { 6977b6ab19dSGarrett Wollman addr = ((ifp->int_if_flags & IFF_POINTOPOINT) 6987b6ab19dSGarrett Wollman ? ifp->int_dstaddr 6997b6ab19dSGarrett Wollman : ifp->int_addr); 7007b6ab19dSGarrett Wollman ifp->int_rip_sock = get_rip_sock(addr, 0); 7017b6ab19dSGarrett Wollman } 7027b6ab19dSGarrett Wollman } 7037b6ab19dSGarrett Wollman 7047b6ab19dSGarrett Wollman fix_select(); 7057b6ab19dSGarrett Wollman 7067b6ab19dSGarrett Wollman age(0); 7077b6ab19dSGarrett Wollman } 7087b6ab19dSGarrett Wollman } 7097b6ab19dSGarrett Wollman 7107b6ab19dSGarrett Wollman 7117b6ab19dSGarrett Wollman /* turn on RIP multicast input via an interface 7127b6ab19dSGarrett Wollman */ 7137b6ab19dSGarrett Wollman static void 7147b6ab19dSGarrett Wollman rip_mcast_on(struct interface *ifp) 7157b6ab19dSGarrett Wollman { 71668b22388SPoul-Henning Kamp struct group_req gr; 71768b22388SPoul-Henning Kamp struct sockaddr_in *sin; 7187b6ab19dSGarrett Wollman 7197b6ab19dSGarrett Wollman if (!IS_RIP_IN_OFF(ifp->int_state) 7207b6ab19dSGarrett Wollman && (ifp->int_if_flags & IFF_MULTICAST) 7217b6ab19dSGarrett Wollman && !(ifp->int_state & IS_ALIAS)) { 72268b22388SPoul-Henning Kamp memset(&gr, 0, sizeof(gr)); 72368b22388SPoul-Henning Kamp gr.gr_interface = ifp->int_index; 72468b22388SPoul-Henning Kamp sin = (struct sockaddr_in *)&gr.gr_group; 72568b22388SPoul-Henning Kamp sin->sin_family = AF_INET; 72668b22388SPoul-Henning Kamp #ifdef _HAVE_SIN_LEN 72768b22388SPoul-Henning Kamp sin->sin_len = sizeof(struct sockaddr_in); 728caa79e36SBruce M Simpson #endif 72968b22388SPoul-Henning Kamp sin->sin_addr.s_addr = htonl(INADDR_RIP_GROUP); 73068b22388SPoul-Henning Kamp if (setsockopt(rip_sock, IPPROTO_IP, MCAST_JOIN_GROUP, 73168b22388SPoul-Henning Kamp &gr, sizeof(gr)) < 0) 73268b22388SPoul-Henning Kamp LOGERR("setsockopt(MCAST_JOIN_GROUP RIP)"); 7337b6ab19dSGarrett Wollman } 7347b6ab19dSGarrett Wollman } 7357b6ab19dSGarrett Wollman 7367b6ab19dSGarrett Wollman 7377b6ab19dSGarrett Wollman /* Prepare socket used for RIP. 7387b6ab19dSGarrett Wollman */ 7397b6ab19dSGarrett Wollman void 7407b6ab19dSGarrett Wollman rip_on(struct interface *ifp) 7417b6ab19dSGarrett Wollman { 7427b6ab19dSGarrett Wollman /* If the main RIP socket is already alive, only start receiving 7437b6ab19dSGarrett Wollman * multicasts for this interface. 7447b6ab19dSGarrett Wollman */ 7457b6ab19dSGarrett Wollman if (rip_sock >= 0) { 7467b6ab19dSGarrett Wollman if (ifp != 0) 7477b6ab19dSGarrett Wollman rip_mcast_on(ifp); 7487b6ab19dSGarrett Wollman return; 7497b6ab19dSGarrett Wollman } 7507b6ab19dSGarrett Wollman 7511608c04fSGarrett Wollman /* If the main RIP socket is off and it makes sense to turn it on, 7521608c04fSGarrett Wollman * then turn it on for all of the interfaces. 7532c7a9781SMark Murray * It makes sense if either router discovery is off, or if 7542c7a9781SMark Murray * router discover is on and at most one interface is doing RIP. 7557b6ab19dSGarrett Wollman */ 7562c7a9781SMark Murray if (rip_interfaces > 0 && (!rdisc_ok || rip_interfaces > 1)) { 7571608c04fSGarrett Wollman trace_act("turn on RIP"); 7587b6ab19dSGarrett Wollman 7597b6ab19dSGarrett Wollman /* Close all of the query sockets so that we can open 7607b6ab19dSGarrett Wollman * the main socket. SO_REUSEPORT is not a solution, 7617b6ab19dSGarrett Wollman * since that would let two daemons bind to the broadcast 7627b6ab19dSGarrett Wollman * socket. 7637b6ab19dSGarrett Wollman */ 7647b6ab19dSGarrett Wollman for (ifp = ifnet; ifp != 0; ifp = ifp->int_next) { 7657b6ab19dSGarrett Wollman if (ifp->int_rip_sock >= 0) { 7667b6ab19dSGarrett Wollman (void)close(ifp->int_rip_sock); 7677b6ab19dSGarrett Wollman ifp->int_rip_sock = -1; 7687b6ab19dSGarrett Wollman } 7697b6ab19dSGarrett Wollman } 7707b6ab19dSGarrett Wollman 7717b6ab19dSGarrett Wollman rip_sock = get_rip_sock(INADDR_ANY, 1); 7727b6ab19dSGarrett Wollman rip_sock_mcast = 0; 7737b6ab19dSGarrett Wollman 7747b6ab19dSGarrett Wollman /* Do not advertise anything until we have heard something 7757b6ab19dSGarrett Wollman */ 7767b6ab19dSGarrett Wollman if (next_bcast.tv_sec < now.tv_sec+MIN_WAITTIME) 7777b6ab19dSGarrett Wollman next_bcast.tv_sec = now.tv_sec+MIN_WAITTIME; 7787b6ab19dSGarrett Wollman 7797b6ab19dSGarrett Wollman for (ifp = ifnet; ifp != 0; ifp = ifp->int_next) { 7801608c04fSGarrett Wollman ifp->int_query_time = NEVER; 7817b6ab19dSGarrett Wollman rip_mcast_on(ifp); 7827b6ab19dSGarrett Wollman } 7837b6ab19dSGarrett Wollman ifinit_timer.tv_sec = now.tv_sec; 7847b6ab19dSGarrett Wollman 7857b6ab19dSGarrett Wollman } else if (ifp != 0 7861608c04fSGarrett Wollman && !(ifp->int_state & IS_REMOTE) 7871608c04fSGarrett Wollman && ifp->int_rip_sock < 0) { 7887b6ab19dSGarrett Wollman /* RIP is off, so ensure there are sockets on which 7897b6ab19dSGarrett Wollman * to listen for queries. 7907b6ab19dSGarrett Wollman */ 7917b6ab19dSGarrett Wollman ifp->int_rip_sock = get_rip_sock(ifp->int_addr, 0); 7921608c04fSGarrett Wollman } 7937b6ab19dSGarrett Wollman 7947b6ab19dSGarrett Wollman fix_select(); 7957b6ab19dSGarrett Wollman } 7967b6ab19dSGarrett Wollman 7977b6ab19dSGarrett Wollman 7987b6ab19dSGarrett Wollman /* die if malloc(3) fails 7997b6ab19dSGarrett Wollman */ 8007b6ab19dSGarrett Wollman void * 8017b6ab19dSGarrett Wollman rtmalloc(size_t size, 8022c7a9781SMark Murray const char *msg) 8037b6ab19dSGarrett Wollman { 8047b6ab19dSGarrett Wollman void *p = malloc(size); 8057b6ab19dSGarrett Wollman if (p == 0) 8062c7a9781SMark Murray logbad(1,"malloc(%lu) failed in %s", (u_long)size, msg); 8077b6ab19dSGarrett Wollman return p; 8087b6ab19dSGarrett Wollman } 8097b6ab19dSGarrett Wollman 8107b6ab19dSGarrett Wollman 8117b6ab19dSGarrett Wollman /* get a random instant in an interval 8127b6ab19dSGarrett Wollman */ 8137b6ab19dSGarrett Wollman void 8147b6ab19dSGarrett Wollman intvl_random(struct timeval *tp, /* put value here */ 8157b6ab19dSGarrett Wollman u_long lo, /* value is after this second */ 8167b6ab19dSGarrett Wollman u_long hi) /* and before this */ 8177b6ab19dSGarrett Wollman { 8187b6ab19dSGarrett Wollman tp->tv_sec = (time_t)(hi == lo 8197b6ab19dSGarrett Wollman ? lo 8207b6ab19dSGarrett Wollman : (lo + random() % ((hi - lo)))); 8217b6ab19dSGarrett Wollman tp->tv_usec = random() % 1000000; 8227b6ab19dSGarrett Wollman } 8237b6ab19dSGarrett Wollman 8247b6ab19dSGarrett Wollman 8257b6ab19dSGarrett Wollman void 8267b6ab19dSGarrett Wollman timevaladd(struct timeval *t1, 8277b6ab19dSGarrett Wollman struct timeval *t2) 8287b6ab19dSGarrett Wollman { 8297b6ab19dSGarrett Wollman 8307b6ab19dSGarrett Wollman t1->tv_sec += t2->tv_sec; 83190100551SPhilippe Charnier if ((t1->tv_usec += t2->tv_usec) >= 1000000) { 8327b6ab19dSGarrett Wollman t1->tv_sec++; 8337b6ab19dSGarrett Wollman t1->tv_usec -= 1000000; 8347b6ab19dSGarrett Wollman } 8357b6ab19dSGarrett Wollman } 8367b6ab19dSGarrett Wollman 8377b6ab19dSGarrett Wollman 8387b6ab19dSGarrett Wollman /* t1 = t2 - t3 8397b6ab19dSGarrett Wollman */ 8407b6ab19dSGarrett Wollman static void 8417b6ab19dSGarrett Wollman timevalsub(struct timeval *t1, 8427b6ab19dSGarrett Wollman struct timeval *t2, 8437b6ab19dSGarrett Wollman struct timeval *t3) 8447b6ab19dSGarrett Wollman { 8457b6ab19dSGarrett Wollman t1->tv_sec = t2->tv_sec - t3->tv_sec; 8467b6ab19dSGarrett Wollman if ((t1->tv_usec = t2->tv_usec - t3->tv_usec) < 0) { 8477b6ab19dSGarrett Wollman t1->tv_sec--; 8487b6ab19dSGarrett Wollman t1->tv_usec += 1000000; 8497b6ab19dSGarrett Wollman } 8507b6ab19dSGarrett Wollman } 8517b6ab19dSGarrett Wollman 8527b6ab19dSGarrett Wollman 8531608c04fSGarrett Wollman /* put a message into the system log 8541608c04fSGarrett Wollman */ 8557b6ab19dSGarrett Wollman void 8562c7a9781SMark Murray msglog(const char *p, ...) 8577b6ab19dSGarrett Wollman { 8587b6ab19dSGarrett Wollman va_list args; 8597b6ab19dSGarrett Wollman 8607b6ab19dSGarrett Wollman trace_flush(); 8617b6ab19dSGarrett Wollman 8627b6ab19dSGarrett Wollman va_start(args, p); 8637b6ab19dSGarrett Wollman vsyslog(LOG_ERR, p, args); 864a4fff644STom Rhodes va_end(args); 8657b6ab19dSGarrett Wollman if (ftrace != 0) { 8667b6ab19dSGarrett Wollman if (ftrace == stdout) 8677b6ab19dSGarrett Wollman (void)fputs("routed: ", ftrace); 868a4fff644STom Rhodes va_start(args, p); 8697b6ab19dSGarrett Wollman (void)vfprintf(ftrace, p, args); 870a4fff644STom Rhodes va_end(args); 8717b6ab19dSGarrett Wollman (void)fputc('\n', ftrace); 8727b6ab19dSGarrett Wollman } 8737b6ab19dSGarrett Wollman } 8747b6ab19dSGarrett Wollman 8757b6ab19dSGarrett Wollman 876a30febecSGarrett Wollman /* Put a message about a bad system into the system log if 8771608c04fSGarrett Wollman * we have not complained about it recently. 878a30febecSGarrett Wollman * 879a30febecSGarrett Wollman * It is desirable to complain about all bad systems, but not too often. 880a30febecSGarrett Wollman * In the worst case, it is not practical to keep track of all bad systems. 881a30febecSGarrett Wollman * For example, there can be many systems with the wrong password. 8821608c04fSGarrett Wollman */ 8831608c04fSGarrett Wollman void 8842c7a9781SMark Murray msglim(struct msg_limit *lim, naddr addr, const char *p, ...) 8851608c04fSGarrett Wollman { 8861608c04fSGarrett Wollman va_list args; 887a30febecSGarrett Wollman int i; 888a30febecSGarrett Wollman struct msg_sub *ms1, *ms; 8892c7a9781SMark Murray const char *p1; 8901608c04fSGarrett Wollman 891a30febecSGarrett Wollman /* look for the oldest slot in the table 892a30febecSGarrett Wollman * or the slot for the bad router. 893a30febecSGarrett Wollman */ 894a30febecSGarrett Wollman ms = ms1 = lim->subs; 895a30febecSGarrett Wollman for (i = MSG_SUBJECT_N; ; i--, ms1++) { 896a30febecSGarrett Wollman if (i == 0) { 897a30febecSGarrett Wollman /* Reuse a slot at most once every 10 minutes. 898a30febecSGarrett Wollman */ 899a30febecSGarrett Wollman if (lim->reuse > now.tv_sec) { 900a30febecSGarrett Wollman ms = 0; 901a30febecSGarrett Wollman } else { 902a30febecSGarrett Wollman ms = ms1; 903a30febecSGarrett Wollman lim->reuse = now.tv_sec + 10*60; 904a30febecSGarrett Wollman } 905a30febecSGarrett Wollman break; 906a30febecSGarrett Wollman } 907a30febecSGarrett Wollman if (ms->addr == addr) { 908a30febecSGarrett Wollman /* Repeat a complaint about a given system at 909a30febecSGarrett Wollman * most once an hour. 910a30febecSGarrett Wollman */ 911a30febecSGarrett Wollman if (ms->until > now.tv_sec) 912a30febecSGarrett Wollman ms = 0; 913a30febecSGarrett Wollman break; 914a30febecSGarrett Wollman } 915a30febecSGarrett Wollman if (ms->until < ms1->until) 916a30febecSGarrett Wollman ms = ms1; 917a30febecSGarrett Wollman } 918a30febecSGarrett Wollman if (ms != 0) { 919a30febecSGarrett Wollman ms->addr = addr; 920a30febecSGarrett Wollman ms->until = now.tv_sec + 60*60; /* 60 minutes */ 9211608c04fSGarrett Wollman 9221608c04fSGarrett Wollman trace_flush(); 9231608c04fSGarrett Wollman for (p1 = p; *p1 == ' '; p1++) 9241608c04fSGarrett Wollman continue; 925a4fff644STom Rhodes va_start(args, p); 9261608c04fSGarrett Wollman vsyslog(LOG_ERR, p1, args); 927a4fff644STom Rhodes va_end(args); 9281608c04fSGarrett Wollman } 9291608c04fSGarrett Wollman 930a30febecSGarrett Wollman /* always display the message if tracing */ 9311608c04fSGarrett Wollman if (ftrace != 0) { 932a4fff644STom Rhodes va_start(args, p); 9331608c04fSGarrett Wollman (void)vfprintf(ftrace, p, args); 934a4fff644STom Rhodes va_end(args); 9351608c04fSGarrett Wollman (void)fputc('\n', ftrace); 9361608c04fSGarrett Wollman } 9371608c04fSGarrett Wollman } 9381608c04fSGarrett Wollman 9391608c04fSGarrett Wollman 9407b6ab19dSGarrett Wollman void 9412c7a9781SMark Murray logbad(int dump, const char *p, ...) 9427b6ab19dSGarrett Wollman { 9437b6ab19dSGarrett Wollman va_list args; 9447b6ab19dSGarrett Wollman 9457b6ab19dSGarrett Wollman trace_flush(); 9467b6ab19dSGarrett Wollman 9477b6ab19dSGarrett Wollman va_start(args, p); 9487b6ab19dSGarrett Wollman vsyslog(LOG_ERR, p, args); 949a4fff644STom Rhodes va_end(args); 9507b6ab19dSGarrett Wollman (void)fputs("routed: ", stderr); 951a4fff644STom Rhodes va_start(args, p); 9527b6ab19dSGarrett Wollman (void)vfprintf(stderr, p, args); 953a4fff644STom Rhodes va_end(args); 9547b6ab19dSGarrett Wollman (void)fputs("; giving up\n",stderr); 9557b6ab19dSGarrett Wollman (void)fflush(stderr); 9567b6ab19dSGarrett Wollman 9577b6ab19dSGarrett Wollman if (dump) 9587b6ab19dSGarrett Wollman abort(); 9597b6ab19dSGarrett Wollman exit(1); 9607b6ab19dSGarrett Wollman } 961