Lines Matching refs:ffrt
42 namespace ffrt {
58 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task;
67 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task;
90 } // namespace ffrt
102 static_assert(sizeof(ffrt::task_attr_private) <= ffrt_task_attr_storage_size,
105 new (attr)ffrt::task_attr_private();
116 auto p = reinterpret_cast<ffrt::task_attr_private *>(attr);
127 (reinterpret_cast<ffrt::task_attr_private *>(attr))->name_ = name;
138 return (reinterpret_cast<ffrt::task_attr_private *>(p))->name_.c_str();
148 if (ffrt::GetFuncQosMap() == nullptr) {
152 (reinterpret_cast<ffrt::task_attr_private *>(attr))->qos_ = ffrt::GetFuncQosMap()(qos);
163 return (reinterpret_cast<ffrt::task_attr_private *>(p))->qos_;
173 (reinterpret_cast<ffrt::task_attr_private *>(attr))->delay_ = delay_us;
184 return (reinterpret_cast<ffrt::task_attr_private *>(p))->delay_;
194 (reinterpret_cast<ffrt::task_attr_private *>(attr))->timeout_ = timeout_ms;
205 return (reinterpret_cast<ffrt::task_attr_private *>(p))->timeout_;
216 (reinterpret_cast<ffrt::task_attr_private *>(attr))->notifyWorker_ = notify;
235 (reinterpret_cast<ffrt::task_attr_private *>(attr))->prio_ = priority;
246 return static_cast<ffrt_queue_priority_t>((reinterpret_cast<ffrt::task_attr_private *>(p))->prio_);
256 (reinterpret_cast<ffrt::task_attr_private *>(attr))->stackSize_ = size;
266 return (reinterpret_cast<const ffrt::task_attr_private *>(attr))->stackSize_;
274 return ffrt::TaskFactory::Alloc()->func_storage;
276 return ffrt::SimpleAllocator<ffrt::QueueTask>::AllocMem()->func_storage;
288 ffrt::task_attr_private *p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr_t *>(attr));
290 ffrt::submit_impl(false, handle, f, in_deps, out_deps, p);
298 ffrt::CreateDelayDeps(delay_handle, in_deps, out_deps, p);
302 ffrt::submit_impl(false, handle, f, &delay_deps, nullptr, p);
315 ffrt::task_attr_private *p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr_t *>(attr));
317 ffrt::submit_impl(true, handle, f, in_deps, out_deps, p);
325 ffrt::CreateDelayDeps(delay_handle, in_deps, out_deps, p);
329 ffrt::submit_impl(true, handle, f, &delay_deps, nullptr, p);
341 return static_cast<ffrt::CPUEUTask*>(handle)->IncDeleteRef();
351 return static_cast<ffrt::CPUEUTask*>(handle)->DecDeleteRef();
373 ffrt::FFRTFacade::GetDMInstance().onWait(&d);
379 ffrt::FFRTFacade::GetDMInstance().onWait();
389 if (ffrt::GetFuncQosMap() == nullptr) {
393 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
394 return ffrt::OSAttrManager::Instance()->UpdateSchedAttr(_qos, attr);
400 ffrt::WorkerGroupCtl *wgCtl = ffrt::FFRTFacade::GetEUInstance().GetGroupCtl();
401 for (auto qos = ffrt::QoS::Min(); qos < ffrt::QoS::Max(); ++qos) {
404 ffrt::SetThreadAttr(thread.first, qos);
412 ffrt::CPUMonitor *monitor = ffrt::FFRTFacade::GetEUInstance().GetCPUMonitor();
419 if (qos < ffrt::QoS::Min() || qos >= ffrt::QoS::Max() || number <= 0) {
424 ffrt::FFRTFacade::GetEUInstance().NotifyWorkers(qos, number);
430 if (qos < ffrt::QoS::Min() || qos >= ffrt::QoS::Max() || stack_size < PTHREAD_STACK_MIN) {
435 ffrt::WorkerGroupCtl* groupCtl = ffrt::FFRTFacade::GetEUInstance().GetGroupCtl();
457 if (ffrt::GetFuncQosMap() == nullptr) {
461 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
462 auto curTask = ffrt::ExecuteCtx::Cur()->task;
483 if (ffrt::ExecuteCtx::Cur()->task == nullptr) {
487 return ffrt::ExecuteCtx::Cur()->qos();
493 auto curTask = ffrt::ExecuteCtx::Cur()->task;
508 auto curTask = ffrt::ExecuteCtx::Cur()->task;
514 ffrt::QueueTask* task = reinterpret_cast<ffrt::QueueTask*>(curTask);
521 return ffrt::FFRTFacade::GetDMInstance().onSkip(handle);
531 ffrt::task_attr_private* p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr_t *>(attr));
533 ffrt::FFRTFacade::GetDMInstance().onSubmitUV(task, p);
542 ffrt::FuncManager* func_mg = ffrt::FuncManager::Instance();
553 ffrt::QoS _qos = qos;
555 ffrt::LinkedList* node = reinterpret_cast<ffrt::LinkedList *>(&task->wq);
556 ffrt::FFRTScheduler* sch = ffrt::FFRTFacade::GetSchedInstance();
559 ffrt::FFRTTraceRecord::TaskCancel<ffrt_uv_task>(qos);
567 return ffrt::ExecuteCtx::Cur()->task;
577 if (!ffrt::USE_COROUTINE) {
580 auto curTask = ffrt::ExecuteCtx::Cur()->task;
599 (reinterpret_cast<ffrt::task_attr_private *>(attr))->taskLocal_ = task_local;
609 return (reinterpret_cast<ffrt::task_attr_private *>(attr))->taskLocal_;
620 auto task = reinterpret_cast<ffrt::CPUEUTask*>(task_handle);
629 return ffrt::ExecuteCtx::Cur()->lastGid_;