src/vnet/lisp-gpe/lisp_gpe.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  * @file
  17  * @brief Common utility functions for IPv4, IPv6 and L2 LISP-GPE tunnels.
  18  *
  19  */
  20
  21 #include <vnet/lisp-gpe/lisp_gpe.h>
  22 #include <vnet/lisp-gpe/lisp_gpe_fwd_entry.h>
  23 #include <vnet/lisp-gpe/lisp_gpe_adjacency.h>
  24 #include <vnet/lisp-gpe/lisp_gpe_tenant.h>
  25
  26 /** LISP-GPE global state */
  27 lisp_gpe_main_t lisp_gpe_main;
  28
  29
  30 /** CLI command to add/del forwarding entry. */
  31 static clib_error_t *
  32 lisp_gpe_add_del_fwd_entry_command_fn (vlib_main_t * vm,
  33                                        unformat_input_t * input,
  34                                        vlib_cli_command_t * cmd)
  35 {
  36   unformat_input_t _line_input, *line_input = &_line_input;
  37   u8 is_add = 1;
  38   ip_address_t lloc, rloc;
  39   clib_error_t *error = 0;
  40   gid_address_t _reid, *reid = &_reid, _leid, *leid = &_leid;
  41   u8 reid_set = 0, leid_set = 0, is_negative = 0, dp_table_set = 0,
  42     vni_set = 0;
  43   u32 vni = 0, dp_table = 0, action = ~0, w;
  44   locator_pair_t pair, *pairs = 0;
  45   int rv;
  46
  47   memset (leid, 0, sizeof (*leid));
  48   memset (reid, 0, sizeof (*reid));
  49
  50   /* Get a line of input. */
  51   if (!unformat_user (input, unformat_line_input, line_input))
  52     return 0;
  53
  54   while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
  55     {
  56       if (unformat (line_input, "del"))
  57         is_add = 0;
  58       else if (unformat (line_input, "add"))
  59         is_add = 1;
  60       else if (unformat (line_input, "leid %U", unformat_gid_address, leid))
  61         {
  62           leid_set = 1;
  63         }
  64       else if (unformat (line_input, "reid %U", unformat_gid_address, reid))
  65         {
  66           reid_set = 1;
  67         }
  68       else if (unformat (line_input, "vni %u", &vni))
  69         {
  70           gid_address_vni (leid) = vni;
  71           gid_address_vni (reid) = vni;
  72           vni_set = 1;
  73         }
  74       else if (unformat (line_input, "vrf %u", &dp_table))
  75         {
  76           dp_table_set = 1;
  77         }
  78       else if (unformat (line_input, "bd %u", &dp_table))
  79         {
  80           dp_table_set = 1;
  81         }
  82       else if (unformat (line_input, "negative action %U",
  83                          unformat_negative_mapping_action, &action))
  84         {
  85           is_negative = 1;
  86         }
  87       else if (unformat (line_input, "loc-pair %U %U w %d",
  88                          unformat_ip_address, &lloc,
  89                          unformat_ip_address, &rloc, &w))
  90         {
  91           pair.lcl_loc = lloc;
  92           pair.rmt_loc = rloc;
  93           pair.weight = w;
  94           pair.priority = 0;
  95           vec_add1 (pairs, pair);
  96         }
  97       else
  98         {
  99           error = unformat_parse_error (line_input);
 100           vlib_cli_output (vm, "parse error: '%U'",
 101                            format_unformat_error, line_input);
 102           goto done;
 103         }
 104     }
 105
 106   if (!reid_set)
 107     {
 108       vlib_cli_output (vm, "remote eid must be set!");
 109       goto done;
 110     }
 111
 112   if (gid_address_type (reid) != GID_ADDR_NSH && (!vni_set || !dp_table_set))
 113     {
 114       vlib_cli_output (vm, "vni and vrf/bd must be set!");
 115       goto done;
 116     }
 117
 118   if (is_negative)
 119     {
 120       if (~0 == action)
 121         {
 122           vlib_cli_output (vm, "no action set for negative tunnel!");
 123           goto done;
 124         }
 125     }
 126   else
 127     {
 128       if (vec_len (pairs) == 0)
 129         {
 130           vlib_cli_output (vm, "expected ip4/ip6 locators");
 131           goto done;
 132         }
 133     }
 134
 135   if (!leid_set)
 136     {
 137       /* if leid not set, make sure it's the same AFI like reid */
 138       gid_address_type (leid) = gid_address_type (reid);
 139       if (GID_ADDR_IP_PREFIX == gid_address_type (reid))
 140         gid_address_ip_version (leid) = gid_address_ip_version (reid);
 141     }
 142
 143   /* add fwd entry */
 144   vnet_lisp_gpe_add_del_fwd_entry_args_t _a, *a = &_a;
 145   memset (a, 0, sizeof (a[0]));
 146
 147   a->is_add = is_add;
 148   a->is_negative = is_negative;
 149   a->vni = vni;
 150   a->table_id = dp_table;
 151   gid_address_copy (&a->lcl_eid, leid);
 152   gid_address_copy (&a->rmt_eid, reid);
 153   a->locator_pairs = pairs;
 154   a->action = action;
 155
 156   rv = vnet_lisp_gpe_add_del_fwd_entry (a, 0);
 157   if (0 != rv)
 158     {
 159       vlib_cli_output (vm, "failed to %s gpe tunnel!",
 160                        is_add ? "add" : "delete");
 161     }
 162
 163 done:
 164   unformat_free (line_input);
 165   vec_free (pairs);
 166   return error;
 167 }
 168
 169 /* *INDENT-OFF* */
 170 VLIB_CLI_COMMAND (lisp_gpe_add_del_fwd_entry_command, static) = {
 171   .path = "gpe entry",
 172   .short_help = "gpe entry add/del vni <vni> vrf/bd <id> [leid <leid>]"
 173       "reid <reid> [loc-pair <lloc> <rloc> w <weight>] "
 174       "[negative action <action>]",
 175   .function = lisp_gpe_add_del_fwd_entry_command_fn,
 176 };
 177 /* *INDENT-ON* */
 178
 179 /** Check if LISP-GPE is enabled. */
 180 u8
 181 vnet_lisp_gpe_enable_disable_status (void)
 182 {
 183   lisp_gpe_main_t *lgm = &lisp_gpe_main;
 184
 185   return lgm->is_en;
 186 }
 187
 188 /** Enable/disable LISP-GPE. */
 189 clib_error_t *
 190 vnet_lisp_gpe_enable_disable (vnet_lisp_gpe_enable_disable_args_t * a)
 191 {
 192   lisp_gpe_main_t *lgm = &lisp_gpe_main;
 193
 194   if (a->is_en)
 195     {
 196       lgm->is_en = 1;
 197     }
 198   else
 199     {
 200       /* remove all entries */
 201       vnet_lisp_gpe_fwd_entry_flush ();
 202
 203       /* disable all l3 ifaces */
 204       lisp_gpe_tenant_flush ();
 205
 206       lgm->is_en = 0;
 207     }
 208
 209   return 0;
 210 }
 211
 212 /** Set GPE encapsulation mode. */
 213 int
 214 vnet_gpe_set_encap_mode (gpe_encap_mode_t mode)
 215 {
 216   lisp_gpe_main_t *lgm = &lisp_gpe_main;
 217
 218   if (mode >= GPE_ENCAP_COUNT)
 219     return VNET_API_ERROR_INVALID_GPE_MODE;
 220
 221   if (pool_elts (lgm->lisp_fwd_entry_pool) != 0)
 222     return VNET_API_ERROR_LISP_GPE_ENTRIES_PRESENT;
 223
 224   lgm->encap_mode = mode;
 225   return 0;
 226 }
 227
 228 /** CLI command to set GPE encap */
 229 static clib_error_t *
 230 gpe_set_encap_mode_command_fn (vlib_main_t * vm,
 231                                unformat_input_t * input,
 232                                vlib_cli_command_t * cmd)
 233 {
 234   unformat_input_t _line_input, *line_input = &_line_input;
 235   gpe_encap_mode_t mode = GPE_ENCAP_COUNT;
 236   vnet_api_error_t rv;
 237
 238   /* Get a line of input. */
 239   if (!unformat_user (input, unformat_line_input, line_input))
 240     return 0;
 241
 242   while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
 243     {
 244       if (unformat (line_input, "lisp"))
 245         mode = GPE_ENCAP_LISP;
 246       else if (unformat (line_input, "vxlan"))
 247         mode = GPE_ENCAP_VXLAN;
 248       else
 249         {
 250           return clib_error_return (0, "parse error: '%U'",
 251                                     format_unformat_error, line_input);
 252         }
 253     }
 254   rv = vnet_gpe_set_encap_mode (mode);
 255   if (rv)
 256     {
 257       return clib_error_return (0,
 258                                 "Error: invalid mode or GPE entries are present!");
 259     }
 260
 261   return 0;
 262 }
 263
 264 /* *INDENT-OFF* */
 265 VLIB_CLI_COMMAND (gpe_set_encap_mode_command, static) = {
 266   .path = "gpe encap",
 267   .short_help = "gpe encap [lisp|vxlan]",
 268   .function = gpe_set_encap_mode_command_fn,
 269 };
 270 /* *INDENT-ON* */
 271
 272 /** Format GPE encap mode. */
 273 u8 *
 274 format_vnet_gpe_encap_mode (u8 * s, va_list * args)
 275 {
 276   lisp_gpe_main_t *lgm = &lisp_gpe_main;
 277
 278   switch (lgm->encap_mode)
 279     {
 280     case GPE_ENCAP_LISP:
 281       return format (s, "lisp");
 282     case GPE_ENCAP_VXLAN:
 283       return format (s, "vxlan");
 284     default:
 285       return 0;
 286     }
 287   return 0;
 288 }
 289
 290 /** CLI command to show GPE encap */
 291 static clib_error_t *
 292 gpe_show_encap_mode_command_fn (vlib_main_t * vm,
 293                                 unformat_input_t * input,
 294                                 vlib_cli_command_t * cmd)
 295 {
 296   vlib_cli_output (vm, "encap mode: %U", format_vnet_gpe_encap_mode);
 297   return 0;
 298 }
 299
 300 /* *INDENT-OFF* */
 301 VLIB_CLI_COMMAND (gpe_show_encap_mode_command, static) = {
 302   .path = "show gpe encap",
 303   .short_help = "show GPE encapulation mode",
 304   .function = gpe_show_encap_mode_command_fn,
 305 };
 306 /* *INDENT-ON* */
 307
 308 /** CLI command to enable/disable LISP-GPE. */
 309 static clib_error_t *
 310 lisp_gpe_enable_disable_command_fn (vlib_main_t * vm,
 311                                     unformat_input_t * input,
 312                                     vlib_cli_command_t * cmd)
 313 {
 314   unformat_input_t _line_input, *line_input = &_line_input;
 315   u8 is_en = 1;
 316   vnet_lisp_gpe_enable_disable_args_t _a, *a = &_a;
 317   clib_error_t *error = NULL;
 318
 319   /* Get a line of input. */
 320   if (!unformat_user (input, unformat_line_input, line_input))
 321     return 0;
 322
 323   while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
 324     {
 325       if (unformat (line_input, "enable"))
 326         is_en = 1;
 327       else if (unformat (line_input, "disable"))
 328         is_en = 0;
 329       else
 330         {
 331           error = clib_error_return (0, "parse error: '%U'",
 332                                      format_unformat_error, line_input);
 333           goto done;
 334         }
 335     }
 336   a->is_en = is_en;
 337   error = vnet_lisp_gpe_enable_disable (a);
 338
 339 done:
 340   unformat_free (line_input);
 341
 342   return error;
 343 }
 344
 345 /* *INDENT-OFF* */
 346 VLIB_CLI_COMMAND (enable_disable_lisp_gpe_command, static) = {
 347   .path = "gpe",
 348   .short_help = "gpe [enable|disable]",
 349   .function = lisp_gpe_enable_disable_command_fn,
 350 };
 351 /* *INDENT-ON* */
 352
 353 /** CLI command to show LISP-GPE interfaces. */
 354 static clib_error_t *
 355 lisp_show_iface_command_fn (vlib_main_t * vm,
 356                             unformat_input_t * input,
 357                             vlib_cli_command_t * cmd)
 358 {
 359   lisp_gpe_main_t *lgm = &lisp_gpe_main;
 360   hash_pair_t *p;
 361
 362   vlib_cli_output (vm, "%=10s%=12s", "vrf", "hw_if_index");
 363
 364   /* *INDENT-OFF* */
 365   hash_foreach_pair (p, lgm->l3_ifaces.hw_if_index_by_dp_table, ({
 366     vlib_cli_output (vm, "%=10d%=10d", p->key, p->value[0]);
 367   }));
 368   /* *INDENT-ON* */
 369
 370   if (0 != lgm->l2_ifaces.hw_if_index_by_dp_table)
 371     {
 372       vlib_cli_output (vm, "%=10s%=12s", "bd_id", "hw_if_index");
 373       /* *INDENT-OFF* */
 374       hash_foreach_pair (p, lgm->l2_ifaces.hw_if_index_by_dp_table, ({
 375         vlib_cli_output (vm, "%=10d%=10d", p->key, p->value[0]);
 376       }));
 377       /* *INDENT-ON* */
 378     }
 379   return 0;
 380 }
 381
 382 /* *INDENT-OFF* */
 383 VLIB_CLI_COMMAND (lisp_show_iface_command) = {
 384     .path = "show gpe interface",
 385     .short_help = "show gpe interface",
 386     .function = lisp_show_iface_command_fn,
 387 };
 388 /* *INDENT-ON* */
 389
 390 /** Format LISP-GPE status. */
 391 u8 *
 392 format_vnet_lisp_gpe_status (u8 * s, va_list * args)
 393 {
 394   lisp_gpe_main_t *lgm = &lisp_gpe_main;
 395   return format (s, "%s", lgm->is_en ? "enabled" : "disabled");
 396 }
 397
 398 /** LISP-GPE init function. */
 399 clib_error_t *
 400 lisp_gpe_init (vlib_main_t * vm)
 401 {
 402   lisp_gpe_main_t *lgm = &lisp_gpe_main;
 403   clib_error_t *error = 0;
 404
 405   if ((error = vlib_call_init_function (vm, ip_main_init)))
 406     return error;
 407
 408   if ((error = vlib_call_init_function (vm, ip4_lookup_init)))
 409     return error;
 410
 411   lgm->vnet_main = vnet_get_main ();
 412   lgm->vlib_main = vm;
 413   lgm->im4 = &ip4_main;
 414   lgm->im6 = &ip6_main;
 415   lgm->lm4 = &ip4_main.lookup_main;
 416   lgm->lm6 = &ip6_main.lookup_main;
 417   lgm->encap_mode = GPE_ENCAP_LISP;
 418
 419   lgm->lisp_gpe_fwd_entries =
 420     hash_create_mem (0, sizeof (lisp_gpe_fwd_entry_key_t), sizeof (uword));
 421
 422   udp_register_dst_port (vm, UDP_DST_PORT_lisp_gpe,
 423                          lisp_gpe_ip4_input_node.index, 1 /* is_ip4 */ );
 424   udp_register_dst_port (vm, UDP_DST_PORT_lisp_gpe6,
 425                          lisp_gpe_ip6_input_node.index, 0 /* is_ip4 */ );
 426
 427   lgm->lisp_stats_index_by_key =
 428     hash_create_mem (0, sizeof (lisp_stats_key_t), sizeof (uword));
 429   memset (&lgm->counters, 0, sizeof (lgm->counters));
 430   lgm->counters.name = "LISP counters";
 431
 432   return 0;
 433 }
 434
 435 gpe_encap_mode_t
 436 vnet_gpe_get_encap_mode (void)
 437 {
 438   lisp_gpe_main_t *lgm = &lisp_gpe_main;
 439   return lgm->encap_mode;
 440 }
 441
 442 VLIB_INIT_FUNCTION (lisp_gpe_init);
 443
 444 /*
 445  * fd.io coding-style-patch-verification: ON
 446  *
 447  * Local Variables:
 448  * eval: (c-set-style "gnu")
 449  * End:
 450  */