| 438 | } |
| 439 | |
| 440 | static int |
| 441 | worker_multi_port_fn(void *arg) |
| 442 | { |
| 443 | struct test_core_param *param = arg; |
| 444 | struct rte_event ev; |
| 445 | uint16_t valid_event; |
| 446 | uint8_t port = param->port; |
| 447 | rte_atomic32_t *total_events = param->total_events; |
| 448 | int ret; |
| 449 | |
| 450 | while (rte_atomic32_read(total_events) > 0) { |
| 451 | valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); |
| 452 | if (!valid_event) |
| 453 | continue; |
| 454 | |
| 455 | ret = validate_event(&ev); |
| 456 | RTE_TEST_ASSERT_SUCCESS(ret, "Failed to validate event"); |
| 457 | rte_pktmbuf_free(ev.mbuf); |
| 458 | rte_atomic32_sub(total_events, 1); |
| 459 | } |
| 460 | return 0; |
| 461 | } |
| 462 | |
| 463 | static int |
| 464 | wait_workers_to_join(int lcore, const rte_atomic32_t *count) |
nothing calls this directly
no test coverage detected