Lines Matching refs:queue
36 inline QueueTask* ffrt_queue_submit_base(ffrt_queue_t queue, ffrt_function_header_t* f, bool withHa… in ffrt_queue_submit_base() argument
39 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return nullptr, "input invalid, queue == nullptr"); in ffrt_queue_submit_base()
41 QueueHandler* handler = static_cast<QueueHandler*>(queue); in ffrt_queue_submit_base()
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* …
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_ta…
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 ff…
192 QueueTask* task = ffrt_queue_submit_base(queue, f, true, true, attr);
206 uint64_t ffrt_queue_get_task_cnt(ffrt_queue_t queue)
208 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return 0, "input invalid, queue == nullptr");
209 QueueHandler* handler = static_cast<QueueHandler*>(queue);
225 void ffrt_queue_cancel_all(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 void ffrt_queue_cancel_and_wait(ffrt_queue_t queue)
235 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return, "input invalid, queue is nullptr");
236 QueueHandler* handler = static_cast<QueueHandler*>(queue);
241 int ffrt_queue_cancel_by_name(ffrt_queue_t queue, const char* name)
243 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return -1, "input invalid, queue is nullptr");
245 QueueHandler* handler = static_cast<QueueHandler*>(queue);
250 bool ffrt_queue_has_task(ffrt_queue_t queue, const char* name)
252 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return false, "input invalid, queue is nullptr");
254 QueueHandler* handler = static_cast<QueueHandler*>(queue);
259 bool ffrt_queue_is_idle(ffrt_queue_t queue)
261 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return false, "input invalid, queue is nullptr");
262 QueueHandler* handler = static_cast<QueueHandler*>(queue);
267 void ffrt_queue_set_eventhandler(ffrt_queue_t queue, void* eventhandler)
269 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return, "input invalid, queue is nullptr");
270 QueueHandler* handler = static_cast<QueueHandler*>(queue);
317 int ffrt_queue_dump(ffrt_queue_t queue, const char* tag, char* buf, uint32_t len, bool history_info)
319 FFRT_COND_DO_ERR((queue == nullptr), return -1, "input invalid, queue is nullptr");
321 QueueHandler* handler = static_cast<QueueHandler*>(queue);
326 int ffrt_queue_size_dump(ffrt_queue_t queue, ffrt_inner_queue_priority_t priority)
328 FFRT_COND_DO_ERR((queue == nullptr), return -1, "input invalid, queue is nullptr");
329 QueueHandler* handler = static_cast<QueueHandler*>(queue);