Lines Matching refs:queue
16 #include "cpp/queue.h"
36 inline QueueTask* ffrt_queue_submit_base(ffrt_queue_t queue, ffrt_function_header_t* f, bool withHandle,
39 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return nullptr, "input invalid, queue == nullptr");
41 QueueHandler* handler = static_cast<QueueHandler*>(queue);
156 void ffrt_queue_destroy(ffrt_queue_t queue)
158 FFRT_COND_DO_ERR((queue == nullptr), return, "input invalid, queue is nullptr");
159 QueueHandler* handler = static_cast<QueueHandler*>(queue);
164 void ffrt_queue_submit(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr)
167 QueueTask* task = ffrt_queue_submit_base(queue, f, false, false, attr);
172 void ffrt_queue_submit_head(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr)
175 QueueTask* task = ffrt_queue_submit_base(queue, f, false, true, attr);
180 ffrt_task_handle_t ffrt_queue_submit_h(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr)
183 QueueTask* task = ffrt_queue_submit_base(queue, f, true, false, attr);
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)
192 QueueTask* task = ffrt_queue_submit_base(queue, f, true, true, attr);
217 void ffrt_queue_cancel_all(ffrt_queue_t queue)
219 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return, "input invalid, queue is nullptr");
220 QueueHandler* handler = static_cast<QueueHandler*>(queue);
225 void ffrt_queue_cancel_and_wait(ffrt_queue_t queue)
227 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return, "input invalid, queue is nullptr");
228 QueueHandler* handler = static_cast<QueueHandler*>(queue);
233 int ffrt_queue_cancel_by_name(ffrt_queue_t queue, const char* name)
235 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return -1, "input invalid, queue is nullptr");
237 QueueHandler* handler = static_cast<QueueHandler*>(queue);
242 bool ffrt_queue_has_task(ffrt_queue_t queue, const char* name)
244 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return false, "input invalid, queue is nullptr");
246 QueueHandler* handler = static_cast<QueueHandler*>(queue);
251 bool ffrt_queue_is_idle(ffrt_queue_t queue)
253 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return false, "input invalid, queue is nullptr");
254 QueueHandler* handler = static_cast<QueueHandler*>(queue);
259 void ffrt_queue_set_eventhandler(ffrt_queue_t queue, void* eventhandler)
261 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return, "input invalid, queue is nullptr");
262 QueueHandler* handler = static_cast<QueueHandler*>(queue);
286 FFRT_COND_DO_ERR((mainHandler == nullptr), return nullptr, "failed to get main queue.");
300 FFRT_COND_DO_ERR((workerHandler == nullptr), return nullptr, "failed to get ArkTs worker queue.");
309 int ffrt_queue_dump(ffrt_queue_t queue, const char* tag, char* buf, uint32_t len, bool history_info)
311 FFRT_COND_DO_ERR((queue == nullptr), return -1, "input invalid, queue is nullptr");
313 QueueHandler* handler = static_cast<QueueHandler*>(queue);
318 int ffrt_queue_size_dump(ffrt_queue_t queue, ffrt_inner_queue_priority_t priority)
320 FFRT_COND_DO_ERR((queue == nullptr), return -1, "input invalid, queue is nullptr");
321 QueueHandler* handler = static_cast<QueueHandler*>(queue);