68 void QueueMonitor::RegisterQueueId(uint32_t queueId, QueueHandler* queueStruct)  in RegisterQueueId()  argument
71     if (queueId == queuesRunningInfo_.size()) {  in RegisterQueueId()
75         FFRT_LOGD("queue registration in monitor gid=%u in turn succ", queueId);  in RegisterQueueId()
80     if (queueId > queuesRunningInfo_.size()) {  in RegisterQueueId()
81         for (uint32_t i = queuesRunningInfo_.size(); i <= queueId; ++i) {  in RegisterQueueId()
86         queuesStructInfo_[queueId] = queueStruct;  in RegisterQueueId()
88     if (queuesStructInfo_[queueId] == nullptr) {  in RegisterQueueId()
89         queuesStructInfo_[queueId] = queueStruct;  in RegisterQueueId()
91     FFRT_LOGD("queue registration in monitor gid=%u by skip succ", queueId);  in RegisterQueueId()
94 void QueueMonitor::ResetQueueInfo(uint32_t queueId)  in ResetQueueInfo()  argument
97     FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return,  in ResetQueueInfo()
98 …"ResetQueueInfo queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.si…  in ResetQueueInfo()
99     queuesRunningInfo_[queueId].first = INVALID_TASK_ID;  in ResetQueueInfo()
100     lastReportedTask_[queueId] = INVALID_TASK_ID;  in ResetQueueInfo()
103 void QueueMonitor::ResetQueueStruct(uint32_t queueId)  in ResetQueueStruct()  argument
106     FFRT_COND_DO_ERR((queuesStructInfo_.size() <= queueId), return,  in ResetQueueStruct()
107 …"ResetQueueStruct queueId=%u access violation, StructInfo_.size=%u", queueId, queuesStructInfo_.si…  in ResetQueueStruct()
108     queuesStructInfo_[queueId] = nullptr;  in ResetQueueStruct()
111 void QueueMonitor::UpdateQueueInfo(uint32_t queueId, const uint64_t &taskId)  in UpdateQueueInfo()  argument
114     FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return,  in UpdateQueueInfo()
115 …"UpdateQueueInfo queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.s…  in UpdateQueueInfo()
117     queuesRunningInfo_[queueId] = {taskId, now};  in UpdateQueueInfo()
123 uint64_t QueueMonitor::QueryQueueStatus(uint32_t queueId)  in QueryQueueStatus()  argument
126     FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return INVALID_TASK_ID,  in QueryQueueStatus()
127 …"QueryQueueStatus queueId=%u access violation, RunningInfo_.size=%u", queueId, queuesRunningInfo_.…  in QueryQueueStatus()
128     return queuesRunningInfo_[queueId].first;  in QueryQueueStatus()
145 void QueueMonitor::ResetTaskTimestampAfterWarning(uint32_t queueId, const uint64_t &taskId)  in ResetTaskTimestampAfterWarning()  argument
148     if (queuesRunningInfo_[queueId].first == taskId) {  in ResetTaskTimestampAfterWarning()
149         queuesRunningInfo_[queueId].second += std::chrono::microseconds(timeoutUs_);  in ResetTaskTimestampAfterWarning()