Lines Matching refs:queue
52 struct rt_workqueue *queue; in do_work_test() local
60 queue = rt_workqueue_create("test", 2048, curr_priority); in do_work_test()
61 if (queue == RT_NULL) in do_work_test()
67 err = rt_workqueue_submit_work(queue, &work, 0); in do_work_test()
75 rt_workqueue_destroy(queue); in do_work_test()
85 struct rt_workqueue *queue; in do_delay_work_test() local
94 queue = rt_workqueue_create("test", 2048, curr_priority); in do_delay_work_test()
95 if (queue == RT_NULL) in do_delay_work_test()
103 err = rt_workqueue_submit_work(queue, &work, 10); in do_delay_work_test()
114 rt_workqueue_destroy(queue); in do_delay_work_test()
124 struct rt_workqueue *queue; in cancle_work_test01() local
132 queue = rt_workqueue_create("test", 2048, curr_priority); in cancle_work_test01()
133 if (queue == RT_NULL) in cancle_work_test01()
141 err = rt_workqueue_submit_work(queue, &work, 0); in cancle_work_test01()
145 err = rt_workqueue_cancel_work(queue, &work); in cancle_work_test01()
152 rt_workqueue_destroy(queue); in cancle_work_test01()
162 struct rt_workqueue *queue; in cancle_work_test02() local
169 queue = rt_workqueue_create("test", 2048, curr_priority); in cancle_work_test02()
170 if (queue == RT_NULL) in cancle_work_test02()
177 err = rt_workqueue_submit_work(queue, &work, 0); in cancle_work_test02()
181 err = rt_workqueue_cancel_work(queue, &work); in cancle_work_test02()
185 rt_workqueue_destroy(queue); in cancle_work_test02()
195 struct rt_workqueue *queue; in cancle_work_test03() local
202 queue = rt_workqueue_create("test", 2048, curr_priority); in cancle_work_test03()
203 if (queue == RT_NULL) in cancle_work_test03()
210 err = rt_workqueue_submit_work(queue, &work, 0); in cancle_work_test03()
214 err = rt_workqueue_cancel_work(queue, &work); in cancle_work_test03()
218 rt_workqueue_destroy(queue); in cancle_work_test03()
229 struct rt_workqueue *queue; in cancle_work_test04() local
237 queue = rt_workqueue_create("test", 2048, curr_priority); in cancle_work_test04()
238 if (queue == RT_NULL) in cancle_work_test04()
244 err = rt_workqueue_submit_work(queue, &work, 0); in cancle_work_test04()
249 err = rt_workqueue_cancel_work_sync(queue, &work); in cancle_work_test04()
255 rt_workqueue_destroy(queue); in cancle_work_test04()
265 struct rt_workqueue *queue; in cancle_delay_work_test01() local
273 queue = rt_workqueue_create("test", 2048, curr_priority); in cancle_delay_work_test01()
274 if (queue == RT_NULL) in cancle_delay_work_test01()
281 err = rt_workqueue_submit_work(queue, &work, 20); in cancle_delay_work_test01()
286 err = rt_workqueue_cancel_work(queue, &work); in cancle_delay_work_test01()
293 rt_workqueue_destroy(queue); in cancle_delay_work_test01()
303 struct rt_workqueue *queue; in repeat_work_test01() local
311 queue = rt_workqueue_create("test01", 2048, curr_priority); in repeat_work_test01()
312 if (queue == RT_NULL) in repeat_work_test01()
320 err = rt_workqueue_submit_work(queue, &work, 0); in repeat_work_test01()
324 err = rt_workqueue_submit_work(queue, &work, 0); in repeat_work_test01()
334 rt_workqueue_destroy(queue); in repeat_work_test01()
345 struct rt_workqueue *queue; in repeat_work_test02() local
353 queue = rt_workqueue_create("test02", 2048, curr_priority); in repeat_work_test02()
354 if (queue == RT_NULL) in repeat_work_test02()
361 err = rt_workqueue_submit_work(queue, &work, 0); in repeat_work_test02()
366 err = rt_workqueue_submit_work(queue, &work, 0); in repeat_work_test02()
377 rt_workqueue_destroy(queue); in repeat_work_test02()
430 struct rt_workqueue *queue; in repeat_delay_work_test01() local
438 queue = rt_workqueue_create("test", 2048, curr_priority); in repeat_delay_work_test01()
439 if (queue == RT_NULL) in repeat_delay_work_test01()
447 err = rt_workqueue_submit_work(queue, &work, 20); in repeat_delay_work_test01()
453 err = rt_workqueue_submit_work(queue, &work, 20); in repeat_delay_work_test01()
464 rt_workqueue_destroy(queue); in repeat_delay_work_test01()
475 struct rt_workqueue *queue; in repeat_delay_work_test02() local
483 queue = rt_workqueue_create("test", 2048, curr_priority); in repeat_delay_work_test02()
484 if (queue == RT_NULL) in repeat_delay_work_test02()
492 err = rt_workqueue_submit_work(queue, &work, 20); in repeat_delay_work_test02()
497 err = rt_workqueue_submit_work(queue, &work, 20); in repeat_delay_work_test02()
509 rt_workqueue_destroy(queue); in repeat_delay_work_test02()
519 struct rt_workqueue *queue; in cancel_all_work_test() local
529 queue = rt_workqueue_create("test", 2048, curr_priority); in cancel_all_work_test()
530 if (queue == RT_NULL) in cancel_all_work_test()
541 err = rt_workqueue_submit_work(queue, &work1, 0); in cancel_all_work_test()
544 err = rt_workqueue_submit_work(queue, &work2, 0); in cancel_all_work_test()
547 err = rt_workqueue_submit_work(queue, &work3, 10); in cancel_all_work_test()
550 err = rt_workqueue_submit_work(queue, &work4, 10); in cancel_all_work_test()
553 err = rt_workqueue_cancel_all_work(queue); in cancel_all_work_test()
560 rt_workqueue_destroy(queue); in cancel_all_work_test()