Lines Matching defs:qos
22 #include "qos.h"
142 void ffrt_task_attr_set_qos(ffrt_task_attr_t *attr, ffrt_qos_t qos)
152 (reinterpret_cast<ffrt::task_attr_private *>(attr))->qos_ = ffrt::GetFuncQosMap()(qos);
383 int ffrt_set_cgroup_attr(ffrt_qos_t qos, ffrt_os_sched_attr *attr)
393 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
401 for (auto qos = ffrt::QoS::Min(); qos < ffrt::QoS::Max(); ++qos) {
402 std::unique_lock<std::shared_mutex> lck(wgCtl[qos].tgMutex);
403 for (auto& thread : wgCtl[qos].threads) {
404 ffrt::SetThreadAttr(thread.first, qos);
417 void ffrt_notify_workers(ffrt_qos_t qos, int number)
419 if (qos < ffrt::QoS::Min() || qos >= ffrt::QoS::Max() || number <= 0) {
420 FFRT_LOGE("qos [%d] or number [%d] or is invalid.", qos, number);
424 ffrt::FFRTFacade::GetEUInstance().NotifyWorkers(qos, number);
428 ffrt_error_t ffrt_set_worker_stack_size(ffrt_qos_t qos, size_t stack_size)
430 if (qos < ffrt::QoS::Min() || qos >= ffrt::QoS::Max() || stack_size < PTHREAD_STACK_MIN) {
431 FFRT_LOGE("qos [%d] or stack size [%d] is invalid.", qos, stack_size);
436 std::unique_lock<std::shared_mutex> lck(groupCtl[qos].tgMutex);
437 if (!groupCtl[qos].threads.empty()) {
448 groupCtl[qos].workerStackSize = (stack_size - 1 + static_cast<size_t>(pageSize)) &
455 int ffrt_this_task_update_qos(ffrt_qos_t qos)
461 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
468 FFRT_COND_DO_ERR((curTask->type != ffrt_normal_task), return 1, "update qos task type invalid");
469 if (_qos() == curTask->qos) {
470 FFRT_LOGW("the target qos is equal to current qos, no need update");
487 return ffrt::ExecuteCtx::Cur()->qos();
547 int ffrt_executor_task_cancel(ffrt_executor_task_t* task, const ffrt_qos_t qos)
553 ffrt::QoS _qos = qos;
559 ffrt::FFRTTraceRecord::TaskCancel<ffrt_uv_task>(qos);