mirror of
https://git.proxmox.com/git/mirror_frr
synced 2025-10-31 05:25:56 +00:00
c992c9a0c0
The linux kernel wants a pimreg vif device. The pimd code wants a 'struct interface *' for anything it works with. Since the pimreg vif device is not a real linux device that zebra knows about. Cheat by creating a pimreg interface pointer and setup the code to properly be able to handle the registration of the vif device. Signed-off-by: Donald Sharp <sharpd@cumulusnetworks.com>
281 lines
9.0 KiB
C
281 lines
9.0 KiB
C
/*
|
|
PIM for Quagga
|
|
Copyright (C) 2008 Everton da Silva Marques
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful, but
|
|
WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; see the file COPYING; if not, write to the
|
|
Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston,
|
|
MA 02110-1301 USA
|
|
|
|
$QuaggaId: $Format:%an, %ai, %h$ $
|
|
*/
|
|
|
|
#include <zebra.h>
|
|
|
|
#include "log.h"
|
|
#include "memory.h"
|
|
#include "linklist.h"
|
|
|
|
#include "pimd.h"
|
|
#include "pim_oil.h"
|
|
#include "pim_str.h"
|
|
#include "pim_iface.h"
|
|
#include "pim_time.h"
|
|
|
|
void pim_channel_oil_free(struct channel_oil *c_oil)
|
|
{
|
|
XFREE(MTYPE_PIM_CHANNEL_OIL, c_oil);
|
|
}
|
|
|
|
static void pim_channel_oil_delete(struct channel_oil *c_oil)
|
|
{
|
|
/*
|
|
notice that listnode_delete() can't be moved
|
|
into pim_channel_oil_free() because the later is
|
|
called by list_delete_all_node()
|
|
*/
|
|
listnode_delete(qpim_channel_oil_list, c_oil);
|
|
|
|
pim_channel_oil_free(c_oil);
|
|
}
|
|
|
|
static struct channel_oil *channel_oil_new(struct in_addr group_addr,
|
|
struct in_addr source_addr,
|
|
int input_vif_index)
|
|
{
|
|
struct channel_oil *c_oil;
|
|
struct interface *ifp_in;
|
|
|
|
ifp_in = pim_if_find_by_vif_index(input_vif_index);
|
|
if (!ifp_in) {
|
|
/* warning only */
|
|
char group_str[100];
|
|
char source_str[100];
|
|
pim_inet4_dump("<group?>", group_addr, group_str, sizeof(group_str));
|
|
pim_inet4_dump("<source?>", source_addr, source_str, sizeof(source_str));
|
|
zlog_warn("%s: (S,G)=(%s,%s) could not find input interface for input_vif_index=%d",
|
|
__PRETTY_FUNCTION__,
|
|
source_str, group_str, input_vif_index);
|
|
}
|
|
|
|
c_oil = XCALLOC(MTYPE_PIM_CHANNEL_OIL, sizeof(*c_oil));
|
|
if (!c_oil) {
|
|
zlog_err("PIM XCALLOC(%zu) failure", sizeof(*c_oil));
|
|
return 0;
|
|
}
|
|
|
|
c_oil->oil.mfcc_mcastgrp = group_addr;
|
|
c_oil->oil.mfcc_origin = source_addr;
|
|
c_oil->oil.mfcc_parent = input_vif_index;
|
|
c_oil->oil_ref_count = 1;
|
|
|
|
zassert(c_oil->oil_size == 0);
|
|
|
|
return c_oil;
|
|
}
|
|
|
|
static struct channel_oil *pim_add_channel_oil(struct in_addr group_addr,
|
|
struct in_addr source_addr,
|
|
int input_vif_index)
|
|
{
|
|
struct channel_oil *c_oil;
|
|
|
|
c_oil = channel_oil_new(group_addr, source_addr, input_vif_index);
|
|
if (!c_oil) {
|
|
zlog_warn("PIM XCALLOC(%zu) failure", sizeof(*c_oil));
|
|
return 0;
|
|
}
|
|
|
|
listnode_add(qpim_channel_oil_list, c_oil);
|
|
|
|
return c_oil;
|
|
}
|
|
|
|
static struct channel_oil *pim_find_channel_oil(struct in_addr group_addr,
|
|
struct in_addr source_addr)
|
|
{
|
|
struct listnode *node;
|
|
struct channel_oil *c_oil;
|
|
|
|
for (ALL_LIST_ELEMENTS_RO(qpim_channel_oil_list, node, c_oil)) {
|
|
if ((group_addr.s_addr == c_oil->oil.mfcc_mcastgrp.s_addr) &&
|
|
(source_addr.s_addr == c_oil->oil.mfcc_origin.s_addr))
|
|
return c_oil;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
struct channel_oil *pim_channel_oil_add(struct in_addr group_addr,
|
|
struct in_addr source_addr,
|
|
int input_vif_index)
|
|
{
|
|
struct channel_oil *c_oil;
|
|
|
|
c_oil = pim_find_channel_oil(group_addr, source_addr);
|
|
if (c_oil) {
|
|
++c_oil->oil_ref_count;
|
|
return c_oil;
|
|
}
|
|
|
|
return pim_add_channel_oil(group_addr, source_addr, input_vif_index);
|
|
}
|
|
|
|
void pim_channel_oil_del(struct channel_oil *c_oil)
|
|
{
|
|
--c_oil->oil_ref_count;
|
|
|
|
if (c_oil->oil_ref_count < 1) {
|
|
pim_channel_oil_delete(c_oil);
|
|
}
|
|
}
|
|
|
|
int pim_channel_add_oif(struct channel_oil *channel_oil,
|
|
struct interface *oif,
|
|
uint32_t proto_mask)
|
|
{
|
|
struct pim_interface *pim_ifp;
|
|
int old_ttl;
|
|
|
|
zassert(channel_oil);
|
|
|
|
pim_ifp = oif->info;
|
|
|
|
if (PIM_DEBUG_MROUTE) {
|
|
char group_str[100];
|
|
char source_str[100];
|
|
pim_inet4_dump("<group?>", channel_oil->oil.mfcc_mcastgrp, group_str, sizeof(group_str));
|
|
pim_inet4_dump("<source?>", channel_oil->oil.mfcc_origin, source_str, sizeof(source_str));
|
|
zlog_debug("%s %s: (S,G)=(%s,%s): proto_mask=%u OIF=%s vif_index=%d",
|
|
__FILE__, __PRETTY_FUNCTION__,
|
|
source_str, group_str,
|
|
proto_mask, oif->name, pim_ifp->mroute_vif_index);
|
|
}
|
|
|
|
if (pim_ifp->mroute_vif_index < 1) {
|
|
zlog_warn("%s %s: interface %s vif_index=%d < 1",
|
|
__FILE__, __PRETTY_FUNCTION__,
|
|
oif->name, pim_ifp->mroute_vif_index);
|
|
return -1;
|
|
}
|
|
|
|
#ifdef PIM_ENFORCE_LOOPFREE_MFC
|
|
/*
|
|
Prevent creating MFC entry with OIF=IIF.
|
|
|
|
This is a protection against implementation mistakes.
|
|
|
|
PIM protocol implicitely ensures loopfree multicast topology.
|
|
|
|
IGMP must be protected against adding looped MFC entries created
|
|
by both source and receiver attached to the same interface. See
|
|
TODO T22.
|
|
*/
|
|
if (pim_ifp->mroute_vif_index == channel_oil->oil.mfcc_parent) {
|
|
char group_str[100];
|
|
char source_str[100];
|
|
pim_inet4_dump("<group?>", channel_oil->oil.mfcc_mcastgrp, group_str, sizeof(group_str));
|
|
pim_inet4_dump("<source?>", channel_oil->oil.mfcc_origin, source_str, sizeof(source_str));
|
|
zlog_warn("%s %s: refusing protocol mask %u request for IIF=OIF=%s (vif_index=%d) for channel (S,G)=(%s,%s)",
|
|
__FILE__, __PRETTY_FUNCTION__,
|
|
proto_mask, oif->name, pim_ifp->mroute_vif_index,
|
|
source_str, group_str);
|
|
return -2;
|
|
}
|
|
#endif
|
|
|
|
/* Prevent single protocol from subscribing same interface to
|
|
channel (S,G) multiple times */
|
|
if (channel_oil->oif_flags[pim_ifp->mroute_vif_index] & proto_mask) {
|
|
char group_str[100];
|
|
char source_str[100];
|
|
pim_inet4_dump("<group?>", channel_oil->oil.mfcc_mcastgrp, group_str, sizeof(group_str));
|
|
pim_inet4_dump("<source?>", channel_oil->oil.mfcc_origin, source_str, sizeof(source_str));
|
|
zlog_warn("%s %s: existing protocol mask %u requested OIF %s (vif_index=%d, min_ttl=%d) for channel (S,G)=(%s,%s)",
|
|
__FILE__, __PRETTY_FUNCTION__,
|
|
proto_mask, oif->name, pim_ifp->mroute_vif_index,
|
|
channel_oil->oil.mfcc_ttls[pim_ifp->mroute_vif_index],
|
|
source_str, group_str);
|
|
return -3;
|
|
}
|
|
|
|
/* Allow other protocol to request subscription of same interface to
|
|
channel (S,G) multiple times, by silently ignoring further
|
|
requests */
|
|
if (channel_oil->oif_flags[pim_ifp->mroute_vif_index] & PIM_OIF_FLAG_PROTO_ANY) {
|
|
|
|
/* Check the OIF really exists before returning, and only log
|
|
warning otherwise */
|
|
if (channel_oil->oil.mfcc_ttls[pim_ifp->mroute_vif_index] < 1) {
|
|
char group_str[100];
|
|
char source_str[100];
|
|
pim_inet4_dump("<group?>", channel_oil->oil.mfcc_mcastgrp, group_str, sizeof(group_str));
|
|
pim_inet4_dump("<source?>", channel_oil->oil.mfcc_origin, source_str, sizeof(source_str));
|
|
zlog_warn("%s %s: new protocol mask %u requested nonexistent OIF %s (vif_index=%d, min_ttl=%d) for channel (S,G)=(%s,%s)",
|
|
__FILE__, __PRETTY_FUNCTION__,
|
|
proto_mask, oif->name, pim_ifp->mroute_vif_index,
|
|
channel_oil->oil.mfcc_ttls[pim_ifp->mroute_vif_index],
|
|
source_str, group_str);
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
old_ttl = channel_oil->oil.mfcc_ttls[pim_ifp->mroute_vif_index];
|
|
|
|
if (old_ttl > 0) {
|
|
char group_str[100];
|
|
char source_str[100];
|
|
pim_inet4_dump("<group?>", channel_oil->oil.mfcc_mcastgrp, group_str, sizeof(group_str));
|
|
pim_inet4_dump("<source?>", channel_oil->oil.mfcc_origin, source_str, sizeof(source_str));
|
|
zlog_warn("%s %s: interface %s (vif_index=%d) is existing output for channel (S,G)=(%s,%s)",
|
|
__FILE__, __PRETTY_FUNCTION__,
|
|
oif->name, pim_ifp->mroute_vif_index,
|
|
source_str, group_str);
|
|
return -4;
|
|
}
|
|
|
|
channel_oil->oil.mfcc_ttls[pim_ifp->mroute_vif_index] = PIM_MROUTE_MIN_TTL;
|
|
|
|
if (pim_mroute_add(&channel_oil->oil)) {
|
|
char group_str[100];
|
|
char source_str[100];
|
|
pim_inet4_dump("<group?>", channel_oil->oil.mfcc_mcastgrp, group_str, sizeof(group_str));
|
|
pim_inet4_dump("<source?>", channel_oil->oil.mfcc_origin, source_str, sizeof(source_str));
|
|
zlog_warn("%s %s: could not add output interface %s (vif_index=%d) for channel (S,G)=(%s,%s)",
|
|
__FILE__, __PRETTY_FUNCTION__,
|
|
oif->name, pim_ifp->mroute_vif_index,
|
|
source_str, group_str);
|
|
|
|
channel_oil->oil.mfcc_ttls[pim_ifp->mroute_vif_index] = old_ttl;
|
|
return -5;
|
|
}
|
|
|
|
channel_oil->oif_creation[pim_ifp->mroute_vif_index] = pim_time_monotonic_sec();
|
|
++channel_oil->oil_size;
|
|
channel_oil->oif_flags[pim_ifp->mroute_vif_index] |= proto_mask;
|
|
|
|
if (PIM_DEBUG_MROUTE) {
|
|
char group_str[100];
|
|
char source_str[100];
|
|
pim_inet4_dump("<group?>", channel_oil->oil.mfcc_mcastgrp, group_str, sizeof(group_str));
|
|
pim_inet4_dump("<source?>", channel_oil->oil.mfcc_origin, source_str, sizeof(source_str));
|
|
zlog_debug("%s %s: (S,G)=(%s,%s): proto_mask=%u OIF=%s vif_index=%d: DONE",
|
|
__FILE__, __PRETTY_FUNCTION__,
|
|
source_str, group_str,
|
|
proto_mask, oif->name, pim_ifp->mroute_vif_index);
|
|
}
|
|
|
|
return 0;
|
|
}
|