X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fvnet%2Fdevices%2Fdevices.h;h=e54c7a29130e7d651f2155d2c90f83acf6813993;hb=a6d16b71308f1badf4b362d26d2326a2977fe462;hp=b74e3713dfc0315b76ea19d4f992c068ea844702;hpb=26054ea1d1bad8d0d383bac59bfbe50912aee146;p=vpp.git diff --git a/src/vnet/devices/devices.h b/src/vnet/devices/devices.h index b74e3713dfc..e54c7a29130 100644 --- a/src/vnet/devices/devices.h +++ b/src/vnet/devices/devices.h @@ -16,7 +16,7 @@ #ifndef included_vnet_vnet_device_h #define included_vnet_vnet_device_h -#include +#include #include typedef enum @@ -27,17 +27,27 @@ typedef enum VNET_DEVICE_INPUT_NEXT_MPLS_INPUT, VNET_DEVICE_INPUT_NEXT_ETHERNET_INPUT, VNET_DEVICE_INPUT_NEXT_DROP, + + /* For tunnels */ + VNET_DEVICE_INPUT_NEXT_IP4_DROP, + VNET_DEVICE_INPUT_NEXT_IP6_DROP, + VNET_DEVICE_INPUT_NEXT_PUNT, + VNET_DEVICE_INPUT_N_NEXT_NODES, } vnet_device_input_next_t; -#define VNET_DEVICE_INPUT_NEXT_NODES { \ - [VNET_DEVICE_INPUT_NEXT_DROP] = "error-drop", \ - [VNET_DEVICE_INPUT_NEXT_ETHERNET_INPUT] = "ethernet-input", \ - [VNET_DEVICE_INPUT_NEXT_IP4_NCS_INPUT] = "ip4-input-no-checksum", \ - [VNET_DEVICE_INPUT_NEXT_IP4_INPUT] = "ip4-input", \ - [VNET_DEVICE_INPUT_NEXT_IP6_INPUT] = "ip6-input", \ - [VNET_DEVICE_INPUT_NEXT_MPLS_INPUT] = "mpls-input", \ -} +#define VNET_DEVICE_INPUT_NEXT_NODES \ + { \ + [VNET_DEVICE_INPUT_NEXT_DROP] = "error-drop", \ + [VNET_DEVICE_INPUT_NEXT_ETHERNET_INPUT] = "ethernet-input", \ + [VNET_DEVICE_INPUT_NEXT_IP4_NCS_INPUT] = "ip4-input-no-checksum", \ + [VNET_DEVICE_INPUT_NEXT_IP4_INPUT] = "ip4-input", \ + [VNET_DEVICE_INPUT_NEXT_IP6_INPUT] = "ip6-input", \ + [VNET_DEVICE_INPUT_NEXT_MPLS_INPUT] = "mpls-input", \ + [VNET_DEVICE_INPUT_NEXT_IP4_DROP] = "ip4-drop", \ + [VNET_DEVICE_INPUT_NEXT_IP6_DROP] = "ip6-drop", \ + [VNET_DEVICE_INPUT_NEXT_PUNT] = "punt-dispatch", \ + } typedef struct { @@ -55,43 +65,10 @@ typedef struct uword next_worker_thread_index; } vnet_device_main_t; -typedef struct -{ - u32 hw_if_index; - u32 dev_instance; - u16 queue_id; - vnet_hw_interface_rx_mode mode; - u32 interrupt_pending; -} vnet_device_and_queue_t; - -typedef struct -{ - vnet_device_and_queue_t *devices_and_queues; - vlib_node_state_t enabled_node_state; -} vnet_device_input_runtime_t; - extern vnet_device_main_t vnet_device_main; extern vlib_node_registration_t device_input_node; extern const u32 device_input_next_node_advance[]; - -static inline void -vnet_hw_interface_set_input_node (vnet_main_t * vnm, u32 hw_if_index, - u32 node_index) -{ - vnet_hw_interface_t *hw = vnet_get_hw_interface (vnm, hw_if_index); - hw->input_node_index = node_index; -} - -void vnet_hw_interface_assign_rx_thread (vnet_main_t * vnm, u32 hw_if_index, - u16 queue_id, uword thread_index); -int vnet_hw_interface_unassign_rx_thread (vnet_main_t * vnm, u32 hw_if_index, - u16 queue_id); -int vnet_hw_interface_set_rx_mode (vnet_main_t * vnm, u32 hw_if_index, - u16 queue_id, - vnet_hw_interface_rx_mode mode); -int vnet_hw_interface_get_rx_mode (vnet_main_t * vnm, u32 hw_if_index, - u16 queue_id, - vnet_hw_interface_rx_mode * mode); +extern const u32 device_input_next_node_flags[]; static inline u64 vnet_get_aggregate_rx_packets (void) @@ -115,48 +92,6 @@ vnet_device_increment_rx_packets (u32 thread_index, u64 count) pwd->aggregate_rx_packets += count; } -static_always_inline vnet_device_and_queue_t * -vnet_get_device_and_queue (vlib_main_t * vm, vlib_node_runtime_t * node) -{ - vnet_device_input_runtime_t *rt = (void *) node->runtime_data; - return rt->devices_and_queues; -} - -static_always_inline uword -vnet_get_device_input_thread_index (vnet_main_t * vnm, u32 hw_if_index, - u16 queue_id) -{ - vnet_hw_interface_t *hw = vnet_get_hw_interface (vnm, hw_if_index); - ASSERT (queue_id < vec_len (hw->input_node_thread_index_by_queue)); - return hw->input_node_thread_index_by_queue[queue_id]; -} - -static_always_inline void -vnet_device_input_set_interrupt_pending (vnet_main_t * vnm, u32 hw_if_index, - u16 queue_id) -{ - vlib_main_t *vm; - vnet_hw_interface_t *hw; - vnet_device_input_runtime_t *rt; - vnet_device_and_queue_t *dq; - uword idx; - - hw = vnet_get_hw_interface (vnm, hw_if_index); - idx = vnet_get_device_input_thread_index (vnm, hw_if_index, queue_id); - vm = vlib_mains[idx]; - rt = vlib_node_get_runtime_data (vm, hw->input_node_index); - idx = hw->dq_runtime_index_by_queue[queue_id]; - dq = vec_elt_at_index (rt->devices_and_queues, idx); - dq->interrupt_pending = 1; - - vlib_node_set_interrupt_pending (vm, hw->input_node_index); -} - -#define foreach_device_and_queue(var,vec) \ - for (var = (vec); var < vec_end (vec); var++) \ - if (clib_smp_swap (&((var)->interrupt_pending), 0) || \ - var->mode == VNET_HW_INTERFACE_RX_MODE_POLLING) - #endif /* included_vnet_vnet_device_h */ /*