bird/proto/ospf/hello.c

274 lines
6.5 KiB
C
Raw Normal View History

/*
* BIRD -- OSPF
*
* (c) 1999 Ondrej Filip <feela@network.cz>
*
* Can be freely distributed and used under the terms of the GNU GPL.
*/
#include "ospf.h"
void
install_inactim(struct ospf_neighbor *n)
{
struct proto *p;
struct ospf_iface *ifa;
ifa=n->ifa;
p=(struct proto *)(ifa->proto);
if(n->inactim==NULL)
{
n->inactim=tm_new(p->pool);
n->inactim->data=n;
n->inactim->randomize=0;
n->inactim->hook=neighbor_timer_hook;
n->inactim->recurrent=0;
DBG("%s: Installing inactivity timer.\n", p->name);
}
}
void
restart_inactim(struct ospf_neighbor *n)
{
tm_start(n->inactim,n->ifa->deadc*n->ifa->helloint);
}
void
restart_hellotim(struct ospf_iface *ifa)
{
tm_start(ifa->hello_timer,ifa->helloint);
}
void
restart_waittim(struct ospf_iface *ifa)
{
tm_start(ifa->wait_timer,ifa->waitint);
}
void
ospf_hello_rx(struct ospf_hello_packet *ps, struct proto *p,
struct ospf_iface *ifa, int size, ip_addr faddr)
{
u32 nrid, *pnrid;
struct ospf_neighbor *neigh,*n;
u8 i,twoway,oldpriority;
u32 olddr,oldbdr;
char *beg=": Bad OSPF hello packet from ", *rec=" received: ";
nrid=ntohl(((struct ospf_packet *)ps)->routerid);
2000-06-06 10:34:57 +08:00
OSPF_TRACE(D_PACKETS, "Received hello from %I via %s",faddr,ifa->iface->name);
2000-05-11 07:42:13 +08:00
if((unsigned)ipa_mklen(ipa_ntoh(ps->netmask))!=ifa->iface->addr->pxlen)
{
log("%s%s%I%s%Ibad netmask %I.", p->name, beg, nrid, rec,
ipa_ntoh(ps->netmask));
return;
}
if(ntohs(ps->helloint)!=ifa->helloint)
{
log("%s%s%I%shello interval mismatch.", p->name, beg, faddr, rec);
return;
}
if(ntohl(ps->deadint)!=ifa->helloint*ifa->deadc)
{
log("%s%s%I%sdead interval mismatch.", p->name, beg, faddr, rec);
return;
}
if(ps->options!=ifa->options)
{
log("%s%s%I%soptions mismatch.", p->name, beg, faddr, rec);
return;
}
if((n=find_neigh(ifa, nrid))==NULL)
{
2000-06-06 10:34:57 +08:00
OSPF_TRACE(D_EVENTS, "New neighbor found: %I on %s.", faddr,
2000-05-11 07:42:13 +08:00
ifa->iface->name);
2000-05-09 06:24:22 +08:00
n=mb_allocz(p->pool, sizeof(struct ospf_neighbor));
add_tail(&ifa->neigh_list, NODE n);
n->rid=nrid;
n->ip=faddr;
n->dr=ntohl(ps->dr);
n->bdr=ntohl(ps->bdr);
n->priority=ps->priority;
n->options=ps->options;
n->ifa=ifa;
n->adj=0;
n->ldbdes=mb_alloc(p->pool, ifa->iface->mtu);
2000-05-09 06:24:22 +08:00
n->state=NEIGHBOR_DOWN;
install_inactim(n);
n->rxmt_timer=tm_new(p->pool);
n->rxmt_timer->data=n;
n->rxmt_timer->randomize=0;
n->rxmt_timer->hook=rxmt_timer_hook;
n->rxmt_timer->recurrent=ifa->rxmtint;
DBG("%s: Installing rxmt timer.\n", p->name);
2000-03-30 08:18:59 +08:00
n->lsrr_timer=tm_new(p->pool);
n->lsrr_timer->data=n;
n->lsrr_timer->randomize=0;
n->lsrr_timer->hook=lsrr_timer_hook;
n->lsrr_timer->recurrent=ifa->rxmtint;
DBG("%s: Installing lsrr timer.\n", p->name);
init_list(&n->ackl);
n->ackd_timer=tm_new(p->pool);
n->ackd_timer->data=n;
n->ackd_timer->randomize=0;
n->ackd_timer->hook=ackd_timer_hook;
n->ackd_timer->recurrent=ifa->rxmtint/2; /* FIXME use some config? */
DBG("%s: Installing ackd timer.\n", p->name);
}
ospf_neigh_sm(n, INM_HELLOREC);
pnrid=(u32 *)((struct ospf_hello_packet *)(ps+1));
twoway=0;
for(i=0;i<size-(sizeof(struct ospf_hello_packet));i++)
{
if(ntohl(*(pnrid+i))==p->cf->global->router_id)
{
2000-05-11 07:42:13 +08:00
DBG("%s: Twoway received from %I\n", p->name, faddr);
ospf_neigh_sm(n, INM_2WAYREC);
twoway=1;
break;
}
}
if(!twoway) ospf_neigh_sm(n, INM_1WAYREC);
olddr = n->dr;
n->dr = ntohl(ps->dr);
oldbdr = n->bdr;
n->bdr = ntohl(ps->bdr);
oldpriority = n->priority;
n->priority = ps->priority;
/* Check priority change */
if(n->state>=NEIGHBOR_2WAY)
{
if(n->priority!=oldpriority) ospf_int_sm(ifa, ISM_NEICH);
/* Router is declaring itself ad DR and there is no BDR */
2000-05-10 02:35:57 +08:00
if((n->rid==n->dr) && (n->bdr==0) && (n->state!=NEIGHBOR_FULL))
ospf_int_sm(ifa, ISM_BACKS);
/* Neighbor is declaring itself as BDR */
2000-05-10 02:35:57 +08:00
if((n->rid==n->bdr) && (n->state!=NEIGHBOR_FULL))
ospf_int_sm(ifa, ISM_BACKS);
/* Neighbor is newly declaring itself as DR or BDR */
if(((n->rid==n->dr) && (n->dr!=olddr)) || ((n->rid==n->bdr) &&
(n->bdr!=oldbdr)))
ospf_int_sm(ifa, ISM_NEICH);
/* Neighbor is no more declaring itself as DR or BDR */
2000-05-09 19:29:52 +08:00
if(((n->rid==olddr) && (n->dr!=olddr)) || ((n->rid==oldbdr) &&
2000-05-09 20:02:48 +08:00
(n->bdr!=oldbdr)))
ospf_int_sm(ifa, ISM_NEICH);
}
ospf_neigh_sm(n, INM_HELLOREC);
}
void
hello_timer_hook(timer *timer)
{
struct ospf_iface *ifa;
struct ospf_hello_packet *pkt;
struct ospf_packet *op;
struct proto *p;
struct ospf_neighbor *neigh;
u16 length;
u32 *pp;
u8 i;
ifa=(struct ospf_iface *)timer->data;
p=(struct proto *)(ifa->proto);
DBG("%s: Hello timer fired on interface %s.\n",
p->name, ifa->iface->name);
/* Now we should send a hello packet */
/* First a common packet header */
if(ifa->type!=OSPF_IT_NBMA)
{
pkt=(struct ospf_hello_packet *)(ifa->hello_sk->tbuf);
2000-06-06 07:44:26 +08:00
}
else
{
pkt=(struct ospf_hello_packet *)(ifa->ip_sk->tbuf);
}
2000-06-06 07:44:26 +08:00
/* Now fill ospf_hello header */
op=(struct ospf_packet *)pkt;
2000-06-06 07:44:26 +08:00
fill_ospf_pkt_hdr(ifa, pkt, HELLO_P);
pkt->netmask=ipa_mkmask(ifa->iface->addr->pxlen);
ipa_hton(pkt->netmask);
pkt->helloint=ntohs(ifa->helloint);
pkt->options=ifa->options;
pkt->priority=ifa->priority;
pkt->deadint=htonl(ifa->deadc*ifa->helloint);
pkt->dr=htonl(ifa->drid);
pkt->bdr=htonl(ifa->bdrid);
/* Fill all neighbors */
i=0;
pp=(u32 *)(((u8 *)pkt)+sizeof(struct ospf_hello_packet));
WALK_LIST (neigh, ifa->neigh_list)
{
*(pp+i)=htonl(neigh->rid);
i++;
}
length=sizeof(struct ospf_hello_packet)+i*sizeof(u32);
op->length=htons(length);
ospf_pkt_finalize(ifa, op);
/* And finally send it :-) */
2000-06-06 07:44:26 +08:00
if(ifa->type!=OSPF_IT_NBMA)
{
sk_send(ifa->hello_sk,length);
}
2000-06-06 07:44:26 +08:00
else /* NBMA */
{
struct ospf_neighbor *n1;
struct nbma_node *nb;
int send;
2000-05-11 07:42:13 +08:00
2000-06-06 07:44:26 +08:00
WALK_LIST(nb,ifa->nbma_list)
{
send=1;
WALK_LIST(n1, ifa->neigh_list)
{
if(ipa_compare(nb->ip,n1->ip)==0)
{
send=0;
break;
}
}
if(send) sk_send_to(ifa->ip_sk, length, nb->ip, OSPF_PROTO);
}
sk_send_to_agt(ifa->ip_sk, length, ifa, NEIGHBOR_DOWN);
}
2000-06-06 10:34:57 +08:00
OSPF_TRACE(D_PACKETS, "Hello sent via %s",ifa->iface->name);
}
void
wait_timer_hook(timer *timer)
{
struct ospf_iface *ifa;
struct proto *p;
ifa=(struct ospf_iface *)timer->data;
p=(struct proto *)(ifa->proto);
2000-06-06 10:50:49 +08:00
OSPF_TRACE(D_EVENTS, "Wait timer fired on interface %s.",
ifa->iface->name);
ospf_int_sm(ifa, ISM_WAITF);
}