Lines Matching refs:attr
37 bool insertHead, const ffrt_task_attr_t* attr) in ffrt_queue_submit_base() argument
42 …ttr_private *p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr_t *>(attr)); in ffrt_queue_submit_base()
55 int ffrt_queue_attr_init(ffrt_queue_attr_t* attr)
57 FFRT_COND_DO_ERR((attr == nullptr), return -1, "input invalid, attr == nullptr");
61 new (attr) ffrt::queue_attr_private();
66 void ffrt_queue_attr_destroy(ffrt_queue_attr_t* attr)
68 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr");
69 auto p = reinterpret_cast<ffrt::queue_attr_private*>(attr);
75 void ffrt_queue_attr_set_qos(ffrt_queue_attr_t* attr, ffrt_qos_t qos)
77 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr");
79 (reinterpret_cast<ffrt::queue_attr_private*>(attr))->qos_ = ffrt::GetFuncQosMap()(qos);
83 ffrt_qos_t ffrt_queue_attr_get_qos(const ffrt_queue_attr_t* attr)
85 FFRT_COND_DO_ERR((attr == nullptr), return ffrt_qos_default, "input invalid, attr == nullptr");
86 ffrt_queue_attr_t* p = const_cast<ffrt_queue_attr_t*>(attr);
91 void ffrt_queue_attr_set_timeout(ffrt_queue_attr_t* attr, uint64_t timeout_us)
93 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr");
94 (reinterpret_cast<ffrt::queue_attr_private*>(attr))->timeout_ = timeout_us;
98 uint64_t ffrt_queue_attr_get_timeout(const ffrt_queue_attr_t* attr)
100 FFRT_COND_DO_ERR((attr == nullptr), return 0, "input invalid, attr == nullptr");
101 ffrt_queue_attr_t* p = const_cast<ffrt_queue_attr_t*>(attr);
106 void ffrt_queue_attr_set_callback(ffrt_queue_attr_t* attr, ffrt_function_header_t* f)
108 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr");
109 ffrt::queue_attr_private* p = reinterpret_cast<ffrt::queue_attr_private*>(attr);
118 ffrt_function_header_t* ffrt_queue_attr_get_callback(const ffrt_queue_attr_t* attr)
120 FFRT_COND_DO_ERR((attr == nullptr), return nullptr, "input invalid, attr == nullptr");
121 ffrt_queue_attr_t* p = const_cast<ffrt_queue_attr_t*>(attr);
126 void ffrt_queue_attr_set_max_concurrency(ffrt_queue_attr_t* attr, const int max_concurrency)
128 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr");
133 (reinterpret_cast<ffrt::queue_attr_private*>(attr))->maxConcurrency_ = max_concurrency;
137 int ffrt_queue_attr_get_max_concurrency(const ffrt_queue_attr_t* attr)
139 FFRT_COND_DO_ERR((attr == nullptr), return 0, "input invalid, attr == nullptr");
140 ffrt_queue_attr_t* p = const_cast<ffrt_queue_attr_t*>(attr);
145 …_queue_t ffrt_queue_create(ffrt_queue_type_t type, const char* name, const ffrt_queue_attr_t* attr)
150 QueueHandler* handler = new (std::nothrow) QueueHandler(name, attr, type);
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 …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 …_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 …rt_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);