Searched refs:taskHandlerMap_ (Results 1 – 7 of 7) sorted by relevance
52 if (taskHandlerMap_.find(eventId) == taskHandlerMap_.end()) { in SendEvent()58 if (reportHandler->taskHandlerMap_.find(eventId) == reportHandler->taskHandlerMap_.end()) { in SendEvent()61 if (!reportHandler->taskHandlerMap_[eventId].empty()) { in SendEvent()62 reportHandler->taskHandlerMap_[eventId].pop(); in SendEvent()65 taskHandlerMap_[eventId].push(std::move(taskHandle)); in SendEvent()75 if (taskHandlerMap_.find(eventId) == taskHandlerMap_.end()) { in RemoveEvent()78 while (!taskHandlerMap_[eventId].empty()) { in RemoveEvent()79 ffrtQueue_->cancel(taskHandlerMap_[eventId].front()); in RemoveEvent()80 taskHandlerMap_[eventId].pop(); in RemoveEvent()82 taskHandlerMap_.erase(eventId); in RemoveEvent()[all …]
130 if (taskHandlerMap_.find(eventId) == taskHandlerMap_.end()) { in SendEvent()131 taskHandlerMap_[eventId] = std::queue<ffrt::task_handle>(); in SendEvent()136 if (groupHandler->taskHandlerMap_.find(eventId) == groupHandler->taskHandlerMap_.end()) { in SendEvent()139 if (!groupHandler->taskHandlerMap_[eventId].empty()) { in SendEvent()140 groupHandler->taskHandlerMap_[eventId].pop(); in SendEvent()143 taskHandlerMap_[eventId].push(std::move(taskHandle)); in SendEvent()153 if (taskHandlerMap_.find(eventId) == taskHandlerMap_.end()) { in RemoveEvent()156 while (!taskHandlerMap_[eventId].empty()) { in RemoveEvent()157 ffrtQueue_->cancel(taskHandlerMap_[eventId].front()); in RemoveEvent()158 taskHandlerMap_[eventId].pop(); in RemoveEvent()[all …]
102 for (auto iter = taskHandlerMap_.begin(); iter != taskHandlerMap_.end();) { in HandleAddRequest()105 taskHandlerMap_.erase(iter++); in HandleAddRequest()118 taskHandlerMap_[identity] = ffrtQueue_->submit_h( in HandleAddRequest()132 for (auto iter = taskHandlerMap_.begin(); iter != taskHandlerMap_.end();) { in HandleDelRequest()135 taskHandlerMap_.erase(iter++); in HandleDelRequest()
54 std::map<int32_t, std::queue<ffrt::task_handle>> taskHandlerMap_; variable
54 std::unordered_map<std::string, ffrt::task_handle> taskHandlerMap_; variable
73 std::map<int32_t, std::queue<ffrt::task_handle>> taskHandlerMap_; variable
806 EXPECT_EQ(bundleActiveReportHandler->taskHandlerMap_.size(), 0);810 EXPECT_NE(bundleActiveReportHandler->taskHandlerMap_.size(), 0);813 EXPECT_EQ(bundleActiveReportHandler->taskHandlerMap_.size(), 0);846 EXPECT_EQ(bundleActiveGroupHandler->taskHandlerMap_.size(), 0);865 EXPECT_NE(bundleActiveGroupHandler->taskHandlerMap_.size(), 0);868 EXPECT_EQ(bundleActiveGroupHandler->taskHandlerMap_.size(), 0);