Lines Matching refs:iter
245 for (auto iter = workers_.begin(); iter != workers_.end(); iter++) {
246 auto worker = *iter;
438 auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [](Worker *worker) {
443 if (iter != idleWorkers_.end()) {
444 auto worker = *iter;
467 for (auto iter = timeoutWorkers_.begin(); iter != timeoutWorkers_.end();) {
468 auto worker = *iter;
471 iter = timeoutWorkers_.erase(iter);
475 timeoutWorkers_.erase(iter++);
478 iter++;
918 auto iter = callbackTable_.find(taskId);
919 if (iter == callbackTable_.end() || iter->second == nullptr) {
923 return iter->second;
932 auto iter = callbackTable_.find(taskId);
933 if (iter == callbackTable_.end() || iter->second == nullptr) {
936 iter->second->refCount++;
945 auto iter = callbackTable_.find(taskId);
946 if (iter == callbackTable_.end() || iter->second == nullptr) {
952 callbackTable_.erase(iter);
956 iter->second->refCount--;
957 if (iter->second->refCount == 0) {
958 callbackTable_.erase(iter);
966 auto iter = callbackTable_.find(task->taskId_);
967 if (iter == callbackTable_.end() || iter->second == nullptr) {
975 auto callbackInfo = iter->second;
1031 auto iter = dependentTaskInfos_.find(taskId);
1032 if (iter == dependentTaskInfos_.end() || iter->second.empty()) {
1036 for (auto taskIdIter = iter->second.begin(); taskIdIter != iter->second.end();) {
1039 taskIdIter = iter->second.erase(taskIdIter);
1063 auto iter = dependTaskInfos_.find(taskId);
1064 if (iter == dependTaskInfos_.end() || iter->second.empty()) {
1073 auto iter = dependentTaskInfos_.find(dependentTaskId);
1074 if (iter == dependentTaskInfos_.end() || iter->second.empty()) {
1085 auto iter = dependTaskInfos_.find(taskId);
1086 if (iter == dependTaskInfos_.end()) {
1100 for (const auto& dependentId : iter->second) {
1105 if (!CheckCircularDependency(iter->second, idIter->second, taskId)) {
1109 iter->second.insert(taskIdSet.begin(), taskIdSet.end());
1119 auto iter = dependentIdSet.find(id);
1120 if (iter != dependentIdSet.end()) {
1139 auto iter = dependTaskInfos_.find(taskId);
1140 if (iter == dependTaskInfos_.end()) {
1143 auto dependIter = iter->second.find(dependentId);
1144 if (dependIter == iter->second.end()) {
1147 iter->second.erase(dependIter);
1189 auto iter = dependentTaskInfos_.find(id);
1190 if (iter == dependentTaskInfos_.end()) {
1194 iter->second.emplace(taskId);
1203 auto iter = dependentTaskInfos_.find(dependentTaskId);
1204 if (iter == dependentTaskInfos_.end()) {
1207 auto taskIter = iter->second.find(taskId);
1208 if (taskIter == iter->second.end()) {
1211 iter->second.erase(taskIter);
1218 auto iter = dependTaskInfos_.find(taskId);
1219 if (iter != dependTaskInfos_.end()) {
1220 for (const auto& id : iter->second) {
1231 auto iter = taskDurationInfos_.find(taskId);
1232 if (iter == taskDurationInfos_.end()) {
1237 iter->second.first = totalDuration;
1240 iter->second.second = cpuDuration;
1248 auto iter = taskDurationInfos_.find(taskId);
1249 if (iter == taskDurationInfos_.end()) {
1253 return iter->second.first;
1255 return iter->second.second;
1256 } else if (iter->second.first == 0) {
1259 return iter->second.first - iter->second.second;
1266 auto iter = taskDurationInfos_.find(taskId);
1267 if (iter != taskDurationInfos_.end()) {
1268 taskDurationInfos_.erase(iter);
1287 auto iter = longTasksMap_.find(taskId);
1288 return iter != longTasksMap_.end() ? iter->second : nullptr;
1409 auto iter = tasks_.find(taskId);
1410 if (iter == tasks_.end()) {
1413 return iter->second;
1580 auto iter = seqRunners_.find(seqRunnerId);
1581 if (iter != seqRunners_.end()) {
1582 return iter->second;
1591 auto iter = seqRunners_.find(seqRunnerId);
1592 if (iter == seqRunners_.end()) {
1596 std::unique_lock<std::shared_mutex> seqRunnerLock(iter->second->seqRunnerMutex_);
1597 iter->second->seqRunnerTasks_.push(task);
1710 auto iter = globalSeqRunner_.find(name);
1711 if (iter == globalSeqRunner_.end()) {
1721 seqRunner = iter->second;
1742 auto iter = seqRunner->globalSeqRunnerRef_.find(env);
1743 if (iter == seqRunner->globalSeqRunnerRef_.end()) {
1746 napi_reference_unref(env, iter->second, nullptr);
1762 auto iter = seqRunner->globalSeqRunnerRef_.find(env);
1763 if (iter != seqRunner->globalSeqRunnerRef_.end()) {
1764 napi_delete_reference(env, iter->second);
1765 seqRunner->globalSeqRunnerRef_.erase(iter);
1772 auto iter = globalSeqRunner_.find(name.c_str());
1773 if (iter != globalSeqRunner_.end()) {
1774 globalSeqRunner_.erase(iter->first);