Home
last modified time | relevance | path

Searched refs:GetLocalSubscribeQueries (Results 1 – 6 of 6) 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.cpp393 subManager.GetLocalSubscribeQueries(device, subscribeQueries);
406 subManager.GetLocalSubscribeQueries(device, subscribeQueries);
414 subManager.GetLocalSubscribeQueries(device, subscribeQueries);
425 subManager.GetLocalSubscribeQueries(device, subscribeQueries);
435 subManager.GetLocalSubscribeQueries(device, subscribeQueries);
439 subManager.GetLocalSubscribeQueries(device, subscribeQueries);
522 subManager.GetLocalSubscribeQueries(device + std::to_string(i), subscribeQueries);
532 subManager.GetLocalSubscribeQueries(device + std::to_string(i), subscribeQueries);
624 subManager.GetLocalSubscribeQueries(DEVICE_A, subscribeQueries);
628 subManager.GetLocalSubscribeQueries(DEVICE_B, subscribeQueries);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_manager.h78 …void GetLocalSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &subscribeQu…
H A Dsync_engine.h89 …void GetLocalSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &subscribeQu…
H A Dsync_engine.cpp861 void SyncEngine::GetLocalSubscribeQueries(const std::string &device, std::vector<QuerySyncObject> &… in GetLocalSubscribeQueries() function in DistributedDB::SyncEngine
863 subManager_->GetLocalSubscribeQueries(device, subscribeQueries); in GetLocalSubscribeQueries()
H A Dsubscribe_manager.cpp159 void SubscribeManager::GetLocalSubscribeQueries(const std::string &device, in GetLocalSubscribeQueries() function in DistributedDB::SubscribeManager
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_kv_syncer.cpp157 static_cast<SingleVerSyncEngine *>(syncEngine_)->GetLocalSubscribeQueries(device, syncQueries); in RemoteDataChanged()