Sending of DBDes. (Checksum and length calculation NOT done.)

proto/ospf/dbdes.c

@@ -1,7 +1,7 @@
 /*
  *	BIRD -- OSPF
  *
- *	(c) 1999 Ondrej Filip <feela@network.cz>
+ *	(c) 1999-2000 Ondrej Filip <feela@network.cz>
  *
  *	Can be freely distributed and used under the terms of the GNU GPL.
  */
@@ -16,19 +16,20 @@ ospf_dbdes_tx(struct ospf_neighbor *n)
   struct ospf_iface *ifa;
   u16 length;
   struct proto *p;
+  u16 i,j;
+  u8 *aa,*bb;
 
   ifa=n->ifa;
 
   p=(struct proto *)(ifa->proto);
+  pkt=(struct ospf_dbdes_packet *)(ifa->ip_sk->tbuf);
+  op=(struct ospf_packet *)pkt;
 
   switch(n->state)
   {
     case NEIGHBOR_EXSTART:		/* Send empty packets */
-      pkt=(struct ospf_dbdes_packet *)(ifa->ip_sk->tbuf);
-      op=(struct ospf_packet *)pkt;
-
       fill_ospf_pkt_hdr(ifa, pkt, DBDES);
-      pkt->iface_mtu= ((struct iface *)ifa)->mtu;
+      pkt->iface_mtu=ifa->iface->mtu;
       pkt->options= ifa->options;
       pkt->imms=n->myimms;
       pkt->ddseq=n->dds;
@@ -37,8 +38,67 @@ ospf_dbdes_tx(struct ospf_neighbor *n)
       ospf_pkt_finalize(ifa, op);
       sk_send_to(ifa->ip_sk,length, n->ip, OSPF_PROTO);
       debug("%s: DB_DES sent for %u.\n", p->name, n->rid);
+      break;
+
+    case NEIGHBOR_EXCHANGE:
+      if(! ((IAMMASTER(n->myimms) && (n->dds==n->ddr+1)) || ((!IAMMASTER(n->myimms)) && (n->dds==n->ddr))))
+      {
+        snode *sn;			/* Send next */
+        struct ospf_lsaheader *lsa;
+	
+        fill_ospf_pkt_hdr(ifa, pkt, DBDES);
+        pkt->iface_mtu= ifa->iface->mtu;
+        pkt->options= ifa->options;
+	pkt->ddseq=n->dds;
+
+	sn=s_get(&(n->dbsi));
+	j=i=(pkt->iface_mtu-sizeof(struct ospf_dbdes_packet))/sizeof(struct ospf_lsaheader);	/* Number of lsaheaders */
+	lsa=(n->ldbdes+sizeof(struct ospf_dbdes_packet));
+
+	for(;i>0;i--)
+	{
+	  struct top_hash_entry *en;
+	  
+	  en=(struct top_hash_entry *)sn;
+	  lsa->lsage=htons(en->lsage);
+	  lsa->options=htons(en->options);
+	  lsa->lstype=htons(en->lsa_type);
+	  lsa->lsid=htons(en->lsa_id);
+	  lsa->advr=htons(en->rtr_id);
+	  lsa->lssn=htons(en->lsseqno);
+	  lsa->length=htons(en->length);
+	  lsa->checksum=htons(en->checksum);
+	  if(sn->next==NULL)
+	  {
+	    break;	/* Should set some flag? */
+	  }
+	  sn=sn->next;
+	}
+	s_put(&(n->dbsi),sn);
+
+	if(sn->next==NULL)
+	{
+	  n->myimms=(n->myimms-DBDES_M);	/* Unset more bit */
+	}
+
+        pkt->imms=n->myimms;
+
+	length=j*sizeof(struct ospf_lsaheader)+sizeof(struct ospf_dbdes_packet);
+	op->length=htons(length);
+        ospf_pkt_finalize(ifa, op);
+        sk_send_to(ifa->ip_sk,length, n->ip, OSPF_PROTO);
+      }
+
+      aa=ifa->ip_sk->tbuf;
+      bb=n->ldbdes;
+      length=ntohs(op->length);
+
+      for(i=0; i<ifa->iface->mtu; i++)
+      {
+        *(aa+i)=*(bb+i);	/* Copy last sent packet again */
+      }
+      sk_send_to(ifa->ip_sk,length, n->ip, OSPF_PROTO);
 
-    /*case NEIGHBOR_EXCHANGE:		*/
     default:				/* Ignore it */
       break;
   }

proto/ospf/hello.c

@@ -103,6 +103,7 @@ ospf_hello_rx(struct ospf_hello_packet *ps, struct proto *p,
     n->options=ps->options;
     n->ifa=ifa;
     n->adj=0;
+    n->ldbdes=mb_alloc(p->pool, ifa->iface->mtu);
     neigh_chstate(n,NEIGHBOR_DOWN);
     install_inactim(n);
   }

proto/ospf/iface.c

