Home
last modified time | relevance | path

Searched refs:deviceWorkingSet_ (Results 1 – 2 of 2) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dremote_executor.cpp344 if (deviceWorkingSet_.find(device) != deviceWorkingSet_.end()) { in CheckTaskExeStatus()
345 exeTaskCount = deviceWorkingSet_.at(device).size(); in CheckTaskExeStatus()
348 int currentExeCount = static_cast<int>(deviceWorkingSet_[device].size()); in CheckTaskExeStatus()
423 if (deviceWorkingSet_[device].size() >= MAX_SEARCH_TASK_EXECUTE) { in TryExecuteTaskInLock()
438 deviceWorkingSet_[device].insert(sessionId); in TryExecuteTaskInLock()
473 deviceWorkingSet_[task.target].erase(sessionId); in DoRollBack()
718 deviceWorkingSet_[task.target].erase(sessionId); in ClearTaskInfo()
856 if (deviceWorkingSet_.find(device) != deviceWorkingSet_.end()) { in RemoveTaskByDevice()
857 for (auto &sessionId : deviceWorkingSet_[device]) { in RemoveTaskByDevice()
885 deviceWorkingSet_.clear(); in RemoveAllTask()
H A Dremote_executor.h152 …std::map<std::string, std::set<uint32_t>> deviceWorkingSet_; // key is device, value is sessionId … variable