aboutsummaryrefslogtreecommitdiffstats
path: root/src/vnet/dpo/interface_tx_dpo.c
blob: 870579884a0bde9c6380e2b0975b224b73252970 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
/*
 * Copyright (c) 2016 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 <vnet/dpo/interface_tx_dpo.h>
#include <vnet/adj/rewrite.h>

/*
 * We do not lock nor unlock these DPOs since there is nothing to lock
 * all we do is construct DPO object wrappers around a sw_if_index
 */
static void
interface_tx_dpo_lock (dpo_id_t *dpo)
{
}

static void
interface_tx_dpo_unlock (dpo_id_t *dpo)
{
}

/*
 * interface_tx_dpo_add_or_lock
 *
 * construct DPO object wrappers around a sw_if_index
 */
void
interface_tx_dpo_add_or_lock (dpo_proto_t proto,
                              u32 sw_if_index,
                              dpo_id_t *dpo)
{
    dpo_set(dpo, DPO_INTERFACE_TX, proto, sw_if_index);
}

u8*
format_interface_tx_dpo (u8* s, va_list *ap)
{
    index_t index = va_arg(*ap, index_t);
    CLIB_UNUSED(u32 indent) = va_arg(*ap, u32);
    vnet_main_t * vnm = vnet_get_main();

    return (format(s, "%U-tx-dpo:",
                   format_vnet_sw_interface_name,
                   vnm,
                   vnet_get_sw_interface(vnm, index)));
}

static void
interface_tx_dpo_mem_show (void)
{
}

u32*
interface_tx_dpo_get_next_node (const dpo_id_t *dpo)
{
    u32 *node_indices = NULL;

    /*
     * return the interface's TX node for the wrapped sw_if_index
     */
    vec_add1(node_indices,
             vnet_tx_node_index_for_sw_interface(vnet_get_main(),
                                                 dpo->dpoi_index));

    return (node_indices);
}

const static dpo_vft_t interface_tx_dpo_vft = {
    .dv_lock = interface_tx_dpo_lock,
    .dv_unlock = interface_tx_dpo_unlock,
    .dv_format = format_interface_tx_dpo,
    .dv_mem_show = interface_tx_dpo_mem_show,
    .dv_get_next_node = interface_tx_dpo_get_next_node,
};

