queue_handler.cpp - OpenGrok cross reference for /foundation/resourceschedule/ffrt/src/queue/queue

Lines Matching refs:GetQueueId
51     FFRT_COND_DO_ERR((queue_ == nullptr), return, "[queueId=%u] constructed failed", GetQueueId());
54         name_ = "sq_" + std::string(name) + "_" + std::to_string(GetQueueId());
56         name_ += "sq_unnamed_" + std::to_string(GetQueueId());
57         FFRT_LOGW("failed to set [queueId=%u] name due to invalid name or length.", GetQueueId());
60     QueueMonitor::GetInstance().RegisterQueueId(GetQueueId(), this);
66     FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot destruct, [queueId=%u] constructed failed", GetQueueId());
70     while (QueueMonitor::GetInstance().QueryQueueStatus(GetQueueId()) || queue_->GetActiveStatus()) {
73     QueueMonitor::GetInstance().ResetQueueStruct(GetQueueId());
92     FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId());
97         return false, "[queueId=%u] type invalid", GetQueueId());
103     FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId());
105         return false, "[queueId=%u] type invalid", GetQueueId());
111     FFRT_COND_DO_ERR((queue_ == nullptr), return nullptr, "[queueId=%u] constructed failed", GetQueueId());
117     FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot submit, [queueId=%u] constructed failed", GetQueueId());
126     FFRT_SERIAL_QUEUE_TASK_SUBMIT_MARKER(GetQueueId(), gid);
161     FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot cancel, [queueId=%u] constructed failed", GetQueueId());
168         GetQueueId());
170     while (QueueMonitor::GetInstance().QueryQueueStatus(GetQueueId()) != 0 || queue_->GetActiveStatus()) {
178          "cannot cancel, [queueId=%u] constructed failed", GetQueueId());
190          "cannot cancel, [queueId=%u] constructed failed", GetQueueId());
210         QueueMonitor::GetInstance().UpdateQueueInfo(GetQueueId(), task->gid);
213         FFRT_LOGD("run task [gid=%llu], queueId=%u", task->gid, GetQueueId());
238             QueueMonitor::GetInstance().ResetQueueInfo(GetQueueId());
338         name_ << "], queueId:[" << GetQueueId() << "], serial task gid:[" << task->gid << "], task name:["
358     FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId());
360         return false, "[queueId=%u] type invalid", GetQueueId());
367     FFRT_COND_DO_ERR((queue_ == nullptr), return, "[queueId=%u] constructed failed", GetQueueId());
371     FFRT_COND_DO_ERR(typeInvalid, return, "[queueId=%u] type invalid", GetQueueId());
378     FFRT_COND_DO_ERR((queue_ == nullptr), return nullptr, "[queueId=%u] constructed failed", GetQueueId());
382     FFRT_COND_DO_ERR(typeInvalid, return nullptr, "[queueId=%u] type invalid", GetQueueId());
389     FFRT_COND_DO_ERR((queue_ == nullptr), return -1, "[queueId=%u] constructed failed", GetQueueId());
391         return -1, "[queueId=%u] type invalid", GetQueueId());
397     FFRT_COND_DO_ERR((queue_ == nullptr), return -1, "[queueId=%u] constructed failed", GetQueueId());
399         return -1, "[queueId=%u] type invalid", GetQueueId());