337 lines
10 KiB
C
337 lines
10 KiB
C
/*
|
|
* Copyright (c) 1998 by the University of Oregon.
|
|
* All rights reserved.
|
|
*
|
|
* Permission to use, copy, modify, and distribute this software and
|
|
* its documentation in source and binary forms for lawful
|
|
* purposes and without fee is hereby granted, provided
|
|
* that the above copyright notice appear in all copies and that both
|
|
* the copyright notice and this permission notice appear in supporting
|
|
* documentation, and that any documentation, advertising materials,
|
|
* and other materials related to such distribution and use acknowledge
|
|
* that the software was developed by the University of Oregon.
|
|
* The name of the University of Oregon may not be used to endorse or
|
|
* promote products derived from this software without specific prior
|
|
* written permission.
|
|
*
|
|
* THE UNIVERSITY OF OREGON DOES NOT MAKE ANY REPRESENTATIONS
|
|
* ABOUT THE SUITABILITY OF THIS SOFTWARE FOR ANY PURPOSE. THIS SOFTWARE IS
|
|
* PROVIDED "AS IS" AND WITHOUT ANY EXPRESS OR IMPLIED WARRANTIES,
|
|
* INCLUDING, WITHOUT LIMITATION, THE IMPLIED WARRANTIES OF
|
|
* MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE, TITLE, AND
|
|
* NON-INFRINGEMENT.
|
|
*
|
|
* IN NO EVENT SHALL UO, OR ANY OTHER CONTRIBUTOR BE LIABLE FOR ANY
|
|
* SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES, WHETHER IN CONTRACT,
|
|
* TORT, OR OTHER FORM OF ACTION, ARISING OUT OF OR IN CONNECTION WITH,
|
|
* THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
*
|
|
* Other copyrights might apply to parts of this software and are so
|
|
* noted when applicable.
|
|
*/
|
|
/*
|
|
* Questions concerning this software should be directed to
|
|
* Kurt Windisch (kurtw@antc.uoregon.edu)
|
|
*
|
|
* $Id: timer.c,v 1.6 2000/10/05 22:20:38 itojun Exp $
|
|
*/
|
|
/*
|
|
* Part of this program has been derived from PIM sparse-mode pimd.
|
|
* The pimd program is covered by the license in the accompanying file
|
|
* named "LICENSE.pimd".
|
|
*
|
|
* The pimd program is COPYRIGHT 1998 by University of Southern California.
|
|
*
|
|
* Part of this program has been derived from mrouted.
|
|
* The mrouted program is covered by the license in the accompanying file
|
|
* named "LICENSE.mrouted".
|
|
*
|
|
* The mrouted program is COPYRIGHT 1989 by The Board of Trustees of
|
|
* Leland Stanford Junior University.
|
|
*
|
|
* $FreeBSD$
|
|
*/
|
|
|
|
#include "defs.h"
|
|
|
|
|
|
/*
|
|
* Global variables
|
|
*/
|
|
|
|
/*
|
|
* Local functions definitions.
|
|
*/
|
|
|
|
|
|
/*
|
|
* Local variables
|
|
*/
|
|
u_int16 unicast_routing_timer; /* Used to check periodically for any
|
|
* change in the unicast routing.
|
|
*/
|
|
u_int16 unicast_routing_check_interval;
|
|
u_int8 ucast_flag; /* Used to indicate there was a timeout */
|
|
|
|
|
|
/* to request and compare any route changes */
|
|
srcentry_t srcentry_save;
|
|
|
|
/*
|
|
* Init some timers
|
|
*/
|
|
void
|
|
init_timers()
|
|
{
|
|
unicast_routing_check_interval = UCAST_ROUTING_CHECK_INTERVAL;
|
|
unicast_routing_timer = unicast_routing_check_interval;
|
|
|
|
/* Initialize the srcentry used to save the old routes
|
|
* during unicast routing change discovery process.
|
|
*/
|
|
srcentry_save.prev = (srcentry_t *)NULL;
|
|
srcentry_save.next = (srcentry_t *)NULL;
|
|
memset(&srcentry_save.address, 0, sizeof(struct sockaddr_in6));
|
|
srcentry_save.address.sin6_len = sizeof(struct sockaddr_in6);
|
|
srcentry_save.address.sin6_family= AF_INET6;
|
|
srcentry_save.mrtlink = (mrtentry_t *)NULL;
|
|
srcentry_save.incoming = NO_VIF;
|
|
srcentry_save.upstream = (pim_nbr_entry_t *)NULL;
|
|
srcentry_save.metric = ~0;
|
|
srcentry_save.preference = ~0;
|
|
srcentry_save.timer = 0;
|
|
|
|
}
|
|
|
|
/*
|
|
* On every timer interrupt, advance (i.e. decrease) the timer for each
|
|
* neighbor and group entry for each vif.
|
|
*/
|
|
void
|
|
age_vifs()
|
|
{
|
|
vifi_t vifi;
|
|
register struct uvif *v;
|
|
register pim_nbr_entry_t *next_nbr, *curr_nbr;
|
|
|
|
/* XXX: TODO: currently, sending to qe* interface which is DOWN
|
|
* doesn't return error (ENETDOWN) on my Solaris machine,
|
|
* so have to check periodically the
|
|
* interfaces status. If this is fixed, just remove the defs around
|
|
* the "if (vifs_down)" line.
|
|
*/
|
|
|
|
#if (!((defined SunOS) && (SunOS >= 50)))
|
|
if (vifs_down)
|
|
#endif /* Solaris */
|
|
check_vif_state();
|
|
|
|
/* Age many things */
|
|
for (vifi = 0, v = uvifs; vifi < numvifs; ++vifi, ++v) {
|
|
if (v->uv_flags & (VIFF_DISABLED | VIFF_DOWN))
|
|
continue;
|
|
|
|
/* Timeout the MLD querier (unless we re the querier) */
|
|
if ((v->uv_flags & VIFF_QUERIER) == 0 &&
|
|
v->uv_querier) { /* this must be non-NULL, but check for safety. */
|
|
IF_TIMEOUT(v->uv_querier->al_timer) {
|
|
/* act as a querier by myself */
|
|
v->uv_flags |= VIFF_QUERIER;
|
|
v->uv_querier->al_addr = v->uv_linklocal->pa_addr;
|
|
v->uv_querier->al_timer = MLD6_OTHER_QUERIER_PRESENT_INTERVAL;
|
|
time(&v->uv_querier->al_ctime); /* reset timestamp */
|
|
query_groups(v);
|
|
}
|
|
}
|
|
|
|
/* Timeout neighbors */
|
|
for (curr_nbr = v->uv_pim_neighbors; curr_nbr != NULL;
|
|
curr_nbr = next_nbr) {
|
|
next_nbr = curr_nbr->next;
|
|
/*
|
|
* Never timeout neighbors with holdtime = 0xffff.
|
|
* This may be used with ISDN lines to avoid keeping the
|
|
* link up with periodic Hello messages.
|
|
*/
|
|
if (PIM_MESSAGE_HELLO_HOLDTIME_FOREVER == curr_nbr->timer)
|
|
continue;
|
|
IF_NOT_TIMEOUT(curr_nbr->timer)
|
|
continue;
|
|
|
|
delete_pim6_nbr(curr_nbr);
|
|
}
|
|
|
|
/* PIM_HELLO periodic */
|
|
IF_TIMEOUT(v->uv_pim_hello_timer)
|
|
send_pim6_hello(v, PIM_TIMER_HELLO_HOLDTIME);
|
|
|
|
/* MLD query periodic */
|
|
IF_TIMEOUT(v->uv_gq_timer)
|
|
query_groups(v);
|
|
}
|
|
|
|
IF_DEBUG(DEBUG_IF) {
|
|
dump_vifs(stderr);
|
|
dump_lcl_grp(stderr);
|
|
}
|
|
}
|
|
|
|
|
|
/*
|
|
* Scan the whole routing table and timeout a bunch of timers:
|
|
* - prune timers
|
|
* - Join/Prune delay timer
|
|
* - routing entry
|
|
* - Assert timer
|
|
*/
|
|
void
|
|
age_routes()
|
|
{
|
|
mrtentry_t *mrtentry_ptr, *mrtentry_next;
|
|
grpentry_t *grpentry_ptr, *grpentry_next;
|
|
vifi_t vifi;
|
|
int change_flag, state_change;
|
|
int update_src_iif;
|
|
u_long curr_bytecnt;
|
|
|
|
/*
|
|
* Timing out of the global `unicast_routing_timer` and data rate timer
|
|
*/
|
|
IF_TIMEOUT(unicast_routing_timer) {
|
|
ucast_flag = TRUE;
|
|
unicast_routing_timer = unicast_routing_check_interval;
|
|
}
|
|
ELSE {
|
|
ucast_flag = FALSE;
|
|
}
|
|
|
|
/* Walk the (S,G) entries */
|
|
if(grplist == (grpentry_t *)NULL)
|
|
return;
|
|
for(grpentry_ptr = grplist;
|
|
grpentry_ptr != (grpentry_t *)NULL;
|
|
grpentry_ptr = grpentry_next) {
|
|
grpentry_next = grpentry_ptr->next;
|
|
|
|
for(mrtentry_ptr = grpentry_ptr->mrtlink;
|
|
mrtentry_ptr != (mrtentry_t *)NULL;
|
|
mrtentry_ptr = mrtentry_next) {
|
|
mrtentry_next = mrtentry_ptr->grpnext;
|
|
|
|
/* Refresh entry timer if data forwarded */
|
|
curr_bytecnt = mrtentry_ptr->sg_count.bytecnt;
|
|
if (k_get_sg_cnt(udp_socket,
|
|
&mrtentry_ptr->source->address,
|
|
&mrtentry_ptr->group->group,
|
|
&mrtentry_ptr->sg_count)) {
|
|
/* No such routing entry in kernel */
|
|
delete_mrtentry(mrtentry_ptr);
|
|
continue;
|
|
}
|
|
if(!(IF_ISEMPTY(&mrtentry_ptr->oifs)) &&
|
|
curr_bytecnt != mrtentry_ptr->sg_count.bytecnt) {
|
|
/* Packets have been forwarded - refresh timer
|
|
* Note that these counters count packets received,
|
|
* not packets forwarded. So only refresh if packets
|
|
* received and non-null oiflist.
|
|
*/
|
|
IF_DEBUG(DEBUG_MFC)
|
|
log(LOG_DEBUG, 0,
|
|
"Refreshing src %s, dst %s after %ld bytes forwarded",
|
|
inet6_fmt(&mrtentry_ptr->source->address.sin6_addr),
|
|
inet6_fmt(&mrtentry_ptr->group->group.sin6_addr),
|
|
mrtentry_ptr->sg_count.bytecnt);
|
|
SET_TIMER(mrtentry_ptr->timer, PIM_DATA_TIMEOUT);
|
|
}
|
|
|
|
/* Time out the entry */
|
|
IF_TIMEOUT(mrtentry_ptr->timer) {
|
|
delete_mrtentry(mrtentry_ptr);
|
|
continue;
|
|
}
|
|
|
|
/* Time out asserts */
|
|
if(mrtentry_ptr->flags & MRTF_ASSERTED)
|
|
IF_TIMEOUT(mrtentry_ptr->assert_timer) {
|
|
mrtentry_ptr->flags &= ~MRTF_ASSERTED;
|
|
mrtentry_ptr->upstream = mrtentry_ptr->source->upstream;
|
|
mrtentry_ptr->metric = mrtentry_ptr->source->metric;
|
|
mrtentry_ptr->preference = mrtentry_ptr->source->preference;
|
|
}
|
|
|
|
/* Time out Pruned interfaces */
|
|
change_flag = FALSE;
|
|
for (vifi = 0; vifi < numvifs; vifi++) {
|
|
if (IF_ISSET(vifi, &mrtentry_ptr->pruned_oifs))
|
|
IF_TIMEOUT(mrtentry_ptr->prune_timers[vifi]) {
|
|
IF_CLR(vifi, &mrtentry_ptr->pruned_oifs);
|
|
SET_TIMER(mrtentry_ptr->prune_timers[vifi], 0);
|
|
change_flag = TRUE;
|
|
}
|
|
}
|
|
|
|
/* Unicast Route changes */
|
|
update_src_iif = FALSE;
|
|
if (ucast_flag == TRUE) {
|
|
/* iif toward the source */
|
|
srcentry_save.incoming = mrtentry_ptr->source->incoming;
|
|
srcentry_save.upstream = mrtentry_ptr->source->upstream;
|
|
srcentry_save.preference = mrtentry_ptr->source->preference;
|
|
srcentry_save.metric = mrtentry_ptr->source->metric;
|
|
|
|
if (set_incoming(mrtentry_ptr->source,
|
|
PIM_IIF_SOURCE) != TRUE) {
|
|
/*
|
|
* XXX: not in the spec!
|
|
* Cannot find route toward that source.
|
|
* This is bad. Delete the entry.
|
|
*/
|
|
delete_mrtentry(mrtentry_ptr);
|
|
continue;
|
|
}
|
|
else {
|
|
/* iif info found */
|
|
if (!(mrtentry_ptr->flags & MRTF_ASSERTED) &&
|
|
((srcentry_save.incoming !=
|
|
mrtentry_ptr->incoming)
|
|
|| (srcentry_save.upstream !=
|
|
mrtentry_ptr->upstream))) {
|
|
/* Route change has occur */
|
|
update_src_iif = TRUE;
|
|
mrtentry_ptr->incoming =
|
|
mrtentry_ptr->source->incoming;
|
|
mrtentry_ptr->upstream =
|
|
mrtentry_ptr->source->upstream;
|
|
/* mrtentry should have pref/metric of upstream
|
|
* assert winner, but we dont have that info,
|
|
* so use the source pref/metric, which will be
|
|
* larger and thus the correct assert winner
|
|
* from upstream will be chosen.
|
|
*/
|
|
mrtentry_ptr->preference =
|
|
mrtentry_ptr->source->preference;
|
|
mrtentry_ptr->metric =
|
|
mrtentry_ptr->source->metric;
|
|
}
|
|
}
|
|
}
|
|
|
|
if ((change_flag == TRUE) || (update_src_iif == TRUE)) {
|
|
/* Flush the changes */
|
|
state_change =
|
|
change_interfaces(mrtentry_ptr,
|
|
mrtentry_ptr->incoming,
|
|
&mrtentry_ptr->pruned_oifs,
|
|
&mrtentry_ptr->leaves,
|
|
&mrtentry_ptr->asserted_oifs);
|
|
if(state_change == -1)
|
|
trigger_prune_alert(mrtentry_ptr);
|
|
}
|
|
}
|
|
}
|
|
|
|
IF_DEBUG(DEBUG_PIM_MRT)
|
|
dump_pim_mrt(stderr);
|
|
return;
|
|
}
|