Home
last modified time | relevance | path

Searched refs:dbInfos (Results 1 - 15 of 15) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Ddb_status_adapter.cpp60 int DBStatusAdapter::GetLocalDBInfos(std::vector<DBInfo> &dbInfos) in GetLocalDBInfos() argument
73 dbInfos.push_back(info); in GetLocalDBInfos()
111 for (const auto &[devInfo, dbInfos]: remoteDBInfos) { in SetDBStatusChangeCallback()
112 remote(devInfo, dbInfos); in SetDBStatusChangeCallback()
123 void DBStatusAdapter::NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) in NotifyDBInfos() argument
125 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, devInfos, dbInfos]() { in NotifyDBInfos()
135 bool isChange = LoadIntoCache(isLocal, devInfos, dbInfos); in NotifyDBInfos()
138 remoteCallback_(devInfos.identifier, dbInfos); in NotifyDBInfos()
242 bool DBStatusAdapter::LoadIntoCache(bool isLocal, const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) in LoadIntoCache() argument
246 return MergeDBInfos(dbInfos, localDBInfos in LoadIntoCache()
[all...]
H A Dcommunicator_linker.cpp288 std::vector<DBInfo> dbInfos; in TriggerLabelExchangeEvent() local
289 if (statusAdapter_ != nullptr && statusAdapter_->GetLocalDBInfos(dbInfos) == E_OK) { in TriggerLabelExchangeEvent()
290 for (const auto &dbInfo: dbInfos) { in TriggerLabelExchangeEvent()
H A Dcommunicator_aggregator.cpp874 void CommunicatorAggregator::OnRemoteDBStatusChange(const std::string &devInfo, const std::vector<DBInfo> &dbInfos) in OnRemoteDBStatusChange() argument
877 for (const auto &dbInfo: dbInfos) { in OnRemoteDBStatusChange()
914 [this](const std::string &devInfo, const std::vector<DBInfo> &dbInfos) { in RegDBChangeCallback()
915 OnRemoteDBStatusChange(devInfo, dbInfos); in RegDBChangeCallback()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Ddb_status_adapter.h24 using RemoteDBChangeCallback = 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);
H A Dcommunicator_aggregator.h138 void OnRemoteDBStatusChange(const std::string &devInfo, const std::vector<DBInfo> &dbInfos);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dkvstore_meta_manager.cpp462 std::vector<DistributedDB::DBInfo> dbInfos;
463 AddDbInfo(metaData, dbInfos, flag == CHANGE_FLAG::DELETE);
464 DistributedDB::RuntimeConfig::NotifyDBInfos({ metaData.deviceId }, dbInfos);
468 void KvStoreMetaManager::GetDbInfosByDeviceId(const std::string& deviceId, std::vector<DistributedDB::DBInfo>& dbInfos)
477 AddDbInfo(data, dbInfos);
482 void KvStoreMetaManager::AddDbInfo(const StoreMetaData& metaData, std::vector<DistributedDB::DBInfo>& dbInfos,
491 dbInfos.push_back(dbInfo);
496 std::vector<DistributedDB::DBInfo> dbInfos;
497 GetDbInfosByDeviceId(deviceId, dbInfos);
498 DistributedDB::RuntimeConfig::NotifyDBInfos({ deviceId }, dbInfos);
[all...]
H A Dkvstore_meta_manager.h88 void AddDbInfo(const DistributedData::StoreMetaData& metaData, std::vector<DistributedDB::DBInfo>& dbInfos,
91 void GetDbInfosByDeviceId(const std::string& deviceId, std::vector<DistributedDB::DBInfo>& dbInfos);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoremanager_fuzzer/
H A Drelationalstoremanager_fuzzer.cpp107 std::vector<DBInfo> dbInfos; in RuntimeConfigTest() local
115 dbInfos.push_back(dbInfo); in RuntimeConfigTest()
117 RuntimeConfig::NotifyDBInfos({ device }, dbInfos); in RuntimeConfigTest()
/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() argument
136 RuntimeContext::GetInstance()->NotifyDBInfos(devInfos, dbInfos); in NotifyDBInfos()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_test.cpp1238 [&actualRemoteDevInfo, &remoteInfoCount](const std::string &devInfo, const std::vector<DBInfo> &dbInfos) { in HWTEST_F()
1240 remoteInfoCount = dbInfos.size(); in HWTEST_F()
1290 std::vector<DBInfo> dbInfos; in HWTEST_F() local
1291 EXPECT_EQ(adapterA->GetLocalDBInfos(dbInfos), E_OK); in HWTEST_F()
1293 EXPECT_EQ(adapterA->GetLocalDBInfos(dbInfos), E_OK); in HWTEST_F()
1295 EXPECT_EQ(adapterA->GetLocalDBInfos(dbInfos), -E_NOT_SUPPORT); in HWTEST_F()
1312 std::vector<DBInfo> dbInfos; in HWTEST_F() local
1320 dbInfos.push_back(dbInfo); in HWTEST_F()
1322 dbInfos.push_back(dbInfo); in HWTEST_F()
1325 dbInfos in HWTEST_F()
[all...]
/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);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dcloud_service_impl.cpp315 std::map<std::string, std::vector<std::string>> dbInfos; in GetDbInfoFromExtraData() local
322 dbInfos.emplace(db.name, std::move(tables)); in GetDbInfoFromExtraData()
340 dbInfos.emplace(db.name, std::move(tables)); in GetDbInfoFromExtraData()
343 if (dbInfos.empty()) { in GetDbInfoFromExtraData()
349 dbInfos.emplace(db.name, std::move(tables)); in GetDbInfoFromExtraData()
352 return dbInfos; in GetDbInfoFromExtraData()
428 auto dbInfos = GetDbInfoFromExtraData(exData, schemaMeta); in NotifyDataChange() local
429 if (dbInfos.empty()) { in NotifyDataChange()
434 for (const auto &dbInfo : dbInfos) { in NotifyDataChange()
/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;
/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;
H A Druntime_context_impl.cpp809 void RuntimeContextImpl::NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos)
813 dbStatusAdapter->NotifyDBInfos(devInfos, dbInfos);

Completed in 14 milliseconds