FD.io VPP  v21.01.1
Vector Packet Processing
common.c
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2017 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 <vnet/vnet.h>
17 #include <vppinfra/vec.h>
18 #include <vppinfra/format.h>
19 #include <assert.h>
20 
21 #include <vnet/ip/ip.h>
22 #include <vnet/ethernet/ethernet.h>
24 #include <dpdk/buffer.h>
25 #include <dpdk/device/dpdk.h>
26 #include <dpdk/device/dpdk_priv.h>
27 #include <vppinfra/error.h>
28 
29 void
30 dpdk_device_error (dpdk_device_t * xd, char *str, int rv)
31 {
32  dpdk_log_err ("Interface %U error %d: %s",
33  format_dpdk_device_name, xd->port_id, rv, rte_strerror (rv));
34  xd->errors = clib_error_return (xd->errors, "%s[port:%d, errno:%d]: %s",
35  str, xd->port_id, rv, rte_strerror (rv));
36 }
37 
38 void
40 {
41  dpdk_main_t *dm = &dpdk_main;
43  vnet_main_t *vnm = vnet_get_main ();
47  struct rte_eth_dev_info dev_info;
48  u64 bitmap;
49  int rv;
50  int j;
51 
52  ASSERT (vlib_get_thread_index () == 0);
53 
54  clib_error_free (xd->errors);
56 
57  if (xd->flags & DPDK_DEVICE_FLAG_ADMIN_UP)
58  {
60  dpdk_device_stop (xd);
61  }
62 
63  /* Enable flow director when flows exist */
64  if (xd->pmd == VNET_DPDK_PMD_I40E)
65  {
66  if ((xd->flags & DPDK_DEVICE_FLAG_RX_FLOW_OFFLOAD) != 0)
67  xd->port_conf.fdir_conf.mode = RTE_FDIR_MODE_PERFECT;
68  else
69  xd->port_conf.fdir_conf.mode = RTE_FDIR_MODE_NONE;
70  }
71 
72  rte_eth_dev_info_get (xd->port_id, &dev_info);
73 
74  bitmap = xd->port_conf.txmode.offloads & ~dev_info.tx_offload_capa;
75  if (bitmap)
76  {
77  dpdk_log_warn ("unsupported tx offloads requested on port %u: %U",
79  xd->port_conf.txmode.offloads ^= bitmap;
80  }
81 
82  bitmap = xd->port_conf.rxmode.offloads & ~dev_info.rx_offload_capa;
83  if (bitmap)
84  {
85  dpdk_log_warn ("unsupported rx offloads requested on port %u: %U",
87  xd->port_conf.rxmode.offloads ^= bitmap;
88  }
89 
90  rv = rte_eth_dev_configure (xd->port_id, xd->rx_q_used,
91  xd->tx_q_used, &xd->port_conf);
92 
93  if (rv < 0)
94  {
95  dpdk_device_error (xd, "rte_eth_dev_configure", rv);
96  goto error;
97  }
98 
101  for (j = 0; j < xd->tx_q_used; j++)
102  {
103  rv =
104  rte_eth_tx_queue_setup (xd->port_id, j, xd->nb_tx_desc,
105  xd->cpu_socket, &xd->tx_conf);
106 
107  /* retry with any other CPU socket */
108  if (rv < 0)
109  rv =
110  rte_eth_tx_queue_setup (xd->port_id, j,
111  xd->nb_tx_desc, SOCKET_ID_ANY,
112  &xd->tx_conf);
113  if (rv < 0)
114  dpdk_device_error (xd, "rte_eth_tx_queue_setup", rv);
115 
116  if (xd->tx_q_used < tm->n_vlib_mains)
117  clib_spinlock_init (&vec_elt (xd->tx_queues, j).lock);
118  }
119 
122  for (j = 0; j < xd->rx_q_used; j++)
123  {
126  xd->hw_if_index, j);
127  unsigned lcore = vlib_worker_threads[tidx].cpu_id;
128  u16 socket_id = rte_lcore_to_socket_id (lcore);
129  u8 bpidx = vlib_buffer_pool_get_default_for_numa (vm, socket_id);
130  vlib_buffer_pool_t *bp = vlib_get_buffer_pool (vm, bpidx);
131  struct rte_mempool *mp = dpdk_mempool_by_buffer_pool_index[bpidx];
132 
133  rv = rte_eth_rx_queue_setup (xd->port_id, j, xd->nb_rx_desc,
134  xd->cpu_socket, 0, mp);
135 
136  /* retry with any other CPU socket */
137  if (rv < 0)
138  rv = rte_eth_rx_queue_setup (xd->port_id, j, xd->nb_rx_desc,
139  SOCKET_ID_ANY, 0, mp);
140 
141  rxq->buffer_pool_index = bp->index;
142 
143  if (rv < 0)
144  dpdk_device_error (xd, "rte_eth_rx_queue_setup", rv);
145  }
146 
147  if (vec_len (xd->errors))
148  goto error;
149 
150  rte_eth_dev_set_mtu (xd->port_id, hi->max_packet_bytes);
151 
152  if (xd->flags & DPDK_DEVICE_FLAG_ADMIN_UP)
153  dpdk_device_start (xd);
154 
155  if (vec_len (xd->errors))
156  goto error;
157 
158  return;
159 
160 error:
161  xd->flags |= DPDK_DEVICE_FLAG_PMD_INIT_FAIL;
163 }
164 
165 void
167 {
168  int rv;
169 
170  if (xd->flags & DPDK_DEVICE_FLAG_PMD_INIT_FAIL)
171  return;
172 
173  rv = rte_eth_dev_start (xd->port_id);
174 
175  if (rv)
176  {
177  dpdk_device_error (xd, "rte_eth_dev_start", rv);
178  return;
179  }
180 
181  if (xd->default_mac_address)
182  rv = rte_eth_dev_default_mac_addr_set (xd->port_id,
183  (void *) xd->default_mac_address);
184 
185  if (rv)
186  dpdk_device_error (xd, "rte_eth_dev_default_mac_addr_set", rv);
187 
188  if (xd->flags & DPDK_DEVICE_FLAG_PROMISC)
189  rte_eth_promiscuous_enable (xd->port_id);
190  else
191  rte_eth_promiscuous_disable (xd->port_id);
192 
193  rte_eth_allmulticast_enable (xd->port_id);
194 
195  dpdk_log_info ("Interface %U started",
197 }
198 
199 void
201 {
202  if (xd->flags & DPDK_DEVICE_FLAG_PMD_INIT_FAIL)
203  return;
204 
205  rte_eth_allmulticast_disable (xd->port_id);
206  rte_eth_dev_stop (xd->port_id);
207  clib_memset (&xd->link, 0, sizeof (struct rte_eth_link));
208 
209  dpdk_log_info ("Interface %U stopped",
211 }
212 
213 void vl_api_force_rpc_call_main_thread (void *fp, u8 * data, u32 data_length);
214 
215 always_inline int
217  enum rte_eth_event_type type, void *param)
218 {
219  struct rte_eth_link link;
220 
221  RTE_SET_USED (param);
222  if (type != RTE_ETH_EVENT_INTR_LSC)
223  {
224  dpdk_log_info ("Unknown event %d received for port %d", type, port_id);
225  return -1;
226  }
227 
228  rte_eth_link_get_nowait (port_id, &link);
229  u8 link_up = link.link_status;
230  if (link_up)
231  dpdk_log_info ("Port %d Link Up - speed %u Mbps - %s",
232  port_id, (unsigned) link.link_speed,
233  (link.link_duplex == ETH_LINK_FULL_DUPLEX) ?
234  "full-duplex" : "half-duplex");
235  else
236  dpdk_log_info ("Port %d Link Down\n\n", port_id);
237 
238  return 0;
239 }
240 
241 int
243  enum rte_eth_event_type type,
244  void *param,
245  void *ret_param __attribute__ ((unused)))
246 {
247  return dpdk_port_state_callback_inline (port_id, type, param);
248 }
249 
250 /* If this device is PCI return pointer to info, otherwise NULL */
251 struct rte_pci_device *
252 dpdk_get_pci_device (const struct rte_eth_dev_info *info)
253 {
254  const struct rte_bus *bus;
255 
256  bus = rte_bus_find_by_device (info->device);
257  if (bus && !strcmp (bus->name, "pci"))
258  return RTE_DEV_TO_PCI (info->device);
259  else
260  return NULL;
261 }
262 
263 /*
264  * fd.io coding-style-patch-verification: ON
265  *
266  * Local Variables:
267  * eval: (c-set-style "gnu")
268  * End:
269  */
u8 * default_mac_address
Definition: dpdk.h:234
format_function_t format_dpdk_tx_offload_caps
Definition: dpdk.h:455
void vl_api_force_rpc_call_main_thread(void *fp, u8 *data, u32 data_length)
Definition: vlib_api.c:630
dpdk_main_t dpdk_main
Definition: init.c:47
vnet_main_t * vnet_get_main(void)
Definition: misc.c:46
unsigned long u64
Definition: types.h:89
u32 sw_if_index
Definition: dpdk.h:185
static_always_inline vlib_buffer_pool_t * vlib_get_buffer_pool(vlib_main_t *vm, u8 buffer_pool_index)
Definition: buffer_funcs.h:521
u8 buffer_pool_index
Definition: dpdk.h:165
clib_memset(h->entries, 0, sizeof(h->entries[0]) *entries)
struct rte_pci_device * dpdk_get_pci_device(const struct rte_eth_dev_info *info)
Definition: common.c:252
u16 flags
Definition: dpdk.h:192
static vnet_hw_interface_t * vnet_get_hw_interface(vnet_main_t *vnm, u32 hw_if_index)
clib_error_t * errors
Definition: dpdk.h:237
static vnet_sw_interface_t * vnet_get_sw_interface(vnet_main_t *vnm, u32 sw_if_index)
vlib_main_t * vm
Definition: in2out_ed.c:1580
int dpdk_port_state_callback(dpdk_portid_t port_id, enum rte_eth_event_type type, void *param, void *ret_param)
Definition: common.c:242
#define vec_validate_aligned(V, I, A)
Make sure vector is long enough for given index (no header, specified alignment)
Definition: vec.h:520
clib_error_t * vnet_hw_interface_set_flags(vnet_main_t *vnm, u32 hw_if_index, vnet_hw_interface_flags_t flags)
Definition: interface.c:509
unsigned char u8
Definition: types.h:56
u8 data[128]
Definition: ipsec_types.api:90
#define dpdk_log_warn(...)
Definition: dpdk.h:409
dpdk_portid_t port_id
Definition: dpdk.h:195
#define vec_elt_at_index(v, i)
Get vector value at index i checking that i is in bounds.
#define clib_error_return(e, args...)
Definition: error.h:99
u16 rx_q_used
Definition: dpdk.h:190
unsigned int u32
Definition: types.h:88
void dpdk_device_setup(dpdk_device_t *xd)
Definition: common.c:39
struct rte_eth_conf port_conf
Definition: dpdk.h:210
static void clib_spinlock_init(clib_spinlock_t *p)
Definition: lock.h:65
struct rte_eth_txconf tx_conf
Definition: dpdk.h:211
Definition: cJSON.c:84
vlib_worker_thread_t * vlib_worker_threads
Definition: threads.c:34
void dpdk_device_start(dpdk_device_t *xd)
Definition: common.c:166
static_always_inline uword vnet_get_device_input_thread_index(vnet_main_t *vnm, u32 hw_if_index, u16 queue_id)
Definition: devices.h:118
unsigned short u16
Definition: types.h:57
#define always_inline
Definition: ipsec.h:28
vnet_sw_interface_flags_t flags
Definition: interface.h:739
dpdk_tx_queue_t * tx_queues
Definition: dpdk.h:179
u16 tx_q_used
Definition: dpdk.h:191
u16 nb_rx_desc
Definition: dpdk.h:201
uint16_t dpdk_portid_t
Definition: dpdk.h:127
#define dpdk_log_info(...)
Definition: dpdk.h:413
u32 hw_if_index
Definition: dpdk.h:184
static_always_inline uword vlib_get_thread_index(void)
Definition: threads.h:219
#define dpdk_log_err(...)
Definition: dpdk.h:407
dpdk_pmd_t pmd
Definition: dpdk.h:196
static int dpdk_port_state_callback_inline(dpdk_portid_t port_id, enum rte_eth_event_type type, void *param)
Definition: common.c:216
void dpdk_device_stop(dpdk_device_t *xd)
Definition: common.c:200
void dpdk_device_error(dpdk_device_t *xd, char *str, int rv)
Definition: common.c:30
#define ASSERT(truth)
format_function_t format_dpdk_device_name
Definition: dpdk.h:445
struct rte_eth_link link
Definition: dpdk.h:224
static vlib_main_t * vlib_get_main(void)
Definition: global_funcs.h:23
vl_api_ip4_address_t hi
Definition: arp.api:37
#define vec_elt(v, i)
Get vector value at index i.
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
u64 uword
Definition: types.h:112
format_function_t format_dpdk_rx_offload_caps
Definition: dpdk.h:454
#define clib_error_free(e)
Definition: error.h:86
static vlib_thread_main_t * vlib_get_thread_main()
Definition: global_funcs.h:32
i8 cpu_socket
Definition: dpdk.h:197
dpdk_rx_queue_t * rx_queues
Definition: dpdk.h:178
struct rte_mempool ** dpdk_mempool_by_buffer_pool_index
Definition: buffer.c:33
u8 bus
Definition: pci_types.api:21
#define CLIB_CACHE_LINE_BYTES
Definition: cache.h:59
vnet_main_t * vnet_main
Definition: dpdk.h:348
u16 nb_tx_desc
Definition: dpdk.h:200
static u8 vlib_buffer_pool_get_default_for_numa(vlib_main_t *vm, u32 numa_node)
Definition: buffer_funcs.h:199
CLIB vectors are ubiquitous dynamically resized arrays with by user defined "headers".