4 #include <vlib/unix/unix.h>
5 #include <vnet/ethernet/ethernet.h>
6 #include <vnet/devices/devices.h>
7 #include <af_xdp/af_xdp.h>
9 #define AF_XDP_TX_RETRIES 5
11 static_always_inline void
12 af_xdp_device_output_free (vlib_main_t * vm, const vlib_node_runtime_t * node,
16 const u32 size = txq->cq.size;
17 const u32 mask = size - 1;
18 u32 bis[VLIB_FRAME_SIZE], *bi = bis;
20 u32 n = xsk_ring_cons__peek (&txq->cq, ARRAY_LEN (bis), &idx);
23 /* we rely on on casting addr (u64) -> bi (u32) to discard XSK offset below */
24 STATIC_ASSERT (BITS (bi[0]) + CLIB_LOG2_CACHE_LINE_BYTES <=
25 XSK_UNALIGNED_BUF_OFFSET_SHIFT, "wrong size");
26 ASSERT (mask == txq->cq.mask);
31 compl = xsk_ring_cons__comp_addr (&txq->cq, idx);
32 n = clib_min (n_free, size - (idx & mask));
39 #ifdef CLIB_HAVE_VEC256
40 u64x4 b0 = (*(u64x4u *) (compl + 0)) >> CLIB_LOG2_CACHE_LINE_BYTES;
41 u64x4 b1 = (*(u64x4u *) (compl + 4)) >> CLIB_LOG2_CACHE_LINE_BYTES;
42 /* permute 256-bit register so lower u32s of each buffer index are
43 * placed into lower 128-bits */
44 const u32x8 mask = { 0, 2, 4, 6, 1, 3, 5, 7 };
45 u32x8 b2 = u32x8_permute ((u32x8) b0, mask);
46 u32x8 b3 = u32x8_permute ((u32x8) b1, mask);
47 /* extract lower 128-bits and save them to the array of buffer indices */
48 *(u32x4u *) (bi + 0) = u32x8_extract_lo (b2);
49 *(u32x4u *) (bi + 4) = u32x8_extract_lo (b3);
51 bi[0] = compl[0] >> CLIB_LOG2_CACHE_LINE_BYTES;
52 bi[1] = compl[1] >> CLIB_LOG2_CACHE_LINE_BYTES;
53 bi[2] = compl[2] >> CLIB_LOG2_CACHE_LINE_BYTES;
54 bi[3] = compl[3] >> CLIB_LOG2_CACHE_LINE_BYTES;
55 bi[4] = compl[4] >> CLIB_LOG2_CACHE_LINE_BYTES;
56 bi[5] = compl[5] >> CLIB_LOG2_CACHE_LINE_BYTES;
57 bi[6] = compl[6] >> CLIB_LOG2_CACHE_LINE_BYTES;
58 bi[7] = compl[7] >> CLIB_LOG2_CACHE_LINE_BYTES;
67 bi[0] = compl[0] >> CLIB_LOG2_CACHE_LINE_BYTES;
68 ASSERT (vlib_buffer_is_known (vm, bi[0]) ==
69 VLIB_BUFFER_KNOWN_ALLOCATED);
77 compl = xsk_ring_cons__comp_addr (&txq->cq, 0);
83 xsk_ring_cons__release (&txq->cq, n_free);
84 vlib_buffer_free (vm, bis, n_free);
87 static_always_inline void
88 af_xdp_device_output_tx_db (vlib_main_t * vm,
89 const vlib_node_runtime_t * node,
91 af_xdp_txq_t * txq, const u32 n_tx)
95 xsk_ring_prod__submit (&txq->tx, n_tx);
97 if (!xsk_ring_prod__needs_wakeup (&txq->tx))
100 vlib_error_count (vm, node->node_index, AF_XDP_TX_ERROR_SENDTO_REQUIRED, 1);
102 ret = sendto (txq->xsk_fd, NULL, 0, MSG_DONTWAIT, NULL, 0);
103 if (PREDICT_TRUE (ret >= 0))
106 /* those errors are fine */
115 /* something bad is happening */
116 vlib_error_count (vm, node->node_index, AF_XDP_TX_ERROR_SENDTO_FAILURES, 1);
117 af_xdp_device_error (ad, "sendto() failed");
120 static_always_inline u32
121 af_xdp_device_output_tx_try (vlib_main_t * vm,
122 const vlib_node_runtime_t * node,
123 af_xdp_device_t * ad, af_xdp_txq_t * txq,
126 vlib_buffer_t *bufs[VLIB_FRAME_SIZE], **b = bufs;
127 const uword start = vm->buffer_main->buffer_mem_start;
128 const u32 size = txq->tx.size;
129 const u32 mask = size - 1;
130 struct xdp_desc *desc;
134 ASSERT (mask == txq->cq.mask);
136 n_tx = xsk_ring_prod__reserve (&txq->tx, n_tx, &idx);
138 /* if ring is full, do nothing */
139 if (PREDICT_FALSE (0 == n_tx))
142 vlib_get_buffers (vm, bi, bufs, n_tx);
144 desc = xsk_ring_prod__tx_desc (&txq->tx, idx);
145 n = clib_min (n_tx, size - (idx & mask));
152 vlib_prefetch_buffer_header (b[4], LOAD);
154 (sizeof (vlib_buffer_t) +
155 b[0]->current_data) << XSK_UNALIGNED_BUF_OFFSET_SHIFT;
156 addr = pointer_to_uword (b[0]) - start;
157 desc[0].addr = offset | addr;
158 desc[0].len = b[0]->current_length;
160 vlib_prefetch_buffer_header (b[5], LOAD);
162 (sizeof (vlib_buffer_t) +
163 b[1]->current_data) << XSK_UNALIGNED_BUF_OFFSET_SHIFT;
164 addr = pointer_to_uword (b[1]) - start;
165 desc[1].addr = offset | addr;
166 desc[1].len = b[1]->current_length;
168 vlib_prefetch_buffer_header (b[6], LOAD);
170 (sizeof (vlib_buffer_t) +
171 b[2]->current_data) << XSK_UNALIGNED_BUF_OFFSET_SHIFT;
172 addr = pointer_to_uword (b[2]) - start;
173 desc[2].addr = offset | addr;
174 desc[2].len = b[2]->current_length;
176 vlib_prefetch_buffer_header (b[7], LOAD);
178 (sizeof (vlib_buffer_t) +
179 b[3]->current_data) << XSK_UNALIGNED_BUF_OFFSET_SHIFT;
180 addr = pointer_to_uword (b[3]) - start;
181 desc[3].addr = offset | addr;
182 desc[3].len = b[3]->current_length;
192 (sizeof (vlib_buffer_t) +
193 b[0]->current_data) << XSK_UNALIGNED_BUF_OFFSET_SHIFT;
194 addr = pointer_to_uword (b[0]) - start;
195 desc[0].addr = offset | addr;
196 desc[0].len = b[0]->current_length;
204 desc = xsk_ring_prod__tx_desc (&txq->tx, 0);
213 VNET_DEVICE_CLASS_TX_FN (af_xdp_device_class) (vlib_main_t * vm,
214 vlib_node_runtime_t * node,
215 vlib_frame_t * frame)
217 af_xdp_main_t *rm = &af_xdp_main;
218 vnet_interface_output_runtime_t *ord = (void *) node->runtime_data;
219 af_xdp_device_t *ad = pool_elt_at_index (rm->devices, ord->dev_instance);
220 u32 thread_index = vm->thread_index;
221 af_xdp_txq_t *txq = vec_elt_at_index (ad->txqs, thread_index % ad->txq_num);
226 from = vlib_frame_vector_args (frame);
227 n_tx = frame->n_vectors;
229 clib_spinlock_lock_if_init (&txq->lock);
231 for (i = 0, n = 0; i < AF_XDP_TX_RETRIES && n < n_tx; i++)
234 af_xdp_device_output_free (vm, node, txq);
235 n_enq = af_xdp_device_output_tx_try (vm, node, ad, txq, n_tx - n, from);
240 af_xdp_device_output_tx_db (vm, node, ad, txq, n);
242 clib_spinlock_unlock_if_init (&txq->lock);
244 if (PREDICT_FALSE (n != n_tx))
246 vlib_buffer_free (vm, from + n, n_tx - n);
247 vlib_error_count (vm, node->node_index,
248 AF_XDP_TX_ERROR_NO_FREE_SLOTS, n_tx - n);
255 * fd.io coding-style-patch-verification: ON
258 * eval: (c-set-style "gnu")