Searched refs:mergingSearcher (Results 1 – 3 of 3) sorted by relevance
59 (executor->mergingSearcher->inCloseMerge.find(cur_state) != in getPrioritizeState()60 executor->mergingSearcher->inCloseMerge.end()); in getPrioritizeState()100 executor->mergingSearcher->pauseState(*es); in addClosedState()110 executor->mergingSearcher->inCloseMerge.erase(es); in addClosedState()117 executor->mergingSearcher->pauseState(*es); in addClosedState()125 executor->mergingSearcher->continueState(*curState); in releaseStates()126 executor->mergingSearcher->inCloseMerge.erase(curState); in releaseStates()139 executor->mergingSearcher->mergeGroups.push_back(this); in MergeHandler()146 assert(it != executor->mergingSearcher->mergeGroups.end() && in ~MergeHandler()148 std::swap(*it, executor->mergingSearcher->mergeGroups.back()); in ~MergeHandler()[all …]
223 MergingSearcher *mergingSearcher = nullptr; variable552 MergingSearcher *getMergingSearcher() const { return mergingSearcher; }; in getMergingSearcher()553 void setMergingSearcher(MergingSearcher *ms) { mergingSearcher = ms; }; in setMergingSearcher()
373 assert(executor.mergingSearcher->inCloseMerge.find(&state) == in handleCloseMerge()374 executor.mergingSearcher->inCloseMerge.end() && in handleCloseMerge()376 executor.mergingSearcher->inCloseMerge.insert(&state); in handleCloseMerge()