Lines Matching refs:ffrt
41 namespace ffrt { namespace
57 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task;
66 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task;
101 static_assert(sizeof(ffrt::task_attr_private) <= ffrt_task_attr_storage_size,
104 new (attr)ffrt::task_attr_private();
115 auto p = reinterpret_cast<ffrt::task_attr_private *>(attr);
126 (reinterpret_cast<ffrt::task_attr_private *>(attr))->name_ = name;
137 return (reinterpret_cast<ffrt::task_attr_private *>(p))->name_.c_str();
147 if (ffrt::GetFuncQosMap() == nullptr) {
151 (reinterpret_cast<ffrt::task_attr_private *>(attr))->qos_ = ffrt::GetFuncQosMap()(qos);
162 return (reinterpret_cast<ffrt::task_attr_private *>(p))->qos_;
172 (reinterpret_cast<ffrt::task_attr_private *>(attr))->delay_ = delay_us;
183 return (reinterpret_cast<ffrt::task_attr_private *>(p))->delay_;
193 (reinterpret_cast<ffrt::task_attr_private *>(attr))->timeout_ = timeout_us;
204 return (reinterpret_cast<ffrt::task_attr_private *>(p))->timeout_;
215 (reinterpret_cast<ffrt::task_attr_private *>(attr))->notifyWorker_ = notify;
234 (reinterpret_cast<ffrt::task_attr_private *>(attr))->prio_ = priority;
245 …return static_cast<ffrt_queue_priority_t>((reinterpret_cast<ffrt::task_attr_private *>(p))->prio_);
255 (reinterpret_cast<ffrt::task_attr_private *>(attr))->stackSize_ = size;
265 return (reinterpret_cast<const ffrt::task_attr_private *>(attr))->stackSize_;
273 return ffrt::TaskFactory::Alloc()->func_storage;
275 return ffrt::SimpleAllocator<ffrt::QueueTask>::AllocMem()->func_storage;
287 …ffrt::task_attr_private *p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr…
289 ffrt::submit_impl(false, handle, f, in_deps, out_deps, p);
297 ffrt::CreateDelayDeps(delay_handle, in_deps, out_deps, p);
301 ffrt::submit_impl(false, handle, f, &delay_deps, nullptr, p);
314 …ffrt::task_attr_private *p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr…
316 ffrt::submit_impl(true, handle, f, in_deps, out_deps, p);
324 ffrt::CreateDelayDeps(delay_handle, in_deps, out_deps, p);
328 ffrt::submit_impl(true, handle, f, &delay_deps, nullptr, p);
340 return static_cast<ffrt::CPUEUTask*>(handle)->IncDeleteRef();
350 return static_cast<ffrt::CPUEUTask*>(handle)->DecDeleteRef();
363 return static_cast<ffrt::TaskBase*>(handle)->gid;
379 ffrt::FFRTFacade::GetDMInstance().onWait(&d);
385 ffrt::FFRTFacade::GetDMInstance().onWait();
395 if (ffrt::GetFuncQosMap() == nullptr) {
399 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
400 return ffrt::OSAttrManager::Instance()->UpdateSchedAttr(_qos, attr);
406 ffrt::WorkerGroupCtl *wgCtl = ffrt::FFRTFacade::GetEUInstance().GetGroupCtl();
407 for (auto qos = ffrt::QoS::Min(); qos < ffrt::QoS::Max(); ++qos) {
410 ffrt::SetThreadAttr(thread.first, qos);
418 if (ffrt::GetFuncQosMap() == nullptr) {
422 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
423 … if (((qos != ffrt::qos_default) && (_qos() == ffrt::qos_default)) || (qos <= ffrt::qos_inherit)) {
427 ffrt::CPUMonitor *monitor = ffrt::FFRTFacade::GetEUInstance().GetCPUMonitor();
434 if (qos < ffrt::QoS::Min() || qos >= ffrt::QoS::Max() || number <= 0) {
439 ffrt::FFRTFacade::GetEUInstance().NotifyWorkers(qos, number);
445 if (qos < ffrt::QoS::Min() || qos >= ffrt::QoS::Max() || stack_size < PTHREAD_STACK_MIN) {
450 ffrt::WorkerGroupCtl* groupCtl = ffrt::FFRTFacade::GetEUInstance().GetGroupCtl();
472 if (ffrt::GetFuncQosMap() == nullptr) {
476 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
477 auto curTask = ffrt::ExecuteCtx::Cur()->task;
498 if (ffrt::ExecuteCtx::Cur()->task == nullptr) {
502 return ffrt::ExecuteCtx::Cur()->qos();
508 auto curTask = ffrt::ExecuteCtx::Cur()->task;
516 return reinterpret_cast<ffrt::QueueTask*>(curTask)->GetHandler()->GetExecTaskId();
525 auto curTask = ffrt::ExecuteCtx::Cur()->task;
531 ffrt::QueueTask* task = reinterpret_cast<ffrt::QueueTask*>(curTask);
542 ffrt::CPUEUTask *task = static_cast<ffrt::CPUEUTask*>(handle);
543 auto exp = ffrt::SkipStatus::SUBMITTED;
544 …if (__atomic_compare_exchange_n(&task->skipped, &exp, ffrt::SkipStatus::SKIPPED, 0, __ATOMIC_ACQUI…
558 …ffrt::task_attr_private* p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr…
560 ffrt::FFRTFacade::GetDMInstance().onSubmitUV(task, p);
569 ffrt::FuncManager* func_mg = ffrt::FuncManager::Instance();
580 ffrt::QoS _qos = qos;
582 ffrt::LinkedList* node = reinterpret_cast<ffrt::LinkedList *>(&task->wq);
583 ffrt::FFRTScheduler* sch = ffrt::FFRTFacade::GetSchedInstance();
586 ffrt::FFRTTraceRecord::TaskCancel<ffrt_uv_task>(qos);
594 return ffrt::ExecuteCtx::Cur()->task;
604 if (!ffrt::USE_COROUTINE) {
607 auto curTask = ffrt::ExecuteCtx::Cur()->task;
626 (reinterpret_cast<ffrt::task_attr_private *>(attr))->taskLocal_ = task_local;
636 return (reinterpret_cast<ffrt::task_attr_private *>(attr))->taskLocal_;
647 auto task = reinterpret_cast<ffrt::CPUEUTask*>(task_handle);
656 return ffrt::ExecuteCtx::Cur()->lastGid_;