Searched refs:searchTaskQueue_ (Results 1 – 2 of 2) sorted by relevance
341 if (searchTaskQueue_.find(device) != searchTaskQueue_.end()) { in CheckTaskExeStatus()342 queueCount = searchTaskQueue_.at(device).size(); in CheckTaskExeStatus()347 for (auto &entry : searchTaskQueue_) { in CheckTaskExeStatus()426 if (searchTaskQueue_[device].empty()) { in TryExecuteTaskInLock()430 sessionId = searchTaskQueue_[device].front(); in TryExecuteTaskInLock()432 searchTaskQueue_[device].pop_front(); in TryExecuteTaskInLock()437 searchTaskQueue_[device].pop_front(); in TryExecuteTaskInLock()462 auto iter = searchTaskQueue_[task.target].begin(); in DoRollBack()470 searchTaskQueue_[task.target].erase(iter); in DoRollBack()861 if (searchTaskQueue_.find(device) != searchTaskQueue_.end()) { in RemoveTaskByDevice()[all …]
151 …std::map<std::string, std::deque<uint32_t>> searchTaskQueue_; // key is device, value is sessionId… variable