Lines Matching refs:work
45 struct k_work_delayable work; member
50 struct k_work_poll work; member
80 struct k_work_poll work; member
88 static void work_handler(struct k_work *work) in work_handler() argument
90 struct k_work_delayable *dwork = k_work_delayable_from_work(work); in work_handler()
92 CONTAINER_OF(dwork, struct delayed_test_item, work); in work_handler()
110 k_work_init_delayable(&delayed_tests[i].work, work_handler); in delayed_test_items_init()
138 k_work_schedule(&delayed_tests[i].work, K_NO_WAIT); in coop_work_main()
157 k_work_schedule(&delayed_tests[i].work, K_NO_WAIT); in delayed_test_items_submit()
203 static void resubmit_work_handler(struct k_work *work) in resubmit_work_handler() argument
205 struct k_work_delayable *dwork = k_work_delayable_from_work(work); in resubmit_work_handler()
207 CONTAINER_OF(dwork, struct delayed_test_item, work); in resubmit_work_handler()
216 k_work_submit(work); in resubmit_work_handler()
231 k_work_init_delayable(&delayed_tests[0].work, resubmit_work_handler); in ZTEST()
234 k_work_schedule(&delayed_tests[0].work, K_NO_WAIT); in ZTEST()
244 static void delayed_work_handler(struct k_work *work) in delayed_work_handler() argument
246 struct k_work_delayable *dwork = k_work_delayable_from_work(work); in delayed_work_handler()
248 CONTAINER_OF(dwork, struct delayed_test_item, work); in delayed_work_handler()
268 k_work_init_delayable(&delayed_tests[i].work, in test_delayed_init()
287 k_work_schedule(&delayed_tests[i].work, in coop_delayed_work_main()
310 zassert_true(k_work_reschedule(&delayed_tests[i].work, in test_delayed_submit()
322 k_work_schedule(&delayed_tests[1].work, K_MSEC(WORK_ITEM_WAIT)); in coop_delayed_work_cancel_main()
325 k_work_cancel_delayable(&delayed_tests[1].work); in coop_delayed_work_cancel_main()
340 k_work_schedule(&delayed_tests[0].work, K_MSEC(WORK_ITEM_WAIT)); in ZTEST()
343 k_work_cancel_delayable(&delayed_tests[0].work); in ZTEST()
361 k_work_init_delayable(&delayed_tests[0].work, delayed_work_handler); in ZTEST()
363 zassert_false(k_work_delayable_is_pending(&delayed_tests[0].work)); in ZTEST()
366 k_work_schedule(&delayed_tests[0].work, K_NO_WAIT); in ZTEST()
367 zassert_true(k_work_delayable_is_pending(&delayed_tests[0].work)); in ZTEST()
370 zassert_false(k_work_delayable_is_pending(&delayed_tests[0].work)); in ZTEST()
377 k_work_schedule(&delayed_tests[0].work, K_MSEC(WORK_ITEM_WAIT)); in ZTEST()
378 zassert_true(k_work_delayable_is_pending(&delayed_tests[0].work)); in ZTEST()
381 zassert_false(k_work_delayable_is_pending(&delayed_tests[0].work)); in ZTEST()
413 static void triggered_work_handler(struct k_work *work) in triggered_work_handler() argument
415 struct k_work_poll *pwork = CONTAINER_OF(work, struct k_work_poll, work); in triggered_work_handler()
417 CONTAINER_OF(pwork, struct triggered_test_item, work); in triggered_work_handler()
421 zassert_equal(ti->work.poll_result, expected_poll_result, in triggered_work_handler()
422 "res %d expect %d", ti->work.poll_result, expected_poll_result); in triggered_work_handler()
440 k_work_poll_init(&triggered_tests[i].work, in test_triggered_init()
464 zassert_true(k_work_poll_submit(&triggered_tests[i].work, in test_triggered_submit()
548 static void triggered_resubmit_work_handler(struct k_work *work) in triggered_resubmit_work_handler() argument
550 struct k_work_poll *pwork = CONTAINER_OF(work, struct k_work_poll, work); in triggered_resubmit_work_handler()
552 CONTAINER_OF(pwork, struct triggered_test_item, work); in triggered_resubmit_work_handler()
561 zassert_true(k_work_poll_submit(&triggered_tests[0].work, in triggered_resubmit_work_handler()
584 k_work_poll_init(&triggered_tests[0].work, in ZTEST()
594 zassert_true(k_work_poll_submit(&triggered_tests[0].work, in ZTEST()
745 static void triggered_from_msgq_work_handler(struct k_work *work) in triggered_from_msgq_work_handler() argument
766 k_work_poll_init(&ctx->work, triggered_from_msgq_work_handler); in test_triggered_from_msgq_init()
773 k_work_poll_submit_to_queue(&ctx->msg_consumer_workq, &ctx->work, in test_triggered_from_msgq_init()
853 ret = k_work_poll_cancel(&triggered_tests[0].work); in ZTEST()
856 ret = k_work_poll_cancel(&triggered_tests[0].work); in ZTEST()