src/plugins/gbp/gbp_api.c

   1 /*
   2  *------------------------------------------------------------------
   3  * Copyright (c) 2018 Cisco and/or its affiliates.
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at:
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  *------------------------------------------------------------------
  16  */
  17
  18 #include <vnet/vnet.h>
  19 #include <vnet/plugin/plugin.h>
  20
  21 #include <vnet/interface.h>
  22 #include <vnet/api_errno.h>
  23 #include <vnet/ip/ip_types_api.h>
  24 #include <vnet/ethernet/ethernet_types_api.h>
  25 #include <vpp/app/version.h>
  26
  27 #include <gbp/gbp.h>
  28 #include <gbp/gbp_learn.h>
  29 #include <gbp/gbp_itf.h>
  30 #include <gbp/gbp_vxlan.h>
  31 #include <gbp/gbp_bridge_domain.h>
  32 #include <gbp/gbp_route_domain.h>
  33
  34 #include <vlibapi/api.h>
  35 #include <vlibmemory/api.h>
  36
  37 /* define message IDs */
  38 #include <gbp/gbp_msg_enum.h>
  39
  40 #define vl_typedefs             /* define message structures */
  41 #include <gbp/gbp_all_api_h.h>
  42 #undef vl_typedefs
  43
  44 #define vl_endianfun            /* define message structures */
  45 #include <gbp/gbp_all_api_h.h>
  46 #undef vl_endianfun
  47
  48 /* instantiate all the print functions we know about */
  49 #define vl_print(handle, ...) vlib_cli_output (handle, __VA_ARGS__)
  50 #define vl_printfun
  51 #include <gbp/gbp_all_api_h.h>
  52 #undef vl_printfun
  53
  54 /* Get the API version number */
  55 #define vl_api_version(n,v) static u32 api_version=(v);
  56 #include <gbp/gbp_all_api_h.h>
  57 #undef vl_api_version
  58
  59 #include <vlibapi/api_helper_macros.h>
  60
  61 #define foreach_gbp_api_msg                                 \
  62   _(GBP_ENDPOINT_ADD, gbp_endpoint_add)                     \
  63   _(GBP_ENDPOINT_DEL, gbp_endpoint_del)                     \
  64   _(GBP_ENDPOINT_DUMP, gbp_endpoint_dump)                   \
  65   _(GBP_SUBNET_ADD_DEL, gbp_subnet_add_del)                 \
  66   _(GBP_SUBNET_DUMP, gbp_subnet_dump)                       \
  67   _(GBP_ENDPOINT_GROUP_ADD, gbp_endpoint_group_add)         \
  68   _(GBP_ENDPOINT_GROUP_DEL, gbp_endpoint_group_del)         \
  69   _(GBP_ENDPOINT_GROUP_DUMP, gbp_endpoint_group_dump)       \
  70   _(GBP_BRIDGE_DOMAIN_ADD, gbp_bridge_domain_add)           \
  71   _(GBP_BRIDGE_DOMAIN_DEL, gbp_bridge_domain_del)           \
  72   _(GBP_BRIDGE_DOMAIN_DUMP, gbp_bridge_domain_dump)         \
  73   _(GBP_ROUTE_DOMAIN_ADD, gbp_route_domain_add)             \
  74   _(GBP_ROUTE_DOMAIN_DEL, gbp_route_domain_del)             \
  75   _(GBP_ROUTE_DOMAIN_DUMP, gbp_route_domain_dump)           \
  76   _(GBP_RECIRC_ADD_DEL, gbp_recirc_add_del)                 \
  77   _(GBP_RECIRC_DUMP, gbp_recirc_dump)                       \
  78   _(GBP_CONTRACT_ADD_DEL, gbp_contract_add_del)             \
  79   _(GBP_CONTRACT_DUMP, gbp_contract_dump)                   \
  80   _(GBP_ENDPOINT_LEARN_SET_INACTIVE_THRESHOLD, gbp_endpoint_learn_set_inactive_threshold) \
  81   _(GBP_VXLAN_TUNNEL_ADD, gbp_vxlan_tunnel_add)                         \
  82   _(GBP_VXLAN_TUNNEL_DEL, gbp_vxlan_tunnel_del)                         \
  83   _(GBP_VXLAN_TUNNEL_DUMP, gbp_vxlan_tunnel_dump)
  84
  85 gbp_main_t gbp_main;
  86
  87 static u16 msg_id_base;
  88
  89 #define GBP_MSG_BASE msg_id_base
  90
  91 static gbp_endpoint_flags_t
  92 gbp_endpoint_flags_decode (vl_api_gbp_endpoint_flags_t v)
  93 {
  94   gbp_endpoint_flags_t f = GBP_ENDPOINT_FLAG_NONE;
  95
  96   v = ntohl (v);
  97
  98   if (v & BOUNCE)
  99     f |= GBP_ENDPOINT_FLAG_BOUNCE;
 100   if (v & REMOTE)
 101     f |= GBP_ENDPOINT_FLAG_REMOTE;
 102   if (v & LEARNT)
 103     f |= GBP_ENDPOINT_FLAG_LEARNT;
 104
 105   return (f);
 106 }
 107
 108 static vl_api_gbp_endpoint_flags_t
 109 gbp_endpoint_flags_encode (gbp_endpoint_flags_t f)
 110 {
 111   vl_api_gbp_endpoint_flags_t v = 0;
 112
 113
 114   if (f & GBP_ENDPOINT_FLAG_BOUNCE)
 115     v |= BOUNCE;
 116   if (f & GBP_ENDPOINT_FLAG_REMOTE)
 117     v |= REMOTE;
 118   if (f & GBP_ENDPOINT_FLAG_LEARNT)
 119     v |= LEARNT;
 120
 121   v = htonl (v);
 122
 123   return (v);
 124 }
 125
 126 static void
 127 vl_api_gbp_endpoint_add_t_handler (vl_api_gbp_endpoint_add_t * mp)
 128 {
 129   vl_api_gbp_endpoint_add_reply_t *rmp;
 130   gbp_endpoint_flags_t gef;
 131   u32 sw_if_index, handle;
 132   ip46_address_t *ips;
 133   mac_address_t mac;
 134   int rv = 0, ii;
 135
 136   VALIDATE_SW_IF_INDEX (&(mp->endpoint));
 137
 138   gef = gbp_endpoint_flags_decode (mp->endpoint.flags), ips = NULL;
 139   sw_if_index = ntohl (mp->endpoint.sw_if_index);
 140
 141   if (mp->endpoint.n_ips)
 142     {
 143       vec_validate (ips, mp->endpoint.n_ips - 1);
 144
 145       vec_foreach_index (ii, ips)
 146       {
 147         ip_address_decode (&mp->endpoint.ips[ii], &ips[ii]);
 148       }
 149     }
 150   mac_address_decode (&mp->endpoint.mac, &mac);
 151
 152   if (GBP_ENDPOINT_FLAG_REMOTE & gef)
 153     {
 154       ip46_address_t tun_src, tun_dst;
 155
 156       ip_address_decode (&mp->endpoint.tun.src, &tun_src);
 157       ip_address_decode (&mp->endpoint.tun.dst, &tun_dst);
 158
 159       rv = gbp_endpoint_update (sw_if_index, ips, &mac,
 160                                 ntohs (mp->endpoint.epg_id),
 161                                 gef, &tun_src, &tun_dst, &handle);
 162     }
 163   else
 164     {
 165       rv = gbp_endpoint_update (sw_if_index, ips, &mac,
 166                                 ntohs (mp->endpoint.epg_id),
 167                                 gef, NULL, NULL, &handle);
 168     }
 169   BAD_SW_IF_INDEX_LABEL;
 170
 171   /* *INDENT-OFF* */
 172   REPLY_MACRO2 (VL_API_GBP_ENDPOINT_ADD_REPLY + GBP_MSG_BASE,
 173   ({
 174     rmp->handle = htonl (handle);
 175   }));
 176   /* *INDENT-ON* */
 177 }
 178
 179 static void
 180 vl_api_gbp_endpoint_del_t_handler (vl_api_gbp_endpoint_del_t * mp)
 181 {
 182   vl_api_gbp_endpoint_del_reply_t *rmp;
 183   int rv = 0;
 184
 185   gbp_endpoint_delete (ntohl (mp->handle));
 186
 187   REPLY_MACRO (VL_API_GBP_ENDPOINT_DEL_REPLY + GBP_MSG_BASE);
 188 }
 189
 190 static void
 191   vl_api_gbp_endpoint_learn_set_inactive_threshold_t_handler
 192   (vl_api_gbp_endpoint_learn_set_inactive_threshold_t * mp)
 193 {
 194   vl_api_gbp_endpoint_learn_set_inactive_threshold_reply_t *rmp;
 195   int rv = 0;
 196
 197   gbp_learn_set_inactive_threshold (ntohl (mp->threshold));
 198
 199   REPLY_MACRO (VL_API_GBP_ENDPOINT_LEARN_SET_INACTIVE_THRESHOLD_REPLY +
 200                GBP_MSG_BASE);
 201 }
 202
 203 typedef struct gbp_walk_ctx_t_
 204 {
 205   vl_api_registration_t *reg;
 206   u32 context;
 207 } gbp_walk_ctx_t;
 208
 209 static walk_rc_t
 210 gbp_endpoint_send_details (index_t gei, void *args)
 211 {
 212   vl_api_gbp_endpoint_details_t *mp;
 213   gbp_endpoint_t *ge;
 214   gbp_walk_ctx_t *ctx;
 215   u8 n_ips, ii;
 216
 217   ctx = args;
 218   ge = gbp_endpoint_get (gei);
 219
 220   n_ips = vec_len (ge->ge_ips);
 221   mp = vl_msg_api_alloc (sizeof (*mp) + (sizeof (*mp->endpoint.ips) * n_ips));
 222   if (!mp)
 223     return 1;
 224
 225   clib_memset (mp, 0, sizeof (*mp));
 226   mp->_vl_msg_id = ntohs (VL_API_GBP_ENDPOINT_DETAILS + GBP_MSG_BASE);
 227   mp->context = ctx->context;
 228
 229   if (gbp_endpoint_is_remote (ge))
 230     {
 231       mp->endpoint.sw_if_index = ntohl (ge->tun.ge_parent_sw_if_index);
 232       ip_address_encode (&ge->tun.ge_src, IP46_TYPE_ANY,
 233                          &mp->endpoint.tun.src);
 234       ip_address_encode (&ge->tun.ge_dst, IP46_TYPE_ANY,
 235                          &mp->endpoint.tun.dst);
 236     }
 237   else
 238     {
 239       mp->endpoint.sw_if_index = ntohl (ge->ge_sw_if_index);
 240     }
 241   mp->endpoint.epg_id = ntohs (ge->ge_epg_id);
 242   mp->endpoint.n_ips = n_ips;
 243   mp->endpoint.flags = gbp_endpoint_flags_encode (ge->ge_flags);
 244   mp->handle = htonl (gei);
 245   mp->age = vlib_time_now (vlib_get_main ()) - ge->ge_last_time;
 246   mac_address_encode (&ge->ge_mac, &mp->endpoint.mac);
 247
 248   vec_foreach_index (ii, ge->ge_ips)
 249   {
 250     ip_address_encode (&ge->ge_ips[ii], IP46_TYPE_ANY, &mp->endpoint.ips[ii]);
 251   }
 252
 253   vl_api_send_msg (ctx->reg, (u8 *) mp);
 254
 255   return (WALK_CONTINUE);
 256 }
 257
 258 static void
 259 vl_api_gbp_endpoint_dump_t_handler (vl_api_gbp_endpoint_dump_t * mp)
 260 {
 261   vl_api_registration_t *reg;
 262
 263   reg = vl_api_client_index_to_registration (mp->client_index);
 264   if (!reg)
 265     return;
 266
 267   gbp_walk_ctx_t ctx = {
 268     .reg = reg,
 269     .context = mp->context,
 270   };
 271
 272   gbp_endpoint_walk (gbp_endpoint_send_details, &ctx);
 273 }
 274
 275 static void
 276   vl_api_gbp_endpoint_group_add_t_handler
 277   (vl_api_gbp_endpoint_group_add_t * mp)
 278 {
 279   vl_api_gbp_endpoint_group_add_reply_t *rmp;
 280   int rv = 0;
 281
 282   rv = gbp_endpoint_group_add_and_lock (ntohs (mp->epg.epg_id),
 283                                         ntohl (mp->epg.bd_id),
 284                                         ntohl (mp->epg.rd_id),
 285                                         ntohl (mp->epg.uplink_sw_if_index));
 286
 287   REPLY_MACRO (VL_API_GBP_ENDPOINT_GROUP_ADD_REPLY + GBP_MSG_BASE);
 288 }
 289
 290 static void
 291   vl_api_gbp_endpoint_group_del_t_handler
 292   (vl_api_gbp_endpoint_group_del_t * mp)
 293 {
 294   vl_api_gbp_endpoint_group_del_reply_t *rmp;
 295   int rv = 0;
 296
 297   rv = gbp_endpoint_group_delete (ntohs (mp->epg_id));
 298
 299   REPLY_MACRO (VL_API_GBP_ENDPOINT_GROUP_DEL_REPLY + GBP_MSG_BASE);
 300 }
 301
 302 static void
 303 vl_api_gbp_bridge_domain_add_t_handler (vl_api_gbp_bridge_domain_add_t * mp)
 304 {
 305   vl_api_gbp_bridge_domain_add_reply_t *rmp;
 306   int rv = 0;
 307
 308   rv = gbp_bridge_domain_add_and_lock (ntohl (mp->bd.bd_id),
 309                                        ntohl (mp->bd.bvi_sw_if_index),
 310                                        ntohl (mp->bd.uu_fwd_sw_if_index));
 311
 312   REPLY_MACRO (VL_API_GBP_BRIDGE_DOMAIN_ADD_REPLY + GBP_MSG_BASE);
 313 }
 314
 315 static void
 316 vl_api_gbp_bridge_domain_del_t_handler (vl_api_gbp_bridge_domain_del_t * mp)
 317 {
 318   vl_api_gbp_bridge_domain_del_reply_t *rmp;
 319   int rv = 0;
 320
 321   rv = gbp_bridge_domain_delete (ntohl (mp->bd_id));
 322
 323   REPLY_MACRO (VL_API_GBP_BRIDGE_DOMAIN_DEL_REPLY + GBP_MSG_BASE);
 324 }
 325
 326 static void
 327 vl_api_gbp_route_domain_add_t_handler (vl_api_gbp_route_domain_add_t * mp)
 328 {
 329   vl_api_gbp_route_domain_add_reply_t *rmp;
 330   int rv = 0;
 331
 332   rv = gbp_route_domain_add_and_lock (ntohl (mp->rd.rd_id),
 333                                       ntohl (mp->rd.ip4_table_id),
 334                                       ntohl (mp->rd.ip6_table_id),
 335                                       ntohl (mp->rd.ip4_uu_sw_if_index),
 336                                       ntohl (mp->rd.ip6_uu_sw_if_index));
 337
 338   REPLY_MACRO (VL_API_GBP_ROUTE_DOMAIN_ADD_REPLY + GBP_MSG_BASE);
 339 }
 340
 341 static void
 342 vl_api_gbp_route_domain_del_t_handler (vl_api_gbp_route_domain_del_t * mp)
 343 {
 344   vl_api_gbp_route_domain_del_reply_t *rmp;
 345   int rv = 0;
 346
 347   rv = gbp_route_domain_delete (ntohl (mp->rd_id));
 348
 349   REPLY_MACRO (VL_API_GBP_ROUTE_DOMAIN_DEL_REPLY + GBP_MSG_BASE);
 350 }
 351
 352 static int
 353 gub_subnet_type_from_api (vl_api_gbp_subnet_type_t a, gbp_subnet_type_t * t)
 354 {
 355   a = clib_net_to_host_u32 (a);
 356
 357   switch (a)
 358     {
 359     case GBP_API_SUBNET_TRANSPORT:
 360       *t = GBP_SUBNET_TRANSPORT;
 361       return (0);
 362     case GBP_API_SUBNET_STITCHED_INTERNAL:
 363       *t = GBP_SUBNET_STITCHED_INTERNAL;
 364       return (0);
 365     case GBP_API_SUBNET_STITCHED_EXTERNAL:
 366       *t = GBP_SUBNET_STITCHED_EXTERNAL;
 367       return (0);
 368     }
 369
 370   return (-1);
 371 }
 372
 373 static void
 374 vl_api_gbp_subnet_add_del_t_handler (vl_api_gbp_subnet_add_del_t * mp)
 375 {
 376   vl_api_gbp_subnet_add_del_reply_t *rmp;
 377   gbp_subnet_type_t type;
 378   fib_prefix_t pfx;
 379   int rv = 0;
 380
 381   ip_prefix_decode (&mp->subnet.prefix, &pfx);
 382
 383   rv = gub_subnet_type_from_api (mp->subnet.type, &type);
 384
 385   if (0 != rv)
 386     goto out;
 387
 388   if (mp->is_add)
 389     rv = gbp_subnet_add (ntohl (mp->subnet.rd_id),
 390                          &pfx, type,
 391                          ntohl (mp->subnet.sw_if_index),
 392                          ntohs (mp->subnet.epg_id));
 393   else
 394     rv = gbp_subnet_del (ntohl (mp->subnet.rd_id), &pfx);
 395
 396 out:
 397   REPLY_MACRO (VL_API_GBP_SUBNET_ADD_DEL_REPLY + GBP_MSG_BASE);
 398 }
 399
 400 static vl_api_gbp_subnet_type_t
 401 gub_subnet_type_to_api (gbp_subnet_type_t t)
 402 {
 403   vl_api_gbp_subnet_type_t a = 0;
 404
 405   switch (t)
 406     {
 407     case GBP_SUBNET_TRANSPORT:
 408       a = GBP_API_SUBNET_TRANSPORT;
 409       break;
 410     case GBP_SUBNET_STITCHED_INTERNAL:
 411       a = GBP_API_SUBNET_STITCHED_INTERNAL;
 412       break;
 413     case GBP_SUBNET_STITCHED_EXTERNAL:
 414       a = GBP_API_SUBNET_STITCHED_EXTERNAL;
 415       break;
 416     }
 417
 418   a = clib_host_to_net_u32 (a);
 419
 420   return (a);
 421 }
 422
 423 static walk_rc_t
 424 gbp_subnet_send_details (u32 rd_id,
 425                          const fib_prefix_t * pfx,
 426                          gbp_subnet_type_t type,
 427                          u32 sw_if_index, epg_id_t epg, void *args)
 428 {
 429   vl_api_gbp_subnet_details_t *mp;
 430   gbp_walk_ctx_t *ctx;
 431
 432   ctx = args;
 433   mp = vl_msg_api_alloc (sizeof (*mp));
 434   if (!mp)
 435     return 1;
 436
 437   clib_memset (mp, 0, sizeof (*mp));
 438   mp->_vl_msg_id = ntohs (VL_API_GBP_SUBNET_DETAILS + GBP_MSG_BASE);
 439   mp->context = ctx->context;
 440
 441   mp->subnet.type = gub_subnet_type_to_api (type);
 442   mp->subnet.sw_if_index = ntohl (sw_if_index);
 443   mp->subnet.epg_id = ntohs (epg);
 444   mp->subnet.rd_id = ntohl (rd_id);
 445   ip_prefix_encode (pfx, &mp->subnet.prefix);
 446
 447   vl_api_send_msg (ctx->reg, (u8 *) mp);
 448
 449   return (WALK_CONTINUE);
 450 }
 451
 452 static void
 453 vl_api_gbp_subnet_dump_t_handler (vl_api_gbp_subnet_dump_t * mp)
 454 {
 455   vl_api_registration_t *reg;
 456
 457   reg = vl_api_client_index_to_registration (mp->client_index);
 458   if (!reg)
 459     return;
 460
 461   gbp_walk_ctx_t ctx = {
 462     .reg = reg,
 463     .context = mp->context,
 464   };
 465
 466   gbp_subnet_walk (gbp_subnet_send_details, &ctx);
 467 }
 468
 469 static int
 470 gbp_endpoint_group_send_details (gbp_endpoint_group_t * gg, void *args)
 471 {
 472   vl_api_gbp_endpoint_group_details_t *mp;
 473   gbp_walk_ctx_t *ctx;
 474
 475   ctx = args;
 476   mp = vl_msg_api_alloc (sizeof (*mp));
 477   if (!mp)
 478     return 1;
 479
 480   clib_memset (mp, 0, sizeof (*mp));
 481   mp->_vl_msg_id = ntohs (VL_API_GBP_ENDPOINT_GROUP_DETAILS + GBP_MSG_BASE);
 482   mp->context = ctx->context;
 483
 484   mp->epg.uplink_sw_if_index = ntohl (gg->gg_uplink_sw_if_index);
 485   mp->epg.epg_id = ntohs (gg->gg_id);
 486   mp->epg.bd_id = ntohl (gbp_endpoint_group_get_bd_id (gg));
 487   mp->epg.rd_id = ntohl (gg->gg_rd);
 488
 489   vl_api_send_msg (ctx->reg, (u8 *) mp);
 490
 491   return (1);
 492 }
 493
 494 static void
 495 vl_api_gbp_endpoint_group_dump_t_handler (vl_api_gbp_endpoint_group_dump_t *
 496                                           mp)
 497 {
 498   vl_api_registration_t *reg;
 499
 500   reg = vl_api_client_index_to_registration (mp->client_index);
 501   if (!reg)
 502     return;
 503
 504   gbp_walk_ctx_t ctx = {
 505     .reg = reg,
 506     .context = mp->context,
 507   };
 508
 509   gbp_endpoint_group_walk (gbp_endpoint_group_send_details, &ctx);
 510 }
 511
 512 static int
 513 gbp_bridge_domain_send_details (gbp_bridge_domain_t * gb, void *args)
 514 {
 515   vl_api_gbp_bridge_domain_details_t *mp;
 516   gbp_walk_ctx_t *ctx;
 517
 518   ctx = args;
 519   mp = vl_msg_api_alloc (sizeof (*mp));
 520   if (!mp)
 521     return 1;
 522
 523   memset (mp, 0, sizeof (*mp));
 524   mp->_vl_msg_id = ntohs (VL_API_GBP_BRIDGE_DOMAIN_DETAILS + GBP_MSG_BASE);
 525   mp->context = ctx->context;
 526
 527   mp->bd.bd_id = ntohl (gb->gb_bd_id);
 528   mp->bd.bvi_sw_if_index = ntohl (gb->gb_bvi_sw_if_index);
 529   mp->bd.uu_fwd_sw_if_index = ntohl (gb->gb_uu_fwd_sw_if_index);
 530
 531   vl_api_send_msg (ctx->reg, (u8 *) mp);
 532
 533   return (1);
 534 }
 535
 536 static void
 537 vl_api_gbp_bridge_domain_dump_t_handler (vl_api_gbp_bridge_domain_dump_t * mp)
 538 {
 539   vl_api_registration_t *reg;
 540
 541   reg = vl_api_client_index_to_registration (mp->client_index);
 542   if (!reg)
 543     return;
 544
 545   gbp_walk_ctx_t ctx = {
 546     .reg = reg,
 547     .context = mp->context,
 548   };
 549
 550   gbp_bridge_domain_walk (gbp_bridge_domain_send_details, &ctx);
 551 }
 552
 553 static int
 554 gbp_route_domain_send_details (gbp_route_domain_t * grd, void *args)
 555 {
 556   vl_api_gbp_route_domain_details_t *mp;
 557   gbp_walk_ctx_t *ctx;
 558
 559   ctx = args;
 560   mp = vl_msg_api_alloc (sizeof (*mp));
 561   if (!mp)
 562     return 1;
 563
 564   memset (mp, 0, sizeof (*mp));
 565   mp->_vl_msg_id = ntohs (VL_API_GBP_ROUTE_DOMAIN_DETAILS + GBP_MSG_BASE);
 566   mp->context = ctx->context;
 567
 568   mp->rd.rd_id = ntohl (grd->grd_id);
 569   mp->rd.ip4_uu_sw_if_index =
 570     ntohl (grd->grd_uu_sw_if_index[FIB_PROTOCOL_IP4]);
 571   mp->rd.ip6_uu_sw_if_index =
 572     ntohl (grd->grd_uu_sw_if_index[FIB_PROTOCOL_IP6]);
 573
 574   vl_api_send_msg (ctx->reg, (u8 *) mp);
 575
 576   return (1);
 577 }
 578
 579 static void
 580 vl_api_gbp_route_domain_dump_t_handler (vl_api_gbp_route_domain_dump_t * mp)
 581 {
 582   vl_api_registration_t *reg;
 583
 584   reg = vl_api_client_index_to_registration (mp->client_index);
 585   if (!reg)
 586     return;
 587
 588   gbp_walk_ctx_t ctx = {
 589     .reg = reg,
 590     .context = mp->context,
 591   };
 592
 593   gbp_route_domain_walk (gbp_route_domain_send_details, &ctx);
 594 }
 595
 596 static void
 597 vl_api_gbp_recirc_add_del_t_handler (vl_api_gbp_recirc_add_del_t * mp)
 598 {
 599   vl_api_gbp_recirc_add_del_reply_t *rmp;
 600   u32 sw_if_index;
 601   int rv = 0;
 602
 603   sw_if_index = ntohl (mp->recirc.sw_if_index);
 604   if (!vnet_sw_if_index_is_api_valid (sw_if_index))
 605     goto bad_sw_if_index;
 606
 607   if (mp->is_add)
 608     gbp_recirc_add (sw_if_index,
 609                     ntohs (mp->recirc.epg_id), mp->recirc.is_ext);
 610   else
 611     gbp_recirc_delete (sw_if_index);
 612
 613   BAD_SW_IF_INDEX_LABEL;
 614
 615   REPLY_MACRO (VL_API_GBP_RECIRC_ADD_DEL_REPLY + GBP_MSG_BASE);
 616 }
 617
 618 static int
 619 gbp_recirc_send_details (gbp_recirc_t * gr, void *args)
 620 {
 621   vl_api_gbp_recirc_details_t *mp;
 622   gbp_walk_ctx_t *ctx;
 623
 624   ctx = args;
 625   mp = vl_msg_api_alloc (sizeof (*mp));
 626   if (!mp)
 627     return 1;
 628
 629   clib_memset (mp, 0, sizeof (*mp));
 630   mp->_vl_msg_id = ntohs (VL_API_GBP_RECIRC_DETAILS + GBP_MSG_BASE);
 631   mp->context = ctx->context;
 632
 633   mp->recirc.epg_id = ntohs (gr->gr_epg);
 634   mp->recirc.sw_if_index = ntohl (gr->gr_sw_if_index);
 635   mp->recirc.is_ext = ntohl (gr->gr_is_ext);
 636
 637   vl_api_send_msg (ctx->reg, (u8 *) mp);
 638
 639   return (1);
 640 }
 641
 642 static void
 643 vl_api_gbp_recirc_dump_t_handler (vl_api_gbp_recirc_dump_t * mp)
 644 {
 645   vl_api_registration_t *reg;
 646
 647   reg = vl_api_client_index_to_registration (mp->client_index);
 648   if (!reg)
 649     return;
 650
 651   gbp_walk_ctx_t ctx = {
 652     .reg = reg,
 653     .context = mp->context,
 654   };
 655
 656   gbp_recirc_walk (gbp_recirc_send_details, &ctx);
 657 }
 658
 659 static void
 660 vl_api_gbp_contract_add_del_t_handler (vl_api_gbp_contract_add_del_t * mp)
 661 {
 662   vl_api_gbp_contract_add_del_reply_t *rmp;
 663   int rv = 0;
 664
 665   if (mp->is_add)
 666     gbp_contract_update (ntohs (mp->contract.src_epg),
 667                          ntohs (mp->contract.dst_epg),
 668                          ntohl (mp->contract.acl_index));
 669   else
 670     gbp_contract_delete (ntohs (mp->contract.src_epg),
 671                          ntohs (mp->contract.dst_epg));
 672
 673   REPLY_MACRO (VL_API_GBP_CONTRACT_ADD_DEL_REPLY + GBP_MSG_BASE);
 674 }
 675
 676 static int
 677 gbp_contract_send_details (gbp_contract_t * gbpc, void *args)
 678 {
 679   vl_api_gbp_contract_details_t *mp;
 680   gbp_walk_ctx_t *ctx;
 681
 682   ctx = args;
 683   mp = vl_msg_api_alloc (sizeof (*mp));
 684   if (!mp)
 685     return 1;
 686
 687   clib_memset (mp, 0, sizeof (*mp));
 688   mp->_vl_msg_id = ntohs (VL_API_GBP_CONTRACT_DETAILS + GBP_MSG_BASE);
 689   mp->context = ctx->context;
 690
 691   mp->contract.src_epg = ntohs (gbpc->gc_key.gck_src);
 692   mp->contract.dst_epg = ntohs (gbpc->gc_key.gck_dst);
 693   mp->contract.acl_index = ntohl (gbpc->gc_value.gc_acl_index);
 694
 695   vl_api_send_msg (ctx->reg, (u8 *) mp);
 696
 697   return (1);
 698 }
 699
 700 static void
 701 vl_api_gbp_contract_dump_t_handler (vl_api_gbp_contract_dump_t * mp)
 702 {
 703   vl_api_registration_t *reg;
 704
 705   reg = vl_api_client_index_to_registration (mp->client_index);
 706   if (!reg)
 707     return;
 708
 709   gbp_walk_ctx_t ctx = {
 710     .reg = reg,
 711     .context = mp->context,
 712   };
 713
 714   gbp_contract_walk (gbp_contract_send_details, &ctx);
 715 }
 716
 717 static int
 718 gbp_vxlan_tunnel_mode_2_layer (vl_api_gbp_vxlan_tunnel_mode_t mode,
 719                                gbp_vxlan_tunnel_layer_t * l)
 720 {
 721   mode = clib_net_to_host_u32 (mode);
 722
 723   switch (mode)
 724     {
 725     case GBP_VXLAN_TUNNEL_MODE_L2:
 726       *l = GBP_VXLAN_TUN_L2;
 727       return (0);
 728     case GBP_VXLAN_TUNNEL_MODE_L3:
 729       *l = GBP_VXLAN_TUN_L3;
 730       return (0);
 731     }
 732   return (-1);
 733 }
 734
 735 static void
 736 vl_api_gbp_vxlan_tunnel_add_t_handler (vl_api_gbp_vxlan_tunnel_add_t * mp)
 737 {
 738   vl_api_gbp_vxlan_tunnel_add_reply_t *rmp;
 739   gbp_vxlan_tunnel_layer_t layer;
 740   u32 sw_if_index;
 741   int rv = 0;
 742
 743   rv = gbp_vxlan_tunnel_mode_2_layer (mp->tunnel.mode, &layer);
 744
 745   if (0 != rv)
 746     goto out;
 747
 748   rv = gbp_vxlan_tunnel_add (ntohl (mp->tunnel.vni),
 749                              layer,
 750                              ntohl (mp->tunnel.bd_rd_id), &sw_if_index);
 751
 752 out:
 753   /* *INDENT-OFF* */
 754   REPLY_MACRO2 (VL_API_GBP_VXLAN_TUNNEL_ADD_REPLY + GBP_MSG_BASE,
 755   ({
 756     rmp->sw_if_index = htonl (sw_if_index);
 757   }));
 758   /* *INDENT-ON* */
 759 }
 760
 761 static void
 762 vl_api_gbp_vxlan_tunnel_del_t_handler (vl_api_gbp_vxlan_tunnel_add_t * mp)
 763 {
 764   vl_api_gbp_vxlan_tunnel_del_reply_t *rmp;
 765   int rv = 0;
 766
 767   rv = gbp_vxlan_tunnel_del (ntohl (mp->tunnel.vni));
 768
 769   REPLY_MACRO (VL_API_GBP_VXLAN_TUNNEL_DEL_REPLY + GBP_MSG_BASE);
 770 }
 771
 772 static vl_api_gbp_vxlan_tunnel_mode_t
 773 gbp_vxlan_tunnel_layer_2_mode (gbp_vxlan_tunnel_layer_t layer)
 774 {
 775   vl_api_gbp_vxlan_tunnel_mode_t mode = GBP_VXLAN_TUNNEL_MODE_L2;
 776
 777   switch (layer)
 778     {
 779     case GBP_VXLAN_TUN_L2:
 780       mode = GBP_VXLAN_TUNNEL_MODE_L2;
 781       break;
 782     case GBP_VXLAN_TUN_L3:
 783       mode = GBP_VXLAN_TUNNEL_MODE_L3;
 784       break;
 785     }
 786   mode = clib_host_to_net_u32 (mode);
 787
 788   return (mode);
 789 }
 790
 791 static walk_rc_t
 792 gbp_vxlan_tunnel_send_details (gbp_vxlan_tunnel_t * gt, void *args)
 793 {
 794   vl_api_gbp_vxlan_tunnel_details_t *mp;
 795   gbp_walk_ctx_t *ctx;
 796
 797   ctx = args;
 798   mp = vl_msg_api_alloc (sizeof (*mp));
 799   if (!mp)
 800     return 1;
 801
 802   memset (mp, 0, sizeof (*mp));
 803   mp->_vl_msg_id = htons (VL_API_GBP_VXLAN_TUNNEL_DETAILS + GBP_MSG_BASE);
 804   mp->context = ctx->context;
 805
 806   mp->tunnel.vni = htonl (gt->gt_vni);
 807   mp->tunnel.mode = gbp_vxlan_tunnel_layer_2_mode (gt->gt_layer);
 808   mp->tunnel.bd_rd_id = htonl (gt->gt_bd_rd_id);
 809
 810   vl_api_send_msg (ctx->reg, (u8 *) mp);
 811
 812   return (1);
 813 }
 814
 815 static void
 816 vl_api_gbp_vxlan_tunnel_dump_t_handler (vl_api_gbp_vxlan_tunnel_dump_t * mp)
 817 {
 818   vl_api_registration_t *reg;
 819
 820   reg = vl_api_client_index_to_registration (mp->client_index);
 821   if (!reg)
 822     return;
 823
 824   gbp_walk_ctx_t ctx = {
 825     .reg = reg,
 826     .context = mp->context,
 827   };
 828
 829   gbp_vxlan_walk (gbp_vxlan_tunnel_send_details, &ctx);
 830 }
 831
 832 /*
 833  * gbp_api_hookup
 834  * Add vpe's API message handlers to the table.
 835  * vlib has already mapped shared memory and
 836  * added the client registration handlers.
 837  * See .../vlib-api/vlibmemory/memclnt_vlib.c:memclnt_process()
 838  */
 839 #define vl_msg_name_crc_list
 840 #include <gbp/gbp_all_api_h.h>
 841 #undef vl_msg_name_crc_list
 842
 843 static void
 844 setup_message_id_table (api_main_t * am)
 845 {
 846 #define _(id,n,crc)                                     \
 847   vl_msg_api_add_msg_name_crc (am, #n "_" #crc, id + GBP_MSG_BASE);
 848   foreach_vl_msg_name_crc_gbp;
 849 #undef _
 850 }
 851
 852 static void
 853 gbp_api_hookup (vlib_main_t * vm)
 854 {
 855 #define _(N,n)                                                  \
 856     vl_msg_api_set_handlers(VL_API_##N + GBP_MSG_BASE,          \
 857                             #n,                                 \
 858                             vl_api_##n##_t_handler,             \
 859                             vl_noop_handler,                    \
 860                             vl_api_##n##_t_endian,              \
 861                             vl_api_##n##_t_print,               \
 862                             sizeof(vl_api_##n##_t), 1);
 863   foreach_gbp_api_msg;
 864 #undef _
 865 }
 866
 867 static clib_error_t *
 868 gbp_init (vlib_main_t * vm)
 869 {
 870   api_main_t *am = &api_main;
 871   gbp_main_t *gbpm = &gbp_main;
 872   u8 *name = format (0, "gbp_%08x%c", api_version, 0);
 873
 874   gbpm->gbp_acl_user_id = ~0;
 875
 876   /* Ask for a correctly-sized block of API message decode slots */
 877   msg_id_base = vl_msg_api_get_msg_ids ((char *) name,
 878                                         VL_MSG_FIRST_AVAILABLE);
 879   gbp_api_hookup (vm);
 880
 881   /* Add our API messages to the global name_crc hash table */
 882   setup_message_id_table (am);
 883
 884   vec_free (name);
 885   return (NULL);
 886 }
 887
 888 VLIB_API_INIT_FUNCTION (gbp_init);
 889
 890 /* *INDENT-OFF* */
 891 VLIB_PLUGIN_REGISTER () = {
 892     .version = VPP_BUILD_VER,
 893     .description = "Group Based Policy",
 894 };
 895 /* *INDENT-ON* */
 896
 897
 898 /*
 899  * fd.io coding-style-patch-verification: ON
 900  *
 901  * Local Variables:
 902  * eval: (c-set-style "gnu")
 903  * End:
 904  */