/foundation/resourceschedule/ffrt/interfaces/inner_api/c/ |
H A D | queue_ext.h | 49 FFRT_C_API void ffrt_queue_submit_head(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr);
62 ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr);
72 FFRT_C_API bool ffrt_queue_has_task(ffrt_queue_t queue, const char* name);
80 FFRT_C_API void ffrt_queue_cancel_all(ffrt_queue_t queue);
88 FFRT_C_API void ffrt_queue_cancel_and_wait(ffrt_queue_t queue);
99 FFRT_C_API int ffrt_queue_cancel_by_name(ffrt_queue_t queue, const char* name);
108 FFRT_C_API bool ffrt_queue_is_idle(ffrt_queue_t queue);
123 FFRT_C_API int ffrt_queue_dump(ffrt_queue_t queue, const char* tag, char* buf, uint32_t len, bool history_info);
134 FFRT_C_API int ffrt_queue_size_dump(ffrt_queue_t queue, ffrt_inner_queue_priority_t priority);
143 FFRT_C_API void ffrt_queue_set_eventhandler(ffrt_queue_t queu [all...] |
/foundation/resourceschedule/ffrt/interfaces/kits/c/ |
H A D | queue.h | 48 typedef void* ffrt_queue_t; typedef 161 FFRT_C_API ffrt_queue_t ffrt_queue_create(ffrt_queue_type_t type, const char* name, const ffrt_queue_attr_t* attr); 170 FFRT_C_API void ffrt_queue_destroy(ffrt_queue_t queue); 181 FFRT_C_API void ffrt_queue_submit(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr); 195 ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr); 224 FFRT_C_API ffrt_queue_t ffrt_get_main_queue(); 233 FFRT_C_API ffrt_queue_t ffrt_get_current_queue();
|
H A D | loop.h | 33 FFRT_C_API ffrt_loop_t ffrt_loop_create(ffrt_queue_t queue);
|
/foundation/resourceschedule/ffrt/src/queue/ |
H A D | queue_api.cpp | 36 inline QueueTask* ffrt_queue_submit_base(ffrt_queue_t queue, ffrt_function_header_t* f, bool withHandle, in ffrt_queue_submit_base() 145 ffrt_queue_t ffrt_queue_create(ffrt_queue_type_t type, const char* name, const ffrt_queue_attr_t* attr) in ffrt_queue_create() 152 return static_cast<ffrt_queue_t>(handler); in ffrt_queue_create() 156 void ffrt_queue_destroy(ffrt_queue_t queue) in ffrt_queue_destroy() 164 void ffrt_queue_submit(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) in ffrt_queue_submit() 172 void ffrt_queue_submit_head(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) in ffrt_queue_submit_head() 180 ffrt_task_handle_t ffrt_queue_submit_h(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) in ffrt_queue_submit_h() 189 ffrt_task_handle_t ffrt_queue_submit_head_h(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) in ffrt_queue_submit_head_h() 217 void ffrt_queue_cancel_all(ffrt_queue_t queue) in ffrt_queue_cancel_all() 225 void ffrt_queue_cancel_and_wait(ffrt_queue_t queu [all...] |
/foundation/resourceschedule/ffrt/test/ut/testcase/ |
H A D | ut_loop.cpp | 88 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); in HWTEST_F() 109 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_concurrent, "test_queue", &queue_attr); in HWTEST_F() 134 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_concurrent, "test_queue", &queue_attr); in HWTEST_F() 187 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_concurrent, "test_queue", &queue_attr); in HWTEST_F() 232 ffrt_queue_t queue_handle = ffrt_queue_create( in HWTEST_F() 241 ffrt_queue_t mainQueue = ffrt_get_main_queue(); in HWTEST_F()
|
H A D | ut_queue.cpp | 97 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); in HWTEST_F() 136 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_max, nullptr, nullptr); in HWTEST_F() 193 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); in HWTEST_F() 217 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); in HWTEST_F() 258 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); in HWTEST_F() 286 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); 344 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); 373 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); 391 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); 407 ffrt_queue_t queue_handl [all...] |
H A D | ut_queue_dump.cpp | 65 static void QueueDumpTask1Test(ffrt_queue_t& queue_handle, char* buf) in QueueDumpTask1Test() 106 static void QueueDumpTask2Test(ffrt_queue_t& queue_handle, char* buf) in QueueDumpTask2Test() 148 static void QueueDumpTask3Test(ffrt_queue_t& queue_handle, char* buf) in QueueDumpTask3Test() 183 static void QueueDumpPriorityTest(ffrt_queue_t& queue_handle, ffrt_task_attr_t& task_attr, in QueueDumpPriorityTest() 194 static void QueueDumpPriorityTest(ffrt_queue_t& queue_handle, char* buf) in QueueDumpPriorityTest() 243 static void QueueDumpMaxDumpSizeTest(ffrt_queue_t& queue_handle, char* buf) in QueueDumpMaxDumpSizeTest() 268 ffrt_queue_t queue_handle = ffrt_queue_create(static_cast<ffrt_queue_type_t>(ffrt_queue_eventhandler_adapter), in HWTEST_F()
|
H A D | ut_dfx.cpp | 142 ffrt_queue_t queue_handle = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr); in HWTEST_F() 144 ffrt_queue_t queue_handle2 = ffrt_queue_create(ffrt_queue_serial, "test_queue", &queue_attr2); in HWTEST_F()
|
/foundation/resourceschedule/ffrt/src/eu/ |
H A D | loop_api.cpp | 25 ffrt_loop_t ffrt_loop_create(ffrt_queue_t queue) in ffrt_loop_create()
|
/foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
H A D | queue.h | 215 ffrt_queue_t queue_handle = nullptr;
|
/foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/ |
H A D | plugin_mgr.cpp | 786 ffrt_queue_cancel_all(*reinterpret_cast<ffrt_queue_t*>(dispatchers_[pluginLib].get()));
in EnablePluginIfResume() 802 ffrt_queue_cancel_all(*reinterpret_cast<ffrt_queue_t*>(dispatchers_[pluginLib].get()));
in HandlePluginTimeout()
|