Searched refs:queuesRunningInfo_ (Results 1 – 2 of 2) sorted by relevance
42 queuesRunningInfo_.reserve(QUEUE_INFO_INITIAL_CAPACITY); in QueueMonitor()71 if (queueId == queuesRunningInfo_.size()) { in RegisterQueueId()80 if (queueId > queuesRunningInfo_.size()) { in RegisterQueueId()99 queuesRunningInfo_[queueId].first = INVALID_TASK_ID; in ResetQueueInfo()117 queuesRunningInfo_[queueId] = {taskId, now}; in UpdateQueueInfo()128 return queuesRunningInfo_[queueId].first; in QueryQueueStatus()148 if (queuesRunningInfo_[queueId].first == taskId) { 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()[all …]
49 std::vector<std::pair<uint64_t, TimePoint>> queuesRunningInfo_; variable