| 5450 | |
| 5451 | |
| 5452 | static int |
| 5453 | latency_test_fft(struct rte_mempool *mempool, |
| 5454 | struct test_buffers *bufs, struct rte_bbdev_fft_op *ref_op, |
| 5455 | uint16_t dev_id, uint16_t queue_id, |
| 5456 | const uint16_t num_to_process, uint16_t burst_sz, |
| 5457 | uint64_t *total_time, uint64_t *min_time, uint64_t *max_time) |
| 5458 | { |
| 5459 | int ret = TEST_SUCCESS; |
| 5460 | uint16_t i, j, dequeued; |
| 5461 | struct rte_bbdev_fft_op *ops_enq[MAX_BURST], *ops_deq[MAX_BURST]; |
| 5462 | uint64_t start_time = 0, last_time = 0; |
| 5463 | |
| 5464 | for (i = 0, dequeued = 0; dequeued < num_to_process; ++i) { |
| 5465 | uint16_t enq = 0, deq = 0; |
| 5466 | uint32_t time_out = 0; |
| 5467 | bool first_time = true; |
| 5468 | last_time = 0; |
| 5469 | |
| 5470 | if (unlikely(num_to_process - dequeued < burst_sz)) |
| 5471 | burst_sz = num_to_process - dequeued; |
| 5472 | |
| 5473 | ret = rte_bbdev_fft_op_alloc_bulk(mempool, ops_enq, burst_sz); |
| 5474 | TEST_ASSERT_SUCCESS(ret, |
| 5475 | "rte_bbdev_fft_op_alloc_bulk() failed"); |
| 5476 | if (test_vector.op_type != RTE_BBDEV_OP_NONE) |
| 5477 | copy_reference_fft_op(ops_enq, burst_sz, dequeued, |
| 5478 | bufs->inputs, |
| 5479 | bufs->hard_outputs, bufs->soft_outputs, bufs->harq_inputs, |
| 5480 | ref_op); |
| 5481 | |
| 5482 | /* Set counter to validate the ordering */ |
| 5483 | for (j = 0; j < burst_sz; ++j) |
| 5484 | ops_enq[j]->opaque_data = (void *)(uintptr_t)j; |
| 5485 | |
| 5486 | start_time = rte_rdtsc_precise(); |
| 5487 | |
| 5488 | enq = rte_bbdev_enqueue_fft_ops(dev_id, queue_id, |
| 5489 | &ops_enq[enq], burst_sz); |
| 5490 | TEST_ASSERT(enq == burst_sz, |
| 5491 | "Error enqueueing burst, expected %u, got %u", |
| 5492 | burst_sz, enq); |
| 5493 | |
| 5494 | /* Dequeue */ |
| 5495 | do { |
| 5496 | deq += rte_bbdev_dequeue_fft_ops(dev_id, queue_id, |
| 5497 | &ops_deq[deq], burst_sz - deq); |
| 5498 | if (likely(first_time && (deq > 0))) { |
| 5499 | last_time += rte_rdtsc_precise() - start_time; |
| 5500 | first_time = false; |
| 5501 | } |
| 5502 | time_out++; |
| 5503 | if (time_out >= TIME_OUT_POLL) { |
| 5504 | timeout_exit(dev_id); |
| 5505 | TEST_ASSERT_SUCCESS(TEST_FAILED, "Dequeue timeout!"); |
| 5506 | } |
| 5507 | } while (unlikely(burst_sz != deq)); |
| 5508 | |
| 5509 | *max_time = RTE_MAX(*max_time, last_time); |
no test coverage detected