Added wait timer for eligible BCAST & NBMA interface.

2 files changed, 89 insertions, 13 deletions

diff --git a/proto/ospf/ospf.c b/proto/ospf/ospf.c
index 683ee66..0569af9 100644
--- a/proto/ospf/ospf.c
+++ b/proto/ospf/ospf.c
@@ -18,6 +18,7 @@
 #include "lib/ip.h"
 #include "lib/socket.h"
 #include "lib/lists.h"
+#include "lib/timer.h"
 
 #include "ospf.h"
 
@@ -67,6 +68,7 @@ ospf_open_socket(struct proto *p, struct ospf_iface *ifa)
     mcsk->err_hook=ospf_err_hook;
     mcsk->iface=(struct iface *)ifa;
     mcsk->rbsize=((struct iface *)ifa)->mtu;
+    mcsk->tbsize=((struct iface *)ifa)->mtu;
     if(sk_open(mcsk)!=0)
     {
       DBG(" OSPF: SK_OPEN: failed\n");
@@ -96,11 +98,45 @@ is_good_iface(struct proto *p, struct iface *iface)
 int
 ospf_iface_clasify(struct iface *ifa)
 {
+  /* FIXME: Latter I'll use config - this is incorrect */
   if((ifa->flags & (IF_MULTIACCESS|IF_MULTICAST))==
-    IF_MULTIACCESS|IF_MULTICAST) return OSPF_IM_BROADCAST;
+    (IF_MULTIACCESS|IF_MULTICAST))
+  {
+     DBG(" OSPF: Clasifying BROADCAST.\n");
+     return OSPF_IT_BROADCAST;
+  }
   if((ifa->flags & (IF_MULTIACCESS|IF_MULTICAST))==
-    IF_MULTIACCESS) return OSPF_IM_NBMA;
-  return OSPF_IM_PTP;
+    IF_MULTIACCESS)
+  {
+    DBG(" OSPF: Clasifying NBMA.\n");
+    return OSPF_IT_NBMA;
+  }
+  DBG(" OSPF: Clasifying P-T-P.\n");
+  return OSPF_IT_PTP;
+}
+
+void
+wait_timer_hook(timer *timer)
+{
+  debug(" OSPF: Wait timer expired for interface %s.\n",
+    ((struct iface *)timer->data)->name);
+}
+
+void
+add_wait_timer(struct ospf_iface *ifa,pool *pool, int wait)
+{
+  DBG(" OSPF: add_wait_timer called.\n");
+  if((ifa->type!=OSPF_IT_PTP) && (ifa->priority>0))
+  {
+    ifa->wait_timer=tm_new(pool);
+    ifa->wait_timer->hook=wait_timer_hook;
+    ifa->wait_timer->data=ifa;
+    ifa->wait_timer->randomize=0;
+    ifa->wait_timer->recurrent=0;
+    ifa->wait_timer->expires=0;
+    tm_start(ifa->wait_timer,(wait!=0 ? wait : WAIT_D));
+    DBG(" OSPF: Installing wait timer.\n");
+  }
 }
 
 void
@@ -125,11 +161,22 @@ ospf_iface_default(struct ospf_iface *ifa)
   ifa->type=ospf_iface_clasify((struct iface *)ifa);
 }
 
