FD.io VPP  v19.01.3-6-g70449b9b9
Vector Packet Processing
mfib_table.c
Go to the documentation of this file.
1 /*
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:
6  *
7  * http://www.apache.org/licenses/LICENSE-2.0
8  *
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.
14  */
15 
16 #include <vlib/vlib.h>
17 #include <vnet/dpo/drop_dpo.h>
18 
19 #include <vnet/mfib/mfib_table.h>
20 #include <vnet/mfib/ip4_mfib.h>
21 #include <vnet/mfib/ip6_mfib.h>
22 #include <vnet/mfib/mfib_entry.h>
25 #include <vnet/mfib/mfib_signal.h>
26 
29  fib_protocol_t proto)
30 {
31  switch (proto)
32  {
33  case FIB_PROTOCOL_IP4:
34  return (pool_elt_at_index(ip4_main.mfibs, index));
35  case FIB_PROTOCOL_IP6:
36  return (pool_elt_at_index(ip6_main.mfibs, index));
37  case FIB_PROTOCOL_MPLS:
38  break;
39  }
40  ASSERT(0);
41  return (NULL);
42 }
43 
44 static inline fib_node_index_t
45 mfib_table_lookup_i (const mfib_table_t *mfib_table,
46  const mfib_prefix_t *prefix)
47 {
48  switch (prefix->fp_proto)
49  {
50  case FIB_PROTOCOL_IP4:
51  return (ip4_mfib_table_lookup(&mfib_table->v4,
52  &prefix->fp_src_addr.ip4,
53  &prefix->fp_grp_addr.ip4,
54  prefix->fp_len));
55  case FIB_PROTOCOL_IP6:
56  return (ip6_mfib_table_lookup(&mfib_table->v6,
57  &prefix->fp_src_addr.ip6,
58  &prefix->fp_grp_addr.ip6,
59  prefix->fp_len));
60  case FIB_PROTOCOL_MPLS:
61  break;
62  }
63  return (FIB_NODE_INDEX_INVALID);
64 }
65 
68  const mfib_prefix_t *prefix)
69 {
70  return (mfib_table_lookup_i(mfib_table_get(fib_index, prefix->fp_proto), prefix));
71 }
72 
73 static inline fib_node_index_t
75  const mfib_prefix_t *prefix)
76 {
77  switch (prefix->fp_proto)
78  {
79  case FIB_PROTOCOL_IP4:
80  return (ip4_mfib_table_lookup_exact_match(&mfib_table->v4,
81  &prefix->fp_grp_addr.ip4,
82  &prefix->fp_src_addr.ip4,
83  prefix->fp_len));
84  case FIB_PROTOCOL_IP6:
85  return (ip6_mfib_table_lookup_exact_match(&mfib_table->v6,
86  &prefix->fp_grp_addr.ip6,
87  &prefix->fp_src_addr.ip6,
88  prefix->fp_len));
89  case FIB_PROTOCOL_MPLS:
90  break;
91  }
92  return (FIB_NODE_INDEX_INVALID);
93 }
94 
97  const mfib_prefix_t *prefix)
98 {
100  prefix->fp_proto),
101  prefix));
102 }
103 
104 static fib_node_index_t
106  const mfib_prefix_t *prefix)
107 {
108  switch (prefix->fp_proto)
109  {
110  case FIB_PROTOCOL_IP4:
111  return (ip4_mfib_table_get_less_specific(&mfib_table->v4,
112  &prefix->fp_src_addr.ip4,
113  &prefix->fp_grp_addr.ip4,
114  prefix->fp_len));
115  case FIB_PROTOCOL_IP6:
116  return (ip6_mfib_table_get_less_specific(&mfib_table->v6,
117  &prefix->fp_src_addr.ip6,
118  &prefix->fp_grp_addr.ip6,
119  prefix->fp_len));
120  case FIB_PROTOCOL_MPLS:
121  break;
122  }
123  return (FIB_NODE_INDEX_INVALID);
124 }
125 
128  const mfib_prefix_t *prefix)
129 {
131  prefix->fp_proto),
132  prefix));
133 }
134 
135 static void
137  const mfib_prefix_t *prefix,
138  fib_node_index_t mfib_entry_index)
139 {
141 
142  mfib_table->mft_total_route_counts--;
143 
144  switch (prefix->fp_proto)
145  {
146  case FIB_PROTOCOL_IP4:
147  ip4_mfib_table_entry_remove(&mfib_table->v4,
148  &prefix->fp_grp_addr.ip4,
149  &prefix->fp_src_addr.ip4,
150  prefix->fp_len);
151  break;
152  case FIB_PROTOCOL_IP6:
153  ip6_mfib_table_entry_remove(&mfib_table->v6,
154  &prefix->fp_grp_addr.ip6,
155  &prefix->fp_src_addr.ip6,
156  prefix->fp_len);
157  break;
158  case FIB_PROTOCOL_MPLS:
159  ASSERT(0);
160  break;
161  }
162 
163  mfib_entry_cover_change_notify(mfib_entry_index,
165  mfib_entry_unlock(mfib_entry_index);
166 }
167 
168 static void
170  const mfib_prefix_t *prefix,
171  fib_node_index_t mfib_entry_index)
172 {
173  fib_node_index_t mfib_entry_cover_index;
174 
175  /*
176  * find the covering entry
177  */
178  mfib_entry_cover_index = mfib_table_get_less_specific_i(mfib_table,
179  prefix);
180  /*
181  * the indicies are the same when the default route is first added
182  */
183  if (mfib_entry_cover_index != mfib_entry_index)
184  {
185  /*
186  * inform the covering entry that a new more specific
187  * has been inserted beneath it.
188  * If the prefix that has been inserted is a host route
189  * then it is not possible that it will be the cover for any
190  * other entry, so we can elide the walk.
191  */
192  if (!mfib_entry_is_host(mfib_entry_index))
193  {
194  mfib_entry_cover_change_notify(mfib_entry_cover_index,
195  mfib_entry_index);
196  }
197  }
198 }
199 
200 
201 static void
203  const mfib_prefix_t *prefix,
204  fib_node_index_t mfib_entry_index)
205 {
207 
208  mfib_entry_lock(mfib_entry_index);
209  mfib_table->mft_total_route_counts++;
210 
211  switch (prefix->fp_proto)
212  {
213  case FIB_PROTOCOL_IP4:
214  ip4_mfib_table_entry_insert(&mfib_table->v4,
215  &prefix->fp_grp_addr.ip4,
216  &prefix->fp_src_addr.ip4,
217  prefix->fp_len,
218  mfib_entry_index);
219  break;
220  case FIB_PROTOCOL_IP6:
221  ip6_mfib_table_entry_insert(&mfib_table->v6,
222  &prefix->fp_grp_addr.ip6,
223  &prefix->fp_src_addr.ip6,
224  prefix->fp_len,
225  mfib_entry_index);
226  break;
227  case FIB_PROTOCOL_MPLS:
228  break;
229  }
230 
231  mfib_table_post_insert_actions(mfib_table, prefix, mfib_entry_index);
232 }
233 
236  const mfib_prefix_t *prefix,
237  mfib_source_t source,
238  fib_rpf_id_t rpf_id,
239  mfib_entry_flags_t entry_flags)
240 {
241  fib_node_index_t mfib_entry_index;
242  mfib_table_t *mfib_table;
243 
244  mfib_table = mfib_table_get(fib_index, prefix->fp_proto);
245  mfib_entry_index = mfib_table_lookup_exact_match_i(mfib_table, prefix);
246 
247  if (FIB_NODE_INDEX_INVALID == mfib_entry_index)
248  {
249  if (MFIB_ENTRY_FLAG_NONE != entry_flags)
250  {
251  /*
252  * update to a non-existing entry with non-zero flags
253  */
254  mfib_entry_index = mfib_entry_create(fib_index, source,
255  prefix, rpf_id,
256  entry_flags,
257  INDEX_INVALID);
258 
259  mfib_table_entry_insert(mfib_table, prefix, mfib_entry_index);
260  }
261  /*
262  * else
263  * the entry doesn't exist and the request is to set no flags
264  * the result would be an entry that doesn't exist - so do nothing
265  */
266  }
267  else
268  {
269  mfib_entry_lock(mfib_entry_index);
270 
271  if (mfib_entry_update(mfib_entry_index,
272  source,
273  entry_flags,
274  rpf_id,
275  INDEX_INVALID))
276  {
277  /*
278  * this update means we can now remove the entry.
279  */
280  mfib_table_entry_remove(mfib_table, prefix, mfib_entry_index);
281  }
282 
283  mfib_entry_unlock(mfib_entry_index);
284  }
285 
286  return (mfib_entry_index);
287 }
288 
291  const mfib_prefix_t *prefix,
292  mfib_source_t source,
293  const fib_route_path_t *rpath,
295 {
296  fib_node_index_t mfib_entry_index;
297  mfib_table_t *mfib_table;
298 
299  mfib_table = mfib_table_get(fib_index, prefix->fp_proto);
300  mfib_entry_index = mfib_table_lookup_exact_match_i(mfib_table, prefix);
301 
302  if (FIB_NODE_INDEX_INVALID == mfib_entry_index)
303  {
304  mfib_entry_index = mfib_entry_create(fib_index,
305  source,
306  prefix,
309  INDEX_INVALID);
310 
311  mfib_entry_path_update(mfib_entry_index,
312  source,
313  rpath,
314  itf_flags);
315 
316  mfib_table_entry_insert(mfib_table, prefix, mfib_entry_index);
317  }
318  else
319  {
320  mfib_entry_path_update(mfib_entry_index,
321  source,
322  rpath,
323  itf_flags);
324  }
325  return (mfib_entry_index);
326 }
327 
328 void
330  const mfib_prefix_t *prefix,
331  mfib_source_t source,
332  const fib_route_path_t *rpath)
333 {
334  fib_node_index_t mfib_entry_index;
335  mfib_table_t *mfib_table;
336 
337  mfib_table = mfib_table_get(fib_index, prefix->fp_proto);
338  mfib_entry_index = mfib_table_lookup_exact_match_i(mfib_table, prefix);
339 
340  if (FIB_NODE_INDEX_INVALID == mfib_entry_index)
341  {
342  /*
343  * removing an etry that does not exist. i'll allow it.
344  */
345  }
346  else
347  {
348  int no_more_sources;
349 
350  /*
351  * don't nobody go nowhere
352  */
353  mfib_entry_lock(mfib_entry_index);
354 
355  no_more_sources = mfib_entry_path_remove(mfib_entry_index,
356  source,
357  rpath);
358 
359  if (no_more_sources)
360  {
361  /*
362  * last source gone. remove from the table
363  */
364  mfib_table_entry_remove(mfib_table, prefix, mfib_entry_index);
365  }
366 
367  mfib_entry_unlock(mfib_entry_index);
368  }
369 }
370 
373  const mfib_prefix_t *prefix,
374  mfib_source_t source,
375  mfib_entry_flags_t entry_flags,
376  index_t repi)
377 {
378  fib_node_index_t mfib_entry_index;
379  mfib_table_t *mfib_table;
380 
381  mfib_table = mfib_table_get(fib_index, prefix->fp_proto);
382  mfib_entry_index = mfib_table_lookup_exact_match_i(mfib_table, prefix);
383 
384  if (INDEX_INVALID != repi)
385  {
386  entry_flags |= MFIB_ENTRY_FLAG_EXCLUSIVE;
387  }
388 
389  if (FIB_NODE_INDEX_INVALID == mfib_entry_index)
390  {
391  mfib_entry_index = mfib_entry_create(fib_index,
392  source,
393  prefix,
395  entry_flags,
396  repi);
397 
398  mfib_table_entry_insert(mfib_table, prefix, mfib_entry_index);
399  }
400  else
401  {
402  mfib_entry_special_add(mfib_entry_index, source, entry_flags,
403  MFIB_RPF_ID_NONE, repi);
404  }
405 
406  return (mfib_entry_index);
407 }
408 
409 static void
411  fib_node_index_t mfib_entry_index,
412  const mfib_prefix_t *prefix,
413  mfib_source_t source)
414 {
415  mfib_table_t *mfib_table;
416 
417  mfib_table = mfib_table_get(fib_index, prefix->fp_proto);
418 
419  /*
420  * don't nobody go nowhere
421  */
422  mfib_entry_lock(mfib_entry_index);
423 
424  if (mfib_entry_delete(mfib_entry_index, source))
425  {
426  /*
427  * last source gone. remove from the table
428  */
429  mfib_table_entry_remove(mfib_table, prefix, mfib_entry_index);
430  }
431  /*
432  * else
433  * still has sources, leave it be.
434  */
435 
436  mfib_entry_unlock(mfib_entry_index);
437 }
438 
439 void
441  const mfib_prefix_t *prefix,
442  mfib_source_t source)
443 {
444  fib_node_index_t mfib_entry_index;
445 
446  mfib_entry_index = mfib_table_lookup_exact_match(fib_index, prefix);
447 
448  if (FIB_NODE_INDEX_INVALID == mfib_entry_index)
449  {
450  /*
451  * removing an etry that does not exist.
452  * i'll allow it, but i won't like it.
453  */
454  clib_warning("%U not in FIB", format_mfib_prefix, prefix);
455  }
456  else
457  {
458  mfib_table_entry_delete_i(fib_index, mfib_entry_index,
459  prefix, source);
460  }
461 }
462 
463 void
465  mfib_source_t source)
466 {
467  const mfib_prefix_t *prefix;
468 
469  prefix = mfib_entry_get_prefix(mfib_entry_index);
470 
472  mfib_entry_index, prefix, source);
473 }
474 
475 u32
478 {
479  switch (proto)
480  {
481  case FIB_PROTOCOL_IP4:
482  return (ip4_mfib_table_get_index_for_sw_if_index(sw_if_index));
483  case FIB_PROTOCOL_IP6:
484  return (ip6_mfib_table_get_index_for_sw_if_index(sw_if_index));
485  case FIB_PROTOCOL_MPLS:
486  ASSERT(0);
487  break;
488  }
489  return (~0);
490 }
491 
492 u32
494  fib_protocol_t proto)
495 {
496  mfib_table_t *mfib_table;
497 
498  mfib_table = mfib_table_get(fib_index, proto);
499 
500  return ((NULL != mfib_table ? mfib_table->mft_table_id : ~0));
501 }
502 
503 u32
505  u32 table_id)
506 {
507  switch (proto)
508  {
509  case FIB_PROTOCOL_IP4:
510  return (ip4_mfib_index_from_table_id(table_id));
511  case FIB_PROTOCOL_IP6:
512  return (ip6_mfib_index_from_table_id(table_id));
513  case FIB_PROTOCOL_MPLS:
514  ASSERT(0);
515  break;
516  }
517  return (~0);
518 }
519 
520 static u32
522  u32 table_id,
524  const u8 *name)
525 {
526  mfib_table_t *mfib_table;
527  fib_node_index_t fi;
528 
529  switch (proto)
530  {
531  case FIB_PROTOCOL_IP4:
532  fi = ip4_mfib_table_find_or_create_and_lock(table_id, src);
533  break;
534  case FIB_PROTOCOL_IP6:
535  fi = ip6_mfib_table_find_or_create_and_lock(table_id, src);
536  break;
537  case FIB_PROTOCOL_MPLS:
538  default:
539  return (~0);
540  }
541 
542  mfib_table = mfib_table_get(fi, proto);
543 
544  if (NULL == mfib_table->mft_desc)
545  {
546  if (name && name[0])
547  {
548  mfib_table->mft_desc = format(NULL, "%s", name);
549  }
550  else
551  {
552  mfib_table->mft_desc = format(NULL, "%U-VRF:%d",
553  format_fib_protocol, proto,
554  table_id);
555  }
556  }
557 
558  return (fi);
559 }
560 
561 u32
563  u32 table_id,
565 {
566  return (mfib_table_find_or_create_and_lock_i(proto, table_id,
567  src, NULL));
568 }
569 
570 u32
572  u32 table_id,
574  const u8 *name)
575 {
576  return (mfib_table_find_or_create_and_lock_i(proto, table_id,
577  src, name));
578 }
579 
580 /**
581  * @brief Table flush context. Store the indicies of matching FIB entries
582  * that need to be removed.
583  */
585 {
586  /**
587  * The list of entries to flush
588  */
590 
591  /**
592  * The source we are flushing
593  */
596 
597 static int
599  void *arg)
600 {
602 
603  if (mfib_entry_is_sourced(mfib_entry_index, ctx->mftf_source))
604  {
605  vec_add1(ctx->mftf_entries, mfib_entry_index);
606  }
607  return (1);
608 }
609 
610 void
611 mfib_table_flush (u32 mfib_index,
612  fib_protocol_t proto,
613  mfib_source_t source)
614 {
615  fib_node_index_t *mfib_entry_index;
617  .mftf_entries = NULL,
618  .mftf_source = source,
619  };
620 
621  mfib_table_walk(mfib_index, proto,
623  &ctx);
624 
625  vec_foreach(mfib_entry_index, ctx.mftf_entries)
626  {
627  mfib_table_entry_delete_index(*mfib_entry_index, source);
628  }
629 
630  vec_free(ctx.mftf_entries);
631 }
632 
633 static void
635 {
636  vec_free(mfib_table->mft_desc);
637 
638  switch (mfib_table->mft_proto)
639  {
640  case FIB_PROTOCOL_IP4:
641  ip4_mfib_table_destroy(&mfib_table->v4);
642  break;
643  case FIB_PROTOCOL_IP6:
644  ip6_mfib_table_destroy(&mfib_table->v6);
645  break;
646  case FIB_PROTOCOL_MPLS:
647  ASSERT(0);
648  break;
649  }
650 }
651 
652 void
654  fib_protocol_t proto,
655  mfib_source_t source)
656 {
657  mfib_table_t *mfib_table;
658 
659  mfib_table = mfib_table_get(fib_index, proto);
660  mfib_table->mft_locks[source]--;
661  mfib_table->mft_locks[MFIB_TABLE_TOTAL_LOCKS]--;
662 
663  if (0 == mfib_table->mft_locks[source])
664  {
665  /*
666  * The source no longer needs the table. flush any routes
667  * from it just in case
668  */
669  mfib_table_flush(fib_index, proto, source);
670  }
671 
672  if (0 == mfib_table->mft_locks[MFIB_TABLE_TOTAL_LOCKS])
673  {
674  /*
675  * no more locak from any source - kill it
676  */
677  mfib_table_destroy(mfib_table);
678  }
679 }
680 
681 void
682 mfib_table_lock (u32 fib_index,
683  fib_protocol_t proto,
684  mfib_source_t source)
685 {
686  mfib_table_t *mfib_table;
687 
688  mfib_table = mfib_table_get(fib_index, proto);
689  mfib_table->mft_locks[source]++;
690  mfib_table->mft_locks[MFIB_TABLE_TOTAL_LOCKS]++;
691 }
692 
693 u32
695  fib_protocol_t proto)
696 {
697  mfib_table_t *mfib_table;
698 
699  mfib_table = mfib_table_get(fib_index, proto);
700 
701  return (mfib_table->mft_total_route_counts);
702 }
703 
704 void
705 mfib_table_walk (u32 fib_index,
706  fib_protocol_t proto,
708  void *ctx)
709 {
710  switch (proto)
711  {
712  case FIB_PROTOCOL_IP4:
713  ip4_mfib_table_walk(ip4_mfib_get(fib_index), fn, ctx);
714  break;
715  case FIB_PROTOCOL_IP6:
716  ip6_mfib_table_walk(ip6_mfib_get(fib_index), fn, ctx);
717  break;
718  case FIB_PROTOCOL_MPLS:
719  break;
720  }
721 }
722 
723 u8*
724 format_mfib_table_name (u8* s, va_list *ap)
725 {
726  fib_node_index_t fib_index = va_arg(*ap, fib_node_index_t);
727  fib_protocol_t proto = va_arg(*ap, int); // int promotion
728  mfib_table_t *mfib_table;
729 
730  mfib_table = mfib_table_get(fib_index, proto);
731 
732  s = format(s, "%v", mfib_table->mft_desc);
733 
734  return (s);
735 }
736 
737 u8 *
738 format_mfib_table_memory (u8 *s, va_list *args)
739 {
740  s = format(s, "%U", format_ip4_mfib_table_memory);
741  s = format(s, "%U", format_ip6_mfib_table_memory);
742 
743  return (s);
744 }
745 
746 static clib_error_t *
748 {
749  clib_error_t * error;
750 
754 
755  if ((error = vlib_call_init_function (vm, fib_module_init)))
756  return (error);
757  if ((error = vlib_call_init_function (vm, rn_module_init)))
758  return (error);
759 
760  return (error);
761 }
762 
static clib_error_t * rn_module_init(vlib_main_t *vm)
Definition: radix.c:1085
void mfib_table_entry_delete(u32 fib_index, const mfib_prefix_t *prefix, mfib_source_t source)
Delete a FIB entry.
Definition: mfib_table.c:440
u32 mfib_table_find_or_create_and_lock(fib_protocol_t proto, u32 table_id, mfib_source_t src)
Get the index of the FIB for a Table-ID.
Definition: mfib_table.c:562
ip46_address_t fp_src_addr
Definition: mfib_types.h:47
fib_node_index_t mfib_table_lookup(u32 fib_index, const mfib_prefix_t *prefix)
Perfom a longest prefix match in the non-forwarding table.
Definition: mfib_table.c:67
vl_api_address_t src
Definition: vxlan_gbp.api:32
int mfib_entry_delete(fib_node_index_t mfib_entry_index, mfib_source_t source)
mfib_entry_delete
Definition: mfib_entry.c:1096
enum mfib_entry_flags_t_ mfib_entry_flags_t
A representation of a path as described by a route producer.
Definition: fib_types.h:470
ip6_mfib_t v6
Definition: mfib_table.h:50
#define MFIB_TABLE_TOTAL_LOCKS
Definition: mfib_table.h:29
void mfib_signal_module_init(void)
Definition: mfib_signal.c:66
u32 ip4_mfib_table_get_index_for_sw_if_index(u32 sw_if_index)
Definition: ip4_mfib.c:131
void mfib_entry_unlock(fib_node_index_t mfib_entry_index)
Definition: mfib_entry.c:1274
#define NULL
Definition: clib.h:58
fib_node_index_t mfib_table_entry_special_add(u32 fib_index, const mfib_prefix_t *prefix, mfib_source_t source, mfib_entry_flags_t entry_flags, index_t repi)
Add a &#39;special&#39; entry to the mFIB that links to the DPO passed A special entry is an entry that the F...
Definition: mfib_table.c:372
fib_node_index_t ip6_mfib_table_get_less_specific(const ip6_mfib_t *mfib, const ip6_address_t *src, const ip6_address_t *grp, u32 len)
Definition: ip6_mfib.c:378
u32 index_t
A Data-Path Object is an object that represents actions that are applied to packets are they are swit...
Definition: dpo.h:41
#define vec_add1(V, E)
Add 1 element to end of vector (unspecified alignment).
Definition: vec.h:525
fib_node_index_t ip6_mfib_table_lookup(const ip6_mfib_t *mfib, const ip6_address_t *src, const ip6_address_t *grp, u32 len)
The IPv4 Multicast-FIB.
Definition: ip6_mfib.c:415
u16 mft_locks[MFIB_TABLE_N_LOCKS]
number of locks on the table
Definition: mfib_table.h:61
u32 mft_total_route_counts
Total route counters.
Definition: mfib_table.h:76
fib_node_index_t mfib_table_entry_update(u32 fib_index, const mfib_prefix_t *prefix, mfib_source_t source, fib_rpf_id_t rpf_id, mfib_entry_flags_t entry_flags)
Add a new (with no replication) or lock an existing entry.
Definition: mfib_table.c:235
u8 * format(u8 *s, const char *fmt,...)
Definition: format.c:419
void ip6_mfib_table_destroy(ip6_mfib_t *mfib)
Definition: ip6_mfib.c:191
fib_node_index_t * mftf_entries
The list of entries to flush.
Definition: mfib_table.c:589
static fib_node_index_t mfib_table_lookup_i(const mfib_table_t *mfib_table, const mfib_prefix_t *prefix)
Definition: mfib_table.c:45
fib_node_index_t ip4_mfib_table_get_less_specific(const ip4_mfib_t *mfib, const ip4_address_t *src, const ip4_address_t *grp, u32 len)
Definition: ip4_mfib.c:228
static void mfib_table_entry_remove(mfib_table_t *mfib_table, const mfib_prefix_t *prefix, fib_node_index_t mfib_entry_index)
Definition: mfib_table.c:136
Table flush context.
Definition: mfib_table.c:584
unsigned char u8
Definition: types.h:56
struct mfib_table_flush_ctx_t_ mfib_table_flush_ctx_t
Table flush context.
static void vlib_smp_unsafe_warning(void)
Definition: threads.h:218
u8 * format_fib_protocol(u8 *s, va_list *ap)
Definition: fib_types.c:32
enum fib_protocol_t_ fib_protocol_t
Protocol Type.
static int mfib_table_flush_cb(fib_node_index_t mfib_entry_index, void *arg)
Definition: mfib_table.c:598
static ip4_mfib_t * ip4_mfib_get(u32 index)
Get the FIB at the given index.
Definition: ip4_mfib.h:62
static void mfib_table_entry_delete_i(u32 fib_index, fib_node_index_t mfib_entry_index, const mfib_prefix_t *prefix, mfib_source_t source)
Definition: mfib_table.c:410
u32 ip6_mfib_table_find_or_create_and_lock(u32 table_id, mfib_source_t src)
Get or create an IPv4 fib.
Definition: ip6_mfib.c:273
enum mfib_source_t_ mfib_source_t
Possible [control plane] sources of MFIB entries.
#define MFIB_RPF_ID_NONE
Definition: fib_types.h:393
#define VLIB_INIT_FUNCTION(x)
Definition: init.h:163
u32 mfib_table_get_index_for_sw_if_index(fib_protocol_t proto, u32 sw_if_index)
Get the index of the FIB bound to the interface.
Definition: mfib_table.c:476
u32 sw_if_index
Definition: vxlan_gbp.api:37
void mfib_table_entry_delete_index(fib_node_index_t mfib_entry_index, mfib_source_t source)
Delete a FIB entry.
Definition: mfib_table.c:464
u32 mfib_table_find_or_create_and_lock_w_name(fib_protocol_t proto, u32 table_id, mfib_source_t src, const u8 *name)
Get the index of the FIB for a Table-ID.
Definition: mfib_table.c:571
fib_node_index_t mfib_table_entry_path_update(u32 fib_index, const mfib_prefix_t *prefix, mfib_source_t source, const fib_route_path_t *rpath, mfib_itf_flags_t itf_flags)
Add n paths to an entry (aka route) in the FIB.
Definition: mfib_table.c:290
u32 mfib_table_get_n_routes(fib_node_index_t fib_index, fib_protocol_t proto)
To assit UT.
Definition: mfib_table.c:694
void mfib_entry_module_init(void)
Definition: mfib_entry.c:1317
unsigned int u32
Definition: types.h:88
struct mfib_table_t_ * mfibs
Vector of MFIBs.
Definition: ip4.h:107
#define vlib_call_init_function(vm, x)
Definition: init.h:260
static void mfib_table_post_insert_actions(mfib_table_t *mfib_table, const mfib_prefix_t *prefix, fib_node_index_t mfib_entry_index)
Definition: mfib_table.c:169
void ip6_mfib_table_entry_insert(ip6_mfib_t *mfib, const ip6_address_t *grp, const ip6_address_t *src, u32 len, fib_node_index_t mfib_entry_index)
Definition: ip6_mfib.c:465
u32 mfib_entry_get_fib_index(fib_node_index_t mfib_entry_index)
Definition: mfib_entry.c:1367
void ip4_mfib_table_walk(ip4_mfib_t *mfib, mfib_table_walk_fn_t fn, void *ctx)
Walk the IP4 mfib table.
Definition: ip4_mfib.c:318
int mfib_entry_update(fib_node_index_t mfib_entry_index, mfib_source_t source, mfib_entry_flags_t entry_flags, fib_rpf_id_t rpf_id, index_t repi)
Definition: mfib_entry.c:894
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
Definition: pool.h:511
u8 * format_ip6_mfib_table_memory(u8 *s, va_list *args)
format (display) ipv6 MFIB mempry usage
Definition: ip6_mfib.c:522
static void mfib_table_entry_insert(mfib_table_t *mfib_table, const mfib_prefix_t *prefix, fib_node_index_t mfib_entry_index)
Definition: mfib_table.c:202
void mfib_table_unlock(u32 fib_index, fib_protocol_t proto, mfib_source_t source)
Take a reference counting lock on the table.
Definition: mfib_table.c:653
void mfib_entry_cover_change_notify(fib_node_index_t cover_index, fib_node_index_t covered)
void ip4_mfib_table_entry_remove(ip4_mfib_t *mfib, const ip4_address_t *grp, const ip4_address_t *src, u32 len)
Definition: ip4_mfib.c:291
int mfib_entry_is_host(fib_node_index_t mfib_entry_index)
Definition: mfib_entry.c:335
long ctx[MAX_CONNS]
Definition: main.c:144
fib_node_index_t mfib_table_lookup_exact_match(u32 fib_index, const mfib_prefix_t *prefix)
Perfom an exact match in the non-forwarding table.
Definition: mfib_table.c:96
int mfib_entry_is_sourced(fib_node_index_t mfib_entry_index, mfib_source_t source)
Definition: mfib_entry.c:324
int mfib_entry_special_add(fib_node_index_t mfib_entry_index, mfib_source_t source, mfib_entry_flags_t entry_flags, fib_rpf_id_t rpf_id, index_t repi)
Definition: mfib_entry.c:872
void mfib_entry_path_update(fib_node_index_t mfib_entry_index, mfib_source_t source, const fib_route_path_t *rpath, mfib_itf_flags_t itf_flags)
Definition: mfib_entry.c:935
void mfib_table_lock(u32 fib_index, fib_protocol_t proto, mfib_source_t source)
Release a reference counting lock on the table.
Definition: mfib_table.c:682
u8 * mft_desc
Table description.
Definition: mfib_table.h:81
void mfib_entry_lock(fib_node_index_t mfib_entry_index)
Definition: mfib_entry.c:1264
u8 name[64]
Definition: memclnt.api:152
void mfib_table_flush(u32 mfib_index, fib_protocol_t proto, mfib_source_t source)
Flush all entries from a table for the source.
Definition: mfib_table.c:611
u32 ip6_mfib_table_get_index_for_sw_if_index(u32 sw_if_index)
Definition: ip6_mfib.c:287
void mfib_table_walk(u32 fib_index, fib_protocol_t proto, mfib_table_walk_fn_t fn, void *ctx)
Walk all entries in a FIB table N.B: This is NOT safe to deletes.
Definition: mfib_table.c:705
vlib_main_t * vm
Definition: buffer.c:301
fib_node_index_t ip4_mfib_table_lookup_exact_match(const ip4_mfib_t *mfib, const ip4_address_t *grp, const ip4_address_t *src, u32 len)
Definition: ip4_mfib.c:165
u8 * format_mfib_table_memory(u8 *s, va_list *args)
format (display) the memory usage for mfibs
Definition: mfib_table.c:738
#define vec_free(V)
Free vector&#39;s memory (no header).
Definition: vec.h:341
#define clib_warning(format, args...)
Definition: error.h:59
u32 fib_node_index_t
A typedef of a node index.
Definition: fib_types.h:30
mfib_source_t mftf_source
The source we are flushing.
Definition: mfib_table.c:594
Aggregrate type for a prefix.
Definition: mfib_types.h:24
u32 fib_rpf_id_t
An RPF-ID is numerical value that is used RPF validate.
Definition: fib_types.h:391
#define ASSERT(truth)
ip6_main_t ip6_main
Definition: ip6_forward.c:2624
fib_node_index_t mfib_table_get_less_specific(u32 fib_index, const mfib_prefix_t *prefix)
Get the less specific (covering) prefix.
Definition: mfib_table.c:127
static clib_error_t * fib_module_init(vlib_main_t *vm)
Definition: fib.c:23
static u32 ip6_mfib_index_from_table_id(u32 table_id)
Definition: ip6_mfib.h:95
struct mfib_table_t_ * mfibs
Vector of MFIBs.
Definition: ip6.h:187
fib_node_index_t ip4_mfib_table_lookup(const ip4_mfib_t *mfib, const ip4_address_t *src, const ip4_address_t *grp, u32 len)
The IPv4 Multicast-FIB.
Definition: ip4_mfib.c:190
void ip4_mfib_table_entry_insert(ip4_mfib_t *mfib, const ip4_address_t *grp, const ip4_address_t *src, u32 len, fib_node_index_t fib_entry_index)
Definition: ip4_mfib.c:260
fib_protocol_t mft_proto
Which protocol this table serves.
Definition: mfib_table.h:56
u32 mft_table_id
Table ID (hash key) for this FIB.
Definition: mfib_table.h:66
u32 mfib_table_get_table_id(u32 fib_index, fib_protocol_t proto)
Get the Table-ID of the FIB from protocol and index.
Definition: mfib_table.c:493
static u32 mfib_table_find_or_create_and_lock_i(fib_protocol_t proto, u32 table_id, mfib_source_t src, const u8 *name)
Definition: mfib_table.c:521
fib_protocol_t fp_proto
protocol type
Definition: mfib_types.h:33
static void mfib_table_destroy(mfib_table_t *mfib_table)
Definition: mfib_table.c:634
fib_node_index_t ip6_mfib_table_lookup_exact_match(const ip6_mfib_t *mfib, const ip6_address_t *grp, const ip6_address_t *src, u32 len)
Definition: ip6_mfib.c:326
mfib_table_t * mfib_table_get(fib_node_index_t index, fib_protocol_t proto)
Get a pointer to a FIB table.
Definition: mfib_table.c:28
#define FIB_NODE_INDEX_INVALID
Definition: fib_types.h:31
static fib_node_index_t mfib_table_get_less_specific_i(const mfib_table_t *mfib_table, const mfib_prefix_t *prefix)
Definition: mfib_table.c:105
fib_node_index_t mfib_entry_create(u32 fib_index, mfib_source_t source, const mfib_prefix_t *prefix, fib_rpf_id_t rpf_id, mfib_entry_flags_t entry_flags, index_t repi)
Definition: mfib_entry.c:763
u32 ip4_mfib_table_find_or_create_and_lock(u32 table_id, mfib_source_t src)
Get or create an IPv4 fib.
Definition: ip4_mfib.c:117
const mfib_prefix_t * mfib_entry_get_prefix(fib_node_index_t mfib_entry_index)
Definition: mfib_entry.c:1357
#define INDEX_INVALID
Invalid index - used when no index is known blazoned capitals INVALID speak volumes where ~0 does not...
Definition: dpo.h:47
u32 mfib_table_find(fib_protocol_t proto, u32 table_id)
Get the index of the FIB for a Table-ID.
Definition: mfib_table.c:504
enum mfib_itf_flags_t_ mfib_itf_flags_t
typedef prefix
Definition: ip_types.api:35
void ip6_mfib_table_walk(ip6_mfib_t *mfib, mfib_table_walk_fn_t fn, void *arg)
Walk the IP6 mfib table.
Definition: ip6_mfib.c:621
void ip6_mfib_table_entry_remove(ip6_mfib_t *mfib, const ip6_address_t *grp, const ip6_address_t *src, u32 len)
Definition: ip6_mfib.c:490
int(* mfib_table_walk_fn_t)(fib_node_index_t fei, void *ctx)
Call back function when walking entries in a FIB table.
Definition: mfib_table.h:447
ip4_mfib_t v4
Definition: mfib_table.h:49
static clib_error_t * mfib_module_init(vlib_main_t *vm)
Definition: mfib_table.c:747
static ip6_mfib_t * ip6_mfib_get(u32 index)
Get the FIB at the given index.
Definition: ip6_mfib.h:72
A protocol Independent IP multicast FIB table.
Definition: mfib_table.h:35
ip4_main_t ip4_main
Global ip4 main structure.
Definition: ip4_forward.c:903
#define vec_foreach(var, vec)
Vector iterator.
void mfib_entry_src_module_init(void)
static fib_node_index_t mfib_table_lookup_exact_match_i(const mfib_table_t *mfib_table, const mfib_prefix_t *prefix)
Definition: mfib_table.c:74
u16 fp_len
The mask length.
Definition: mfib_types.h:28
void mfib_table_entry_path_remove(u32 fib_index, const mfib_prefix_t *prefix, mfib_source_t source, const fib_route_path_t *rpath)
Remove n paths to an entry (aka route) in the FIB.
Definition: mfib_table.c:329
static u32 ip4_mfib_index_from_table_id(u32 table_id)
Definition: ip4_mfib.h:84
u8 * format_mfib_table_name(u8 *s, va_list *ap)
Format the description/name of the table.
Definition: mfib_table.c:724
void ip4_mfib_table_destroy(ip4_mfib_t *mfib)
Definition: ip4_mfib.c:84
u8 * format_mfib_prefix(u8 *s, va_list *args)
Definition: mfib_types.c:106
ip46_address_t fp_grp_addr
The address type is not deriveable from the fp_addr member.
Definition: mfib_types.h:46
int mfib_entry_path_remove(fib_node_index_t mfib_entry_index, mfib_source_t source, const fib_route_path_t *rpath)
Definition: mfib_entry.c:1022
u32 itf_flags
Definition: ip.api:508
u8 * format_ip4_mfib_table_memory(u8 *s, va_list *args)
format (display) the memory usage for IP4 mfibs
Definition: ip4_mfib.c:341