Lines Matching refs:whenMap
32 std::multimap<uint64_t, T*>& whenMap, void* args) in DequeBatch() argument
36 T* head = whenMap.begin()->second; in DequeBatch()
37 whenMap.erase(whenMap.begin()); in DequeBatch()
40 while (!whenMap.empty() && whenMap.begin()->first < now) { in DequeBatch()
41 auto next = whenMap.begin()->second; in DequeBatch()
46 whenMap.erase(whenMap.begin()); in DequeBatch()
51 head->gid, node->gid, whenMap.size(), queueId); in DequeBatch()
56 const uint64_t now, std::multimap<uint64_t, T*>& whenMap, void* args) in DequeSingleByPriority() argument
60 auto iterTarget = whenMap.begin(); in DequeSingleByPriority()
61 for (auto ite = whenMap.begin(); ite != whenMap.end() && ite->first < now; ite++) { in DequeSingleByPriority()
71 whenMap.erase(iterTarget); in DequeSingleByPriority()
73 …FFRT_LOGD("dequeue [gid=%llu], %u other tasks in [queueId=%u] ", head->gid, whenMap.size(), queueI… in DequeSingleByPriority()
78 const uint64_t now, std::multimap<uint64_t, T*>& whenMap, void* args) in DequeSingleAgainstStarvation() argument
85 auto iterTarget = whenMap.begin(); in DequeSingleAgainstStarvation()
91 auto iter = std::find_if(whenMap.begin(), whenMap.end(), in DequeSingleAgainstStarvation()
93 if (iter != whenMap.end()) { in DequeSingleAgainstStarvation()
105 whenMap.erase(iterTarget); in DequeSingleAgainstStarvation()
106 …FFRT_LOGD("dequeue [gid=%llu], %u other tasks in [queueId=%u] ", head->gid, whenMap.size(), queueI… in DequeSingleAgainstStarvation()