src/vnet/geneve/geneve_test.c

   1 /*
   2  *------------------------------------------------------------------
   3  * geneve_test.c
   4  *
   5  * Copyright (c) 2020 Cisco and/or its affiliates.
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at:
   9  *
  10  *     http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *------------------------------------------------------------------
  18  */
  19
  20 #include <vat/vat.h>
  21 #include <vlibapi/api.h>
  22 #include <vlibmemory/api.h>
  23 #include <vnet/format_fns.h>
  24 #include <vnet/ip/ip.h>
  25 #include <vpp/api/types.h>
  26 #include <vnet/geneve/geneve.h>
  27
  28 typedef struct
  29 {
  30   /* API message ID base */
  31   u16 msg_id_base;
  32   u32 ping_id;
  33   vat_main_t *vat_main;
  34 } geneve_test_main_t;
  35
  36 geneve_test_main_t geneve_test_main;
  37
  38 /* Declare message IDs */
  39 #include <vnet/geneve/geneve.api_enum.h>
  40 #include <vnet/geneve/geneve.api_types.h>
  41 #include <vpp/api/vpe.api_types.h>
  42
  43 #define __plugin_msg_base geneve_test_main.msg_id_base
  44 #include <vlibapi/vat_helper_macros.h>
  45 uword unformat_sw_if_index (unformat_input_t * input, va_list * args);
  46
  47 static void vl_api_geneve_add_del_tunnel2_reply_t_handler
  48   (vl_api_geneve_add_del_tunnel2_reply_t * mp)
  49 {
  50 }
  51 static void vl_api_geneve_add_del_tunnel_reply_t_handler
  52   (vl_api_geneve_add_del_tunnel_reply_t * mp)
  53 {
  54   vat_main_t *vam = &vat_main;
  55   i32 retval = ntohl (mp->retval);
  56   if (vam->async_mode)
  57     {
  58       vam->async_errors += (retval < 0);
  59     }
  60   else
  61     {
  62       vam->retval = retval;
  63       vam->sw_if_index = ntohl (mp->sw_if_index);
  64       vam->result_ready = 1;
  65     }
  66 }
  67
  68 static int
  69 api_sw_interface_set_geneve_bypass (vat_main_t * vam)
  70 {
  71   unformat_input_t *i = vam->input;
  72   vl_api_sw_interface_set_geneve_bypass_t *mp;
  73   u32 sw_if_index = 0;
  74   u8 sw_if_index_set = 0;
  75   u8 is_enable = 1;
  76   u8 is_ipv6 = 0;
  77   int ret;
  78
  79   /* Parse args required to build the message */
  80   while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT)
  81     {
  82       if (unformat (i, "%U", unformat_sw_if_index, vam, &sw_if_index))
  83         sw_if_index_set = 1;
  84       else if (unformat (i, "sw_if_index %d", &sw_if_index))
  85         sw_if_index_set = 1;
  86       else if (unformat (i, "enable"))
  87         is_enable = 1;
  88       else if (unformat (i, "disable"))
  89         is_enable = 0;
  90       else if (unformat (i, "ip4"))
  91         is_ipv6 = 0;
  92       else if (unformat (i, "ip6"))
  93         is_ipv6 = 1;
  94       else
  95         break;
  96     }
  97
  98   if (sw_if_index_set == 0)
  99     {
 100       errmsg ("missing interface name or sw_if_index");
 101       return -99;
 102     }
 103
 104   /* Construct the API message */
 105   M (SW_INTERFACE_SET_GENEVE_BYPASS, mp);
 106
 107   mp->sw_if_index = ntohl (sw_if_index);
 108   mp->enable = is_enable;
 109   mp->is_ipv6 = is_ipv6;
 110
 111   /* send it... */
 112   S (mp);
 113
 114   /* Wait for a reply... */
 115   W (ret);
 116   return ret;
 117 }
 118 static uword unformat_geneve_decap_next
 119   (unformat_input_t * input, va_list * args)
 120 {
 121   u32 *result = va_arg (*args, u32 *);
 122   u32 tmp;
 123
 124   if (unformat (input, "l2"))
 125     *result = GENEVE_INPUT_NEXT_L2_INPUT;
 126   else if (unformat (input, "%d", &tmp))
 127     *result = tmp;
 128   else
 129     return 0;
 130   return 1;
 131 }
 132
 133 static int
 134 api_geneve_add_del_tunnel2 (vat_main_t * vam)
 135 {
 136   return 0; // NOT YET IMPLEMENTED
 137 }
 138
 139 static int
 140 api_geneve_add_del_tunnel (vat_main_t * vam)
 141 {
 142   unformat_input_t *line_input = vam->input;
 143   vl_api_geneve_add_del_tunnel_t *mp;
 144   ip46_address_t src, dst;
 145   u8 is_add = 1;
 146   u8 ipv4_set = 0, ipv6_set = 0;
 147   u8 src_set = 0;
 148   u8 dst_set = 0;
 149   u8 grp_set = 0;
 150   u32 mcast_sw_if_index = ~0;
 151   u32 encap_vrf_id = 0;
 152   u32 decap_next_index = ~0;
 153   u32 vni = 0;
 154   int ret;
 155
 156   /* Can't "universally zero init" (={0}) due to GCC bug 53119 */
 157   clib_memset (&src, 0, sizeof src);
 158   clib_memset (&dst, 0, sizeof dst);
 159
 160   while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
 161     {
 162       if (unformat (line_input, "del"))
 163         is_add = 0;
 164       else
 165         if (unformat (line_input, "src %U", unformat_ip4_address, &src.ip4))
 166         {
 167           ipv4_set = 1;
 168           src_set = 1;
 169         }
 170       else
 171         if (unformat (line_input, "dst %U", unformat_ip4_address, &dst.ip4))
 172         {
 173           ipv4_set = 1;
 174           dst_set = 1;
 175         }
 176       else
 177         if (unformat (line_input, "src %U", unformat_ip6_address, &src.ip6))
 178         {
 179           ipv6_set = 1;
 180           src_set = 1;
 181         }
 182       else
 183         if (unformat (line_input, "dst %U", unformat_ip6_address, &dst.ip6))
 184         {
 185           ipv6_set = 1;
 186           dst_set = 1;
 187         }
 188       else if (unformat (line_input, "group %U %U",
 189                          unformat_ip4_address, &dst.ip4,
 190                          unformat_sw_if_index, vam, &mcast_sw_if_index))
 191         {
 192           grp_set = dst_set = 1;
 193           ipv4_set = 1;
 194         }
 195       else if (unformat (line_input, "group %U",
 196                          unformat_ip4_address, &dst.ip4))
 197         {
 198           grp_set = dst_set = 1;
 199           ipv4_set = 1;
 200         }
 201       else if (unformat (line_input, "group %U %U",
 202                          unformat_ip6_address, &dst.ip6,
 203                          unformat_sw_if_index, vam, &mcast_sw_if_index))
 204         {
 205           grp_set = dst_set = 1;
 206           ipv6_set = 1;
 207         }
 208       else if (unformat (line_input, "group %U",
 209                          unformat_ip6_address, &dst.ip6))
 210         {
 211           grp_set = dst_set = 1;
 212           ipv6_set = 1;
 213         }
 214       else
 215         if (unformat (line_input, "mcast_sw_if_index %u", &mcast_sw_if_index))
 216         ;
 217       else if (unformat (line_input, "encap-vrf-id %d", &encap_vrf_id))
 218         ;
 219       else if (unformat (line_input, "decap-next %U",
 220                          unformat_geneve_decap_next, &decap_next_index))
 221         ;
 222       else if (unformat (line_input, "vni %d", &vni))
 223         ;
 224       else
 225         {
 226           errmsg ("parse error '%U'", format_unformat_error, line_input);
 227           return -99;
 228         }
 229     }
 230
 231   if (src_set == 0)
 232     {
 233       errmsg ("tunnel src address not specified");
 234       return -99;
 235     }
 236   if (dst_set == 0)
 237     {
 238       errmsg ("tunnel dst address not specified");
 239       return -99;
 240     }
 241
 242   if (grp_set && !ip46_address_is_multicast (&dst))
 243     {
 244       errmsg ("tunnel group address not multicast");
 245       return -99;
 246     }
 247   if (grp_set && mcast_sw_if_index == ~0)
 248     {
 249       errmsg ("tunnel nonexistent multicast device");
 250       return -99;
 251     }
 252   if (grp_set == 0 && ip46_address_is_multicast (&dst))
 253     {
 254       errmsg ("tunnel dst address must be unicast");
 255       return -99;
 256     }
 257
 258
 259   if (ipv4_set && ipv6_set)
 260     {
 261       errmsg ("both IPv4 and IPv6 addresses specified");
 262       return -99;
 263     }
 264
 265   if ((vni == 0) || (vni >> 24))
 266     {
 267       errmsg ("vni not specified or out of range");
 268       return -99;
 269     }
 270
 271   M (GENEVE_ADD_DEL_TUNNEL, mp);
 272
 273   if (ipv6_set)
 274     {
 275       clib_memcpy (&mp->local_address.un.ip6, &src.ip6, sizeof (src.ip6));
 276       clib_memcpy (&mp->remote_address.un.ip6, &dst.ip6, sizeof (dst.ip6));
 277     }
 278   else
 279     {
 280       clib_memcpy (&mp->local_address.un.ip4, &src.ip4, sizeof (src.ip4));
 281       clib_memcpy (&mp->remote_address.un.ip4, &dst.ip4, sizeof (dst.ip4));
 282     }
 283   mp->encap_vrf_id = ntohl (encap_vrf_id);
 284   mp->decap_next_index = ntohl (decap_next_index);
 285   mp->mcast_sw_if_index = ntohl (mcast_sw_if_index);
 286   mp->vni = ntohl (vni);
 287   mp->is_add = is_add;
 288
 289   S (mp);
 290   W (ret);
 291   return ret;
 292 }
 293
 294 static void vl_api_geneve_tunnel_details_t_handler
 295   (vl_api_geneve_tunnel_details_t * mp)
 296 {
 297   vat_main_t *vam = &vat_main;
 298   ip46_address_t src = {.as_u64[0] = 0,.as_u64[1] = 0 };
 299   ip46_address_t dst = {.as_u64[0] = 0,.as_u64[1] = 0 };
 300
 301   if (mp->src_address.af == ADDRESS_IP6)
 302     {
 303       clib_memcpy (&src.ip6, &mp->src_address.un.ip6, sizeof (ip6_address_t));
 304       clib_memcpy (&dst.ip6, &mp->dst_address.un.ip6, sizeof (ip6_address_t));
 305     }
 306   else
 307     {
 308       clib_memcpy (&src.ip4, &mp->src_address.un.ip4, sizeof (ip4_address_t));
 309       clib_memcpy (&dst.ip4, &mp->dst_address.un.ip4, sizeof (ip4_address_t));
 310     }
 311
 312   print (vam->ofp, "%11d%24U%24U%14d%18d%13d%19d",
 313          ntohl (mp->sw_if_index),
 314          format_ip46_address, &src, IP46_TYPE_ANY,
 315          format_ip46_address, &dst, IP46_TYPE_ANY,
 316          ntohl (mp->encap_vrf_id),
 317          ntohl (mp->decap_next_index), ntohl (mp->vni),
 318          ntohl (mp->mcast_sw_if_index));
 319 }
 320
 321 static int
 322 api_geneve_tunnel_dump (vat_main_t * vam)
 323 {
 324   unformat_input_t *i = vam->input;
 325   vl_api_geneve_tunnel_dump_t *mp;
 326   vl_api_control_ping_t *mp_ping;
 327   u32 sw_if_index;
 328   u8 sw_if_index_set = 0;
 329   int ret;
 330   geneve_test_main_t *gm = &geneve_test_main;
 331
 332   /* Parse args required to build the message */
 333   while (unformat_check_input (i) != UNFORMAT_END_OF_INPUT)
 334     {
 335       if (unformat (i, "sw_if_index %d", &sw_if_index))
 336         sw_if_index_set = 1;
 337       else
 338         break;
 339     }
 340
 341   if (sw_if_index_set == 0)
 342     {
 343       sw_if_index = ~0;
 344     }
 345
 346   if (!vam->json_output)
 347     {
 348       print (vam->ofp, "%11s%24s%24s%14s%18s%13s%19s",
 349              "sw_if_index", "local_address", "remote_address",
 350              "encap_vrf_id", "decap_next_index", "vni", "mcast_sw_if_index");
 351     }
 352
 353   /* Get list of geneve-tunnel interfaces */
 354   M (GENEVE_TUNNEL_DUMP, mp);
 355
 356   mp->sw_if_index = htonl (sw_if_index);
 357
 358   S (mp);
 359
 360   /* Use a control ping for synchronization */
 361   if (!gm->ping_id)
 362     gm->ping_id = vl_msg_api_get_msg_index ((u8 *) (VL_API_CONTROL_PING_CRC));
 363   mp_ping = vl_msg_api_alloc_as_if_client (sizeof (*mp_ping));
 364   mp_ping->_vl_msg_id = htons (gm->ping_id);
 365   mp_ping->client_index = vam->my_client_index;
 366   S (mp_ping);
 367
 368   W (ret);
 369   return ret;
 370 }
 371
 372 #include <vnet/geneve/geneve.api_test.c>
 373 VAT_REGISTER_FEATURE_FUNCTION(vat_geneve_plugin_register);
 374