90 u16 socket_id = rte_lcore_to_socket_id (lcore);
146 (
struct ether_addr *)
159 if (xd->
pmd == VNET_DPDK_PMD_BOND)
162 int nlink = rte_eth_bond_slaves_get (xd->
device_index, slink, 16);
166 rte_eth_allmulticast_enable (dpdk_port);
181 if (xd->
pmd == VNET_DPDK_PMD_BOND)
184 int nlink = rte_eth_bond_slaves_get (xd->
device_index, slink, 16);
188 rte_eth_dev_stop (dpdk_port);
206 uword event_type, *event_data = 0;
215 for (i = 0; i <
vec_len (event_data); i++)
217 dpdk_port = event_data[
i];
236 .name =
"send-garp-na-process",
248 (vm, send_garp_na_proc_node.index,
SEND_GARP_NA, *dpdk_port);
253 enum rte_eth_event_type type,
void *param)
255 struct rte_eth_link link;
258 RTE_SET_USED (param);
259 if (type != RTE_ETH_EVENT_INTR_LSC)
261 clib_warning (
"Unknown event %d received for port %d", type, port_id);
265 rte_eth_link_get_nowait (port_id, &link);
266 u8 link_up = link.link_status;
270 uword bd_port = xd->bond_port;
271 int bd_mode = rte_eth_bond_mode_get (bd_port);
274 "slave of port %d BondEthernet%d in mode %d",
275 port_id, (link_up) ?
"UP" :
"DOWN",
276 bd_port, xd->port_id, bd_mode);
278 if (bd_mode == BONDING_MODE_ACTIVE_BACKUP)
283 xd->flags |= link_up ?
290 port_id, (
unsigned) link.link_speed,
291 (link.link_duplex == ETH_LINK_FULL_DUPLEX) ?
292 "full-duplex" :
"half-duplex");
302 enum rte_eth_event_type type,
304 void *ret_param __attribute__ ((unused)))
#define DPDK_DEVICE_FLAG_PROMISC
sll srl srl sll sra u16x4 i
clib_error_t * vnet_hw_interface_set_flags(vnet_main_t *vnm, u32 hw_if_index, u32 flags)
#define DPDK_DEVICE_FLAG_PMD_INIT_FAIL
void vl_api_force_rpc_call_main_thread(void *fp, u8 *data, u32 data_length)
static uword * vlib_process_wait_for_event(vlib_main_t *vm)
vnet_main_t * vnet_get_main(void)
static f64 vlib_time_now(vlib_main_t *vm)
static vnet_hw_interface_t * vnet_get_hw_interface(vnet_main_t *vnm, u32 hw_if_index)
struct _vlib_node_registration vlib_node_registration_t
static vnet_sw_interface_t * vnet_get_sw_interface(vnet_main_t *vnm, u32 sw_if_index)
int dpdk_port_state_callback(dpdk_portid_t port_id, enum rte_eth_event_type type, void *param, void *ret_param)
#define vec_validate_aligned(V, I, A)
Make sure vector is long enough for given index (no header, specified alignment)
#define vec_reset_length(v)
Reset vector length to zero NULL-pointer tolerant.
enum @318 dpdk_send_garp_na_process_event_t
static uword vlib_process_suspend(vlib_main_t *vm, f64 dt)
Suspend a vlib cooperative multi-tasking thread for a period of time.
static uword vlib_process_get_events(vlib_main_t *vm, uword **data_vector)
Return the first event type which has occurred and a vector of per-event data of that type...
#define clib_error_return(e, args...)
void dpdk_device_setup(dpdk_device_t *xd)
struct rte_eth_conf port_conf
static uword send_garp_na_process(vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f)
struct rte_eth_txconf tx_conf
vlib_worker_thread_t * vlib_worker_threads
void dpdk_device_start(dpdk_device_t *xd)
static_always_inline uword vnet_get_device_input_thread_index(vnet_main_t *vnm, u32 hw_if_index, u16 queue_id)
static void vlib_process_signal_event(vlib_main_t *vm, uword node_index, uword type_opaque, uword data)
void send_ip4_garp(vlib_main_t *vm, vnet_hw_interface_t *hi)
static void garp_na_proc_callback(uword *dpdk_port)
void send_ip6_na(vlib_main_t *vm, vnet_hw_interface_t *hi)
#define DPDK_DEVICE_FLAG_ADMIN_UP
static_always_inline uword vlib_get_thread_index(void)
#define clib_warning(format, args...)
static vlib_node_registration_t send_garp_na_proc_node
(constructor) VLIB_REGISTER_NODE (send_garp_na_proc_node)
static int dpdk_port_state_callback_inline(dpdk_portid_t port_id, enum rte_eth_event_type type, void *param)
void dpdk_device_stop(dpdk_device_t *xd)
void dpdk_device_error(dpdk_device_t *xd, char *str, int rv)
struct rte_mempool ** pktmbuf_pools
void dpdk_update_link_state(dpdk_device_t *xd, f64 now)
dpdk_portid_t device_index
static vlib_main_t * vlib_get_main(void)
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
#define VNET_SW_INTERFACE_FLAG_ERROR
#define DPDK_DEVICE_FLAG_BOND_SLAVE
#define clib_error_free(e)
#define VLIB_REGISTER_NODE(x,...)
#define CLIB_CACHE_LINE_BYTES
u8 * buffer_pool_for_queue
CLIB vectors are ubiquitous dynamically resized arrays with by user defined "headers".
#define DPDK_DEVICE_FLAG_BOND_SLAVE_UP