Home
last modified time | relevance | path

Searched refs:DBInfo (Results 1 – 25 of 29) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_recorder.h31 …void RecordSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId, const QuerySyncObject &query);
37 void RemoveRemoteSubscribe(const DBInfo &dbInfo);
39 void RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId);
41 …void RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId, const QuerySyncObject &…
43 void GetSubscribeQuery(const DBInfo &dbInfo,
47 void RemoveSubscribeQueries(const DBInfo &dbInfo, const DeviceID &deviceId);
49 …void RemoveSubscribeQuery(const DBInfo &dbInfo, const DeviceID &deviceId, const std::string &query…
51 static bool CheckSameDBInfo(const DBInfo &srcDbInfo, const DBInfo &dtsDbInfo);
54 DBInfo dbInfo;
H A Dsubscribe_recorder.cpp18 void SubscribeRecorder::RecordSubscribe(const DistributedDB::DBInfo &dbInfo, const DistributedDB::D… in RecordSubscribe()
51 void SubscribeRecorder::RemoveRemoteSubscribe(const DBInfo &dbInfo) in RemoveRemoteSubscribe()
63 void SubscribeRecorder::RemoveRemoteSubscribe(const DistributedDB::DBInfo &dbInfo, in RemoveRemoteSubscribe()
70 void SubscribeRecorder::RemoveRemoteSubscribe(const DistributedDB::DBInfo &dbInfo, in RemoveRemoteSubscribe()
77 void SubscribeRecorder::GetSubscribeQuery(const DistributedDB::DBInfo &dbInfo, in GetSubscribeQuery()
91 void SubscribeRecorder::RemoveSubscribeQueries(const DBInfo &dbInfo, const DeviceID &deviceId) in RemoveSubscribeQueries()
103 void SubscribeRecorder::RemoveSubscribeQuery(const DBInfo &dbInfo, const DeviceID &deviceId, in RemoveSubscribeQuery()
124 bool SubscribeRecorder::CheckSameDBInfo(const DBInfo &srcDbInfo, const DBInfo &dtsDbInfo) in CheckSameDBInfo()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Ddb_status_adapter.h24 …angeCallback = std::function<void(const std::string &devInfo, const std::vector<DBInfo> &dbInfos)>;
35 int GetLocalDBInfos(std::vector<DBInfo> &dbInfos);
38 void NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos);
46 … bool LoadIntoCache(bool isLocal, const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos);
52 … static bool MergeDBInfos(const std::vector<DBInfo> &srcDbInfos, std::vector<DBInfo> &dstDbInfos);
62 std::vector<DBInfo> localDBInfos_;
65 …std::map<std::string, std::vector<DBInfo>> remoteDBInfos_; // key: device uuid, value: all db whic…
H A Dcommunicator_aggregator.h138 void OnRemoteDBStatusChange(const std::string &devInfo, const std::vector<DBInfo> &dbInfos);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Ddb_status_adapter.cpp60 int DBStatusAdapter::GetLocalDBInfos(std::vector<DBInfo> &dbInfos) in GetLocalDBInfos()
94 std::map<std::string, std::vector<DBInfo>> remoteDBInfos; in SetDBStatusChangeCallback()
123 void DBStatusAdapter::NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) in NotifyDBInfos()
242 …apter::LoadIntoCache(bool isLocal, const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) in LoadIntoCache()
274 std::map<std::string, std::vector<DBInfo>> remoteOnlineDBInfos; in NotifyRemoteOffline()
280 DBInfo info = dbInfo; in NotifyRemoteOffline()
302 bool DBStatusAdapter::MergeDBInfos(const std::vector<DBInfo> &srcDbInfos, std::vector<DBInfo> &dstD… in MergeDBInfos()
309 … auto res = std::find_if(dstDbInfos.begin(), dstDbInfos.end(), [&srcInfo](const DBInfo &dstInfo) { in MergeDBInfos()
H A Dcommunicator_aggregator.cpp877 …rAggregator::OnRemoteDBStatusChange(const std::string &devInfo, const std::vector<DBInfo> &dbInfos) in OnRemoteDBStatusChange()
917 [this](const std::string &devInfo, const std::vector<DBInfo> &dbInfos) { in RegDBChangeCallback()
H A Dcommunicator_linker.cpp288 std::vector<DBInfo> dbInfos; in TriggerLabelExchangeEvent()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Druntime_context.h153 virtual void NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) = 0;
155 virtual void RecordRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId,
160 virtual void RemoveRemoteSubscribe(const DBInfo &dbInfo) = 0;
162 virtual void RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId) = 0;
164 virtual void RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId,
167 virtual void GetSubscribeQuery(const DBInfo &dbInfo,
H A Ddb_common.h140 static std::string GenerateHashLabel(const DBInfo &dbInfo);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Druntime_context_impl.h138 void NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) override;
140 …void RecordRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId, const QuerySyncObject &…
144 void RemoveRemoteSubscribe(const DBInfo &dbInfo) override;
146 void RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId) override;
148 …void RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId, const QuerySyncObject &…
150 void GetSubscribeQuery(const DBInfo &dbInfo,
H A Druntime_context_impl.cpp808 void RuntimeContextImpl::NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbIn… in NotifyDBInfos()
828 void RuntimeContextImpl::RecordRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId, in RecordRemoteSubscribe()
853 void RuntimeContextImpl::RemoveRemoteSubscribe(const DBInfo &dbInfo) in RemoveRemoteSubscribe()
865 void RuntimeContextImpl::RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId) in RemoveRemoteSubscribe()
877 void RuntimeContextImpl::RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId, in RemoveRemoteSubscribe()
890 void RuntimeContextImpl::GetSubscribeQuery(const DBInfo &dbInfo, in GetSubscribeQuery()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dextension_util.h37 using DBInfo = DistributedData::CloudInfo::AppInfo; variable
46 static DBInfo ConvertAppInfo(OhCloudExtAppInfo *appInfo);
H A Dextension_util.cpp405 DBInfo ExtensionUtil::ConvertAppInfo(OhCloudExtAppInfo *appInfo) in ConvertAppInfo()
407 DBInfo info; in ConvertAppInfo()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dkvstore_meta_manager.cpp452 std::vector<DistributedDB::DBInfo> dbInfos; in OnDataChange()
458 …ger::GetDbInfosByDeviceId(const std::string& deviceId, std::vector<DistributedDB::DBInfo>& dbInfos) in GetDbInfosByDeviceId()
472 void KvStoreMetaManager::AddDbInfo(const StoreMetaData& metaData, std::vector<DistributedDB::DBInfo… in AddDbInfo()
475 DistributedDB::DBInfo dbInfo; in AddDbInfo()
486 std::vector<DistributedDB::DBInfo> dbInfos; in OnDeviceChange()
503 std::vector<DistributedDB::DBInfo> dbInfos; in NotifyAllAutoSyncDBInfo()
H A Dkvstore_meta_manager.h88 …DbInfo(const DistributedData::StoreMetaData& metaData, std::vector<DistributedDB::DBInfo>& dbInfos,
91 …void GetDbInfosByDeviceId(const std::string& deviceId, std::vector<DistributedDB::DBInfo>& dbInfos…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_test.cpp919 DBInfo dbInfo;
998 DBInfo dbInfo;
1054 DBInfo dbInfo;
1121 DBInfo dbInfo;
1178 DBInfo dbInfo;
1221 DBInfo dbInfo;
1238 …lRemoteDevInfo, &remoteInfoCount](const std::string &devInfo, const std::vector<DBInfo> &dbInfos) { in __anonf82a9c550f02()
1290 std::vector<DBInfo> dbInfos;
1312 std::vector<DBInfo> dbInfos;
1313 DBInfo dbInfo = {
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dmock_kv_sync_interface.h27 MOCK_CONST_METHOD1(GetDBInfo, void(DBInfo &));
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp1203 DBInfo dbInfo = {
1264 DBInfo dbInfo = {
1278 DBInfo dbInfo2 = dbInfo;
1369 DBInfo dbInfo = {
H A Ddistributeddb_mock_sync_module_test.cpp1139 EXPECT_CALL(*syncDBInterface, GetDBInfo(_)).WillRepeatedly([&dbInfoCount](DBInfo &) { in __anon34a84a721102() argument
2082 EXPECT_CALL(*syncDBInterface, GetDBInfo(_)).WillRepeatedly([](DBInfo &) { in __anon34a84a722602() argument
2090 DBInfo info;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoremanager_fuzzer/
H A Drelationalstoremanager_fuzzer.cpp107 std::vector<DBInfo> dbInfos; in RuntimeConfigTest()
108 DBInfo dbInfo = { in RuntimeConfigTest()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Druntime_config.h64 … DB_API static void NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos);
H A Dstore_types.h204 struct DBInfo { struct
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h149 virtual void GetDBInfo(DBInfo &dbInfo) const in GetDBInfo()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Druntime_config.cpp134 void RuntimeConfig::NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) in NotifyDBInfos()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_kv_syncer.cpp316 DBInfo dbInfo; in TriggerAddSubscribeAsync()

12