#ifndef lint
-static char sccsid[] = "@(#)routed.c 4.8 %G%";
+static char sccsid[] = "@(#)routed.c 4.14 82/06/09";
#endif
/*
#include <stdio.h>
#include <nlist.h>
#include <signal.h>
+#include <time.h>
#include "rip.h"
#include "router.h"
struct sockaddr_in myaddr = { AF_INET, IPPORT_ROUTESERVER };
int s;
+int snoroute; /* socket with no routing */
int kmem = -1;
-int supplier; /* process should supply updates */
-int initializing; /* stem off broadcast() calls */
-int install = 0; /* if 1 call kernel */
-int lookforinterfaces = 1;
-int performnlist = 1;
-int timeval;
+int supplier = -1; /* process should supply updates */
+int install = 1; /* if 1 call kernel */
+int timeval = -TIMER_RATE;
int timer();
int cleanup();
+
+#define tprintf if (trace) printf
int trace = 0;
+FILE *ftrace;
-char packet[MAXPACKETSIZE];
+char packet[MAXPACKETSIZE+1];
+struct rip *msg = (struct rip *)packet;
struct in_addr if_makeaddr();
struct ifnet *if_ifwithaddr(), *if_ifwithnet();
extern char *malloc();
extern int errno, exit();
+char **argv0;
+
+int sndmsg(), supply();
main(argc, argv)
int argc;
int cc;
struct sockaddr from;
- { int t = open("/dev/tty", 2);
- if (t >= 0) {
- ioctl(t, TIOCNOTTY, 0);
- close(t);
- }
+ argv0 = argv;
+#ifndef DEBUG
+ if (fork())
+ exit(0);
+ for (cc = 0; cc < 10; cc++)
+ (void) close(cc);
+ (void) open("/", 0);
+ (void) dup2(0, 1);
+ (void) dup2(0, 2);
+ { int t = open("/dev/tty", 2);
+ if (t >= 0) {
+ ioctl(t, TIOCNOTTY, (char *)0);
+ (void) close(t);
+ }
}
+#endif
if (trace) {
- (void) freopen("/etc/routerlog", "a", stdout);
- (void) dup2(fileno(stdout), 2);
- setbuf(stdout, NULL);
+ ftrace = fopen("/etc/routerlog", "w");
+ dup2(fileno(ftrace), 1);
+ dup2(fileno(ftrace), 2);
}
#ifdef vax || pdp11
myaddr.sin_port = htons(myaddr.sin_port);
sleep(30);
goto again;
}
- rtinit();
- getothers();
- initializing = 1;
- getinterfaces();
- initializing = 0;
- request();
-
+again2:
+ snoroute = socket(SOCK_DGRAM, 0, 0, SO_DONTROUTE);
+ if (snoroute < 0) {
+ perror("socket");
+ sleep(30);
+ goto again2;
+ }
argv++, argc--;
- while (argc > 0) {
- if (strcmp(*argv, "-s") == 0)
+ while (argc > 0 && **argv == '-') {
+ if (!strcmp(*argv, "-s") == 0) {
supplier = 1;
- else if (strcmp(*argv, "-q") == 0)
+ argv++, argc--;
+ continue;
+ }
+ if (!strcmp(*argv, "-q") == 0) {
supplier = 0;
- argv++, argc--;
+ argv++, argc--;
+ continue;
+ }
+ goto usage;
+ }
+ if (argc > 0) {
+usage:
+ fprintf(stderr, "usage: routed [ -s ]\n");
+ exit(1);
}
+ rtinit();
+ ifinit();
+ if (supplier < 0)
+ supplier = 0;
+ gwkludge();
+ msg->rip_cmd = RIPCMD_REQUEST;
+ msg->rip_nets[0].rip_dst.sa_family = AF_UNSPEC;
+ msg->rip_nets[0].rip_metric = HOPCNT_INFINITY;
+ toall(sendmsg);
sigset(SIGALRM, timer);
timer();
- /*
- * Listen for routing packets
- */
for (;;) {
cc = receive(s, &from, packet, sizeof (packet));
if (cc <= 0) {
}
}
-/*
- * Look in a file for any gateways we should configure
- * outside the directly connected ones. This is a kludge,
- * but until we can find out about gateways on the "other side"
- * of the ARPANET using GGP, it's a must.
- *
- * We don't really know the distance to the gateway, so we
- * assume it's a neighbor.
- */
-getothers()
+rtinit()
+{
+ register struct rthash *rh;
+
+ for (rh = nethash; rh < &nethash[ROUTEHASHSIZ]; rh++)
+ rh->rt_forw = rh->rt_back = (struct rt_entry *)rh;
+ for (rh = hosthash; rh < &hosthash[ROUTEHASHSIZ]; rh++)
+ rh->rt_forw = rh->rt_back = (struct rt_entry *)rh;
+}
+
+struct ifnet *ifnet;
+
+ifinit()
+{
+ struct ifnet *ifp, *next;
+ register struct sockaddr *dst;
+ int uniquemultihostinterfaces = 0;
+
+ nlist("/vmunix", nl);
+ if (nl[N_IFNET].n_value == 0) {
+ printf("ifnet: not in namelist\n");
+ goto bad;
+ }
+ kmem = open("/dev/kmem", 0);
+ if (kmem < 0) {
+ perror("/dev/kmem");
+ goto bad;
+ }
+ if (lseek(kmem, (long)nl[N_IFNET].n_value, 0) == -1 ||
+ read(kmem, (char *)&next, sizeof (next)) != sizeof (next)) {
+ printf("ifnet: error reading kmem\n");
+ goto bad;
+ }
+ while (next) {
+ ifp = (struct ifnet *)malloc(sizeof (struct ifnet));
+ if (ifp == 0) {
+ printf("routed: out of memory\n");
+ break;
+ }
+ if (lseek(kmem, (long)next, 0) == -1 ||
+ read(kmem, (char *)ifp, sizeof (*ifp)) != sizeof (*ifp)) {
+ perror("read");
+ goto bad;
+ }
+ next = ifp->if_next;
+ if (ifp->if_addr.sa_family != AF_INET)
+ continue;
+ if (ifp->if_net == LOOPBACKNET)
+ continue;
+ if ((ifp->if_flags & IFF_POINTOPOINT) == 0 ||
+ if_ifwithaddr(&ifp->if_dstaddr) == 0)
+ uniquemultihostinterfaces++;
+ ifp->if_next = ifnet;
+ ifnet = ifp;
+ addrouteforif(ifp);
+ }
+ if (uniquemultihostinterfaces > 1 && supplier < 0)
+ supplier = 1;
+ return;
+bad:
+ sleep(60);
+ execv("/etc/routed", argv0);
+ _exit(0177);
+}
+
+addrouteforif(ifp)
+ struct ifnet *ifp;
+{
+ struct sockaddr_in net;
+ struct sockaddr *dst;
+
+ if (ifp->if_flags & IFF_POINTOPOINT)
+ dst = &ifp->if_dstaddr;
+ else {
+ bzero((char *)&net, sizeof (net));
+ net.sin_family = AF_INET;
+ net.sin_addr = if_makeaddr(ifp->if_net, INADDR_ANY);
+ dst = (struct sockaddr *)&net;
+ }
+ rtadd(dst, &ifp->if_addr, 0, RTS_INTERFACE);
+}
+
+gwkludge()
{
struct sockaddr_in dst, gate;
- FILE *fp = fopen("/etc/gateways", "r");
+ FILE *fp;
struct rt_entry *rt;
+ char flags[BUFSIZ];
+ fp = fopen("/etc/gateways", "r");
if (fp == NULL)
return;
bzero((char *)&dst, sizeof (dst));
bzero((char *)&gate, sizeof (gate));
dst.sin_family = AF_INET;
gate.sin_family = AF_INET;
- while (fscanf(fp, "%x %x", &dst.sin_addr.s_addr,
- &gate.sin_addr.s_addr) != EOF) {
- rtadd((struct sockaddr *)&dst, (struct sockaddr *)&gate, 1);
- rt = rtlookup((struct sockaddr *)&dst);
- if (rt)
- rt->rt_state |= RTS_SILENT;
+ for (;;) {
+ if (fscanf(fp, "dst %x gateway %x\n", &dst.sin_addr.s_addr,
+ &gate.sin_addr.s_addr, flags) == EOF)
+ break;
+ rtadd((struct sockaddr *)&dst, (struct sockaddr *)&gate, 1,
+ RTS_GLOBAL|(!strcmp(flags, "passive") ? RTS_PASSIVE : 0));
}
fclose(fp);
}
-/*
- * Timer routine:
- *
- * o handle timers on table entries,
- * o invalidate entries which haven't been updated in a while,
- * o delete entries which are too old,
- * o retry ioctl's which weren't successful the first
- * time due to the kernel entry being busy
- * o if we're an internetwork router, supply routing updates
- * periodically
- */
timer()
{
register struct rthash *rh;
register struct rt_entry *rt;
struct rthash *base = hosthash;
- int doinghost = 1;
+ int doinghost = 1, state;
- if (trace)
- printf(">>> time %d >>>\n", timeval);
+ timeval += TIMER_RATE;
+ tprintf(">>> time %d >>>\n", timeval);
again:
for (rh = base; rh < &base[ROUTEHASHSIZ]; rh++) {
rt = rh->rt_forw;
for (; rt != (struct rt_entry *)rh; rt = rt->rt_forw) {
-
- /*
- * If the host is indicated to be
- * "silent" (i.e. it's one we got
- * from the initialization file),
- * don't time out it's entry.
- */
- if ((rt->rt_state & RTS_SILENT) == 0)
+ if (!(rt->rt_state & RTS_GLOBAL))
rt->rt_timer += TIMER_RATE;
log("", rt);
-
- /*
- * If the entry should be deleted
- * attempt to do so and reclaim space.
- */
- if (rt->rt_timer >= GARBAGE_TIME ||
- (rt->rt_state & RTS_DELRT)) {
+ if (rt->rt_timer >= EXPIRE_TIME)
+ rt->rt_metric = HOPCNT_INFINITY;
+ if ((rt->rt_state & RTS_DELRT) ||
+ rt->rt_timer >= GARBAGE_TIME) {
+ if (rt->rt_state&(RTS_INTERFACE|RTS_GLOBAL)) {
+ if (rt->rt_timer > 9999)
+ rt->rt_timer = 9999;
+ continue;
+ }
rt = rt->rt_back;
rtdelete(rt->rt_forw);
continue;
}
-
- /*
- * If we haven't heard from the router
- * in a long time indicate the route is
- * hard to reach.
- */
- if (rt->rt_timer >= EXPIRE_TIME)
- rt->rt_metric = HOPCNT_INFINITY;
- if (rt->rt_state & RTS_CHGRT)
- if (!ioctl(s, SIOCCHGRT,(char *)&rt->rt_rt) ||
- --rt->rt_retry == 0)
- rt->rt_state &= ~RTS_CHGRT;
-
- /*
- * Try to add the route to the kernel tables.
- * If this fails because the entry already exists
- * (perhaps because someone manually added it)
- * change the add to a change. If the operation
- * fails otherwise (likely because the entry is
- * in use), retry the operation a few more times.
- */
+ state = rt->rt_state;
if (rt->rt_state & RTS_ADDRT) {
- if (!ioctl(s, SIOCADDRT,(char *)&rt->rt_rt)) {
- if (errno == EEXIST) {
- rt->rt_state &= ~RTS_ADDRT;
- rt->rt_state |= RTS_CHGRT;
- rt->rt_retry =
- (EXPIRE_TIME/TIMER_RATE);
- continue;
- }
- if (--rt->rt_retry)
- continue;
- }
+ if (ioctl(s, SIOCADDRT,(char *)&rt->rt_rt) < 0)
+ perror("SIOCADDRT");
rt->rt_state &= ~RTS_ADDRT;
}
+ if (rt->rt_state & RTS_CHGRT) {
+ struct rtentry oldroute;
+
+ oldroute = rt->rt_rt;
+ rt->rt_router = rt->rt_newrouter;
+ if (ioctl(s, SIOCADDRT,(char *)&rt->rt_rt) < 0)
+ perror("SIOCADDRT");
+ if (ioctl(s, SIOCDELRT, (char *)&oldroute) < 0)
+ perror("SIOCDELRT");
+ rt->rt_state &= ~RTS_CHGRT;
+ }
+ if (supplier && (state & (RTS_CHGRT|RTS_ADDRT))) {
+ log("broadcast", rt);
+ msg->rip_cmd = RIPCMD_RESPONSE;
+ msg->rip_nets[0].rip_dst = rt->rt_dst;
+ msg->rip_nets[0].rip_metric =
+ min(rt->rt_metric+1, HOPCNT_INFINITY);
+ sendmsgtoall();
+ }
}
}
if (doinghost) {
base = nethash;
goto again;
}
- timeval += TIMER_RATE;
- if (lookforinterfaces && (timeval % CHECK_INTERVAL) == 0)
- getinterfaces();
if (supplier && (timeval % SUPPLY_INTERVAL) == 0)
- supplyall();
- if (trace)
- printf("<<< time %d <<<\n", timeval);
+ toall(supply);
+ tprintf("<<< time %d <<<\n", timeval);
alarm(TIMER_RATE);
}
-struct ifnet *ifnet;
-/*
- * Find the network interfaces attached to this machine.
- * The info is used to:
- *
- * (1) initialize the routing tables, as done by the kernel.
- * (2) ignore incoming packets we send.
- * (3) figure out broadcast capability and addresses.
- * (4) figure out if we're an internetwork gateway.
- *
- * We don't handle anything but Internet addresses.
- *
- * Note: this routine may be called periodically to
- * scan for new interfaces. In fact, the timer routine
- * does so based on the flag lookforinterfaces. The
- * flag performnlist is set whenever something odd occurs
- * while scanning the kernel; this is likely to occur
- * if /vmunix isn't up to date (e.g. someone booted /ovmunix).
- */
-getinterfaces()
-{
- struct ifnet *ifp;
- struct ifnet ifstruct, *next;
- struct sockaddr_in net;
- register struct sockaddr *dst;
- int nets;
-
- if (performnlist) {
- nlist("/vmunix", nl);
- if (nl[N_IFNET].n_value == 0) {
- performnlist++;
- printf("ifnet: not in namelist\n");
- return;
- }
- performnlist = 0;
- }
- if (kmem < 0) {
- kmem = open("/dev/kmem", 0);
- if (kmem < 0) {
- perror("/dev/kmem");
- return;
- }
- }
- if (lseek(kmem, (long)nl[N_IFNET].n_value, 0) == -1 ||
- read(kmem, (char *)&ifp, sizeof (ifp)) != sizeof (ifp)) {
- performnlist = 1;
- return;
- }
- bzero((char *)&net, sizeof (net));
- net.sin_family = AF_INET;
- lookforinterfaces = 0;
- nets = 0;
- while (ifp) {
- if (lseek(kmem, (long)ifp, 0) == -1 ||
- read(kmem, (char *)&ifstruct, sizeof (ifstruct)) !=
- sizeof (ifstruct)) {
- perror("read");
- lookforinterfaces = performnlist = 1;
- break;
- }
- ifp = &ifstruct;
- if ((ifp->if_flags & IFF_UP) == 0) {
- lookforinterfaces = 1;
- skip:
- ifp = ifp->if_next;
- continue;
- }
- if (ifp->if_addr.sa_family != AF_INET)
- goto skip;
- /* ignore software loopback networks. */
- if (ifp->if_net == LOOPBACKNET)
- goto skip;
- /* check if we already know about this one */
- if (if_ifwithaddr(&ifstruct.if_addr)) {
- nets++;
- goto skip;
- }
- ifp = (struct ifnet *)malloc(sizeof (struct ifnet));
- if (ifp == 0) {
- printf("routed: out of memory\n");
- break;
- }
- bcopy((char *)&ifstruct, (char *)ifp, sizeof (struct ifnet));
-
- /*
- * Count the # of directly connected networks
- * and point to point links which aren't looped
- * back to ourself. This is used below to
- * decide if we should be a routing "supplier".
- */
- if ((ifp->if_flags & IFF_POINTOPOINT) == 0 ||
- if_ifwithaddr(&ifp->if_dstaddr) == 0)
- nets++;
-
- if (ifp->if_flags & IFF_POINTOPOINT)
- dst = &ifp->if_dstaddr;
- else {
- net.sin_addr = if_makeaddr(ifp->if_net, INADDR_ANY);
- dst = (struct sockaddr *)&net;
- }
- next = ifp->if_next;
- ifp->if_next = ifnet;
- ifnet = ifp;
- if (rtlookup(dst) == 0)
- rtadd(dst, &ifp->if_addr, 0);
- ifp = next;
- }
- supplier = nets > 1;
-}
-
-/*
- * Send a request message to all directly
- * connected hosts and networks.
- */
-request()
-{
- register struct rip *msg = (struct rip *)packet;
-
- msg->rip_cmd = RIPCMD_REQUEST;
- msg->rip_nets[0].rip_dst.sa_family = AF_UNSPEC;
- msg->rip_nets[0].rip_metric = HOPCNT_INFINITY;
- sendall();
-}
-
-/*
- * Broadcast a new, or modified, routing table entry
- * to all directly connected hosts and networks.
- */
-broadcast(entry)
- struct rt_entry *entry;
-{
- struct rip *msg = (struct rip *)packet;
-
- log("broadcast", entry);
- msg->rip_cmd = RIPCMD_RESPONSE;
- msg->rip_nets[0].rip_dst = entry->rt_dst;
- msg->rip_nets[0].rip_metric = min(entry->rt_metric+1, HOPCNT_INFINITY);
- sendall();
-}
-
-/*
- * Send "packet" to all neighbors.
- */
-sendall()
+toall(f)
+ int (*f)();
{
register struct rthash *rh;
register struct rt_entry *rt;
again:
for (rh = base; rh < &base[ROUTEHASHSIZ]; rh++)
for (rt = rh->rt_forw; rt != (struct rt_entry *)rh; rt = rt->rt_forw) {
- if ((rt->rt_state & RTS_SILENT) || rt->rt_metric > 0)
+ if ((rt->rt_state&RTS_PASSIVE) || rt->rt_metric > 0)
continue;
if (rt->rt_ifp && (rt->rt_ifp->if_flags & IFF_BROADCAST))
dst = &rt->rt_ifp->if_broadaddr;
else
- dst = &rt->rt_gateway;
- (*afswitch[dst->sa_family].af_output)(dst, sizeof (struct rip));
+ dst = &rt->rt_router;
+ (*f)(rt, dst);
}
if (doinghost) {
base = nethash;
}
}
-/*
- * Supply all directly connected neighbors with the
- * current state of the routing tables.
- */
-supplyall()
-{
+sendmsg(rt, dst)
register struct rt_entry *rt;
- register struct rthash *rh;
- register struct sockaddr *dst;
- struct rthash *base = hosthash;
- int doinghost = 1;
+ struct sockaddr *dst;
+{
-again:
- for (rh = base; rh < &base[ROUTEHASHSIZ]; rh++)
- for (rt = rh->rt_forw; rt != (struct rt_entry *)rh; rt = rt->rt_forw) {
- if ((rt->rt_state & RTS_SILENT) || rt->rt_metric > 0)
- continue;
- if (rt->rt_ifp && (rt->rt_ifp->if_flags & IFF_BROADCAST))
- dst = &rt->rt_ifp->if_broadaddr;
- else
- dst = &rt->rt_gateway;
- log("supply", rt);
- supply(dst);
- }
- if (doinghost) {
- base = nethash;
- doinghost = 0;
- goto again;
- }
+ (*afswitch[dst->sa_family].af_output)(s, dst, sizeof (struct rip));
}
-/*
- * Supply routing information to target "sa".
- */
-supply(sa)
+supply(rt, sa)
+ register struct rt_entry *rt;
struct sockaddr *sa;
{
- struct rip *msg = (struct rip *)packet;
struct netinfo *n = msg->rip_nets;
register struct rthash *rh;
- register struct rt_entry *rt;
struct rthash *base = hosthash;
int doinghost = 1, size;
int (*output)() = afswitch[sa->sa_family].af_output;
+ int sto = (rt->rt_state&RTS_INTERFACE) ? snoroute : s;
+ log("supply", rt);
msg->rip_cmd = RIPCMD_RESPONSE;
again:
for (rh = base; rh < &base[ROUTEHASHSIZ]; rh++)
for (rt = rh->rt_forw; rt != (struct rt_entry *)rh; rt = rt->rt_forw) {
-
- /*
- * Flush packet out if not enough room for
- * another routing table entry.
- */
size = (char *)n - packet;
if (size > MAXPACKETSIZE - sizeof (struct netinfo)) {
- (*output)(sa, size);
+ (*output)(sto, sa, size);
n = msg->rip_nets;
}
n->rip_dst = rt->rt_dst;
goto again;
}
if (n != msg->rip_nets)
- (*output)(sa, (char *)n - packet);
+ (*output)(sto, sa, (char *)n - packet);
}
/*
struct sockaddr *from;
int size;
{
- register struct rip *msg = (struct rip *)packet;
struct netinfo *np = msg->rip_nets;
struct rt_entry *rt;
int newsize = 0;
size -= sizeof (struct netinfo);
if (np->rip_dst.sa_family == AF_UNSPEC &&
np->rip_metric == HOPCNT_INFINITY && size == 0) {
- supply(from);
+ supply(s, from);
return;
}
rt = rtlookup(&np->rip_dst);
if (newsize > 0) {
msg->rip_cmd = RIPCMD_RESPONSE;
newsize += sizeof (int);
- (*afswitch[from->sa_family].af_output)(from, newsize);
+ (*afswitch[from->sa_family].af_output)(s, from, newsize);
}
}
struct sockaddr *from;
int size;
{
- register struct rip *msg = (struct rip *)packet;
struct rt_entry *rt;
struct netinfo *n;
+ struct ifnet *ifp;
+ time_t t;
switch (msg->rip_cmd) {
rip_respond(from, size);
return;
- case RIPCMD_RESPONSE:
+ case RIPCMD_TRACEON:
+ if ((*afswitch[from->sa_family].af_portcheck)(from) == 0)
+ return;
+ if (trace)
+ return;
+ packet[size] = '\0';
+ ftrace = fopen(msg->rip_tracefile, "a");
+ if (ftrace == NULL)
+ return;
+ (void) dup2(fileno(ftrace), 1);
+ (void) dup2(fileno(ftrace), 2);
+ trace = 1;
+ t = time(0);
+ printf("*** Tracing turned on at %.24s ***\n", ctime(&t));
+ return;
+
+ case RIPCMD_TRACEOFF:
/* verify message came from a priviledged port */
- if ((*afswitch[from->sa_family].af_portmatch)(from) == 0)
+ if ((*afswitch[from->sa_family].af_portcheck)(from) == 0)
+ return;
+ if (!trace)
return;
- break;
- }
-
- /*
- * Process updates.
- * Extraneous information like Internet ports
- * must first be purged from the sender's address for
- * pattern matching below.
- */
- (*afswitch[from->sa_family].af_canon)(from);
- if (trace)
- printf("input from %x\n",
- ((struct sockaddr_in *)from)->sin_addr);
- /*
- * If response packet is from ourselves, use it only
- * to reset timer on entry. Otherwise, we'd believe
- * it as gospel (since it comes from the router) and
- * unknowingly update the metric to show the outgoing
- * cost (higher than our real cost). I guess the protocol
- * spec doesn't address this because Xerox Ethernets
- * don't hear their own broadcasts?
- */
- if (if_ifwithaddr(from)) {
- rt = rtlookup(from);
- if (rt)
- rt->rt_timer = 0;
+ t = time(0);
+ printf("*** Tracing turned off at %.24s ***\n", ctime(&t));
+ fflush(stdout), fflush(stderr);
+ if (ftrace)
+ fclose(ftrace);
+ (void) close(1), (void) close(2);
+ trace = 0;
return;
- }
- size -= 4 * sizeof (char);
- n = msg->rip_nets;
- for (; size > 0; size -= sizeof (struct netinfo), n++) {
- if (size < sizeof (struct netinfo))
- break;
- if (trace)
- printf("dst %x hc %d...",
- ((struct sockaddr_in *)&n->rip_dst)->sin_addr,
- n->rip_metric);
- rt = rtlookup(&n->rip_dst);
-
- /*
- * Unknown entry, add it to the tables only if
- * its interesting.
- */
- if (rt == 0) {
- if (n->rip_metric < HOPCNT_INFINITY)
- rtadd(&n->rip_dst, from, n->rip_metric);
- if (trace)
- printf("new\n");
- continue;
- }
- if (trace)
- printf("ours: gate %x hc %d timer %d\n",
- ((struct sockaddr_in *)&rt->rt_gateway)->sin_addr,
+ case RIPCMD_RESPONSE:
+ /* verify message came from a router */
+ if ((*afswitch[from->sa_family].af_portmatch)(from) == 0)
+ return;
+ (*afswitch[from->sa_family].af_canon)(from);
+ tprintf("input from %x\n",
+ ((struct sockaddr_in *)from)->sin_addr);
+ /* are we talking to ourselves? */
+ ifp = if_ifwithaddr(from);
+ if (ifp) {
+ rt = rtfind(from);
+ if (rt)
+ rt->rt_timer = 0;
+ else
+ addrouteforif(ifp);
+ return;
+ }
+ size -= 4 * sizeof (char);
+ n = msg->rip_nets;
+ for (; size > 0; size -= sizeof (struct netinfo), n++) {
+ if (size < sizeof (struct netinfo))
+ break;
+ if (n->rip_metric >= HOPCNT_INFINITY)
+ continue;
+ tprintf("dst %x hc %d...",
+ ((struct sockaddr_in *)&n->rip_dst)->sin_addr,
+ n->rip_metric);
+ rt = rtlookup(&n->rip_dst);
+ if (rt == 0) {
+ rtadd(&n->rip_dst, from, n->rip_metric, 0);
+ tprintf("new\n");
+ continue;
+ }
+ tprintf("ours: gate %x hc %d timer %d\n",
+ ((struct sockaddr_in *)&rt->rt_router)->sin_addr,
rt->rt_metric, rt->rt_timer);
- /*
- * Update the entry if one of the following is true:
- *
- * (1) The update came directly from the gateway.
- * (2) A shorter path is provided.
- * (3) The entry hasn't been updated in a while
- * and a path of equivalent cost is offered
- * (with the cost finite).
- */
- if (equal(from, &rt->rt_gateway) ||
- rt->rt_metric > n->rip_metric ||
- (rt->rt_timer > (EXPIRE_TIME/2) &&
- rt->rt_metric == n->rip_metric &&
- rt->rt_metric < HOPCNT_INFINITY)) {
- rtchange(rt, from, n->rip_metric);
- rt->rt_timer = 0;
+ /*
+ * update if from gateway, shorter, or getting stale
+ * and equivalent.
+ */
+ if (equal(from, &rt->rt_router) ||
+ n->rip_metric < rt->rt_metric ||
+ (rt->rt_timer > (EXPIRE_TIME/2) &&
+ rt->rt_metric == n->rip_metric)) {
+ rtchange(rt, from, n->rip_metric);
+ rt->rt_timer = 0;
+ }
}
+ return;
}
}
-rtinit()
+struct rt_entry *
+rtlookup(dst)
+ struct sockaddr *dst;
{
+ register struct rt_entry *rt;
register struct rthash *rh;
+ register int hash;
+ struct afhash h;
+ int doinghost = 1;
- for (rh = nethash; rh < &nethash[ROUTEHASHSIZ]; rh++)
- rh->rt_forw = rh->rt_back = (struct rt_entry *)rh;
- for (rh = hosthash; rh < &hosthash[ROUTEHASHSIZ]; rh++)
- rh->rt_forw = rh->rt_back = (struct rt_entry *)rh;
+ if (dst->sa_family >= AF_MAX)
+ return (0);
+ (*afswitch[dst->sa_family].af_hash)(dst, &h);
+ hash = h.afh_hosthash;
+ rh = &hosthash[hash % ROUTEHASHSIZ];
+again:
+ for (rt = rh->rt_forw; rt != (struct rt_entry *)rh; rt = rt->rt_forw) {
+ if (rt->rt_hash != hash)
+ continue;
+ if (equal(&rt->rt_dst, dst))
+ return (rt);
+ }
+ if (doinghost) {
+ doinghost = 0;
+ hash = h.afh_nethash;
+ rh = &nethash[hash % ROUTEHASHSIZ];
+ goto again;
+ }
+ return (0);
}
-/*
- * Lookup an entry to the appropriate dstination.
- */
struct rt_entry *
-rtlookup(dst)
+rtfind(dst)
struct sockaddr *dst;
{
register struct rt_entry *rt;
register struct rthash *rh;
- register int hash, (*match)();
+ register int hash;
struct afhash h;
- int af = dst->sa_family, doinghost = 1;
+ int af = dst->sa_family;
+ int doinghost = 1, (*match)();
if (af >= AF_MAX)
return (0);
if (doinghost) {
doinghost = 0;
hash = h.afh_nethash;
- match = afswitch[af].af_netmatch;
rh = &nethash[hash % ROUTEHASHSIZ];
+ match = afswitch[af].af_netmatch;
goto again;
}
return (0);
}
-/*
- * Add a new entry.
- */
-rtadd(dst, gate, metric)
+rtadd(dst, gate, metric, iflags)
struct sockaddr *dst, *gate;
- short metric;
+ int metric, iflags;
{
struct afhash h;
register struct rt_entry *rt;
return;
rt->rt_hash = hash;
rt->rt_dst = *dst;
- rt->rt_gateway = *gate;
+ rt->rt_router = *gate;
rt->rt_metric = metric;
rt->rt_timer = 0;
- rt->rt_flags = RTF_UP | flags;
+ rt->rt_flags = RTF_UP | flags | iflags;
rt->rt_state = 0;
- rt->rt_ifp = if_ifwithnet(&rt->rt_gateway);
- if (metric == 0)
- rt->rt_flags |= RTF_DIRECT;
+ rt->rt_ifp = if_ifwithnet(&rt->rt_router);
+ if (metric)
+ rt->rt_flags |= RTF_GATEWAY;
insque(rt, rh);
log("add", rt);
- if (initializing)
- return;
- if (supplier)
- broadcast(rt);
- if (install) {
+ if (install)
rt->rt_state |= RTS_ADDRT;
- rt->rt_retry = EXPIRE_TIME/TIMER_RATE;
- }
}
-/*
- * Look to see if a change to an existing entry
- * is warranted; if so, make it.
- */
rtchange(rt, gate, metric)
struct rt_entry *rt;
struct sockaddr *gate;
{
int change = 0;
- if (!equal(&rt->rt_gateway, gate)) {
- rt->rt_gateway = *gate;
+ if (!equal(&rt->rt_router, gate)) {
+ rt->rt_newrouter = *gate;
change++;
}
-
- /*
- * If the hop count has changed, adjust
- * the flags in the routing table entry accordingly.
- */
if (metric != rt->rt_metric) {
- if (rt->rt_metric == 0)
- rt->rt_flags &= ~RTF_DIRECT;
+ if (metric == 0)
+ rt->rt_flags |= RTF_GATEWAY;
rt->rt_metric = metric;
- if (metric >= HOPCNT_INFINITY)
- rt->rt_flags &= ~RTF_UP;
- else
- rt->rt_flags |= RTF_UP;
change++;
}
-
if (!change)
return;
- if (supplier)
- broadcast(rt);
log("change", rt);
- if (install) {
+ if (install)
rt->rt_state |= RTS_CHGRT;
- rt->rt_retry = EXPIRE_TIME/TIMER_RATE;
- }
}
-/*
- * Delete a routing table entry.
- */
rtdelete(rt)
struct rt_entry *rt;
{
+
log("delete", rt);
- if (install)
- if (ioctl(s, SIOCDELRT, (char *)&rt->rt_rt) &&
- errno == EBUSY)
- rt->rt_state |= RTS_DELRT;
+ if (install && ioctl(s, SIOCDELRT, (char *)&rt->rt_rt))
+ perror("SIOCDELRT");
+ /* don't delete interface entries so we can poll them later */
+ if (rt->rt_state & RTS_INTERFACE)
+ return;
remque(rt);
free((char *)rt);
}
char *t_name;
} flagbits[] = {
{ RTF_UP, "UP" },
- { RTF_DIRECT, "DIRECT" },
+ { RTF_GATEWAY, "GATEWAY" },
{ RTF_HOST, "HOST" },
{ 0 }
}, statebits[] = {
{ RTS_DELRT, "DELETE" },
{ RTS_CHGRT, "CHANGE" },
- { RTS_SILENT, "SILENT" },
+ { RTS_PASSIVE, "PASSIVE" },
+ { RTS_INTERFACE,"INTERFACE" },
+ { RTS_GLOBAL, "GLOBAL" },
{ 0 }
};
register struct bits *p;
return;
printf("%s ", operation);
dst = (struct sockaddr_in *)&rt->rt_dst;
- gate = (struct sockaddr_in *)&rt->rt_gateway;
+ gate = (struct sockaddr_in *)&rt->rt_router;
printf("dst %x, router %x, metric %d, flags",
dst->sin_addr, gate->sin_addr, rt->rt_metric);
cp = " %s";
putchar('\n');
}
-/*
- * Find the interface with address "addr".
- */
struct ifnet *
if_ifwithaddr(addr)
struct sockaddr *addr;
#undef same
}
-/*
- * Find the interface with network imbedded in
- * the sockaddr "addr". Must use per-af routine
- * look for match.
- */
struct ifnet *
if_ifwithnet(addr)
register struct sockaddr *addr;
return (ifp);
}
-/*
- * Formulate an Internet address.
- */
struct in_addr
if_makeaddr(net, host)
int net, host;