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 <vnet/mpls/mpls_types.h>
18 #include <vnet/mfib/mfib_table.h>
19 #include <vnet/mfib/mfib_entry.h>
20 #include <vnet/mfib/mfib_signal.h>
21 #include <vnet/mfib/ip6_mfib.h>
22 #include <vnet/fib/fib_path_list.h>
23 #include <vnet/fib/fib_test.h>
24 #include <vnet/fib/fib_table.h>
25 #include <vnet/fib/mpls_fib.h>
27 #include <vnet/dpo/replicate_dpo.h>
28 #include <vnet/adj/adj_mcast.h>
30 #define MFIB_TEST_I(_cond, _comment, _args...) \
32 int _evald = (_cond); \
34 fformat(stderr, "FAIL:%d: " _comment "\n", \
37 fformat(stderr, "PASS:%d: " _comment "\n", \
42 #define MFIB_TEST(_cond, _comment, _args...) \
44 if (!MFIB_TEST_I(_cond, _comment, ##_args)) { \
46 ASSERT(!("FAIL: " _comment)); \
49 #define MFIB_TEST_NS(_cond) \
51 if (!MFIB_TEST_I(_cond, "")) { \
53 ASSERT(!("FAIL: ")); \
58 * A 'i'm not fussed is this is not efficient' store of test data
60 typedef struct test_main_t_ {
64 u32 hw_if_indicies[4];
68 vnet_hw_interface_t * hw[4];
71 static test_main_t test_main;
73 /* fake ethernet device class, distinct from "fake-ethX" */
74 static u8 * format_test_interface_name (u8 * s, va_list * args)
76 u32 dev_instance = va_arg (*args, u32);
77 return format (s, "test-eth%d", dev_instance);
80 static uword dummy_interface_tx (vlib_main_t * vm,
81 vlib_node_runtime_t * node,
84 clib_warning ("you shouldn't be here, leaking buffers...");
85 return frame->n_vectors;
89 test_interface_admin_up_down (vnet_main_t * vnm,
93 u32 hw_flags = (flags & VNET_SW_INTERFACE_FLAG_ADMIN_UP) ?
94 VNET_HW_INTERFACE_FLAG_LINK_UP : 0;
95 vnet_hw_interface_set_flags (vnm, hw_if_index, hw_flags);
99 VNET_DEVICE_CLASS (test_interface_device_class,static) = {
100 .name = "Test interface",
101 .format_device_name = format_test_interface_name,
102 .tx_function = dummy_interface_tx,
103 .admin_up_down_function = test_interface_admin_up_down,
106 static u8 *hw_address;
109 mfib_test_mk_intf (u32 ninterfaces)
111 clib_error_t * error = NULL;
112 test_main_t *tm = &test_main;
116 ASSERT(ninterfaces <= ARRAY_LEN(tm->hw_if_indicies));
121 vec_add1(hw_address, byte);
124 for (i = 0; i < ninterfaces; i++)
128 error = ethernet_register_interface(vnet_get_main(),
129 test_interface_device_class.index,
132 &tm->hw_if_indicies[i],
133 /* flag change */ 0);
135 MFIB_TEST((NULL == error), "ADD interface %d", i);
137 error = vnet_hw_interface_set_flags(vnet_get_main(),
138 tm->hw_if_indicies[i],
139 VNET_HW_INTERFACE_FLAG_LINK_UP);
140 tm->hw[i] = vnet_get_hw_interface(vnet_get_main(),
141 tm->hw_if_indicies[i]);
142 vec_validate (ip4_main.fib_index_by_sw_if_index,
143 tm->hw[i]->sw_if_index);
144 vec_validate (ip6_main.fib_index_by_sw_if_index,
145 tm->hw[i]->sw_if_index);
146 ip4_main.fib_index_by_sw_if_index[tm->hw[i]->sw_if_index] = 0;
147 ip6_main.fib_index_by_sw_if_index[tm->hw[i]->sw_if_index] = 0;
149 vec_validate (ip4_main.mfib_index_by_sw_if_index,
150 tm->hw[i]->sw_if_index);
151 vec_validate (ip6_main.mfib_index_by_sw_if_index,
152 tm->hw[i]->sw_if_index);
153 ip4_main.mfib_index_by_sw_if_index[tm->hw[i]->sw_if_index] = 0;
154 ip6_main.mfib_index_by_sw_if_index[tm->hw[i]->sw_if_index] = 0;
156 error = vnet_sw_interface_set_flags(vnet_get_main(),
157 tm->hw[i]->sw_if_index,
158 VNET_SW_INTERFACE_FLAG_ADMIN_UP);
159 MFIB_TEST((NULL == error), "UP interface %d", i);
162 * re-eval after the inevitable realloc
164 for (i = 0; i < ninterfaces; i++)
166 tm->hw[i] = vnet_get_hw_interface(vnet_get_main(),
167 tm->hw_if_indicies[i]);
173 #define MFIB_TEST_REP(_cond, _comment, _args...) \
175 if (!MFIB_TEST_I(_cond, _comment, ##_args)) { \
181 mfib_test_validate_rep_v (const replicate_t *rep,
190 MFIB_TEST_REP((n_buckets == rep->rep_n_buckets),
191 "n_buckets = %d", rep->rep_n_buckets);
193 for (bucket = 0; bucket < n_buckets; bucket++)
195 dt = va_arg(*ap, int); // type promotion
196 ai = va_arg(*ap, adj_index_t);
197 dpo = replicate_get_bucket_i(rep, bucket);
199 MFIB_TEST_REP((dt == dpo->dpoi_type),
200 "bucket %d stacks on %U",
202 format_dpo_type, dpo->dpoi_type);
204 if (DPO_RECEIVE != dt)
206 MFIB_TEST_REP((ai == dpo->dpoi_index),
207 "bucket %d [exp:%d] stacks on %U",
209 format_dpo_id, dpo, 0);
215 static fib_forward_chain_type_t
216 fib_forw_chain_type_from_fib_proto (fib_protocol_t proto)
220 case FIB_PROTOCOL_IP4:
221 return (FIB_FORW_CHAIN_TYPE_UNICAST_IP4);
222 case FIB_PROTOCOL_IP6:
223 return (FIB_FORW_CHAIN_TYPE_UNICAST_IP6);
233 mfib_test_entry (fib_node_index_t fei,
234 mfib_entry_flags_t eflags,
238 const mfib_entry_t *mfe;
239 const replicate_t *rep;
244 va_start(ap, n_buckets);
246 mfe = mfib_entry_get(fei);
247 mfib_entry_get_prefix(fei, &pfx);
249 MFIB_TEST_REP((eflags == mfe->mfe_flags),
250 "%U has %U expect %U",
251 format_mfib_prefix, &pfx,
252 format_mfib_entry_flags, mfe->mfe_flags,
253 format_mfib_entry_flags, eflags);
257 MFIB_TEST_REP((DPO_DROP == mfe->mfe_rep.dpoi_type),
259 format_mfib_prefix, &pfx,
260 format_dpo_id, &mfe->mfe_rep, 0);
265 dpo_id_t tmp = DPO_INVALID;
267 mfib_entry_contribute_forwarding(
269 fib_forw_chain_type_from_fib_proto(pfx.fp_proto),
271 rep = replicate_get(tmp.dpoi_index);
273 MFIB_TEST_REP((DPO_REPLICATE == tmp.dpoi_type),
275 format_mfib_prefix, &pfx,
276 format_dpo_type, tmp.dpoi_type);
278 res = mfib_test_validate_rep_v(rep, n_buckets, &ap);
289 mfib_test_entry_itf (fib_node_index_t fei,
291 mfib_itf_flags_t flags)
293 const mfib_entry_t *mfe;
294 const mfib_itf_t *mfi;
297 mfe = mfib_entry_get(fei);
298 mfi = mfib_entry_get_itf(mfe, sw_if_index);
299 mfib_entry_get_prefix(fei, &pfx);
301 MFIB_TEST_REP((NULL != mfi),
302 "%U has interface %d",
303 format_mfib_prefix, &pfx, sw_if_index);
305 MFIB_TEST_REP((flags == mfi->mfi_flags),
306 "%U interface %d has flags %U expect %U",
307 format_mfib_prefix, &pfx, sw_if_index,
308 format_mfib_itf_flags, flags,
309 format_mfib_itf_flags, mfi->mfi_flags);
315 mfib_test_entry_no_itf (fib_node_index_t fei,
318 const mfib_entry_t *mfe;
319 const mfib_itf_t *mfi;
322 mfe = mfib_entry_get(fei);
323 mfi = mfib_entry_get_itf(mfe, sw_if_index);
324 mfib_entry_get_prefix(fei, &pfx);
326 MFIB_TEST_REP((NULL == mfi),
327 "%U has no interface %d",
328 format_mfib_prefix, &pfx, sw_if_index);
334 mfib_test_i (fib_protocol_t PROTO,
336 const mfib_prefix_t *pfx_no_forward,
337 const mfib_prefix_t *pfx_s_g,
338 const mfib_prefix_t *pfx_star_g_1,
339 const mfib_prefix_t *pfx_star_g_2,
340 const mfib_prefix_t *pfx_star_g_3,
341 const mfib_prefix_t *pfx_star_g_slash_m)
343 fib_node_index_t mfei, mfei_dflt, mfei_no_f, mfei_s_g, mfei_g_1, mfei_g_2, mfei_g_3, mfei_g_m;
344 u32 fib_index, n_entries, n_itfs, n_reps, n_pls;
345 fib_node_index_t ai_1, ai_2, ai_3;
348 mfib_prefix_t all_1s;
349 memset(&all_1s, 0xfd, sizeof(all_1s));
351 n_entries = pool_elts(mfib_entry_pool);
352 n_itfs = pool_elts(mfib_itf_pool);
353 n_reps = pool_elts(replicate_pool);
354 n_pls = fib_path_list_pool_size();
357 ai_1 = adj_mcast_add_or_lock(PROTO,
359 tm->hw[1]->sw_if_index);
360 ai_2 = adj_mcast_add_or_lock(PROTO,
362 tm->hw[2]->sw_if_index);
363 ai_3 = adj_mcast_add_or_lock(PROTO,
365 tm->hw[3]->sw_if_index);
367 MFIB_TEST(3 == adj_mcast_db_size(), "3 MCAST adjs");
369 /* Find or create FIB table 11 */
370 fib_index = mfib_table_find_or_create_and_lock(PROTO, 11, MFIB_SOURCE_API);
372 mfib_prefix_t pfx_dft = {
376 mfei_dflt = mfib_table_lookup_exact_match(fib_index, &pfx_dft);
377 MFIB_TEST(FIB_NODE_INDEX_INVALID != mfei_dflt, "(*,*) presnet");
378 MFIB_TEST(mfib_test_entry(mfei_dflt,
379 MFIB_ENTRY_FLAG_DROP,
381 "(*,*) no replcaitions");
383 MFIB_TEST(FIB_NODE_INDEX_INVALID != mfei_dflt, "(*,*) presnet");
384 MFIB_TEST(mfib_test_entry(mfei_dflt,
385 MFIB_ENTRY_FLAG_DROP,
387 "(*,*) no replcaitions");
390 fib_route_path_t path_via_if0 = {
391 .frp_proto = fib_proto_to_dpo(PROTO),
392 .frp_addr = zero_addr,
393 .frp_sw_if_index = tm->hw[0]->sw_if_index,
399 mfib_table_entry_path_update(fib_index,
403 MFIB_ITF_FLAG_ACCEPT);
405 mfei_no_f = mfib_table_lookup_exact_match(fib_index, pfx_no_forward);
406 MFIB_TEST(mfib_test_entry(mfei_no_f,
407 MFIB_ENTRY_FLAG_NONE,
409 "%U no replcaitions",
410 format_mfib_prefix, pfx_no_forward);
411 MFIB_TEST_NS(mfib_test_entry_itf(mfei_no_f, tm->hw[0]->sw_if_index,
412 MFIB_ITF_FLAG_ACCEPT));
414 fib_route_path_t path_via_if1 = {
415 .frp_proto = fib_proto_to_dpo(PROTO),
416 .frp_addr = zero_addr,
417 .frp_sw_if_index = tm->hw[1]->sw_if_index,
422 fib_route_path_t path_via_if2 = {
423 .frp_proto = fib_proto_to_dpo(PROTO),
424 .frp_addr = zero_addr,
425 .frp_sw_if_index = tm->hw[2]->sw_if_index,
430 fib_route_path_t path_via_if3 = {
431 .frp_proto = fib_proto_to_dpo(PROTO),
432 .frp_addr = zero_addr,
433 .frp_sw_if_index = tm->hw[3]->sw_if_index,
438 fib_route_path_t path_for_us = {
439 .frp_proto = fib_proto_to_dpo(PROTO),
440 .frp_addr = zero_addr,
441 .frp_sw_if_index = 0xffffffff,
444 .frp_flags = FIB_ROUTE_PATH_LOCAL,
448 * An (S,G) with 1 accepting and 3 forwarding paths
450 mfib_table_entry_path_update(fib_index,
454 MFIB_ITF_FLAG_ACCEPT);
455 mfib_table_entry_path_update(fib_index,
459 MFIB_ITF_FLAG_FORWARD);
460 mfib_table_entry_path_update(fib_index,
464 MFIB_ITF_FLAG_FORWARD);
465 mfib_table_entry_path_update(fib_index,
469 (MFIB_ITF_FLAG_FORWARD |
470 MFIB_ITF_FLAG_NEGATE_SIGNAL));
472 mfei_s_g = mfib_table_lookup_exact_match(fib_index, pfx_s_g);
474 MFIB_TEST(FIB_NODE_INDEX_INVALID != mfei_s_g,
476 format_mfib_prefix, pfx_s_g);
477 MFIB_TEST(mfib_test_entry(mfei_s_g,
478 MFIB_ENTRY_FLAG_NONE,
480 DPO_ADJACENCY_MCAST, ai_1,
481 DPO_ADJACENCY_MCAST, ai_2,
482 DPO_ADJACENCY_MCAST, ai_3),
484 format_mfib_prefix, pfx_s_g);
485 MFIB_TEST_NS(mfib_test_entry_itf(mfei_s_g, tm->hw[0]->sw_if_index,
486 MFIB_ITF_FLAG_ACCEPT));
487 MFIB_TEST_NS(mfib_test_entry_itf(mfei_s_g, tm->hw[1]->sw_if_index,
488 MFIB_ITF_FLAG_FORWARD));
489 MFIB_TEST_NS(mfib_test_entry_itf(mfei_s_g, tm->hw[2]->sw_if_index,
490 MFIB_ITF_FLAG_FORWARD));
491 MFIB_TEST_NS(mfib_test_entry_itf(mfei_s_g, tm->hw[3]->sw_if_index,
492 (MFIB_ITF_FLAG_FORWARD |
493 MFIB_ITF_FLAG_NEGATE_SIGNAL)));
496 * A (*,G), which the same G as the (S,G).
497 * different paths. test our LPM.
499 mfei_g_1 = mfib_table_entry_path_update(fib_index,
503 MFIB_ITF_FLAG_ACCEPT);
504 mfib_table_entry_path_update(fib_index,
508 MFIB_ITF_FLAG_FORWARD);
511 * test we find the *,G and S,G via LPM and exact matches
513 mfei = mfib_table_lookup_exact_match(fib_index,
515 MFIB_TEST(mfei == mfei_g_1,
516 "%U found via exact match",
517 format_mfib_prefix, pfx_star_g_1);
518 MFIB_TEST(mfib_test_entry(mfei,
519 MFIB_ENTRY_FLAG_NONE,
521 DPO_ADJACENCY_MCAST, ai_1),
523 format_mfib_prefix, pfx_star_g_1);
525 mfei = mfib_table_lookup(fib_index,
527 MFIB_TEST(mfei == mfei_g_1,
528 "%U found via LP match",
529 format_mfib_prefix, pfx_star_g_1);
531 MFIB_TEST(mfib_test_entry(mfei,
532 MFIB_ENTRY_FLAG_NONE,
534 DPO_ADJACENCY_MCAST, ai_1),
536 format_mfib_prefix, pfx_star_g_1);
538 mfei = mfib_table_lookup_exact_match(fib_index, pfx_s_g);
539 MFIB_TEST(mfei == mfei_s_g,
540 "%U found via exact match",
541 format_mfib_prefix, pfx_s_g);
543 MFIB_TEST(mfib_test_entry(mfei,
544 MFIB_ENTRY_FLAG_NONE,
546 DPO_ADJACENCY_MCAST, ai_1,
547 DPO_ADJACENCY_MCAST, ai_2,
548 DPO_ADJACENCY_MCAST, ai_3),
550 format_mfib_prefix, pfx_s_g);
551 mfei = mfib_table_lookup(fib_index, pfx_s_g);
552 MFIB_TEST(mfei == mfei_s_g,
553 "%U found via LP match",
554 format_mfib_prefix, pfx_s_g);
556 MFIB_TEST(mfib_test_entry(mfei,
557 MFIB_ENTRY_FLAG_NONE,
559 DPO_ADJACENCY_MCAST, ai_1,
560 DPO_ADJACENCY_MCAST, ai_2,
561 DPO_ADJACENCY_MCAST, ai_3),
563 format_mfib_prefix, pfx_s_g);
566 * A (*,G/m), which the same root G as the (*,G).
567 * different paths. test our LPM.
569 mfei_g_m = mfib_table_entry_path_update(fib_index,
573 MFIB_ITF_FLAG_ACCEPT);
574 mfib_table_entry_path_update(fib_index,
578 MFIB_ITF_FLAG_FORWARD);
581 * test we find the (*,G/m), (*,G) and (S,G) via LPM and exact matches
583 mfei = mfib_table_lookup_exact_match(fib_index, pfx_star_g_1);
584 MFIB_TEST((mfei_g_1 == mfei),
585 "%U found via DP LPM: %d",
586 format_mfib_prefix, pfx_star_g_1, mfei);
588 MFIB_TEST(mfib_test_entry(mfei,
589 MFIB_ENTRY_FLAG_NONE,
591 DPO_ADJACENCY_MCAST, ai_1),
593 format_mfib_prefix, pfx_star_g_1);
595 mfei = mfib_table_lookup(fib_index, pfx_star_g_1);
597 MFIB_TEST(mfib_test_entry(mfei,
598 MFIB_ENTRY_FLAG_NONE,
600 DPO_ADJACENCY_MCAST, ai_1),
602 format_mfib_prefix, pfx_star_g_1);
604 mfei = mfib_table_lookup_exact_match(fib_index, pfx_s_g);
606 MFIB_TEST(mfib_test_entry(mfei,
607 MFIB_ENTRY_FLAG_NONE,
609 DPO_ADJACENCY_MCAST, ai_1,
610 DPO_ADJACENCY_MCAST, ai_2,
611 DPO_ADJACENCY_MCAST, ai_3),
613 format_mfib_prefix, pfx_s_g);
614 mfei = mfib_table_lookup(fib_index, pfx_s_g);
616 MFIB_TEST(mfib_test_entry(mfei,
617 MFIB_ENTRY_FLAG_NONE,
619 DPO_ADJACENCY_MCAST, ai_1,
620 DPO_ADJACENCY_MCAST, ai_2,
621 DPO_ADJACENCY_MCAST, ai_3),
623 format_mfib_prefix, pfx_s_g);
625 mfei = mfib_table_lookup_exact_match(fib_index, pfx_star_g_slash_m);
626 MFIB_TEST(mfei = mfei_g_m,
627 "%U Found via exact match",
628 format_mfib_prefix, pfx_star_g_slash_m);
629 MFIB_TEST(mfib_test_entry(mfei,
630 MFIB_ENTRY_FLAG_NONE,
632 DPO_ADJACENCY_MCAST, ai_3),
634 format_mfib_prefix, pfx_star_g_slash_m);
635 MFIB_TEST(mfei_g_m == mfib_table_lookup(fib_index, pfx_star_g_slash_m),
637 format_mfib_prefix, pfx_star_g_slash_m);
642 mfei = mfib_table_entry_path_update(fib_index,
646 MFIB_ITF_FLAG_FORWARD);
648 MFIB_TEST(mfib_test_entry(mfei,
649 MFIB_ENTRY_FLAG_NONE,
651 DPO_ADJACENCY_MCAST, ai_1,
652 DPO_ADJACENCY_MCAST, ai_2,
653 DPO_ADJACENCY_MCAST, ai_3,
656 format_mfib_prefix, pfx_s_g);
659 * remove a for-us path
661 mfib_table_entry_path_remove(fib_index,
666 MFIB_TEST(mfib_test_entry(mfei,
667 MFIB_ENTRY_FLAG_NONE,
669 DPO_ADJACENCY_MCAST, ai_1,
670 DPO_ADJACENCY_MCAST, ai_2,
671 DPO_ADJACENCY_MCAST, ai_3),
673 format_mfib_prefix, pfx_s_g);
676 * update an existing forwarding path to be only accepting
677 * - expect it to be removed from the replication set.
679 mfib_table_entry_path_update(fib_index,
683 MFIB_ITF_FLAG_ACCEPT);
685 MFIB_TEST(mfib_test_entry(mfei,
686 MFIB_ENTRY_FLAG_NONE,
688 DPO_ADJACENCY_MCAST, ai_1,
689 DPO_ADJACENCY_MCAST, ai_2),
691 format_mfib_prefix, pfx_s_g);
692 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[0]->sw_if_index,
693 MFIB_ITF_FLAG_ACCEPT));
694 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[1]->sw_if_index,
695 MFIB_ITF_FLAG_FORWARD));
696 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[2]->sw_if_index,
697 MFIB_ITF_FLAG_FORWARD));
698 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[3]->sw_if_index,
699 MFIB_ITF_FLAG_ACCEPT));
701 * Make the path forwarding again
702 * - expect it to be added back to the replication set
704 mfib_table_entry_path_update(fib_index,
708 (MFIB_ITF_FLAG_FORWARD |
709 MFIB_ITF_FLAG_ACCEPT |
710 MFIB_ITF_FLAG_NEGATE_SIGNAL));
712 mfei = mfib_table_lookup_exact_match(fib_index,
715 MFIB_TEST(mfib_test_entry(mfei,
716 MFIB_ENTRY_FLAG_NONE,
718 DPO_ADJACENCY_MCAST, ai_1,
719 DPO_ADJACENCY_MCAST, ai_2,
720 DPO_ADJACENCY_MCAST, ai_3),
722 format_mfib_prefix, pfx_s_g);
723 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[0]->sw_if_index,
724 MFIB_ITF_FLAG_ACCEPT));
725 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[1]->sw_if_index,
726 MFIB_ITF_FLAG_FORWARD));
727 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[2]->sw_if_index,
728 MFIB_ITF_FLAG_FORWARD));
729 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[3]->sw_if_index,
730 (MFIB_ITF_FLAG_FORWARD |
731 MFIB_ITF_FLAG_ACCEPT |
732 MFIB_ITF_FLAG_NEGATE_SIGNAL)));
735 * update flags on the entry
737 mfib_table_entry_update(fib_index,
741 MFIB_ENTRY_FLAG_SIGNAL);
742 MFIB_TEST(mfib_test_entry(mfei,
743 MFIB_ENTRY_FLAG_SIGNAL,
745 DPO_ADJACENCY_MCAST, ai_1,
746 DPO_ADJACENCY_MCAST, ai_2,
747 DPO_ADJACENCY_MCAST, ai_3),
749 format_mfib_prefix, pfx_s_g);
754 mfib_table_entry_path_remove(fib_index,
759 MFIB_TEST(mfib_test_entry(mfei,
760 MFIB_ENTRY_FLAG_SIGNAL,
762 DPO_ADJACENCY_MCAST, ai_1,
763 DPO_ADJACENCY_MCAST, ai_2),
765 format_mfib_prefix, pfx_s_g);
766 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[0]->sw_if_index,
767 MFIB_ITF_FLAG_ACCEPT));
768 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[1]->sw_if_index,
769 MFIB_ITF_FLAG_FORWARD));
770 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[2]->sw_if_index,
771 MFIB_ITF_FLAG_FORWARD));
772 MFIB_TEST_NS(mfib_test_entry_no_itf(mfei, tm->hw[3]->sw_if_index));
774 mfib_table_entry_path_remove(fib_index,
779 MFIB_TEST(mfib_test_entry(mfei,
780 MFIB_ENTRY_FLAG_SIGNAL,
782 DPO_ADJACENCY_MCAST, ai_2),
784 format_mfib_prefix, pfx_s_g);
785 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[0]->sw_if_index,
786 MFIB_ITF_FLAG_ACCEPT));
787 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[2]->sw_if_index,
788 MFIB_ITF_FLAG_FORWARD));
789 MFIB_TEST_NS(mfib_test_entry_no_itf(mfei, tm->hw[3]->sw_if_index));
792 * remove the accpeting only interface
794 mfib_table_entry_path_remove(fib_index,
799 MFIB_TEST(mfib_test_entry(mfei,
800 MFIB_ENTRY_FLAG_SIGNAL,
802 DPO_ADJACENCY_MCAST, ai_2),
804 format_mfib_prefix, pfx_s_g);
805 MFIB_TEST_NS(mfib_test_entry_itf(mfei, tm->hw[2]->sw_if_index,
806 MFIB_ITF_FLAG_FORWARD));
807 MFIB_TEST_NS(mfib_test_entry_no_itf(mfei, tm->hw[0]->sw_if_index));
808 MFIB_TEST_NS(mfib_test_entry_no_itf(mfei, tm->hw[1]->sw_if_index));
809 MFIB_TEST_NS(mfib_test_entry_no_itf(mfei, tm->hw[3]->sw_if_index));
812 * remove the last path, the entry still has flags so it remains
814 mfib_table_entry_path_remove(fib_index,
819 MFIB_TEST(mfib_test_entry(mfei,
820 MFIB_ENTRY_FLAG_SIGNAL,
822 "%U no replications",
823 format_mfib_prefix, pfx_s_g);
826 * update flags on the entry
828 mfib_table_entry_update(fib_index,
832 (MFIB_ENTRY_FLAG_SIGNAL |
833 MFIB_ENTRY_FLAG_CONNECTED));
834 MFIB_TEST(mfib_test_entry(mfei,
835 (MFIB_ENTRY_FLAG_SIGNAL |
836 MFIB_ENTRY_FLAG_CONNECTED),
838 "%U no replications",
839 format_mfib_prefix, pfx_s_g);
842 * An entry with a NS interface
844 mfei_g_2 = mfib_table_entry_path_update(fib_index,
848 (MFIB_ITF_FLAG_ACCEPT |
849 MFIB_ITF_FLAG_NEGATE_SIGNAL));
850 MFIB_TEST(mfib_test_entry(mfei_g_2,
851 MFIB_ENTRY_FLAG_NONE,
853 "%U No replications",
854 format_mfib_prefix, pfx_star_g_2);
857 * Simulate a signal from the data-plane
863 mfe = mfib_entry_get(mfei_g_2);
864 mfi = mfib_entry_get_itf(mfe, path_via_if0.frp_sw_if_index);
866 mfib_signal_push(mfe, mfi, NULL);
870 * An entry with a NS interface
872 mfei_g_3 = mfib_table_entry_path_update(fib_index,
876 (MFIB_ITF_FLAG_ACCEPT |
877 MFIB_ITF_NEGATE_SIGNAL));
878 MFIB_TEST(mfib_test_entry(mfei_g_3,
879 MFIB_ENTRY_FLAG_NONE,
881 "%U No replications",
882 format_mfib_prefix, pfx_star_g_3);
885 * Simulate a signal from the data-plane
891 mfe = mfib_entry_get(mfei_g_3);
892 mfi = mfib_entry_get_itf(mfe, path_via_if0.frp_sw_if_index);
894 mfib_signal_push(mfe, mfi, NULL);
897 if (FIB_PROTOCOL_IP6 == PROTO)
900 * All the entries are present. let's ensure we can find them all
901 * via exact and longest prefix matches.
904 * A source address we will never match
906 ip6_address_t src = {
907 .as_u64[0] = clib_host_to_net_u64(0x3001000000000000),
908 .as_u64[1] = clib_host_to_net_u64(0xffffffffffffffff),
914 MFIB_TEST((mfei_g_m == ip6_mfib_table_lookup2(
915 ip6_mfib_get(fib_index),
917 &pfx_star_g_slash_m->fp_grp_addr.ip6)),
918 "%U found via DP LPM grp=%U",
919 format_mfib_prefix, pfx_star_g_slash_m,
920 format_ip6_address, &pfx_star_g_slash_m->fp_grp_addr.ip6);
922 ip6_address_t tmp = pfx_star_g_slash_m->fp_grp_addr.ip6;
923 tmp.as_u8[15] = 0xff;
925 MFIB_TEST((mfei_g_m == ip6_mfib_table_lookup2(
926 ip6_mfib_get(fib_index),
927 &pfx_s_g->fp_src_addr.ip6,
929 "%U found via DP LPM grp=%U",
930 format_mfib_prefix, pfx_star_g_slash_m,
931 format_ip6_address, &tmp);
936 mfei = ip6_mfib_table_lookup2(ip6_mfib_get(fib_index),
937 &pfx_s_g->fp_src_addr.ip6,
938 &pfx_s_g->fp_grp_addr.ip6);
939 MFIB_TEST((mfei_s_g == mfei),
940 "%U found via DP LPM: %d",
941 format_mfib_prefix, pfx_s_g, mfei);
946 mfei = ip6_mfib_table_lookup2(ip6_mfib_get(fib_index),
948 &pfx_star_g_1->fp_grp_addr.ip6);
949 MFIB_TEST((mfei_g_1 == mfei),
950 "%U found via DP LPM: %d",
951 format_mfib_prefix, pfx_star_g_1, mfei);
952 mfei = ip6_mfib_table_lookup2(ip6_mfib_get(fib_index),
954 &pfx_star_g_2->fp_grp_addr.ip6);
955 MFIB_TEST((mfei_g_2 == mfei),
956 "%U found via DP LPM: %d",
957 format_mfib_prefix, pfx_star_g_2, mfei);
958 mfei = ip6_mfib_table_lookup2(ip6_mfib_get(fib_index),
960 &pfx_star_g_3->fp_grp_addr.ip6);
961 MFIB_TEST((mfei_g_3 == mfei),
962 "%U found via DP LPM: %d",
963 format_mfib_prefix, pfx_star_g_3, mfei);
967 * remove flags on the entry. This is the last of the
968 * state associated with the entry, so now it goes.
970 mfib_table_entry_update(fib_index,
974 MFIB_ENTRY_FLAG_NONE);
975 mfei = mfib_table_lookup_exact_match(fib_index,
977 MFIB_TEST(FIB_NODE_INDEX_INVALID == mfei,
979 format_mfib_prefix, pfx_s_g);
982 * remove the last path on the no forward entry - the last entry
984 mfib_table_entry_path_remove(fib_index,
989 mfei = mfib_table_lookup_exact_match(fib_index, pfx_no_forward);
990 MFIB_TEST(FIB_NODE_INDEX_INVALID == mfei,
992 format_mfib_prefix, pfx_no_forward);
995 * hard delete the (*,232.1.1.1)
997 mfib_table_entry_delete(fib_index,
1001 mfei = mfib_table_lookup_exact_match(fib_index, pfx_star_g_1);
1002 MFIB_TEST(FIB_NODE_INDEX_INVALID == mfei,
1004 format_mfib_prefix, pfx_star_g_1);
1006 * remove the entry whilst the signal is pending
1008 mfib_table_entry_delete(fib_index,
1012 mfei = mfib_table_lookup_exact_match(fib_index, pfx_star_g_2);
1013 MFIB_TEST(FIB_NODE_INDEX_INVALID == mfei,
1015 format_mfib_prefix, pfx_star_g_2);
1016 mfib_table_entry_delete(fib_index,
1020 mfei = mfib_table_lookup_exact_match(fib_index, pfx_star_g_3);
1021 MFIB_TEST(FIB_NODE_INDEX_INVALID == mfei,
1023 format_mfib_prefix, pfx_star_g_3);
1025 mfib_table_entry_delete(fib_index,
1029 mfei = mfib_table_lookup_exact_match(fib_index, pfx_star_g_slash_m);
1030 MFIB_TEST(FIB_NODE_INDEX_INVALID == mfei,
1032 format_mfib_prefix, pfx_star_g_slash_m);
1035 * Add a prefix as a special/exclusive route
1037 dpo_id_t td = DPO_INVALID;
1038 index_t repi = replicate_create(1, fib_proto_to_dpo(PROTO));
1040 dpo_set(&td, DPO_ADJACENCY_MCAST, fib_proto_to_dpo(PROTO), ai_2);
1041 replicate_set_bucket(repi, 0, &td);
1043 mfei = mfib_table_entry_special_add(fib_index,
1046 MFIB_ENTRY_FLAG_ACCEPT_ALL_ITF,
1048 MFIB_TEST(mfib_test_entry(mfei,
1049 (MFIB_ENTRY_FLAG_ACCEPT_ALL_ITF |
1050 MFIB_ENTRY_FLAG_EXCLUSIVE),
1052 DPO_ADJACENCY_MCAST, ai_2),
1053 "%U exclusive replicate OK",
1054 format_mfib_prefix, pfx_star_g_3);
1057 * update a special/exclusive route
1059 index_t repi2 = replicate_create(1, fib_proto_to_dpo(PROTO));
1061 dpo_set(&td, DPO_ADJACENCY_MCAST, fib_proto_to_dpo(PROTO), ai_1);
1062 replicate_set_bucket(repi2, 0, &td);
1064 mfei = mfib_table_entry_special_add(fib_index,
1067 MFIB_ENTRY_FLAG_ACCEPT_ALL_ITF,
1069 MFIB_TEST(mfib_test_entry(mfei,
1070 (MFIB_ENTRY_FLAG_ACCEPT_ALL_ITF |
1071 MFIB_ENTRY_FLAG_EXCLUSIVE),
1073 DPO_ADJACENCY_MCAST, ai_1),
1074 "%U exclusive update replicate OK",
1075 format_mfib_prefix, pfx_star_g_3);
1077 mfib_table_entry_delete(fib_index,
1083 * A Multicast LSP. This a mLDP head-end
1085 fib_node_index_t ai_mpls_10_10_10_1, lfei;
1086 ip46_address_t nh_10_10_10_1 = {
1088 .as_u32 = clib_host_to_net_u32(0x0a0a0a01),
1091 ai_mpls_10_10_10_1 = adj_nbr_add_or_lock(FIB_PROTOCOL_IP4,
1094 tm->hw[0]->sw_if_index);
1096 fib_prefix_t pfx_3500 = {
1098 .fp_proto = FIB_PROTOCOL_MPLS,
1101 .fp_payload_proto = DPO_PROTO_IP4,
1103 fib_test_rep_bucket_t mc_0 = {
1104 .type = FT_REP_LABEL_O_ADJ,
1106 .adj = ai_mpls_10_10_10_1,
1111 mpls_label_t *l3300 = NULL;
1112 vec_add1(l3300, 3300);
1115 * MPLS enable an interface so we get the MPLS table created
1117 mpls_table_create(MPLS_FIB_DEFAULT_TABLE_ID, FIB_SOURCE_API, NULL);
1118 mpls_sw_interface_enable_disable(&mpls_main,
1119 tm->hw[0]->sw_if_index,
1122 lfei = fib_table_entry_update_one_path(0, // default MPLS Table
1125 FIB_ENTRY_FLAG_MULTICAST,
1128 tm->hw[0]->sw_if_index,
1129 ~0, // invalid fib index
1132 FIB_ROUTE_PATH_FLAG_NONE);
1133 MFIB_TEST(fib_test_validate_entry(lfei,
1134 FIB_FORW_CHAIN_TYPE_MPLS_EOS,
1137 "3500 via replicate over 10.10.10.1");
1140 * An (S,G) that resolves via the mLDP head-end
1142 fib_route_path_t path_via_mldp = {
1143 .frp_proto = DPO_PROTO_MPLS,
1144 .frp_local_label = pfx_3500.fp_label,
1145 .frp_eos = MPLS_EOS,
1146 .frp_sw_if_index = 0xffffffff,
1149 .frp_flags = FIB_ROUTE_PATH_FLAG_NONE,
1151 dpo_id_t mldp_dpo = DPO_INVALID;
1153 fib_entry_contribute_forwarding(lfei,
1154 FIB_FORW_CHAIN_TYPE_MPLS_EOS,
1157 mfei = mfib_table_entry_path_update(fib_index,
1161 MFIB_ITF_FLAG_FORWARD);
1163 MFIB_TEST(mfib_test_entry(mfei,
1164 MFIB_ENTRY_FLAG_NONE,
1166 DPO_REPLICATE, mldp_dpo.dpoi_index),
1167 "%U over-mLDP replicate OK",
1168 format_mfib_prefix, pfx_s_g);
1171 * add a for-us path. this tests two types of non-attached paths on one entry
1173 mfei = mfib_table_entry_path_update(fib_index,
1177 MFIB_ITF_FLAG_FORWARD);
1178 MFIB_TEST(mfib_test_entry(mfei,
1179 MFIB_ENTRY_FLAG_NONE,
1181 DPO_REPLICATE, mldp_dpo.dpoi_index,
1183 "%U mLDP+for-us replicate OK",
1184 format_mfib_prefix, pfx_s_g);
1186 mfib_table_entry_delete(fib_index,
1189 fib_table_entry_delete(0,
1192 dpo_reset(&mldp_dpo);
1195 * Unlock the table - it's the last lock so should be gone thereafter
1197 mfib_table_unlock(fib_index, PROTO, MFIB_SOURCE_API);
1199 MFIB_TEST((FIB_NODE_INDEX_INVALID ==
1200 mfib_table_find(PROTO, fib_index)),
1201 "MFIB table %d gone", fib_index);
1208 * MPLS disable the interface
1210 mpls_sw_interface_enable_disable(&mpls_main,
1211 tm->hw[0]->sw_if_index,
1213 mpls_table_delete(MPLS_FIB_DEFAULT_TABLE_ID, FIB_SOURCE_API);
1216 * test we've leaked no resources
1218 MFIB_TEST(0 == adj_mcast_db_size(), "%d MCAST adjs", adj_mcast_db_size());
1219 MFIB_TEST(n_pls == fib_path_list_pool_size(), "%d=%d path-lists",
1220 n_pls, fib_path_list_pool_size());
1221 MFIB_TEST(n_reps == pool_elts(replicate_pool), "%d=%d replicates",
1222 n_reps, pool_elts(replicate_pool));
1223 MFIB_TEST(n_entries == pool_elts(mfib_entry_pool),
1224 " No more entries %d!=%d",
1225 n_entries, pool_elts(mfib_entry_pool));
1226 MFIB_TEST(n_itfs == pool_elts(mfib_itf_pool),
1227 " No more Interfaces %d!=%d",
1228 n_itfs, pool_elts(mfib_itf_pool));
1236 const mfib_prefix_t pfx_224_s_8 = {
1238 .fp_proto = FIB_PROTOCOL_IP4,
1240 .ip4.as_u32 = clib_host_to_net_u32(0xe0000000),
1243 const mfib_prefix_t pfx_1_1_1_1_c_239_1_1_1 = {
1245 .fp_proto = FIB_PROTOCOL_IP4,
1247 .ip4.as_u32 = clib_host_to_net_u32(0xef010101),
1250 .ip4.as_u32 = clib_host_to_net_u32(0x01010101),
1253 const mfib_prefix_t pfx_239_1_1_1 = {
1255 .fp_proto = FIB_PROTOCOL_IP4,
1257 .ip4.as_u32 = clib_host_to_net_u32(0xef010101),
1263 const mfib_prefix_t pfx_239_1_1_2 = {
1265 .fp_proto = FIB_PROTOCOL_IP4,
1267 .ip4.as_u32 = clib_host_to_net_u32(0xef010102),
1273 const mfib_prefix_t pfx_239_1_1_3 = {
1275 .fp_proto = FIB_PROTOCOL_IP4,
1277 .ip4.as_u32 = clib_host_to_net_u32(0xef010103),
1283 const mfib_prefix_t pfx_239 = {
1285 .fp_proto = FIB_PROTOCOL_IP4,
1287 .ip4.as_u32 = clib_host_to_net_u32(0xef000000),
1294 return (mfib_test_i(FIB_PROTOCOL_IP4,
1297 &pfx_1_1_1_1_c_239_1_1_1,
1307 const mfib_prefix_t pfx_ffd_s_12 = {
1309 .fp_proto = FIB_PROTOCOL_IP6,
1311 .ip6.as_u64[0] = clib_host_to_net_u64(0xffd0000000000000),
1314 const mfib_prefix_t pfx_2001_1_c_ff_1 = {
1316 .fp_proto = FIB_PROTOCOL_IP6,
1318 .ip6.as_u64[0] = clib_host_to_net_u64(0xff01000000000000),
1319 .ip6.as_u64[1] = clib_host_to_net_u64(0x0000000000000001),
1322 .ip6.as_u64[0] = clib_host_to_net_u64(0x2001000000000000),
1323 .ip6.as_u64[1] = clib_host_to_net_u64(0x0000000000000001),
1326 const mfib_prefix_t pfx_ff_1 = {
1328 .fp_proto = FIB_PROTOCOL_IP6,
1330 .ip6.as_u64[0] = clib_host_to_net_u64(0xff01000000000000),
1331 .ip6.as_u64[1] = clib_host_to_net_u64(0x0000000000000001),
1334 const mfib_prefix_t pfx_ff_2 = {
1336 .fp_proto = FIB_PROTOCOL_IP6,
1338 .ip6.as_u64[0] = clib_host_to_net_u64(0xff01000000000000),
1339 .ip6.as_u64[1] = clib_host_to_net_u64(0x0000000000000002),
1342 const mfib_prefix_t pfx_ff_3 = {
1344 * this is the ALL DHCP routers address
1347 .fp_proto = FIB_PROTOCOL_IP6,
1349 .ip6.as_u64[0] = clib_host_to_net_u64(0xff02000100000000),
1350 .ip6.as_u64[1] = clib_host_to_net_u64(0x0000000000000002),
1353 const mfib_prefix_t pfx_ff = {
1355 .fp_proto = FIB_PROTOCOL_IP6,
1357 .ip6.as_u64[0] = clib_host_to_net_u64(0xff01000000000000),
1358 .ip6.as_u64[1] = clib_host_to_net_u64(0x0000000000000000),
1362 return (mfib_test_i(FIB_PROTOCOL_IP6,
1372 static clib_error_t *
1373 mfib_test (vlib_main_t * vm,
1374 unformat_input_t * input,
1375 vlib_cli_command_t * cmd_arg)
1379 res += mfib_test_mk_intf(4);
1380 res += mfib_test_v4();
1381 res += mfib_test_v6();
1385 return clib_error_return(0, "MFIB Unit Test Failed");
1393 VLIB_CLI_COMMAND (test_fib_command, static) = {
1394 .path = "test mfib",
1395 .short_help = "mfib unit tests - DO NOT RUN ON A LIVE SYSTEM",
1396 .function = mfib_test,
1400 mfib_test_init (vlib_main_t *vm)
1405 VLIB_INIT_FUNCTION (mfib_test_init);