Home
last modified time | relevance | path

Searched refs:dbInfo (Results 1 - 25 of 30) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsubscribe_recorder.cpp18 void SubscribeRecorder::RecordSubscribe(const DistributedDB::DBInfo &dbInfo, const DistributedDB::DeviceID &deviceId, in RecordSubscribe() argument
23 [&dbInfo](const SubscribeEntry &entry) { in RecordSubscribe()
24 return entry.dbInfo.userId == dbInfo.userId && entry.dbInfo.appId == dbInfo.appId && in RecordSubscribe()
25 entry.dbInfo.storeId == dbInfo.storeId; in RecordSubscribe()
32 entry.dbInfo = dbInfo; in RecordSubscribe()
51 RemoveRemoteSubscribe(const DBInfo &dbInfo) RemoveRemoteSubscribe() argument
63 RemoveRemoteSubscribe(const DistributedDB::DBInfo &dbInfo, const DistributedDB::DeviceID &deviceId) RemoveRemoteSubscribe() argument
70 RemoveRemoteSubscribe(const DistributedDB::DBInfo &dbInfo, const DistributedDB::DeviceID &deviceId, const DistributedDB::QuerySyncObject &query) RemoveRemoteSubscribe() argument
77 GetSubscribeQuery(const DistributedDB::DBInfo &dbInfo, std::map<std::string, std::vector<QuerySyncObject>> &subscribeQuery) const GetSubscribeQuery() argument
91 RemoveSubscribeQueries(const DBInfo &dbInfo, const DeviceID &deviceId) RemoveSubscribeQueries() argument
103 RemoveSubscribeQuery(const DBInfo &dbInfo, const DeviceID &deviceId, const std::string &queryId) RemoveSubscribeQuery() argument
[all...]
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 &query);
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 &queryId);
54 DBInfo dbInfo; member
/foundation/ability/form_fwk/services/src/
H A Dform_db_cache.cpp185 for (const FormDBInfo &dbInfo : formDBInfos_) { in GetDBRecord()
186 if (dbInfo.formId == formId) { in GetDBRecord()
187 record.userId = dbInfo.userId; in GetDBRecord()
188 record.providerUserId= dbInfo.providerUserId; in GetDBRecord()
189 record.formName = dbInfo.formName; in GetDBRecord()
190 record.bundleName = dbInfo.bundleName; in GetDBRecord()
191 record.moduleName = dbInfo.moduleName; in GetDBRecord()
192 record.abilityName = dbInfo.abilityName; in GetDBRecord()
193 record.formUserUids = dbInfo.formUserUids; in GetDBRecord()
194 record.formLocation = dbInfo in GetDBRecord()
373 FormDBInfo dbInfo; BatchDeleteNoHostDBForms() local
445 FormDBInfo dbInfo; IsHostOwner() local
[all...]
H A Dform_event_util.cpp513 FormDBInfo dbInfo; in BatchDeleteNoHostDBForms() local
514 int errCode = FormDbCache::GetInstance().GetDBRecord(formId, dbInfo); in BatchDeleteNoHostDBForms()
516 dbInfo.formUserUids.emplace_back(uid); in BatchDeleteNoHostDBForms()
517 FormDbCache::GetInstance().SaveFormInfo(dbInfo); in BatchDeleteNoHostDBForms()
523 FormDBInfo dbInfo; in BatchDeleteNoHostDBForms() local
524 int errCode = FormDbCache::GetInstance().GetDBRecord(formId, dbInfo); in BatchDeleteNoHostDBForms()
526 FormIdKey removableModuleFormIdKey(dbInfo.bundleName, dbInfo.moduleName); in BatchDeleteNoHostDBForms()
H A Dform_data_mgr.cpp2079 for (const auto& dbInfo : formDBInfos) { in GetUnusedFormInstancesByFilter()
2080 if (formInstancesFilter.bundleName != dbInfo.bundleName) { in GetUnusedFormInstancesByFilter()
2083 if (!formInstancesFilter.moduleName.empty() && formInstancesFilter.moduleName != dbInfo.moduleName) { in GetUnusedFormInstancesByFilter()
2085 } else if (!formInstancesFilter.abilityName.empty() && formInstancesFilter.abilityName != dbInfo.abilityName) { in GetUnusedFormInstancesByFilter()
2087 } else if (!formInstancesFilter.formName.empty() && formInstancesFilter.formName != dbInfo.formName) { in GetUnusedFormInstancesByFilter()
2091 [&dbInfo](const auto &it) { return it.formId == dbInfo.formId; }); in GetUnusedFormInstancesByFilter()
2096 ErrCode getDbRet = FormDbCache::GetInstance().GetDBRecord(dbInfo.formId, dbRecord); in GetUnusedFormInstancesByFilter()
2101 instance.formId = dbInfo.formId; in GetUnusedFormInstancesByFilter()
2287 for (const auto& dbInfo in GetUnusedFormInfos()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_test.cpp875 void InitCommunicator(DBInfo &dbInfo, EnvHandle &envDevice, OnOfflineDevice &onlineCallback, ICommunicator *&comm) in InitCommunicator() argument
877 dbInfo.userId = USER_ID; in InitCommunicator()
878 dbInfo.appId = APP_ID; in InitCommunicator()
879 dbInfo.storeId = STORE_ID_1; in InitCommunicator()
880 dbInfo.isNeedSync = true; in InitCommunicator()
881 dbInfo.syncDualTupleMode = false; in InitCommunicator()
882 std::string label = DBCommon::GenerateHashLabel(dbInfo); in InitCommunicator()
919 DBInfo dbInfo; in HWTEST_F() local
922 InitCommunicator(dbInfo, envDeviceA, onlineForAA, commAA); in HWTEST_F()
926 InitCommunicator(dbInfo, envDevice in HWTEST_F()
998 DBInfo dbInfo; HWTEST_F() local
1054 DBInfo dbInfo; HWTEST_F() local
1121 DBInfo dbInfo; HWTEST_F() local
1178 DBInfo dbInfo; HWTEST_F() local
1221 DBInfo dbInfo; HWTEST_F() local
1313 DBInfo dbInfo = { HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h159 virtual void GetDBInfo(DBInfo &dbInfo) const in GetDBInfo()
161 dbInfo.appId = GetDbProperties().GetStringProp(DBProperties::APP_ID, ""); in GetDBInfo()
162 dbInfo.userId = GetDbProperties().GetStringProp(DBProperties::USER_ID, ""); in GetDBInfo()
163 dbInfo.storeId = GetDbProperties().GetStringProp(DBProperties::STORE_ID, ""); in GetDBInfo()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp1203 DBInfo dbInfo = { in HWTEST_F() local
1215 recorder.RecordSubscribe(dbInfo, DEVICE_A, querySyncObject); in HWTEST_F()
1216 recorder.RecordSubscribe(dbInfo, DEVICE_A, querySyncObject); in HWTEST_F()
1217 recorder.RemoveRemoteSubscribe(dbInfo, DEVICE_A, querySyncObject); in HWTEST_F()
1219 recorder.GetSubscribeQuery(dbInfo, subscribeQuery); in HWTEST_F()
1226 recorder.RemoveRemoteSubscribe(dbInfo, DEVICE_A, querySyncObject); in HWTEST_F()
1227 recorder.GetSubscribeQuery(dbInfo, subscribeQuery); in HWTEST_F()
1234 recorder.RecordSubscribe(dbInfo, DEVICE_A, querySyncObject); in HWTEST_F()
1236 recorder.RecordSubscribe(dbInfo, DEVICE_A, QuerySyncObject(query2)); in HWTEST_F()
1237 recorder.RemoveRemoteSubscribe(dbInfo, DEVICE_ in HWTEST_F()
1264 DBInfo dbInfo = { HWTEST_F() local
1369 DBInfo dbInfo = { HWTEST_F() local
[all...]
/foundation/ability/form_fwk/test/unittest/fms_form_mgr_delete_form_test/
H A Dfms_form_mgr_delete_form_test.cpp150 FormDBInfo dbInfo {formDBInfos[0]}; in HWTEST_F()
151 EXPECT_EQ(formId, dbInfo.formId); in HWTEST_F()
152 EXPECT_EQ(dataCnt, dbInfo.formUserUids.size()); in HWTEST_F()
306 FormDBInfo dbInfo {formDBInfos[0]}; in HWTEST_F()
307 EXPECT_EQ(formId, dbInfo.formId); in HWTEST_F()
309 EXPECT_EQ(dataCnt, dbInfo.formUserUids.size()); in HWTEST_F()
443 FormDBInfo dbInfo {formDBInfos[0]}; in HWTEST_F()
444 EXPECT_EQ(formId, dbInfo.formId); in HWTEST_F()
445 EXPECT_EQ(dataCnt, dbInfo.formUserUids.size()); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.cpp88 int DistributedDBToolsUnitTest::CreateMockSingleDb(DatabaseInfo &dbInfo, OpenDbProperties &properties) in CreateMockSingleDb() argument
90 std::string identifier = dbInfo.userId + "-" + dbInfo.appId + "-" + dbInfo.storeId; in CreateMockSingleDb()
94 if (OS::GetRealPath(dbInfo.dir, properties.uri) != E_OK) { in CreateMockSingleDb()
99 int errCode = DBCommon::CreateStoreDirectory(dbInfo.dir, identifierName, DBConstant::SINGLE_SUB_DIR, true); in CreateMockSingleDb()
104 properties.uri = dbInfo.dir + "/" + identifierName + "/" + in CreateMockSingleDb()
121 errCode = SQLiteUtils::SetUserVer(properties, dbInfo.dbUserVersion); in CreateMockSingleDb()
131 static int CreatMockMultiDb(OpenDbProperties &properties, DatabaseInfo &dbInfo) in CreatMockMultiDb() argument
135 int errCode = SQLiteUtils::SetUserVer(properties, dbInfo in CreatMockMultiDb()
144 OpenMockMultiDb(DatabaseInfo &dbInfo, OpenDbProperties &properties) OpenMockMultiDb() argument
183 CreateMockMultiDb(DatabaseInfo &dbInfo, OpenDbProperties &properties) CreateMockMultiDb() argument
[all...]
H A Ddistributeddb_tools_unit_test.h188 static int CreateMockSingleDb(DatabaseInfo &dbInfo, DistributedDB::OpenDbProperties &properties);
190 static int CreateMockMultiDb(DatabaseInfo &dbInfo, DistributedDB::OpenDbProperties &properties);
235 static int OpenMockMultiDb(DatabaseInfo &dbInfo, DistributedDB::OpenDbProperties &properties);
/foundation/ability/form_fwk/test/unittest/fms_form_mgr_add_form_test/
H A Dfms_form_mgr_add_form_test.cpp255 FormDBInfo dbInfo {formDBInfos[0]}; in HWTEST_F()
256 EXPECT_EQ(formId, dbInfo.formId); in HWTEST_F()
257 EXPECT_EQ(dataCnt, dbInfo.formUserUids.size()); in HWTEST_F()
344 FormDBInfo dbInfo {formDBInfos[0]}; in HWTEST_F()
345 EXPECT_EQ(formId, dbInfo.formId); in HWTEST_F()
346 EXPECT_EQ(formUserUidCnt, dbInfo.formUserUids.size()); in HWTEST_F()
429 FormDBInfo dbInfo {formDBInfos[0]}; in HWTEST_F()
430 EXPECT_EQ(formId, dbInfo.formId); in HWTEST_F()
431 EXPECT_EQ(formUserUidCnt, dbInfo.formUserUids.size()); in HWTEST_F()
763 FormDBInfo dbInfo {formDBInfo in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Druntime_context.h155 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.h142 static std::string GenerateHashLabel(const DBInfo &dbInfo);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync_extend.cpp246 DBInfo dbInfo; in SubscribeRequestRecv() local
247 storage_->GetDBInfo(dbInfo); in SubscribeRequestRecv()
248 RuntimeContext::GetInstance()->RecordRemoteSubscribe(dbInfo, context->GetDeviceId(), packet->GetQuery()); in SubscribeRequestRecv()
283 DBInfo dbInfo; in UnsubscribeRequestRecv() local
284 storage_->GetDBInfo(dbInfo); in UnsubscribeRequestRecv()
285 RuntimeContext::GetInstance()->RemoveRemoteSubscribe(dbInfo, context->GetDeviceId(), packet->GetQuery()); in UnsubscribeRequestRecv()
H A Dsingle_ver_kv_syncer.cpp316 DBInfo dbInfo; in TriggerAddSubscribeAsync() local
318 storage->GetDBInfo(dbInfo); in TriggerAddSubscribeAsync()
320 RuntimeContext::GetInstance()->GetSubscribeQuery(dbInfo, subscribeQuery); in TriggerAddSubscribeAsync()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dkvstore_meta_manager.cpp485 DistributedDB::DBInfo dbInfo;
486 dbInfo.appId = metaData.deviceId;
487 dbInfo.userId = metaData.user;
488 dbInfo.storeId = metaData.storeId;
489 dbInfo.isNeedSync = !isDeleted;
490 dbInfo.syncDualTupleMode = true;
491 dbInfos.push_back(dbInfo);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Druntime_context_impl.h140 void RecordRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId, const QuerySyncObject &query) override;
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 &query) override;
150 void GetSubscribeQuery(const DBInfo &dbInfo,
H A Druntime_context_impl.cpp829 void RuntimeContextImpl::RecordRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId,
838 subscribeRecorder->RecordSubscribe(dbInfo, deviceId, query);
854 void RuntimeContextImpl::RemoveRemoteSubscribe(const DBInfo &dbInfo)
862 subscribeRecorder->RemoveRemoteSubscribe(dbInfo);
866 void RuntimeContextImpl::RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId)
874 subscribeRecorder->RemoveRemoteSubscribe(dbInfo, deviceId);
878 void RuntimeContextImpl::RemoveRemoteSubscribe(const DBInfo &dbInfo, const DeviceID &deviceId,
887 subscribeRecorder->RemoveRemoteSubscribe(dbInfo, deviceId, query);
891 void RuntimeContextImpl::GetSubscribeQuery(const DBInfo &dbInfo,
900 subscribeRecorder->GetSubscribeQuery(dbInfo, subscribeQuer
[all...]
H A Ddb_common.cpp748 std::string DBCommon::GenerateHashLabel(const DBInfo &dbInfo) in GenerateHashLabel() argument
750 if (dbInfo.syncDualTupleMode) { in GenerateHashLabel()
751 return DBCommon::TransferHashString(dbInfo.appId + "-" + dbInfo.storeId); in GenerateHashLabel()
753 return DBCommon::TransferHashString(dbInfo.userId + "-" + dbInfo.appId + "-" + dbInfo.storeId); in GenerateHashLabel()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Ddb_status_adapter.cpp278 for (const auto &dbInfo: dbInfos) { in NotifyRemoteOffline()
279 if (dbInfo.isNeedSync) { in NotifyRemoteOffline()
280 DBInfo info = dbInfo; in NotifyRemoteOffline()
H A Dcommunicator_linker.cpp290 for (const auto &dbInfo: dbInfos) { in TriggerLabelExchangeEvent()
291 std::string label = DBCommon::GenerateHashLabel(dbInfo); in TriggerLabelExchangeEvent()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_delegate_manager.cpp424 DBInfo dbInfo; in DeleteKvStore() local
425 dbInfo.userId = userId_; in DeleteKvStore()
426 dbInfo.appId = appId_; in DeleteKvStore()
427 dbInfo.storeId = storeId; in DeleteKvStore()
428 RuntimeContext::GetInstance()->RemoveRemoteSubscribe(dbInfo); in DeleteKvStore()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoremanager_fuzzer/
H A Drelationalstoremanager_fuzzer.cpp108 DBInfo dbInfo = { in RuntimeConfigTest() local
115 dbInfos.push_back(dbInfo); in RuntimeConfigTest()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/mock/src/
H A Dbundle_mgr_service_event_handler.cpp329 InnerBundleInfo dbInfo; in SaveInstallInfoToCache() local
333 bundleExist = dataMgr->FetchInnerBundleInfo(bundleName, dbInfo); in SaveInstallInfoToCache()
345 dbInfo.GetModuleNames(dbModuleNames); in SaveInstallInfoToCache()
353 dataMgr->AddNewModuleInfo(bundleName, info, dbInfo); in SaveInstallInfoToCache()

Completed in 25 milliseconds

12