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 * 3. All advertising materials mentioning features or use of this software 147b6ab19dSGarrett Wollman * must display the following acknowledgement: 157b6ab19dSGarrett Wollman * This product includes software developed by the University of 167b6ab19dSGarrett Wollman * California, Berkeley and its contributors. 177b6ab19dSGarrett Wollman * 4. Neither the name of the University nor the names of its contributors 187b6ab19dSGarrett Wollman * may be used to endorse or promote products derived from this software 197b6ab19dSGarrett Wollman * without specific prior written permission. 207b6ab19dSGarrett Wollman * 217b6ab19dSGarrett Wollman * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 227b6ab19dSGarrett Wollman * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 237b6ab19dSGarrett Wollman * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 247b6ab19dSGarrett Wollman * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 257b6ab19dSGarrett Wollman * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 267b6ab19dSGarrett Wollman * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 277b6ab19dSGarrett Wollman * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 287b6ab19dSGarrett Wollman * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 297b6ab19dSGarrett Wollman * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 307b6ab19dSGarrett Wollman * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 317b6ab19dSGarrett Wollman * SUCH DAMAGE. 327b6ab19dSGarrett Wollman */ 337b6ab19dSGarrett Wollman 347b6ab19dSGarrett Wollman char copyright[] = 357b6ab19dSGarrett Wollman "@(#) Copyright (c) 1983, 1988, 1993\n\ 367b6ab19dSGarrett Wollman The Regents of the University of California. All rights reserved.\n"; 377b6ab19dSGarrett Wollman #if !defined(lint) && !defined(sgi) && !defined(__NetBSD__) 387b6ab19dSGarrett Wollman static char sccsid[] = "@(#)main.c 8.1 (Berkeley) 6/5/93"; 397b6ab19dSGarrett Wollman #elif defined(__NetBSD__) 407b6ab19dSGarrett Wollman static char rcsid[] = "$NetBSD$"; 417b6ab19dSGarrett Wollman #endif 421608c04fSGarrett Wollman #ident "$Revision: 1.18 $" 437b6ab19dSGarrett Wollman 447b6ab19dSGarrett Wollman #include "defs.h" 457b6ab19dSGarrett Wollman #include "pathnames.h" 467b6ab19dSGarrett Wollman #ifdef sgi 477b6ab19dSGarrett Wollman #include "math.h" 487b6ab19dSGarrett Wollman #endif 497b6ab19dSGarrett Wollman #include <signal.h> 507b6ab19dSGarrett Wollman #include <fcntl.h> 517b6ab19dSGarrett Wollman #include <sys/file.h> 527b6ab19dSGarrett Wollman 537b6ab19dSGarrett Wollman pid_t mypid; 547b6ab19dSGarrett Wollman 557b6ab19dSGarrett Wollman naddr myaddr; /* system address */ 567b6ab19dSGarrett Wollman char myname[MAXHOSTNAMELEN+1]; 577b6ab19dSGarrett Wollman 587b6ab19dSGarrett Wollman int supplier; /* supply or broadcast updates */ 597b6ab19dSGarrett Wollman int supplier_set; 607b6ab19dSGarrett Wollman int ipforwarding = 1; /* kernel forwarding on */ 617b6ab19dSGarrett Wollman 627b6ab19dSGarrett Wollman int default_gateway; /* 1=advertise default */ 637b6ab19dSGarrett Wollman int background = 1; 647b6ab19dSGarrett Wollman int ridhosts; /* 1=reduce host routes */ 657b6ab19dSGarrett Wollman int mhome; /* 1=want multi-homed host route */ 667b6ab19dSGarrett Wollman int advertise_mhome; /* 1=must continue adverising it */ 677b6ab19dSGarrett Wollman int auth_ok = 1; /* 1=ignore auth if we do not care */ 687b6ab19dSGarrett Wollman 697b6ab19dSGarrett Wollman struct timeval epoch; /* when started */ 707b6ab19dSGarrett Wollman struct timeval clk, prev_clk; 717b6ab19dSGarrett Wollman struct timeval now; /* current idea of time */ 727b6ab19dSGarrett Wollman time_t now_stale; 737b6ab19dSGarrett Wollman time_t now_expire; 747b6ab19dSGarrett Wollman time_t now_garbage; 757b6ab19dSGarrett Wollman 767b6ab19dSGarrett Wollman struct timeval next_bcast; /* next general broadcast */ 777b6ab19dSGarrett Wollman struct timeval no_flash = {EPOCH+SUPPLY_INTERVAL}; /* inhibit flash update */ 787b6ab19dSGarrett Wollman 797b6ab19dSGarrett Wollman fd_set fdbits; 807b6ab19dSGarrett Wollman int sock_max; 817b6ab19dSGarrett Wollman int rip_sock = -1; /* RIP socket */ 827b6ab19dSGarrett Wollman struct interface *rip_sock_mcast; /* current multicast interface */ 837b6ab19dSGarrett Wollman int rt_sock; /* routing socket */ 847b6ab19dSGarrett Wollman int rt_sock_seqno; 857b6ab19dSGarrett Wollman 867b6ab19dSGarrett Wollman 877b6ab19dSGarrett Wollman static int get_rip_sock(naddr, int); 887b6ab19dSGarrett Wollman static void timevalsub(struct timeval *, struct timeval *, struct timeval *); 897b6ab19dSGarrett Wollman 907b6ab19dSGarrett Wollman int 917b6ab19dSGarrett Wollman main(int argc, 927b6ab19dSGarrett Wollman char *argv[]) 937b6ab19dSGarrett Wollman { 947b6ab19dSGarrett Wollman int n, mib[4], off; 957b6ab19dSGarrett Wollman size_t len; 967b6ab19dSGarrett Wollman char *p, *q; 977b6ab19dSGarrett Wollman struct timeval wtime, t2; 987b6ab19dSGarrett Wollman time_t dt; 997b6ab19dSGarrett Wollman fd_set ibits; 1001608c04fSGarrett Wollman naddr p_net, p_mask; 1017b6ab19dSGarrett Wollman struct interface *ifp; 1027b6ab19dSGarrett Wollman struct parm parm; 1037b6ab19dSGarrett Wollman char *tracename = 0; 1047b6ab19dSGarrett Wollman 1057b6ab19dSGarrett Wollman 1061608c04fSGarrett Wollman /* Some shells are badly broken and send SIGHUP to backgrounded 1071608c04fSGarrett Wollman * processes. 1081608c04fSGarrett Wollman */ 1091608c04fSGarrett Wollman signal(SIGHUP, SIG_IGN); 1101608c04fSGarrett Wollman 1117b6ab19dSGarrett Wollman openlog("routed", LOG_PID | LOG_ODELAY, LOG_DAEMON); 1127b6ab19dSGarrett Wollman ftrace = stdout; 1137b6ab19dSGarrett Wollman 1147b6ab19dSGarrett Wollman gettimeofday(&clk, 0); 1157b6ab19dSGarrett Wollman prev_clk = clk; 1167b6ab19dSGarrett Wollman epoch = clk; 1177b6ab19dSGarrett Wollman epoch.tv_sec -= EPOCH; 1187b6ab19dSGarrett Wollman now.tv_sec = EPOCH; 1197b6ab19dSGarrett Wollman now_stale = EPOCH - STALE_TIME; 1207b6ab19dSGarrett Wollman now_expire = EPOCH - EXPIRE_TIME; 1217b6ab19dSGarrett Wollman now_garbage = EPOCH - GARBAGE_TIME; 1227b6ab19dSGarrett Wollman wtime.tv_sec = 0; 1237b6ab19dSGarrett Wollman 1247b6ab19dSGarrett Wollman (void)gethostname(myname, sizeof(myname)-1); 1257b6ab19dSGarrett Wollman (void)gethost(myname, &myaddr); 1267b6ab19dSGarrett Wollman 1271608c04fSGarrett Wollman while ((n = getopt(argc, argv, "sqdghmpAtT:F:P:")) != EOF) { 1287b6ab19dSGarrett Wollman switch (n) { 1297b6ab19dSGarrett Wollman case 's': 1307b6ab19dSGarrett Wollman supplier = 1; 1317b6ab19dSGarrett Wollman supplier_set = 1; 1327b6ab19dSGarrett Wollman break; 1337b6ab19dSGarrett Wollman 1347b6ab19dSGarrett Wollman case 'q': 1357b6ab19dSGarrett Wollman supplier = 0; 1367b6ab19dSGarrett Wollman supplier_set = 1; 1377b6ab19dSGarrett Wollman break; 1387b6ab19dSGarrett Wollman 1397b6ab19dSGarrett Wollman case 'd': 1407b6ab19dSGarrett Wollman background = 0; 1417b6ab19dSGarrett Wollman break; 1427b6ab19dSGarrett Wollman 1437b6ab19dSGarrett Wollman case 'g': 1447b6ab19dSGarrett Wollman bzero(&parm, sizeof(parm)); 1457b6ab19dSGarrett Wollman parm.parm_d_metric = 1; 1467b6ab19dSGarrett Wollman p = check_parms(&parm); 1477b6ab19dSGarrett Wollman if (p != 0) 1487b6ab19dSGarrett Wollman msglog("bad -g: %s", p); 1497b6ab19dSGarrett Wollman else 1507b6ab19dSGarrett Wollman default_gateway = 1; 1517b6ab19dSGarrett Wollman break; 1527b6ab19dSGarrett Wollman 1537b6ab19dSGarrett Wollman case 'h': /* suppress extra host routes */ 1547b6ab19dSGarrett Wollman ridhosts = 1; 1557b6ab19dSGarrett Wollman break; 1567b6ab19dSGarrett Wollman 1577b6ab19dSGarrett Wollman case 'm': /* advertise host route */ 1587b6ab19dSGarrett Wollman mhome = 1; /* on multi-homed hosts */ 1597b6ab19dSGarrett Wollman break; 1607b6ab19dSGarrett Wollman 1617b6ab19dSGarrett Wollman case 'A': 1627b6ab19dSGarrett Wollman /* Ignore authentication if we do not care. 1637b6ab19dSGarrett Wollman * Crazy as it is, that is what RFC 1723 requires. 1647b6ab19dSGarrett Wollman */ 1657b6ab19dSGarrett Wollman auth_ok = 0; 1667b6ab19dSGarrett Wollman break; 1677b6ab19dSGarrett Wollman 1687b6ab19dSGarrett Wollman case 't': 1697b6ab19dSGarrett Wollman new_tracelevel++; 1707b6ab19dSGarrett Wollman break; 1717b6ab19dSGarrett Wollman 1727b6ab19dSGarrett Wollman case 'T': 1737b6ab19dSGarrett Wollman tracename = optarg; 1747b6ab19dSGarrett Wollman break; 1757b6ab19dSGarrett Wollman 1767b6ab19dSGarrett Wollman case 'F': /* minimal routes for SLIP */ 1771608c04fSGarrett Wollman n = FAKE_METRIC; 1787b6ab19dSGarrett Wollman p = strchr(optarg,','); 1797b6ab19dSGarrett Wollman if (p && *p != '\0') { 1807b6ab19dSGarrett Wollman n = (int)strtoul(p+1, &q, 0); 1817b6ab19dSGarrett Wollman if (*q == '\0' 1827b6ab19dSGarrett Wollman && n <= HOPCNT_INFINITY-1 1837b6ab19dSGarrett Wollman && n >= 1) 1847b6ab19dSGarrett Wollman *p = '\0'; 1857b6ab19dSGarrett Wollman } 1861608c04fSGarrett Wollman if (!getnet(optarg, &p_net, &p_mask)) { 1877b6ab19dSGarrett Wollman msglog("bad network; \"-F %s\"", 1887b6ab19dSGarrett Wollman optarg); 1897b6ab19dSGarrett Wollman break; 1907b6ab19dSGarrett Wollman } 1917b6ab19dSGarrett Wollman bzero(&parm, sizeof(parm)); 1921608c04fSGarrett Wollman parm.parm_net = p_net; 1937b6ab19dSGarrett Wollman parm.parm_mask = p_mask; 1947b6ab19dSGarrett Wollman parm.parm_d_metric = n; 1957b6ab19dSGarrett Wollman p = check_parms(&parm); 1967b6ab19dSGarrett Wollman if (p != 0) 1977b6ab19dSGarrett Wollman msglog("bad -F: %s", p); 1987b6ab19dSGarrett Wollman break; 1997b6ab19dSGarrett Wollman 2007b6ab19dSGarrett Wollman case 'P': 2017b6ab19dSGarrett Wollman /* handle arbirary, (usually) per-interface 2027b6ab19dSGarrett Wollman * parameters. 2037b6ab19dSGarrett Wollman */ 2047b6ab19dSGarrett Wollman p = parse_parms(optarg); 2057b6ab19dSGarrett Wollman if (p != 0) 2067b6ab19dSGarrett Wollman msglog("bad \"%s\" in \"%s\"", 2077b6ab19dSGarrett Wollman p, optarg); 2087b6ab19dSGarrett Wollman break; 2097b6ab19dSGarrett Wollman 2107b6ab19dSGarrett Wollman default: 2117b6ab19dSGarrett Wollman goto usage; 2127b6ab19dSGarrett Wollman } 2137b6ab19dSGarrett Wollman } 2147b6ab19dSGarrett Wollman argc -= optind; 2157b6ab19dSGarrett Wollman argv += optind; 2167b6ab19dSGarrett Wollman 2177b6ab19dSGarrett Wollman if (tracename == 0 && argc >= 1) { 2187b6ab19dSGarrett Wollman tracename = *argv++; 2197b6ab19dSGarrett Wollman argc--; 2207b6ab19dSGarrett Wollman } 2217b6ab19dSGarrett Wollman if (argc != 0) { 2227b6ab19dSGarrett Wollman usage: 2237b6ab19dSGarrett Wollman logbad(0, "usage: routed [-sqdghmpAt] [-T /tracefile]" 2247b6ab19dSGarrett Wollman " [-F net[,metric]] [-P parms]"); 2257b6ab19dSGarrett Wollman } 2267b6ab19dSGarrett Wollman if (geteuid() != 0) 2277b6ab19dSGarrett Wollman logbad(0, "requires UID 0"); 2287b6ab19dSGarrett Wollman 2297b6ab19dSGarrett Wollman mib[0] = CTL_NET; 2307b6ab19dSGarrett Wollman mib[1] = PF_INET; 2317b6ab19dSGarrett Wollman mib[2] = IPPROTO_IP; 2327b6ab19dSGarrett Wollman mib[3] = IPCTL_FORWARDING; 2337b6ab19dSGarrett Wollman len = sizeof(ipforwarding); 2347b6ab19dSGarrett Wollman if (sysctl(mib, 4, &ipforwarding, &len, 0, 0) < 0) 2357b6ab19dSGarrett Wollman LOGERR("sysctl(IPCTL_FORWARDING)"); 2367b6ab19dSGarrett Wollman 2377b6ab19dSGarrett Wollman if (!ipforwarding) { 2387b6ab19dSGarrett Wollman if (supplier) 2397b6ab19dSGarrett Wollman msglog("-s incompatible with ipforwarding=0"); 2407b6ab19dSGarrett Wollman if (default_gateway) { 2417b6ab19dSGarrett Wollman msglog("-g incompatible with ipforwarding=0"); 2427b6ab19dSGarrett Wollman default_gateway = 0; 2437b6ab19dSGarrett Wollman } 2447b6ab19dSGarrett Wollman supplier = 0; 2457b6ab19dSGarrett Wollman supplier_set = 1; 2467b6ab19dSGarrett Wollman } 2477b6ab19dSGarrett Wollman if (default_gateway) { 2487b6ab19dSGarrett Wollman if (supplier_set && !supplier) { 2497b6ab19dSGarrett Wollman msglog("-g and -q incompatible"); 2507b6ab19dSGarrett Wollman } else { 2517b6ab19dSGarrett Wollman supplier = 1; 2527b6ab19dSGarrett Wollman supplier_set = 1; 2537b6ab19dSGarrett Wollman } 2547b6ab19dSGarrett Wollman } 2557b6ab19dSGarrett Wollman 2567b6ab19dSGarrett Wollman 2577b6ab19dSGarrett Wollman signal(SIGALRM, sigalrm); 2587b6ab19dSGarrett Wollman if (!background) 2597b6ab19dSGarrett Wollman signal(SIGHUP, sigterm); /* SIGHUP fatal during debugging */ 2607b6ab19dSGarrett Wollman signal(SIGTERM, sigterm); 2617b6ab19dSGarrett Wollman signal(SIGINT, sigterm); 2627b6ab19dSGarrett Wollman signal(SIGUSR1, sigtrace_on); 2637b6ab19dSGarrett Wollman signal(SIGUSR2, sigtrace_off); 2647b6ab19dSGarrett Wollman 2657b6ab19dSGarrett Wollman /* get into the background */ 2667b6ab19dSGarrett Wollman if (background) { 2677b6ab19dSGarrett Wollman #ifdef sgi 2687b6ab19dSGarrett Wollman if (0 > _daemonize(_DF_NOCHDIR, 2697b6ab19dSGarrett Wollman new_tracelevel == 0 ? -1 : STDOUT_FILENO, 2707b6ab19dSGarrett Wollman new_tracelevel == 0 ? -1 : STDERR_FILENO, 2717b6ab19dSGarrett Wollman -1)) 2727b6ab19dSGarrett Wollman BADERR(0, "_daemonize()"); 2737b6ab19dSGarrett Wollman #else 2747b6ab19dSGarrett Wollman if (daemon(1, 1) < 0) 2757b6ab19dSGarrett Wollman BADERR(0,"daemon()"); 2767b6ab19dSGarrett Wollman #endif 2777b6ab19dSGarrett Wollman } 2787b6ab19dSGarrett Wollman 2797b6ab19dSGarrett Wollman mypid = getpid(); 2807b6ab19dSGarrett Wollman srandom((int)(clk.tv_sec ^ clk.tv_usec ^ mypid)); 2817b6ab19dSGarrett Wollman 2827b6ab19dSGarrett Wollman /* prepare socket connected to the kernel. 2837b6ab19dSGarrett Wollman */ 2847b6ab19dSGarrett Wollman rt_sock = socket(AF_ROUTE, SOCK_RAW, 0); 2857b6ab19dSGarrett Wollman if (rt_sock < 0) 2867b6ab19dSGarrett Wollman BADERR(1,"rt_sock = socket()"); 2877b6ab19dSGarrett Wollman if (fcntl(rt_sock, F_SETFL, O_NONBLOCK) == -1) 2887b6ab19dSGarrett Wollman logbad(1, "fcntl(rt_sock) O_NONBLOCK: %s", strerror(errno)); 2897b6ab19dSGarrett Wollman off = 0; 2907b6ab19dSGarrett Wollman if (setsockopt(rt_sock, SOL_SOCKET,SO_USELOOPBACK, 2917b6ab19dSGarrett Wollman &off,sizeof(off)) < 0) 2927b6ab19dSGarrett Wollman LOGERR("setsockopt(SO_USELOOPBACK,0)"); 2937b6ab19dSGarrett Wollman 2947b6ab19dSGarrett Wollman fix_select(); 2957b6ab19dSGarrett Wollman 2967b6ab19dSGarrett Wollman 2977b6ab19dSGarrett Wollman if (background && new_tracelevel == 0) 2987b6ab19dSGarrett Wollman ftrace = 0; 2997b6ab19dSGarrett Wollman if (tracename != 0) { 3007b6ab19dSGarrett Wollman trace_on(tracename, 1); 3017b6ab19dSGarrett Wollman if (new_tracelevel == 0) /* use stdout if file is bad */ 3027b6ab19dSGarrett Wollman new_tracelevel = 1; 3037b6ab19dSGarrett Wollman } 3041608c04fSGarrett Wollman set_tracelevel(1); 3051608c04fSGarrett Wollman 3061608c04fSGarrett Wollman bufinit(); 3077b6ab19dSGarrett Wollman 3087b6ab19dSGarrett Wollman /* initialize radix tree */ 3097b6ab19dSGarrett Wollman rtinit(); 3107b6ab19dSGarrett Wollman 3117b6ab19dSGarrett Wollman /* Pick a random part of the second for our output to minimize 3127b6ab19dSGarrett Wollman * collisions. 3137b6ab19dSGarrett Wollman * 3147b6ab19dSGarrett Wollman * Start broadcasting after hearing from other routers, and 3157b6ab19dSGarrett Wollman * at a random time so a bunch of systems do not get synchronized 3167b6ab19dSGarrett Wollman * after a power failure. 3177b6ab19dSGarrett Wollman */ 3187b6ab19dSGarrett Wollman intvl_random(&next_bcast, EPOCH+MIN_WAITTIME, EPOCH+SUPPLY_INTERVAL); 3197b6ab19dSGarrett Wollman age_timer.tv_usec = next_bcast.tv_usec; 3207b6ab19dSGarrett Wollman age_timer.tv_sec = EPOCH+MIN_WAITTIME; 3217b6ab19dSGarrett Wollman rdisc_timer = next_bcast; 3227b6ab19dSGarrett Wollman ifinit_timer.tv_usec = next_bcast.tv_usec; 3237b6ab19dSGarrett Wollman 3247b6ab19dSGarrett Wollman /* Collect an initial view of the world by checking the interface 3257b6ab19dSGarrett Wollman * configuration and the kludge file. 3267b6ab19dSGarrett Wollman */ 3277b6ab19dSGarrett Wollman gwkludge(); 3287b6ab19dSGarrett Wollman ifinit(); 3297b6ab19dSGarrett Wollman flush_kern(); 3307b6ab19dSGarrett Wollman 3317b6ab19dSGarrett Wollman /* Ask for routes */ 3327b6ab19dSGarrett Wollman rip_query(); 3337b6ab19dSGarrett Wollman rdisc_sol(); 3347b6ab19dSGarrett Wollman 3357b6ab19dSGarrett Wollman /* Loop forever, listening and broadcasting. 3367b6ab19dSGarrett Wollman */ 3377b6ab19dSGarrett Wollman for (;;) { 3387b6ab19dSGarrett Wollman prev_clk = clk; 3397b6ab19dSGarrett Wollman gettimeofday(&clk, 0); 3407b6ab19dSGarrett Wollman timevalsub(&t2, &clk, &prev_clk); 3417b6ab19dSGarrett Wollman if (t2.tv_sec < 0 3427b6ab19dSGarrett Wollman || t2.tv_sec > wtime.tv_sec + 5) { 3437b6ab19dSGarrett Wollman /* Deal with time changes before other housekeeping to 3447b6ab19dSGarrett Wollman * keep everything straight. 3457b6ab19dSGarrett Wollman */ 3467b6ab19dSGarrett Wollman dt = t2.tv_sec; 3477b6ab19dSGarrett Wollman if (dt > 0) 3487b6ab19dSGarrett Wollman dt -= wtime.tv_sec; 3491608c04fSGarrett Wollman trace_act("time changed by %d sec", dt); 3507b6ab19dSGarrett Wollman epoch.tv_sec += dt; 3517b6ab19dSGarrett Wollman } 3527b6ab19dSGarrett Wollman timevalsub(&now, &clk, &epoch); 3537b6ab19dSGarrett Wollman now_stale = now.tv_sec - STALE_TIME; 3547b6ab19dSGarrett Wollman now_expire = now.tv_sec - EXPIRE_TIME; 3557b6ab19dSGarrett Wollman now_garbage = now.tv_sec - GARBAGE_TIME; 3567b6ab19dSGarrett Wollman 3577b6ab19dSGarrett Wollman /* deal with interrupts that should affect tracing */ 3581608c04fSGarrett Wollman set_tracelevel(0); 3597b6ab19dSGarrett Wollman 3607b6ab19dSGarrett Wollman if (stopint != 0) { 3617b6ab19dSGarrett Wollman rip_bcast(0); 3627b6ab19dSGarrett Wollman rdisc_adv(); 3637b6ab19dSGarrett Wollman trace_off("exiting with signal %d\n", stopint); 3647b6ab19dSGarrett Wollman exit(stopint | 128); 3657b6ab19dSGarrett Wollman } 3667b6ab19dSGarrett Wollman 3677b6ab19dSGarrett Wollman /* look for new or dead interfaces */ 3687b6ab19dSGarrett Wollman timevalsub(&wtime, &ifinit_timer, &now); 3697b6ab19dSGarrett Wollman if (wtime.tv_sec <= 0) { 3707b6ab19dSGarrett Wollman wtime.tv_sec = 0; 3717b6ab19dSGarrett Wollman ifinit(); 3727b6ab19dSGarrett Wollman rip_query(); 3737b6ab19dSGarrett Wollman continue; 3747b6ab19dSGarrett Wollman } 3757b6ab19dSGarrett Wollman 3767b6ab19dSGarrett Wollman /* If it is time, then broadcast our routes. 3777b6ab19dSGarrett Wollman */ 3787b6ab19dSGarrett Wollman if (supplier || advertise_mhome) { 3797b6ab19dSGarrett Wollman timevalsub(&t2, &next_bcast, &now); 3807b6ab19dSGarrett Wollman if (t2.tv_sec <= 0) { 3817b6ab19dSGarrett Wollman /* Synchronize the aging and broadcast 3827b6ab19dSGarrett Wollman * timers to minimize awakenings 3837b6ab19dSGarrett Wollman */ 3847b6ab19dSGarrett Wollman age(0); 3857b6ab19dSGarrett Wollman 3867b6ab19dSGarrett Wollman rip_bcast(0); 3877b6ab19dSGarrett Wollman 3887b6ab19dSGarrett Wollman /* It is desirable to send routing updates 3897b6ab19dSGarrett Wollman * regularly. So schedule the next update 3907b6ab19dSGarrett Wollman * 30 seconds after the previous one was 3917b6ab19dSGarrett Wollman * secheduled, instead of 30 seconds after 3927b6ab19dSGarrett Wollman * the previous update was finished. 3937b6ab19dSGarrett Wollman * Even if we just started after discovering 3947b6ab19dSGarrett Wollman * a 2nd interface or were otherwise delayed, 3957b6ab19dSGarrett Wollman * pick a 30-second aniversary of the 3967b6ab19dSGarrett Wollman * original broadcast time. 3977b6ab19dSGarrett Wollman */ 3987b6ab19dSGarrett Wollman n = 1 + (0-t2.tv_sec)/SUPPLY_INTERVAL; 3997b6ab19dSGarrett Wollman next_bcast.tv_sec += n*SUPPLY_INTERVAL; 4007b6ab19dSGarrett Wollman 4017b6ab19dSGarrett Wollman continue; 4027b6ab19dSGarrett Wollman } 4037b6ab19dSGarrett Wollman 4047b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4057b6ab19dSGarrett Wollman wtime = t2; 4067b6ab19dSGarrett Wollman } 4077b6ab19dSGarrett Wollman 4087b6ab19dSGarrett Wollman /* If we need a flash update, either do it now or 4097b6ab19dSGarrett Wollman * set the delay to end when it is time. 4107b6ab19dSGarrett Wollman * 4117b6ab19dSGarrett Wollman * If we are within MIN_WAITTIME seconds of a full update, 4127b6ab19dSGarrett Wollman * do not bother. 4137b6ab19dSGarrett Wollman */ 4147b6ab19dSGarrett Wollman if (need_flash 4157b6ab19dSGarrett Wollman && supplier 4167b6ab19dSGarrett Wollman && no_flash.tv_sec+MIN_WAITTIME < next_bcast.tv_sec) { 4177b6ab19dSGarrett Wollman /* accurate to the millisecond */ 4187b6ab19dSGarrett Wollman if (!timercmp(&no_flash, &now, >)) 4197b6ab19dSGarrett Wollman rip_bcast(1); 4207b6ab19dSGarrett Wollman timevalsub(&t2, &no_flash, &now); 4217b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4227b6ab19dSGarrett Wollman wtime = t2; 4237b6ab19dSGarrett Wollman } 4247b6ab19dSGarrett Wollman 4257b6ab19dSGarrett Wollman /* trigger the main aging timer. 4267b6ab19dSGarrett Wollman */ 4277b6ab19dSGarrett Wollman timevalsub(&t2, &age_timer, &now); 4287b6ab19dSGarrett Wollman if (t2.tv_sec <= 0) { 4297b6ab19dSGarrett Wollman age(0); 4307b6ab19dSGarrett Wollman continue; 4317b6ab19dSGarrett Wollman } 4327b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4337b6ab19dSGarrett Wollman wtime = t2; 4347b6ab19dSGarrett Wollman 4357b6ab19dSGarrett Wollman /* update the kernel routing table 4367b6ab19dSGarrett Wollman */ 4377b6ab19dSGarrett Wollman timevalsub(&t2, &need_kern, &now); 4387b6ab19dSGarrett Wollman if (t2.tv_sec <= 0) { 4397b6ab19dSGarrett Wollman age(0); 4407b6ab19dSGarrett Wollman continue; 4417b6ab19dSGarrett Wollman } 4427b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4437b6ab19dSGarrett Wollman wtime = t2; 4447b6ab19dSGarrett Wollman 4457b6ab19dSGarrett Wollman /* take care of router discovery, 4467b6ab19dSGarrett Wollman * but do it to the millisecond 4477b6ab19dSGarrett Wollman */ 4487b6ab19dSGarrett Wollman if (!timercmp(&rdisc_timer, &now, >)) { 4497b6ab19dSGarrett Wollman rdisc_age(0); 4507b6ab19dSGarrett Wollman continue; 4517b6ab19dSGarrett Wollman } 4527b6ab19dSGarrett Wollman timevalsub(&t2, &rdisc_timer, &now); 4537b6ab19dSGarrett Wollman if (timercmp(&t2, &wtime, <)) 4547b6ab19dSGarrett Wollman wtime = t2; 4557b6ab19dSGarrett Wollman 4567b6ab19dSGarrett Wollman 4577b6ab19dSGarrett Wollman /* wait for input or a timer to expire. 4587b6ab19dSGarrett Wollman */ 4597b6ab19dSGarrett Wollman trace_flush(); 4607b6ab19dSGarrett Wollman ibits = fdbits; 4617b6ab19dSGarrett Wollman n = select(sock_max, &ibits, 0, 0, &wtime); 4627b6ab19dSGarrett Wollman if (n <= 0) { 4637b6ab19dSGarrett Wollman if (n < 0 && errno != EINTR && errno != EAGAIN) 4647b6ab19dSGarrett Wollman BADERR(1,"select"); 4657b6ab19dSGarrett Wollman continue; 4667b6ab19dSGarrett Wollman } 4677b6ab19dSGarrett Wollman 4687b6ab19dSGarrett Wollman if (FD_ISSET(rt_sock, &ibits)) { 4697b6ab19dSGarrett Wollman read_rt(); 4707b6ab19dSGarrett Wollman n--; 4717b6ab19dSGarrett Wollman } 4727b6ab19dSGarrett Wollman if (rdisc_sock >= 0 && FD_ISSET(rdisc_sock, &ibits)) { 4737b6ab19dSGarrett Wollman read_d(); 4747b6ab19dSGarrett Wollman n--; 4757b6ab19dSGarrett Wollman } 4767b6ab19dSGarrett Wollman if (rip_sock >= 0 && FD_ISSET(rip_sock, &ibits)) { 4777b6ab19dSGarrett Wollman read_rip(rip_sock, 0); 4787b6ab19dSGarrett Wollman n--; 4797b6ab19dSGarrett Wollman } 4807b6ab19dSGarrett Wollman 4817b6ab19dSGarrett Wollman for (ifp = ifnet; n > 0 && 0 != ifp; ifp = ifp->int_next) { 4827b6ab19dSGarrett Wollman if (ifp->int_rip_sock >= 0 4837b6ab19dSGarrett Wollman && FD_ISSET(ifp->int_rip_sock, &ibits)) { 4847b6ab19dSGarrett Wollman read_rip(ifp->int_rip_sock, ifp); 4857b6ab19dSGarrett Wollman n--; 4867b6ab19dSGarrett Wollman } 4877b6ab19dSGarrett Wollman } 4887b6ab19dSGarrett Wollman } 4897b6ab19dSGarrett Wollman } 4907b6ab19dSGarrett Wollman 4917b6ab19dSGarrett Wollman 4927b6ab19dSGarrett Wollman /* ARGSUSED */ 4937b6ab19dSGarrett Wollman void 4947b6ab19dSGarrett Wollman sigalrm(int sig) 4957b6ab19dSGarrett Wollman { 4967b6ab19dSGarrett Wollman /* Historically, SIGALRM would cause the daemon to check for 4977b6ab19dSGarrett Wollman * new and broken interfaces. 4987b6ab19dSGarrett Wollman */ 4997b6ab19dSGarrett Wollman ifinit_timer.tv_sec = now.tv_sec; 5001608c04fSGarrett Wollman trace_act("SIGALRM"); 5017b6ab19dSGarrett Wollman } 5027b6ab19dSGarrett Wollman 5037b6ab19dSGarrett Wollman 5047b6ab19dSGarrett Wollman /* watch for fatal signals */ 5057b6ab19dSGarrett Wollman void 5067b6ab19dSGarrett Wollman sigterm(int sig) 5077b6ab19dSGarrett Wollman { 5087b6ab19dSGarrett Wollman stopint = sig; 5097b6ab19dSGarrett Wollman (void)signal(sig, SIG_DFL); /* catch it only once */ 5107b6ab19dSGarrett Wollman } 5117b6ab19dSGarrett Wollman 5127b6ab19dSGarrett Wollman 5137b6ab19dSGarrett Wollman void 5147b6ab19dSGarrett Wollman fix_select(void) 5157b6ab19dSGarrett Wollman { 5167b6ab19dSGarrett Wollman struct interface *ifp; 5177b6ab19dSGarrett Wollman 5187b6ab19dSGarrett Wollman 5197b6ab19dSGarrett Wollman FD_ZERO(&fdbits); 5207b6ab19dSGarrett Wollman sock_max = 0; 5217b6ab19dSGarrett Wollman 5227b6ab19dSGarrett Wollman FD_SET(rt_sock, &fdbits); 5237b6ab19dSGarrett Wollman if (sock_max <= rt_sock) 5247b6ab19dSGarrett Wollman sock_max = rt_sock+1; 5257b6ab19dSGarrett Wollman if (rip_sock >= 0) { 5267b6ab19dSGarrett Wollman FD_SET(rip_sock, &fdbits); 5277b6ab19dSGarrett Wollman if (sock_max <= rip_sock) 5287b6ab19dSGarrett Wollman sock_max = rip_sock+1; 5297b6ab19dSGarrett Wollman } 5307b6ab19dSGarrett Wollman for (ifp = ifnet; 0 != ifp; ifp = ifp->int_next) { 5317b6ab19dSGarrett Wollman if (ifp->int_rip_sock >= 0) { 5327b6ab19dSGarrett Wollman FD_SET(ifp->int_rip_sock, &fdbits); 5337b6ab19dSGarrett Wollman if (sock_max <= ifp->int_rip_sock) 5347b6ab19dSGarrett Wollman sock_max = ifp->int_rip_sock+1; 5357b6ab19dSGarrett Wollman } 5367b6ab19dSGarrett Wollman } 5377b6ab19dSGarrett Wollman if (rdisc_sock >= 0) { 5387b6ab19dSGarrett Wollman FD_SET(rdisc_sock, &fdbits); 5397b6ab19dSGarrett Wollman if (sock_max <= rdisc_sock) 5407b6ab19dSGarrett Wollman sock_max = rdisc_sock+1; 5417b6ab19dSGarrett Wollman } 5427b6ab19dSGarrett Wollman } 5437b6ab19dSGarrett Wollman 5447b6ab19dSGarrett Wollman 5457b6ab19dSGarrett Wollman void 5467b6ab19dSGarrett Wollman fix_sock(int sock, 5477b6ab19dSGarrett Wollman char *name) 5487b6ab19dSGarrett Wollman { 5497b6ab19dSGarrett Wollman int on; 5507b6ab19dSGarrett Wollman #define MIN_SOCKBUF (4*1024) 5517b6ab19dSGarrett Wollman static int rbuf; 5527b6ab19dSGarrett Wollman 5537b6ab19dSGarrett Wollman if (fcntl(sock, F_SETFL, O_NONBLOCK) == -1) 5547b6ab19dSGarrett Wollman logbad(1, "fcntl(%s) O_NONBLOCK: %s", 5557b6ab19dSGarrett Wollman name, strerror(errno)); 5567b6ab19dSGarrett Wollman on = 1; 5571608c04fSGarrett Wollman if (setsockopt(sock, SOL_SOCKET,SO_BROADCAST, &on,sizeof(on)) < 0) 5587b6ab19dSGarrett Wollman msglog("setsockopt(%s,SO_BROADCAST): %s", 5597b6ab19dSGarrett Wollman name, strerror(errno)); 5601608c04fSGarrett Wollman #ifdef USE_PASSIFNAME 5611608c04fSGarrett Wollman on = 1; 5621608c04fSGarrett Wollman if (setsockopt(sock, SOL_SOCKET, SO_PASSIFNAME, &on,sizeof(on)) < 0) 5631608c04fSGarrett Wollman msglog("setsockopt(%s,SO_PASSIFNAME): %s", 5641608c04fSGarrett Wollman name, strerror(errno)); 5651608c04fSGarrett Wollman #endif 5661608c04fSGarrett Wollman 5677b6ab19dSGarrett Wollman if (rbuf >= MIN_SOCKBUF) { 5687b6ab19dSGarrett Wollman if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, 5697b6ab19dSGarrett Wollman &rbuf, sizeof(rbuf)) < 0) 5707b6ab19dSGarrett Wollman msglog("setsockopt(%s,SO_RCVBUF=%d): %s", 5717b6ab19dSGarrett Wollman name, rbuf, strerror(errno)); 5727b6ab19dSGarrett Wollman } else { 5737b6ab19dSGarrett Wollman for (rbuf = 60*1024; ; rbuf -= 4096) { 5747b6ab19dSGarrett Wollman if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, 5757b6ab19dSGarrett Wollman &rbuf, sizeof(rbuf)) == 0) { 5761608c04fSGarrett Wollman trace_act("RCVBUF=%d", rbuf); 5777b6ab19dSGarrett Wollman break; 5787b6ab19dSGarrett Wollman } 5797b6ab19dSGarrett Wollman if (rbuf < MIN_SOCKBUF) { 5807b6ab19dSGarrett Wollman msglog("setsockopt(%s,SO_RCVBUF = %d): %s", 5817b6ab19dSGarrett Wollman name, rbuf, strerror(errno)); 5827b6ab19dSGarrett Wollman break; 5837b6ab19dSGarrett Wollman } 5847b6ab19dSGarrett Wollman } 5857b6ab19dSGarrett Wollman } 5867b6ab19dSGarrett Wollman } 5877b6ab19dSGarrett Wollman 5887b6ab19dSGarrett Wollman 5897b6ab19dSGarrett Wollman /* get a rip socket 5907b6ab19dSGarrett Wollman */ 5917b6ab19dSGarrett Wollman static int /* <0 or file descriptor */ 5927b6ab19dSGarrett Wollman get_rip_sock(naddr addr, 5937b6ab19dSGarrett Wollman int serious) /* 1=failure to bind is serious */ 5947b6ab19dSGarrett Wollman { 5957b6ab19dSGarrett Wollman struct sockaddr_in sin; 5967b6ab19dSGarrett Wollman unsigned char ttl; 5977b6ab19dSGarrett Wollman int s; 5987b6ab19dSGarrett Wollman 5997b6ab19dSGarrett Wollman 6007b6ab19dSGarrett Wollman if ((s = socket(AF_INET, SOCK_DGRAM, 0)) < 0) 6017b6ab19dSGarrett Wollman BADERR(1,"rip_sock = socket()"); 6027b6ab19dSGarrett Wollman 6037b6ab19dSGarrett Wollman bzero(&sin,sizeof(sin)); 6047b6ab19dSGarrett Wollman #ifdef _HAVE_SIN_LEN 6057b6ab19dSGarrett Wollman sin.sin_len = sizeof(sin); 6067b6ab19dSGarrett Wollman #endif 6077b6ab19dSGarrett Wollman sin.sin_family = AF_INET; 6087b6ab19dSGarrett Wollman sin.sin_port = htons(RIP_PORT); 6097b6ab19dSGarrett Wollman sin.sin_addr.s_addr = addr; 6107b6ab19dSGarrett Wollman if (bind(s, (struct sockaddr *)&sin,sizeof(sin)) < 0) { 6117b6ab19dSGarrett Wollman if (serious) 6127b6ab19dSGarrett Wollman BADERR(errno != EADDRINUSE, "bind(rip_sock)"); 6137b6ab19dSGarrett Wollman return -1; 6147b6ab19dSGarrett Wollman } 6157b6ab19dSGarrett Wollman fix_sock(s,"rip_sock"); 6167b6ab19dSGarrett Wollman 6177b6ab19dSGarrett Wollman ttl = 1; 6187b6ab19dSGarrett Wollman if (setsockopt(s, IPPROTO_IP, IP_MULTICAST_TTL, 6197b6ab19dSGarrett Wollman &ttl, sizeof(ttl)) < 0) 6207b6ab19dSGarrett Wollman DBGERR(1,"rip_sock setsockopt(IP_MULTICAST_TTL)"); 6217b6ab19dSGarrett Wollman 6227b6ab19dSGarrett Wollman return s; 6237b6ab19dSGarrett Wollman } 6247b6ab19dSGarrett Wollman 6257b6ab19dSGarrett Wollman 6267b6ab19dSGarrett Wollman /* turn off main RIP socket */ 6277b6ab19dSGarrett Wollman void 6287b6ab19dSGarrett Wollman rip_off(void) 6297b6ab19dSGarrett Wollman { 6307b6ab19dSGarrett Wollman struct interface *ifp; 6317b6ab19dSGarrett Wollman register naddr addr; 6327b6ab19dSGarrett Wollman 6337b6ab19dSGarrett Wollman 6347b6ab19dSGarrett Wollman if (rip_sock >= 0 && !mhome) { 6351608c04fSGarrett Wollman trace_act("turn off RIP"); 6367b6ab19dSGarrett Wollman 6377b6ab19dSGarrett Wollman (void)close(rip_sock); 6387b6ab19dSGarrett Wollman rip_sock = -1; 6397b6ab19dSGarrett Wollman 6407b6ab19dSGarrett Wollman /* get non-broadcast sockets to listen to queries. 6417b6ab19dSGarrett Wollman */ 6427b6ab19dSGarrett Wollman for (ifp = ifnet; ifp != 0; ifp = ifp->int_next) { 6431608c04fSGarrett Wollman if (ifp->int_state & IS_REMOTE) 6441608c04fSGarrett Wollman continue; 6451608c04fSGarrett Wollman if (ifp->int_rip_sock < 0) { 6467b6ab19dSGarrett Wollman addr = ((ifp->int_if_flags & IFF_POINTOPOINT) 6477b6ab19dSGarrett Wollman ? ifp->int_dstaddr 6487b6ab19dSGarrett Wollman : ifp->int_addr); 6497b6ab19dSGarrett Wollman ifp->int_rip_sock = get_rip_sock(addr, 0); 6507b6ab19dSGarrett Wollman } 6517b6ab19dSGarrett Wollman } 6527b6ab19dSGarrett Wollman 6537b6ab19dSGarrett Wollman fix_select(); 6547b6ab19dSGarrett Wollman 6557b6ab19dSGarrett Wollman age(0); 6567b6ab19dSGarrett Wollman } 6577b6ab19dSGarrett Wollman } 6587b6ab19dSGarrett Wollman 6597b6ab19dSGarrett Wollman 6607b6ab19dSGarrett Wollman /* turn on RIP multicast input via an interface 6617b6ab19dSGarrett Wollman */ 6627b6ab19dSGarrett Wollman static void 6637b6ab19dSGarrett Wollman rip_mcast_on(struct interface *ifp) 6647b6ab19dSGarrett Wollman { 6657b6ab19dSGarrett Wollman struct ip_mreq m; 6667b6ab19dSGarrett Wollman 6677b6ab19dSGarrett Wollman if (!IS_RIP_IN_OFF(ifp->int_state) 6687b6ab19dSGarrett Wollman && (ifp->int_if_flags & IFF_MULTICAST) 6697b6ab19dSGarrett Wollman #ifdef MCAST_PPP_BUG 6707b6ab19dSGarrett Wollman && !(ifp->int_if_flags & IFF_POINTOPOINT) 6717b6ab19dSGarrett Wollman #endif 6727b6ab19dSGarrett Wollman && !(ifp->int_state & IS_ALIAS)) { 6737b6ab19dSGarrett Wollman m.imr_multiaddr.s_addr = htonl(INADDR_RIP_GROUP); 6747b6ab19dSGarrett Wollman m.imr_interface.s_addr = ((ifp->int_if_flags & IFF_POINTOPOINT) 6757b6ab19dSGarrett Wollman ? ifp->int_dstaddr 6767b6ab19dSGarrett Wollman : ifp->int_addr); 6777b6ab19dSGarrett Wollman if (setsockopt(rip_sock,IPPROTO_IP, IP_ADD_MEMBERSHIP, 6787b6ab19dSGarrett Wollman &m, sizeof(m)) < 0) 6797b6ab19dSGarrett Wollman LOGERR("setsockopt(IP_ADD_MEMBERSHIP RIP)"); 6807b6ab19dSGarrett Wollman } 6817b6ab19dSGarrett Wollman } 6827b6ab19dSGarrett Wollman 6837b6ab19dSGarrett Wollman 6847b6ab19dSGarrett Wollman /* Prepare socket used for RIP. 6857b6ab19dSGarrett Wollman */ 6867b6ab19dSGarrett Wollman void 6877b6ab19dSGarrett Wollman rip_on(struct interface *ifp) 6887b6ab19dSGarrett Wollman { 6897b6ab19dSGarrett Wollman /* If the main RIP socket is already alive, only start receiving 6907b6ab19dSGarrett Wollman * multicasts for this interface. 6917b6ab19dSGarrett Wollman */ 6927b6ab19dSGarrett Wollman if (rip_sock >= 0) { 6937b6ab19dSGarrett Wollman if (ifp != 0) 6947b6ab19dSGarrett Wollman rip_mcast_on(ifp); 6957b6ab19dSGarrett Wollman return; 6967b6ab19dSGarrett Wollman } 6977b6ab19dSGarrett Wollman 6981608c04fSGarrett Wollman /* If the main RIP socket is off and it makes sense to turn it on, 6991608c04fSGarrett Wollman * then turn it on for all of the interfaces. 7007b6ab19dSGarrett Wollman */ 7017b6ab19dSGarrett Wollman if (rip_interfaces > 0 && !rdisc_ok) { 7021608c04fSGarrett Wollman trace_act("turn on RIP"); 7037b6ab19dSGarrett Wollman 7047b6ab19dSGarrett Wollman /* Close all of the query sockets so that we can open 7057b6ab19dSGarrett Wollman * the main socket. SO_REUSEPORT is not a solution, 7067b6ab19dSGarrett Wollman * since that would let two daemons bind to the broadcast 7077b6ab19dSGarrett Wollman * socket. 7087b6ab19dSGarrett Wollman */ 7097b6ab19dSGarrett Wollman for (ifp = ifnet; ifp != 0; ifp = ifp->int_next) { 7107b6ab19dSGarrett Wollman if (ifp->int_rip_sock >= 0) { 7117b6ab19dSGarrett Wollman (void)close(ifp->int_rip_sock); 7127b6ab19dSGarrett Wollman ifp->int_rip_sock = -1; 7137b6ab19dSGarrett Wollman } 7147b6ab19dSGarrett Wollman } 7157b6ab19dSGarrett Wollman 7167b6ab19dSGarrett Wollman rip_sock = get_rip_sock(INADDR_ANY, 1); 7177b6ab19dSGarrett Wollman rip_sock_mcast = 0; 7187b6ab19dSGarrett Wollman 7197b6ab19dSGarrett Wollman /* Do not advertise anything until we have heard something 7207b6ab19dSGarrett Wollman */ 7217b6ab19dSGarrett Wollman if (next_bcast.tv_sec < now.tv_sec+MIN_WAITTIME) 7227b6ab19dSGarrett Wollman next_bcast.tv_sec = now.tv_sec+MIN_WAITTIME; 7237b6ab19dSGarrett Wollman 7247b6ab19dSGarrett Wollman for (ifp = ifnet; ifp != 0; ifp = ifp->int_next) { 7251608c04fSGarrett Wollman ifp->int_query_time = NEVER; 7267b6ab19dSGarrett Wollman rip_mcast_on(ifp); 7277b6ab19dSGarrett Wollman } 7287b6ab19dSGarrett Wollman ifinit_timer.tv_sec = now.tv_sec; 7297b6ab19dSGarrett Wollman 7307b6ab19dSGarrett Wollman } else if (ifp != 0 7311608c04fSGarrett Wollman && !(ifp->int_state & IS_REMOTE) 7321608c04fSGarrett Wollman && ifp->int_rip_sock < 0) { 7337b6ab19dSGarrett Wollman /* RIP is off, so ensure there are sockets on which 7347b6ab19dSGarrett Wollman * to listen for queries. 7357b6ab19dSGarrett Wollman */ 7367b6ab19dSGarrett Wollman ifp->int_rip_sock = get_rip_sock(ifp->int_addr, 0); 7371608c04fSGarrett Wollman } 7387b6ab19dSGarrett Wollman 7397b6ab19dSGarrett Wollman fix_select(); 7407b6ab19dSGarrett Wollman } 7417b6ab19dSGarrett Wollman 7427b6ab19dSGarrett Wollman 7437b6ab19dSGarrett Wollman /* die if malloc(3) fails 7447b6ab19dSGarrett Wollman */ 7457b6ab19dSGarrett Wollman void * 7467b6ab19dSGarrett Wollman rtmalloc(size_t size, 7477b6ab19dSGarrett Wollman char *msg) 7487b6ab19dSGarrett Wollman { 7497b6ab19dSGarrett Wollman void *p = malloc(size); 7507b6ab19dSGarrett Wollman if (p == 0) 7517b6ab19dSGarrett Wollman logbad(1,"malloc() failed in %s", msg); 7527b6ab19dSGarrett Wollman return p; 7537b6ab19dSGarrett Wollman } 7547b6ab19dSGarrett Wollman 7557b6ab19dSGarrett Wollman 7567b6ab19dSGarrett Wollman /* get a random instant in an interval 7577b6ab19dSGarrett Wollman */ 7587b6ab19dSGarrett Wollman void 7597b6ab19dSGarrett Wollman intvl_random(struct timeval *tp, /* put value here */ 7607b6ab19dSGarrett Wollman u_long lo, /* value is after this second */ 7617b6ab19dSGarrett Wollman u_long hi) /* and before this */ 7627b6ab19dSGarrett Wollman { 7637b6ab19dSGarrett Wollman tp->tv_sec = (time_t)(hi == lo 7647b6ab19dSGarrett Wollman ? lo 7657b6ab19dSGarrett Wollman : (lo + random() % ((hi - lo)))); 7667b6ab19dSGarrett Wollman tp->tv_usec = random() % 1000000; 7677b6ab19dSGarrett Wollman } 7687b6ab19dSGarrett Wollman 7697b6ab19dSGarrett Wollman 7707b6ab19dSGarrett Wollman void 7717b6ab19dSGarrett Wollman timevaladd(struct timeval *t1, 7727b6ab19dSGarrett Wollman struct timeval *t2) 7737b6ab19dSGarrett Wollman { 7747b6ab19dSGarrett Wollman 7757b6ab19dSGarrett Wollman t1->tv_sec += t2->tv_sec; 7767b6ab19dSGarrett Wollman if ((t1->tv_usec += t2->tv_usec) > 1000000) { 7777b6ab19dSGarrett Wollman t1->tv_sec++; 7787b6ab19dSGarrett Wollman t1->tv_usec -= 1000000; 7797b6ab19dSGarrett Wollman } 7807b6ab19dSGarrett Wollman } 7817b6ab19dSGarrett Wollman 7827b6ab19dSGarrett Wollman 7837b6ab19dSGarrett Wollman /* t1 = t2 - t3 7847b6ab19dSGarrett Wollman */ 7857b6ab19dSGarrett Wollman static void 7867b6ab19dSGarrett Wollman timevalsub(struct timeval *t1, 7877b6ab19dSGarrett Wollman struct timeval *t2, 7887b6ab19dSGarrett Wollman struct timeval *t3) 7897b6ab19dSGarrett Wollman { 7907b6ab19dSGarrett Wollman t1->tv_sec = t2->tv_sec - t3->tv_sec; 7917b6ab19dSGarrett Wollman if ((t1->tv_usec = t2->tv_usec - t3->tv_usec) < 0) { 7927b6ab19dSGarrett Wollman t1->tv_sec--; 7937b6ab19dSGarrett Wollman t1->tv_usec += 1000000; 7947b6ab19dSGarrett Wollman } 7957b6ab19dSGarrett Wollman } 7967b6ab19dSGarrett Wollman 7977b6ab19dSGarrett Wollman 7981608c04fSGarrett Wollman /* put a message into the system log 7991608c04fSGarrett Wollman */ 8007b6ab19dSGarrett Wollman void 8017b6ab19dSGarrett Wollman msglog(char *p, ...) 8027b6ab19dSGarrett Wollman { 8037b6ab19dSGarrett Wollman va_list args; 8047b6ab19dSGarrett Wollman 8057b6ab19dSGarrett Wollman trace_flush(); 8067b6ab19dSGarrett Wollman 8077b6ab19dSGarrett Wollman va_start(args, p); 8087b6ab19dSGarrett Wollman vsyslog(LOG_ERR, p, args); 8097b6ab19dSGarrett Wollman 8107b6ab19dSGarrett Wollman if (ftrace != 0) { 8117b6ab19dSGarrett Wollman if (ftrace == stdout) 8127b6ab19dSGarrett Wollman (void)fputs("routed: ", ftrace); 8137b6ab19dSGarrett Wollman (void)vfprintf(ftrace, p, args); 8147b6ab19dSGarrett Wollman (void)fputc('\n', ftrace); 8157b6ab19dSGarrett Wollman } 8167b6ab19dSGarrett Wollman } 8177b6ab19dSGarrett Wollman 8187b6ab19dSGarrett Wollman 8191608c04fSGarrett Wollman /* Put a message about a bad router into the system log if 8201608c04fSGarrett Wollman * we have not complained about it recently. 8211608c04fSGarrett Wollman */ 8221608c04fSGarrett Wollman void 8231608c04fSGarrett Wollman msglim(struct msg_limit *lim, naddr addr, char *p, ...) 8241608c04fSGarrett Wollman { 8251608c04fSGarrett Wollman va_list args; 8261608c04fSGarrett Wollman char *p1; 8271608c04fSGarrett Wollman 8281608c04fSGarrett Wollman va_start(args, p); 8291608c04fSGarrett Wollman 8301608c04fSGarrett Wollman if ( lim->addr != addr || lim->until <= now.tv_sec) { 8311608c04fSGarrett Wollman lim->addr = addr; 8321608c04fSGarrett Wollman lim->until = now.tv_sec + 60*60; 8331608c04fSGarrett Wollman 8341608c04fSGarrett Wollman trace_flush(); 8351608c04fSGarrett Wollman for (p1 = p; *p1 == ' '; p1++) 8361608c04fSGarrett Wollman continue; 8371608c04fSGarrett Wollman vsyslog(LOG_ERR, p1, args); 8381608c04fSGarrett Wollman } 8391608c04fSGarrett Wollman 8401608c04fSGarrett Wollman if (ftrace != 0) { 8411608c04fSGarrett Wollman (void)vfprintf(ftrace, p, args); 8421608c04fSGarrett Wollman (void)fputc('\n', ftrace); 8431608c04fSGarrett Wollman } 8441608c04fSGarrett Wollman } 8451608c04fSGarrett Wollman 8461608c04fSGarrett Wollman 8477b6ab19dSGarrett Wollman void 8487b6ab19dSGarrett Wollman logbad(int dump, char *p, ...) 8497b6ab19dSGarrett Wollman { 8507b6ab19dSGarrett Wollman va_list args; 8517b6ab19dSGarrett Wollman 8527b6ab19dSGarrett Wollman trace_flush(); 8537b6ab19dSGarrett Wollman 8547b6ab19dSGarrett Wollman va_start(args, p); 8557b6ab19dSGarrett Wollman vsyslog(LOG_ERR, p, args); 8567b6ab19dSGarrett Wollman 8577b6ab19dSGarrett Wollman (void)fputs("routed: ", stderr); 8587b6ab19dSGarrett Wollman (void)vfprintf(stderr, p, args); 8597b6ab19dSGarrett Wollman (void)fputs("; giving up\n",stderr); 8607b6ab19dSGarrett Wollman (void)fflush(stderr); 8617b6ab19dSGarrett Wollman 8627b6ab19dSGarrett Wollman if (dump) 8637b6ab19dSGarrett Wollman abort(); 8647b6ab19dSGarrett Wollman exit(1); 8657b6ab19dSGarrett Wollman } 866