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: packet TX test

Browse Source 
Signed-off-by: Jesper Dangaard Brouer <brouer@redhat.com>
This commit is contained in:
Jesper Dangaard Brouer
2021-12-03 21:35:02 +01:00
parent 25e8873f2f
commit ea8b2df6aa
1 changed files with 34 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
AF_XDP-interaction/af_xdp_user.c
View File

@@ -566,7 +566,7 @@ static void gen_ip_hdr(struct iphdr *ip_hdr)
ip_hdr->check = ip_fast_csum((const void *)ip_hdr, ip_hdr->ihl);
}
static uint32_t opt_pkt_fill_pattern = 0x2a2b2c2d;
static uint32_t opt_pkt_fill_pattern = 0x41424344;
static void gen_udp_hdr(struct udphdr *udp_hdr, struct iphdr *ip_hdr)
{
@@ -580,6 +580,15 @@ static void gen_udp_hdr(struct udphdr *udp_hdr, struct iphdr *ip_hdr)
opt_pkt_fill_pattern,
UDP_PKT_DATA_SIZE);
if (0) {
uint8_t *p = udp_hdr + sizeof(struct udphdr);
int i;
for (i = 0; i < UDP_PKT_DATA_SIZE; i++) {
printf("i[%d] = %c\n", i, p[i]);
}
}
/* UDP header checksum */
udp_hdr->check = 0;
udp_hdr->check = udp_csum(ip_hdr->saddr, ip_hdr->daddr, UDP_PKT_SIZE,
@@ -757,6 +766,9 @@ static void print_pkt_info(uint8_t *pkt, uint32_t len)
}
}
static void tx_pkt(struct config *cfg,
struct xsk_socket_info *xsk);
static bool process_packet(struct xsk_socket_info *xsk,
uint64_t addr, uint32_t len)
{
@@ -931,6 +943,7 @@ static void rx_and_process(struct config *cfg,
//printf("XXX i[%d] queue:%d xsk_info:%p \n",
// i, xsk_info->queue_id, xsk_info);
tx_pkt(cfg, xsk_info);
handle_receive_packets(xsk_info);
}
}
@@ -957,7 +970,7 @@ static void tx_pkt(struct config *cfg,
struct xsk_umem_info *umem = xsk->umem;
uint64_t pkt_addr = mem_alloc_umem_frame(&umem->mem);
uint8_t *pkt = NULL;
uint32_t offset = 256;
uint32_t offset = 0; // 256;
pkt_addr += offset;
pr_addr_info(__func__, pkt_addr, umem);
@@ -965,7 +978,22 @@ static void tx_pkt(struct config *cfg,
pkt = xsk_umem__get_data(umem->buffer, pkt_addr);
gen_base_pkt(pkt);
mem_free_umem_frame(&umem->mem, pkt_addr);
{
uint32_t tx_idx = 0;
int ret;
ret = xsk_ring_prod__reserve(&xsk->tx, 1, &tx_idx);
if (ret != 1) {
/* No more transmit slots, drop the packet */
mem_free_umem_frame(&umem->mem, pkt_addr);
}
xsk_ring_prod__tx_desc(&xsk->tx, tx_idx)->addr = pkt_addr;
xsk_ring_prod__tx_desc(&xsk->tx, tx_idx)->len = 64;
xsk_ring_prod__submit(&xsk->tx, 1);
xsk->outstanding_tx++;
}
//complete_tx(xsk);
}
static double calc_period(struct stats_record *r, struct stats_record *p)
@@ -1253,7 +1281,9 @@ int main(int argc, char **argv)
cfg.sched_prio, cfg.sched_policy);
}
tx_pkt(&cfg, xsks.sockets[0]);
//sleep(3);
// tx_pkt(&cfg, xsks.sockets[0]);
/* Receive and count packets than drop them */
rx_and_process(&cfg, &xsks);