diff options
Diffstat (limited to 'proto/rip/rip.c')
| -rw-r--r-- | proto/rip/rip.c | 311 |
1 files changed, 311 insertions, 0 deletions
diff --git a/proto/rip/rip.c b/proto/rip/rip.c new file mode 100644 index 00000000..f8c2d784 --- /dev/null +++ b/proto/rip/rip.c @@ -0,0 +1,311 @@ +/* + * Rest in pieces - RIP protocol + * + * (c) 1998 Pavel Machek <pavel@ucw.cz> + * + * Can be freely distributed and used under the terms of the GNU GPL. + */ + +#define LOCAL_DEBUG + +#include <string.h> +#include <stdlib.h> + +#include "nest/bird.h" +#include "nest/iface.h" +#include "nest/protocol.h" +#include "nest/route.h" +#include "lib/socket.h" +#include "lib/resource.h" +#include "lib/lists.h" +#include "lib/timer.h" + +#include "rip.h" + +int infinity = 16; + +/* XXX should be 520 */ +#define RIP_PORT 1520 + +static void +rip_if_notify(struct proto *p, unsigned c, struct iface *old, struct iface *new) +{ +} + +static void +rip_reply(struct proto *p) +{ + P->listen->tbuf = "ACK!"; + sk_send_to( P->listen, 5, P->listen->faddr, P->listen->fport ); +} + +#define BAD( x ) { log( L_WARN "RIP/%s: " x "\n", p->name ); return; } + +static int +process_authentication( struct proto *p, struct rip_block *block ) +{ + return 0; +} + +static struct rip_entry * +find_entry( struct proto *p, ip_addr network, ip_addr netmask ) +{ + struct node *e; + + CHK_MAGIC; + WALK_LIST( e, P->rtable ) { + if (ipa_equal( network, E->network ) && + ipa_equal( netmask, E->netmask )) { + return E; + } + } + return NULL; +} + +#define ipa_from_u32(a) (*(ip_addr *) &a) + +static struct rip_entry * +new_entry( struct proto *p, struct rip_block *b, ip_addr whotoldme ) +{ + struct rip_entry *e; + + e = mb_alloc(p->pool, sizeof( struct rip_entry )); + e->whotoldme = whotoldme; + e->network = ipa_from_u32( b->network ); + e->netmask = ipa_from_u32( b->netmask ); + /* FIXME: verify that it is really netmask */ + if (b->nexthop) + e->nexthop = ipa_from_u32( b->nexthop ); + else + e->nexthop = whotoldme; + e->tag = ntohs( b->tag ); + e->metric = ntohl( b->metric ); + e->updated = e->changed = now; + + return e; +} + +static void +kill_entry( struct proto *p, struct rip_entry *e ) +{ + struct rip_connection *c; + + rem_node( NODE e ); + WALK_LIST( c, P->connections ) { + if (c->sendptr == e) + die( "kill_entry: one of connections has this as current, fix me!" ); + } + mb_free( e ); +} + +#define DELETE( msg ) { debug( msg ); kill_entry( p, e ); e = NULL; } + +static void +process_block( struct proto *p, struct rip_block *block, ip_addr whotoldme ) +{ + struct rip_entry *e; + int metric = ntohl( block->metric ); + ip_addr network = ipa_from_u32( block->network ); + + CHK_MAGIC; + if ((!metric) || (metric > infinity)) { + log( L_WARN "Got metric %d from %I\n", metric, whotoldme ); + return; + } + + /* XXX Check if destination looks valid - ie not net 0 or 127 */ + + /* XXX Should add configurable ammount */ + if (metric < infinity) + metric++; + + debug( "block: %I tells me: %I available, metric %d... ", whotoldme, network, metric ); + + e = find_entry( p, network, ipa_from_u32( block->netmask ) ); + if (e && (e->metric > metric)) /* || if same metrics and this is much newer */ + DELETE( "better metrics... " ); + + if (e && ((e->updated - now) > 180)) + DELETE( "more than 180 seconds old... " ); + + if (e && ipa_equal( whotoldme, e->whotoldme ) && + (e->metric == metric)) { + debug( "old news, updating time" ); + e->updated = now; + } + + if (!e) { + debug( "this is new" ); + e = new_entry( p, block, whotoldme ); + add_head( &P->rtable, NODE e ); + } + + debug( "\n" ); +} +#undef DELETE + +static void +rip_process_packet( struct proto *p, struct rip_packet *packet, int num, ip_addr whotoldme, int port ) +{ + int i; + + switch( packet->heading.version ) { + case RIP_V1: debug( "Warning: I do not talk ripv1\n" ); break; + case RIP_V2: break; + case '!': debug( "OOk, sir!\n" ); break; + default: BAD( "Unknown version" ); + } + + switch( packet->heading.command ) { + case 1: debug( "Asked to send my routing table\n" ); break; + case 2: debug( "Part of routing table came\n" ); + if (port != RIP_PORT) { + log( L_AUTH "%I send me routing info from port %d\n", whotoldme, port ); + return; + } + + if (!neigh_find( p, &whotoldme, 0 )) { + log( L_AUTH "%I send me routing info but he is not my neighbour\n", whotoldme ); + return; + } + + /* Should check if it is not my own packet */ + + for (i=0; i<num; i++) { + struct rip_block *block = &packet->block[i]; + if (block->family == 0xffff) + if (!i) { + if (process_authentication(p, block)) + BAD( "Authentication failed\n" ); + } else BAD( "Authentication is not the first!" ); + process_block( p, block, whotoldme ); + } + break; + case 3: + case 4: BAD( "I was asked for traceon/traceoff\n" ); + case 5: BAD( "Some Sun extension around here\n" ); + case '!': debug( "He gave me!\n" ); break; + default: BAD( "Unknown command" ); + } + + rip_reply(p); +} + +static void +rip_rx(sock *s, int size) +{ + struct proto *p = s->data; + int num; + + CHK_MAGIC; + debug( "RIP: message came: %d bytes\n", size ); + if (size <= 0) BAD( "Zero sized packet" ); + size -= sizeof( struct rip_packet_heading ); + if (size < 0) BAD( "Too small packet" ); + if (size % sizeof( struct rip_block )) BAD( "Odd sized packet" ); + num = size / sizeof( struct rip_block ); + if (num>25) BAD( "Too many blocks" ); + + rip_process_packet( p, (struct rip_packet *) s->rbuf, num, s->faddr, s->fport ); +} + +static void +rip_dump_entry( struct rip_entry *e ) +{ + debug( "%I told me %d/%d ago: to %I/%I go via %I, metric %d\n", + e->whotoldme, e->updated-now, e->changed-now, e->network, e->netmask, e->nexthop, e->metric ); +} + +static void +rip_timer(timer *t) +{ + struct proto *p = t->data; + struct rip_entry *e, *et; + + CHK_MAGIC; + debug( "RIP: tick tock\n" ); + + WALK_LIST_DELSAFE( e, et, P->rtable ) { + if ((now - E->updated) > (180+120)) { + debug( "RIP: entry is too old: " ); + rip_dump_entry( E ); + kill_entry( p, E ); + } + } +} + +static void +rip_start(struct proto *p) +{ + debug( "RIP: initializing instance...\n" ); + + P->listen = sk_new( p->pool ); + P->listen->type = SK_UDP; + P->listen->sport = RIP_PORT; + P->listen->rx_hook = rip_rx; + P->listen->data = p; + P->listen->rbsize = 10240; + P->magic = RIP_MAGIC; + if (sk_open(P->listen)<0) + die( "RIP/%s: could not listen\n", p->name ); + init_list( &P->rtable ); + init_list( &P->connections ); + P->timer = tm_new( p->pool ); + P->timer->data = p; + P->timer->randomize = 5; + P->timer->recurrent = 30; + P->timer->hook = rip_timer; + tm_start( P->timer, 30 ); + + debug( "RIP: ...done\n"); +} + +static void +rip_init(struct protocol *p) +{ + debug( "RIP: initializing RIP...\n" ); +} + +static void +rip_dump(struct proto *p) +{ + int i; + node *w, *e; + i = 0; + WALK_LIST( w, P->connections ) { + struct rip_connection *n = w; + debug( "RIP: connection #%d: %I\n", i, n->addr ); + } + i = 0; + WALK_LIST( e, P->rtable ) { + debug( "RIP: entry #%d: ", i++ ); + rip_dump_entry( E ); + } +} + +static void +rip_preconfig(struct protocol *x) +{ + struct proto *p = proto_new(&proto_rip, sizeof(struct rip_data)); + + debug( "RIP: preconfig\n" ); + p->preference = DEF_PREF_DIRECT; + p->start = rip_start; + p->if_notify = rip_if_notify; + p->dump = rip_dump; +} + +static void +rip_postconfig(struct protocol *p) +{ +} + +struct protocol proto_rip = { + { NULL, NULL }, + "RIP", + 0, + rip_init, + rip_preconfig, + rip_postconfig +}; + |