pimd/pim_ssm.c

   1 /*
   2  * IP SSM ranges for FRR
   3  * Copyright (C) 2017 Cumulus Networks, Inc.
   4  *
   5  * This program is free software; you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License as published by
   7  * the Free Software Foundation; either version 2 of the License, or
   8  * (at your option) any later version.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License along
  16  * with this program; see the file COPYING; if not, write to the Free Software
  17  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  18  */
  19
  20 #include <zebra.h>
  21
  22 #include <lib/linklist.h>
  23 #include <lib/prefix.h>
  24 #include <lib/vty.h>
  25 #include <lib/vrf.h>
  26 #include <lib/plist.h>
  27
  28 #include "pimd.h"
  29 #include "pim_ssm.h"
  30 #include "pim_zebra.h"
  31
  32 static void
  33 pim_ssm_range_reevaluate (void)
  34 {
  35   /* 1. Setup register state for (S,G) entries if G has changed from SSM to
  36    *    ASM.
  37    * 2. check existing (*,G) IGMP registrations to see if they are
  38    * still ASM. if they are now SSM delete them.
  39    * 3. Allow channel setup for IGMP (*,G) members if G is now ASM
  40    * 4. I could tear down all (*,G), (S,G,rpt) states. But that is an
  41    * unnecessary sladge hammer and may not be particularly useful as it is
  42    * likely the SPT switchover has already happened for flows along such RPTs.
  43    * As for the RPT states it seems that the best thing to do is let them age
  44    * out gracefully. As long as the FHR and LHR do the right thing RPTs will
  45    * disappear in time for SSM groups.
  46    */
  47   pim_upstream_register_reevaluate ();
  48   igmp_source_forward_reevaluate_all ();
  49 }
  50
  51 void
  52 pim_ssm_prefix_list_update (struct prefix_list *plist)
  53 {
  54   struct pim_ssm *ssm = pimg->ssm_info;
  55
  56   if (!ssm->plist_name || strcmp (ssm->plist_name, prefix_list_name (plist)))
  57     {
  58       /* not ours */
  59       return;
  60     }
  61
  62   pim_ssm_range_reevaluate ();
  63 }
  64
  65 static int
  66 pim_is_grp_standard_ssm (struct prefix *group)
  67 {
  68   static int first = 1;
  69   static struct prefix group_ssm;
  70
  71   if (first)
  72     {
  73       str2prefix (PIM_SSM_STANDARD_RANGE, &group_ssm);
  74       first = 0;
  75     }
  76
  77   return prefix_match (&group_ssm, group);
  78 }
  79
  80 int
  81 pim_is_grp_ssm (struct in_addr group_addr)
  82 {
  83   struct pim_ssm *ssm;
  84   struct prefix group;
  85   struct prefix_list *plist;
  86
  87   memset (&group, 0, sizeof (group));
  88   group.family = AF_INET;
  89   group.u.prefix4 = group_addr;
  90   group.prefixlen = 32;
  91
  92   ssm = pimg->ssm_info;
  93   if (!ssm->plist_name)
  94     {
  95       return pim_is_grp_standard_ssm (&group);
  96     }
  97
  98   plist = prefix_list_lookup (AFI_IP, ssm->plist_name);
  99   if (!plist)
 100     return 0;
 101
 102   return (prefix_list_apply (plist, &group) == PREFIX_PERMIT);
 103 }
 104
 105 int
 106 pim_ssm_range_set (vrf_id_t vrf_id, const char *plist_name)
 107 {
 108   struct pim_ssm *ssm;
 109   int change = 0;
 110
 111   if (vrf_id != VRF_DEFAULT)
 112     return PIM_SSM_ERR_NO_VRF;
 113
 114   ssm = pimg->ssm_info;
 115   if (plist_name)
 116     {
 117       if (ssm->plist_name)
 118         {
 119           if (!strcmp (ssm->plist_name, plist_name))
 120             return PIM_SSM_ERR_DUP;
 121           XFREE (MTYPE_PIM_FILTER_NAME, ssm->plist_name);
 122         }
 123       ssm->plist_name = XSTRDUP (MTYPE_PIM_FILTER_NAME, plist_name);
 124       change = 1;
 125     }
 126   else
 127     {
 128       if (ssm->plist_name)
 129         {
 130           change = 1;
 131           XFREE (MTYPE_PIM_FILTER_NAME, ssm->plist_name);
 132         }
 133     }
 134
 135   if (change)
 136     pim_ssm_range_reevaluate ();
 137
 138   return PIM_SSM_ERR_NONE;
 139 }
 140
 141 void *
 142 pim_ssm_init (vrf_id_t vrf_id)
 143 {
 144   struct pim_ssm *ssm;
 145
 146   ssm = XCALLOC (MTYPE_PIM_SSM_INFO, sizeof (*ssm));
 147   ssm->vrf_id = vrf_id;
 148
 149   return ssm;
 150 }
 151
 152 void
 153 pim_ssm_terminate (struct pim_ssm *ssm)
 154 {
 155   if (ssm && ssm->plist_name)
 156     XFREE (MTYPE_PIM_FILTER_NAME, ssm->plist_name);
 157 }