Home
last modified time | relevance | path

Searched refs:storeId (Results 1 - 25 of 308) sorted by relevance

12345678910>>...13

/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dstore_manager.cpp32 std::shared_ptr<SingleKvStore> StoreManager::GetKVStore(const AppId &appId, const StoreId &storeId, in GetKVStore() argument
36 ZLOGD("appId:%{public}s, storeId:%{public}s type:%{public}d area:%{public}d dir:%{public}s", appId.appId.c_str(), in GetKVStore()
37 StoreUtil::Anonymous(storeId.storeId).c_str(), options.kvStoreType, options.area, path.c_str()); in GetKVStore()
39 if (!appId.IsValid() || !storeId.IsValid() || !options.IsValidType()) { in GetKVStore()
46 status = service->BeforeCreate(appId, storeId, options); in GetKVStore()
49 ZLOGE("appId:%{public}s, storeId:%{public}s type:%{public}d encrypt:%{public}d", appId.appId.c_str(), in GetKVStore()
50 StoreUtil::Anonymous(storeId.storeId).c_str(), options.kvStoreType, options.encrypt); in GetKVStore()
54 auto kvStore = StoreFactory::GetInstance().GetOrOpenStore(appId, storeId, option in GetKVStore()
83 GetSecretKeyFromService(const AppId &appId, const StoreId &storeId, const std::string &path) GetSecretKeyFromService() argument
111 CloseKVStore(const AppId &appId, const StoreId &storeId) CloseKVStore() argument
145 Delete(const AppId &appId, const StoreId &storeId, const std::string &path) Delete() argument
[all...]
H A Dkvdb_service_client.cpp118 Status KVDBServiceClient::BeforeCreate(const AppId &appId, const StoreId &storeId, const Options &options) in BeforeCreate() argument
122 reply, appId, storeId, options); in BeforeCreate()
124 ZLOGE("status:0x%{public}x appId:%{public}s, storeId:%{public}s", status, appId.appId.c_str(), in BeforeCreate()
125 StoreUtil::Anonymous(storeId.storeId).c_str()); in BeforeCreate()
131 const AppId &appId, const StoreId &storeId, const Options &options, const std::vector<uint8_t> &password) in AfterCreate()
135 reply, appId, storeId, options, password); in AfterCreate()
137 ZLOGE("status:0x%{public}x appId:%{public}s, storeId:%{public}s, encrypt:%{public}d", status, in AfterCreate()
138 appId.appId.c_str(), StoreUtil::Anonymous(storeId.storeId) in AfterCreate()
130 AfterCreate( const AppId &appId, const StoreId &storeId, const Options &options, const std::vector<uint8_t> &password) AfterCreate() argument
143 Delete(const AppId &appId, const StoreId &storeId) Delete() argument
155 Close(const AppId &appId, const StoreId &storeId) Close() argument
167 Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) Sync() argument
179 CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) CloudSync() argument
191 NotifyDataChange(const AppId &appId, const StoreId &storeId, uint64_t delay) NotifyDataChange() argument
226 SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) SetSyncParam() argument
238 GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) GetSyncParam() argument
252 EnableCapability(const AppId &appId, const StoreId &storeId) EnableCapability() argument
264 DisableCapability(const AppId &appId, const StoreId &storeId) DisableCapability() argument
276 SetCapability(const AppId &appId, const StoreId &storeId, const std::vector<std::string> &local, const std::vector<std::string> &remote) SetCapability() argument
289 AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) AddSubscribeInfo() argument
302 RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) RmvSubscribeInfo() argument
315 Subscribe(const AppId &appId, const StoreId &storeId, sptr<IKvStoreObserver> observer) Subscribe() argument
328 Unsubscribe(const AppId &appId, const StoreId &storeId, sptr<IKvStoreObserver> observer) Unsubscribe() argument
341 GetBackupPassword( const AppId &appId, const StoreId &storeId, std::vector<uint8_t> &password, int32_t passwordType) GetBackupPassword() argument
416 SetConfig(const AppId &appId, const StoreId &storeId, const StoreConfig &storeConfig) SetConfig() argument
428 RemoveDeviceData(const AppId &appId, const StoreId &storeId, const std::string &device) RemoveDeviceData() argument
[all...]
H A Dstore_factory.cpp60 std::shared_ptr<SingleKvStore> StoreFactory::GetOrOpenStore(const AppId &appId, const StoreId &storeId, in GetOrOpenStore() argument
66 if (stores.find(storeId) != stores.end()) { in GetOrOpenStore()
67 kvStore = stores[storeId]; in GetOrOpenStore()
75 SecurityManager::GetInstance().GetDBPassword(storeId.storeId, path, options.encrypt); in GetOrOpenStore()
78 ZLOGE("Crypt kvStore failed to get password, storeId is %{public}s, error is %{public}d", in GetOrOpenStore()
79 StoreUtil::Anonymous(storeId.storeId).c_str(), static_cast<int>(status)); in GetOrOpenStore()
83 status = RekeyRecover(storeId, path, dbPassword, dbManager, options); in GetOrOpenStore()
85 ZLOGE("KvStore password error, storeId i in GetOrOpenStore()
120 Delete(const AppId &appId, const StoreId &storeId, const std::string &path) Delete() argument
129 Close(const AppId &appId, const StoreId &storeId, bool isForce) Close() argument
205 ReKey(const std::string &storeId, const std::string &path, DBPassword &dbPassword, std::shared_ptr<DBManager> dbManager, const Options &options) ReKey() argument
234 RekeyRecover(const std::string &storeId, const std::string &path, DBPassword &dbPassword, std::shared_ptr<DBManager> dbManager, const Options &options) RekeyRecover() argument
264 IsPwdValid(const std::string &storeId, std::shared_ptr<DBManager> dbManager, const Options &options, DBPassword &dbPassword) IsPwdValid() argument
278 ExecuteRekey(const std::string &storeId, const std::string &path, DBPassword &dbPassword, DBStore *dbStore) ExecuteRekey() argument
[all...]
H A Dbackup_manager.cpp56 for (auto &storeId : storeIds) { in Init()
57 if (storeId == "." || storeId == "..") { in Init()
60 auto backupPath = topPath + "/" + storeId; in Init()
62 if (HaveResidueFile(backupFiles) || HaveResidueKey(keyFiles, storeId)) { in Init()
63 auto ResidueInfo = BuildResidueInfo(backupFiles, keyFiles, storeId); in Init()
64 ClearResidueFile(ResidueInfo, baseDir, storeId); in Init()
71 void BackupManager::Prepare(const std::string &path, const std::string &storeId) in Prepare() argument
74 std::string storePath = topPath + "/" + storeId; in Prepare()
110 const std::string &name, const std::string &baseDir, const std::string &storeId, st in Backup()
109 Backup( const std::string &name, const std::string &baseDir, const std::string &storeId, std::shared_ptr<DBStore> dbStore) Backup() argument
154 GetBackupFileInfo( const std::string &name, const std::string &baseDir, const std::string &storeId) GetBackupFileInfo() argument
176 Restore(const std::string &name, const std::string &baseDir, const std::string &appId, const std::string &storeId, std::shared_ptr<DBStore> dbStore) Restore() argument
196 GetRestorePassword( const std::string &name, const std::string &baseDir, const std::string &appId, const std::string &storeId) GetRestorePassword() argument
217 DeleteBackup( std::map<std::string, Status> &deleteList, const std::string &baseDir, const std::string &storeId) DeleteBackup() argument
253 HaveResidueKey(const std::vector<StoreUtil::FileInfo> &files, std::string storeId) HaveResidueKey() argument
294 BuildResidueInfo( const std::vector<StoreUtil::FileInfo> &files, const std::vector<StoreUtil::FileInfo> &keys, const std::string &storeId) BuildResidueInfo() argument
386 ClearResidueFile( std::map<std::string, ResidueInfo> residueInfo, const std::string &baseDir, const std::string &storeId) ClearResidueFile() argument
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_service_stub.cpp76 return (this->*HANDLERS[code])({ storeInfo.bundleName }, { storeInfo.storeId }, data, reply); in OnRemoteRequest()
78 ZLOGE("PERMISSION_DENIED uid:%{public}d appId:%{public}s storeId:%{public}s", storeInfo.uid, in OnRemoteRequest()
79 storeInfo.bundleName.c_str(), Anonymous::Change(storeInfo.storeId).c_str()); in OnRemoteRequest()
82 ZLOGE("Marshal PERMISSION_DENIED code:%{public}u appId:%{public}s storeId:%{public}s", code, in OnRemoteRequest()
83 storeInfo.bundleName.c_str(), Anonymous::Change(storeInfo.storeId).c_str()); in OnRemoteRequest()
92 StoreId storeId; in GetStoreInfo() local
93 if (!ITypesUtil::Unmarshal(data, appId, storeId)) { in GetStoreInfo()
94 ZLOGE("Unmarshal appId:%{public}s storeId:%{public}s", in GetStoreInfo()
95 appId.appId.c_str(), Anonymous::Change(storeId.storeId) in GetStoreInfo()
117 OnGetStoreIds( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnGetStoreIds() argument
129 OnBeforeCreate( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnBeforeCreate() argument
147 OnAfterCreate( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnAfterCreate() argument
167 OnDelete(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnDelete() argument
178 OnClose(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnClose() argument
189 OnSync(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnSync() argument
206 OnCloudSync( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnCloudSync() argument
224 OnNotifyDataChange( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnNotifyDataChange() argument
242 OnRegServiceNotifier( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnRegServiceNotifier() argument
261 OnUnregServiceNotifier( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnUnregServiceNotifier() argument
273 OnSetSyncParam( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnSetSyncParam() argument
291 OnGetSyncParam( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnGetSyncParam() argument
304 OnEnableCap( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnEnableCap() argument
316 OnDisableCap( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnDisableCap() argument
328 OnSetCapability( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnSetCapability() argument
347 OnAddSubInfo(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnAddSubInfo() argument
365 OnRmvSubInfo(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnRmvSubInfo() argument
383 OnSubscribe( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnSubscribe() argument
402 OnUnsubscribe( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnUnsubscribe() argument
421 OnGetBackupPassword( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnGetBackupPassword() argument
442 OnPutSwitch( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnPutSwitch() argument
458 OnGetSwitch( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnGetSwitch() argument
477 OnSubscribeSwitchData( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnSubscribeSwitchData() argument
488 OnUnsubscribeSwitchData( const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnUnsubscribeSwitchData() argument
499 OnSetConfig(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnSetConfig() argument
516 OnRemoveDeviceData(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply) OnRemoveDeviceData() argument
[all...]
H A Dkvdb_service_stub.h31 const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
32 int32_t OnGetStoreIds(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
33 int32_t OnBeforeCreate(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
34 int32_t OnAfterCreate(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
35 int32_t OnDelete(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
36 int32_t OnClose(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
37 int32_t OnSync(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
38 int32_t OnCloudSync(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
39 int32_t OnRegServiceNotifier(const AppId &appId, const StoreId &storeId, MessageParcel &data, MessageParcel &reply);
41 const AppId &appId, const StoreId &storeId, MessageParce
[all...]
H A Dkvdb_service_impl.cpp104 ZLOGE("meta empty, bundleName:%{public}s, storeId:%{public}s, user = %{public}s", in Init()
112 ZLOGE("meta empty, not public store. bundleName:%{public}s, storeId:%{public}s, user = %{public}s", in Init()
121 auto watchers = GetWatchers(meta.tokenId, meta.storeId); in Init()
124 ZLOGE("store null, storeId:%{public}s", meta.GetStoreAlias().c_str()); in Init()
169 storeIds.push_back({ item.storeId }); in GetStoreIds()
175 Status KVDBServiceImpl::Delete(const AppId &appId, const StoreId &storeId) in Delete() argument
177 StoreMetaData metaData = GetStoreMetaData(appId, storeId); in Delete()
183 syncAgents_.ComputeIfPresent(tokenId, [&appId, &storeId](auto &key, SyncAgent &syncAgent) { in Delete()
189 syncAgent.delayTimes_.erase(storeId); in Delete()
201 AutoCache::GetInstance().CloseStore(tokenId, storeId); in Delete()
207 Close(const AppId &appId, const StoreId &storeId) Close() argument
220 CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) CloudSync() argument
240 Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) Sync() argument
265 NotifyDataChange(const AppId &appId, const StoreId &storeId, uint64_t delay) NotifyDataChange() argument
442 SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) SetSyncParam() argument
461 GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) GetSyncParam() argument
481 EnableCapability(const AppId &appId, const StoreId &storeId) EnableCapability() argument
493 DisableCapability(const AppId &appId, const StoreId &storeId) DisableCapability() argument
505 SetCapability(const AppId &appId, const StoreId &storeId, const std::vector<std::string> &local, const std::vector<std::string> &remote) SetCapability() argument
519 AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) AddSubscribeInfo() argument
529 RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) RmvSubscribeInfo() argument
540 Subscribe(const AppId &appId, const StoreId &storeId, sptr<IKvStoreObserver> observer) Subscribe() argument
565 Unsubscribe(const AppId &appId, const StoreId &storeId, sptr<IKvStoreObserver> observer) Unsubscribe() argument
594 GetBackupPassword(const AppId &appId, const StoreId &storeId, std::vector<uint8_t> &password, int32_t passwordType) GetBackupPassword() argument
611 SetConfig(const AppId &appId, const StoreId &storeId, const StoreConfig &storeConfig) SetConfig() argument
640 BeforeCreate(const AppId &appId, const StoreId &storeId, const Options &options) BeforeCreate() argument
686 AfterCreate( const AppId &appId, const StoreId &storeId, const Options &options, const std::vector<uint8_t> &password) AfterCreate() argument
857 GetStoreMetaData(const AppId &appId, const StoreId &storeId) GetStoreMetaData() argument
871 GetStrategyMeta(const AppId &appId, const StoreId &storeId) GetStrategyMeta() argument
1148 GetSyncDelayTime(uint32_t delay, const StoreId &storeId) GetSyncDelayTime() argument
1327 GetWatchers(uint32_t tokenId, const std::string &storeId) GetWatchers() argument
1385 RemoveDeviceData(const AppId &appId, const StoreId &storeId, const std::string &device) RemoveDeviceData() argument
[all...]
H A Dkvdb_service_impl.h45 Status BeforeCreate(const AppId &appId, const StoreId &storeId, const Options &options) override;
46 Status AfterCreate(const AppId &appId, const StoreId &storeId, const Options &options,
48 Status Delete(const AppId &appId, const StoreId &storeId) override;
49 Status Close(const AppId &appId, const StoreId &storeId) override;
50 Status CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
51 Status Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) override;
54 Status SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) override;
55 Status GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) override;
56 Status EnableCapability(const AppId &appId, const StoreId &storeId) override;
57 Status DisableCapability(const AppId &appId, const StoreId &storeId) overrid
[all...]
/foundation/distributeddatamgr/kv_store/test/fuzztest/distributedkvdatamanager_fuzzer/
H A Ddistributedkvdatamanager_fuzzer.cpp96 StoreId storeId; in GetKvStoreFuzz() local
97 storeId.storeId = std::string(data, data + size); in GetKvStoreFuzz()
99 manager.GetSingleKvStore(create, appId, storeId, notExistKvStore); in GetKvStoreFuzz()
101 manager.GetSingleKvStore(noCreate, appId, storeId, existKvStore); in GetKvStoreFuzz()
102 manager.CloseKvStore(appId, storeId); in GetKvStoreFuzz()
103 manager.DeleteKvStore(appId, storeId); in GetKvStoreFuzz()
115 StoreId storeId; in GetAllKvStoreFuzz() local
116 storeId.storeId in GetAllKvStoreFuzz()
127 StoreId storeId; CloseKvStoreFuzz() local
138 StoreId storeId; DeleteKvStoreFuzz() local
160 StoreId storeId; DeleteAllKvStoreFuzz1() local
180 StoreId storeId; DeleteAllKvStoreFuzz2() local
196 StoreId storeId; DeleteAllKvStoreFuzz3() local
[all...]
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/
H A Dstore_manager.cpp28 std::shared_ptr<SingleKvStore> StoreManager::GetKVStore(const AppId &appId, const StoreId &storeId, in GetKVStore() argument
31 ZLOGD("appId:%{public}s, storeId:%{public}s type:%{public}d area:%{public}d dir:%{public}s", appId.appId.c_str(), in GetKVStore()
32 StoreUtil::Anonymous(storeId.storeId).c_str(), options.kvStoreType, options.area, options.baseDir.c_str()); in GetKVStore()
34 if (!appId.IsValid() || !storeId.IsValid() || !options.IsValidType()) { in GetKVStore()
40 auto kvStore = StoreFactory::GetInstance().GetOrOpenStore(appId, storeId, options, status, isCreate); in GetKVStore()
42 auto password = SecurityManager::GetInstance().GetDBPassword(storeId.storeId, options.baseDir, options.encrypt); in GetKVStore()
49 Status StoreManager::CloseKVStore(const AppId &appId, const StoreId &storeId) in CloseKVStore() argument
51 ZLOGD("appId:%{public}s, storeId in CloseKVStore()
80 Delete(const AppId &appId, const StoreId &storeId, const std::string &path) Delete() argument
[all...]
H A Dstore_factory.cpp38 std::shared_ptr<SingleKvStore> StoreFactory::GetOrOpenStore(const AppId &appId, const StoreId &storeId, in GetOrOpenStore() argument
44 if (stores.find(storeId) != stores.end()) { in GetOrOpenStore()
45 kvStore = stores[storeId]; in GetOrOpenStore()
52 auto password = SecurityManager::GetInstance().GetDBPassword(storeId.storeId, options.baseDir, options.encrypt); in GetOrOpenStore()
54 dbManager->GetKvStore(storeId, GetDBOption(options, password), in GetOrOpenStore()
67 ZLOGE("failed! status:%{public}d appId:%{public}s storeId:%{public}s path:%{public}s", dbStatus, in GetOrOpenStore()
68 appId.appId.c_str(), StoreUtil::Anonymous(storeId.storeId).c_str(), options.baseDir.c_str()); in GetOrOpenStore()
72 stores[storeId] in GetOrOpenStore()
78 Delete(const AppId &appId, const StoreId &storeId, const std::string &path) Delete() argument
87 Close(const AppId &appId, const StoreId &storeId, bool isForce) Close() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_auto_launch_test.cpp125 std::string storeId; member
131 const std::string &storeId, AutoLaunchStatus status) in AutoLaunchNotifierCallback()
136 info.storeId = storeId; in AutoLaunchNotifierCallback()
203 std::string storeId = "test1"; in HWTEST_F() local
204 g_mgr.GetKvStore(storeId, option, g_kvNbDelegateCallback); in HWTEST_F()
217 DBStatus status = KvStoreDelegateManager::EnableKvStoreAutoLaunch(USER_ID1, APP_ID1, storeId, in HWTEST_F()
227 status = KvStoreDelegateManager::EnableKvStoreAutoLaunch(USER_ID1, APP_ID1, storeId, in HWTEST_F()
237 status = KvStoreDelegateManager::EnableKvStoreAutoLaunch(USER_ID1, APP_ID1, storeId, in HWTEST_F()
240 KvStoreDelegateManager::DisableKvStoreAutoLaunch(USER_ID1, APP_ID1, storeId); in HWTEST_F()
130 AutoLaunchNotifierCallback(AutoLaunchNotifyInfo &info, const std::string &userId, const std::string &appId, const std::string &storeId, AutoLaunchStatus status) AutoLaunchNotifierCallback() argument
258 std::string storeId = "test2"; HWTEST_F() local
278 GetKvDB(const std::string &storeId) GetKvDB() argument
296 PutSyncData(const std::string &storeId, const Key &key, const Value &value, bool isCover) PutSyncData() argument
318 GetSyncData(const std::string &storeId) GetSyncData() argument
340 PrePutDataIntoDatabase(const std::string &storeId) PrePutDataIntoDatabase() argument
354 TriggerAutoLaunch(const std::string &storeId, bool isWriteCovered) TriggerAutoLaunch() argument
452 std::string storeId = "test5"; HWTEST_F() local
486 std::string storeId = "store_" + std::to_string(i + 1); HWTEST_F() local
518 std::string storeId = "store_" + std::to_string(i + 1); HWTEST_F() local
529 SetAutoLaunchLifeCycleTime(const std::string &storeId, uint32_t time) SetAutoLaunchLifeCycleTime() argument
558 std::string storeId = "test7"; HWTEST_F() local
599 std::string storeId = "test8"; HWTEST_F() local
639 DelayAutoLaunchCycle(const std::string &storeId, bool isWrite) DelayAutoLaunchCycle() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/
H A Dbackup_manager_test.cpp36 Status DeleteBackUpFiles(std::shared_ptr<SingleKvStore> kvStore, std::string baseDir, StoreId storeId);
37 void MkdirPath(std::string baseDir, AppId appId, StoreId storeId);
74 StoreId storeId = { "SingleKVStore" }; in TearDown() local
76 auto status = DeleteBackUpFiles(kvStore_, baseDir, storeId); in TearDown()
79 status = StoreManager::GetInstance().CloseKVStore(appId, storeId); in TearDown()
81 status = StoreManager::GetInstance().Delete(appId, storeId, baseDir); in TearDown()
96 StoreId storeId = { storeIdTest }; in CreateKVStore() local
97 Status status = StoreManager::GetInstance().Delete(appId, storeId, options.baseDir); in CreateKVStore()
98 return StoreManager::GetInstance().GetKVStore(appId, storeId, options, status); in CreateKVStore()
100 Status BackupManagerTest::DeleteBackUpFiles(std::shared_ptr<SingleKvStore> kvStore, string baseDir, StoreId storeId) in DeleteBackUpFiles() argument
114 MkdirPath(std::string baseDir, AppId appId, StoreId storeId) MkdirPath() argument
245 StoreId storeId = { "SingleKVStoreEncrypt" }; HWTEST_F() local
291 StoreId storeId = { "SingleKVStoreEncrypt" }; HWTEST_F() local
331 StoreId storeId = { "SingleKVStoreEncrypt" }; HWTEST_F() local
386 StoreId storeId = { "SingleKVStoreEncrypt" }; HWTEST_F() local
441 StoreId storeId = { "SingleKVStoreEncrypt" }; HWTEST_F() local
[all...]
H A Dstore_factory_test.cpp33 static StoreId storeId = { "single_test" }; member
61 bool MoveToRekeyPath(Options options, StoreId storeId);
64 DBStatus ChangeKVStoreDate(const std::string &storeId, std::shared_ptr<DBManager> dbManager,
92 StoreManager::GetInstance().Delete(appId, storeId, options.baseDir); in DeleteKVStore()
137 bool StoreFactoryTest::MoveToRekeyPath(Options options, StoreId storeId) in MoveToRekeyPath() argument
139 std::string keyFileName = options.baseDir + "/key/" + storeId.storeId + ".key"; in MoveToRekeyPath()
140 std::string rekeyFileName = options.baseDir + "/rekey/key/" + storeId.storeId + ".new.key"; in MoveToRekeyPath()
182 StoreFactoryTest::DBStatus StoreFactoryTest::ChangeKVStoreDate(const std::string &storeId, in ChangeKVStoreDate() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service_client.h34 Status BeforeCreate(const AppId &appId, const StoreId &storeId, const Options &options) override;
35 Status AfterCreate(const AppId &appId, const StoreId &storeId, const Options &options,
37 Status Delete(const AppId &appId, const StoreId &storeId) override;
38 Status Close(const AppId &appId, const StoreId &storeId) override;
39 Status Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) override;
42 Status SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) override;
43 Status GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) override;
44 Status EnableCapability(const AppId &appId, const StoreId &storeId) override;
45 Status DisableCapability(const AppId &appId, const StoreId &storeId) override;
46 Status SetCapability(const AppId &appId, const StoreId &storeId, cons
[all...]
H A Dkvdb_service.h50 virtual Status BeforeCreate(const AppId &appId, const StoreId &storeId, const Options &options) = 0;
52 const AppId &appId, const StoreId &storeId, const Options &options, const std::vector<uint8_t> &password) = 0;
53 virtual Status Delete(const AppId &appId, const StoreId &storeId) = 0;
54 virtual Status Close(const AppId &appId, const StoreId &storeId) = 0;
55 virtual Status Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) = 0;
58 virtual Status SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) = 0;
59 virtual Status GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) = 0;
60 virtual Status EnableCapability(const AppId &appId, const StoreId &storeId) = 0;
61 virtual Status DisableCapability(const AppId &appId, const StoreId &storeId) = 0;
62 virtual Status SetCapability(const AppId &appId, const StoreId &storeId, cons
[all...]
H A Dbackup_manager.h48 void Prepare(const std::string &path, const std::string &storeId);
50 const std::string &storeId, std::shared_ptr<DBStore> dbStore);
52 const std::string &appId, const std::string &storeId, std::shared_ptr<DBStore> dbStore);
54 const std::string &baseDir, const std::string &storeId);
63 const std::string &baseDir, const std::string &storeId);
65 const std::string &appId, const std::string &storeId);
67 bool HaveResidueKey(const std::vector<StoreUtil::FileInfo> &files, std::string storeId);
72 const std::vector<StoreUtil::FileInfo> &keys, const std::string &storeId);
75 const std::string &baseDir, const std::string &storeId);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/
H A Dcorrupted_meta_data.cpp25 SetValue(node[GET_NAME(storeId)], storeId); in Marshal()
34 GetValue(node, GET_NAME(storeId), storeId); in Unmarshal()
48 const std::string &appId, const std::string &bundleName, const std::string &storeId) in CorruptedMetaData()
49 : appId(appId), bundleName(bundleName), storeId(storeId) in CorruptedMetaData()
56 { appId, bundleName, storeId }); in GetKey()
47 CorruptedMetaData( const std::string &appId, const std::string &bundleName, const std::string &storeId) CorruptedMetaData() argument
H A Dstrategy_meta_data.cpp26 ret = SetValue(node[GET_NAME(storeId)], storeId) && ret; in Marshal()
39 ret = GetValue(node, GET_NAME(storeId), storeId) && ret; in Unmarshal()
46 const std::string &devId, const std::string &userId, const std::string &bundleName, const std::string &storeId) in StrategyMeta()
47 : devId(devId), userId(userId), bundleName(bundleName), storeId(storeId) in StrategyMeta()
59 return Constant::Join(PREFIX, Constant::KEY_SEPARATOR, { devId, userId, "default", bundleName, storeId }); in GetKey()
62 { devId, userId, "default", bundleName, storeId, std::to_string(instanceId) }); in GetKey()
45 StrategyMeta( const std::string &devId, const std::string &userId, const std::string &bundleName, const std::string &storeId) StrategyMeta() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/kvdelegatemanager_fuzzer/
H A Dkvdelegatemanager_fuzzer.cpp71 void CallbackFuzz(const uint8_t *data, std::string storeId) in CallbackFuzz() argument
74 g_mgr.GetKvStoreDiskSize(storeId, diskSize); in CallbackFuzz()
77 const std::string &storeId, uint8_t flag) -> bool { return isPermissionCheck; }; in CallbackFuzz()
80 const std::string &storeId, const std::string &deviceId, uint8_t flag) -> bool { in CallbackFuzz()
86 const std::string &storeId) -> bool { return isSyncActivationCheck; }; in CallbackFuzz()
101 std::string storeId = GetRandomString(data, size, len, start); in CombineTest() local
103 (void) KvStoreDelegateManager::GetDatabaseDir(storeId, appId, userId, dir); in CombineTest()
104 (void) KvStoreDelegateManager::GetDatabaseDir(storeId, dir); in CombineTest()
107 (void) KvStoreDelegateManager::GetKvStoreIdentifier(userId, appId, storeId, syncDualTupleMode); in CombineTest()
111 (void) KvStoreDelegateManager::EnableKvStoreAutoLaunch(userId, appId, storeId, optio in CombineTest()
[all...]
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service.h39 virtual Status BeforeCreate(const AppId &appId, const StoreId &storeId, const Options &options) = 0;
41 const AppId &appId, const StoreId &storeId, const Options &options, const std::vector<uint8_t> &password) = 0;
42 virtual Status Delete(const AppId &appId, const StoreId &storeId) = 0;
43 virtual Status Sync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
45 virtual Status SetSyncParam(const AppId &appId, const StoreId &storeId, const KvSyncParam &syncParam) = 0;
46 virtual Status GetSyncParam(const AppId &appId, const StoreId &storeId, KvSyncParam &syncParam) = 0;
47 virtual Status EnableCapability(const AppId &appId, const StoreId &storeId) = 0;
48 virtual Status DisableCapability(const AppId &appId, const StoreId &storeId) = 0;
49 virtual Status SetCapability(const AppId &appId, const StoreId &storeId, const std::vector<std::string> &local,
51 virtual Status AddSubscribeInfo(const AppId &appId, const StoreId &storeId, cons
[all...]
/foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/
H A Dkv_store_death_recipient.cpp33 KvDeathRecipient::KvDeathRecipient(const std::string& storeId) in KvDeathRecipient() argument
36 storeId_ = storeId; in KvDeathRecipient()
60 auto reInitTask = [storeId = storeId_]() { in OnRemoteDied()
61 HILOGI("ReInit, storeId:%{public}s", storeId.c_str()); in OnRemoteDied()
62 if (storeId == DYNAMIC_STORE_ID) { in OnRemoteDied()
65 if (storeId == STATIC_STORE_ID) { in OnRemoteDied()
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Ddistributed_kv_data_manager.cpp30 Status DistributedKvDataManager::GetSingleKvStore(const Options &options, const AppId &appId, const StoreId &storeId, in GetSingleKvStore() argument
37 singleKvStore = StoreManager::GetInstance().GetKVStore(appId, storeId, options, status); in GetSingleKvStore()
53 Status DistributedKvDataManager::CloseKvStore(const AppId &appId, const StoreId &storeId) in CloseKvStore() argument
55 auto status = StoreManager::GetInstance().CloseKVStore(appId, storeId); in CloseKvStore()
69 StoreId storeId = kvStorePtr->GetStoreId(); in CloseKvStore() local
72 auto status = StoreManager::GetInstance().CloseKVStore(appId, storeId); in CloseKvStore()
87 Status DistributedKvDataManager::DeleteKvStore(const AppId &appId, const StoreId &storeId, const std::string &path) in DeleteKvStore() argument
90 return StoreManager::GetInstance().Delete(appId, storeId, path); in DeleteKvStore()
104 for (auto &storeId : storeIds) { in DeleteAllKvStore()
105 status = StoreManager::GetInstance().Delete(appId, storeId, pat in DeleteAllKvStore()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_delegate_manager.cpp190 void KvStoreDelegateManager::GetKvStore(const std::string &storeId, const KvStoreDelegate::Option &option, in GetKvStore() argument
199 if (!ParamCheckUtils::CheckStoreParameter(storeId, appId_, userId_, false, subUser_) || GetKvStorePath().empty()) { in GetKvStore()
213 DbIdParam dbIdParam = { appId_, userId_, storeId }; in GetKvStore()
224 auto kvStore = new (std::nothrow) KvStoreDelegateImpl(conn, storeId); in GetKvStore()
260 bool KvStoreDelegateManager::GetKvStoreParamCheck(const std::string &storeId, const KvStoreNbDelegate::Option &option, in GetKvStoreParamCheck() argument
271 if (!ParamCheckUtils::CheckStoreParameter(storeId, appId_, userId_, false, subUser_) || in GetKvStoreParamCheck()
312 void KvStoreDelegateManager::GetKvStore(const std::string &storeId, const KvStoreNbDelegate::Option &option, in GetKvStore() argument
315 if (!GetKvStoreParamCheck(storeId, option, callback)) { in GetKvStore()
334 DbIdParam dbIdParam = { appId_, userId_, storeId, subUser_, instanceId_ }; in GetKvStore()
345 auto kvStore = new (std::nothrow) KvStoreNbDelegateImpl(conn, storeId); in GetKvStore()
410 DeleteKvStore(const std::string &storeId) DeleteKvStore() argument
480 GetKvStoreDiskSize(const std::string &storeId, uint64_t &size) GetKvStoreDiskSize() argument
508 GetDatabaseDir(const std::string &storeId, const std::string &appId, const std::string &userId, std::string &directory) GetDatabaseDir() argument
524 GetDatabaseDir(const std::string &storeId, std::string &directory) GetDatabaseDir() argument
566 EnableKvStoreAutoLaunch(const std::string &userId, const std::string &appId, const std::string &storeId, const AutoLaunchOption &option, const AutoLaunchNotifier &notifier) EnableKvStoreAutoLaunch() argument
590 DisableKvStoreAutoLaunch(const std::string &userId, const std::string &appId, const std::string &storeId) DisableKvStoreAutoLaunch() argument
614 GetKvStoreIdentifier(const std::string &userId, const std::string &appId, const std::string &storeId, bool syncDualTupleMode) GetKvStoreIdentifier() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Dkv_store_delegate_manager.h49 DB_API void GetKvStore(const std::string &storeId, const KvStoreDelegate::Option &option,
56 DB_API void GetKvStore(const std::string &storeId, const KvStoreNbDelegate::Option &option,
65 DB_API DBStatus DeleteKvStore(const std::string &storeId);
68 DB_API DBStatus GetKvStoreDiskSize(const std::string &storeId, uint64_t &size);
78 // Get database directory by storeId + appId + userId
79 DB_API static DBStatus GetDatabaseDir(const std::string &storeId, const std::string &appId,
82 // Get database directory by storeId
83 DB_API static DBStatus GetDatabaseDir(const std::string &storeId, std::string &directory);
90 const std::string &storeId, const AutoLaunchOption &option, const AutoLaunchNotifier &notifier);
93 const std::string &storeId);
[all...]

Completed in 12 milliseconds

12345678910>>...13