+struct ospf_iface*
+find_iface(struct proto_ospf *p, struct iface *what)
+{
+  struct ospf_iface *i;
+
+  WALK_LIST (i, p->iface_list)
+    if (((struct iface *)i)->index == what->index)
+      return i;
+  return NULL;
+}
+
 void
 ospf_if_notify(struct proto *p, unsigned flags, struct iface *new, struct iface *old)
 {
   struct ospf_iface *ifa;
-  sock *mcsk;
+  sock *mcsk, *newsk;
 
   struct ospf_config *c;
   c=(struct ospf_config *)(p->cf);
@@ -141,17 +188,34 @@ ospf_if_notify(struct proto *p, unsigned flags, struct iface *new, struct iface
   if(((flags & IF_CHANGE_UP)==IF_CHANGE_UP) && is_good_iface(p, new))
   {
     debug(" OSPF: using interface %s.\n", new->name);
-    /* Latter I'll use config - this is incorrect */
+    /* FIXME: Latter I'll use config - this is incorrect */
     ifa=mb_alloc(p->pool, sizeof(struct ospf_iface));
     bcopy(new, ifa, sizeof(struct ospf_iface));
-    add_tail(&c->iface_list, NODE ifa);
+    add_tail(&((struct proto_ospf *)p)->iface_list, NODE ifa);
     ospf_iface_default(ifa);
+    add_wait_timer(ifa,p->pool,0);
     init_list(&(ifa->sk_list));
     if((mcsk=ospf_open_socket(p, ifa))!=NULL)
     {
       add_tail(&(ifa->sk_list),NODE mcsk);
     }
   }
+
+  if((flags & IF_CHANGE_DOWN)==IF_CHANGE_DOWN)
+  {
+    if((ifa=find_iface((struct proto_ospf *)p, old))!=NULL)
+    {
+      debug(" OSPF: killing interface %s.\n", old->name);
+    }
+  }
+
+  if((flags & IF_CHANGE_MTU)==IF_CHANGE_MTU)
+  {
+    if((ifa=find_iface((struct proto_ospf *)p, old))!=NULL)
+    {
+      debug(" OSPF: changing MTU on interface %s.\n", old->name);
+    }
+  }
 }
 
 
@@ -178,12 +242,12 @@ ospf_dump(struct proto *p)
 static struct proto *
 ospf_init(struct proto_config *c)
 {
-  struct proto *p = proto_new(c, sizeof(struct proto));
+  struct proto *p = proto_new(c, sizeof(struct proto_ospf));
 
   DBG(" OSPF: Init.\n");
-  init_list(&((struct ospf_config *)c)->iface_list);
   p->neigh_notify = NULL;
   p->if_notify = NULL;
+  init_list(&((struct proto_ospf *)p)->iface_list);
   return p;
 }
 
diff --git a/proto/ospf/ospf.h b/proto/ospf/ospf.h
index b4809b7..324cdb1 100644
--- a/proto/ospf/ospf.h
+++ b/proto/ospf/ospf.h
@@ -22,7 +22,6 @@ struct ospf_config {
   struct proto_config c;
   u32 area;		/* Area ID  !!! This is wrong !!!
                          * Should respect interface */
-  list iface_list;
 };
 
 struct ospf_iface {
@@ -45,17 +44,26 @@ struct ospf_iface {
   ip_addr bdrip;	/* Backup DR */
   u32 bdrid;
   int type;		/* OSPF view of type */
-#define OSPF_IM_BROADCAST 0
-#define OSPF_IM_NBMA 1
-#define OSPF_IM_PTP 2
+#define OSPF_IT_BROADCAST 0
+#define OSPF_IT_NBMA 1
+#define OSPF_IT_PTP 2
+  int state;		/* Interface state machine */
+#define OSPF_IS_WAITING 0	/* Waiting for Wait timer */
+#define OSPF_IS_PTP 1		/* PTP operational */
+#define OSPF_IS_DROTHER 2	/* I'm on BCAST or NBMA and I'm not DR */
+#define OSPF_IS_BACKUP 3	/* I'm BDR */
+#define OSPF_IS_DR 4		/* I'm DR */
+  timer *wait_timer;		/* One shot Wait timer - used after DOWN->UP */
 
 /* Default values for interface parameters */
 #define COST_D 10
 #define RXMTINT_D 5
 #define IFTRANSDELAY_D 1
-#define PRIORITY_D 0
+#define PRIORITY_D 1
 #define HELLOINT_D 10
 #define DEADINT_D 4
+#define WAIT_D 40	/* Value of Wait timer - I didn't found it in RFC */
+
 };
 
 
@@ -66,5 +74,9 @@ struct ospf_patt {
   byte mode;
 };
 
+struct proto_ospf {
+  struct proto proto;
+  list iface_list;		/* Interfaces we really use */
+};
 
 #endif /* _BIRD_OSPF_H_ */