| 552 | } |
| 553 | |
| 554 | static int |
| 555 | worker_multi_port_fn(void *arg) |
| 556 | { |
| 557 | struct test_core_param *param = arg; |
| 558 | struct rte_event ev; |
| 559 | uint16_t valid_event; |
| 560 | uint8_t port = param->port; |
| 561 | rte_atomic32_t *total_events = param->total_events; |
| 562 | int ret; |
| 563 | |
| 564 | while (rte_atomic32_read(total_events) > 0) { |
| 565 | valid_event = rte_event_dequeue_burst(evdev, port, &ev, 1, 0); |
| 566 | if (!valid_event) |
| 567 | continue; |
| 568 | |
| 569 | ret = validate_event(&ev); |
| 570 | RTE_TEST_ASSERT_SUCCESS(ret, "Failed to validate event"); |
| 571 | rte_pktmbuf_free(ev.mbuf); |
| 572 | rte_atomic32_sub(total_events, 1); |
| 573 | } |
| 574 | return 0; |
| 575 | } |
| 576 | |
| 577 | static inline int |
| 578 | wait_workers_to_join(int lcore, const rte_atomic32_t *count) |
nothing calls this directly
no test coverage detected