ip: Fragmentation fixes
[vpp.git] / src / vnet / ip / lookup.c
index 2a9b3fe..c1fbc42 100644 (file)
@@ -13,7 +13,7 @@
  * limitations under the License.
  */
 /*
- * ip/ip_lookup.c: ip4/6 adjacency and lookup table managment
+ * ip/ip_lookup.c: ip4/6 adjacency and lookup table management
  *
  * Copyright (c) 2008 Eliot Dresselhaus
  *
 #include <vnet/dpo/ip_null_dpo.h>
 #include <vnet/dpo/l3_proxy_dpo.h>
 #include <vnet/ip/ip6_neighbor.h>
+#include <vnet/ethernet/arp.h>
 
 /**
  * @file
- * @brief IPv4 and IPv6 adjacency and lookup table managment.
+ * @brief IPv4 and IPv6 adjacency and lookup table management.
  *
  */
 
@@ -206,6 +207,8 @@ ip_lookup_init (ip_lookup_main_t * lm, u32 is_ip6)
     lm->fib_result_n_bytes = sizeof (uword);
 
   lm->is_ip6 = is_ip6;
+  mhash_init (&lm->prefix_to_if_prefix_index, sizeof (uword),
+             sizeof (ip_interface_prefix_key_t));
   if (is_ip6)
     {
       lm->format_address_and_length = format_ip6_address_and_length;
@@ -255,22 +258,10 @@ format_ip_flow_hash_config (u8 * s, va_list * args)
 u8 *
 format_ip_adjacency_packet_data (u8 * s, va_list * args)
 {
-  u32 adj_index = va_arg (*args, u32);
   u8 *packet_data = va_arg (*args, u8 *);
   u32 n_packet_data_bytes = va_arg (*args, u32);
-  ip_adjacency_t *adj = adj_get (adj_index);
 
-  switch (adj->lookup_next_index)
-    {
-    case IP_LOOKUP_NEXT_REWRITE:
-    case IP_LOOKUP_NEXT_MCAST:
-      s =
-       format (s, "%U", format_hex_bytes, packet_data, n_packet_data_bytes);
-      break;
-
-    default:
-      break;
-    }
+  s = format (s, "%U", format_hex_bytes, packet_data, n_packet_data_bytes);
 
   return s;
 }
@@ -440,7 +431,7 @@ vnet_ip_route_cmd (vlib_main_t * vm,
        }
       else if (0 < vec_len (rpaths))
        {
-         u32 k, j, n, incr;
+         u32 k, n, incr;
          ip46_address_t dst = prefixs[i].fp_addr;
          f64 t[2];
          n = count;
@@ -450,25 +441,20 @@ vnet_ip_route_cmd (vlib_main_t * vm,
 
          for (k = 0; k < n; k++)
            {
-             for (j = 0; j < vec_len (rpaths); j++)
-               {
-                 fib_prefix_t rpfx = {
-                   .fp_len = prefixs[i].fp_len,
-                   .fp_proto = prefixs[i].fp_proto,
-                   .fp_addr = dst,
-                 };
-
-                 if (is_del)
-                   fib_table_entry_path_remove2 (fib_index,
-                                                 &rpfx,
-                                                 FIB_SOURCE_CLI, &rpaths[j]);
-                 else
-                   fib_table_entry_path_add2 (fib_index,
-                                              &rpfx,
-                                              FIB_SOURCE_CLI,
-                                              FIB_ENTRY_FLAG_NONE,
-                                              &rpaths[j]);
-               }
+             fib_prefix_t rpfx = {
+               .fp_len = prefixs[i].fp_len,
+               .fp_proto = prefixs[i].fp_proto,
+               .fp_addr = dst,
+             };
+
+             if (is_del)
+               fib_table_entry_path_remove2 (fib_index,
+                                             &rpfx, FIB_SOURCE_CLI, rpaths);
+             else
+               fib_table_entry_path_add2 (fib_index,
+                                          &rpfx,
+                                          FIB_SOURCE_CLI,
+                                          FIB_ENTRY_FLAG_NONE, rpaths);
 
              if (FIB_PROTOCOL_IP4 == prefixs[0].fp_proto)
                {
@@ -484,9 +470,9 @@ vnet_ip_route_cmd (vlib_main_t * vm,
                    clib_host_to_net_u64 (incr +
                                          clib_net_to_host_u64 (dst.ip6.as_u64
                                                                [bucket]));
-
                }
            }
+
          t[1] = vlib_time_now (vm);
          if (count > 1)
            vlib_cli_output (vm, "%.6e routes/sec", count / (t[1] - t[0]));
@@ -498,7 +484,6 @@ vnet_ip_route_cmd (vlib_main_t * vm,
        }
     }
 
-
 done:
   vec_free (dpos);
   vec_free (prefixs);
@@ -804,20 +789,17 @@ vnet_ip_mroute_cmd (vlib_main_t * vm,
                    unformat_input_t * main_input, vlib_cli_command_t * cmd)
 {
   unformat_input_t _line_input, *line_input = &_line_input;
+  fib_route_path_t rpath, *rpaths = NULL;
   clib_error_t *error = NULL;
-  fib_route_path_t rpath;
-  u32 table_id, is_del;
-  vnet_main_t *vnm;
+  u32 table_id, is_del, payload_proto;
   mfib_prefix_t pfx;
   u32 fib_index;
-  mfib_itf_flags_t iflags = 0;
   mfib_entry_flags_t eflags = 0;
   u32 gcount, scount, ss, gg, incr;
   f64 timet[2];
   u32 rpf_id = MFIB_RPF_ID_NONE;
 
   gcount = scount = 1;
-  vnm = vnet_get_main ();
   is_del = 0;
   table_id = 0;
   clib_memset (&pfx, 0, sizeof (pfx));
@@ -886,51 +868,6 @@ vnet_ip_mroute_cmd (vlib_main_t * vm,
          pfx.fp_proto = FIB_PROTOCOL_IP6;
          pfx.fp_len = 128;
        }
-      else if (unformat (line_input, "via %U %U %U",
-                        unformat_ip4_address, &rpath.frp_addr.ip4,
-                        unformat_vnet_sw_interface, vnm,
-                        &rpath.frp_sw_if_index,
-                        unformat_mfib_itf_flags, &iflags))
-       {
-         rpath.frp_weight = 1;
-       }
-      else if (unformat (line_input, "via %U %U %U",
-                        unformat_ip6_address, &rpath.frp_addr.ip6,
-                        unformat_vnet_sw_interface, vnm,
-                        &rpath.frp_sw_if_index,
-                        unformat_mfib_itf_flags, &iflags))
-       {
-         rpath.frp_weight = 1;
-       }
-      else if (unformat (line_input, "via %U %U",
-                        unformat_vnet_sw_interface, vnm,
-                        &rpath.frp_sw_if_index,
-                        unformat_mfib_itf_flags, &iflags))
-       {
-         clib_memset (&rpath.frp_addr, 0, sizeof (rpath.frp_addr));
-         rpath.frp_weight = 1;
-       }
-      else if (unformat (line_input, "via %U %U",
-                        unformat_ip4_address, &rpath.frp_addr.ip4,
-                        unformat_vnet_sw_interface, vnm,
-                        &rpath.frp_sw_if_index))
-       {
-         rpath.frp_weight = 1;
-       }
-      else if (unformat (line_input, "via %U %U",
-                        unformat_ip6_address, &rpath.frp_addr.ip6,
-                        unformat_vnet_sw_interface, vnm,
-                        &rpath.frp_sw_if_index))
-       {
-         rpath.frp_weight = 1;
-       }
-      else if (unformat (line_input, "via %U",
-                        unformat_vnet_sw_interface, vnm,
-                        &rpath.frp_sw_if_index))
-       {
-         clib_memset (&rpath.frp_addr, 0, sizeof (rpath.frp_addr));
-         rpath.frp_weight = 1;
-       }
       else if (unformat (line_input, "via local Forward"))
        {
          clib_memset (&rpath.frp_addr, 0, sizeof (rpath.frp_addr));
@@ -941,7 +878,14 @@ vnet_ip_mroute_cmd (vlib_main_t * vm,
           * set the path proto appropriately for the prefix
           */
          rpath.frp_proto = fib_proto_to_dpo (pfx.fp_proto);
-         iflags = MFIB_ITF_FLAG_FORWARD;
+         rpath.frp_mitf_flags = MFIB_ITF_FLAG_FORWARD;
+
+         vec_add1 (rpaths, rpath);
+       }
+      else if (unformat (line_input, "via %U",
+                        unformat_fib_route_path, &rpath, &payload_proto))
+       {
+         vec_add1 (rpaths, rpath);
        }
       else if (unformat (line_input, "%U",
                         unformat_mfib_entry_flags, &eflags))
@@ -986,7 +930,7 @@ vnet_ip_mroute_cmd (vlib_main_t * vm,
     {
       for (gg = 0; gg < gcount; gg++)
        {
-         if (is_del && 0 == rpath.frp_weight)
+         if (is_del && 0 == vec_len (rpaths))
            {
              /* no path provided => route delete */
              mfib_table_entry_delete (fib_index, &pfx, MFIB_SOURCE_CLI);
@@ -1000,11 +944,10 @@ vnet_ip_mroute_cmd (vlib_main_t * vm,
            {
              if (is_del)
                mfib_table_entry_path_remove (fib_index,
-                                             &pfx, MFIB_SOURCE_CLI, &rpath);
+                                             &pfx, MFIB_SOURCE_CLI, rpaths);
              else
                mfib_table_entry_path_update (fib_index,
-                                             &pfx, MFIB_SOURCE_CLI, &rpath,
-                                             iflags);
+                                             &pfx, MFIB_SOURCE_CLI, rpaths);
            }
 
          if (FIB_PROTOCOL_IP4 == pfx.fp_proto)
@@ -1049,13 +992,14 @@ vnet_ip_mroute_cmd (vlib_main_t * vm,
                     (scount * gcount) / (timet[1] - timet[0]));
 
 done:
+  vec_free (rpaths);
   unformat_free (line_input);
 
   return error;
 }
 
 /*?
- * This command is used to add or delete IPv4 or IPv6  multicastroutes. All
+ * This command is used to add or delete IPv4 or IPv6  multicast routes. All
  * IP Addresses ('<em><dst-ip-addr>/<width></em>',
  * '<em><next-hop-ip-addr></em>' and '<em><adj-hop-ip-addr></em>')
  * can be IPv4 or IPv6, but all must be of the same form in a single