Lines Matching refs:queueId
80 void QueueMonitor::RegisterQueueId(uint32_t queueId, QueueHandler* queueStruct)
83 if (queueId == queuesRunningInfo_.size()) {
87 FFRT_LOGD("queue registration in monitor gid=%u in turn succ", queueId);
92 if (queueId > queuesRunningInfo_.size()) {
93 for (uint32_t i = queuesRunningInfo_.size(); i <= queueId; ++i) {
98 queuesStructInfo_[queueId] = queueStruct;
100 if (queuesStructInfo_[queueId] == nullptr) {
101 queuesStructInfo_[queueId] = queueStruct;
103 FFRT_LOGD("queue registration in monitor gid=%u by skip succ", queueId);
106 void QueueMonitor::ResetQueueInfo(uint32_t queueId)
109 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return,
110 "ResetQueueInfo queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.size());
111 queuesRunningInfo_[queueId].first = INVALID_TASK_ID;
112 lastReportedTask_[queueId] = INVALID_TASK_ID;
115 void QueueMonitor::ResetQueueStruct(uint32_t queueId)
118 FFRT_COND_DO_ERR((queuesStructInfo_.size() <= queueId), return,
119 "ResetQueueStruct queueId=%u access violation, StructInfo_.size=%u", queueId, queuesStructInfo_.size());
120 queuesStructInfo_[queueId] = nullptr;
123 void QueueMonitor::UpdateQueueInfo(uint32_t queueId, const uint64_t &taskId)
126 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return,
127 "UpdateQueueInfo queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.size());
129 queuesRunningInfo_[queueId] = {taskId, now};
136 uint64_t QueueMonitor::QueryQueueStatus(uint32_t queueId)
139 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return INVALID_TASK_ID,
140 "QueryQueueStatus queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.size());
141 return queuesRunningInfo_[queueId].first;
162 void QueueMonitor::ResetTaskTimestampAfterWarning(uint32_t queueId, const uint64_t &taskId)
165 if (queuesRunningInfo_[queueId].first == taskId) {
166 queuesRunningInfo_[queueId].second += std::chrono::microseconds(timeoutUs_);