| 461 | } |
| 462 | |
| 463 | static int |
| 464 | wait_workers_to_join(int lcore, const rte_atomic32_t *count) |
| 465 | { |
| 466 | uint64_t cycles, print_cycles; |
| 467 | |
| 468 | RTE_SET_USED(count); |
| 469 | |
| 470 | print_cycles = cycles = rte_get_timer_cycles(); |
| 471 | while (rte_eal_get_lcore_state(lcore) != WAIT) { |
| 472 | uint64_t new_cycles = rte_get_timer_cycles(); |
| 473 | |
| 474 | if (new_cycles - print_cycles > rte_get_timer_hz()) { |
| 475 | dpaa2_evdev_dbg("\r%s: events %d", __func__, |
| 476 | rte_atomic32_read(count)); |
| 477 | print_cycles = new_cycles; |
| 478 | } |
| 479 | if (new_cycles - cycles > rte_get_timer_hz() * 10) { |
| 480 | dpaa2_evdev_info( |
| 481 | "%s: No schedules for seconds, deadlock (%d)", |
| 482 | __func__, |
| 483 | rte_atomic32_read(count)); |
| 484 | rte_event_dev_dump(evdev, stdout); |
| 485 | cycles = new_cycles; |
| 486 | return -1; |
| 487 | } |
| 488 | } |
| 489 | rte_eal_mp_wait_lcore(); |
| 490 | return 0; |
| 491 | } |
| 492 | |
| 493 | |
| 494 | static int |
no test coverage detected