Flooding work continues.

This commit is contained in:
Ondrej Filip 2000-04-04 00:32:17 +00:00
parent 8496b2e41a
commit 921a93f217
8 changed files with 90 additions and 7 deletions

View file

@ -37,3 +37,9 @@ ospf_lsack_rx(struct ospf_lsack_packet *ps, struct proto *p,
/* FIXME Go on! */ /* FIXME Go on! */
} }
void
add_ack_list(struct ospf_neighbor *n,struct ospf_lsa_header *lsa)
{
/* FIXME Go on */
}

View file

@ -13,5 +13,6 @@
void ospf_lsack_tx(struct ospf_neighbor *n); void ospf_lsack_tx(struct ospf_neighbor *n);
void ospf_lsack_rx(struct ospf_lsack_packet *ps, struct proto *p, void ospf_lsack_rx(struct ospf_lsack_packet *ps, struct proto *p,
struct ospf_iface *ifa, u16 size); struct ospf_iface *ifa, u16 size);
void add_ack_list(struct ospf_neighbor *n,struct ospf_lsa_header *lsa);
#endif /* _BIRD_OSPF_LSACK_H_ */ #endif /* _BIRD_OSPF_LSACK_H_ */

View file

@ -25,7 +25,7 @@ ospf_lsreq_tx(struct ospf_neighbor *n)
fill_ospf_pkt_hdr(n->ifa, pk, LSREQ); fill_ospf_pkt_hdr(n->ifa, pk, LSREQ);
sn=SHEAD(n->lsrql); sn=SHEAD(n->lsrql);
if(sn==NULL) if(EMPTY_SLIST(n->lsrql))
{ {
if(n->state==NEIGHBOR_LOADING) ospf_neigh_sm(n, INM_LOADDONE); if(n->state==NEIGHBOR_LOADING) ospf_neigh_sm(n, INM_LOADDONE);
return; return;

View file

@ -87,6 +87,7 @@ ospf_lsupd_rx(struct ospf_lsupd_packet *ps, struct proto *p,
struct ospf_neighbor *n; struct ospf_neighbor *n;
struct ospf_lsa_header *lsa; struct ospf_lsa_header *lsa;
struct ospf_area *oa; struct ospf_area *oa;
struct proto_ospf *po=(struct proto_ospf *)p;
u16 length; u16 length;
u8 i; u8 i;
@ -113,7 +114,9 @@ ospf_lsupd_rx(struct ospf_lsupd_packet *ps, struct proto *p,
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))) lsa=(struct ospf_lsa_header *)(((u8 *)lsa)+ntohs(lsa->length)))
{ {
if(lsa->checksum!=lsasum_check(lsa,NULL,(struct proto_ospf *)p)) struct ospf_lsa_header lsatmp;
struct top_hash_entry *lsadb;
if(lsa->checksum!=lsasum_check(lsa,NULL,po))
{ {
log("Received bad lsa checksum from %u\n",n->rid); log("Received bad lsa checksum from %u\n",n->rid);
continue; continue;
@ -128,9 +131,72 @@ ospf_lsupd_rx(struct ospf_lsupd_packet *ps, struct proto *p,
log("Received External LSA in stub area from %u\n",n->rid); log("Received External LSA in stub area from %u\n",n->rid);
continue; continue;
} }
/* FIXME Go on */ ntohlsah(lsa,&lsatmp);
DBG("Processing update Type: %u ID: %u RT: %u\n",lsa->type, DBG("Processing update Type: %u ID: %u RT: %u\n",lsa->type,
ntohl(lsa->id), ntohl(lsa->rt)); ntohl(lsa->id), ntohl(lsa->rt));
lsadb=ospf_hash_find_header(oa->gr, &lsatmp);
if((lsatmp.age==LSA_MAXAGE)&&(lsadb==NULL))
{
struct ospf_neighbor *n=NULL;
struct ospf_iface *ifa=NULL;
int flag=0;
WALK_LIST(NODE ifa,po->iface_list)
WALK_LIST(NODE n,ifa->neigh_list)
if((n->state==NEIGHBOR_EXCHANGE)&&(n->state==NEIGHBOR_LOADING))
flag=1;
if(flag==0)
{
add_ack_list(n,lsa);
continue;
}
}
if((lsadb==NULL)||(lsa_comp(&lsatmp,&lsadb->lsa)==CMP_NEWER))
{
struct ospf_neighbor *n=NULL;
struct ospf_iface *ifa=NULL;
/* FIXME self originated? */
if(lsadb && ((lsadb->inst_t-now)<MINLSARRIVAL)) continue;
/* Remove old from all ret lists */
WALK_LIST(NODE ifa,po->iface_list)
WALK_LIST(NODE n,ifa->neigh_list)
{
struct top_hash_entry *en;
if((en=ospf_hash_find_header(n->lsrth,&lsadb->lsa))!=NULL)
s_rem_node(SNODE en);
}
/* Install new */
memcpy(&lsadb->lsa,&lsatmp,sizeof(struct ospf_lsa_header));
lsadb->inst_t=now;
if(lsadb->lsa_body!=NULL) mb_free(lsadb->lsa_body);
lsadb->lsa_body=mb_alloc(p->pool,lsadb->lsa.length-
sizeof(struct ospf_lsa_header));
ntohlsab(lsa+1,lsadb->lsa_body,lsadb->lsa.type,lsadb->lsa.length);
/* FIXME lsa_flood(n,lsadb) */
/* FIXME ack_lsa() */
continue;
}
/* FIXME pg144 (6)?? */
if(lsa_comp(&lsatmp,&lsadb->lsa)==CMP_SAME)
{
struct top_hash_entry *en;
if((en=ospf_hash_find_header(n->lsrth,&lsadb->lsa))!=NULL)
s_rem_node(SNODE en);
/* FIXME ack_lsa() */
continue;
}
if((lsadb->lsa.age==LSA_MAXAGE)&&(lsadb->lsa.sn==LSA_MAXSEQNO)) continue;
/* FIXME lsa_send(n,lsa) */
} }
} }

