2 *------------------------------------------------------------------
3 * Copyright (c) 2018 Cisco and/or its affiliates.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at:
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 *------------------------------------------------------------------
18 #include <igmp/igmp_src.h>
19 #include <igmp/igmp_group.h>
20 #include <igmp/igmp.h>
23 igmp_src_free (igmp_src_t * src)
25 igmp_main_t *im = &igmp_main;
27 IGMP_DBG ("free-src: (%U)", format_igmp_key, src->key);
29 igmp_timer_retire (&src->timers[IGMP_SRC_TIMER_EXP]);
31 clib_mem_free (src->key);
32 pool_put (im->srcs, src);
36 igmp_src_exp (u32 obj, void *dat)
41 src = pool_elt_at_index (igmp_main.srcs, obj);
42 group = igmp_group_get (src->group);
44 IGMP_DBG ("src-exp: %U", format_igmp_key, src->key);
46 igmp_timer_retire (&src->timers[IGMP_SRC_TIMER_EXP]);
48 if (IGMP_MODE_ROUTER == src->mode)
50 igmp_config_t *config;
54 * inform interest parties
56 group = igmp_group_get (src->group);
57 config = igmp_config_get (group->config);
59 igmp_event (IGMP_FILTER_MODE_EXCLUDE,
60 config->sw_if_index, src->key, group->key);
63 igmp_group_src_remove (group, src);
66 if (0 == igmp_group_n_srcs (group, IGMP_FILTER_MODE_INCLUDE))
67 igmp_group_clear (group);
71 igmp_src_alloc (u32 group_index, const igmp_key_t * skey, igmp_mode_t mode)
73 igmp_main_t *im = &igmp_main;
76 IGMP_DBG ("new-src: (%U)", format_igmp_key, skey);
78 pool_get (im->srcs, src);
79 memset (src, 0, sizeof (igmp_src_t));
81 src->key = clib_mem_alloc (sizeof (*skey));
82 src->group = group_index;
83 clib_memcpy (src->key, skey, sizeof (*skey));
85 if (IGMP_MODE_ROUTER == mode)
87 igmp_config_t *config;
90 * start a timer that determines whether the source is still
93 src->timers[IGMP_SRC_TIMER_EXP] =
94 igmp_timer_schedule (igmp_timer_type_get (IGMP_TIMER_SRC),
95 src - im->srcs, igmp_src_exp, NULL);
98 * inform interest parties
100 group = igmp_group_get (src->group);
101 config = igmp_config_get (group->config);
103 igmp_event (IGMP_FILTER_MODE_INCLUDE,
104 config->sw_if_index, src->key, group->key);
108 src->timers[IGMP_SRC_TIMER_EXP] = IGMP_TIMER_ID_INVALID;
115 igmp_src_refresh (igmp_src_t * src)
117 IGMP_DBG ("refresh-src: (%U)", format_igmp_key, src->key);
119 igmp_timer_retire (&src->timers[IGMP_SRC_TIMER_EXP]);
121 src->timers[IGMP_SRC_TIMER_EXP] =
122 igmp_timer_schedule (igmp_timer_type_get (IGMP_TIMER_SRC),
123 igmp_src_index (src), igmp_src_exp, NULL);
127 igmp_src_blocked (igmp_src_t * src)
129 IGMP_DBG ("block-src: (%U)", format_igmp_key, src->key);
131 igmp_timer_retire (&src->timers[IGMP_SRC_TIMER_EXP]);
133 src->timers[IGMP_SRC_TIMER_EXP] =
134 igmp_timer_schedule (igmp_timer_type_get (IGMP_TIMER_LEAVE),
135 igmp_src_index (src), igmp_src_exp, NULL);
139 igmp_src_index (igmp_src_t * src)
141 return (src - igmp_main.srcs);
146 * fd.io coding-style-patch-verification: ON
149 * eval: (c-set-style "gnu")