@@ -233,7 +233,8 @@ ospf_iface_default(struct ospf_iface *ifa)
 {
   u8 i;
 
-  ifa->area=0; /* FIXME: Read from config */
+  ifa->oa=NULL;
+  ifa->an=0;		/* FIXME This should respect config */
   ifa->cost=COST_D;
   ifa->rxmtint=RXMTINT_D;
   ifa->iftransdelay=IFTRANSDELAY_D;

proto/ospf/neighbor.c

@@ -204,7 +204,10 @@ ospf_neigh_sm(struct ospf_neighbor *n, int event)
       if(n->state==NEIGHBOR_EXSTART)
       {
         neigh_chstate(n,NEIGHBOR_EXCHANGE);
-        /* FIXME Go on... */
+        s_init_list(&(n->lsrql));
+        s_init_list(&(n->lsrtl));
+	s_init(&(n->dbsi), &(n->ifa->oa->lsal));
+	ospf_dbdes_tx(n);
       }
       break;
     case INM_EXDONE:

proto/ospf/ospf.h

@@ -21,6 +21,7 @@
 #include "lib/checksum.h"
 #include "lib/ip.h"
 #include "lib/lists.h"
+#include "lib/slists.h"
 #include "lib/socket.h"
 #include "lib/timer.h"
 #include "lib/resource.h"
@@ -60,10 +61,11 @@ struct ospf_iface {
   node n;
   struct proto_ospf *proto;
   struct iface *iface;	/* Nest's iface */
+  struct ospf_area *oa;
+  u32 an;		/* Area number */
   sock *hello_sk;	/* Hello socket */
   sock *ip_sk;		/* IP socket (for DD ...) */
   list neigh_list;	/* List of neigbours */
-  u32 area;		/* OSPF Area */
   u16 cost;		/* Cost of iface */
   u16 rxmtint;		/* number of seconds between LSA retransmissions */
   u16 iftransdelay;	/* The estimated number of seconds it takes to
@@ -183,6 +185,12 @@ struct ospf_neighbor
   u32 dr;		/* Neigbour's idea of DR */
   u32 bdr;		/* Neigbour's idea of BDR */
   u8 adj;		/* built adjacency? */
+  siterator dbsi;	/* Database summary list iterator */
+  slist lsrql;		/* Link state request */ /* FIXME add top_gr hashing? */
+  siterator lsrqi;
+  slist lsrtl;		/* Link state retransmission list */
+  siterator lsrti;
+  void *ldbdes;		/* Last database description packet */
 };
 
 /* Definitions for interface state machine */
@@ -213,6 +221,7 @@ struct ospf_area {
   struct ospf_area *next;
   u32 areaid;
   struct top_graph *gr;		/* LSA graph */
+  slist lsal;			/* List of all LSA's */
   struct top_hash_entry *rt;	/* My own router LSA */
   slab *rtlinks;
 };

proto/ospf/packet.c

@@ -23,7 +23,7 @@ fill_ospf_pkt_hdr(struct ospf_iface *ifa, void *buf, u8 h_type)
   pkt->type=h_type;
 
   pkt->routerid=htonl(p->cf->global->router_id);
-  pkt->areaid=htonl(ifa->area);
+  pkt->areaid=htonl(ifa->an);
   pkt->autype=htons(ifa->autype);
   pkt->checksum=0;
 }
@@ -101,7 +101,7 @@ ospf_rx_hook(sock *sk, int size)
 
   /* FIXME: Do authetification */
 
-  if(ps->areaid!=ifa->area)
+  if(ps->areaid!=ifa->an)
   {
     log("%s: Bad OSPF packet received: other area %ld", p->name, ps->areaid);
     log("%s: Discarding",p->name);

proto/ospf/topology.c

@@ -38,22 +38,25 @@ addifa_rtlsa(struct ospf_iface *ifa)
 
   while(oa!=NULL)
   {
-    if(oa->areaid==ifa->area) break;
+    if(oa->areaid==ifa->an) break;
     oa=oa->next;
   }
 
+  ifa->oa=oa;
+ 
   if(oa==NULL)	/* New area */
   {
     oa=po->firstarea;
     po->firstarea=mb_alloc(po->proto.pool, sizeof(struct ospf_area));
     po->firstarea->next=oa;
     oa=po->firstarea;
-    oa->areaid=ifa->area;
+    oa->areaid=ifa->an;
     oa->gr=ospf_top_new(po);
+    s_init_list(&(oa->lsal));
     oa->rtlinks=sl_new(po->proto.pool,
       sizeof(struct top_graph_rtlsa_link));
     oa->rt=ospf_hash_get(oa->gr, rtid, rtid, LSA_T_RT);
-    DBG("XXXXXX %x XXXXXXX\n", oa->rt);
+    s_add_head(&(oa->lsal), (snode *)oa->rt);
     rt=mb_alloc(po->proto.pool, sizeof(struct top_graph_rtlsa));
     oa->rt->vertex=(void *)rt;
     oa->rt->lsage=0;
@@ -61,7 +64,7 @@ addifa_rtlsa(struct ospf_iface *ifa)
     rt->Vbit=0;
     rt->Ebit= (po->areano++ ? 0 : 1);	/* If it's 1st area set 0 */
     rt->Bbit=0;				/* FIXME Could read config */
-    DBG("%s: New OSPF area \"%d\" added.\n", po->proto.name, ifa->area);
+    DBG("%s: New OSPF area \"%d\" added.\n", po->proto.name, ifa->an);
 
     if(po->areano==2)	/* We are attached to more than 2 areas! */
     {

proto/ospf/topology.h

@@ -10,6 +10,7 @@
 #define _BIRD_OSPF_TOPOLOGY_H_
 
 struct top_hash_entry {  /* Index for fast mapping (type,rtrid,LSid)->vertex */
+   snode n;
   struct top_hash_entry *next;		/* Next in hash chain */
   struct top_vertex *vertex;
   u32 lsa_id, rtr_id;
@@ -25,6 +26,7 @@ struct top_hash_entry {  /* Index for fast mapping (type,rtrid,LSid)->vertex */
 #define LSA_CHECKAGE 300		/* 5 minutes */
 #define LSA_MAXAGEDIFF 900		/* 15 minutes */
   u32 lsseqno;
+  u16 length, checksum;
 #define LSA_INITSEQNO 0x80000001
 #define LSA_MAXSEQNO 0x7fffffff
 };