Home
last modified time | relevance | path

Searched refs:allSyncQueries (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_engine.cpp108 std::map<std::string, std::vector<QuerySyncObject>> allSyncQueries; in SubscribeTimeOut() local
109 GetAllUnFinishSubQueries(allSyncQueries); in SubscribeTimeOut()
110 if (allSyncQueries.empty()) { // LCOV_EXCL_BR_LINE in SubscribeTimeOut()
113 for (const auto &item : allSyncQueries) { in SubscribeTimeOut()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp222 std::map<std::string, std::vector<QuerySyncObject>> allSyncQueries; in CheckUnFinishedMap() local
223 subManager.GetAllUnFinishSubQueries(allSyncQueries); in CheckUnFinishedMap()
224 ASSERT_TRUE(allSyncQueries[DEVICE_A].size() == sizeA); in CheckUnFinishedMap()
225 ASSERT_TRUE(allSyncQueries[DEVICE_B].size() == sizeB); in CheckUnFinishedMap()
226 for (auto &item : allSyncQueries[DEVICE_A]) { in CheckUnFinishedMap()
230 for (auto &item : allSyncQueries[DEVICE_B]) { in CheckUnFinishedMap()
690 std::map<std::string, std::vector<QuerySyncObject>> allSyncQueries; variable
691 subManager.GetAllUnFinishSubQueries(allSyncQueries);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_manager.cpp116 std::map<std::string, std::vector<QuerySyncObject>> &allSyncQueries) const in GetAllUnFinishSubQueries()
123 allSyncQueries[item.first] = {}; in GetAllUnFinishSubQueries()
124 auto iter = allSyncQueries.find(item.first); in GetAllUnFinishSubQueries()
H A Dsubscribe_manager.h69 …etAllUnFinishSubQueries(std::map<std::string, std::vector<QuerySyncObject>> &allSyncQueries) const;
H A Dsync_engine.h98 …void GetAllUnFinishSubQueries(std::map<std::string, std::vector<QuerySyncObject>> &allSyncQueries);
H A Dsync_engine.cpp882 …gine::GetAllUnFinishSubQueries(std::map<std::string, std::vector<QuerySyncObject>> &allSyncQueries) in GetAllUnFinishSubQueries() argument
884 subManager_->GetAllUnFinishSubQueries(allSyncQueries); in GetAllUnFinishSubQueries()