src/plugins/linux-cp/lcp_api.c

   1 /*
   2  * Copyright 2020 Rubicon Communications, LLC.
   3  *
   4  * SPDX-License-Identifier: Apache-2.0
   5  */
   6
   7 #include <sys/socket.h>
   8 #include <linux/if.h>
   9
  10 #include <vnet/vnet.h>
  11 #include <vnet/plugin/plugin.h>
  12
  13 #include <vlibapi/api.h>
  14 #include <vlibmemory/api.h>
  15 #include <vpp/app/version.h>
  16 #include <vnet/format_fns.h>
  17
  18 #include <linux-cp/lcp_interface.h>
  19 #include <linux-cp/lcp.api_enum.h>
  20 #include <linux-cp/lcp.api_types.h>
  21
  22 static u16 lcp_msg_id_base;
  23 #define REPLY_MSG_ID_BASE lcp_msg_id_base
  24 #include <vlibapi/api_helper_macros.h>
  25
  26 static lip_host_type_t
  27 api_decode_host_type (vl_api_lcp_itf_host_type_t type)
  28 {
  29   if (type == LCP_API_ITF_HOST_TUN)
  30     return LCP_ITF_HOST_TUN;
  31
  32   return LCP_ITF_HOST_TAP;
  33 }
  34
  35 static vl_api_lcp_itf_host_type_t
  36 api_encode_host_type (lip_host_type_t type)
  37 {
  38   if (type == LCP_ITF_HOST_TUN)
  39     return LCP_API_ITF_HOST_TUN;
  40
  41   return LCP_API_ITF_HOST_TAP;
  42 }
  43
  44 void
  45 lcp_set_auto_intf (u8 is_auto)
  46 {
  47   lcp_main_t *lcpm = &lcp_main;
  48
  49   lcpm->auto_intf = (is_auto != 0);
  50 }
  51
  52 int
  53 lcp_auto_intf (void)
  54 {
  55   lcp_main_t *lcpm = &lcp_main;
  56
  57   return lcpm->auto_intf;
  58 }
  59
  60 static void
  61 vl_api_lcp_itf_pair_add_del_t_handler (vl_api_lcp_itf_pair_add_del_t *mp)
  62 {
  63   u32 phy_sw_if_index;
  64   vl_api_lcp_itf_pair_add_del_reply_t *rmp;
  65   lip_host_type_t lip_host_type;
  66   int rv;
  67
  68   if (!vnet_sw_if_index_is_api_valid (mp->sw_if_index))
  69     {
  70       rv = VNET_API_ERROR_INVALID_SW_IF_INDEX;
  71       goto bad_sw_if_index;
  72     }
  73
  74   phy_sw_if_index = mp->sw_if_index;
  75   lip_host_type = api_decode_host_type (mp->host_if_type);
  76   if (mp->is_add)
  77     {
  78       u8 *host_if_name, *netns;
  79       int host_len, netns_len;
  80
  81       host_if_name = netns = 0;
  82
  83       /* lcp_itf_pair_create expects vec of u8 */
  84       host_len = clib_strnlen ((char *) mp->host_if_name,
  85                                sizeof (mp->host_if_name) - 1);
  86       vec_add (host_if_name, mp->host_if_name, host_len);
  87       vec_add1 (host_if_name, 0);
  88
  89       netns_len =
  90         clib_strnlen ((char *) mp->namespace, sizeof (mp->namespace) - 1);
  91       vec_add (netns, mp->namespace, netns_len);
  92       vec_add1 (netns, 0);
  93
  94       rv = lcp_itf_pair_create (phy_sw_if_index, host_if_name, lip_host_type,
  95                                 netns);
  96
  97       vec_free (host_if_name);
  98       vec_free (netns);
  99     }
 100   else
 101     {
 102       rv = lcp_itf_pair_delete (phy_sw_if_index);
 103     }
 104
 105   BAD_SW_IF_INDEX_LABEL;
 106   REPLY_MACRO (VL_API_LCP_ITF_PAIR_ADD_DEL_REPLY);
 107 }
 108
 109 static void
 110 send_lcp_itf_pair_details (index_t lipi, vl_api_registration_t *rp,
 111                            u32 context)
 112 {
 113   vl_api_lcp_itf_pair_details_t *rmp;
 114   lcp_itf_pair_t *lcp_pair = lcp_itf_pair_get (lipi);
 115
 116   REPLY_MACRO_DETAILS4 (
 117     VL_API_LCP_ITF_PAIR_DETAILS, rp, context, ({
 118       rmp->phy_sw_if_index = lcp_pair->lip_phy_sw_if_index;
 119       rmp->host_sw_if_index = lcp_pair->lip_host_sw_if_index;
 120       rmp->vif_index = lcp_pair->lip_vif_index;
 121       rmp->host_if_type = api_encode_host_type (lcp_pair->lip_host_type);
 122
 123       clib_strncpy ((char *) rmp->host_if_name,
 124                     (char *) lcp_pair->lip_host_name,
 125                     vec_len (lcp_pair->lip_host_name) - 1);
 126
 127       clib_strncpy ((char *) rmp->namespace, (char *) lcp_pair->lip_namespace,
 128                     vec_len (lcp_pair->lip_namespace));
 129     }));
 130 }
 131
 132 static void
 133 vl_api_lcp_itf_pair_get_t_handler (vl_api_lcp_itf_pair_get_t *mp)
 134 {
 135   vl_api_lcp_itf_pair_get_reply_t *rmp;
 136   i32 rv = 0;
 137
 138   REPLY_AND_DETAILS_MACRO (
 139     VL_API_LCP_ITF_PAIR_GET_REPLY, lcp_itf_pair_pool,
 140     ({ send_lcp_itf_pair_details (cursor, rp, mp->context); }));
 141 }
 142
 143 static void
 144 vl_api_lcp_default_ns_set_t_handler (vl_api_lcp_default_ns_set_t *mp)
 145 {
 146   vl_api_lcp_default_ns_set_reply_t *rmp;
 147   int rv;
 148
 149   mp->namespace[LCP_NS_LEN - 1] = 0;
 150   rv = lcp_set_default_ns (mp->namespace);
 151
 152   REPLY_MACRO (VL_API_LCP_DEFAULT_NS_SET_REPLY);
 153 }
 154
 155 static void
 156 vl_api_lcp_default_ns_get_t_handler (vl_api_lcp_default_ns_get_t *mp)
 157 {
 158   lcp_main_t *lcpm = &lcp_main;
 159   vl_api_lcp_default_ns_get_reply_t *rmp;
 160   vl_api_registration_t *reg;
 161   char *ns;
 162
 163   reg = vl_api_client_index_to_registration (mp->client_index);
 164   if (!reg)
 165     return;
 166
 167   rmp = vl_msg_api_alloc (sizeof (*rmp));
 168   clib_memset (rmp, 0, sizeof (*rmp));
 169   rmp->_vl_msg_id = (VL_API_LCP_DEFAULT_NS_GET_REPLY + lcpm->msg_id_base);
 170   rmp->context = mp->context;
 171
 172   ns = (char *) lcp_get_default_ns ();
 173   if (ns)
 174     clib_strncpy ((char *) rmp->namespace, ns, LCP_NS_LEN - 1);
 175
 176   vl_api_send_msg (reg, (u8 *) rmp);
 177 }
 178
 179 static void
 180 vl_api_lcp_itf_pair_replace_begin_t_handler (
 181   vl_api_lcp_itf_pair_replace_begin_t *mp)
 182 {
 183   vl_api_lcp_itf_pair_replace_begin_reply_t *rmp;
 184   int rv;
 185
 186   rv = lcp_itf_pair_replace_begin ();
 187
 188   REPLY_MACRO (VL_API_LCP_ITF_PAIR_REPLACE_BEGIN_REPLY);
 189 }
 190
 191 static void
 192 vl_api_lcp_itf_pair_replace_end_t_handler (
 193   vl_api_lcp_itf_pair_replace_end_t *mp)
 194 {
 195   vl_api_lcp_itf_pair_replace_end_reply_t *rmp;
 196   int rv = 0;
 197
 198   rv = lcp_itf_pair_replace_end ();
 199
 200   REPLY_MACRO (VL_API_LCP_ITF_PAIR_REPLACE_END_REPLY);
 201 }
 202
 203 /*
 204  * Set up the API message handling tables
 205  */
 206 #include <linux-cp/lcp.api.c>
 207
 208 static clib_error_t *
 209 lcp_plugin_api_hookup (vlib_main_t *vm)
 210 {
 211   /* Ask for a correctly-sized block of API message decode slots */
 212   lcp_msg_id_base = setup_message_id_table ();
 213
 214   return (NULL);
 215 }
 216
 217 VLIB_INIT_FUNCTION (lcp_plugin_api_hookup);
 218
 219 #include <vpp/app/version.h>
 220 VLIB_PLUGIN_REGISTER () = {
 221   .version = VPP_BUILD_VER,
 222   .description = "Linux Control Plane - Interface Mirror",
 223   .default_disabled = 1,
 224 };
 225
 226 /*
 227  * fd.io coding-style-patch-verification: ON
 228  *
 229  * Local Variables:
 230  * eval: (c-set-style "gnu")
 231  * End:
 232  */