diff options
Diffstat (limited to 'libtransport/src/hicn/transport/core/hicn_binary_api.c')
| -rw-r--r-- | libtransport/src/hicn/transport/core/hicn_binary_api.c | 296 |
1 files changed, 0 insertions, 296 deletions
diff --git a/libtransport/src/hicn/transport/core/hicn_binary_api.c b/libtransport/src/hicn/transport/core/hicn_binary_api.c deleted file mode 100644 index 1f8dfd326..000000000 --- a/libtransport/src/hicn/transport/core/hicn_binary_api.c +++ /dev/null @@ -1,296 +0,0 @@ -/* - * Copyright (c) 2017-2019 Cisco and/or its affiliates. - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at: - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include <hicn/transport/config.h> - -#ifdef __vpp__ - -#include <hicn/transport/core/hicn_binary_api.h> -#include <hicn/transport/core/vpp_binary_api_internal.h> -#include <hicn/transport/utils/log.h> - -#define HICN_VPP_PLUGIN -#include <hicn/name.h> -#undef HICN_VPP_PLUGIN - -#include <fcntl.h> -#include <inttypes.h> -#include <semaphore.h> -#include <string.h> -#include <sys/stat.h> - -#include <vlib/vlib.h> -#include <vlibapi/api.h> -#include <vlibmemory/api.h> -#include <vppinfra/error.h> - -#include <vnet/ip/format.h> -#include <vnet/ip/ip4_packet.h> -#include <vnet/ip/ip6_packet.h> -#include <vnet/ip/ip_types_api.h> -#include <vnet/fib/fib_types.h> - -#include <vpp_plugins/hicn/error.h> -#include <vpp_plugins/hicn/hicn_api.h> - -// uword unformat_sw_if_index (unformat_input_t * input, va_list * args); - -/* Declare message IDs */ -#include <hicn/hicn_msg_enum.h> - -#define vl_endianfun -#define vl_typedefs -#include <vnet/ip/ip_types.api.h> -#undef vl_typedefs -#undef vl_endianfun - -#define vl_endianfun /* define message structures */ -#define vl_print(handle, ...) -#define vl_printfun -#define vl_api_version(n, v) static u32 api_version = (v); -#define vl_msg_name_crc_list -#include <hicn/hicn_all_api_h.h> -#undef vl_msg_name_crc_list -#undef vl_api_version -#undef vl_printfun -#undef vl_endianfun -///////////////////////////////////////////////////// -const char *HICN_ERROR_STRING[] = { -#define _(a, b, c) c, - foreach_hicn_error -#undef _ -}; -///////////////////////////////////////////////////// - -/*********************** Missing Symbol in vpp libraries *************************/ -u8 * -format_vl_api_address_union (u8 * s, va_list * args) -{ - const vl_api_address_union_t *addr = - va_arg (*args, vl_api_address_union_t *); - vl_api_address_family_t af = va_arg (*args, vl_api_address_family_t); - - if (ADDRESS_IP6 == af) - s = format (s, "%U", format_ip6_address, addr->ip6); - else - s = format (s, "%U", format_ip4_address, addr->ip4); - - return s; -} - -/*********************************************************************************/ - -static context_store_t context_store = { - .global_pointers_map_index = 0, -}; - -/* - * Table of message reply handlers, must include boilerplate handlers - * we just generated - */ -#define foreach_hicn_api_reply_msg \ - _(HICN_API_REGISTER_PROD_APP_REPLY, hicn_api_register_prod_app_reply) \ - _(HICN_API_FACE_PROD_DEL_REPLY, hicn_api_face_prod_del_reply) \ - _(HICN_API_REGISTER_CONS_APP_REPLY, hicn_api_register_cons_app_reply) \ - _(HICN_API_FACE_CONS_DEL_REPLY, hicn_api_face_cons_del_reply) \ - _(HICN_API_ROUTE_NHOPS_ADD_REPLY, hicn_api_route_nhops_add_reply) - -int hicn_binary_api_register_prod_app( - vpp_plugin_binary_api_t *api, hicn_producer_input_params *input_params, - hicn_producer_output_params *output_params) { - vl_api_hicn_api_register_prod_app_t *mp; - vpp_plugin_binary_api_t *hm = api; - vpp_binary_api_set_user_param(api->vpp_api, output_params); - - /* Construct the API message */ - M(HICN_API_REGISTER_PROD_APP, mp); - - CONTEXT_SAVE(context_store, api, mp) - - fib_prefix_t prefix; - memcpy(&prefix.fp_addr, &input_params->prefix->address, sizeof(ip46_address_t)); - prefix.fp_len = input_params->prefix->len; - prefix.fp_proto = ip46_address_is_ip4(&prefix.fp_addr) ? FIB_PROTOCOL_IP4 : FIB_PROTOCOL_IP6; - ip_prefix_encode(&prefix, &(mp->prefix)); - mp->swif = clib_host_to_net_u32(input_params->swif); - mp->cs_reserved = clib_host_to_net_u32(input_params->cs_reserved); - - return vpp_binary_api_send_request_wait_reply(api->vpp_api, mp); -} - -static void vl_api_hicn_api_register_prod_app_reply_t_handler( - vl_api_hicn_api_register_prod_app_reply_t *mp) { - vpp_plugin_binary_api_t *binary_api; - CONTEXT_GET(context_store, mp, binary_api); - hicn_producer_output_params *params = - vpp_binary_api_get_user_param(binary_api->vpp_api); - - vpp_binary_api_set_ret_value(binary_api->vpp_api, - clib_net_to_host_u32(mp->retval)); - params->cs_reserved = mp->cs_reserved; - params->prod_addr = (ip_address_t *)malloc(sizeof(ip_address_t)); - ip_address_decode(&mp->prod_addr, (ip46_address_t *)(params->prod_addr)); - params->face_id = clib_net_to_host_u32(mp->faceid); - - vpp_binary_api_unlock_waiting_thread(binary_api->vpp_api); -} - -int hicn_binary_api_face_prod_del( - vpp_plugin_binary_api_t *api, hicn_del_face_app_input_params *input_params) { - vl_api_hicn_api_face_prod_del_t *mp; - vpp_plugin_binary_api_t *hm = api; - - //vpp_binary_api_set_user_param(hm->vpp_api, output_params); - - /* Construct the API message */ - M(HICN_API_FACE_PROD_DEL, mp); - - mp->faceid = clib_host_to_net_u32(input_params->face_id); - - CONTEXT_SAVE(context_store, api, mp) - - return vpp_binary_api_send_request_wait_reply(api->vpp_api, mp); -} - -static void vl_api_hicn_api_face_prod_del_reply_t_handler( - vl_api_hicn_api_face_prod_del_reply_t *mp) { - vpp_plugin_binary_api_t *binary_api; - CONTEXT_GET(context_store, mp, binary_api); - - vpp_binary_api_set_ret_value(binary_api->vpp_api, - clib_net_to_host_u32(mp->retval)); - - vpp_binary_api_unlock_waiting_thread(binary_api->vpp_api); -} - -int hicn_binary_api_register_cons_app( - vpp_plugin_binary_api_t *api, hicn_consumer_input_params *input_params, - hicn_consumer_output_params *output_params) { - vl_api_hicn_api_register_cons_app_t *mp; - vpp_plugin_binary_api_t *hm = api; - - vpp_binary_api_set_user_param(hm->vpp_api, output_params); - - /* Construct the API message */ - M(HICN_API_REGISTER_CONS_APP, mp); - - mp->swif = clib_host_to_net_u32(input_params->swif); - - CONTEXT_SAVE(context_store, api, mp) - - return vpp_binary_api_send_request_wait_reply(api->vpp_api, mp); -} - -static void vl_api_hicn_api_register_cons_app_reply_t_handler( - vl_api_hicn_api_register_cons_app_reply_t *mp) { - vpp_plugin_binary_api_t *binary_api; - CONTEXT_GET(context_store, mp, binary_api); - hicn_consumer_output_params *params = - vpp_binary_api_get_user_param(binary_api->vpp_api); - - vpp_binary_api_set_ret_value(binary_api->vpp_api, - clib_net_to_host_u32(mp->retval)); - - ip_address_decode(&mp->src_addr4, (ip46_address_t *)params->src4); - ip_address_decode(&mp->src_addr6, (ip46_address_t *)params->src6); - params->face_id1 = clib_host_to_net_u32(mp->faceid1); - params->face_id2 = clib_host_to_net_u32(mp->faceid2); - - vpp_binary_api_unlock_waiting_thread(binary_api->vpp_api); -} - -int hicn_binary_api_face_cons_del( - vpp_plugin_binary_api_t *api, hicn_del_face_app_input_params *input_params) { - vl_api_hicn_api_face_cons_del_t *mp; - vpp_plugin_binary_api_t *hm = api; - - /* Construct the API message */ - M(HICN_API_FACE_CONS_DEL, mp); - - mp->faceid = clib_host_to_net_u32(input_params->face_id); - - CONTEXT_SAVE(context_store, api, mp) - - return vpp_binary_api_send_request_wait_reply(api->vpp_api, mp); -} - -static void vl_api_hicn_api_face_cons_del_reply_t_handler( - vl_api_hicn_api_face_cons_del_reply_t *mp) { - vpp_plugin_binary_api_t *binary_api; - CONTEXT_GET(context_store, mp, binary_api); - - vpp_binary_api_set_ret_value(binary_api->vpp_api, - clib_net_to_host_u32(mp->retval)); - - vpp_binary_api_unlock_waiting_thread(binary_api->vpp_api); -} - -int hicn_binary_api_register_route( - vpp_plugin_binary_api_t *api, - hicn_producer_set_route_params *input_params) { - vl_api_hicn_api_route_nhops_add_t *mp; - vpp_plugin_binary_api_t *hm = api; - - /* Construct the API message */ - M(HICN_API_ROUTE_NHOPS_ADD, mp); - - CONTEXT_SAVE(context_store, api, mp) - fib_prefix_t prefix; - memcpy(&prefix.fp_addr, &input_params->prefix->address, sizeof(ip46_address_t)); - prefix.fp_len = input_params->prefix->len; - mp->face_ids[0] = clib_host_to_net_u32(input_params->face_id); - mp->n_faces = 1; - - return vpp_binary_api_send_request_wait_reply(api->vpp_api, mp); -} - -static void vl_api_hicn_api_route_nhops_add_reply_t_handler( - vl_api_hicn_api_route_nhops_add_reply_t *mp) { - vpp_plugin_binary_api_t *binary_api; - CONTEXT_GET(context_store, mp, binary_api); - - vpp_binary_api_set_ret_value(binary_api->vpp_api, - clib_net_to_host_u32(mp->retval)); - - vpp_binary_api_unlock_waiting_thread(binary_api->vpp_api); -} - -static int hicn_binary_api_setup_handlers(vpp_plugin_binary_api_t *binary_api) { - vpp_plugin_binary_api_t *sm __attribute__((unused)) = binary_api; -#define _(N, n) \ - vl_msg_api_set_handlers(VL_API_##N + sm->msg_id_base, #n, \ - vl_api_##n##_t_handler, vl_noop_handler, \ - vl_api_##n##_t_endian, vl_api_##n##_t_print, \ - sizeof(vl_api_##n##_t), 1); - foreach_hicn_api_reply_msg; -#undef _ - return 0; -} - -char *hicn_binary_api_get_error_string(int ret_val) { - return get_error_string(ret_val); -} - -vpp_plugin_binary_api_t *hicn_binary_api_init(vpp_binary_api_t *api) { - vpp_plugin_binary_api_t *ret = malloc(sizeof(vpp_plugin_binary_api_t)); - u8 *name = format(0, "hicn_%08x%c", api_version, 0); - ret->msg_id_base = vl_client_get_first_plugin_msg_id((char *)name); - ret->vpp_api = api; - ret->my_client_index = vpp_binary_api_get_client_index(api); - hicn_binary_api_setup_handlers(ret); - return ret; -} - -#endif // __vpp__ |