summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--proto/ospf/ospf.c80
-rw-r--r--proto/ospf/ospf.h22
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_ */
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-04 22:14:51 +0100