Lines Matching refs:end
245 for (auto iter = workers_.begin(); iter != workers_.end(); iter++) {
438 auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [](Worker *worker) {
443 if (iter != idleWorkers_.end()) {
467 for (auto iter = timeoutWorkers_.begin(); iter != timeoutWorkers_.end();) {
469 if (workers_.find(worker) == workers_.end()) {
692 return std::count_if(workers_.begin(), workers_.end(), [](const auto& worker) {
902 idleWorkers_.emplace_hint(idleWorkers_.end(), worker);
919 if (iter == callbackTable_.end() || iter->second == nullptr) {
933 if (iter == callbackTable_.end() || iter->second == nullptr) {
946 if (iter == callbackTable_.end() || iter->second == nullptr) {
967 if (iter == callbackTable_.end() || iter->second == nullptr) {
1032 if (iter == dependentTaskInfos_.end() || iter->second.empty()) {
1036 for (auto taskIdIter = iter->second.begin(); taskIdIter != iter->second.end();) {
1052 if (dependTaskIter != dependTaskInfos_.end()) {
1054 if (dependTaskInnerIter != dependTaskIter->second.end()) {
1064 if (iter == dependTaskInfos_.end() || iter->second.empty()) {
1074 if (iter == dependentTaskInfos_.end() || iter->second.empty()) {
1086 if (iter == dependTaskInfos_.end()) {
1089 if (idIter == dependTaskInfos_.end()) {
1102 if (idIter == dependTaskInfos_.end()) {
1109 iter->second.insert(taskIdSet.begin(), taskIdSet.end());
1120 if (iter != dependentIdSet.end()) {
1124 if (dIter == dependTaskInfos_.end()) {
1140 if (iter == dependTaskInfos_.end()) {
1144 if (dependIter == iter->second.end()) {
1167 for (auto it = pendingTaskInfos_.begin(); it != pendingTaskInfos_.end(); ++it) {
1190 if (iter == dependentTaskInfos_.end()) {
1204 if (iter == dependentTaskInfos_.end()) {
1208 if (taskIter == iter->second.end()) {
1219 if (iter != dependTaskInfos_.end()) {
1232 if (iter == taskDurationInfos_.end()) {
1249 if (iter == taskDurationInfos_.end()) {
1267 if (iter != taskDurationInfos_.end()) {
1288 return iter != longTasksMap_.end() ? iter->second : nullptr;
1335 for (auto dependentTaskIter = dependentTaskInfos_.begin(); dependentTaskIter != dependentTaskInfos_.end();) {
1336 if (dependentTaskIter->second.find(taskId) != dependentTaskIter->second.end()) {
1345 if (dependTaskIter != dependTaskInfos_.end()) {
1410 if (iter == tasks_.end()) {
1456 return item != tasks_.end();
1470 if (groupIter == taskGroups_.end()) {
1581 if (iter != seqRunners_.end()) {
1592 if (iter == seqRunners_.end()) {
1673 if (groupIter == taskGroups_.end()) {
1686 if (groupIter == taskGroups_.end()) {
1711 if (iter == globalSeqRunner_.end()) {
1729 if (tmpIter == seqRunner->globalSeqRunnerRef_.end()) {
1743 if (iter == seqRunner->globalSeqRunnerRef_.end()) {
1763 if (iter != seqRunner->globalSeqRunnerRef_.end()) {
1773 if (iter != globalSeqRunner_.end()) {