summaryrefslogtreecommitdiffstats
path: root/proto/ospf/lsupd.c
diff options
context:
space:
mode:
authorOndrej Filip <feela@network.cz>2004-06-04 14:53:10 +0200
committerOndrej Filip <feela@network.cz>2004-06-04 14:53:10 +0200
commit39e517d47c6070dd81bb7d6f57358ea98e462f03 (patch)
tree9bec961ab5750cec7941da8f9187876014f805b5 /proto/ospf/lsupd.c
parent591656cdd5b13a4626dfb26e45dd02690cdb450c (diff)
downloadbird-39e517d47c6070dd81bb7d6f57358ea98e462f03.tar
bird-39e517d47c6070dd81bb7d6f57358ea98e462f03.zip
hello.c and hello.h cleaned up. No design changes.
Diffstat (limited to 'proto/ospf/lsupd.c')
-rw-r--r--proto/ospf/lsupd.c196
1 files changed, 114 insertions, 82 deletions
diff --git a/proto/ospf/lsupd.c b/proto/ospf/lsupd.c
index a8896d6..aa452be 100644
--- a/proto/ospf/lsupd.c
+++ b/proto/ospf/lsupd.c
@@ -1,13 +1,30 @@
/*
* BIRD -- OSPF
*
- * (c) 2000 Ondrej Filip <feela@network.cz>
+ * (c) 2000-2004 Ondrej Filip <feela@network.cz>
*
* Can be freely distributed and used under the terms of the GNU GPL.
*/
#include "ospf.h"
+/**
+ * flood_lsa - send received or generated lsa to the neighbors
+ * @n: neighbor than sent this lsa (or NULL if generated)
+ * @hn: LSA header
+ * @hh: LSA header
+ * @po: actual instance of OSPF protocol
+ * @iff: interface which received this LSA (or NULL if LSA is generated)
+ * @oa: ospf_area which is the LSA generated for
+ * @rtl: add this LSA into retransmission list
+ *
+ * Calculation of internal paths in an area is described in 16.1 of RFC 2328.
+ * It's based on Dijkstra's shortest path tree algorithms.
+ * RFC recommends to add ASBR routers into routing table. I don't do this
+ * and latter parts of routing table calculation look directly into LSA
+ * Database. This function is invoked from area_disp().
+ */
+
int
flood_lsa(struct ospf_neighbor *n, struct ospf_lsa_header *hn,
struct ospf_lsa_header *hh, struct proto_ospf *po, struct ospf_iface *iff,
@@ -74,8 +91,10 @@ flood_lsa(struct ospf_neighbor *n, struct ospf_lsa_header *hn,
}
}
}
+
if(nn==n) continue;
- if(rtl!=0)
+
+ if(rtl)
{
if((en=ospf_hash_find_header(nn->lsrth, hh))==NULL)
{
@@ -100,15 +119,16 @@ flood_lsa(struct ospf_neighbor *n, struct ospf_lsa_header *hn,
ospf_hash_delete(nn->lsrth, en);
}
}
+
ret=1;
}
- if(ret==0) continue;
+ if(ret==0) continue; /* pg 150 (2) */
if(ifa==iff)
{
- if((n->rid==iff->drid)||n->rid==iff->bdrid) continue;
- if(iff->state==OSPF_IS_BACKUP) continue;
+ if((n->rid==iff->drid)||n->rid==iff->bdrid) continue; /* pg 150 (3) */
+ if(iff->state==OSPF_IS_BACKUP) continue; /* pg 150 (4) */
retval=1;
}
@@ -127,21 +147,26 @@ flood_lsa(struct ospf_neighbor *n, struct ospf_lsa_header *hn,
fill_ospf_pkt_hdr(ifa, pk, LSUPD_P);
pk->lsano=htonl(1);
- if(hn!=NULL)
+
+ if(hn)
{
+ struct ospf_lsa_header *lh = (struct ospf_lsa_header *)(pk+1);
+ u16 age = ntohs(lh->age);
+
memcpy(pk+1,hn,ntohs(hn->length));
len=sizeof(struct ospf_lsupd_packet)+ntohs(hn->length);
+ age += ifa->inftransdelay;
+ if(age>LSA_MAXAGE) age = LSA_MAXAGE;
+ lh->age = htons(age);
}
else
{
u8 *help;
struct top_hash_entry *en;
- struct ospf_lsa_header *lh;
- u16 age;
+ struct ospf_lsa_header *lh = (struct ospf_lsa_header *)(pk+1);
+ u16 age = hh->age;
- lh=(struct ospf_lsa_header *)(pk+1);
htonlsah(hh,lh);
- age=hh->age;
age+=ifa->inftransdelay;
if(age>LSA_MAXAGE) age=LSA_MAXAGE;
lh->age=htons(age);
@@ -151,6 +176,7 @@ flood_lsa(struct ospf_neighbor *n, struct ospf_lsa_header *hn,
-sizeof(struct ospf_lsa_header));
len=hh->length+sizeof(struct ospf_lsupd_packet);
}
+
op->length=htons(len);
ospf_pkt_finalize(ifa, op);
OSPF_TRACE(D_PACKETS, "LS upd flooded via %s", ifa->iface->name);
@@ -263,136 +289,141 @@ ospf_lsupd_rx(struct ospf_lsupd_packet *ps, struct proto *p,
nrid);
return ;
}
+
if(n->state<NEIGHBOR_EXCHANGE)
{
- OSPF_TRACE(D_PACKETS,"Received lsupd in lesser state than EXCHANGE from (%I)",
+ OSPF_TRACE(D_PACKETS, "Received lsupd in lesser state than EXCHANGE from (%I)",
n->ip);
return;
}
+
if(size<=(sizeof(struct ospf_lsupd_packet)+sizeof(struct ospf_lsa_header)))
{
- OSPF_TRACE(D_PACKETS, "Received lsupd from %I is too short!", n->ip);
+ log(L_WARN "Received lsupd from %I is too short!", n->ip);
return;
}
OSPF_TRACE(D_PACKETS, "Received LS upd from %I", n->ip);
- ospf_neigh_sm(n, INM_HELLOREC);
+ ospf_neigh_sm(n, INM_HELLOREC); /* Questionable */
lsa=(struct ospf_lsa_header *)(ps+1);
area=htonl(ps->ospf_packet.areaid);
oa=ospf_find_area((struct proto_ospf *)p,area);
- for(i=0;i<ntohl(ps->lsano);i++,
+
+ for(i=0; i<ntohl(ps->lsano); i++,
lsa=(struct ospf_lsa_header *)(((u8 *)lsa)+ntohs(lsa->length)))
{
struct ospf_lsa_header lsatmp;
struct top_hash_entry *lsadb;
- u16 lenn;
int diff=((u8 *)lsa)-((u8 *)ps);
- u16 chsum;
-
- if(((diff+sizeof(struct ospf_lsa_header))>=size) ||
- ((ntohs(lsa->length)+diff)>size))
- log("%s: Received lsupd from %I is too short.", p->name,n->ip);
+ u16 chsum, lenn = ntohs(lsa->length);
- lenn=ntohs(lsa->length);
+ if(((diff+sizeof(struct ospf_lsa_header))>=size) || ((lenn+diff)>size))
+ {
+ log(L_WARN "Received lsupd from %I is too short!", n->ip);
+ ospf_neigh_sm(n, INM_BADLSREQ);
+ break;
+ }
if((lenn<=sizeof(struct ospf_lsa_header))||(lenn!=(4*(lenn/4))))
{
- log("Received LSA with bad length");
- ospf_neigh_sm(n,INM_BADLSREQ);
+ log(L_WARN "Received LSA from %I with bad length", n->ip);
+ ospf_neigh_sm(n, INM_BADLSREQ);
break;
}
+
/* pg 143 (1) */
chsum=lsa->checksum;
if(chsum!=lsasum_check(lsa,NULL,po))
{
- log("Received bad lsa checksum from %I",n->rid);
+ log(L_WARN "Received bad lsa checksum from %I", n->ip);
continue;
}
+
/* pg 143 (2) */
if((lsa->type<LSA_T_RT)||(lsa->type>LSA_T_EXT))
{
- log("Unknown LSA type from %I",n->rid);
+ log(L_WARN "Unknown LSA type from %I", n->ip);
continue;
}
+
/* pg 143 (3) */
if((lsa->type==LSA_T_EXT)&&oa->stub)
{
- log("Received External LSA in stub area from %I",n->rid);
+ log(L_WARN "Received External LSA in stub area from %I", n->ip);
continue;
}
+
ntohlsah(lsa,&lsatmp);
+
DBG("Update Type: %u ID: %I RT: %I, Sn: 0x%08x Age: %u, Sum: %u\n",
lsatmp.type, lsatmp.id, lsatmp.rt, lsatmp.sn, lsatmp.age,
lsatmp.checksum);
+
lsadb=ospf_hash_find_header(oa->gr, &lsatmp);
+
+#ifdef LOCAL_DEBUG
if(lsadb)
DBG("I have Type: %u ID: %I RT: %I, Sn: 0x%08x Age: %u, Sum: %u\n",
lsadb->lsa.type, lsadb->lsa.id, lsadb->lsa.rt, lsadb->lsa.sn,
lsadb->lsa.age, lsadb->lsa.checksum);
+#endif
/* pg 143 (4) */
- if((lsatmp.age==LSA_MAXAGE)&&(lsadb==NULL))
+ if((lsatmp.age==LSA_MAXAGE)&&(lsadb==NULL)&&can_flush_lsa(oa))
{
- int flag=0;
- struct ospf_iface *ifatmp;
-
- if(can_flush_lsa(oa))
- {
- ospf_lsack_direct_tx(n,lsa);
- continue;
- }
+ ospf_lsack_direct_tx(n,lsa);
+ continue;
}
+
/* pg 144 (5) */
if((lsadb==NULL)||(lsa_comp(&lsatmp,&lsadb->lsa)==CMP_NEWER))
{
- struct ospf_iface *ift=NULL;
- void *body;
- struct ospf_iface *nifa;
- int self=0;
-
- DBG("PG143(5): Received LSA is newer\n");
-
- if(lsatmp.rt==p->cf->global->router_id) self=1;
-
- if(lsatmp.type==LSA_T_NET)
- {
- WALK_LIST(nifa,po->iface_list)
- {
- if(ipa_compare(nifa->iface->addr->ip,ipa_from_u32(lsatmp.id))==0)
- {
- self=1;
- break;
- }
- }
- }
-
- if(self)
- {
- struct top_hash_entry *en;
-
- if((lsatmp.age==LSA_MAXAGE)&&(lsatmp.sn==LSA_MAXSEQNO))
- {
- ospf_lsack_direct_tx(n,lsa);
- continue;
- }
-
- lsatmp.age=LSA_MAXAGE;
- lsatmp.sn=LSA_MAXSEQNO;
- lsa->age=htons(LSA_MAXAGE);
- lsa->sn=htonl(LSA_MAXSEQNO);
- OSPF_TRACE(D_EVENTS, "Premature aging self originated lsa.");
- OSPF_TRACE(D_EVENTS, "Type: %d, Id: %I, Rt: %I",lsatmp.type,
- lsatmp.id, lsatmp.rt);
- lsasum_check(lsa,(lsa+1),po);
- lsatmp.checksum=ntohs(lsa->checksum);
- flood_lsa(NULL,lsa,&lsatmp,po,NULL,oa,0);
- if(en=ospf_hash_find_header(oa->gr,&lsatmp))
- {
- flood_lsa(NULL,NULL,&en->lsa,po,NULL,oa,1);
- }
- continue;
- }
+ struct ospf_iface *ift=NULL;
+ void *body;
+ struct ospf_iface *nifa;
+ int self = (lsatmp.rt == p->cf->global->router_id);
+
+ DBG("PG143(5): Received LSA is newer\n");
+
+ if(lsatmp.type==LSA_T_NET)
+ {
+ WALK_LIST(nifa,po->iface_list)
+ {
+ if(ipa_compare(nifa->iface->addr->ip,ipa_from_u32(lsatmp.id))==0)
+ {
+ self=1;
+ break;
+ }
+ }
+ }
+
+ if(self)
+ {
+ struct top_hash_entry *en;
+
+ if((lsatmp.age==LSA_MAXAGE)&&(lsatmp.sn==LSA_MAXSEQNO))
+ {
+ ospf_lsack_direct_tx(n,lsa);
+ continue;
+ }
+
+ lsatmp.age=LSA_MAXAGE;
+ lsatmp.sn=LSA_MAXSEQNO;
+ lsa->age=htons(LSA_MAXAGE);
+ lsa->sn=htonl(LSA_MAXSEQNO);
+ OSPF_TRACE(D_EVENTS, "Premature aging self originated lsa.");
+ OSPF_TRACE(D_EVENTS, "Type: %d, Id: %I, Rt: %I",lsatmp.type,
+ lsatmp.id, lsatmp.rt);
+ lsasum_check(lsa,(lsa+1),po);
+ lsatmp.checksum=ntohs(lsa->checksum);
+ flood_lsa(NULL,lsa,&lsatmp,po,NULL,oa,0);
+ if(en=ospf_hash_find_header(oa->gr,&lsatmp))
+ {
+ flood_lsa(NULL,NULL,&en->lsa,po,NULL,oa,1);
+ }
+ continue;
+ }
/* pg 144 (5a) */
if(lsadb && ((now-lsadb->inst_t)<=MINLSARRIVAL))
@@ -488,6 +519,7 @@ ospf_lsupd_rx(struct ospf_lsupd_packet *ps, struct proto *p,
ospf_lsupd_tx_list(n, &l);
}
}
+
if(n->state==NEIGHBOR_LOADING)
{
ospf_lsreq_tx(n); /* Send me another part of database */