--- /dev/null
+/*
+ * 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
+};
+
projects / thirdparty / bird.git / commitdiff
