2 * Copyright (c) 2016 Cisco and/or its affiliates.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
7 * http://www.apache.org/licenses/LICENSE-2.0
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
16 #include "fib_entry.h"
17 #include "fib_entry_src.h"
18 #include "fib_path_list.h"
19 #include "fib_table.h"
20 #include "fib_entry_cover.h"
21 #include "fib_attached_export.h"
22 #include "fib_path_ext.h"
25 * Source initialisation Function
28 fib_entry_src_adj_init (fib_entry_src_t *src)
30 src->adj.fesa_cover = FIB_NODE_INDEX_INVALID;
31 src->adj.fesa_sibling = FIB_NODE_INDEX_INVALID;
35 fib_entry_src_adj_path_add (fib_entry_src_t *src,
36 const fib_entry_t *entry,
37 fib_path_list_flags_t pl_flags,
38 const fib_route_path_t *paths)
40 const fib_route_path_t *rpath;
42 if (FIB_NODE_INDEX_INVALID == src->fes_pl)
44 src->fes_pl = fib_path_list_create(pl_flags, paths);
48 src->fes_pl = fib_path_list_copy_and_path_add(src->fes_pl,
54 * resolve the existing extensions
56 fib_path_ext_list_resolve(&src->fes_path_exts, src->fes_pl);
61 vec_foreach(rpath, paths)
63 fib_path_ext_list_insert(&src->fes_path_exts,
71 fib_entry_src_adj_path_remove (fib_entry_src_t *src,
72 fib_path_list_flags_t pl_flags,
73 const fib_route_path_t *rpaths)
75 const fib_route_path_t *rpath;
77 if (FIB_NODE_INDEX_INVALID != src->fes_pl)
79 src->fes_pl = fib_path_list_copy_and_path_remove(src->fes_pl,
85 * remove the path-extension for the path
87 vec_foreach(rpath, rpaths)
89 fib_path_ext_list_remove(&src->fes_path_exts, FIB_PATH_EXT_ADJ, rpath);
92 * resolve the remaining extensions
94 fib_path_ext_list_resolve(&src->fes_path_exts, src->fes_pl);
98 fib_entry_src_adj_path_swap (fib_entry_src_t *src,
99 const fib_entry_t *entry,
100 fib_path_list_flags_t pl_flags,
101 const fib_route_path_t *paths)
103 const fib_route_path_t *rpath;
106 * flush all the old extensions before we create a brand new path-list
108 fib_path_ext_list_flush(&src->fes_path_exts);
110 src->fes_pl = fib_path_list_create(pl_flags, paths);
115 vec_foreach(rpath, paths)
117 fib_path_ext_list_push_back(&src->fes_path_exts,
125 fib_entry_src_adj_remove (fib_entry_src_t *src)
127 src->fes_pl = FIB_NODE_INDEX_INVALID;
131 * Add a path-extension indicating whether this path is resolved,
132 * because it passed the refinement check
135 fib_enty_src_adj_update_path_ext (fib_entry_src_t *src,
136 fib_node_index_t path_index,
137 fib_path_ext_adj_flags_t flags)
139 fib_path_ext_t *path_ext;
141 path_ext = fib_path_ext_list_find_by_path_index(&src->fes_path_exts,
144 if (NULL != path_ext)
146 path_ext->fpe_adj_flags = flags;
150 ASSERT(!"no path extension");
154 typedef struct fib_entry_src_path_list_walk_cxt_t_
156 fib_entry_src_t *src;
158 fib_path_ext_adj_flags_t flags;
159 } fib_entry_src_path_list_walk_cxt_t;
161 static fib_path_list_walk_rc_t
162 fib_entry_src_adj_path_list_walk (fib_node_index_t pl_index,
163 fib_node_index_t path_index,
166 fib_entry_src_path_list_walk_cxt_t *ctx;
170 adj_itf = fib_path_get_resolving_interface(path_index);
172 if (ctx->cover_itf == adj_itf)
174 fib_enty_src_adj_update_path_ext(ctx->src, path_index,
175 FIB_PATH_EXT_ADJ_FLAG_REFINES_COVER);
176 ctx->flags |= FIB_PATH_EXT_ADJ_FLAG_REFINES_COVER;
181 * if the interface the adj is on is unnumbered to the
182 * cover's, then allow that too.
184 vnet_sw_interface_t *swif;
186 swif = vnet_get_sw_interface (vnet_get_main(), adj_itf);
188 if (swif->flags & VNET_SW_INTERFACE_FLAG_UNNUMBERED &&
189 ctx->cover_itf == swif->unnumbered_sw_if_index)
191 fib_enty_src_adj_update_path_ext(ctx->src, path_index,
192 FIB_PATH_EXT_ADJ_FLAG_REFINES_COVER);
193 ctx->flags |= FIB_PATH_EXT_ADJ_FLAG_REFINES_COVER;
197 fib_enty_src_adj_update_path_ext(ctx->src, path_index,
198 FIB_PATH_EXT_ADJ_FLAG_NONE);
201 return (FIB_PATH_LIST_WALK_CONTINUE);
205 fib_entry_src_adj_activate (fib_entry_src_t *src,
206 const fib_entry_t *fib_entry)
211 * find the covering prefix. become a dependent thereof.
212 * there should always be a cover, though it may be the default route.
214 src->adj.fesa_cover = fib_table_get_less_specific(fib_entry->fe_fib_index,
215 &fib_entry->fe_prefix);
217 ASSERT(FIB_NODE_INDEX_INVALID != src->adj.fesa_cover);
218 ASSERT(fib_entry_get_index(fib_entry) != src->adj.fesa_cover);
220 cover = fib_entry_get(src->adj.fesa_cover);
222 ASSERT(cover != fib_entry);
224 src->adj.fesa_sibling =
225 fib_entry_cover_track(cover,
226 fib_entry_get_index(fib_entry));
229 * if the cover is attached on the same interface as this adj source then
230 * install the FIB entry via the adj. otherwise install a drop.
231 * This prevents ARP/ND entries that on interface X that do not belong
232 * on X's subnet from being added to the FIB. To do so would allow
233 * nefarious gratuitous ARP requests from attracting traffic to the sender.
235 * and yes, I really do mean attached and not connected.
237 * ip route add 10.0.0.0/24 Eth0
238 * is attached. and we want adj-fibs to install on Eth0.
240 if (FIB_ENTRY_FLAG_ATTACHED & fib_entry_get_flags_i(cover))
242 fib_entry_src_path_list_walk_cxt_t ctx = {
243 .cover_itf = fib_entry_get_resolving_interface(src->adj.fesa_cover),
244 .flags = FIB_PATH_EXT_ADJ_FLAG_NONE,
248 fib_path_list_walk(src->fes_pl,
249 fib_entry_src_adj_path_list_walk,
253 * active the entry is one of the paths refines the cover.
255 return (FIB_PATH_EXT_ADJ_FLAG_REFINES_COVER & ctx.flags);
261 * Source re-activate.
262 * Called when the source path lit has changed and the source is still
266 fib_entry_src_adj_reactivate (fib_entry_src_t *src,
267 const fib_entry_t *fib_entry)
269 fib_entry_src_path_list_walk_cxt_t ctx = {
270 .cover_itf = fib_entry_get_resolving_interface(src->adj.fesa_cover),
271 .flags = FIB_PATH_EXT_ADJ_FLAG_NONE,
275 fib_path_list_walk(src->fes_pl,
276 fib_entry_src_adj_path_list_walk,
279 return (FIB_PATH_EXT_ADJ_FLAG_REFINES_COVER & ctx.flags);
284 * Called when the source is no longer best source on the entry
287 fib_entry_src_adj_deactivate (fib_entry_src_t *src,
288 const fib_entry_t *fib_entry)
293 * remove the depednecy on the covering entry
295 ASSERT(FIB_NODE_INDEX_INVALID != src->adj.fesa_cover);
296 cover = fib_entry_get(src->adj.fesa_cover);
298 fib_entry_cover_untrack(cover, src->adj.fesa_sibling);
301 * tell the cover this entry no longer needs exporting
303 fib_attached_export_covered_removed(cover, fib_entry_get_index(fib_entry));
305 src->adj.fesa_cover = FIB_NODE_INDEX_INVALID;
309 fib_entry_src_adj_format (fib_entry_src_t *src,
312 return (format(s, " cover:%d", src->adj.fesa_cover));
316 fib_entry_src_adj_installed (fib_entry_src_t *src,
317 const fib_entry_t *fib_entry)
320 * The adj source now rules! poke our cover to get exported
324 ASSERT(FIB_NODE_INDEX_INVALID != src->adj.fesa_cover);
325 cover = fib_entry_get(src->adj.fesa_cover);
327 fib_attached_export_covered_added(cover,
328 fib_entry_get_index(fib_entry));
331 static fib_entry_src_cover_res_t
332 fib_entry_src_adj_cover_change (fib_entry_src_t *src,
333 const fib_entry_t *fib_entry)
335 fib_entry_src_cover_res_t res = {
337 .bw_reason = FIB_NODE_BW_REASON_FLAG_NONE,
340 fib_entry_src_adj_deactivate(src, fib_entry);
342 res.install = fib_entry_src_adj_activate(src, fib_entry);
346 * ADJ fib can install
348 res.bw_reason = FIB_NODE_BW_REASON_FLAG_EVALUATE;
355 * fib_entry_src_adj_cover_update
357 static fib_entry_src_cover_res_t
358 fib_entry_src_adj_cover_update (fib_entry_src_t *src,
359 const fib_entry_t *fib_entry)
362 * the cover has updated, i.e. its forwarding or flags
363 * have changed. don't decativate/activate here, since this
364 * prefix is updated during the covers walk.
366 fib_entry_src_cover_res_t res = {
368 .bw_reason = FIB_NODE_BW_REASON_FLAG_NONE,
372 ASSERT(FIB_NODE_INDEX_INVALID != src->adj.fesa_cover);
374 cover = fib_entry_get(src->adj.fesa_cover);
376 res.install = (FIB_ENTRY_FLAG_ATTACHED & fib_entry_get_flags_i(cover));
381 const static fib_entry_src_vft_t adj_src_vft = {
382 .fesv_init = fib_entry_src_adj_init,
383 .fesv_path_swap = fib_entry_src_adj_path_swap,
384 .fesv_path_add = fib_entry_src_adj_path_add,
385 .fesv_path_remove = fib_entry_src_adj_path_remove,
386 .fesv_remove = fib_entry_src_adj_remove,
387 .fesv_activate = fib_entry_src_adj_activate,
388 .fesv_deactivate = fib_entry_src_adj_deactivate,
389 .fesv_reactivate = fib_entry_src_adj_reactivate,
390 .fesv_format = fib_entry_src_adj_format,
391 .fesv_installed = fib_entry_src_adj_installed,
392 .fesv_cover_change = fib_entry_src_adj_cover_change,
393 .fesv_cover_update = fib_entry_src_adj_cover_update,
397 fib_entry_src_adj_register (void)
399 fib_entry_src_register(FIB_SOURCE_ADJ, &adj_src_vft);