Commit ee44416d authored by Luis Ubieda's avatar Luis Ubieda Committed by Daniel DeGrasse
Browse files

tests: rtio: workq: Add test-case for same-prio items 



Processed on separate worker threads. This test is expected to fail
as the P4WQ limits the number of active items assigned to worker
threads to the number of CPU cores the system has.

Signed-off-by: default avatarLuis Ubieda <luisf@croxel.com>
parent 3e9eea2c

tests/subsys/rtio/workq/src/main.c

+33 −0
Original line number Diff line number Diff line
@@ -128,6 +128,39 @@ ZTEST(rtio_work, test_work_supports_batching_submissions) 
	rtio_cqe_release(&r_test, cqe);

}



ZTEST(rtio_work, test_work_supports_working_same_prio_items_on_separate_threads)

{

	struct rtio_sqe *sqe_a;

	struct rtio_sqe *sqe_b;

	struct rtio_cqe *cqe;



	sqe_a = rtio_sqe_acquire(&r_test);

	rtio_sqe_prep_nop(sqe_a, &dummy_iodev, &work_handler_sem_1);

	sqe_a->prio = RTIO_PRIO_NORM;



	sqe_b = rtio_sqe_acquire(&r_test_2);

	rtio_sqe_prep_nop(sqe_b, &dummy_iodev_2, &work_handler_sem_2);

	sqe_b->prio = RTIO_PRIO_NORM;



	zassert_ok(rtio_submit(&r_test, 0));

	zassert_ok(rtio_submit(&r_test_2, 0));



	zassert_equal(2, work_handler_called);

	zassert_equal(2, rtio_work_req_used_count_get());



	k_sem_give(&work_handler_sem_1);

	k_sem_give(&work_handler_sem_2);



	zassert_equal(2, work_handler_called);

	zassert_equal(0, rtio_work_req_used_count_get());



	/** Clean-up */

	cqe = rtio_cqe_consume_block(&r_test);

	rtio_cqe_release(&r_test, cqe);

	cqe = rtio_cqe_consume_block(&r_test_2);

	rtio_cqe_release(&r_test_2, cqe);

}



ZTEST(rtio_work, test_work_supports_preempting_on_higher_prio_submissions)

{

	struct rtio_sqe *sqe_a;

CRA Git | Maintained and supported by SUSTech CRA and CCSE