Home
last modified time | relevance | path

Searched refs:subscribeQueries (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp394 ASSERT_TRUE(subscribeQueries.size() == 4);
395 subscribeQueries.clear();
407 ASSERT_TRUE(subscribeQueries.size() == 4);
408 subscribeQueries.clear();
415 ASSERT_TRUE(subscribeQueries.size() == 4);
416 subscribeQueries.clear();
437 subscribeQueries.clear();
524 subscribeQueries.clear();
534 subscribeQueries.clear();
627 subscribeQueries.clear();
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_manager.cpp100 const std::vector<QuerySyncObject> &subscribeQueries) in PutLocalUnFinishedSubQueries() argument
102 …LOGI("[SubscribeManager] put local unfinished subscribe queries, nums=%zu", subscribeQueries.size(… in PutLocalUnFinishedSubQueries()
104 if (subscribeQueries.empty()) { in PutLocalUnFinishedSubQueries()
110 for (const auto &query : subscribeQueries) { in PutLocalUnFinishedSubQueries()
160 std::vector<QuerySyncObject> &subscribeQueries) const in GetLocalSubscribeQueries()
163 GetSubscribeQueries(device, localSubscribeMap_, localSubscribeTotalMap_, subscribeQueries); in GetLocalSubscribeQueries()
167 std::vector<QuerySyncObject> &subscribeQueries) const in GetRemoteSubscribeQueries()
170 GetSubscribeQueries(device, remoteSubscribedMap_, remoteSubscribedTotalMap_, subscribeQueries); in GetRemoteSubscribeQueries()
374 …const SubscribedTotalMap &subscribedTotalMap, std::vector<QuerySyncObject> &subscribeQueries) const in GetSubscribeQueries()
387 subscribeQueries.push_back(iterTmp->second.first); in GetSubscribeQueries()
H A Dsubscribe_manager.h66 …inishedSubQueries(const std::string &device, const std::vector<QuerySyncObject> &subscribeQueries);
78 …lSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &subscribeQueries) const;
83 …eSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &subscribeQueries) const;
107 …onst SubscribedTotalMap &subscribedTotalMap, std::vector<QuerySyncObject> &subscribeQueries) const;
H A Dsync_engine.h89 …etLocalSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &subscribeQueries);
94 …tRemoteSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &subscribeQueries);
96 …inishedSubQueries(const std::string &device, const std::vector<QuerySyncObject> &subscribeQueries);
H A Dsync_engine.cpp861 …GetLocalSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &subscribeQueries) in GetLocalSubscribeQueries() argument
863 subManager_->GetLocalSubscribeQueries(device, subscribeQueries); in GetLocalSubscribeQueries()
871 …etRemoteSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &subscribeQueries) in GetRemoteSubscribeQueries() argument
873 subManager_->GetRemoteSubscribeQueries(device, subscribeQueries); in GetRemoteSubscribeQueries()
877 const std::vector<QuerySyncObject> &subscribeQueries) in PutUnfinishedSubQueries() argument
879 subManager_->PutLocalUnFinishedSubQueries(device, subscribeQueries); in PutUnfinishedSubQueries()