MTU: IP fragmentation added to ip4-rewrite and ip6-rewrite
[vpp.git] / src / vnet / ip / ip6_forward.c
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  * ip/ip6_forward.c: IP v6 forwarding
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/vnet.h>
41 #include <vnet/ip/ip.h>
42 #include <vnet/ip/ip_frag.h>
43 #include <vnet/ip/ip6_neighbor.h>
44 #include <vnet/ethernet/ethernet.h>     /* for ethernet_header_t */
45 #include <vnet/srp/srp.h>       /* for srp_hw_interface_class */
46 #include <vppinfra/cache.h>
47 #include <vnet/fib/fib_urpf_list.h>     /* for FIB uRPF check */
48 #include <vnet/fib/ip6_fib.h>
49 #include <vnet/mfib/ip6_mfib.h>
50 #include <vnet/dpo/load_balance_map.h>
51 #include <vnet/dpo/classify_dpo.h>
52
53 #include <vppinfra/bihash_template.c>
54 #include <vnet/ip/ip6_forward.h>
55
56 /* Flag used by IOAM code. Classifier sets it pop-hop-by-hop checks it */
57 #define OI_DECAP   0x80000000
58
59 static void
60 ip6_add_interface_routes (vnet_main_t * vnm, u32 sw_if_index,
61                           ip6_main_t * im, u32 fib_index,
62                           ip_interface_address_t * a)
63 {
64   ip_lookup_main_t *lm = &im->lookup_main;
65   ip6_address_t *address = ip_interface_address_get_address (lm, a);
66   fib_prefix_t pfx = {
67     .fp_len = a->address_length,
68     .fp_proto = FIB_PROTOCOL_IP6,
69     .fp_addr.ip6 = *address,
70   };
71
72   if (a->address_length < 128)
73     {
74       fib_table_entry_update_one_path (fib_index,
75                                        &pfx,
76                                        FIB_SOURCE_INTERFACE,
77                                        (FIB_ENTRY_FLAG_CONNECTED |
78                                         FIB_ENTRY_FLAG_ATTACHED),
79                                        DPO_PROTO_IP6,
80                                        /* No next-hop address */
81                                        NULL, sw_if_index,
82                                        /* invalid FIB index */
83                                        ~0, 1,
84                                        /* no label stack */
85                                        NULL, FIB_ROUTE_PATH_FLAG_NONE);
86     }
87
88   pfx.fp_len = 128;
89   if (sw_if_index < vec_len (lm->classify_table_index_by_sw_if_index))
90     {
91       u32 classify_table_index =
92         lm->classify_table_index_by_sw_if_index[sw_if_index];
93       if (classify_table_index != (u32) ~ 0)
94         {
95           dpo_id_t dpo = DPO_INVALID;
96
97           dpo_set (&dpo,
98                    DPO_CLASSIFY,
99                    DPO_PROTO_IP6,
100                    classify_dpo_create (DPO_PROTO_IP6, classify_table_index));
101
102           fib_table_entry_special_dpo_add (fib_index,
103                                            &pfx,
104                                            FIB_SOURCE_CLASSIFY,
105                                            FIB_ENTRY_FLAG_NONE, &dpo);
106           dpo_reset (&dpo);
107         }
108     }
109
110   fib_table_entry_update_one_path (fib_index, &pfx,
111                                    FIB_SOURCE_INTERFACE,
112                                    (FIB_ENTRY_FLAG_CONNECTED |
113                                     FIB_ENTRY_FLAG_LOCAL),
114                                    DPO_PROTO_IP6,
115                                    &pfx.fp_addr,
116                                    sw_if_index, ~0,
117                                    1, NULL, FIB_ROUTE_PATH_FLAG_NONE);
118 }
119
120 static void
121 ip6_del_interface_routes (ip6_main_t * im,
122                           u32 fib_index,
123                           ip6_address_t * address, u32 address_length)
124 {
125   fib_prefix_t pfx = {
126     .fp_len = address_length,
127     .fp_proto = FIB_PROTOCOL_IP6,
128     .fp_addr.ip6 = *address,
129   };
130
131   if (pfx.fp_len < 128)
132     {
133       fib_table_entry_delete (fib_index, &pfx, FIB_SOURCE_INTERFACE);
134
135     }
136
137   pfx.fp_len = 128;
138   fib_table_entry_delete (fib_index, &pfx, FIB_SOURCE_INTERFACE);
139 }
140
141 void
142 ip6_sw_interface_enable_disable (u32 sw_if_index, u32 is_enable)
143 {
144   ip6_main_t *im = &ip6_main;
145
146   vec_validate_init_empty (im->ip_enabled_by_sw_if_index, sw_if_index, 0);
147
148   /*
149    * enable/disable only on the 1<->0 transition
150    */
151   if (is_enable)
152     {
153       if (1 != ++im->ip_enabled_by_sw_if_index[sw_if_index])
154         return;
155     }
156   else
157     {
158       /* The ref count is 0 when an address is removed from an interface that has
159        * no address - this is not a ciritical error */
160       if (0 == im->ip_enabled_by_sw_if_index[sw_if_index] ||
161           0 != --im->ip_enabled_by_sw_if_index[sw_if_index])
162         return;
163     }
164
165   vnet_feature_enable_disable ("ip6-unicast", "ip6-not-enabled", sw_if_index,
166                                !is_enable, 0, 0);
167
168   vnet_feature_enable_disable ("ip6-multicast", "ip6-not-enabled",
169                                sw_if_index, !is_enable, 0, 0);
170 }
171
172 /* get first interface address */
173 ip6_address_t *
174 ip6_interface_first_address (ip6_main_t * im, u32 sw_if_index)
175 {
176   ip_lookup_main_t *lm = &im->lookup_main;
177   ip_interface_address_t *ia = 0;
178   ip6_address_t *result = 0;
179
180   /* *INDENT-OFF* */
181   foreach_ip_interface_address (lm, ia, sw_if_index,
182                                 1 /* honor unnumbered */,
183   ({
184     ip6_address_t * a = ip_interface_address_get_address (lm, ia);
185     result = a;
186     break;
187   }));
188   /* *INDENT-ON* */
189   return result;
190 }
191
192 clib_error_t *
193 ip6_add_del_interface_address (vlib_main_t * vm,
194                                u32 sw_if_index,
195                                ip6_address_t * address,
196                                u32 address_length, u32 is_del)
197 {
198   vnet_main_t *vnm = vnet_get_main ();
199   ip6_main_t *im = &ip6_main;
200   ip_lookup_main_t *lm = &im->lookup_main;
201   clib_error_t *error;
202   u32 if_address_index;
203   ip6_address_fib_t ip6_af, *addr_fib = 0;
204
205   /* local0 interface doesn't support IP addressing */
206   if (sw_if_index == 0)
207     {
208       return
209         clib_error_create ("local0 interface doesn't support IP addressing");
210     }
211
212   vec_validate (im->fib_index_by_sw_if_index, sw_if_index);
213   vec_validate (im->mfib_index_by_sw_if_index, sw_if_index);
214
215   ip6_addr_fib_init (&ip6_af, address,
216                      vec_elt (im->fib_index_by_sw_if_index, sw_if_index));
217   vec_add1 (addr_fib, ip6_af);
218
219   /* *INDENT-OFF* */
220   if (!is_del)
221     {
222       /* When adding an address check that it does not conflict
223          with an existing address on any interface in this table. */
224       ip_interface_address_t *ia;
225       vnet_sw_interface_t *sif;
226
227       pool_foreach(sif, vnm->interface_main.sw_interfaces,
228       ({
229           if (im->fib_index_by_sw_if_index[sw_if_index] ==
230               im->fib_index_by_sw_if_index[sif->sw_if_index])
231             {
232               foreach_ip_interface_address
233                 (&im->lookup_main, ia, sif->sw_if_index,
234                  0 /* honor unnumbered */ ,
235                  ({
236                    ip6_address_t * x =
237                      ip_interface_address_get_address
238                      (&im->lookup_main, ia);
239                    if (ip6_destination_matches_route
240                        (im, address, x, ia->address_length) ||
241                        ip6_destination_matches_route (im,
242                                                       x,
243                                                       address,
244                                                       address_length))
245                      {
246                        vnm->api_errno = VNET_API_ERROR_DUPLICATE_IF_ADDRESS;
247                        return
248                          clib_error_create
249                          ("failed to add %U which conflicts with %U for interface %U",
250                           format_ip6_address_and_length, address,
251                           address_length,
252                           format_ip6_address_and_length, x,
253                           ia->address_length,
254                           format_vnet_sw_if_index_name, vnm,
255                           sif->sw_if_index);
256                      }
257                  }));
258             }
259       }));
260     }
261   /* *INDENT-ON* */
262
263   {
264     uword elts_before = pool_elts (lm->if_address_pool);
265
266     error = ip_interface_address_add_del
267       (lm, sw_if_index, addr_fib, address_length, is_del, &if_address_index);
268     if (error)
269       goto done;
270
271     /* Pool did not grow: add duplicate address. */
272     if (elts_before == pool_elts (lm->if_address_pool))
273       goto done;
274   }
275
276   ip6_sw_interface_enable_disable (sw_if_index, !is_del);
277
278   if (is_del)
279     ip6_del_interface_routes (im, ip6_af.fib_index, address, address_length);
280   else
281     ip6_add_interface_routes (vnm, sw_if_index,
282                               im, ip6_af.fib_index,
283                               pool_elt_at_index (lm->if_address_pool,
284                                                  if_address_index));
285
286   {
287     ip6_add_del_interface_address_callback_t *cb;
288     vec_foreach (cb, im->add_del_interface_address_callbacks)
289       cb->function (im, cb->function_opaque, sw_if_index,
290                     address, address_length, if_address_index, is_del);
291   }
292
293 done:
294   vec_free (addr_fib);
295   return error;
296 }
297
298 clib_error_t *
299 ip6_sw_interface_admin_up_down (vnet_main_t * vnm, u32 sw_if_index, u32 flags)
300 {
301   ip6_main_t *im = &ip6_main;
302   ip_interface_address_t *ia;
303   ip6_address_t *a;
304   u32 is_admin_up, fib_index;
305
306   /* Fill in lookup tables with default table (0). */
307   vec_validate (im->fib_index_by_sw_if_index, sw_if_index);
308
309   vec_validate_init_empty (im->
310                            lookup_main.if_address_pool_index_by_sw_if_index,
311                            sw_if_index, ~0);
312
313   is_admin_up = (flags & VNET_SW_INTERFACE_FLAG_ADMIN_UP) != 0;
314
315   fib_index = vec_elt (im->fib_index_by_sw_if_index, sw_if_index);
316
317   /* *INDENT-OFF* */
318   foreach_ip_interface_address (&im->lookup_main, ia, sw_if_index,
319                                 0 /* honor unnumbered */,
320   ({
321     a = ip_interface_address_get_address (&im->lookup_main, ia);
322     if (is_admin_up)
323       ip6_add_interface_routes (vnm, sw_if_index,
324                                 im, fib_index,
325                                 ia);
326     else
327       ip6_del_interface_routes (im, fib_index,
328                                 a, ia->address_length);
329   }));
330   /* *INDENT-ON* */
331
332   return 0;
333 }
334
335 VNET_SW_INTERFACE_ADMIN_UP_DOWN_FUNCTION (ip6_sw_interface_admin_up_down);
336
337 /* Built-in ip6 unicast rx feature path definition */
338 /* *INDENT-OFF* */
339 VNET_FEATURE_ARC_INIT (ip6_unicast, static) =
340 {
341   .arc_name  = "ip6-unicast",
342   .start_nodes = VNET_FEATURES ("ip6-input"),
343   .arc_index_ptr = &ip6_main.lookup_main.ucast_feature_arc_index,
344 };
345
346 VNET_FEATURE_INIT (ip6_flow_classify, static) =
347 {
348   .arc_name = "ip6-unicast",
349   .node_name = "ip6-flow-classify",
350   .runs_before = VNET_FEATURES ("ip6-inacl"),
351 };
352
353 VNET_FEATURE_INIT (ip6_inacl, static) =
354 {
355   .arc_name = "ip6-unicast",
356   .node_name = "ip6-inacl",
357   .runs_before = VNET_FEATURES ("ip6-policer-classify"),
358 };
359
360 VNET_FEATURE_INIT (ip6_policer_classify, static) =
361 {
362   .arc_name = "ip6-unicast",
363   .node_name = "ip6-policer-classify",
364   .runs_before = VNET_FEATURES ("ipsec-input-ip6"),
365 };
366
367 VNET_FEATURE_INIT (ip6_ipsec, static) =
368 {
369   .arc_name = "ip6-unicast",
370   .node_name = "ipsec-input-ip6",
371   .runs_before = VNET_FEATURES ("l2tp-decap"),
372 };
373
374 VNET_FEATURE_INIT (ip6_l2tp, static) =
375 {
376   .arc_name = "ip6-unicast",
377   .node_name = "l2tp-decap",
378   .runs_before = VNET_FEATURES ("vpath-input-ip6"),
379 };
380
381 VNET_FEATURE_INIT (ip6_vpath, static) =
382 {
383   .arc_name = "ip6-unicast",
384   .node_name = "vpath-input-ip6",
385   .runs_before = VNET_FEATURES ("ip6-vxlan-bypass"),
386 };
387
388 VNET_FEATURE_INIT (ip6_vxlan_bypass, static) =
389 {
390   .arc_name = "ip6-unicast",
391   .node_name = "ip6-vxlan-bypass",
392   .runs_before = VNET_FEATURES ("ip6-lookup"),
393 };
394
395 VNET_FEATURE_INIT (ip6_not_enabled, static) =
396 {
397   .arc_name = "ip6-unicast",
398   .node_name = "ip6-not-enabled",
399   .runs_before = VNET_FEATURES ("ip6-lookup"),
400 };
401
402 VNET_FEATURE_INIT (ip6_lookup, static) =
403 {
404   .arc_name = "ip6-unicast",
405   .node_name = "ip6-lookup",
406   .runs_before = 0,  /*last feature*/
407 };
408
409 /* Built-in ip6 multicast rx feature path definition (none now) */
410 VNET_FEATURE_ARC_INIT (ip6_multicast, static) =
411 {
412   .arc_name  = "ip6-multicast",
413   .start_nodes = VNET_FEATURES ("ip6-input"),
414   .arc_index_ptr = &ip6_main.lookup_main.mcast_feature_arc_index,
415 };
416
417 VNET_FEATURE_INIT (ip6_vpath_mc, static) = {
418   .arc_name = "ip6-multicast",
419   .node_name = "vpath-input-ip6",
420   .runs_before = VNET_FEATURES ("ip6-mfib-forward-lookup"),
421 };
422
423 VNET_FEATURE_INIT (ip6_not_enabled_mc, static) = {
424   .arc_name = "ip6-multicast",
425   .node_name = "ip6-not-enabled",
426   .runs_before = VNET_FEATURES ("ip6-mfib-forward-lookup"),
427 };
428
429 VNET_FEATURE_INIT (ip6_mc_lookup, static) = {
430   .arc_name = "ip6-multicast",
431   .node_name = "ip6-mfib-forward-lookup",
432   .runs_before = 0, /* last feature */
433 };
434
435 /* Built-in ip4 tx feature path definition */
436 VNET_FEATURE_ARC_INIT (ip6_output, static) =
437 {
438   .arc_name  = "ip6-output",
439   .start_nodes = VNET_FEATURES ("ip6-rewrite", "ip6-midchain", "ip6-dvr-dpo"),
440   .arc_index_ptr = &ip6_main.lookup_main.output_feature_arc_index,
441 };
442
443 VNET_FEATURE_INIT (ip6_outacl, static) = {
444   .arc_name = "ip6-output",
445   .node_name = "ip6-outacl",
446   .runs_before = VNET_FEATURES ("ipsec-output-ip6"),
447 };
448
449 VNET_FEATURE_INIT (ip6_ipsec_output, static) = {
450   .arc_name = "ip6-output",
451   .node_name = "ipsec-output-ip6",
452   .runs_before = VNET_FEATURES ("interface-output"),
453 };
454
455 VNET_FEATURE_INIT (ip6_interface_output, static) = {
456   .arc_name = "ip6-output",
457   .node_name = "interface-output",
458   .runs_before = 0, /* not before any other features */
459 };
460 /* *INDENT-ON* */
461
462 clib_error_t *
463 ip6_sw_interface_add_del (vnet_main_t * vnm, u32 sw_if_index, u32 is_add)
464 {
465   ip6_main_t *im = &ip6_main;
466
467   vec_validate (im->fib_index_by_sw_if_index, sw_if_index);
468   vec_validate (im->mfib_index_by_sw_if_index, sw_if_index);
469
470   if (!is_add)
471     {
472       /* Ensure that IPv6 is disabled */
473       ip6_main_t *im6 = &ip6_main;
474       ip_lookup_main_t *lm6 = &im6->lookup_main;
475       ip_interface_address_t *ia = 0;
476       ip6_address_t *address;
477       vlib_main_t *vm = vlib_get_main ();
478
479       ip6_neighbor_sw_interface_add_del (vnm, sw_if_index, 0 /* is_add */ );
480       vnet_sw_interface_update_unnumbered (sw_if_index, ~0, 0);
481       /* *INDENT-OFF* */
482       foreach_ip_interface_address (lm6, ia, sw_if_index, 0,
483       ({
484         address = ip_interface_address_get_address (lm6, ia);
485         ip6_add_del_interface_address(vm, sw_if_index, address, ia->address_length, 1);
486       }));
487       /* *INDENT-ON* */
488       ip6_mfib_interface_enable_disable (sw_if_index, 0);
489     }
490
491   vnet_feature_enable_disable ("ip6-unicast", "ip6-not-enabled", sw_if_index,
492                                is_add, 0, 0);
493
494   vnet_feature_enable_disable ("ip6-multicast", "ip6-not-enabled",
495                                sw_if_index, is_add, 0, 0);
496
497   return /* no error */ 0;
498 }
499
500 VNET_SW_INTERFACE_ADD_DEL_FUNCTION (ip6_sw_interface_add_del);
501
502 static uword
503 ip6_lookup (vlib_main_t * vm,
504             vlib_node_runtime_t * node, vlib_frame_t * frame)
505 {
506   return ip6_lookup_inline (vm, node, frame);
507 }
508
509 static u8 *format_ip6_lookup_trace (u8 * s, va_list * args);
510
511 /* *INDENT-OFF* */
512 VLIB_REGISTER_NODE (ip6_lookup_node) =
513 {
514   .function = ip6_lookup,
515   .name = "ip6-lookup",
516   .vector_size = sizeof (u32),
517   .format_trace = format_ip6_lookup_trace,
518   .n_next_nodes = IP6_LOOKUP_N_NEXT,
519   .next_nodes = IP6_LOOKUP_NEXT_NODES,
520 };
521 /* *INDENT-ON* */
522
523 VLIB_NODE_FUNCTION_MULTIARCH (ip6_lookup_node, ip6_lookup);
524
525 always_inline uword
526 ip6_load_balance (vlib_main_t * vm,
527                   vlib_node_runtime_t * node, vlib_frame_t * frame)
528 {
529   vlib_combined_counter_main_t *cm = &load_balance_main.lbm_via_counters;
530   u32 n_left_from, n_left_to_next, *from, *to_next;
531   ip_lookup_next_t next;
532   u32 thread_index = vlib_get_thread_index ();
533   ip6_main_t *im = &ip6_main;
534
535   from = vlib_frame_vector_args (frame);
536   n_left_from = frame->n_vectors;
537   next = node->cached_next_index;
538
539   if (node->flags & VLIB_NODE_FLAG_TRACE)
540     ip6_forward_next_trace (vm, node, frame, VLIB_TX);
541
542   while (n_left_from > 0)
543     {
544       vlib_get_next_frame (vm, node, next, to_next, n_left_to_next);
545
546
547       while (n_left_from >= 4 && n_left_to_next >= 2)
548         {
549           ip_lookup_next_t next0, next1;
550           const load_balance_t *lb0, *lb1;
551           vlib_buffer_t *p0, *p1;
552           u32 pi0, lbi0, hc0, pi1, lbi1, hc1;
553           const ip6_header_t *ip0, *ip1;
554           const dpo_id_t *dpo0, *dpo1;
555
556           /* Prefetch next iteration. */
557           {
558             vlib_buffer_t *p2, *p3;
559
560             p2 = vlib_get_buffer (vm, from[2]);
561             p3 = vlib_get_buffer (vm, from[3]);
562
563             vlib_prefetch_buffer_header (p2, STORE);
564             vlib_prefetch_buffer_header (p3, STORE);
565
566             CLIB_PREFETCH (p2->data, sizeof (ip0[0]), STORE);
567             CLIB_PREFETCH (p3->data, sizeof (ip0[0]), STORE);
568           }
569
570           pi0 = to_next[0] = from[0];
571           pi1 = to_next[1] = from[1];
572
573           from += 2;
574           n_left_from -= 2;
575           to_next += 2;
576           n_left_to_next -= 2;
577
578           p0 = vlib_get_buffer (vm, pi0);
579           p1 = vlib_get_buffer (vm, pi1);
580
581           ip0 = vlib_buffer_get_current (p0);
582           ip1 = vlib_buffer_get_current (p1);
583           lbi0 = vnet_buffer (p0)->ip.adj_index[VLIB_TX];
584           lbi1 = vnet_buffer (p1)->ip.adj_index[VLIB_TX];
585
586           lb0 = load_balance_get (lbi0);
587           lb1 = load_balance_get (lbi1);
588
589           /*
590            * this node is for via FIBs we can re-use the hash value from the
591            * to node if present.
592            * We don't want to use the same hash value at each level in the recursion
593            * graph as that would lead to polarisation
594            */
595           hc0 = hc1 = 0;
596
597           if (PREDICT_FALSE (lb0->lb_n_buckets > 1))
598             {
599               if (PREDICT_TRUE (vnet_buffer (p0)->ip.flow_hash))
600                 {
601                   hc0 = vnet_buffer (p0)->ip.flow_hash =
602                     vnet_buffer (p0)->ip.flow_hash >> 1;
603                 }
604               else
605                 {
606                   hc0 = vnet_buffer (p0)->ip.flow_hash =
607                     ip6_compute_flow_hash (ip0, lb0->lb_hash_config);
608                 }
609               dpo0 =
610                 load_balance_get_fwd_bucket (lb0,
611                                              (hc0 &
612                                               lb0->lb_n_buckets_minus_1));
613             }
614           else
615             {
616               dpo0 = load_balance_get_bucket_i (lb0, 0);
617             }
618           if (PREDICT_FALSE (lb1->lb_n_buckets > 1))
619             {
620               if (PREDICT_TRUE (vnet_buffer (p1)->ip.flow_hash))
621                 {
622                   hc1 = vnet_buffer (p1)->ip.flow_hash =
623                     vnet_buffer (p1)->ip.flow_hash >> 1;
624                 }
625               else
626                 {
627                   hc1 = vnet_buffer (p1)->ip.flow_hash =
628                     ip6_compute_flow_hash (ip1, lb1->lb_hash_config);
629                 }
630               dpo1 =
631                 load_balance_get_fwd_bucket (lb1,
632                                              (hc1 &
633                                               lb1->lb_n_buckets_minus_1));
634             }
635           else
636             {
637               dpo1 = load_balance_get_bucket_i (lb1, 0);
638             }
639
640           next0 = dpo0->dpoi_next_node;
641           next1 = dpo1->dpoi_next_node;
642
643           /* Only process the HBH Option Header if explicitly configured to do so */
644           if (PREDICT_FALSE
645               (ip0->protocol == IP_PROTOCOL_IP6_HOP_BY_HOP_OPTIONS))
646             {
647               next0 = (dpo_is_adj (dpo0) && im->hbh_enabled) ?
648                 (ip_lookup_next_t) IP6_LOOKUP_NEXT_HOP_BY_HOP : next0;
649             }
650           /* Only process the HBH Option Header if explicitly configured to do so */
651           if (PREDICT_FALSE
652               (ip1->protocol == IP_PROTOCOL_IP6_HOP_BY_HOP_OPTIONS))
653             {
654               next1 = (dpo_is_adj (dpo1) && im->hbh_enabled) ?
655                 (ip_lookup_next_t) IP6_LOOKUP_NEXT_HOP_BY_HOP : next1;
656             }
657
658           vnet_buffer (p0)->ip.adj_index[VLIB_TX] = dpo0->dpoi_index;
659           vnet_buffer (p1)->ip.adj_index[VLIB_TX] = dpo1->dpoi_index;
660
661           vlib_increment_combined_counter
662             (cm, thread_index, lbi0, 1, vlib_buffer_length_in_chain (vm, p0));
663           vlib_increment_combined_counter
664             (cm, thread_index, lbi1, 1, vlib_buffer_length_in_chain (vm, p1));
665
666           vlib_validate_buffer_enqueue_x2 (vm, node, next,
667                                            to_next, n_left_to_next,
668                                            pi0, pi1, next0, next1);
669         }
670
671       while (n_left_from > 0 && n_left_to_next > 0)
672         {
673           ip_lookup_next_t next0;
674           const load_balance_t *lb0;
675           vlib_buffer_t *p0;
676           u32 pi0, lbi0, hc0;
677           const ip6_header_t *ip0;
678           const dpo_id_t *dpo0;
679
680           pi0 = from[0];
681           to_next[0] = pi0;
682           from += 1;
683           to_next += 1;
684           n_left_to_next -= 1;
685           n_left_from -= 1;
686
687           p0 = vlib_get_buffer (vm, pi0);
688
689           ip0 = vlib_buffer_get_current (p0);
690           lbi0 = vnet_buffer (p0)->ip.adj_index[VLIB_TX];
691
692           lb0 = load_balance_get (lbi0);
693
694           hc0 = 0;
695           if (PREDICT_FALSE (lb0->lb_n_buckets > 1))
696             {
697               if (PREDICT_TRUE (vnet_buffer (p0)->ip.flow_hash))
698                 {
699                   hc0 = vnet_buffer (p0)->ip.flow_hash =
700                     vnet_buffer (p0)->ip.flow_hash >> 1;
701                 }
702               else
703                 {
704                   hc0 = vnet_buffer (p0)->ip.flow_hash =
705                     ip6_compute_flow_hash (ip0, lb0->lb_hash_config);
706                 }
707               dpo0 =
708                 load_balance_get_fwd_bucket (lb0,
709                                              (hc0 &
710                                               lb0->lb_n_buckets_minus_1));
711             }
712           else
713             {
714               dpo0 = load_balance_get_bucket_i (lb0, 0);
715             }
716
717           next0 = dpo0->dpoi_next_node;
718           vnet_buffer (p0)->ip.adj_index[VLIB_TX] = dpo0->dpoi_index;
719
720           /* Only process the HBH Option Header if explicitly configured to do so */
721           if (PREDICT_FALSE
722               (ip0->protocol == IP_PROTOCOL_IP6_HOP_BY_HOP_OPTIONS))
723             {
724               next0 = (dpo_is_adj (dpo0) && im->hbh_enabled) ?
725                 (ip_lookup_next_t) IP6_LOOKUP_NEXT_HOP_BY_HOP : next0;
726             }
727
728           vlib_increment_combined_counter
729             (cm, thread_index, lbi0, 1, vlib_buffer_length_in_chain (vm, p0));
730
731           vlib_validate_buffer_enqueue_x1 (vm, node, next,
732                                            to_next, n_left_to_next,
733                                            pi0, next0);
734         }
735
736       vlib_put_next_frame (vm, node, next, n_left_to_next);
737     }
738
739   return frame->n_vectors;
740 }
741
742 /* *INDENT-OFF* */
743 VLIB_REGISTER_NODE (ip6_load_balance_node) =
744 {
745   .function = ip6_load_balance,
746   .name = "ip6-load-balance",
747   .vector_size = sizeof (u32),
748   .sibling_of = "ip6-lookup",
749   .format_trace = format_ip6_lookup_trace,
750 };
751 /* *INDENT-ON* */
752
753 VLIB_NODE_FUNCTION_MULTIARCH (ip6_load_balance_node, ip6_load_balance);
754
755 typedef struct
756 {
757   /* Adjacency taken. */
758   u32 adj_index;
759   u32 flow_hash;
760   u32 fib_index;
761
762   /* Packet data, possibly *after* rewrite. */
763   u8 packet_data[128 - 1 * sizeof (u32)];
764 }
765 ip6_forward_next_trace_t;
766
767 u8 *
768 format_ip6_forward_next_trace (u8 * s, va_list * args)
769 {
770   CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *);
771   CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *);
772   ip6_forward_next_trace_t *t = va_arg (*args, ip6_forward_next_trace_t *);
773   u32 indent = format_get_indent (s);
774
775   s = format (s, "%U%U",
776               format_white_space, indent,
777               format_ip6_header, t->packet_data, sizeof (t->packet_data));
778   return s;
779 }
780
781 static u8 *
782 format_ip6_lookup_trace (u8 * s, va_list * args)
783 {
784   CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *);
785   CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *);
786   ip6_forward_next_trace_t *t = va_arg (*args, ip6_forward_next_trace_t *);
787   u32 indent = format_get_indent (s);
788
789   s = format (s, "fib %d dpo-idx %d flow hash: 0x%08x",
790               t->fib_index, t->adj_index, t->flow_hash);
791   s = format (s, "\n%U%U",
792               format_white_space, indent,
793               format_ip6_header, t->packet_data, sizeof (t->packet_data));
794   return s;
795 }
796
797
798 static u8 *
799 format_ip6_rewrite_trace (u8 * s, va_list * args)
800 {
801   CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *);
802   CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *);
803   ip6_forward_next_trace_t *t = va_arg (*args, ip6_forward_next_trace_t *);
804   u32 indent = format_get_indent (s);
805
806   s = format (s, "tx_sw_if_index %d adj-idx %d : %U flow hash: 0x%08x",
807               t->fib_index, t->adj_index, format_ip_adjacency,
808               t->adj_index, FORMAT_IP_ADJACENCY_NONE, t->flow_hash);
809   s = format (s, "\n%U%U",
810               format_white_space, indent,
811               format_ip_adjacency_packet_data,
812               t->adj_index, t->packet_data, sizeof (t->packet_data));
813   return s;
814 }
815
816 /* Common trace function for all ip6-forward next nodes. */
817 void
818 ip6_forward_next_trace (vlib_main_t * vm,
819                         vlib_node_runtime_t * node,
820                         vlib_frame_t * frame, vlib_rx_or_tx_t which_adj_index)
821 {
822   u32 *from, n_left;
823   ip6_main_t *im = &ip6_main;
824
825   n_left = frame->n_vectors;
826   from = vlib_frame_vector_args (frame);
827
828   while (n_left >= 4)
829     {
830       u32 bi0, bi1;
831       vlib_buffer_t *b0, *b1;
832       ip6_forward_next_trace_t *t0, *t1;
833
834       /* Prefetch next iteration. */
835       vlib_prefetch_buffer_with_index (vm, from[2], LOAD);
836       vlib_prefetch_buffer_with_index (vm, from[3], LOAD);
837
838       bi0 = from[0];
839       bi1 = from[1];
840
841       b0 = vlib_get_buffer (vm, bi0);
842       b1 = vlib_get_buffer (vm, bi1);
843
844       if (b0->flags & VLIB_BUFFER_IS_TRACED)
845         {
846           t0 = vlib_add_trace (vm, node, b0, sizeof (t0[0]));
847           t0->adj_index = vnet_buffer (b0)->ip.adj_index[which_adj_index];
848           t0->flow_hash = vnet_buffer (b0)->ip.flow_hash;
849           t0->fib_index =
850             (vnet_buffer (b0)->sw_if_index[VLIB_TX] !=
851              (u32) ~ 0) ? vnet_buffer (b0)->sw_if_index[VLIB_TX] :
852             vec_elt (im->fib_index_by_sw_if_index,
853                      vnet_buffer (b0)->sw_if_index[VLIB_RX]);
854
855           clib_memcpy (t0->packet_data,
856                        vlib_buffer_get_current (b0),
857                        sizeof (t0->packet_data));
858         }
859       if (b1->flags & VLIB_BUFFER_IS_TRACED)
860         {
861           t1 = vlib_add_trace (vm, node, b1, sizeof (t1[0]));
862           t1->adj_index = vnet_buffer (b1)->ip.adj_index[which_adj_index];
863           t1->flow_hash = vnet_buffer (b1)->ip.flow_hash;
864           t1->fib_index =
865             (vnet_buffer (b1)->sw_if_index[VLIB_TX] !=
866              (u32) ~ 0) ? vnet_buffer (b1)->sw_if_index[VLIB_TX] :
867             vec_elt (im->fib_index_by_sw_if_index,
868                      vnet_buffer (b1)->sw_if_index[VLIB_RX]);
869
870           clib_memcpy (t1->packet_data,
871                        vlib_buffer_get_current (b1),
872                        sizeof (t1->packet_data));
873         }
874       from += 2;
875       n_left -= 2;
876     }
877
878   while (n_left >= 1)
879     {
880       u32 bi0;
881       vlib_buffer_t *b0;
882       ip6_forward_next_trace_t *t0;
883
884       bi0 = from[0];
885
886       b0 = vlib_get_buffer (vm, bi0);
887
888       if (b0->flags & VLIB_BUFFER_IS_TRACED)
889         {
890           t0 = vlib_add_trace (vm, node, b0, sizeof (t0[0]));
891           t0->adj_index = vnet_buffer (b0)->ip.adj_index[which_adj_index];
892           t0->flow_hash = vnet_buffer (b0)->ip.flow_hash;
893           t0->fib_index =
894             (vnet_buffer (b0)->sw_if_index[VLIB_TX] !=
895              (u32) ~ 0) ? vnet_buffer (b0)->sw_if_index[VLIB_TX] :
896             vec_elt (im->fib_index_by_sw_if_index,
897                      vnet_buffer (b0)->sw_if_index[VLIB_RX]);
898
899           clib_memcpy (t0->packet_data,
900                        vlib_buffer_get_current (b0),
901                        sizeof (t0->packet_data));
902         }
903       from += 1;
904       n_left -= 1;
905     }
906 }
907
908 /* Compute TCP/UDP/ICMP6 checksum in software. */
909 u16
910 ip6_tcp_udp_icmp_compute_checksum (vlib_main_t * vm, vlib_buffer_t * p0,
911                                    ip6_header_t * ip0, int *bogus_lengthp)
912 {
913   ip_csum_t sum0;
914   u16 sum16, payload_length_host_byte_order;
915   u32 i, n_this_buffer, n_bytes_left;
916   u32 headers_size = sizeof (ip0[0]);
917   void *data_this_buffer;
918
919   ASSERT (bogus_lengthp);
920   *bogus_lengthp = 0;
921
922   /* Initialize checksum with ip header. */
923   sum0 = ip0->payload_length + clib_host_to_net_u16 (ip0->protocol);
924   payload_length_host_byte_order = clib_net_to_host_u16 (ip0->payload_length);
925   data_this_buffer = (void *) (ip0 + 1);
926
927   for (i = 0; i < ARRAY_LEN (ip0->src_address.as_uword); i++)
928     {
929       sum0 = ip_csum_with_carry (sum0,
930                                  clib_mem_unaligned (&ip0->
931                                                      src_address.as_uword[i],
932                                                      uword));
933       sum0 =
934         ip_csum_with_carry (sum0,
935                             clib_mem_unaligned (&ip0->dst_address.as_uword[i],
936                                                 uword));
937     }
938
939   /* some icmp packets may come with a "router alert" hop-by-hop extension header (e.g., mldv2 packets)
940    * or UDP-Ping packets */
941   if (PREDICT_FALSE (ip0->protocol == IP_PROTOCOL_IP6_HOP_BY_HOP_OPTIONS))
942     {
943       u32 skip_bytes;
944       ip6_hop_by_hop_ext_t *ext_hdr =
945         (ip6_hop_by_hop_ext_t *) data_this_buffer;
946
947       /* validate really icmp6 next */
948       ASSERT ((ext_hdr->next_hdr == IP_PROTOCOL_ICMP6)
949               || (ext_hdr->next_hdr == IP_PROTOCOL_UDP));
950
951       skip_bytes = 8 * (1 + ext_hdr->n_data_u64s);
952       data_this_buffer = (void *) ((u8 *) data_this_buffer + skip_bytes);
953
954       payload_length_host_byte_order -= skip_bytes;
955       headers_size += skip_bytes;
956     }
957
958   n_bytes_left = n_this_buffer = payload_length_host_byte_order;
959   if (p0 && n_this_buffer + headers_size > p0->current_length)
960     n_this_buffer =
961       p0->current_length >
962       headers_size ? p0->current_length - headers_size : 0;
963   while (1)
964     {
965       sum0 = ip_incremental_checksum (sum0, data_this_buffer, n_this_buffer);
966       n_bytes_left -= n_this_buffer;
967       if (n_bytes_left == 0)
968         break;
969
970       if (!(p0->flags & VLIB_BUFFER_NEXT_PRESENT))
971         {
972           *bogus_lengthp = 1;
973           return 0xfefe;
974         }
975       p0 = vlib_get_buffer (vm, p0->next_buffer);
976       data_this_buffer = vlib_buffer_get_current (p0);
977       n_this_buffer = p0->current_length;
978     }
979
980   sum16 = ~ip_csum_fold (sum0);
981
982   return sum16;
983 }
984
985 u32
986 ip6_tcp_udp_icmp_validate_checksum (vlib_main_t * vm, vlib_buffer_t * p0)
987 {
988   ip6_header_t *ip0 = vlib_buffer_get_current (p0);
989   udp_header_t *udp0;
990   u16 sum16;
991   int bogus_length;
992
993   /* some icmp packets may come with a "router alert" hop-by-hop extension header (e.g., mldv2 packets) */
994   ASSERT (ip0->protocol == IP_PROTOCOL_TCP
995           || ip0->protocol == IP_PROTOCOL_ICMP6
996           || ip0->protocol == IP_PROTOCOL_UDP
997           || ip0->protocol == IP_PROTOCOL_IP6_HOP_BY_HOP_OPTIONS);
998
999   udp0 = (void *) (ip0 + 1);
1000   if (ip0->protocol == IP_PROTOCOL_UDP && udp0->checksum == 0)
1001     {
1002       p0->flags |= (VNET_BUFFER_F_L4_CHECKSUM_COMPUTED
1003                     | VNET_BUFFER_F_L4_CHECKSUM_CORRECT);
1004       return p0->flags;
1005     }
1006
1007   sum16 = ip6_tcp_udp_icmp_compute_checksum (vm, p0, ip0, &bogus_length);
1008
1009   p0->flags |= (VNET_BUFFER_F_L4_CHECKSUM_COMPUTED
1010                 | ((sum16 == 0) << VNET_BUFFER_F_LOG2_L4_CHECKSUM_CORRECT));
1011
1012   return p0->flags;
1013 }
1014
1015 /**
1016  * @brief returns number of links on which src is reachable.
1017  */
1018 always_inline int
1019 ip6_urpf_loose_check (ip6_main_t * im, vlib_buffer_t * b, ip6_header_t * i)
1020 {
1021   const load_balance_t *lb0;
1022   index_t lbi;
1023   u32 fib_index;
1024
1025   fib_index = vec_elt (im->fib_index_by_sw_if_index,
1026                        vnet_buffer (b)->sw_if_index[VLIB_RX]);
1027   fib_index =
1028     (vnet_buffer (b)->sw_if_index[VLIB_TX] == (u32) ~ 0) ?
1029     fib_index : vnet_buffer (b)->sw_if_index[VLIB_TX];
1030
1031   lbi = ip6_fib_table_fwding_lookup (im, fib_index, &i->src_address);
1032   lb0 = load_balance_get (lbi);
1033
1034   return (fib_urpf_check_size (lb0->lb_urpf));
1035 }
1036
1037 always_inline u8
1038 ip6_next_proto_is_tcp_udp (vlib_buffer_t * p0, ip6_header_t * ip0,
1039                            u32 * udp_offset0)
1040 {
1041   u32 proto0;
1042   proto0 = ip6_locate_header (p0, ip0, IP_PROTOCOL_UDP, udp_offset0);
1043   if (proto0 != IP_PROTOCOL_UDP)
1044     {
1045       proto0 = ip6_locate_header (p0, ip0, IP_PROTOCOL_TCP, udp_offset0);
1046       proto0 = (proto0 == IP_PROTOCOL_TCP) ? proto0 : 0;
1047     }
1048   return proto0;
1049 }
1050
1051 /* *INDENT-OFF* */
1052 VNET_FEATURE_ARC_INIT (ip6_local) =
1053 {
1054   .arc_name  = "ip6-local",
1055   .start_nodes = VNET_FEATURES ("ip6-local"),
1056 };
1057 /* *INDENT-ON* */
1058
1059 static uword
1060 ip6_local_inline (vlib_main_t * vm, vlib_node_runtime_t * node,
1061                   vlib_frame_t * frame, int head_of_feature_arc)
1062 {
1063   ip6_main_t *im = &ip6_main;
1064   ip_lookup_main_t *lm = &im->lookup_main;
1065   ip_local_next_t next_index;
1066   u32 *from, *to_next, n_left_from, n_left_to_next;
1067   vlib_node_runtime_t *error_node =
1068     vlib_node_get_runtime (vm, ip6_input_node.index);
1069   u8 arc_index = vnet_feat_arc_ip6_local.feature_arc_index;
1070
1071   from = vlib_frame_vector_args (frame);
1072   n_left_from = frame->n_vectors;
1073   next_index = node->cached_next_index;
1074
1075   if (node->flags & VLIB_NODE_FLAG_TRACE)
1076     ip6_forward_next_trace (vm, node, frame, VLIB_TX);
1077
1078   while (n_left_from > 0)
1079     {
1080       vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next);
1081
1082       while (n_left_from >= 4 && n_left_to_next >= 2)
1083         {
1084           vlib_buffer_t *p0, *p1;
1085           ip6_header_t *ip0, *ip1;
1086           udp_header_t *udp0, *udp1;
1087           u32 pi0, ip_len0, udp_len0, flags0, next0;
1088           u32 pi1, ip_len1, udp_len1, flags1, next1;
1089           i32 len_diff0, len_diff1;
1090           u8 error0, type0, good_l4_csum0, is_tcp_udp0;
1091           u8 error1, type1, good_l4_csum1, is_tcp_udp1;
1092           u32 udp_offset0, udp_offset1;
1093
1094           pi0 = to_next[0] = from[0];
1095           pi1 = to_next[1] = from[1];
1096           from += 2;
1097           n_left_from -= 2;
1098           to_next += 2;
1099           n_left_to_next -= 2;
1100
1101           error0 = error1 = IP6_ERROR_UNKNOWN_PROTOCOL;
1102
1103           p0 = vlib_get_buffer (vm, pi0);
1104           p1 = vlib_get_buffer (vm, pi1);
1105
1106           ip0 = vlib_buffer_get_current (p0);
1107           ip1 = vlib_buffer_get_current (p1);
1108
1109           if (head_of_feature_arc == 0)
1110             goto skip_checks;
1111
1112           vnet_buffer (p0)->l3_hdr_offset = p0->current_data;
1113           vnet_buffer (p1)->l3_hdr_offset = p1->current_data;
1114
1115           type0 = lm->builtin_protocol_by_ip_protocol[ip0->protocol];
1116           type1 = lm->builtin_protocol_by_ip_protocol[ip1->protocol];
1117
1118           flags0 = p0->flags;
1119           flags1 = p1->flags;
1120
1121           is_tcp_udp0 = ip6_next_proto_is_tcp_udp (p0, ip0, &udp_offset0);
1122           is_tcp_udp1 = ip6_next_proto_is_tcp_udp (p1, ip1, &udp_offset1);
1123
1124           good_l4_csum0 = (flags0 & VNET_BUFFER_F_L4_CHECKSUM_CORRECT
1125                            || (flags0 & VNET_BUFFER_F_OFFLOAD_TCP_CKSUM
1126                                || flags0 & VNET_BUFFER_F_OFFLOAD_UDP_CKSUM))
1127             != 0;
1128           good_l4_csum1 = (flags1 & VNET_BUFFER_F_L4_CHECKSUM_CORRECT
1129                            || (flags1 & VNET_BUFFER_F_OFFLOAD_TCP_CKSUM
1130                                || flags1 & VNET_BUFFER_F_OFFLOAD_UDP_CKSUM))
1131             != 0;
1132           len_diff0 = 0;
1133           len_diff1 = 0;
1134
1135           if (PREDICT_TRUE (is_tcp_udp0))
1136             {
1137               udp0 = (udp_header_t *) ((u8 *) ip0 + udp_offset0);
1138               /* Don't verify UDP checksum for packets with explicit zero checksum. */
1139               good_l4_csum0 |= type0 == IP_BUILTIN_PROTOCOL_UDP
1140                 && udp0->checksum == 0;
1141               /* Verify UDP length. */
1142               if (is_tcp_udp0 == IP_PROTOCOL_UDP)
1143                 {
1144                   ip_len0 = clib_net_to_host_u16 (ip0->payload_length);
1145                   udp_len0 = clib_net_to_host_u16 (udp0->length);
1146                   len_diff0 = ip_len0 - udp_len0;
1147                 }
1148             }
1149           if (PREDICT_TRUE (is_tcp_udp1))
1150             {
1151               udp1 = (udp_header_t *) ((u8 *) ip1 + udp_offset1);
1152               /* Don't verify UDP checksum for packets with explicit zero checksum. */
1153               good_l4_csum1 |= type1 == IP_BUILTIN_PROTOCOL_UDP
1154                 && udp1->checksum == 0;
1155               /* Verify UDP length. */
1156               if (is_tcp_udp1 == IP_PROTOCOL_UDP)
1157                 {
1158                   ip_len1 = clib_net_to_host_u16 (ip1->payload_length);
1159                   udp_len1 = clib_net_to_host_u16 (udp1->length);
1160                   len_diff1 = ip_len1 - udp_len1;
1161                 }
1162             }
1163
1164           good_l4_csum0 |= type0 == IP_BUILTIN_PROTOCOL_UNKNOWN;
1165           good_l4_csum1 |= type1 == IP_BUILTIN_PROTOCOL_UNKNOWN;
1166
1167           len_diff0 = type0 == IP_BUILTIN_PROTOCOL_UDP ? len_diff0 : 0;
1168           len_diff1 = type1 == IP_BUILTIN_PROTOCOL_UDP ? len_diff1 : 0;
1169
1170           if (PREDICT_FALSE (type0 != IP_BUILTIN_PROTOCOL_UNKNOWN
1171                              && !good_l4_csum0
1172                              && !(flags0 &
1173                                   VNET_BUFFER_F_L4_CHECKSUM_COMPUTED)))
1174             {
1175               flags0 = ip6_tcp_udp_icmp_validate_checksum (vm, p0);
1176               good_l4_csum0 =
1177                 (flags0 & VNET_BUFFER_F_L4_CHECKSUM_CORRECT) != 0;
1178             }
1179           if (PREDICT_FALSE (type1 != IP_BUILTIN_PROTOCOL_UNKNOWN
1180                              && !good_l4_csum1
1181                              && !(flags1 &
1182                                   VNET_BUFFER_F_L4_CHECKSUM_COMPUTED)))
1183             {
1184               flags1 = ip6_tcp_udp_icmp_validate_checksum (vm, p1);
1185               good_l4_csum1 =
1186                 (flags1 & VNET_BUFFER_F_L4_CHECKSUM_CORRECT) != 0;
1187             }
1188
1189           error0 = error1 = IP6_ERROR_UNKNOWN_PROTOCOL;
1190           error0 = len_diff0 < 0 ? IP6_ERROR_UDP_LENGTH : error0;
1191           error1 = len_diff1 < 0 ? IP6_ERROR_UDP_LENGTH : error1;
1192
1193           ASSERT (IP6_ERROR_UDP_CHECKSUM + IP_BUILTIN_PROTOCOL_UDP ==
1194                   IP6_ERROR_UDP_CHECKSUM);
1195           ASSERT (IP6_ERROR_UDP_CHECKSUM + IP_BUILTIN_PROTOCOL_ICMP ==
1196                   IP6_ERROR_ICMP_CHECKSUM);
1197           error0 = (!good_l4_csum0 ? IP6_ERROR_UDP_CHECKSUM + type0 : error0);
1198           error1 = (!good_l4_csum1 ? IP6_ERROR_UDP_CHECKSUM + type1 : error1);
1199
1200           /* Drop packets from unroutable hosts. */
1201           /* If this is a neighbor solicitation (ICMP), skip source RPF check */
1202           if (error0 == IP6_ERROR_UNKNOWN_PROTOCOL &&
1203               type0 != IP_BUILTIN_PROTOCOL_ICMP &&
1204               !ip6_address_is_link_local_unicast (&ip0->src_address))
1205             {
1206               error0 = (!ip6_urpf_loose_check (im, p0, ip0)
1207                         ? IP6_ERROR_SRC_LOOKUP_MISS : error0);
1208             }
1209           if (error1 == IP6_ERROR_UNKNOWN_PROTOCOL &&
1210               type1 != IP_BUILTIN_PROTOCOL_ICMP &&
1211               !ip6_address_is_link_local_unicast (&ip1->src_address))
1212             {
1213               error1 = (!ip6_urpf_loose_check (im, p1, ip1)
1214                         ? IP6_ERROR_SRC_LOOKUP_MISS : error1);
1215             }
1216
1217           vnet_buffer (p0)->ip.fib_index =
1218             vnet_buffer (p0)->sw_if_index[VLIB_TX] != ~0 ?
1219             vnet_buffer (p0)->sw_if_index[VLIB_TX] :
1220             vnet_buffer (p0)->ip.fib_index;
1221
1222           vnet_buffer (p1)->ip.fib_index =
1223             vnet_buffer (p1)->sw_if_index[VLIB_TX] != ~0 ?
1224             vnet_buffer (p1)->sw_if_index[VLIB_TX] :
1225             vnet_buffer (p1)->ip.fib_index;
1226
1227         skip_checks:
1228
1229           next0 = lm->local_next_by_ip_protocol[ip0->protocol];
1230           next1 = lm->local_next_by_ip_protocol[ip1->protocol];
1231
1232           next0 =
1233             error0 != IP6_ERROR_UNKNOWN_PROTOCOL ? IP_LOCAL_NEXT_DROP : next0;
1234           next1 =
1235             error1 != IP6_ERROR_UNKNOWN_PROTOCOL ? IP_LOCAL_NEXT_DROP : next1;
1236
1237           p0->error = error_node->errors[error0];
1238           p1->error = error_node->errors[error1];
1239
1240           if (head_of_feature_arc)
1241             {
1242               if (PREDICT_TRUE (error0 == (u8) IP6_ERROR_UNKNOWN_PROTOCOL))
1243                 vnet_feature_arc_start (arc_index,
1244                                         vnet_buffer (p0)->sw_if_index
1245                                         [VLIB_RX], &next0, p0);
1246               if (PREDICT_TRUE (error1 == (u8) IP6_ERROR_UNKNOWN_PROTOCOL))
1247                 vnet_feature_arc_start (arc_index,
1248                                         vnet_buffer (p1)->sw_if_index
1249                                         [VLIB_RX], &next1, p1);
1250             }
1251
1252           vlib_validate_buffer_enqueue_x2 (vm, node, next_index,
1253                                            to_next, n_left_to_next,
1254                                            pi0, pi1, next0, next1);
1255         }
1256
1257       while (n_left_from > 0 && n_left_to_next > 0)
1258         {
1259           vlib_buffer_t *p0;
1260           ip6_header_t *ip0;
1261           udp_header_t *udp0;
1262           u32 pi0, ip_len0, udp_len0, flags0, next0;
1263           i32 len_diff0;
1264           u8 error0, type0, good_l4_csum0;
1265           u32 udp_offset0;
1266           u8 is_tcp_udp0;
1267
1268           pi0 = to_next[0] = from[0];
1269           from += 1;
1270           n_left_from -= 1;
1271           to_next += 1;
1272           n_left_to_next -= 1;
1273
1274           error0 = IP6_ERROR_UNKNOWN_PROTOCOL;
1275
1276           p0 = vlib_get_buffer (vm, pi0);
1277           ip0 = vlib_buffer_get_current (p0);
1278
1279           if (head_of_feature_arc == 0)
1280             goto skip_check;
1281
1282           vnet_buffer (p0)->l3_hdr_offset = p0->current_data;
1283
1284           type0 = lm->builtin_protocol_by_ip_protocol[ip0->protocol];
1285           flags0 = p0->flags;
1286           is_tcp_udp0 = ip6_next_proto_is_tcp_udp (p0, ip0, &udp_offset0);
1287           good_l4_csum0 = (flags0 & VNET_BUFFER_F_L4_CHECKSUM_CORRECT
1288                            || (flags0 & VNET_BUFFER_F_OFFLOAD_TCP_CKSUM
1289                                || flags0 & VNET_BUFFER_F_OFFLOAD_UDP_CKSUM))
1290             != 0;
1291
1292           len_diff0 = 0;
1293           if (PREDICT_TRUE (is_tcp_udp0))
1294             {
1295               udp0 = (udp_header_t *) ((u8 *) ip0 + udp_offset0);
1296               /* Don't verify UDP checksum for packets with explicit zero
1297                * checksum. */
1298               good_l4_csum0 |= type0 == IP_BUILTIN_PROTOCOL_UDP
1299                 && udp0->checksum == 0;
1300               /* Verify UDP length. */
1301               if (is_tcp_udp0 == IP_PROTOCOL_UDP)
1302                 {
1303                   ip_len0 = clib_net_to_host_u16 (ip0->payload_length);
1304                   udp_len0 = clib_net_to_host_u16 (udp0->length);
1305                   len_diff0 = ip_len0 - udp_len0;
1306                 }
1307             }
1308
1309           good_l4_csum0 |= type0 == IP_BUILTIN_PROTOCOL_UNKNOWN;
1310           len_diff0 = type0 == IP_BUILTIN_PROTOCOL_UDP ? len_diff0 : 0;
1311
1312           if (PREDICT_FALSE (type0 != IP_BUILTIN_PROTOCOL_UNKNOWN
1313                              && !good_l4_csum0
1314                              && !(flags0 &
1315                                   VNET_BUFFER_F_L4_CHECKSUM_COMPUTED)))
1316             {
1317               flags0 = ip6_tcp_udp_icmp_validate_checksum (vm, p0);
1318               good_l4_csum0 =
1319                 (flags0 & VNET_BUFFER_F_L4_CHECKSUM_CORRECT) != 0;
1320             }
1321
1322           error0 = IP6_ERROR_UNKNOWN_PROTOCOL;
1323           error0 = len_diff0 < 0 ? IP6_ERROR_UDP_LENGTH : error0;
1324
1325           ASSERT (IP6_ERROR_UDP_CHECKSUM + IP_BUILTIN_PROTOCOL_UDP ==
1326                   IP6_ERROR_UDP_CHECKSUM);
1327           ASSERT (IP6_ERROR_UDP_CHECKSUM + IP_BUILTIN_PROTOCOL_ICMP ==
1328                   IP6_ERROR_ICMP_CHECKSUM);
1329           error0 = (!good_l4_csum0 ? IP6_ERROR_UDP_CHECKSUM + type0 : error0);
1330
1331           /* If this is a neighbor solicitation (ICMP), skip src RPF check */
1332           if (error0 == IP6_ERROR_UNKNOWN_PROTOCOL &&
1333               type0 != IP_BUILTIN_PROTOCOL_ICMP &&
1334               !ip6_address_is_link_local_unicast (&ip0->src_address))
1335             {
1336               error0 = (!ip6_urpf_loose_check (im, p0, ip0)
1337                         ? IP6_ERROR_SRC_LOOKUP_MISS : error0);
1338             }
1339
1340           vnet_buffer (p0)->ip.fib_index =
1341             vnet_buffer (p0)->sw_if_index[VLIB_TX] != ~0 ?
1342             vnet_buffer (p0)->sw_if_index[VLIB_TX] :
1343             vnet_buffer (p0)->ip.fib_index;
1344
1345         skip_check:
1346
1347           next0 = lm->local_next_by_ip_protocol[ip0->protocol];
1348           next0 =
1349             error0 != IP6_ERROR_UNKNOWN_PROTOCOL ? IP_LOCAL_NEXT_DROP : next0;
1350
1351           p0->error = error_node->errors[error0];
1352
1353           if (head_of_feature_arc)
1354             {
1355               if (PREDICT_TRUE (error0 == (u8) IP6_ERROR_UNKNOWN_PROTOCOL))
1356                 vnet_feature_arc_start (arc_index,
1357                                         vnet_buffer (p0)->sw_if_index
1358                                         [VLIB_RX], &next0, p0);
1359             }
1360
1361           vlib_validate_buffer_enqueue_x1 (vm, node, next_index,
1362                                            to_next, n_left_to_next,
1363                                            pi0, next0);
1364         }
1365
1366       vlib_put_next_frame (vm, node, next_index, n_left_to_next);
1367     }
1368
1369   return frame->n_vectors;
1370 }
1371
1372 static uword
1373 ip6_local (vlib_main_t * vm, vlib_node_runtime_t * node, vlib_frame_t * frame)
1374 {
1375   return ip6_local_inline (vm, node, frame, 1 /* head of feature arc */ );
1376 }
1377
1378 /* *INDENT-OFF* */
1379 VLIB_REGISTER_NODE (ip6_local_node, static) =
1380 {
1381   .function = ip6_local,
1382   .name = "ip6-local",
1383   .vector_size = sizeof (u32),
1384   .format_trace = format_ip6_forward_next_trace,
1385   .n_next_nodes = IP_LOCAL_N_NEXT,
1386   .next_nodes =
1387   {
1388     [IP_LOCAL_NEXT_DROP] = "ip6-drop",
1389     [IP_LOCAL_NEXT_PUNT] = "ip6-punt",
1390     [IP_LOCAL_NEXT_UDP_LOOKUP] = "ip6-udp-lookup",
1391     [IP_LOCAL_NEXT_ICMP] = "ip6-icmp-input",
1392   },
1393 };
1394 /* *INDENT-ON* */
1395
1396 VLIB_NODE_FUNCTION_MULTIARCH (ip6_local_node, ip6_local);
1397
1398
1399 static uword
1400 ip6_local_end_of_arc (vlib_main_t * vm,
1401                       vlib_node_runtime_t * node, vlib_frame_t * frame)
1402 {
1403   return ip6_local_inline (vm, node, frame, 0 /* head of feature arc */ );
1404 }
1405
1406 /* *INDENT-OFF* */
1407 VLIB_REGISTER_NODE (ip6_local_end_of_arc_node,static) = {
1408   .function = ip6_local_end_of_arc,
1409   .name = "ip6-local-end-of-arc",
1410   .vector_size = sizeof (u32),
1411
1412   .format_trace = format_ip6_forward_next_trace,
1413   .sibling_of = "ip6-local",
1414 };
1415
1416 VLIB_NODE_FUNCTION_MULTIARCH (ip6_local_end_of_arc_node, ip6_local_end_of_arc)
1417
1418 VNET_FEATURE_INIT (ip6_local_end_of_arc, static) = {
1419   .arc_name = "ip6-local",
1420   .node_name = "ip6-local-end-of-arc",
1421   .runs_before = 0, /* not before any other features */
1422 };
1423 /* *INDENT-ON* */
1424
1425 void
1426 ip6_register_protocol (u32 protocol, u32 node_index)
1427 {
1428   vlib_main_t *vm = vlib_get_main ();
1429   ip6_main_t *im = &ip6_main;
1430   ip_lookup_main_t *lm = &im->lookup_main;
1431
1432   ASSERT (protocol < ARRAY_LEN (lm->local_next_by_ip_protocol));
1433   lm->local_next_by_ip_protocol[protocol] =
1434     vlib_node_add_next (vm, ip6_local_node.index, node_index);
1435 }
1436
1437 clib_error_t *
1438 ip6_probe_neighbor (vlib_main_t * vm, ip6_address_t * dst, u32 sw_if_index)
1439 {
1440   vnet_main_t *vnm = vnet_get_main ();
1441   ip6_main_t *im = &ip6_main;
1442   icmp6_neighbor_solicitation_header_t *h;
1443   ip6_address_t *src;
1444   ip_interface_address_t *ia;
1445   ip_adjacency_t *adj;
1446   vnet_hw_interface_t *hi;
1447   vnet_sw_interface_t *si;
1448   vlib_buffer_t *b;
1449   adj_index_t ai;
1450   u32 bi = 0;
1451   int bogus_length;
1452
1453   si = vnet_get_sw_interface (vnm, sw_if_index);
1454
1455   if (!(si->flags & VNET_SW_INTERFACE_FLAG_ADMIN_UP))
1456     {
1457       return clib_error_return (0, "%U: interface %U down",
1458                                 format_ip6_address, dst,
1459                                 format_vnet_sw_if_index_name, vnm,
1460                                 sw_if_index);
1461     }
1462
1463   src =
1464     ip6_interface_address_matching_destination (im, dst, sw_if_index, &ia);
1465   if (!src)
1466     {
1467       vnm->api_errno = VNET_API_ERROR_NO_MATCHING_INTERFACE;
1468       return clib_error_return
1469         (0, "no matching interface address for destination %U (interface %U)",
1470          format_ip6_address, dst,
1471          format_vnet_sw_if_index_name, vnm, sw_if_index);
1472     }
1473
1474   h =
1475     vlib_packet_template_get_packet (vm,
1476                                      &im->discover_neighbor_packet_template,
1477                                      &bi);
1478
1479   hi = vnet_get_sup_hw_interface (vnm, sw_if_index);
1480
1481   /* Destination address is a solicited node multicast address.  We need to fill in
1482      the low 24 bits with low 24 bits of target's address. */
1483   h->ip.dst_address.as_u8[13] = dst->as_u8[13];
1484   h->ip.dst_address.as_u8[14] = dst->as_u8[14];
1485   h->ip.dst_address.as_u8[15] = dst->as_u8[15];
1486
1487   h->ip.src_address = src[0];
1488   h->neighbor.target_address = dst[0];
1489
1490   if (PREDICT_FALSE (!hi->hw_address))
1491     {
1492       return clib_error_return (0, "%U: interface %U do not support ip probe",
1493                                 format_ip6_address, dst,
1494                                 format_vnet_sw_if_index_name, vnm,
1495                                 sw_if_index);
1496     }
1497
1498   clib_memcpy (h->link_layer_option.ethernet_address, hi->hw_address,
1499                vec_len (hi->hw_address));
1500
1501   h->neighbor.icmp.checksum =
1502     ip6_tcp_udp_icmp_compute_checksum (vm, 0, &h->ip, &bogus_length);
1503   ASSERT (bogus_length == 0);
1504
1505   b = vlib_get_buffer (vm, bi);
1506   vnet_buffer (b)->sw_if_index[VLIB_RX] =
1507     vnet_buffer (b)->sw_if_index[VLIB_TX] = sw_if_index;
1508
1509   /* Add encapsulation string for software interface (e.g. ethernet header). */
1510   ip46_address_t nh = {
1511     .ip6 = *dst,
1512   };
1513
1514   ai = adj_nbr_add_or_lock (FIB_PROTOCOL_IP6,
1515                             VNET_LINK_IP6, &nh, sw_if_index);
1516   adj = adj_get (ai);
1517
1518   /* Peer has been previously resolved, retrieve glean adj instead */
1519   if (adj->lookup_next_index == IP_LOOKUP_NEXT_REWRITE)
1520     {
1521       adj_unlock (ai);
1522       ai = adj_glean_add_or_lock (FIB_PROTOCOL_IP6,
1523                                   VNET_LINK_IP6, sw_if_index, &nh);
1524       adj = adj_get (ai);
1525     }
1526
1527   vnet_rewrite_one_header (adj[0], h, sizeof (ethernet_header_t));
1528   vlib_buffer_advance (b, -adj->rewrite_header.data_bytes);
1529
1530   {
1531     vlib_frame_t *f = vlib_get_frame_to_node (vm, hi->output_node_index);
1532     u32 *to_next = vlib_frame_vector_args (f);
1533     to_next[0] = bi;
1534     f->n_vectors = 1;
1535     vlib_put_frame_to_node (vm, hi->output_node_index, f);
1536   }
1537
1538   adj_unlock (ai);
1539   return /* no error */ 0;
1540 }
1541
1542 typedef enum
1543 {
1544   IP6_REWRITE_NEXT_DROP,
1545   IP6_REWRITE_NEXT_ICMP_ERROR,
1546   IP6_REWRITE_NEXT_FRAGMENT,
1547   IP6_REWRITE_N_NEXT            /* Last */
1548 } ip6_rewrite_next_t;
1549
1550 /**
1551  * This bits of an IPv6 address to mask to construct a multicast
1552  * MAC address
1553  */
1554 #define IP6_MCAST_ADDR_MASK 0xffffffff
1555
1556 always_inline void
1557 ip6_mtu_check (vlib_buffer_t * b, u16 packet_bytes,
1558                u16 adj_packet_bytes, bool is_locally_generated,
1559                u32 * next, u32 * error)
1560 {
1561   if (adj_packet_bytes >= 1280 && packet_bytes > adj_packet_bytes)
1562     {
1563       if (is_locally_generated)
1564         {
1565           /* IP fragmentation */
1566           ip_frag_set_vnet_buffer (b, 0, adj_packet_bytes,
1567                                    IP6_FRAG_NEXT_IP6_LOOKUP, 0);
1568           *next = IP6_REWRITE_NEXT_FRAGMENT;
1569         }
1570       else
1571         {
1572           *error = IP6_ERROR_MTU_EXCEEDED;
1573           icmp6_error_set_vnet_buffer (b, ICMP6_packet_too_big, 0,
1574                                        adj_packet_bytes);
1575           *next = IP6_REWRITE_NEXT_ICMP_ERROR;
1576         }
1577     }
1578 }
1579
1580 always_inline uword
1581 ip6_rewrite_inline (vlib_main_t * vm,
1582                     vlib_node_runtime_t * node,
1583                     vlib_frame_t * frame,
1584                     int do_counters, int is_midchain, int is_mcast)
1585 {
1586   ip_lookup_main_t *lm = &ip6_main.lookup_main;
1587   u32 *from = vlib_frame_vector_args (frame);
1588   u32 n_left_from, n_left_to_next, *to_next, next_index;
1589   vlib_node_runtime_t *error_node =
1590     vlib_node_get_runtime (vm, ip6_input_node.index);
1591
1592   n_left_from = frame->n_vectors;
1593   next_index = node->cached_next_index;
1594   u32 thread_index = vlib_get_thread_index ();
1595
1596   while (n_left_from > 0)
1597     {
1598       vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next);
1599
1600       while (n_left_from >= 4 && n_left_to_next >= 2)
1601         {
1602           ip_adjacency_t *adj0, *adj1;
1603           vlib_buffer_t *p0, *p1;
1604           ip6_header_t *ip0, *ip1;
1605           u32 pi0, rw_len0, next0, error0, adj_index0;
1606           u32 pi1, rw_len1, next1, error1, adj_index1;
1607           u32 tx_sw_if_index0, tx_sw_if_index1;
1608           bool is_locally_originated0, is_locally_originated1;
1609
1610           /* Prefetch next iteration. */
1611           {
1612             vlib_buffer_t *p2, *p3;
1613
1614             p2 = vlib_get_buffer (vm, from[2]);
1615             p3 = vlib_get_buffer (vm, from[3]);
1616
1617             vlib_prefetch_buffer_header (p2, LOAD);
1618             vlib_prefetch_buffer_header (p3, LOAD);
1619
1620             CLIB_PREFETCH (p2->pre_data, 32, STORE);
1621             CLIB_PREFETCH (p3->pre_data, 32, STORE);
1622
1623             CLIB_PREFETCH (p2->data, sizeof (ip0[0]), STORE);
1624             CLIB_PREFETCH (p3->data, sizeof (ip0[0]), STORE);
1625           }
1626
1627           pi0 = to_next[0] = from[0];
1628           pi1 = to_next[1] = from[1];
1629
1630           from += 2;
1631           n_left_from -= 2;
1632           to_next += 2;
1633           n_left_to_next -= 2;
1634
1635           p0 = vlib_get_buffer (vm, pi0);
1636           p1 = vlib_get_buffer (vm, pi1);
1637
1638           adj_index0 = vnet_buffer (p0)->ip.adj_index[VLIB_TX];
1639           adj_index1 = vnet_buffer (p1)->ip.adj_index[VLIB_TX];
1640
1641           ip0 = vlib_buffer_get_current (p0);
1642           ip1 = vlib_buffer_get_current (p1);
1643
1644           error0 = error1 = IP6_ERROR_NONE;
1645           next0 = next1 = IP6_REWRITE_NEXT_DROP;
1646
1647           is_locally_originated0 =
1648             p0->flags & VNET_BUFFER_F_LOCALLY_ORIGINATED;
1649           if (PREDICT_TRUE (!is_locally_originated0))
1650             {
1651               i32 hop_limit0 = ip0->hop_limit;
1652
1653               /* Input node should have reject packets with hop limit 0. */
1654               ASSERT (ip0->hop_limit > 0);
1655
1656               hop_limit0 -= 1;
1657
1658               ip0->hop_limit = hop_limit0;
1659
1660               /*
1661                * If the hop count drops below 1 when forwarding, generate
1662                * an ICMP response.
1663                */
1664               if (PREDICT_FALSE (hop_limit0 <= 0))
1665                 {
1666                   error0 = IP6_ERROR_TIME_EXPIRED;
1667                   next0 = IP6_REWRITE_NEXT_ICMP_ERROR;
1668                   vnet_buffer (p0)->sw_if_index[VLIB_TX] = (u32) ~ 0;
1669                   icmp6_error_set_vnet_buffer (p0, ICMP6_time_exceeded,
1670                                                ICMP6_time_exceeded_ttl_exceeded_in_transit,
1671                                                0);
1672                 }
1673             }
1674           else
1675             {
1676               p0->flags &= ~VNET_BUFFER_F_LOCALLY_ORIGINATED;
1677             }
1678           is_locally_originated1 =
1679             p1->flags & VNET_BUFFER_F_LOCALLY_ORIGINATED;
1680           if (PREDICT_TRUE (!is_locally_originated1))
1681             {
1682               i32 hop_limit1 = ip1->hop_limit;
1683
1684               /* Input node should have reject packets with hop limit 0. */
1685               ASSERT (ip1->hop_limit > 0);
1686
1687               hop_limit1 -= 1;
1688
1689               ip1->hop_limit = hop_limit1;
1690
1691               /*
1692                * If the hop count drops below 1 when forwarding, generate
1693                * an ICMP response.
1694                */
1695               if (PREDICT_FALSE (hop_limit1 <= 0))
1696                 {
1697                   error1 = IP6_ERROR_TIME_EXPIRED;
1698                   next1 = IP6_REWRITE_NEXT_ICMP_ERROR;
1699                   vnet_buffer (p1)->sw_if_index[VLIB_TX] = (u32) ~ 0;
1700                   icmp6_error_set_vnet_buffer (p1, ICMP6_time_exceeded,
1701                                                ICMP6_time_exceeded_ttl_exceeded_in_transit,
1702                                                0);
1703                 }
1704             }
1705           else
1706             {
1707               p1->flags &= ~VNET_BUFFER_F_LOCALLY_ORIGINATED;
1708             }
1709           adj0 = adj_get (adj_index0);
1710           adj1 = adj_get (adj_index1);
1711
1712           rw_len0 = adj0[0].rewrite_header.data_bytes;
1713           rw_len1 = adj1[0].rewrite_header.data_bytes;
1714           vnet_buffer (p0)->ip.save_rewrite_length = rw_len0;
1715           vnet_buffer (p1)->ip.save_rewrite_length = rw_len1;
1716
1717           if (do_counters)
1718             {
1719               vlib_increment_combined_counter
1720                 (&adjacency_counters,
1721                  thread_index, adj_index0, 1,
1722                  vlib_buffer_length_in_chain (vm, p0) + rw_len0);
1723               vlib_increment_combined_counter
1724                 (&adjacency_counters,
1725                  thread_index, adj_index1, 1,
1726                  vlib_buffer_length_in_chain (vm, p1) + rw_len1);
1727             }
1728
1729           /* Check MTU of outgoing interface. */
1730           ip6_mtu_check (p0, clib_net_to_host_u16 (ip0->payload_length) +
1731                          sizeof (ip6_header_t),
1732                          adj0[0].rewrite_header.max_l3_packet_bytes,
1733                          is_locally_originated0, &next0, &error0);
1734           ip6_mtu_check (p1, clib_net_to_host_u16 (ip1->payload_length) +
1735                          sizeof (ip6_header_t),
1736                          adj1[0].rewrite_header.max_l3_packet_bytes,
1737                          is_locally_originated1, &next1, &error1);
1738
1739           /* Don't adjust the buffer for hop count issue; icmp-error node
1740            * wants to see the IP headerr */
1741           if (PREDICT_TRUE (error0 == IP6_ERROR_NONE))
1742             {
1743               p0->current_data -= rw_len0;
1744               p0->current_length += rw_len0;
1745
1746               tx_sw_if_index0 = adj0[0].rewrite_header.sw_if_index;
1747               vnet_buffer (p0)->sw_if_index[VLIB_TX] = tx_sw_if_index0;
1748               next0 = adj0[0].rewrite_header.next_index;
1749
1750               if (PREDICT_FALSE
1751                   (adj0[0].rewrite_header.flags & VNET_REWRITE_HAS_FEATURES))
1752                 vnet_feature_arc_start (lm->output_feature_arc_index,
1753                                         tx_sw_if_index0, &next0, p0);
1754             }
1755           if (PREDICT_TRUE (error1 == IP6_ERROR_NONE))
1756             {
1757               p1->current_data -= rw_len1;
1758               p1->current_length += rw_len1;
1759
1760               tx_sw_if_index1 = adj1[0].rewrite_header.sw_if_index;
1761               vnet_buffer (p1)->sw_if_index[VLIB_TX] = tx_sw_if_index1;
1762               next1 = adj1[0].rewrite_header.next_index;
1763
1764               if (PREDICT_FALSE
1765                   (adj1[0].rewrite_header.flags & VNET_REWRITE_HAS_FEATURES))
1766                 vnet_feature_arc_start (lm->output_feature_arc_index,
1767                                         tx_sw_if_index1, &next1, p1);
1768             }
1769
1770           /* Guess we are only writing on simple Ethernet header. */
1771           vnet_rewrite_two_headers (adj0[0], adj1[0],
1772                                     ip0, ip1, sizeof (ethernet_header_t));
1773
1774           if (is_midchain)
1775             {
1776               adj0->sub_type.midchain.fixup_func
1777                 (vm, adj0, p0, adj0->sub_type.midchain.fixup_data);
1778               adj1->sub_type.midchain.fixup_func
1779                 (vm, adj1, p1, adj1->sub_type.midchain.fixup_data);
1780             }
1781           if (is_mcast)
1782             {
1783               /*
1784                * copy bytes from the IP address into the MAC rewrite
1785                */
1786               vnet_ip_mcast_fixup_header (IP6_MCAST_ADDR_MASK,
1787                                           adj0->
1788                                           rewrite_header.dst_mcast_offset,
1789                                           &ip0->dst_address.as_u32[3],
1790                                           (u8 *) ip0);
1791               vnet_ip_mcast_fixup_header (IP6_MCAST_ADDR_MASK,
1792                                           adj1->
1793                                           rewrite_header.dst_mcast_offset,
1794                                           &ip1->dst_address.as_u32[3],
1795                                           (u8 *) ip1);
1796             }
1797
1798           vlib_validate_buffer_enqueue_x2 (vm, node, next_index,
1799                                            to_next, n_left_to_next,
1800                                            pi0, pi1, next0, next1);
1801         }
1802
1803       while (n_left_from > 0 && n_left_to_next > 0)
1804         {
1805           ip_adjacency_t *adj0;
1806           vlib_buffer_t *p0;
1807           ip6_header_t *ip0;
1808           u32 pi0, rw_len0;
1809           u32 adj_index0, next0, error0;
1810           u32 tx_sw_if_index0;
1811           bool is_locally_originated0;
1812
1813           pi0 = to_next[0] = from[0];
1814
1815           p0 = vlib_get_buffer (vm, pi0);
1816
1817           adj_index0 = vnet_buffer (p0)->ip.adj_index[VLIB_TX];
1818
1819           adj0 = adj_get (adj_index0);
1820
1821           ip0 = vlib_buffer_get_current (p0);
1822
1823           error0 = IP6_ERROR_NONE;
1824           next0 = IP6_REWRITE_NEXT_DROP;
1825
1826           /* Check hop limit */
1827           is_locally_originated0 =
1828             p0->flags & VNET_BUFFER_F_LOCALLY_ORIGINATED;
1829           if (PREDICT_TRUE (!is_locally_originated0))
1830             {
1831               i32 hop_limit0 = ip0->hop_limit;
1832
1833               ASSERT (ip0->hop_limit > 0);
1834
1835               hop_limit0 -= 1;
1836
1837               ip0->hop_limit = hop_limit0;
1838
1839               if (PREDICT_FALSE (hop_limit0 <= 0))
1840                 {
1841                   /*
1842                    * If the hop count drops below 1 when forwarding, generate
1843                    * an ICMP response.
1844                    */
1845                   error0 = IP6_ERROR_TIME_EXPIRED;
1846                   next0 = IP6_REWRITE_NEXT_ICMP_ERROR;
1847                   vnet_buffer (p0)->sw_if_index[VLIB_TX] = (u32) ~ 0;
1848                   icmp6_error_set_vnet_buffer (p0, ICMP6_time_exceeded,
1849                                                ICMP6_time_exceeded_ttl_exceeded_in_transit,
1850                                                0);
1851                 }
1852             }
1853           else
1854             {
1855               p0->flags &= ~VNET_BUFFER_F_LOCALLY_ORIGINATED;
1856             }
1857
1858           /* Guess we are only writing on simple Ethernet header. */
1859           vnet_rewrite_one_header (adj0[0], ip0, sizeof (ethernet_header_t));
1860
1861           /* Update packet buffer attributes/set output interface. */
1862           rw_len0 = adj0[0].rewrite_header.data_bytes;
1863           vnet_buffer (p0)->ip.save_rewrite_length = rw_len0;
1864
1865           if (do_counters)
1866             {
1867               vlib_increment_combined_counter
1868                 (&adjacency_counters,
1869                  thread_index, adj_index0, 1,
1870                  vlib_buffer_length_in_chain (vm, p0) + rw_len0);
1871             }
1872
1873           /* Check MTU of outgoing interface. */
1874           ip6_mtu_check (p0, clib_net_to_host_u16 (ip0->payload_length) +
1875                          sizeof (ip6_header_t),
1876                          adj0[0].rewrite_header.max_l3_packet_bytes,
1877                          is_locally_originated0, &next0, &error0);
1878
1879           /* Don't adjust the buffer for hop count issue; icmp-error node
1880            * wants to see the IP header */
1881           if (PREDICT_TRUE (error0 == IP6_ERROR_NONE))
1882             {
1883               p0->current_data -= rw_len0;
1884               p0->current_length += rw_len0;
1885
1886               tx_sw_if_index0 = adj0[0].rewrite_header.sw_if_index;
1887
1888               vnet_buffer (p0)->sw_if_index[VLIB_TX] = tx_sw_if_index0;
1889               next0 = adj0[0].rewrite_header.next_index;
1890
1891               if (PREDICT_FALSE
1892                   (adj0[0].rewrite_header.flags & VNET_REWRITE_HAS_FEATURES))
1893                 vnet_feature_arc_start (lm->output_feature_arc_index,
1894                                         tx_sw_if_index0, &next0, p0);
1895             }
1896
1897           if (is_midchain)
1898             {
1899               adj0->sub_type.midchain.fixup_func
1900                 (vm, adj0, p0, adj0->sub_type.midchain.fixup_data);
1901             }
1902           if (is_mcast)
1903             {
1904               vnet_ip_mcast_fixup_header (IP6_MCAST_ADDR_MASK,
1905                                           adj0->
1906                                           rewrite_header.dst_mcast_offset,
1907                                           &ip0->dst_address.as_u32[3],
1908                                           (u8 *) ip0);
1909             }
1910
1911           p0->error = error_node->errors[error0];
1912
1913           from += 1;
1914           n_left_from -= 1;
1915           to_next += 1;
1916           n_left_to_next -= 1;
1917
1918           vlib_validate_buffer_enqueue_x1 (vm, node, next_index,
1919                                            to_next, n_left_to_next,
1920                                            pi0, next0);
1921         }
1922
1923       vlib_put_next_frame (vm, node, next_index, n_left_to_next);
1924     }
1925
1926   /* Need to do trace after rewrites to pick up new packet data. */
1927   if (node->flags & VLIB_NODE_FLAG_TRACE)
1928     ip6_forward_next_trace (vm, node, frame, VLIB_TX);
1929
1930   return frame->n_vectors;
1931 }
1932
1933 static uword
1934 ip6_rewrite (vlib_main_t * vm,
1935              vlib_node_runtime_t * node, vlib_frame_t * frame)
1936 {
1937   if (adj_are_counters_enabled ())
1938     return ip6_rewrite_inline (vm, node, frame, 1, 0, 0);
1939   else
1940     return ip6_rewrite_inline (vm, node, frame, 0, 0, 0);
1941 }
1942
1943 static uword
1944 ip6_rewrite_mcast (vlib_main_t * vm,
1945                    vlib_node_runtime_t * node, vlib_frame_t * frame)
1946 {
1947   if (adj_are_counters_enabled ())
1948     return ip6_rewrite_inline (vm, node, frame, 1, 0, 1);
1949   else
1950     return ip6_rewrite_inline (vm, node, frame, 0, 0, 1);
1951 }
1952
1953 static uword
1954 ip6_midchain (vlib_main_t * vm,
1955               vlib_node_runtime_t * node, vlib_frame_t * frame)
1956 {
1957   if (adj_are_counters_enabled ())
1958     return ip6_rewrite_inline (vm, node, frame, 1, 1, 0);
1959   else
1960     return ip6_rewrite_inline (vm, node, frame, 0, 1, 0);
1961 }
1962
1963 static uword
1964 ip6_mcast_midchain (vlib_main_t * vm,
1965                     vlib_node_runtime_t * node, vlib_frame_t * frame)
1966 {
1967   if (adj_are_counters_enabled ())
1968     return ip6_rewrite_inline (vm, node, frame, 1, 1, 1);
1969   else
1970     return ip6_rewrite_inline (vm, node, frame, 0, 1, 1);
1971 }
1972
1973 /* *INDENT-OFF* */
1974 VLIB_REGISTER_NODE (ip6_midchain_node) =
1975 {
1976   .function = ip6_midchain,
1977   .name = "ip6-midchain",
1978   .vector_size = sizeof (u32),
1979   .format_trace = format_ip6_forward_next_trace,
1980   .sibling_of = "ip6-rewrite",
1981   };
1982 /* *INDENT-ON* */
1983
1984 VLIB_NODE_FUNCTION_MULTIARCH (ip6_midchain_node, ip6_midchain);
1985
1986 /* *INDENT-OFF* */
1987 VLIB_REGISTER_NODE (ip6_rewrite_node) =
1988 {
1989   .function = ip6_rewrite,
1990   .name = "ip6-rewrite",
1991   .vector_size = sizeof (u32),
1992   .format_trace = format_ip6_rewrite_trace,
1993   .n_next_nodes = IP6_REWRITE_N_NEXT,
1994   .next_nodes =
1995   {
1996     [IP6_REWRITE_NEXT_DROP] = "ip6-drop",
1997     [IP6_REWRITE_NEXT_ICMP_ERROR] = "ip6-icmp-error",
1998     [IP6_REWRITE_NEXT_FRAGMENT] = "ip6-frag",
1999   },
2000 };
2001 /* *INDENT-ON* */
2002
2003 VLIB_NODE_FUNCTION_MULTIARCH (ip6_rewrite_node, ip6_rewrite);
2004
2005 /* *INDENT-OFF* */
2006 VLIB_REGISTER_NODE (ip6_rewrite_mcast_node) =
2007 {
2008   .function = ip6_rewrite_mcast,
2009   .name = "ip6-rewrite-mcast",
2010   .vector_size = sizeof (u32),
2011   .format_trace = format_ip6_rewrite_trace,
2012   .sibling_of = "ip6-rewrite",
2013 };
2014 /* *INDENT-ON* */
2015
2016 VLIB_NODE_FUNCTION_MULTIARCH (ip6_rewrite_mcast_node, ip6_rewrite_mcast);
2017
2018 /* *INDENT-OFF* */
2019 VLIB_REGISTER_NODE (ip6_mcast_midchain_node, static) =
2020 {
2021   .function = ip6_mcast_midchain,
2022   .name = "ip6-mcast-midchain",
2023   .vector_size = sizeof (u32),
2024   .format_trace = format_ip6_rewrite_trace,
2025   .sibling_of = "ip6-rewrite",
2026 };
2027 /* *INDENT-ON* */
2028
2029 VLIB_NODE_FUNCTION_MULTIARCH (ip6_mcast_midchain_node, ip6_mcast_midchain);
2030
2031 /*
2032  * Hop-by-Hop handling
2033  */
2034 ip6_hop_by_hop_main_t ip6_hop_by_hop_main;
2035
2036 #define foreach_ip6_hop_by_hop_error \
2037 _(PROCESSED, "pkts with ip6 hop-by-hop options") \
2038 _(FORMAT, "incorrectly formatted hop-by-hop options") \
2039 _(UNKNOWN_OPTION, "unknown ip6 hop-by-hop options")
2040
2041 /* *INDENT-OFF* */
2042 typedef enum
2043 {
2044 #define _(sym,str) IP6_HOP_BY_HOP_ERROR_##sym,
2045   foreach_ip6_hop_by_hop_error
2046 #undef _
2047   IP6_HOP_BY_HOP_N_ERROR,
2048 } ip6_hop_by_hop_error_t;
2049 /* *INDENT-ON* */
2050
2051 /*
2052  * Primary h-b-h handler trace support
2053  * We work pretty hard on the problem for obvious reasons
2054  */
2055 typedef struct
2056 {
2057   u32 next_index;
2058   u32 trace_len;
2059   u8 option_data[256];
2060 } ip6_hop_by_hop_trace_t;
2061
2062 vlib_node_registration_t ip6_hop_by_hop_node;
2063
2064 static char *ip6_hop_by_hop_error_strings[] = {
2065 #define _(sym,string) string,
2066   foreach_ip6_hop_by_hop_error
2067 #undef _
2068 };
2069
2070 u8 *
2071 format_ip6_hop_by_hop_ext_hdr (u8 * s, va_list * args)
2072 {
2073   ip6_hop_by_hop_header_t *hbh0 = va_arg (*args, ip6_hop_by_hop_header_t *);
2074   int total_len = va_arg (*args, int);
2075   ip6_hop_by_hop_option_t *opt0, *limit0;
2076   ip6_hop_by_hop_main_t *hm = &ip6_hop_by_hop_main;
2077   u8 type0;
2078
2079   s = format (s, "IP6_HOP_BY_HOP: next protocol %d len %d total %d",
2080               hbh0->protocol, (hbh0->length + 1) << 3, total_len);
2081
2082   opt0 = (ip6_hop_by_hop_option_t *) (hbh0 + 1);
2083   limit0 = (ip6_hop_by_hop_option_t *) ((u8 *) hbh0 + total_len);
2084
2085   while (opt0 < limit0)
2086     {
2087       type0 = opt0->type;
2088       switch (type0)
2089         {
2090         case 0:         /* Pad, just stop */
2091           opt0 = (ip6_hop_by_hop_option_t *) ((u8 *) opt0 + 1);
2092           break;
2093
2094         default:
2095           if (hm->trace[type0])
2096             {
2097               s = (*hm->trace[type0]) (s, opt0);
2098             }
2099           else
2100             {
2101               s =
2102                 format (s, "\n    unrecognized option %d length %d", type0,
2103                         opt0->length);
2104             }
2105           opt0 =
2106             (ip6_hop_by_hop_option_t *) (((u8 *) opt0) + opt0->length +
2107                                          sizeof (ip6_hop_by_hop_option_t));
2108           break;
2109         }
2110     }
2111   return s;
2112 }
2113
2114 static u8 *
2115 format_ip6_hop_by_hop_trace (u8 * s, va_list * args)
2116 {
2117   CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *);
2118   CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *);
2119   ip6_hop_by_hop_trace_t *t = va_arg (*args, ip6_hop_by_hop_trace_t *);
2120   ip6_hop_by_hop_header_t *hbh0;
2121   ip6_hop_by_hop_option_t *opt0, *limit0;
2122   ip6_hop_by_hop_main_t *hm = &ip6_hop_by_hop_main;
2123
2124   u8 type0;
2125
2126   hbh0 = (ip6_hop_by_hop_header_t *) t->option_data;
2127
2128   s = format (s, "IP6_HOP_BY_HOP: next index %d len %d traced %d",
2129               t->next_index, (hbh0->length + 1) << 3, t->trace_len);
2130
2131   opt0 = (ip6_hop_by_hop_option_t *) (hbh0 + 1);
2132   limit0 = (ip6_hop_by_hop_option_t *) ((u8 *) hbh0) + t->trace_len;
2133
2134   while (opt0 < limit0)
2135     {
2136       type0 = opt0->type;
2137       switch (type0)
2138         {
2139         case 0:         /* Pad, just stop */
2140           opt0 = (ip6_hop_by_hop_option_t *) ((u8 *) opt0) + 1;
2141           break;
2142
2143         default:
2144           if (hm->trace[type0])
2145             {
2146               s = (*hm->trace[type0]) (s, opt0);
2147             }
2148           else
2149             {
2150               s =
2151                 format (s, "\n    unrecognized option %d length %d", type0,
2152                         opt0->length);
2153             }
2154           opt0 =
2155             (ip6_hop_by_hop_option_t *) (((u8 *) opt0) + opt0->length +
2156                                          sizeof (ip6_hop_by_hop_option_t));
2157           break;
2158         }
2159     }
2160   return s;
2161 }
2162
2163 always_inline u8
2164 ip6_scan_hbh_options (vlib_buffer_t * b0,
2165                       ip6_header_t * ip0,
2166                       ip6_hop_by_hop_header_t * hbh0,
2167                       ip6_hop_by_hop_option_t * opt0,
2168                       ip6_hop_by_hop_option_t * limit0, u32 * next0)
2169 {
2170   ip6_hop_by_hop_main_t *hm = &ip6_hop_by_hop_main;
2171   u8 type0;
2172   u8 error0 = 0;
2173
2174   while (opt0 < limit0)
2175     {
2176       type0 = opt0->type;
2177       switch (type0)
2178         {
2179         case 0:         /* Pad1 */
2180           opt0 = (ip6_hop_by_hop_option_t *) ((u8 *) opt0) + 1;
2181           continue;
2182         case 1:         /* PadN */
2183           break;
2184         default:
2185           if (hm->options[type0])
2186             {
2187               if ((*hm->options[type0]) (b0, ip0, opt0) < 0)
2188                 {
2189                   error0 = IP6_HOP_BY_HOP_ERROR_FORMAT;
2190                   return (error0);
2191                 }
2192             }
2193           else
2194             {
2195               /* Unrecognized mandatory option, check the two high order bits */
2196               switch (opt0->type & HBH_OPTION_TYPE_HIGH_ORDER_BITS)
2197                 {
2198                 case HBH_OPTION_TYPE_SKIP_UNKNOWN:
2199                   break;
2200                 case HBH_OPTION_TYPE_DISCARD_UNKNOWN:
2201                   error0 = IP6_HOP_BY_HOP_ERROR_UNKNOWN_OPTION;
2202                   *next0 = IP_LOOKUP_NEXT_DROP;
2203                   break;
2204                 case HBH_OPTION_TYPE_DISCARD_UNKNOWN_ICMP:
2205                   error0 = IP6_HOP_BY_HOP_ERROR_UNKNOWN_OPTION;
2206                   *next0 = IP_LOOKUP_NEXT_ICMP_ERROR;
2207                   icmp6_error_set_vnet_buffer (b0, ICMP6_parameter_problem,
2208                                                ICMP6_parameter_problem_unrecognized_option,
2209                                                (u8 *) opt0 - (u8 *) ip0);
2210                   break;
2211                 case HBH_OPTION_TYPE_DISCARD_UNKNOWN_ICMP_NOT_MCAST:
2212                   error0 = IP6_HOP_BY_HOP_ERROR_UNKNOWN_OPTION;
2213                   if (!ip6_address_is_multicast (&ip0->dst_address))
2214                     {
2215                       *next0 = IP_LOOKUP_NEXT_ICMP_ERROR;
2216                       icmp6_error_set_vnet_buffer (b0,
2217                                                    ICMP6_parameter_problem,
2218                                                    ICMP6_parameter_problem_unrecognized_option,
2219                                                    (u8 *) opt0 - (u8 *) ip0);
2220                     }
2221                   else
2222                     {
2223                       *next0 = IP_LOOKUP_NEXT_DROP;
2224                     }
2225                   break;
2226                 }
2227               return (error0);
2228             }
2229         }
2230       opt0 =
2231         (ip6_hop_by_hop_option_t *) (((u8 *) opt0) + opt0->length +
2232                                      sizeof (ip6_hop_by_hop_option_t));
2233     }
2234   return (error0);
2235 }
2236
2237 /*
2238  * Process the Hop-by-Hop Options header
2239  */
2240 static uword
2241 ip6_hop_by_hop (vlib_main_t * vm,
2242                 vlib_node_runtime_t * node, vlib_frame_t * frame)
2243 {
2244   vlib_node_runtime_t *error_node =
2245     vlib_node_get_runtime (vm, ip6_hop_by_hop_node.index);
2246   ip6_hop_by_hop_main_t *hm = &ip6_hop_by_hop_main;
2247   u32 n_left_from, *from, *to_next;
2248   ip_lookup_next_t next_index;
2249
2250   from = vlib_frame_vector_args (frame);
2251   n_left_from = frame->n_vectors;
2252   next_index = node->cached_next_index;
2253
2254   while (n_left_from > 0)
2255     {
2256       u32 n_left_to_next;
2257
2258       vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next);
2259
2260       while (n_left_from >= 4 && n_left_to_next >= 2)
2261         {
2262           u32 bi0, bi1;
2263           vlib_buffer_t *b0, *b1;
2264           u32 next0, next1;
2265           ip6_header_t *ip0, *ip1;
2266           ip6_hop_by_hop_header_t *hbh0, *hbh1;
2267           ip6_hop_by_hop_option_t *opt0, *limit0, *opt1, *limit1;
2268           u8 error0 = 0, error1 = 0;
2269
2270           /* Prefetch next iteration. */
2271           {
2272             vlib_buffer_t *p2, *p3;
2273
2274             p2 = vlib_get_buffer (vm, from[2]);
2275             p3 = vlib_get_buffer (vm, from[3]);
2276
2277             vlib_prefetch_buffer_header (p2, LOAD);
2278             vlib_prefetch_buffer_header (p3, LOAD);
2279
2280             CLIB_PREFETCH (p2->data, 2 * CLIB_CACHE_LINE_BYTES, LOAD);
2281             CLIB_PREFETCH (p3->data, 2 * CLIB_CACHE_LINE_BYTES, LOAD);
2282           }
2283
2284           /* Speculatively enqueue b0, b1 to the current next frame */
2285           to_next[0] = bi0 = from[0];
2286           to_next[1] = bi1 = from[1];
2287           from += 2;
2288           to_next += 2;
2289           n_left_from -= 2;
2290           n_left_to_next -= 2;
2291
2292           b0 = vlib_get_buffer (vm, bi0);
2293           b1 = vlib_get_buffer (vm, bi1);
2294
2295           /* Default use the next_index from the adjacency. A HBH option rarely redirects to a different node */
2296           u32 adj_index0 = vnet_buffer (b0)->ip.adj_index[VLIB_TX];
2297           ip_adjacency_t *adj0 = adj_get (adj_index0);
2298           u32 adj_index1 = vnet_buffer (b1)->ip.adj_index[VLIB_TX];
2299           ip_adjacency_t *adj1 = adj_get (adj_index1);
2300
2301           /* Default use the next_index from the adjacency. A HBH option rarely redirects to a different node */
2302           next0 = adj0->lookup_next_index;
2303           next1 = adj1->lookup_next_index;
2304
2305           ip0 = vlib_buffer_get_current (b0);
2306           ip1 = vlib_buffer_get_current (b1);
2307           hbh0 = (ip6_hop_by_hop_header_t *) (ip0 + 1);
2308           hbh1 = (ip6_hop_by_hop_header_t *) (ip1 + 1);
2309           opt0 = (ip6_hop_by_hop_option_t *) (hbh0 + 1);
2310           opt1 = (ip6_hop_by_hop_option_t *) (hbh1 + 1);
2311           limit0 =
2312             (ip6_hop_by_hop_option_t *) ((u8 *) hbh0 +
2313                                          ((hbh0->length + 1) << 3));
2314           limit1 =
2315             (ip6_hop_by_hop_option_t *) ((u8 *) hbh1 +
2316                                          ((hbh1->length + 1) << 3));
2317
2318           /*
2319            * Basic validity checks
2320            */
2321           if ((hbh0->length + 1) << 3 >
2322               clib_net_to_host_u16 (ip0->payload_length))
2323             {
2324               error0 = IP6_HOP_BY_HOP_ERROR_FORMAT;
2325               next0 = IP_LOOKUP_NEXT_DROP;
2326               goto outdual;
2327             }
2328           /* Scan the set of h-b-h options, process ones that we understand */
2329           error0 = ip6_scan_hbh_options (b0, ip0, hbh0, opt0, limit0, &next0);
2330
2331           if ((hbh1->length + 1) << 3 >
2332               clib_net_to_host_u16 (ip1->payload_length))
2333             {
2334               error1 = IP6_HOP_BY_HOP_ERROR_FORMAT;
2335               next1 = IP_LOOKUP_NEXT_DROP;
2336               goto outdual;
2337             }
2338           /* Scan the set of h-b-h options, process ones that we understand */
2339           error1 = ip6_scan_hbh_options (b1, ip1, hbh1, opt1, limit1, &next1);
2340
2341         outdual:
2342           /* Has the classifier flagged this buffer for special treatment? */
2343           if (PREDICT_FALSE
2344               ((error0 == 0)
2345                && (vnet_buffer (b0)->l2_classify.opaque_index & OI_DECAP)))
2346             next0 = hm->next_override;
2347
2348           /* Has the classifier flagged this buffer for special treatment? */
2349           if (PREDICT_FALSE
2350               ((error1 == 0)
2351                && (vnet_buffer (b1)->l2_classify.opaque_index & OI_DECAP)))
2352             next1 = hm->next_override;
2353
2354           if (PREDICT_FALSE ((node->flags & VLIB_NODE_FLAG_TRACE)))
2355             {
2356               if (b0->flags & VLIB_BUFFER_IS_TRACED)
2357                 {
2358                   ip6_hop_by_hop_trace_t *t =
2359                     vlib_add_trace (vm, node, b0, sizeof (*t));
2360                   u32 trace_len = (hbh0->length + 1) << 3;
2361                   t->next_index = next0;
2362                   /* Capture the h-b-h option verbatim */
2363                   trace_len =
2364                     trace_len <
2365                     ARRAY_LEN (t->option_data) ? trace_len :
2366                     ARRAY_LEN (t->option_data);
2367                   t->trace_len = trace_len;
2368                   clib_memcpy (t->option_data, hbh0, trace_len);
2369                 }
2370               if (b1->flags & VLIB_BUFFER_IS_TRACED)
2371                 {
2372                   ip6_hop_by_hop_trace_t *t =
2373                     vlib_add_trace (vm, node, b1, sizeof (*t));
2374                   u32 trace_len = (hbh1->length + 1) << 3;
2375                   t->next_index = next1;
2376                   /* Capture the h-b-h option verbatim */
2377                   trace_len =
2378                     trace_len <
2379                     ARRAY_LEN (t->option_data) ? trace_len :
2380                     ARRAY_LEN (t->option_data);
2381                   t->trace_len = trace_len;
2382                   clib_memcpy (t->option_data, hbh1, trace_len);
2383                 }
2384
2385             }
2386
2387           b0->error = error_node->errors[error0];
2388           b1->error = error_node->errors[error1];
2389
2390           /* verify speculative enqueue, maybe switch current next frame */
2391           vlib_validate_buffer_enqueue_x2 (vm, node, next_index, to_next,
2392                                            n_left_to_next, bi0, bi1, next0,
2393                                            next1);
2394         }
2395
2396       while (n_left_from > 0 && n_left_to_next > 0)
2397         {
2398           u32 bi0;
2399           vlib_buffer_t *b0;
2400           u32 next0;
2401           ip6_header_t *ip0;
2402           ip6_hop_by_hop_header_t *hbh0;
2403           ip6_hop_by_hop_option_t *opt0, *limit0;
2404           u8 error0 = 0;
2405
2406           /* Speculatively enqueue b0 to the current next frame */
2407           bi0 = from[0];
2408           to_next[0] = bi0;
2409           from += 1;
2410           to_next += 1;
2411           n_left_from -= 1;
2412           n_left_to_next -= 1;
2413
2414           b0 = vlib_get_buffer (vm, bi0);
2415           /*
2416            * Default use the next_index from the adjacency.
2417            * A HBH option rarely redirects to a different node
2418            */
2419           u32 adj_index0 = vnet_buffer (b0)->ip.adj_index[VLIB_TX];
2420           ip_adjacency_t *adj0 = adj_get (adj_index0);
2421           next0 = adj0->lookup_next_index;
2422
2423           ip0 = vlib_buffer_get_current (b0);
2424           hbh0 = (ip6_hop_by_hop_header_t *) (ip0 + 1);
2425           opt0 = (ip6_hop_by_hop_option_t *) (hbh0 + 1);
2426           limit0 =
2427             (ip6_hop_by_hop_option_t *) ((u8 *) hbh0 +
2428                                          ((hbh0->length + 1) << 3));
2429
2430           /*
2431            * Basic validity checks
2432            */
2433           if ((hbh0->length + 1) << 3 >
2434               clib_net_to_host_u16 (ip0->payload_length))
2435             {
2436               error0 = IP6_HOP_BY_HOP_ERROR_FORMAT;
2437               next0 = IP_LOOKUP_NEXT_DROP;
2438               goto out0;
2439             }
2440
2441           /* Scan the set of h-b-h options, process ones that we understand */
2442           error0 = ip6_scan_hbh_options (b0, ip0, hbh0, opt0, limit0, &next0);
2443
2444         out0:
2445           /* Has the classifier flagged this buffer for special treatment? */
2446           if (PREDICT_FALSE
2447               ((error0 == 0)
2448                && (vnet_buffer (b0)->l2_classify.opaque_index & OI_DECAP)))
2449             next0 = hm->next_override;
2450
2451           if (PREDICT_FALSE (b0->flags & VLIB_BUFFER_IS_TRACED))
2452             {
2453               ip6_hop_by_hop_trace_t *t =
2454                 vlib_add_trace (vm, node, b0, sizeof (*t));
2455               u32 trace_len = (hbh0->length + 1) << 3;
2456               t->next_index = next0;
2457               /* Capture the h-b-h option verbatim */
2458               trace_len =
2459                 trace_len <
2460                 ARRAY_LEN (t->option_data) ? trace_len :
2461                 ARRAY_LEN (t->option_data);
2462               t->trace_len = trace_len;
2463               clib_memcpy (t->option_data, hbh0, trace_len);
2464             }
2465
2466           b0->error = error_node->errors[error0];
2467
2468           /* verify speculative enqueue, maybe switch current next frame */
2469           vlib_validate_buffer_enqueue_x1 (vm, node, next_index, to_next,
2470                                            n_left_to_next, bi0, next0);
2471         }
2472       vlib_put_next_frame (vm, node, next_index, n_left_to_next);
2473     }
2474   return frame->n_vectors;
2475 }
2476
2477 /* *INDENT-OFF* */
2478 VLIB_REGISTER_NODE (ip6_hop_by_hop_node) =
2479 {
2480   .function = ip6_hop_by_hop,
2481   .name = "ip6-hop-by-hop",
2482   .sibling_of = "ip6-lookup",
2483   .vector_size = sizeof (u32),
2484   .format_trace = format_ip6_hop_by_hop_trace,
2485   .type = VLIB_NODE_TYPE_INTERNAL,
2486   .n_errors = ARRAY_LEN (ip6_hop_by_hop_error_strings),
2487   .error_strings = ip6_hop_by_hop_error_strings,
2488   .n_next_nodes = 0,
2489 };
2490 /* *INDENT-ON* */
2491
2492 VLIB_NODE_FUNCTION_MULTIARCH (ip6_hop_by_hop_node, ip6_hop_by_hop);
2493
2494 static clib_error_t *
2495 ip6_hop_by_hop_init (vlib_main_t * vm)
2496 {
2497   ip6_hop_by_hop_main_t *hm = &ip6_hop_by_hop_main;
2498   memset (hm->options, 0, sizeof (hm->options));
2499   memset (hm->trace, 0, sizeof (hm->trace));
2500   hm->next_override = IP6_LOOKUP_NEXT_POP_HOP_BY_HOP;
2501   return (0);
2502 }
2503
2504 VLIB_INIT_FUNCTION (ip6_hop_by_hop_init);
2505
2506 void
2507 ip6_hbh_set_next_override (uword next)
2508 {
2509   ip6_hop_by_hop_main_t *hm = &ip6_hop_by_hop_main;
2510
2511   hm->next_override = next;
2512 }
2513
2514 int
2515 ip6_hbh_register_option (u8 option,
2516                          int options (vlib_buffer_t * b, ip6_header_t * ip,
2517                                       ip6_hop_by_hop_option_t * opt),
2518                          u8 * trace (u8 * s, ip6_hop_by_hop_option_t * opt))
2519 {
2520   ip6_main_t *im = &ip6_main;
2521   ip6_hop_by_hop_main_t *hm = &ip6_hop_by_hop_main;
2522
2523   ASSERT ((u32) option < ARRAY_LEN (hm->options));
2524
2525   /* Already registered */
2526   if (hm->options[option])
2527     return (-1);
2528
2529   hm->options[option] = options;
2530   hm->trace[option] = trace;
2531
2532   /* Set global variable */
2533   im->hbh_enabled = 1;
2534
2535   return (0);
2536 }
2537
2538 int
2539 ip6_hbh_unregister_option (u8 option)
2540 {
2541   ip6_main_t *im = &ip6_main;
2542   ip6_hop_by_hop_main_t *hm = &ip6_hop_by_hop_main;
2543
2544   ASSERT ((u32) option < ARRAY_LEN (hm->options));
2545
2546   /* Not registered */
2547   if (!hm->options[option])
2548     return (-1);
2549
2550   hm->options[option] = NULL;
2551   hm->trace[option] = NULL;
2552
2553   /* Disable global knob if this was the last option configured */
2554   int i;
2555   bool found = false;
2556   for (i = 0; i < 256; i++)
2557     {
2558       if (hm->options[option])
2559         {
2560           found = true;
2561           break;
2562         }
2563     }
2564   if (!found)
2565     im->hbh_enabled = 0;
2566
2567   return (0);
2568 }
2569
2570 /* Global IP6 main. */
2571 ip6_main_t ip6_main;
2572
2573 static clib_error_t *
2574 ip6_lookup_init (vlib_main_t * vm)
2575 {
2576   ip6_main_t *im = &ip6_main;
2577   clib_error_t *error;
2578   uword i;
2579
2580   if ((error = vlib_call_init_function (vm, vnet_feature_init)))
2581     return error;
2582
2583   for (i = 0; i < ARRAY_LEN (im->fib_masks); i++)
2584     {
2585       u32 j, i0, i1;
2586
2587       i0 = i / 32;
2588       i1 = i % 32;
2589
2590       for (j = 0; j < i0; j++)
2591         im->fib_masks[i].as_u32[j] = ~0;
2592
2593       if (i1)
2594         im->fib_masks[i].as_u32[i0] =
2595           clib_host_to_net_u32 (pow2_mask (i1) << (32 - i1));
2596     }
2597
2598   ip_lookup_init (&im->lookup_main, /* is_ip6 */ 1);
2599
2600   if (im->lookup_table_nbuckets == 0)
2601     im->lookup_table_nbuckets = IP6_FIB_DEFAULT_HASH_NUM_BUCKETS;
2602
2603   im->lookup_table_nbuckets = 1 << max_log2 (im->lookup_table_nbuckets);
2604
2605   if (im->lookup_table_size == 0)
2606     im->lookup_table_size = IP6_FIB_DEFAULT_HASH_MEMORY_SIZE;
2607
2608   BV (clib_bihash_init) (&(im->ip6_table[IP6_FIB_TABLE_FWDING].ip6_hash),
2609                          "ip6 FIB fwding table",
2610                          im->lookup_table_nbuckets, im->lookup_table_size);
2611   BV (clib_bihash_init) (&im->ip6_table[IP6_FIB_TABLE_NON_FWDING].ip6_hash,
2612                          "ip6 FIB non-fwding table",
2613                          im->lookup_table_nbuckets, im->lookup_table_size);
2614
2615   /* Create FIB with index 0 and table id of 0. */
2616   fib_table_find_or_create_and_lock (FIB_PROTOCOL_IP6, 0,
2617                                      FIB_SOURCE_DEFAULT_ROUTE);
2618   mfib_table_find_or_create_and_lock (FIB_PROTOCOL_IP6, 0,
2619                                       MFIB_SOURCE_DEFAULT_ROUTE);
2620
2621   {
2622     pg_node_t *pn;
2623     pn = pg_get_node (ip6_lookup_node.index);
2624     pn->unformat_edit = unformat_pg_ip6_header;
2625   }
2626
2627   /* Unless explicitly configured, don't process HBH options */
2628   im->hbh_enabled = 0;
2629
2630   {
2631     icmp6_neighbor_solicitation_header_t p;
2632
2633     memset (&p, 0, sizeof (p));
2634
2635     p.ip.ip_version_traffic_class_and_flow_label =
2636       clib_host_to_net_u32 (0x6 << 28);
2637     p.ip.payload_length =
2638       clib_host_to_net_u16 (sizeof (p) -
2639                             STRUCT_OFFSET_OF
2640                             (icmp6_neighbor_solicitation_header_t, neighbor));
2641     p.ip.protocol = IP_PROTOCOL_ICMP6;
2642     p.ip.hop_limit = 255;
2643     ip6_set_solicited_node_multicast_address (&p.ip.dst_address, 0);
2644
2645     p.neighbor.icmp.type = ICMP6_neighbor_solicitation;
2646
2647     p.link_layer_option.header.type =
2648       ICMP6_NEIGHBOR_DISCOVERY_OPTION_source_link_layer_address;
2649     p.link_layer_option.header.n_data_u64s =
2650       sizeof (p.link_layer_option) / sizeof (u64);
2651
2652     vlib_packet_template_init (vm,
2653                                &im->discover_neighbor_packet_template,
2654                                &p, sizeof (p),
2655                                /* alloc chunk size */ 8,
2656                                "ip6 neighbor discovery");
2657   }
2658
2659   return error;
2660 }
2661
2662 VLIB_INIT_FUNCTION (ip6_lookup_init);
2663
2664 void
2665 ip6_link_local_address_from_ethernet_mac_address (ip6_address_t * ip,
2666                                                   u8 * mac)
2667 {
2668   ip->as_u64[0] = clib_host_to_net_u64 (0xFE80000000000000ULL);
2669   /* Invert the "u" bit */
2670   ip->as_u8[8] = mac[0] ^ (1 << 1);
2671   ip->as_u8[9] = mac[1];
2672   ip->as_u8[10] = mac[2];
2673   ip->as_u8[11] = 0xFF;
2674   ip->as_u8[12] = 0xFE;
2675   ip->as_u8[13] = mac[3];
2676   ip->as_u8[14] = mac[4];
2677   ip->as_u8[15] = mac[5];
2678 }
2679
2680 void
2681 ip6_ethernet_mac_address_from_link_local_address (u8 * mac,
2682                                                   ip6_address_t * ip)
2683 {
2684   /* Invert the previously inverted "u" bit */
2685   mac[0] = ip->as_u8[8] ^ (1 << 1);
2686   mac[1] = ip->as_u8[9];
2687   mac[2] = ip->as_u8[10];
2688   mac[3] = ip->as_u8[13];
2689   mac[4] = ip->as_u8[14];
2690   mac[5] = ip->as_u8[15];
2691 }
2692
2693 static clib_error_t *
2694 test_ip6_link_command_fn (vlib_main_t * vm,
2695                           unformat_input_t * input, vlib_cli_command_t * cmd)
2696 {
2697   u8 mac[6];
2698   ip6_address_t _a, *a = &_a;
2699
2700   if (unformat (input, "%U", unformat_ethernet_address, mac))
2701     {
2702       ip6_link_local_address_from_ethernet_mac_address (a, mac);
2703       vlib_cli_output (vm, "Link local address: %U", format_ip6_address, a);
2704       ip6_ethernet_mac_address_from_link_local_address (mac, a);
2705       vlib_cli_output (vm, "Original MAC address: %U",
2706                        format_ethernet_address, mac);
2707     }
2708
2709   return 0;
2710 }
2711
2712 /*?
2713  * This command converts the given MAC Address into an IPv6 link-local
2714  * address.
2715  *
2716  * @cliexpar
2717  * Example of how to create an IPv6 link-local address:
2718  * @cliexstart{test ip6 link 16:d9:e0:91:79:86}
2719  * Link local address: fe80::14d9:e0ff:fe91:7986
2720  * Original MAC address: 16:d9:e0:91:79:86
2721  * @cliexend
2722 ?*/
2723 /* *INDENT-OFF* */
2724 VLIB_CLI_COMMAND (test_link_command, static) =
2725 {
2726   .path = "test ip6 link",
2727   .function = test_ip6_link_command_fn,
2728   .short_help = "test ip6 link <mac-address>",
2729 };
2730 /* *INDENT-ON* */
2731
2732 int
2733 vnet_set_ip6_flow_hash (u32 table_id, u32 flow_hash_config)
2734 {
2735   u32 fib_index;
2736
2737   fib_index = fib_table_find (FIB_PROTOCOL_IP6, table_id);
2738
2739   if (~0 == fib_index)
2740     return VNET_API_ERROR_NO_SUCH_FIB;
2741
2742   fib_table_set_flow_hash_config (fib_index, FIB_PROTOCOL_IP6,
2743                                   flow_hash_config);
2744
2745   return 0;
2746 }
2747
2748 static clib_error_t *
2749 set_ip6_flow_hash_command_fn (vlib_main_t * vm,
2750                               unformat_input_t * input,
2751                               vlib_cli_command_t * cmd)
2752 {
2753   int matched = 0;
2754   u32 table_id = 0;
2755   u32 flow_hash_config = 0;
2756   int rv;
2757
2758   while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
2759     {
2760       if (unformat (input, "table %d", &table_id))
2761         matched = 1;
2762 #define _(a,v) \
2763     else if (unformat (input, #a)) { flow_hash_config |= v; matched=1;}
2764       foreach_flow_hash_bit
2765 #undef _
2766         else
2767         break;
2768     }
2769
2770   if (matched == 0)
2771     return clib_error_return (0, "unknown input `%U'",
2772                               format_unformat_error, input);
2773
2774   rv = vnet_set_ip6_flow_hash (table_id, flow_hash_config);
2775   switch (rv)
2776     {
2777     case 0:
2778       break;
2779
2780     case -1:
2781       return clib_error_return (0, "no such FIB table %d", table_id);
2782
2783     default:
2784       clib_warning ("BUG: illegal flow hash config 0x%x", flow_hash_config);
2785       break;
2786     }
2787
2788   return 0;
2789 }
2790
2791 /*?
2792  * Configure the set of IPv6 fields used by the flow hash.
2793  *
2794  * @cliexpar
2795  * @parblock
2796  * Example of how to set the flow hash on a given table:
2797  * @cliexcmd{set ip6 flow-hash table 8 dst sport dport proto}
2798  *
2799  * Example of display the configured flow hash:
2800  * @cliexstart{show ip6 fib}
2801  * ipv6-VRF:0, fib_index 0, flow hash: src dst sport dport proto
2802  * @::/0
2803  *   unicast-ip6-chain
2804  *   [@0]: dpo-load-balance: [index:5 buckets:1 uRPF:5 to:[0:0]]
2805  *     [0] [@0]: dpo-drop ip6
2806  * fe80::/10
2807  *   unicast-ip6-chain
2808  *   [@0]: dpo-load-balance: [index:10 buckets:1 uRPF:10 to:[0:0]]
2809  *     [0] [@2]: dpo-receive
2810  * ff02::1/128
2811  *   unicast-ip6-chain
2812  *   [@0]: dpo-load-balance: [index:8 buckets:1 uRPF:8 to:[0:0]]
2813  *     [0] [@2]: dpo-receive
2814  * ff02::2/128
2815  *   unicast-ip6-chain
2816  *   [@0]: dpo-load-balance: [index:7 buckets:1 uRPF:7 to:[0:0]]
2817  *     [0] [@2]: dpo-receive
2818  * ff02::16/128
2819  *   unicast-ip6-chain
2820  *   [@0]: dpo-load-balance: [index:9 buckets:1 uRPF:9 to:[0:0]]
2821  *     [0] [@2]: dpo-receive
2822  * ff02::1:ff00:0/104
2823  *   unicast-ip6-chain
2824  *   [@0]: dpo-load-balance: [index:6 buckets:1 uRPF:6 to:[0:0]]
2825  *     [0] [@2]: dpo-receive
2826  * ipv6-VRF:8, fib_index 1, flow hash: dst sport dport proto
2827  * @::/0
2828  *   unicast-ip6-chain
2829  *   [@0]: dpo-load-balance: [index:21 buckets:1 uRPF:20 to:[0:0]]
2830  *     [0] [@0]: dpo-drop ip6
2831  * @::a:1:1:0:4/126
2832  *   unicast-ip6-chain
2833  *   [@0]: dpo-load-balance: [index:27 buckets:1 uRPF:26 to:[0:0]]
2834  *     [0] [@4]: ipv6-glean: af_packet0
2835  * @::a:1:1:0:7/128
2836  *   unicast-ip6-chain
2837  *   [@0]: dpo-load-balance: [index:28 buckets:1 uRPF:27 to:[0:0]]
2838  *     [0] [@2]: dpo-receive: @::a:1:1:0:7 on af_packet0
2839  * fe80::/10
2840  *   unicast-ip6-chain
2841  *   [@0]: dpo-load-balance: [index:26 buckets:1 uRPF:25 to:[0:0]]
2842  *     [0] [@2]: dpo-receive
2843  * fe80::fe:3eff:fe3e:9222/128
2844  *   unicast-ip6-chain
2845  *   [@0]: dpo-load-balance: [index:29 buckets:1 uRPF:28 to:[0:0]]
2846  *     [0] [@2]: dpo-receive: fe80::fe:3eff:fe3e:9222 on af_packet0
2847  * ff02::1/128
2848  *   unicast-ip6-chain
2849  *   [@0]: dpo-load-balance: [index:24 buckets:1 uRPF:23 to:[0:0]]
2850  *     [0] [@2]: dpo-receive
2851  * ff02::2/128
2852  *   unicast-ip6-chain
2853  *   [@0]: dpo-load-balance: [index:23 buckets:1 uRPF:22 to:[0:0]]
2854  *     [0] [@2]: dpo-receive
2855  * ff02::16/128
2856  *   unicast-ip6-chain
2857  *   [@0]: dpo-load-balance: [index:25 buckets:1 uRPF:24 to:[0:0]]
2858  *     [0] [@2]: dpo-receive
2859  * ff02::1:ff00:0/104
2860  *   unicast-ip6-chain
2861  *   [@0]: dpo-load-balance: [index:22 buckets:1 uRPF:21 to:[0:0]]
2862  *     [0] [@2]: dpo-receive
2863  * @cliexend
2864  * @endparblock
2865 ?*/
2866 /* *INDENT-OFF* */
2867 VLIB_CLI_COMMAND (set_ip6_flow_hash_command, static) =
2868 {
2869   .path = "set ip6 flow-hash",
2870   .short_help =
2871   "set ip6 flow-hash table <table-id> [src] [dst] [sport] [dport] [proto] [reverse]",
2872   .function = set_ip6_flow_hash_command_fn,
2873 };
2874 /* *INDENT-ON* */
2875
2876 static clib_error_t *
2877 show_ip6_local_command_fn (vlib_main_t * vm,
2878                            unformat_input_t * input, vlib_cli_command_t * cmd)
2879 {
2880   ip6_main_t *im = &ip6_main;
2881   ip_lookup_main_t *lm = &im->lookup_main;
2882   int i;
2883
2884   vlib_cli_output (vm, "Protocols handled by ip6_local");
2885   for (i = 0; i < ARRAY_LEN (lm->local_next_by_ip_protocol); i++)
2886     {
2887       if (lm->local_next_by_ip_protocol[i] != IP_LOCAL_NEXT_PUNT)
2888         {
2889
2890           u32 node_index = vlib_get_node (vm,
2891                                           ip6_local_node.index)->
2892             next_nodes[lm->local_next_by_ip_protocol[i]];
2893           vlib_cli_output (vm, "%d: %U", i, format_vlib_node_name, vm,
2894                            node_index);
2895         }
2896     }
2897   return 0;
2898 }
2899
2900
2901
2902 /*?
2903  * Display the set of protocols handled by the local IPv6 stack.
2904  *
2905  * @cliexpar
2906  * Example of how to display local protocol table:
2907  * @cliexstart{show ip6 local}
2908  * Protocols handled by ip6_local
2909  * 17
2910  * 43
2911  * 58
2912  * 115
2913  * @cliexend
2914 ?*/
2915 /* *INDENT-OFF* */
2916 VLIB_CLI_COMMAND (show_ip6_local, static) =
2917 {
2918   .path = "show ip6 local",
2919   .function = show_ip6_local_command_fn,
2920   .short_help = "show ip6 local",
2921 };
2922 /* *INDENT-ON* */
2923
2924 int
2925 vnet_set_ip6_classify_intfc (vlib_main_t * vm, u32 sw_if_index,
2926                              u32 table_index)
2927 {
2928   vnet_main_t *vnm = vnet_get_main ();
2929   vnet_interface_main_t *im = &vnm->interface_main;
2930   ip6_main_t *ipm = &ip6_main;
2931   ip_lookup_main_t *lm = &ipm->lookup_main;
2932   vnet_classify_main_t *cm = &vnet_classify_main;
2933   ip6_address_t *if_addr;
2934
2935   if (pool_is_free_index (im->sw_interfaces, sw_if_index))
2936     return VNET_API_ERROR_NO_MATCHING_INTERFACE;
2937
2938   if (table_index != ~0 && pool_is_free_index (cm->tables, table_index))
2939     return VNET_API_ERROR_NO_SUCH_ENTRY;
2940
2941   vec_validate (lm->classify_table_index_by_sw_if_index, sw_if_index);
2942   lm->classify_table_index_by_sw_if_index[sw_if_index] = table_index;
2943
2944   if_addr = ip6_interface_first_address (ipm, sw_if_index);
2945
2946   if (NULL != if_addr)
2947     {
2948       fib_prefix_t pfx = {
2949         .fp_len = 128,
2950         .fp_proto = FIB_PROTOCOL_IP6,
2951         .fp_addr.ip6 = *if_addr,
2952       };
2953       u32 fib_index;
2954
2955       fib_index = fib_table_get_index_for_sw_if_index (FIB_PROTOCOL_IP4,
2956                                                        sw_if_index);
2957
2958
2959       if (table_index != (u32) ~ 0)
2960         {
2961           dpo_id_t dpo = DPO_INVALID;
2962
2963           dpo_set (&dpo,
2964                    DPO_CLASSIFY,
2965                    DPO_PROTO_IP6,
2966                    classify_dpo_create (DPO_PROTO_IP6, table_index));
2967
2968           fib_table_entry_special_dpo_add (fib_index,
2969                                            &pfx,
2970                                            FIB_SOURCE_CLASSIFY,
2971                                            FIB_ENTRY_FLAG_NONE, &dpo);
2972           dpo_reset (&dpo);
2973         }
2974       else
2975         {
2976           fib_table_entry_special_remove (fib_index,
2977                                           &pfx, FIB_SOURCE_CLASSIFY);
2978         }
2979     }
2980
2981   return 0;
2982 }
2983
2984 static clib_error_t *
2985 set_ip6_classify_command_fn (vlib_main_t * vm,
2986                              unformat_input_t * input,
2987                              vlib_cli_command_t * cmd)
2988 {
2989   u32 table_index = ~0;
2990   int table_index_set = 0;
2991   u32 sw_if_index = ~0;
2992   int rv;
2993
2994   while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
2995     {
2996       if (unformat (input, "table-index %d", &table_index))
2997         table_index_set = 1;
2998       else if (unformat (input, "intfc %U", unformat_vnet_sw_interface,
2999                          vnet_get_main (), &sw_if_index))
3000         ;
3001       else
3002         break;
3003     }
3004
3005   if (table_index_set == 0)
3006     return clib_error_return (0, "classify table-index must be specified");
3007
3008   if (sw_if_index == ~0)
3009     return clib_error_return (0, "interface / subif must be specified");
3010
3011   rv = vnet_set_ip6_classify_intfc (vm, sw_if_index, table_index);
3012
3013   switch (rv)
3014     {
3015     case 0:
3016       break;
3017
3018     case VNET_API_ERROR_NO_MATCHING_INTERFACE:
3019       return clib_error_return (0, "No such interface");
3020
3021     case VNET_API_ERROR_NO_SUCH_ENTRY:
3022       return clib_error_return (0, "No such classifier table");
3023     }
3024   return 0;
3025 }
3026
3027 /*?
3028  * Assign a classification table to an interface. The classification
3029  * table is created using the '<em>classify table</em>' and '<em>classify session</em>'
3030  * commands. Once the table is create, use this command to filter packets
3031  * on an interface.
3032  *
3033  * @cliexpar
3034  * Example of how to assign a classification table to an interface:
3035  * @cliexcmd{set ip6 classify intfc GigabitEthernet2/0/0 table-index 1}
3036 ?*/
3037 /* *INDENT-OFF* */
3038 VLIB_CLI_COMMAND (set_ip6_classify_command, static) =
3039 {
3040   .path = "set ip6 classify",
3041   .short_help =
3042   "set ip6 classify intfc <interface> table-index <classify-idx>",
3043   .function = set_ip6_classify_command_fn,
3044 };
3045 /* *INDENT-ON* */
3046
3047 static clib_error_t *
3048 ip6_config (vlib_main_t * vm, unformat_input_t * input)
3049 {
3050   ip6_main_t *im = &ip6_main;
3051   uword heapsize = 0;
3052   u32 tmp;
3053   u32 nbuckets = 0;
3054
3055   while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
3056     {
3057       if (unformat (input, "hash-buckets %d", &tmp))
3058         nbuckets = tmp;
3059       else if (unformat (input, "heap-size %U",
3060                          unformat_memory_size, &heapsize))
3061         ;
3062       else
3063         return clib_error_return (0, "unknown input '%U'",
3064                                   format_unformat_error, input);
3065     }
3066
3067   im->lookup_table_nbuckets = nbuckets;
3068   im->lookup_table_size = heapsize;
3069
3070   return 0;
3071 }
3072
3073 VLIB_EARLY_CONFIG_FUNCTION (ip6_config, "ip6");
3074
3075 /*
3076  * fd.io coding-style-patch-verification: ON
3077  *
3078  * Local Variables:
3079  * eval: (c-set-style "gnu")
3080  * End:
3081  */