fib: multiple memory leaks upon deleting a VRF table
[vpp.git] / src / vnet / ip / lookup.c
1 /*
2  * Copyright (c) 2015 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  * ip/ip_lookup.c: ip4/6 adjacency and lookup table management
17  *
18  * Copyright (c) 2008 Eliot Dresselhaus
19  *
20  * Permission is hereby granted, free of charge, to any person obtaining
21  * a copy of this software and associated documentation files (the
22  * "Software"), to deal in the Software without restriction, including
23  * without limitation the rights to use, copy, modify, merge, publish,
24  * distribute, sublicense, and/or sell copies of the Software, and to
25  * permit persons to whom the Software is furnished to do so, subject to
26  * the following conditions:
27  *
28  * The above copyright notice and this permission notice shall be
29  * included in all copies or substantial portions of the Software.
30  *
31  *  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
32  *  EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
33  *  MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
34  *  NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
35  *  LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
36  *  OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
37  *  WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
38  */
39
40 #include <vnet/ip/ip.h>
41 #include <vnet/adj/adj.h>
42 #include <vnet/fib/fib_table.h>
43 #include <vnet/fib/ip4_fib.h>
44 #include <vnet/fib/ip6_fib.h>
45 #include <vnet/mpls/mpls.h>
46 #include <vnet/mfib/mfib_table.h>
47 #include <vnet/dpo/drop_dpo.h>
48 #include <vnet/dpo/classify_dpo.h>
49 #include <vnet/dpo/punt_dpo.h>
50 #include <vnet/dpo/receive_dpo.h>
51 #include <vnet/dpo/ip_null_dpo.h>
52
53 /**
54  * @file
55  * @brief IPv4 and IPv6 adjacency and lookup table management.
56  *
57  */
58
59 static clib_error_t *
60 ip_sw_interface_add_del (vnet_main_t * vnm, u32 sw_if_index, u32 is_add)
61 {
62   vec_validate_init_empty (ip4_main.
63                            lookup_main.if_address_pool_index_by_sw_if_index,
64                            sw_if_index, ~0);
65   vec_validate_init_empty (ip6_main.
66                            lookup_main.if_address_pool_index_by_sw_if_index,
67                            sw_if_index, ~0);
68
69   return (NULL);
70 }
71
72 VNET_SW_INTERFACE_ADD_DEL_FUNCTION (ip_sw_interface_add_del);
73
74 void
75 ip_lookup_init (ip_lookup_main_t * lm, u32 is_ip6)
76 {
77   if (!lm->fib_result_n_bytes)
78     lm->fib_result_n_bytes = sizeof (uword);
79
80   lm->is_ip6 = is_ip6;
81   mhash_init (&lm->prefix_to_if_prefix_index, sizeof (uword),
82               sizeof (ip_interface_prefix_key_t));
83   if (is_ip6)
84     {
85       lm->format_address_and_length = format_ip6_address_and_length;
86       mhash_init (&lm->address_to_if_address_index, sizeof (uword),
87                   sizeof (ip6_address_fib_t));
88     }
89   else
90     {
91       lm->format_address_and_length = format_ip4_address_and_length;
92       mhash_init (&lm->address_to_if_address_index, sizeof (uword),
93                   sizeof (ip4_address_fib_t));
94     }
95
96   {
97     int i;
98
99     /* Setup all IP protocols to be punted and builtin-unknown. */
100     for (i = 0; i < 256; i++)
101       {
102         lm->local_next_by_ip_protocol[i] = IP_LOCAL_NEXT_PUNT;
103         lm->builtin_protocol_by_ip_protocol[i] = IP_BUILTIN_PROTOCOL_UNKNOWN;
104       }
105
106     lm->local_next_by_ip_protocol[IP_PROTOCOL_UDP] = IP_LOCAL_NEXT_UDP_LOOKUP;
107     lm->local_next_by_ip_protocol[is_ip6 ? IP_PROTOCOL_ICMP6 :
108                                   IP_PROTOCOL_ICMP] = IP_LOCAL_NEXT_ICMP;
109     lm->builtin_protocol_by_ip_protocol[IP_PROTOCOL_UDP] =
110       IP_BUILTIN_PROTOCOL_UDP;
111     lm->builtin_protocol_by_ip_protocol[is_ip6 ? IP_PROTOCOL_ICMP6 :
112                                         IP_PROTOCOL_ICMP] =
113       IP_BUILTIN_PROTOCOL_ICMP;
114   }
115 }
116
117 u8 *
118 format_ip_flow_hash_config (u8 * s, va_list * args)
119 {
120   flow_hash_config_t flow_hash_config = va_arg (*args, u32);
121
122 #define _(n, b, v)                                                            \
123   if (flow_hash_config & v)                                                   \
124     s = format (s, "%s ", #n);
125   foreach_flow_hash_bit;
126 #undef _
127
128   return s;
129 }
130
131 u8 *
132 format_ip_adjacency_packet_data (u8 * s, va_list * args)
133 {
134   u8 *packet_data = va_arg (*args, u8 *);
135   u32 n_packet_data_bytes = va_arg (*args, u32);
136
137   s = format (s, "%U", format_hex_bytes, packet_data, n_packet_data_bytes);
138
139   return s;
140 }
141
142 static uword
143 unformat_dpo (unformat_input_t * input, va_list * args)
144 {
145   dpo_id_t *dpo = va_arg (*args, dpo_id_t *);
146   fib_protocol_t fp = va_arg (*args, int);
147   dpo_proto_t proto;
148
149   proto = fib_proto_to_dpo (fp);
150
151   if (unformat (input, "drop"))
152     dpo_copy (dpo, drop_dpo_get (proto));
153   else if (unformat (input, "punt"))
154     dpo_copy (dpo, punt_dpo_get (proto));
155   else if (unformat (input, "local"))
156     receive_dpo_add_or_lock (proto, ~0, NULL, dpo);
157   else if (unformat (input, "null-send-unreach"))
158     ip_null_dpo_add_and_lock (proto, IP_NULL_ACTION_SEND_ICMP_UNREACH, dpo);
159   else if (unformat (input, "null-send-prohibit"))
160     ip_null_dpo_add_and_lock (proto, IP_NULL_ACTION_SEND_ICMP_PROHIBIT, dpo);
161   else if (unformat (input, "null"))
162     ip_null_dpo_add_and_lock (proto, IP_NULL_ACTION_NONE, dpo);
163   else if (unformat (input, "classify"))
164     {
165       u32 classify_table_index;
166
167       if (!unformat (input, "%d", &classify_table_index))
168         {
169           clib_warning ("classify adj must specify table index");
170           return 0;
171         }
172
173       dpo_set (dpo, DPO_CLASSIFY, proto,
174                classify_dpo_create (proto, classify_table_index));
175     }
176   else
177     return 0;
178
179   return 1;
180 }
181
182 const ip46_address_t zero_addr = {
183   .as_u64 = {
184              0, 0},
185 };
186
187 static clib_error_t *
188 vnet_ip_route_cmd (vlib_main_t * vm,
189                    unformat_input_t * main_input, vlib_cli_command_t * cmd)
190 {
191   unformat_input_t _line_input, *line_input = &_line_input;
192   u32 table_id, is_del, fib_index, payload_proto;
193   dpo_id_t dpo = DPO_INVALID, *dpos = NULL;
194   fib_route_path_t *rpaths = NULL, rpath;
195   fib_prefix_t *prefixs = NULL, pfx;
196   clib_error_t *error = NULL;
197   f64 count;
198   int i;
199
200   is_del = 0;
201   table_id = 0;
202   count = 1;
203   clib_memset (&pfx, 0, sizeof (pfx));
204
205   /* Get a line of input. */
206   if (!unformat_user (main_input, unformat_line_input, line_input))
207     return 0;
208
209   while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
210     {
211       clib_memset (&rpath, 0, sizeof (rpath));
212
213       if (unformat (line_input, "table %d", &table_id))
214         ;
215       else if (unformat (line_input, "count %f", &count))
216         ;
217
218       else if (unformat (line_input, "%U/%d",
219                          unformat_ip4_address, &pfx.fp_addr.ip4, &pfx.fp_len))
220         {
221           payload_proto = pfx.fp_proto = FIB_PROTOCOL_IP4;
222           vec_add1 (prefixs, pfx);
223         }
224       else if (unformat (line_input, "%U/%d",
225                          unformat_ip6_address, &pfx.fp_addr.ip6, &pfx.fp_len))
226         {
227           payload_proto = pfx.fp_proto = FIB_PROTOCOL_IP6;
228           vec_add1 (prefixs, pfx);
229         }
230       else if (unformat (line_input, "via %U",
231                          unformat_fib_route_path, &rpath, &payload_proto))
232         {
233           vec_add1 (rpaths, rpath);
234         }
235       else if (vec_len (prefixs) > 0 &&
236                unformat (line_input, "via %U",
237                          unformat_dpo, &dpo, prefixs[0].fp_proto))
238         {
239           vec_add1 (dpos, dpo);
240         }
241       else if (unformat (line_input, "del"))
242         is_del = 1;
243       else if (unformat (line_input, "add"))
244         is_del = 0;
245       else
246         {
247           error = unformat_parse_error (line_input);
248           goto done;
249         }
250     }
251
252   if (vec_len (prefixs) == 0)
253     {
254       error =
255         clib_error_return (0, "expected ip4/ip6 destination address/length.");
256       goto done;
257     }
258
259   if (!is_del && vec_len (rpaths) + vec_len (dpos) == 0)
260     {
261       error = clib_error_return (0, "expected paths.");
262       goto done;
263     }
264
265   if (~0 == table_id)
266     {
267       /*
268        * if no table_id is passed we will manipulate the default
269        */
270       fib_index = 0;
271     }
272   else
273     {
274       fib_index = fib_table_find (prefixs[0].fp_proto, table_id);
275
276       if (~0 == fib_index)
277         {
278           error = clib_error_return (0, "Nonexistent table id %d", table_id);
279           goto done;
280         }
281     }
282
283   for (i = 0; i < vec_len (prefixs); i++)
284     {
285       if (is_del && 0 == vec_len (rpaths))
286         {
287           fib_table_entry_delete (fib_index, &prefixs[i], FIB_SOURCE_CLI);
288         }
289       else if (!is_del && 1 == vec_len (dpos))
290         {
291           fib_table_entry_special_dpo_add (fib_index,
292                                            &prefixs[i],
293                                            FIB_SOURCE_CLI,
294                                            FIB_ENTRY_FLAG_EXCLUSIVE,
295                                            &dpos[0]);
296           dpo_reset (&dpos[0]);
297         }
298       else if (vec_len (dpos) > 0)
299         {
300           error =
301             clib_error_return (0,
302                                "Load-balancing over multiple special adjacencies is unsupported");
303           goto done;
304         }
305       else if (0 < vec_len (rpaths))
306         {
307           u32 k, n;
308           f64 t[2];
309           n = count;
310           t[0] = vlib_time_now (vm);
311
312           for (k = 0; k < n; k++)
313             {
314               fib_prefix_t rpfx = {
315                 .fp_len = prefixs[i].fp_len,
316                 .fp_proto = prefixs[i].fp_proto,
317                 .fp_addr = prefixs[i].fp_addr,
318               };
319
320               if (is_del)
321                 fib_table_entry_path_remove2 (fib_index,
322                                               &rpfx, FIB_SOURCE_CLI, rpaths);
323               else
324                 fib_table_entry_path_add2 (fib_index,
325                                            &rpfx,
326                                            FIB_SOURCE_CLI,
327                                            FIB_ENTRY_FLAG_NONE, rpaths);
328
329               fib_prefix_increment (&prefixs[i]);
330             }
331
332           t[1] = vlib_time_now (vm);
333           if (count > 1)
334             vlib_cli_output (vm, "%.6e routes/sec", count / (t[1] - t[0]));
335         }
336       else
337         {
338           error = clib_error_return (0, "Don't understand what you want...");
339           goto done;
340         }
341     }
342
343 done:
344   vec_free (dpos);
345   vec_free (prefixs);
346   vec_free (rpaths);
347   unformat_free (line_input);
348   return error;
349 }
350
351 clib_error_t *
352 vnet_ip_table_cmd (vlib_main_t * vm,
353                    unformat_input_t * main_input,
354                    vlib_cli_command_t * cmd, fib_protocol_t fproto)
355 {
356   unformat_input_t _line_input, *line_input = &_line_input;
357   clib_error_t *error = NULL;
358   u32 table_id, is_add;
359   u8 *name = NULL;
360
361   is_add = 1;
362   table_id = ~0;
363
364   /* Get a line of input. */
365   if (!unformat_user (main_input, unformat_line_input, line_input))
366     return 0;
367
368   while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
369     {
370       if (unformat (line_input, "%d", &table_id))
371         ;
372       else if (unformat (line_input, "del"))
373         is_add = 0;
374       else if (unformat (line_input, "add"))
375         is_add = 1;
376       else if (unformat (line_input, "name %s", &name))
377         ;
378       else
379         {
380           error = unformat_parse_error (line_input);
381           goto done;
382         }
383     }
384
385   if (0 == table_id)
386     {
387       error = clib_error_return (0, "Can't change the default table");
388       goto done;
389     }
390   else
391         {
392           if (is_add)
393             {
394               if (~0 == table_id)
395                 {
396                   table_id = ip_table_get_unused_id (fproto);
397                   vlib_cli_output (vm, "%u\n", table_id);
398                 }
399               ip_table_create (fproto, table_id, 0, name);
400             }
401           else
402             {
403               if (~0 == table_id)
404                 {
405                   error = clib_error_return (0, "No table id");
406                   goto done;
407                 }
408               ip_table_delete (fproto, table_id, 0);
409             }
410         }
411
412 done:
413   vec_free (name);
414   unformat_free (line_input);
415   return error;
416 }
417
418 clib_error_t *
419 vnet_ip4_table_cmd (vlib_main_t * vm,
420                     unformat_input_t * main_input, vlib_cli_command_t * cmd)
421 {
422   return (vnet_ip_table_cmd (vm, main_input, cmd, FIB_PROTOCOL_IP4));
423 }
424
425 clib_error_t *
426 vnet_ip6_table_cmd (vlib_main_t * vm,
427                     unformat_input_t * main_input, vlib_cli_command_t * cmd)
428 {
429   return (vnet_ip_table_cmd (vm, main_input, cmd, FIB_PROTOCOL_IP6));
430 }
431
432 clib_error_t *
433 vnet_show_ip_table_cmd (vlib_main_t *vm, unformat_input_t *main_input,
434                         vlib_cli_command_t *cmd, fib_protocol_t fproto)
435 {
436   unformat_input_t _line_input, *line_input = &_line_input;
437   fib_table_t *fib, *fibs;
438   clib_error_t *error = NULL;
439   u32 table_id = ~0, fib_index;
440   /* Get a line of input. */
441   if (unformat_user (main_input, unformat_line_input, line_input))
442     {
443       while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
444         {
445           if (unformat (line_input, "%d", &table_id))
446             ;
447           else
448             {
449               error = unformat_parse_error (line_input);
450               goto done;
451             }
452         }
453       unformat_free (line_input);
454     }
455
456   fibs = (fproto == FIB_PROTOCOL_IP4) ? ip4_main.fibs : ip6_main.fibs;
457
458   if (table_id != (u32) ~0)
459     {
460       fib_index = fib_table_find (fproto, table_id);
461       if (fib_index == (u32) ~0)
462         {
463           error = clib_error_return (0, "Couldn't find table with table_id %u",
464                                      table_id);
465           goto done;
466         }
467
468       fib = fib_table_get (fib_index, fproto);
469       vlib_cli_output (vm, "[%3u] table_id:%3u %v", fib->ft_index,
470                        fib->ft_table_id, fib->ft_desc);
471     }
472   else
473     {
474       pool_foreach (fib, fibs)
475         vlib_cli_output (vm, "[%3u] table_id:%3u %v", fib->ft_index,
476                          fib->ft_table_id, fib->ft_desc);
477     }
478
479 done:
480   return error;
481 }
482
483 clib_error_t *
484 vnet_show_ip4_table_cmd (vlib_main_t *vm, unformat_input_t *main_input,
485                          vlib_cli_command_t *cmd)
486 {
487   return (vnet_show_ip_table_cmd (vm, main_input, cmd, FIB_PROTOCOL_IP4));
488 }
489
490 clib_error_t *
491 vnet_show_ip6_table_cmd (vlib_main_t *vm, unformat_input_t *main_input,
492                          vlib_cli_command_t *cmd)
493 {
494   return (vnet_show_ip_table_cmd (vm, main_input, cmd, FIB_PROTOCOL_IP6));
495 }
496
497 /* *INDENT-OFF* */
498 VLIB_CLI_COMMAND (vlib_cli_ip_command, static) = {
499   .path = "ip",
500   .short_help = "Internet protocol (IP) commands",
501 };
502 /* *INDENT-ON* */
503
504 /* *INDENT-OFF* */
505 VLIB_CLI_COMMAND (vlib_cli_ip6_command, static) = {
506   .path = "ip6",
507   .short_help = "Internet protocol version 6 (IPv6) commands",
508 };
509 /* *INDENT-ON* */
510
511 /* *INDENT-OFF* */
512 VLIB_CLI_COMMAND (vlib_cli_show_ip_command, static) = {
513   .path = "show ip",
514   .short_help = "Internet protocol (IP) show commands",
515 };
516 /* *INDENT-ON* */
517
518 /* *INDENT-OFF* */
519 VLIB_CLI_COMMAND (vlib_cli_show_ip6_command, static) = {
520   .path = "show ip6",
521   .short_help = "Internet protocol version 6 (IPv6) show commands",
522 };
523 /* *INDENT-ON* */
524
525 /*?
526  * This command is used to add or delete IPv4 or IPv6 routes. All
527  * IP Addresses ('<em><dst-ip-addr>/<width></em>',
528  * '<em><next-hop-ip-addr></em>' and '<em><adj-hop-ip-addr></em>')
529  * can be IPv4 or IPv6, but all must be of the same form in a single
530  * command. To display the current set of routes, use the commands
531  * '<em>show ip fib</em>' and '<em>show ip6 fib</em>'.
532  *
533  * @cliexpar
534  * Example of how to add a straight forward static route:
535  * @cliexcmd{ip route add 6.0.1.2/32 via 6.0.0.1 GigabitEthernet2/0/0}
536  * Example of how to delete a straight forward static route:
537  * @cliexcmd{ip route del 6.0.1.2/32 via 6.0.0.1 GigabitEthernet2/0/0}
538  * Mainly for route add/del performance testing, one can add or delete
539  * multiple routes by adding 'count N' to the previous item:
540  * @cliexcmd{ip route add count 10 7.0.0.0/24 via 6.0.0.1 GigabitEthernet2/0/0}
541  * Add multiple routes for the same destination to create equal-cost multipath:
542  * @cliexcmd{ip route add 7.0.0.1/32 via 6.0.0.1 GigabitEthernet2/0/0}
543  * @cliexcmd{ip route add 7.0.0.1/32 via 6.0.0.2 GigabitEthernet2/0/0}
544  * For unequal-cost multipath, specify the desired weights. This
545  * combination of weights results in 3/4 of the traffic following the
546  * second path, 1/4 following the first path:
547  * @cliexcmd{ip route add 7.0.0.1/32 via 6.0.0.1 GigabitEthernet2/0/0 weight 1}
548  * @cliexcmd{ip route add 7.0.0.1/32 via 6.0.0.2 GigabitEthernet2/0/0 weight 3}
549  * To add a route to a particular FIB table (VRF), use:
550  * @cliexcmd{ip route add 172.16.24.0/24 table 7 via GigabitEthernet2/0/0}
551  ?*/
552 /* *INDENT-OFF* */
553 VLIB_CLI_COMMAND (ip_route_command, static) = {
554   .path = "ip route",
555   .short_help = "ip route [add|del] [count <n>] <dst-ip-addr>/<width> [table <table-id>] via [next-hop-address] [next-hop-interface] [next-hop-table <value>] [weight <value>] [preference <value>] [udp-encap-id <value>] [ip4-lookup-in-table <value>] [ip6-lookup-in-table <value>] [mpls-lookup-in-table <value>] [resolve-via-host] [resolve-via-connected] [rx-ip4 <interface>] [out-labels <value value value>]",
556   .function = vnet_ip_route_cmd,
557   .is_mp_safe = 1,
558 };
559
560 /* *INDENT-ON* */
561 /*?
562  * This command is used to add or delete IPv4  Tables. All
563  * Tables must be explicitly added before that can be used. Creating a
564  * table will add both unicast and multicast FIBs
565  *
566  ?*/
567 /* *INDENT-OFF* */
568 VLIB_CLI_COMMAND (ip4_table_command, static) = {
569   .path = "ip table",
570   .short_help = "ip table [add|del] <table-id>",
571   .function = vnet_ip4_table_cmd,
572 };
573 /* *INDENT-ON* */
574
575 /* *INDENT-ON* */
576 /*?
577  * This command is used to add or delete IPv4  Tables. All
578  * Tables must be explicitly added before that can be used. Creating a
579  * table will add both unicast and multicast FIBs
580  *
581  ?*/
582 /* *INDENT-OFF* */
583 VLIB_CLI_COMMAND (ip6_table_command, static) = {
584   .path = "ip6 table",
585   .short_help = "ip6 table [add|del] <table-id>",
586   .function = vnet_ip6_table_cmd,
587 };
588
589 VLIB_CLI_COMMAND (show_ip4_table_command, static) = {
590   .path = "show ip table",
591   .short_help = "show ip table <table-id>",
592   .function = vnet_show_ip4_table_cmd,
593 };
594
595 VLIB_CLI_COMMAND (show_ip6_table_command, static) = {
596   .path = "show ip6 table",
597   .short_help = "show ip6 table <table-id>",
598   .function = vnet_show_ip6_table_cmd,
599 };
600
601 static clib_error_t *
602 ip_table_bind_cmd (vlib_main_t * vm,
603                    unformat_input_t * input,
604                    vlib_cli_command_t * cmd,
605                    fib_protocol_t fproto)
606 {
607   vnet_main_t *vnm = vnet_get_main ();
608   clib_error_t *error = 0;
609   u32 sw_if_index, table_id;
610   int rv;
611
612   sw_if_index = ~0;
613
614   if (!unformat_user (input, unformat_vnet_sw_interface, vnm, &sw_if_index))
615     {
616       error = clib_error_return (0, "unknown interface `%U'",
617                                  format_unformat_error, input);
618       goto done;
619     }
620
621   if (unformat (input, "%d", &table_id))
622     ;
623   else
624     {
625       error = clib_error_return (0, "expected table id `%U'",
626                                  format_unformat_error, input);
627       goto done;
628     }
629
630   rv = ip_table_bind (fproto, sw_if_index, table_id);
631
632   if (VNET_API_ERROR_ADDRESS_FOUND_FOR_INTERFACE == rv)
633     {
634       error = clib_error_return (0, "IP addresses are still present on %U",
635                                  format_vnet_sw_if_index_name,
636                                  vnet_get_main(),
637                                  sw_if_index);
638     }
639   else if (VNET_API_ERROR_NO_SUCH_FIB == rv)
640     {
641       error = clib_error_return (0, "no such table %d", table_id);
642     }
643   else if (0 != rv)
644     {
645       error = clib_error_return (0, "unknown error");
646     }
647
648  done:
649   return error;
650 }
651
652 static clib_error_t *
653 ip4_table_bind_cmd (vlib_main_t * vm,
654                     unformat_input_t * input,
655                     vlib_cli_command_t * cmd)
656 {
657   return (ip_table_bind_cmd (vm , input, cmd, FIB_PROTOCOL_IP4));
658 }
659
660 static clib_error_t *
661 ip6_table_bind_cmd (vlib_main_t * vm,
662                     unformat_input_t * input,
663                     vlib_cli_command_t * cmd)
664 {
665   return (ip_table_bind_cmd (vm , input, cmd, FIB_PROTOCOL_IP6));
666 }
667
668 /*?
669  * Place the indicated interface into the supplied IPv4 FIB table (also known
670  * as a VRF). The FIB table must be created using "ip table add" already. To
671  * display the current IPv4 FIB table, use the command '<em>show ip fib</em>'.
672  * FIB table will only be displayed if a route has been added to the table, or
673  * an IP Address is assigned to an interface in the table (which adds a route
674  * automatically).
675  *
676  * @note IP addresses added after setting the interface IP table are added to
677  * the indicated FIB table. If an IP address is added prior to changing the
678  * table then this is an error. The control plane must remove these addresses
679  * first and then change the table. VPP will not automatically move the
680  * addresses from the old to the new table as it does not know the validity
681  * of such a change.
682  *
683  * @cliexpar
684  * Example of how to add an interface to an IPv4 FIB table (where 2 is the table-id):
685  * @cliexcmd{set interface ip table GigabitEthernet2/0/0 2}
686  ?*/
687 /* *INDENT-OFF* */
688 VLIB_CLI_COMMAND (set_interface_ip_table_command, static) =
689 {
690   .path = "set interface ip table",
691   .function = ip4_table_bind_cmd,
692   .short_help = "set interface ip table <interface> <table-id>",
693 };
694 /* *INDENT-ON* */
695
696 /*?
697  * Place the indicated interface into the supplied IPv6 FIB table (also known
698  * as a VRF). The FIB table must be created using "ip6 table add" already. To
699  * display the current IPv6 FIB table, use the command '<em>show ip6 fib</em>'.
700  * FIB table will only be displayed if a route has been added to the table, or
701  * an IP Address is assigned to an interface in the table (which adds a route
702  * automatically).
703  *
704  * @note IP addresses added after setting the interface IP table are added to
705  * the indicated FIB table. If an IP address is added prior to changing the
706  * table then this is an error. The control plane must remove these addresses
707  * first and then change the table. VPP will not automatically move the
708  * addresses from the old to the new table as it does not know the validity
709  * of such a change.
710  *
711  * @cliexpar
712  * Example of how to add an interface to an IPv6 FIB table (where 2 is the table-id):
713  * @cliexcmd{set interface ip6 table GigabitEthernet2/0/0 2}
714  ?*/
715 /* *INDENT-OFF* */
716 VLIB_CLI_COMMAND (set_interface_ip6_table_command, static) =
717 {
718   .path = "set interface ip6 table",
719   .function = ip6_table_bind_cmd,
720   .short_help = "set interface ip6 table <interface> <table-id>"
721 };
722 /* *INDENT-ON* */
723
724 clib_error_t *
725 vnet_ip_mroute_cmd (vlib_main_t * vm,
726                     unformat_input_t * main_input, vlib_cli_command_t * cmd)
727 {
728   unformat_input_t _line_input, *line_input = &_line_input;
729   fib_route_path_t rpath, *rpaths = NULL;
730   clib_error_t *error = NULL;
731   u32 table_id, is_del, payload_proto;
732   mfib_prefix_t pfx;
733   u32 fib_index;
734   mfib_entry_flags_t eflags = 0;
735   u32 gcount, scount, ss, gg, incr;
736   f64 timet[2];
737   u32 rpf_id = MFIB_RPF_ID_NONE;
738
739   gcount = scount = 1;
740   is_del = 0;
741   table_id = 0;
742   clib_memset (&pfx, 0, sizeof (pfx));
743   clib_memset (&rpath, 0, sizeof (rpath));
744   rpath.frp_sw_if_index = ~0;
745
746   /* Get a line of input. */
747   if (!unformat_user (main_input, unformat_line_input, line_input))
748     return 0;
749
750   while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
751     {
752       if (unformat (line_input, "table %d", &table_id))
753         ;
754       else if (unformat (line_input, "del"))
755         is_del = 1;
756       else if (unformat (line_input, "add"))
757         is_del = 0;
758       else if (unformat (line_input, "rpf-id %d", &rpf_id))
759         ;
760       else if (unformat (line_input, "scount %d", &scount))
761         ;
762       else if (unformat (line_input, "gcount %d", &gcount))
763         ;
764       else if (unformat (line_input, "%U %U",
765                          unformat_ip4_address,
766                          &pfx.fp_src_addr.ip4,
767                          unformat_ip4_address, &pfx.fp_grp_addr.ip4))
768         {
769           payload_proto = pfx.fp_proto = FIB_PROTOCOL_IP4;
770           pfx.fp_len = 64;
771         }
772       else if (unformat (line_input, "%U %U",
773                          unformat_ip6_address,
774                          &pfx.fp_src_addr.ip6,
775                          unformat_ip6_address, &pfx.fp_grp_addr.ip6))
776         {
777           payload_proto = pfx.fp_proto = FIB_PROTOCOL_IP6;
778           pfx.fp_len = 256;
779         }
780       else if (unformat (line_input, "%U/%d",
781                          unformat_ip4_address,
782                          &pfx.fp_grp_addr.ip4, &pfx.fp_len))
783         {
784           clib_memset (&pfx.fp_src_addr.ip4, 0, sizeof (pfx.fp_src_addr.ip4));
785           payload_proto = pfx.fp_proto = FIB_PROTOCOL_IP4;
786         }
787       else if (unformat (line_input, "%U/%d",
788                          unformat_ip6_address,
789                          &pfx.fp_grp_addr.ip6, &pfx.fp_len))
790         {
791           clib_memset (&pfx.fp_src_addr.ip6, 0, sizeof (pfx.fp_src_addr.ip6));
792           payload_proto = pfx.fp_proto = FIB_PROTOCOL_IP6;
793         }
794       else if (unformat (line_input, "%U",
795                          unformat_ip4_address, &pfx.fp_grp_addr.ip4))
796         {
797           clib_memset (&pfx.fp_src_addr.ip4, 0, sizeof (pfx.fp_src_addr.ip4));
798           payload_proto = pfx.fp_proto = FIB_PROTOCOL_IP4;
799           pfx.fp_len = 32;
800         }
801       else if (unformat (line_input, "%U",
802                          unformat_ip6_address, &pfx.fp_grp_addr.ip6))
803         {
804           clib_memset (&pfx.fp_src_addr.ip6, 0, sizeof (pfx.fp_src_addr.ip6));
805           payload_proto = pfx.fp_proto = FIB_PROTOCOL_IP6;
806           pfx.fp_len = 128;
807         }
808       else if (unformat (line_input, "via local Forward"))
809         {
810           clib_memset (&rpath.frp_addr, 0, sizeof (rpath.frp_addr));
811           rpath.frp_sw_if_index = ~0;
812           rpath.frp_weight = 1;
813           rpath.frp_flags |= FIB_ROUTE_PATH_LOCAL;
814           /*
815            * set the path proto appropriately for the prefix
816            */
817           rpath.frp_proto = fib_proto_to_dpo (pfx.fp_proto);
818           rpath.frp_mitf_flags = MFIB_ITF_FLAG_FORWARD;
819
820           vec_add1 (rpaths, rpath);
821         }
822       else if (unformat (line_input, "via %U",
823                          unformat_fib_route_path, &rpath, &payload_proto))
824         {
825           vec_add1 (rpaths, rpath);
826         }
827       else if (unformat (line_input, "%U",
828                          unformat_mfib_entry_flags, &eflags))
829         ;
830       else
831         {
832           error = unformat_parse_error (line_input);
833           goto done;
834         }
835     }
836
837   if (~0 == table_id)
838     {
839       /*
840        * if no table_id is passed we will manipulate the default
841        */
842       fib_index = 0;
843     }
844   else
845     {
846       fib_index = mfib_table_find (pfx.fp_proto, table_id);
847
848       if (~0 == fib_index)
849         {
850           error = clib_error_return (0, "Nonexistent table id %d", table_id);
851           goto done;
852         }
853     }
854
855   timet[0] = vlib_time_now (vm);
856
857   if (FIB_PROTOCOL_IP4 == pfx.fp_proto)
858     {
859       incr = 1 << (32 - (pfx.fp_len % 32));
860     }
861   else
862     {
863       incr = 1 << (128 - (pfx.fp_len % 128));
864     }
865
866   for (ss = 0; ss < scount; ss++)
867     {
868       for (gg = 0; gg < gcount; gg++)
869         {
870           if (is_del && 0 == vec_len (rpaths))
871             {
872               /* no path provided => route delete */
873               mfib_table_entry_delete (fib_index, &pfx, MFIB_SOURCE_CLI);
874             }
875           else if (eflags || (MFIB_RPF_ID_NONE != rpf_id))
876             {
877               mfib_table_entry_update (fib_index, &pfx, MFIB_SOURCE_CLI,
878                                        rpf_id, eflags);
879             }
880           else
881             {
882               if (is_del)
883                 mfib_table_entry_path_remove (fib_index,
884                                               &pfx, MFIB_SOURCE_CLI, rpaths);
885               else
886                 mfib_table_entry_path_update (fib_index, &pfx, MFIB_SOURCE_CLI,
887                                               MFIB_ENTRY_FLAG_NONE, rpaths);
888             }
889
890           if (FIB_PROTOCOL_IP4 == pfx.fp_proto)
891             {
892               pfx.fp_grp_addr.ip4.as_u32 =
893                 clib_host_to_net_u32 (incr +
894                                       clib_net_to_host_u32 (pfx.
895                                                             fp_grp_addr.ip4.
896                                                             as_u32));
897             }
898           else
899             {
900               int bucket = (incr < 64 ? 0 : 1);
901               pfx.fp_grp_addr.ip6.as_u64[bucket] =
902                 clib_host_to_net_u64 (incr +
903                                       clib_net_to_host_u64 (pfx.
904                                                             fp_grp_addr.ip6.as_u64
905                                                             [bucket]));
906
907             }
908         }
909       if (FIB_PROTOCOL_IP4 == pfx.fp_proto)
910         {
911           pfx.fp_src_addr.ip4.as_u32 =
912             clib_host_to_net_u32 (1 +
913                                   clib_net_to_host_u32 (pfx.fp_src_addr.
914                                                         ip4.as_u32));
915         }
916       else
917         {
918           pfx.fp_src_addr.ip6.as_u64[1] =
919             clib_host_to_net_u64 (1 +
920                                   clib_net_to_host_u64 (pfx.fp_src_addr.
921                                                         ip6.as_u64[1]));
922         }
923     }
924
925   timet[1] = vlib_time_now (vm);
926
927   if (scount > 1 || gcount > 1)
928     vlib_cli_output (vm, "%.6e routes/sec",
929                      (scount * gcount) / (timet[1] - timet[0]));
930
931 done:
932   vec_free (rpaths);
933   unformat_free (line_input);
934
935   return error;
936 }
937
938 /*?
939  * This command is used to add or delete IPv4 or IPv6  multicast routes. All
940  * IP Addresses ('<em><dst-ip-addr>/<width></em>',
941  * '<em><next-hop-ip-addr></em>' and '<em><adj-hop-ip-addr></em>')
942  * can be IPv4 or IPv6, but all must be of the same form in a single
943  * command. To display the current set of routes, use the commands
944  * '<em>show ip mfib</em>' and '<em>show ip6 mfib</em>'.
945  * The full set of support flags for interfaces and route is shown via;
946  * '<em>show mfib route flags</em>' and '<em>show mfib itf flags</em>'
947  * respectively.
948  * @cliexpar
949  * Example of how to add a forwarding interface to a route (and create the
950  * route if it does not exist)
951  * @cliexcmd{ip mroute add 232.1.1.1 via GigabitEthernet2/0/0 Forward}
952  * Example of how to add an accepting interface to a route (and create the
953  * route if it does not exist)
954  * @cliexcmd{ip mroute add 232.1.1.1 via GigabitEthernet2/0/1 Accept}
955  * Example of changing the route's flags to send signals via the API
956  * @cliexcmd{ip mroute add 232.1.1.1 Signal}
957
958  ?*/
959 /* *INDENT-OFF* */
960 VLIB_CLI_COMMAND (ip_mroute_command, static) =
961 {
962   .path = "ip mroute",
963   .short_help = "ip mroute [add|del] <dst-ip-addr>/<width> [table <table-id>] [rpf-id <ID>] [via <next-hop-ip-addr> [<interface>],",
964   .function = vnet_ip_mroute_cmd,
965   .is_mp_safe = 1,
966 };
967 /* *INDENT-ON* */
968
969 /*
970  * fd.io coding-style-patch-verification: ON
971  *
972  * Local Variables:
973  * eval: (c-set-style "gnu")
974  * End:
975  */