mirror/xdp-project-bpf-examples
1
0
Fork 0
mirror of https://github.com/xdp-project/bpf-examples.git synced 2024-05-06 15:54:53 +00:00
Code Issues Projects Releases Wiki Activity

AF_XDP-interaction: Move invent_tx_pkts() out of tx_batch_pkts

Browse Source 
Signed-off-by: Jesper Dangaard Brouer <brouer@redhat.com>
This commit is contained in:
Jesper Dangaard Brouer
2021-12-13 18:25:58 +01:00
parent 56ba3a10df
commit 1750679402
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
AF_XDP-interaction/af_xdp_user.c
View File

@@ -835,15 +835,13 @@ static int invent_tx_pkts(struct xsk_umem_info *umem,
return i; return i;
} }
static int tx_batch_pkts(struct xsk_socket_info *xsk, const unsigned int n) static int tx_batch_pkts(struct xsk_socket_info *xsk,
const unsigned int nr, struct xdp_desc pkts[nr])
{ {
struct xsk_umem_info *umem = xsk->umem; struct xsk_umem_info *umem = xsk->umem;
struct xdp_desc pkts[n];
uint32_t tx_res; uint32_t tx_res;
uint32_t tx_idx = 0; uint32_t tx_idx = 0;
int i, nr; int i;
nr = invent_tx_pkts(umem, n, pkts);
tx_res = xsk_ring_prod__reserve(&xsk->tx, nr, &tx_idx); tx_res = xsk_ring_prod__reserve(&xsk->tx, nr, &tx_idx);
if (tx_res != nr) { if (tx_res != nr) {
@@ -987,15 +985,17 @@ void restock_receive_fill_queue(struct xsk_socket_info *xsk)
static void handle_receive_packets(struct xsk_socket_info *xsk) static void handle_receive_packets(struct xsk_socket_info *xsk)
{ {
struct xdp_desc tx_pkts[4];
unsigned int rcvd, i; unsigned int rcvd, i;
uint32_t idx_rx = 0; uint32_t idx_rx = 0;
int tx_nr;
rcvd = xsk_ring_cons__peek(&xsk->rx, RX_BATCH_SIZE, &idx_rx); rcvd = xsk_ring_cons__peek(&xsk->rx, RX_BATCH_SIZE, &idx_rx);
if (!rcvd) if (!rcvd)
return; return;
//tx_pkt(xsk); tx_nr = invent_tx_pkts(xsk->umem, 4, tx_pkts);
tx_batch_pkts(xsk, 4); tx_batch_pkts(xsk, tx_nr, tx_pkts);
/* Process received packets */ /* Process received packets */
for (i = 0; i < rcvd; i++) { for (i = 0; i < rcvd; i++) {