extras/deprecated/plugins/gbp/gbp_route_domain.c

   1 /*
   2  * Copyright (c) 2018 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 #include <plugins/gbp/gbp_route_domain.h>
  17 #include <plugins/gbp/gbp_endpoint.h>
  18
  19 #include <vnet/dpo/dvr_dpo.h>
  20 #include <vnet/fib/fib_table.h>
  21
  22 /**
  23  * A fixed MAC address to use as the source MAC for packets L3 switched
  24  * onto the routed uu-fwd interfaces.
  25  * Magic values - origin lost to the mists of time...
  26  */
  27 /* *INDENT-OFF* */
  28 const static mac_address_t GBP_ROUTED_SRC_MAC = {
  29   .bytes = {
  30     0x0, 0x22, 0xBD, 0xF8, 0x19, 0xFF,
  31   }
  32 };
  33
  34 const static mac_address_t GBP_ROUTED_DST_MAC = {
  35   .bytes = {
  36     00, 0x0c, 0x0c, 0x0c, 0x0c, 0x0c,
  37   }
  38 };
  39 /* *INDENT-ON* */
  40
  41 /**
  42  * Pool of GBP route_domains
  43  */
  44 gbp_route_domain_t *gbp_route_domain_pool;
  45
  46 /**
  47  * DB of route_domains
  48  */
  49 typedef struct gbp_route_domain_db_t
  50 {
  51   uword *gbd_by_rd_id;
  52 } gbp_route_domain_db_t;
  53
  54 static gbp_route_domain_db_t gbp_route_domain_db;
  55 static fib_source_t gbp_fib_source;
  56
  57 /**
  58  * logger
  59  */
  60 vlib_log_class_t grd_logger;
  61
  62 #define GBP_BD_DBG(...)                           \
  63     vlib_log_debug (grd_logger, __VA_ARGS__);
  64
  65 index_t
  66 gbp_route_domain_index (const gbp_route_domain_t * grd)
  67 {
  68   return (grd - gbp_route_domain_pool);
  69 }
  70
  71 gbp_route_domain_t *
  72 gbp_route_domain_get (index_t i)
  73 {
  74   return (pool_elt_at_index (gbp_route_domain_pool, i));
  75 }
  76
  77 static void
  78 gbp_route_domain_lock (index_t i)
  79 {
  80   gbp_route_domain_t *grd;
  81
  82   grd = gbp_route_domain_get (i);
  83   grd->grd_locks++;
  84 }
  85
  86 index_t
  87 gbp_route_domain_find (u32 rd_id)
  88 {
  89   uword *p;
  90
  91   p = hash_get (gbp_route_domain_db.gbd_by_rd_id, rd_id);
  92
  93   if (NULL != p)
  94     return p[0];
  95
  96   return (INDEX_INVALID);
  97 }
  98
  99 index_t
 100 gbp_route_domain_find_and_lock (u32 rd_id)
 101 {
 102   index_t grdi;
 103
 104   grdi = gbp_route_domain_find (rd_id);
 105
 106   if (INDEX_INVALID != grdi)
 107     {
 108       gbp_route_domain_lock (grdi);
 109     }
 110   return (grdi);
 111 }
 112
 113 static void
 114 gbp_route_domain_db_add (gbp_route_domain_t * grd)
 115 {
 116   index_t grdi = grd - gbp_route_domain_pool;
 117
 118   hash_set (gbp_route_domain_db.gbd_by_rd_id, grd->grd_id, grdi);
 119 }
 120
 121 static void
 122 gbp_route_domain_db_remove (gbp_route_domain_t * grd)
 123 {
 124   hash_unset (gbp_route_domain_db.gbd_by_rd_id, grd->grd_id);
 125 }
 126
 127 int
 128 gbp_route_domain_add_and_lock (u32 rd_id,
 129                                gbp_scope_t scope,
 130                                u32 ip4_table_id,
 131                                u32 ip6_table_id,
 132                                u32 ip4_uu_sw_if_index, u32 ip6_uu_sw_if_index)
 133 {
 134   gbp_route_domain_t *grd;
 135   index_t grdi;
 136
 137   grdi = gbp_route_domain_find (rd_id);
 138
 139   if (INDEX_INVALID == grdi)
 140     {
 141       fib_protocol_t fproto;
 142
 143       pool_get_zero (gbp_route_domain_pool, grd);
 144
 145       grd->grd_id = rd_id;
 146       grd->grd_scope = scope;
 147       grd->grd_table_id[FIB_PROTOCOL_IP4] = ip4_table_id;
 148       grd->grd_table_id[FIB_PROTOCOL_IP6] = ip6_table_id;
 149       grd->grd_uu_sw_if_index[FIB_PROTOCOL_IP4] = ip4_uu_sw_if_index;
 150       grd->grd_uu_sw_if_index[FIB_PROTOCOL_IP6] = ip6_uu_sw_if_index;
 151
 152       FOR_EACH_FIB_IP_PROTOCOL (fproto)
 153       {
 154         grd->grd_fib_index[fproto] =
 155           fib_table_find_or_create_and_lock (fproto,
 156                                              grd->grd_table_id[fproto],
 157                                              gbp_fib_source);
 158
 159         if (~0 != grd->grd_uu_sw_if_index[fproto])
 160           {
 161             ethernet_header_t *eth;
 162             u8 *rewrite;
 163
 164             rewrite = NULL;
 165             vec_validate (rewrite, sizeof (*eth) - 1);
 166             eth = (ethernet_header_t *) rewrite;
 167
 168             eth->type = clib_host_to_net_u16 ((fproto == FIB_PROTOCOL_IP4 ?
 169                                                ETHERNET_TYPE_IP4 :
 170                                                ETHERNET_TYPE_IP6));
 171
 172             mac_address_to_bytes (gbp_route_domain_get_local_mac (),
 173                                   eth->src_address);
 174             mac_address_to_bytes (gbp_route_domain_get_remote_mac (),
 175                                   eth->dst_address);
 176
 177             /*
 178              * create an adjacency out of the uu-fwd interfaces that will
 179              * be used when adding subnet routes.
 180              */
 181             grd->grd_adj[fproto] =
 182               adj_nbr_add_or_lock_w_rewrite (fproto,
 183                                              fib_proto_to_link (fproto),
 184                                              &ADJ_BCAST_ADDR,
 185                                              grd->grd_uu_sw_if_index[fproto],
 186                                              rewrite);
 187           }
 188         else
 189           {
 190             grd->grd_adj[fproto] = INDEX_INVALID;
 191           }
 192       }
 193
 194       gbp_route_domain_db_add (grd);
 195     }
 196   else
 197     {
 198       grd = gbp_route_domain_get (grdi);
 199     }
 200
 201   grd->grd_locks++;
 202   GBP_BD_DBG ("add: %U", format_gbp_route_domain, grd);
 203
 204   return (0);
 205 }
 206
 207 void
 208 gbp_route_domain_unlock (index_t index)
 209 {
 210   gbp_route_domain_t *grd;
 211
 212   grd = gbp_route_domain_get (index);
 213
 214   grd->grd_locks--;
 215
 216   if (0 == grd->grd_locks)
 217     {
 218       fib_protocol_t fproto;
 219
 220       GBP_BD_DBG ("destroy: %U", format_gbp_route_domain, grd);
 221
 222       FOR_EACH_FIB_IP_PROTOCOL (fproto)
 223       {
 224         fib_table_unlock (grd->grd_fib_index[fproto], fproto, gbp_fib_source);
 225         if (INDEX_INVALID != grd->grd_adj[fproto])
 226           adj_unlock (grd->grd_adj[fproto]);
 227       }
 228
 229       gbp_route_domain_db_remove (grd);
 230
 231       pool_put (gbp_route_domain_pool, grd);
 232     }
 233 }
 234
 235 u32
 236 gbp_route_domain_get_rd_id (index_t grdi)
 237 {
 238   gbp_route_domain_t *grd;
 239
 240   grd = gbp_route_domain_get (grdi);
 241
 242   return (grd->grd_id);
 243 }
 244
 245 gbp_scope_t
 246 gbp_route_domain_get_scope (index_t grdi)
 247 {
 248   gbp_route_domain_t *grd;
 249
 250   grd = gbp_route_domain_get (grdi);
 251
 252   return (grd->grd_scope);
 253 }
 254
 255 int
 256 gbp_route_domain_delete (u32 rd_id)
 257 {
 258   index_t grdi;
 259
 260   GBP_BD_DBG ("del: %d", rd_id);
 261   grdi = gbp_route_domain_find (rd_id);
 262
 263   if (INDEX_INVALID != grdi)
 264     {
 265       GBP_BD_DBG ("del: %U", format_gbp_route_domain,
 266                   gbp_route_domain_get (grdi));
 267       gbp_route_domain_unlock (grdi);
 268
 269       return (0);
 270     }
 271
 272   return (VNET_API_ERROR_NO_SUCH_ENTRY);
 273 }
 274
 275 const mac_address_t *
 276 gbp_route_domain_get_local_mac (void)
 277 {
 278   return (&GBP_ROUTED_SRC_MAC);
 279 }
 280
 281 const mac_address_t *
 282 gbp_route_domain_get_remote_mac (void)
 283 {
 284   return (&GBP_ROUTED_DST_MAC);
 285 }
 286
 287 void
 288 gbp_route_domain_walk (gbp_route_domain_cb_t cb, void *ctx)
 289 {
 290   gbp_route_domain_t *gbpe;
 291
 292   /* *INDENT-OFF* */
 293   pool_foreach (gbpe, gbp_route_domain_pool)
 294   {
 295     if (!cb(gbpe, ctx))
 296       break;
 297   }
 298   /* *INDENT-ON* */
 299 }
 300
 301 static clib_error_t *
 302 gbp_route_domain_cli (vlib_main_t * vm,
 303                       unformat_input_t * input, vlib_cli_command_t * cmd)
 304 {
 305   vnet_main_t *vnm = vnet_get_main ();
 306   u32 ip4_uu_sw_if_index = ~0;
 307   u32 ip6_uu_sw_if_index = ~0;
 308   u32 ip4_table_id = ~0;
 309   u32 ip6_table_id = ~0;
 310   u32 scope = ~0;
 311   u32 rd_id = ~0;
 312   u8 add = 1;
 313
 314   while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
 315     {
 316       if (unformat (input, "ip4-uu %U", unformat_vnet_sw_interface,
 317                     vnm, &ip4_uu_sw_if_index))
 318         ;
 319       else if (unformat (input, "ip6-uu %U", unformat_vnet_sw_interface,
 320                          vnm, &ip6_uu_sw_if_index))
 321         ;
 322       else if (unformat (input, "ip4-table-id %d", &ip4_table_id))
 323         ;
 324       else if (unformat (input, "ip6-table-id %d", &ip6_table_id))
 325         ;
 326       else if (unformat (input, "add"))
 327         add = 1;
 328       else if (unformat (input, "del"))
 329         add = 0;
 330       else if (unformat (input, "rd %d", &rd_id))
 331         ;
 332       else if (unformat (input, "scope %d", &scope))
 333         ;
 334       else
 335         break;
 336     }
 337
 338   if (~0 == rd_id)
 339     return clib_error_return (0, "RD-ID must be specified");
 340
 341   if (add)
 342     {
 343       if (~0 == ip4_table_id)
 344         return clib_error_return (0, "IP4 table-ID must be specified");
 345       if (~0 == ip6_table_id)
 346         return clib_error_return (0, "IP6 table-ID must be specified");
 347
 348       gbp_route_domain_add_and_lock (rd_id, scope,
 349                                      ip4_table_id,
 350                                      ip6_table_id,
 351                                      ip4_uu_sw_if_index, ip6_uu_sw_if_index);
 352     }
 353   else
 354     gbp_route_domain_delete (rd_id);
 355
 356   return (NULL);
 357 }
 358
 359 /*?
 360  * Configure a GBP route-domain
 361  *
 362  * @cliexpar
 363  * @cliexstart{gbp route-domain [del] rd <ID> ip4-table-id <ID> ip6-table-id <ID> [ip4-uu <interface>] [ip6-uu <interface>]}
 364  * @cliexend
 365  ?*/
 366 /* *INDENT-OFF* */
 367 VLIB_CLI_COMMAND (gbp_route_domain_cli_node, static) = {
 368   .path = "gbp route-domain",
 369   .short_help = "gbp route-domain [del] rd <ID> ip4-table-id <ID> ip6-table-id <ID> [ip4-uu <interface>] [ip6-uu <interface>]",
 370   .function = gbp_route_domain_cli,
 371 };
 372
 373 u8 *
 374 format_gbp_route_domain (u8 * s, va_list * args)
 375 {
 376   gbp_route_domain_t *grd = va_arg (*args, gbp_route_domain_t*);
 377   vnet_main_t *vnm = vnet_get_main ();
 378
 379   if (NULL != grd)
 380     s = format (s, "[%d] rd:%d ip4-uu:%U ip6-uu:%U locks:%d",
 381                 grd - gbp_route_domain_pool,
 382                 grd->grd_id,
 383                 format_vnet_sw_if_index_name, vnm, grd->grd_uu_sw_if_index[FIB_PROTOCOL_IP4],
 384                 format_vnet_sw_if_index_name, vnm, grd->grd_uu_sw_if_index[FIB_PROTOCOL_IP6],
 385                 grd->grd_locks);
 386   else
 387     s = format (s, "NULL");
 388
 389   return (s);
 390 }
 391
 392 static int
 393 gbp_route_domain_show_one (gbp_route_domain_t *gb, void *ctx)
 394 {
 395   vlib_main_t *vm;
 396
 397   vm = ctx;
 398   vlib_cli_output (vm, "  %U",format_gbp_route_domain, gb);
 399
 400   return (1);
 401 }
 402
 403 static clib_error_t *
 404 gbp_route_domain_show (vlib_main_t * vm,
 405                    unformat_input_t * input, vlib_cli_command_t * cmd)
 406 {
 407   vlib_cli_output (vm, "Route-Domains:");
 408   gbp_route_domain_walk (gbp_route_domain_show_one, vm);
 409
 410   return (NULL);
 411 }
 412
 413 /*?
 414  * Show Group Based Policy Route_Domains and derived information
 415  *
 416  * @cliexpar
 417  * @cliexstart{show gbp route_domain}
 418  * @cliexend
 419  ?*/
 420 /* *INDENT-OFF* */
 421 VLIB_CLI_COMMAND (gbp_route_domain_show_node, static) = {
 422   .path = "show gbp route-domain",
 423   .short_help = "show gbp route-domain\n",
 424   .function = gbp_route_domain_show,
 425 };
 426 /* *INDENT-ON* */
 427
 428 static clib_error_t *
 429 gbp_route_domain_init (vlib_main_t * vm)
 430 {
 431   grd_logger = vlib_log_register_class ("gbp", "rd");
 432   gbp_fib_source = fib_source_allocate ("gbp-rd",
 433                                         FIB_SOURCE_PRIORITY_HI,
 434                                         FIB_SOURCE_BH_DROP);
 435
 436   return (NULL);
 437 }
 438
 439 VLIB_INIT_FUNCTION (gbp_route_domain_init);
 440
 441 /*
 442  * fd.io coding-style-patch-verification: ON
 443  *
 444  * Local Variables:
 445  * eval: (c-set-style "gnu")
 446  * End:
 447  */