Lines Matching refs:queuesRunningInfo_
42 queuesRunningInfo_.reserve(QUEUE_INFO_INITIAL_CAPACITY); in QueueMonitor()
71 if (queueId == queuesRunningInfo_.size()) { in RegisterQueueId()
72 …queuesRunningInfo_.emplace_back(std::make_pair(INVALID_TASK_ID, std::chrono::steady_clock::now())); in RegisterQueueId()
80 if (queueId > queuesRunningInfo_.size()) { in RegisterQueueId()
81 for (uint32_t i = queuesRunningInfo_.size(); i <= queueId; ++i) { in RegisterQueueId()
82 …queuesRunningInfo_.emplace_back(std::make_pair(INVALID_TASK_ID, std::chrono::steady_clock::now())); in RegisterQueueId()
97 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return, in ResetQueueInfo()
98 …tQueueInfo queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.size()); in ResetQueueInfo()
99 queuesRunningInfo_[queueId].first = INVALID_TASK_ID; in ResetQueueInfo()
114 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return, in UpdateQueueInfo()
115 …eQueueInfo queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.size()); in UpdateQueueInfo()
117 queuesRunningInfo_[queueId] = {taskId, now}; in UpdateQueueInfo()
126 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return INVALID_TASK_ID, in QueryQueueStatus()
127 …ueueStatus queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.size()); in QueryQueueStatus()
128 return queuesRunningInfo_[queueId].first; in QueryQueueStatus()
148 if (queuesRunningInfo_[queueId].first == taskId) { in ResetTaskTimestampAfterWarning()
149 queuesRunningInfo_[queueId].second += std::chrono::microseconds(timeoutUs_); in ResetTaskTimestampAfterWarning()
157 auto iter = std::find_if(queuesRunningInfo_.cbegin(), queuesRunningInfo_.cend(), in CheckQueuesStatus()
159 if (iter == queuesRunningInfo_.cend()) { in CheckQueuesStatus()
172 queueRunningInfoSize = queuesRunningInfo_.size(); in CheckQueuesStatus()
177 taskId = queuesRunningInfo_[i].first; in CheckQueuesStatus()
178 taskTimestamp = queuesRunningInfo_[i].second; in CheckQueuesStatus()
224 for (uint32_t i = 0; i < queuesRunningInfo_.size(); ++i) { in HasQueueActive()
225 if (queuesRunningInfo_[i].first != INVALID_TASK_ID) { in HasQueueActive()