summaryrefslogtreecommitdiffstats
path: root/proto
diff options
context:
space:
mode:
Diffstat (limited to 'proto')
-rw-r--r--proto/ospf/ospf.c133
1 files changed, 121 insertions, 12 deletions
diff --git a/proto/ospf/ospf.c b/proto/ospf/ospf.c
index 65b76a2..a5ec2d1 100644
--- a/proto/ospf/ospf.c
+++ b/proto/ospf/ospf.c
@@ -23,6 +23,19 @@
#include "ospf.h"
+/* Try to build neighbor adjacency (if does not exists) */
+void
+tryadj(struct ospf_neighbor *n, struct proto *p)
+{
+ if(n->state==NEIGHBOR_INIT)
+ {
+ DBG("%s: Going to build adjacency.\n", p->name);
+ n->state=NEIGHBOR_EXSTART;
+ /* FIXME Go on */
+ }
+}
+
+/* Neighbor is inactive for a long time. Remove it. */
void
neighbor_timer_hook(timer *timer)
{
@@ -42,14 +55,22 @@ neighbor_timer_hook(timer *timer)
debug("%s: Deleting neigbor.\n", p->name);
}
+/*
+void
+backupseen()
+{
+ ; /* Backup Seen Event *
+}
+*/
+
void
ospf_hello_rx(struct ospf_hello_packet *ps, struct proto *p,
- struct ospf_iface *ifa)
+ struct ospf_iface *ifa, int size)
{
char sip[100]; /* FIXME: Should be smaller */
- u32 nrid;
+ u32 nrid, *pnrid;
struct ospf_neighbor *neigh,*n;
- int i;
+ int i,twoway;
nrid=ntohl(((struct ospf_packet *)ps)->routerid);
@@ -109,14 +130,78 @@ ospf_hello_rx(struct ospf_hello_packet *ps, struct proto *p,
n->inactim->recurrent=0;
DBG("%s: Installing inactivity timer.\n", p->name);
n->state=NEIGHBOR_INIT;
+ n->rid=nrid;
+ n->dr=ntohl(ps->dr);
+ n->bdr=ntohl(ps->bdr);
+ n->priority=ps->priority;
+ n->options=ps->options;
}
- n->rid=nrid;
- n->dr=ntohl(ps->dr);
- n->bdr=ntohl(ps->bdr);
- n->priority=ps->priority;
- n->options=ps->options;
tm_start(n->inactim,ifa->deadc*ifa->helloint);
+ twoway=0;
+ pnrid=(u32 *)((struct ospf_hello_packet *)(ps+1));
+
+ for(i=0;i<size-(sizeof(struct ospf_hello_packet));i++)
+ {
+ if(ntohl(*(pnrid+i))==p->cf->global->router_id)
+ {
+ twoway=1;
+ DBG("%s: Twoway received. %d\n", p->name, nrid);
+ break;
+ }
+ }
+
+ if(twoway)
+ {
+ if(n->state<NEIGHBOR_2WAY) n->state=NEIGHBOR_2WAY;
+ }
+ else
+ {
+ if(n->state>=NEIGHBOR_2WAY)
+ {
+ /* FIXME Delete all learnt */
+ n->state=NEIGHBOR_INIT;
+ }
+ }
+
+ /* Check priority change */
+ if(n->priority!=(n->priority=ps->priority))
+ {
+ /* FIXME NeighborChange */;
+ }
+
+ /* Check neighbor's designed router idea */
+ if((n->rid!=ntohl(ps->dr)) && (ntohl(ps->bdr)==0) &&
+ (ifa->state==OSPF_IS_WAITING))
+ {
+ /* FIXME BackupSeen */;
+ }
+ if((n->rid==ntohl(ps->dr)) && (n->dr!=ntohl(ps->dr)))
+ {
+ /* FIXME NeighborChange */;
+ }
+ if((n->rid==n->dr) && (n->dr!=ntohl(ps->dr)))
+ {
+ /* FIXME NeighborChange */;
+ }
+ n->dr=ntohl(ps->dr); /* And update it */
+
+ /* Check neighbor's backup designed router idea */
+ if((n->rid==ntohl(ps->bdr)) && (ifa->state==OSPF_IS_WAITING))
+ {
+ /* FIXME BackupSeen */;
+ }
+ if((n->rid==ntohl(ps->bdr)) && (n->bdr!=ntohl(ps->bdr)))
+ {
+ /* FIXME NeighborChange */;
+ }
+ if((n->rid==n->bdr) && (n->bdr!=ntohl(ps->bdr)))
+ {
+ /* FIXME NeighborChange */;
+ }
+ n->bdr=ntohl(ps->bdr); /* And update it */
+
+
switch(ifa->state)
{
case OSPF_IS_DOWN:
@@ -124,15 +209,39 @@ ospf_hello_rx(struct ospf_hello_packet *ps, struct proto *p,
break;
case OSPF_IS_WAITING:
DBG(p->name);
- DBG(": Neighbour? on iface ");
+ DBG(": Neighbor? on iface ");
DBG(ifa->iface->name);
DBG("\n");
break;
- case OSPF_IS_PTP:
case OSPF_IS_DROTHER:
+ if(twoway)
+ {
+ if((n->rid==n->dr) || (n->rid==n->bdr)) tryadj(n,p);
+ else n->state=NEIGHBOR_2WAY;
+ }
+ else
+ {
+ if(n->state==NEIGHBOR_2WAY) n->state=NEIGHBOR_INIT;
+ if(n->state>NEIGHBOR_2WAY)
+ {
+ /* FIXME Kill adjacency */;
+ n->state=NEIGHBOR_INIT;
+ }
+ }
+ break;
+ case OSPF_IS_PTP:
case OSPF_IS_BACKUP:
case OSPF_IS_DR:
- DBG("OSPF, RX, Unimplemented state.\n");
+ if(twoway) tryadj(n,p);
+ else
+ {
+ if(n->state==NEIGHBOR_2WAY) n->state=NEIGHBOR_INIT;
+ if(n->state>NEIGHBOR_2WAY)
+ {
+ /* FIXME Kill adjacency */;
+ n->state=NEIGHBOR_INIT;
+ }
+ }
break;
default:
die("%s: Iface %s in unknown state?",p->name, ifa->iface->name);
@@ -217,7 +326,7 @@ ospf_rx_hook(sock *sk, int size)
case HELLO:
DBG(p->name);
DBG(": Hello received.\n");
- ospf_hello_rx((struct ospf_hello_packet *)ps, p, ifa);
+ ospf_hello_rx((struct ospf_hello_packet *)ps, p, ifa, size);
break;
case DBDES:
break;