void
interface_tx_dpo_module_init (void)
{
    dpo_register(DPO_INTERFACE_TX, &interface_tx_dpo_vft, NULL);
}
ses/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 <vnet/vnet.h> #include <vlibmemory/api.h> #include <vnet/interface.h> #include <vnet/api_errno.h> #include <vnet/ethernet/ethernet.h> #include <vnet/vnet_msg_enum.h> #define vl_typedefs /* define message structures */ #include <vnet/vnet_all_api_h.h> #undef vl_typedefs #define vl_endianfun /* define message structures */ #include <vnet/vnet_all_api_h.h> #undef vl_endianfun /* instantiate all the print functions we know about */ #define vl_print(handle, ...) vlib_cli_output (handle, __VA_ARGS__) #define vl_printfun #include <vnet/vnet_all_api_h.h> #undef vl_printfun #include <vlibapi/api_helper_macros.h> #include <vnet/bonding/node.h> #define foreach_bond_api_msg \ _(BOND_CREATE, bond_create) \ _(BOND_DELETE, bond_delete) \ _(BOND_ENSLAVE, bond_enslave) \ _(BOND_DETACH_SLAVE, bond_detach_slave) \ _(SW_INTERFACE_BOND_DUMP, sw_interface_bond_dump)\ _(SW_INTERFACE_SLAVE_DUMP, sw_interface_slave_dump) static void bond_send_sw_interface_event_deleted (vpe_api_main_t * am, unix_shared_memory_queue_t * q, u32 sw_if_index) { vl_api_sw_interface_event_t *mp; mp = vl_msg_api_alloc (sizeof (*mp)); clib_memset (mp, 0, sizeof (*mp)); mp->_vl_msg_id = ntohs (VL_API_SW_INTERFACE_EVENT); mp->sw_if_index = ntohl (sw_if_index); mp->admin_up_down = 0; mp->link_up_down = 0; mp->deleted = 1; vl_msg_api_send_shmem (q, (u8 *) & mp); } static void vl_api_bond_delete_t_handler (vl_api_bond_delete_t * mp) { vlib_main_t *vm = vlib_get_main (); int rv; vpe_api_main_t *vam = &vpe_api_main; vl_api_bond_delete_reply_t *rmp; unix_shared_memory_queue_t *q; u32 sw_if_index = ntohl (mp->sw_if_index); rv = bond_delete_if (vm, sw_if_index); q = vl_api_client_index_to_input_queue (mp->client_index); if (!q) return; rmp = vl_msg_api_alloc (sizeof (*rmp)); rmp->_vl_msg_id = ntohs (VL_API_BOND_DELETE_REPLY); rmp->context = mp->context; rmp->retval = ntohl (rv); vl_msg_api_send_shmem (q, (u8 *) & rmp); if (!rv) bond_send_sw_interface_event_deleted (vam, q, sw_if_index); } static void vl_api_bond_create_t_handler (vl_api_bond_create_t * mp) { vlib_main_t *vm = vlib_get_main (); vl_api_bond_create_reply_t *rmp; unix_shared_memory_queue_t *q; bond_create_if_args_t _a, *ap = &_a; clib_memset (ap, 0, sizeof (*ap)); ap->id = ntohl (mp->id); if (mp->use_custom_mac) { clib_memcpy (ap->hw_addr, mp->mac_address, 6); ap->hw_addr_set = 1; } ap->mode = mp->mode; ap->lb = mp->lb; bond_create_if (vm, ap); q = vl_api_client_index_to_input_queue (mp->client_index); if (!q) return; if (ap->rv != 0) return; rmp = vl_msg_api_alloc (sizeof (*rmp)); rmp->_vl_msg_id = ntohs (VL_API_BOND_CREATE_REPLY); rmp->context = mp->context; rmp->retval = ntohl (ap->rv); rmp->sw_if_index = ntohl (ap->sw_if_index); vl_msg_api_send_shmem (q, (u8 *) & rmp); } static void vl_api_bond_enslave_t_handler (vl_api_bond_enslave_t * mp) { vlib_main_t *vm = vlib_get_main (); vl_api_bond_enslave_reply_t *rmp; unix_shared_memory_queue_t *q; bond_enslave_args_t _a, *ap = &_a; clib_memset (ap, 0, sizeof (*ap)); ap->group = ntohl (mp->bond_sw_if_index); ap->slave = ntohl (mp->sw_if_index); ap->is_passive = mp->is_passive; ap->is_long_timeout = mp->is_long_timeout; bond_enslave (vm, ap); q = vl_api_client_index_to_input_queue (mp->client_index); if (!q) return; rmp = vl_msg_api_alloc (sizeof (*rmp)); rmp->_vl_msg_id = ntohs (VL_API_BOND_ENSLAVE_REPLY); rmp->context = mp->context; rmp->retval = ntohl (ap->rv); vl_msg_api_send_shmem (q, (u8 *) & rmp); } static void vl_api_bond_detach_slave_t_handler (vl_api_bond_detach_slave_t * mp) { vlib_main_t *vm = vlib_get_main (); vl_api_bond_detach_slave_reply_t *rmp; unix_shared_memory_queue_t *q; bond_detach_slave_args_t _a, *ap = &_a; clib_memset (ap, 0, sizeof (*ap)); ap->slave = ntohl (mp->sw_if_index); bond_detach_slave (vm, ap); q = vl_api_client_index_to_input_queue (mp->client_index); if (!q) return; rmp = vl_msg_api_alloc (sizeof (*rmp)); rmp->_vl_msg_id = ntohs (VL_API_BOND_DETACH_SLAVE_REPLY); rmp->context = mp->context; rmp->retval = htonl (ap->rv); vl_msg_api_send_shmem (q, (u8 *) & rmp); } static void bond_send_sw_interface_details (vpe_api_main_t * am, vl_api_registration_t * reg, bond_interface_details_t * bond_if, u32 context) { vl_api_sw_interface_bond_details_t *mp; mp = vl_msg_api_alloc (sizeof (*mp)); clib_memset (mp, 0, sizeof (*mp)); mp->_vl_msg_id = htons (VL_API_SW_INTERFACE_BOND_DETAILS); mp->sw_if_index = htonl (bond_if->sw_if_index); mp->id = htonl (bond_if->id); clib_memcpy (mp->interface_name, bond_if->interface_name, MIN (ARRAY_LEN (mp->interface_name) - 1, strlen ((const char *) bond_if->interface_name))); mp->mode = bond_if->mode; mp->lb = bond_if->lb; mp->active_slaves = htonl (bond_if->active_slaves); mp->slaves = htonl (bond_if->slaves); mp->context = context; vl_api_send_msg (reg, (u8 *) mp); } static void vl_api_sw_interface_bond_dump_t_handler (vl_api_sw_interface_bond_dump_t * mp) { int rv; vpe_api_main_t *am = &vpe_api_main; vl_api_registration_t *reg; bond_interface_details_t *bondifs = NULL; bond_interface_details_t *bond_if = NULL; reg = vl_api_client_index_to_registration (mp->client_index); if (!reg) return; rv = bond_dump_ifs (&bondifs); if (rv) return; vec_foreach (bond_if, bondifs) { bond_send_sw_interface_details (am, reg, bond_if, mp->context); } vec_free (bondifs); } static void bond_send_sw_interface_slave_details (vpe_api_main_t * am, vl_api_registration_t * reg, slave_interface_details_t * slave_if, u32 context) { vl_api_sw_interface_slave_details_t *mp; mp = vl_msg_api_alloc (sizeof (*mp)); clib_memset (mp, 0, sizeof (*mp)); mp->_vl_msg_id = htons (VL_API_SW_INTERFACE_SLAVE_DETAILS); mp->sw_if_index = htonl (slave_if->sw_if_index); clib_memcpy (mp->interface_name, slave_if->interface_name, MIN (ARRAY_LEN (mp->interface_name) - 1, strlen ((const char *) slave_if->interface_name))); mp->is_passive = slave_if->is_passive; mp->is_long_timeout = slave_if->is_long_timeout; mp->context = context; vl_api_send_msg (reg, (u8 *) mp); } static void vl_api_sw_interface_slave_dump_t_handler (vl_api_sw_interface_slave_dump_t * mp) { int rv; vpe_api_main_t *am = &vpe_api_main; vl_api_registration_t *reg; slave_interface_details_t *slaveifs = NULL; slave_interface_details_t *slave_if = NULL; reg = vl_api_client_index_to_registration (mp->client_index); if (!reg) return; rv = bond_dump_slave_ifs (&slaveifs, ntohl (mp->sw_if_index)); if (rv) return; vec_foreach (slave_if, slaveifs) { bond_send_sw_interface_slave_details (am, reg, slave_if, mp->context); } vec_free (slaveifs); } #define vl_msg_name_crc_list #include <vnet/vnet_all_api_h.h> #undef vl_msg_name_crc_list static void bond_setup_message_id_table (api_main_t * am) { #define _(id,n,crc) vl_msg_api_add_msg_name_crc (am, #n "_" #crc, id); foreach_vl_msg_name_crc_bond; #undef _ } static clib_error_t * bond_api_hookup (vlib_main_t * vm) { api_main_t *am = &api_main; #define _(N,n) \ vl_msg_api_set_handlers(VL_API_##N, #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_bond_api_msg; #undef _ /* * Set up the (msg_name, crc, message-id) table */ bond_setup_message_id_table (am); return 0; } VLIB_API_INIT_FUNCTION (bond_api_hookup); /* * fd.io coding-style-patch-verification: ON * * Local Variables: * eval: (c-set-style "gnu") * End: */