Removes timers for stub interfaces. Also fixes some minor bugs.

This commit is contained in:
Ondrej Zajicek 2011-07-07 17:43:39 +02:00
parent 7d4e923603
commit beeda6af44
4 changed files with 50 additions and 49 deletions

View file

@ -217,15 +217,14 @@ ospf_hello_receive(struct ospf_packet *ps_i, struct ospf_iface *ifa,
if (ifa->type == OSPF_IT_NBMA) if (ifa->type == OSPF_IT_NBMA)
{ {
if ((ifa->priority == 0) && (n->priority > 0)) if ((ifa->priority == 0) && (n->priority > 0))
ospf_hello_send(NULL, OHS_HELLO, n); ospf_hello_send(n->ifa, OHS_HELLO, n);
} }
ospf_neigh_sm(n, INM_HELLOREC); ospf_neigh_sm(n, INM_HELLOREC);
} }
void void
ospf_hello_send(timer *timer, int kind, struct ospf_neighbor *dirn) ospf_hello_send(struct ospf_iface *ifa, int kind, struct ospf_neighbor *dirn)
{ {
struct ospf_iface *ifa;
struct ospf_hello_packet *pkt; struct ospf_hello_packet *pkt;
struct ospf_packet *op; struct ospf_packet *op;
struct proto *p; struct proto *p;
@ -234,11 +233,6 @@ ospf_hello_send(timer *timer, int kind, struct ospf_neighbor *dirn)
int i; int i;
struct nbma_node *nb; struct nbma_node *nb;
if (timer == NULL)
ifa = dirn->ifa;
else
ifa = (struct ospf_iface *) timer->data;
if (ifa->state <= OSPF_IS_LOOP) if (ifa->state <= OSPF_IS_LOOP)
return; return;
@ -313,7 +307,7 @@ ospf_hello_send(timer *timer, int kind, struct ospf_neighbor *dirn)
break; break;
case OSPF_IT_NBMA: case OSPF_IT_NBMA:
if (timer == NULL) /* Response to received hello */ if (dirn) /* Response to received hello */
{ {
ospf_send_to(ifa, dirn->ip); ospf_send_to(ifa, dirn->ip);
break; break;

View file

@ -12,7 +12,7 @@
void ospf_hello_receive(struct ospf_packet *ps_i, struct ospf_iface *ifa, void ospf_hello_receive(struct ospf_packet *ps_i, struct ospf_iface *ifa,
struct ospf_neighbor *n, ip_addr faddr); struct ospf_neighbor *n, ip_addr faddr);
void ospf_hello_send(timer *timer, int kind, struct ospf_neighbor *dirn); void ospf_hello_send(struct ospf_iface *ifa, int kind, struct ospf_neighbor *dirn);
#define OHS_HELLO 0 #define OHS_HELLO 0
#define OHS_POLL 1 #define OHS_POLL 1

View file

@ -21,13 +21,13 @@ char *ospf_it[] = { "broadcast", "nbma", "ptp", "ptmp", "virtual link" };
static void static void
poll_timer_hook(timer * timer) poll_timer_hook(timer * timer)
{ {
ospf_hello_send(timer, OHS_POLL, NULL); ospf_hello_send(timer->data, OHS_POLL, NULL);
} }
static void static void
hello_timer_hook(timer * timer) hello_timer_hook(timer * timer)
{ {
ospf_hello_send(timer, OHS_HELLO, NULL); ospf_hello_send(timer->data, OHS_HELLO, NULL);
} }
static void static void
@ -232,7 +232,7 @@ void
ospf_iface_shutdown(struct ospf_iface *ifa) ospf_iface_shutdown(struct ospf_iface *ifa)
{ {
if (ifa->state > OSPF_IS_DOWN) if (ifa->state > OSPF_IS_DOWN)
ospf_hello_send(ifa->hello_timer, OHS_SHUTDOWN, NULL); ospf_hello_send(ifa, OHS_SHUTDOWN, NULL);
} }
/** /**
@ -323,16 +323,18 @@ ospf_iface_sm(struct ospf_iface *ifa, int event)
else else
{ {
ospf_iface_chstate(ifa, OSPF_IS_WAITING); ospf_iface_chstate(ifa, OSPF_IS_WAITING);
tm_start(ifa->wait_timer, ifa->waitint); if (ifa->wait_timer)
tm_start(ifa->wait_timer, ifa->waitint);
} }
} }
tm_start(ifa->hello_timer, ifa->helloint); if (ifa->hello_timer)
tm_start(ifa->hello_timer, ifa->helloint);
if (ifa->poll_timer) if (ifa->poll_timer)
tm_start(ifa->poll_timer, ifa->pollint); tm_start(ifa->poll_timer, ifa->pollint);
hello_timer_hook(ifa->hello_timer); ospf_hello_send(ifa, OHS_HELLO, NULL);
schedule_link_lsa(ifa); schedule_link_lsa(ifa);
} }
break; break;
@ -424,6 +426,17 @@ ospf_iface_add(struct object_lock *lock)
ifa->stub = 1; ifa->stub = 1;
} }
if (! ifa->stub)
{
ifa->hello_timer = tm_new_set(ifa->pool, hello_timer_hook, ifa, 0, ifa->helloint);
if (ifa->type == OSPF_IT_NBMA)
ifa->poll_timer = tm_new_set(ifa->pool, poll_timer_hook, ifa, 0, ifa->pollint);
if ((ifa->type == OSPF_IT_BCAST) || (ifa->type == OSPF_IT_NBMA))
ifa->wait_timer = tm_new_set(ifa->pool, wait_timer_hook, ifa, 0, 0);
}
/* Do iface UP, unless there is no link and we use link detection */ /* Do iface UP, unless there is no link and we use link detection */
ospf_iface_sm(ifa, (ifa->check_link && !(ifa->iface->flags & IF_LINK_UP)) ? ISM_LOOP : ISM_UP); ospf_iface_sm(ifa, (ifa->check_link && !(ifa->iface->flags & IF_LINK_UP)) ? ISM_LOOP : ISM_UP);
} }
@ -548,33 +561,6 @@ ospf_iface_new(struct ospf_area *oa, struct ifa *addr, struct ospf_iface_patt *i
if (ipa_in_net(nb->ip, addr->prefix, addr->pxlen)) if (ipa_in_net(nb->ip, addr->prefix, addr->pxlen))
add_nbma_node(ifa, nb, 0); add_nbma_node(ifa, nb, 0);
DBG("%s: Installing hello timer. (%u)\n", p->name, ifa->helloint);
ifa->hello_timer = tm_new(pool);
ifa->hello_timer->data = ifa;
ifa->hello_timer->randomize = 0;
ifa->hello_timer->hook = hello_timer_hook;
ifa->hello_timer->recurrent = ifa->helloint;
if (ifa->type == OSPF_IT_NBMA)
{
DBG("%s: Installing poll timer. (%u)\n", p->name, ifa->pollint);
ifa->poll_timer = tm_new(pool);
ifa->poll_timer->data = ifa;
ifa->poll_timer->randomize = 0;
ifa->poll_timer->hook = poll_timer_hook;
ifa->poll_timer->recurrent = ifa->pollint;
}
if ((ifa->type == OSPF_IT_BCAST) || (ifa->type == OSPF_IT_NBMA))
{
DBG("%s: Installing wait timer. (%u)\n", p->name, ifa->waitint);
ifa->wait_timer = tm_new(pool);
ifa->wait_timer->data = ifa;
ifa->wait_timer->randomize = 0;
ifa->wait_timer->hook = wait_timer_hook;
ifa->wait_timer->recurrent = 0;
}
ifa->state = OSPF_IS_DOWN; ifa->state = OSPF_IS_DOWN;
add_tail(&oa->po->iface_list, NODE ifa); add_tail(&oa->po->iface_list, NODE ifa);
@ -607,6 +593,18 @@ ospf_iface_new(struct ospf_area *oa, struct ifa *addr, struct ospf_iface_patt *i
olock_acquire(lock); olock_acquire(lock);
} }
static void
ospf_iface_change_timer(timer *tm, unsigned val)
{
if (!tm)
return;
tm->recurrent = val;
if (tm->expires)
tm_start(tm, val);
}
int int
ospf_iface_reconfigure(struct ospf_iface *ifa, struct ospf_iface_patt *new) ospf_iface_reconfigure(struct ospf_iface *ifa, struct ospf_iface_patt *new)
{ {
@ -636,8 +634,7 @@ ospf_iface_reconfigure(struct ospf_iface *ifa, struct ospf_iface_patt *new)
ifname, ifa->helloint, new->helloint); ifname, ifa->helloint, new->helloint);
ifa->helloint = new->helloint; ifa->helloint = new->helloint;
ifa->hello_timer->recurrent = ifa->helloint; ospf_iface_change_timer(ifa->hello_timer, ifa->helloint);
tm_start(ifa->hello_timer, ifa->helloint);
} }
/* RXMT TIMER */ /* RXMT TIMER */
@ -655,9 +652,8 @@ ospf_iface_reconfigure(struct ospf_iface *ifa, struct ospf_iface_patt *new)
OSPF_TRACE(D_EVENTS, "Changing poll interval on interface %s from %d to %d", OSPF_TRACE(D_EVENTS, "Changing poll interval on interface %s from %d to %d",
ifname, ifa->pollint, new->pollint); ifname, ifa->pollint, new->pollint);
ifa->pollint = new->helloint; ifa->pollint = new->pollint;
ifa->poll_timer->recurrent = ifa->pollint; ospf_iface_change_timer(ifa->poll_timer, ifa->pollint);
tm_start(ifa->poll_timer, ifa->pollint);
} }
/* WAIT TIMER */ /* WAIT TIMER */
@ -667,7 +663,7 @@ ospf_iface_reconfigure(struct ospf_iface *ifa, struct ospf_iface_patt *new)
ifname, ifa->waitint, new->waitint); ifname, ifa->waitint, new->waitint);
ifa->waitint = new->waitint; ifa->waitint = new->waitint;
if (ifa->wait_timer->expires != 0) if (ifa->wait_timer && ifa->wait_timer->expires)
tm_start(ifa->wait_timer, ifa->waitint); tm_start(ifa->wait_timer, ifa->waitint);
} }

View file

@ -30,6 +30,17 @@ void tm_start(timer *, unsigned after);
void tm_stop(timer *); void tm_stop(timer *);
void tm_dump_all(void); void tm_dump_all(void);
static inline timer *
tm_new_set(pool *p, void (*hook)(struct timer *), void *data, unsigned rand, unsigned rec)
{
timer *t = tm_new(p);
t->hook = hook;
t->data = data;
t->randomize = rand;
t->recurrent = rec;
return t;
}
extern bird_clock_t now; /* Relative, monotonic time in seconds */ extern bird_clock_t now; /* Relative, monotonic time in seconds */
extern bird_clock_t now_real; /* Time in seconds since fixed known epoch */ extern bird_clock_t now_real; /* Time in seconds since fixed known epoch */