src/plugins/l3xc/l3xc_api.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 #include <stddef.h>
  17
  18 #include <vnet/vnet.h>
  19 #include <vnet/plugin/plugin.h>
  20 #include <l3xc/l3xc.h>
  21 #include <vnet/mpls/mpls_types.h>
  22 #include <vnet/fib/fib_path_list.h>
  23 #include <vnet/fib/fib_api.h>
  24
  25 #include <vpp/app/version.h>
  26
  27 #include <vlibapi/api.h>
  28 #include <vlibmemory/api.h>
  29
  30 /* define message IDs */
  31 #include <vnet/format_fns.h>
  32 #include <l3xc/l3xc.api_enum.h>
  33 #include <l3xc/l3xc.api_types.h>
  34
  35 /**
  36  * Base message ID fot the plugin
  37  */
  38 static u32 l3xc_base_msg_id;
  39
  40 #include <vlibapi/api_helper_macros.h>
  41
  42 static void
  43 vl_api_l3xc_plugin_get_version_t_handler (vl_api_l3xc_plugin_get_version_t *
  44                                           mp)
  45 {
  46   vl_api_l3xc_plugin_get_version_reply_t *rmp;
  47   vl_api_registration_t *rp;
  48
  49   rp = vl_api_client_index_to_registration (mp->client_index);
  50   if (rp == 0)
  51     return;
  52
  53   rmp = vl_msg_api_alloc (sizeof (*rmp));
  54   rmp->_vl_msg_id =
  55     ntohs (VL_API_L3XC_PLUGIN_GET_VERSION_REPLY + l3xc_base_msg_id);
  56   rmp->context = mp->context;
  57   rmp->major = htonl (L3XC_PLUGIN_VERSION_MAJOR);
  58   rmp->minor = htonl (L3XC_PLUGIN_VERSION_MINOR);
  59
  60   vl_api_send_msg (rp, (u8 *) rmp);
  61 }
  62
  63 static void
  64 vl_api_l3xc_update_t_handler (vl_api_l3xc_update_t * mp)
  65 {
  66   vl_api_l3xc_update_reply_t *rmp;
  67   fib_route_path_t *paths = NULL, *path;
  68   int rv = 0;
  69   u8 pi;
  70
  71   VALIDATE_SW_IF_INDEX (&mp->l3xc);
  72
  73   if (0 == mp->l3xc.n_paths)
  74     {
  75       rv = VNET_API_ERROR_INVALID_VALUE;
  76       goto done;
  77     }
  78
  79   vec_validate (paths, mp->l3xc.n_paths - 1);
  80
  81   for (pi = 0; pi < mp->l3xc.n_paths; pi++)
  82     {
  83       path = &paths[pi];
  84       rv = fib_api_path_decode (&mp->l3xc.paths[pi], path);
  85
  86       if (0 != rv)
  87         {
  88           goto done;
  89         }
  90     }
  91
  92   rv = l3xc_update (ntohl (mp->l3xc.sw_if_index), mp->l3xc.is_ip6, paths);
  93
  94 done:
  95   vec_free (paths);
  96
  97   BAD_SW_IF_INDEX_LABEL;
  98
  99   /* *INDENT-OFF* */
 100   REPLY_MACRO2 (VL_API_L3XC_UPDATE_REPLY + l3xc_base_msg_id,
 101   ({
 102     rmp->stats_index = 0;
 103   }))
 104   /* *INDENT-ON* */
 105 }
 106
 107 static void
 108 vl_api_l3xc_del_t_handler (vl_api_l3xc_del_t * mp)
 109 {
 110   vl_api_l3xc_del_reply_t *rmp;
 111   int rv = 0;
 112
 113   VALIDATE_SW_IF_INDEX (mp);
 114
 115   rv = l3xc_delete (ntohl (mp->sw_if_index), mp->is_ip6);
 116
 117   BAD_SW_IF_INDEX_LABEL;
 118
 119   REPLY_MACRO (VL_API_L3XC_DEL_REPLY + l3xc_base_msg_id);
 120 }
 121
 122 typedef struct l3xc_dump_walk_ctx_t_
 123 {
 124   vl_api_registration_t *rp;
 125   u32 context;
 126 } l3xc_dump_walk_ctx_t;
 127
 128 static int
 129 l3xc_send_details (u32 l3xci, void *args)
 130 {
 131   fib_path_encode_ctx_t path_ctx = {
 132     .rpaths = NULL,
 133   };
 134   vl_api_l3xc_details_t *mp;
 135   l3xc_dump_walk_ctx_t *ctx;
 136   fib_route_path_t *rpath;
 137   vl_api_fib_path_t *fp;
 138   size_t msg_size;
 139   l3xc_t *l3xc;
 140   u8 n_paths;
 141
 142   ctx = args;
 143   l3xc = l3xc_get (l3xci);
 144   n_paths = fib_path_list_get_n_paths (l3xc->l3xc_pl);
 145   msg_size = sizeof (*mp) + sizeof (mp->l3xc.paths[0]) * n_paths;
 146
 147   mp = vl_msg_api_alloc (msg_size);
 148   clib_memset (mp, 0, msg_size);
 149   mp->_vl_msg_id = ntohs (VL_API_L3XC_DETAILS + l3xc_base_msg_id);
 150
 151   /* fill in the message */
 152   mp->context = ctx->context;
 153   mp->l3xc.n_paths = n_paths;
 154   mp->l3xc.sw_if_index = htonl (l3xc->l3xc_sw_if_index);
 155
 156   fib_path_list_walk_w_ext (l3xc->l3xc_pl, NULL, fib_path_encode, &path_ctx);
 157
 158   fp = mp->l3xc.paths;
 159   vec_foreach (rpath, path_ctx.rpaths)
 160   {
 161     fib_api_path_encode (rpath, fp);
 162     fp++;
 163   }
 164
 165   vl_api_send_msg (ctx->rp, (u8 *) mp);
 166
 167   return (1);
 168 }
 169
 170 static void
 171 vl_api_l3xc_dump_t_handler (vl_api_l3xc_dump_t * mp)
 172 {
 173   vl_api_registration_t *rp;
 174   u32 sw_if_index;
 175
 176   rp = vl_api_client_index_to_registration (mp->client_index);
 177   if (rp == 0)
 178     return;
 179
 180   l3xc_dump_walk_ctx_t ctx = {
 181     .rp = rp,
 182     .context = mp->context,
 183   };
 184
 185   sw_if_index = ntohl (mp->sw_if_index);
 186
 187   if (~0 == sw_if_index)
 188     l3xc_walk (l3xc_send_details, &ctx);
 189   else
 190     {
 191       fib_protocol_t fproto;
 192       index_t l3xci;
 193
 194       FOR_EACH_FIB_IP_PROTOCOL (fproto)
 195       {
 196         l3xci = l3xc_find (sw_if_index, fproto);
 197
 198         if (INDEX_INVALID != l3xci)
 199           l3xc_send_details (l3xci, &ctx);
 200       }
 201     }
 202 }
 203
 204 #include <l3xc/l3xc.api.c>
 205 static clib_error_t *
 206 l3xc_api_init (vlib_main_t * vm)
 207 {
 208   /* Ask for a correctly-sized block of API message decode slots */
 209   l3xc_base_msg_id = setup_message_id_table ();
 210
 211   return 0;
 212 }
 213
 214 VLIB_INIT_FUNCTION (l3xc_api_init);
 215
 216 /* *INDENT-OFF* */
 217 VLIB_PLUGIN_REGISTER () = {
 218     .version = VPP_BUILD_VER,
 219     .description = "L3 Cross-Connect (L3XC)",
 220 };
 221 /* *INDENT-ON* */
 222
 223 /*
 224  * fd.io coding-style-patch-verification: ON
 225  *
 226  * Local Variables:
 227  * eval: (c-set-style "gnu")
 228  * End:
 229  */