diff options
Diffstat (limited to 'proto/ospf')
| -rw-r--r-- | proto/ospf/ospf.c | 80 | ||||
| -rw-r--r-- | proto/ospf/ospf.h | 22 |
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_ */ |