View file

@ -210,10 +210,11 @@ ospf_neigh_sm(struct ospf_neighbor *n, int event)
s_init_list(&(n->lsrql)); s_init_list(&(n->lsrql));
n->lsrqh=ospf_top_new(n->ifa->proto); n->lsrqh=ospf_top_new(n->ifa->proto);
s_init_list(&(n->lsrtl)); s_init_list(&(n->lsrtl));
n->lsrth=ospf_top_new(n->ifa->proto);
s_init(&(n->dbsi), &(n->ifa->oa->lsal)); s_init(&(n->dbsi), &(n->ifa->oa->lsal));
s_init(&(n->lsrqi), &(n->lsrql)); s_init(&(n->lsrqi), &(n->lsrql));
s_init(&(n->lsrti), &(n->lsrtl));
tm_start(n->lsrr_timer,n->ifa->rxmtint); tm_start(n->lsrr_timer,n->ifa->rxmtint);
/*ospf_dbdes_tx(n);*/
} }
else die("NEGDONE and I'm not in EXSTART?\n"); else die("NEGDONE and I'm not in EXSTART?\n");
break; break;
@ -222,6 +223,7 @@ ospf_neigh_sm(struct ospf_neighbor *n, int event)
/* FIXME Go on */ /* FIXME Go on */
break; break;
case INM_LOADDONE: case INM_LOADDONE:
neigh_chstate(n,NEIGHBOR_FULL);
break; break;
case INM_ADJOK: case INM_ADJOK:
switch(n->state) switch(n->state)

View file

@ -37,12 +37,12 @@
#endif #endif
#define LSREFRESHTIME 1800 /* 30 minut */ #define LSREFRESHTIME 1800 /* 30 minutes */
#define MINLSINTERVAL 5 #define MINLSINTERVAL 5
#define MINLSARRIVAL 1 #define MINLSARRIVAL 1
#define MAXAGE 3600 /* 1 hour */ #define MAXAGE 3600 /* 1 hour */
#define CHECKAGE 300 /* 5 min */ #define CHECKAGE 300 /* 5 minutes */
#define MAXAGEDIFF 900 /* 15 min */ #define MAXAGEDIFF 900 /* 15 minutes */
#define LSINFINITY 0xffffff #define LSINFINITY 0xffffff
/*#define DEFAULTDES 0.0.0.0 FIXME: How to define it? */ /*#define DEFAULTDES 0.0.0.0 FIXME: How to define it? */
#define INITSEQNUM 0x80000001 /* Initial Sequence Number */ #define INITSEQNUM 0x80000001 /* Initial Sequence Number */
@ -285,6 +285,7 @@ struct ospf_neighbor
siterator lsrqi; siterator lsrqi;
slist lsrtl; /* Link state retransmission list */ slist lsrtl; /* Link state retransmission list */
siterator lsrti; siterator lsrti;
struct top_graph *lsrth;
void *ldbdes; /* Last database description packet */ void *ldbdes; /* Last database description packet */
timer *rxmt_timer; /* RXMT timer */ timer *rxmt_timer; /* RXMT timer */
timer *lsrr_timer; /* Link state requiest retransmition timer */ timer *lsrr_timer; /* Link state requiest retransmition timer */

View file

@ -291,6 +291,11 @@ ospf_top_rehash(struct top_graph *f, int step)
ospf_top_ht_free(oldt); ospf_top_ht_free(oldt);
} }
struct top_hash_entry *
ospf_hash_find_header(struct top_graph *f, struct ospf_lsa_header *h)
{
return ospf_hash_find(f,h->id,h->rt,h->type);
}
struct top_hash_entry * struct top_hash_entry *
ospf_hash_find(struct top_graph *f, u32 lsa, u32 rtr, u32 type) ospf_hash_find(struct top_graph *f, u32 lsa, u32 rtr, u32 type)
{ {

View file

@ -14,6 +14,7 @@ struct top_hash_entry { /* Index for fast mapping (type,rtrid,LSid)->vertex */
struct top_hash_entry *next; /* Next in hash chain */ struct top_hash_entry *next; /* Next in hash chain */
struct ospf_lsa_header lsa; struct ospf_lsa_header lsa;
void *lsa_body; void *lsa_body;
bird_clock_t inst_t; /* Time of installation into DB */
}; };
struct top_graph { struct top_graph {
@ -30,6 +31,7 @@ struct top_graph {
struct top_graph *ospf_top_new(struct proto_ospf *); struct top_graph *ospf_top_new(struct proto_ospf *);
void ospf_top_free(struct top_graph *); void ospf_top_free(struct top_graph *);
void ospf_top_dump(struct top_graph *); void ospf_top_dump(struct top_graph *);
struct top_hash_entry *ospf_hash_find_header(struct top_graph *f, struct ospf_lsa_header *h);
struct top_hash_entry *ospf_hash_find(struct top_graph *, u32 lsa, u32 rtr, u32 type); struct top_hash_entry *ospf_hash_find(struct top_graph *, u32 lsa, u32 rtr, u32 type);
struct top_hash_entry *ospf_hash_get(struct top_graph *, u32 lsa, u32 rtr, u32 type); struct top_hash_entry *ospf_hash_get(struct top_graph *, u32 lsa, u32 rtr, u32 type);
void ospf_hash_delete(struct top_graph *, struct top_hash_entry *); void ospf_hash_delete(struct top_graph *, struct top_hash_entry *);