| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
| H A D | checker_manager_test.cpp | 165 CheckerManager::StoreInfo storeInfo; in HWTEST_F() local
166 storeInfo.uid = 2000000; in HWTEST_F()
167 storeInfo.tokenId = AccessTokenKit::GetHapTokenID(100, "ohos.test.demo", 0); in HWTEST_F()
168 storeInfo.bundleName = "ohos.test.demo"; in HWTEST_F()
169 ASSERT_FALSE(CheckerManager::GetInstance().IsDynamic(storeInfo)); in HWTEST_F()
181 CheckerManager::StoreInfo storeInfo; in HWTEST_F() local
182 storeInfo.uid = 2000000; in HWTEST_F()
183 storeInfo.tokenId = AccessTokenKit::GetHapTokenID(100, "ohos.test.demo", 0); in HWTEST_F()
184 storeInfo.bundleName = "ohos.test.demo"; in HWTEST_F()
185 ASSERT_FALSE(CheckerManager::GetInstance().IsStatic(storeInfo)); in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 159 auto storeInfo = evt.GetStoreInfo(); in GetLockChangeHandler()
163 storeInfo.bundleName.c_str(), Anonymous::Change(storeInfo.storeName).c_str(), storeInfo.user); in GetLockChangeHandler()
167 cloud.user = storeInfo.user; in GetLockChangeHandler()
168 SyncInfo info(storeInfo.user, storeInfo.bundleName); in GetLockChangeHandler()
174 StoreMetaData meta(storeInfo); in GetLockChangeHandler()
178 storeInfo.bundleName.c_str(), Anonymous::Change(storeInfo in GetLockChangeHandler()
307 StoreInfo storeInfo = { 0, schema.bundleName, database.name, cloud.apps[schema.bundleName].instanceId, GetPostEventTask() local
[all...] |
| H A D | cloud_service_impl.cpp | 229 DistributedData::StoreInfo storeInfo; in DoClean() local
230 storeInfo.bundleName = meta.bundleName; in DoClean()
231 storeInfo.user = atoi(meta.user.c_str()); in DoClean()
232 storeInfo.storeName = meta.storeId; in DoClean()
233 EventCenter::GetInstance().PostEvent(std::make_unique<CloudEvent>(CloudEvent::CLEAN_DATA, storeInfo)); in DoClean()
360 bool found = std::any_of(stores.begin(), stores.end(), [&bundleName](const CheckerManager::StoreInfo &storeInfo) { in DoKvCloudSync()
361 return bundleName.empty() || storeInfo.bundleName == bundleName; in DoKvCloudSync()
971 auto &storeInfo = rdbEvent.GetStoreInfo(); in GetSchema() local
973 storeInfo.bundleName.c_str(), Anonymous::Change(storeInfo in GetSchema()
986 auto &storeInfo = cloudShareEvent.GetStoreInfo(); CloudShare() local
1006 PreShare( const StoreInfo &storeInfo, GenQuery &query) PreShare() argument
1157 StoreInfo storeInfo; AllocResourceAndShare() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/sync_strategies/ |
| H A D | network_sync_strategy.cpp | 53 int32_t NetworkSyncStrategy::CheckSyncAction(const StoreInfo &storeInfo) in CheckSyncAction() argument
58 if (storeInfo.user != user_) { in CheckSyncAction()
60 user_ = storeInfo.user; in CheckSyncAction()
62 StrategyInfo info = GetStrategy(storeInfo.user, storeInfo.bundleName); in CheckSyncAction()
64 info = GetStrategy(storeInfo.user, GLOBAL_BUNDLE); in CheckSyncAction()
69 return next_ ? next_->CheckSyncAction(storeInfo) : E_OK; in CheckSyncAction()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_service_impl.cpp | 102 auto &storeInfo = evt.GetStoreInfo(); in RdbServiceImpl()
103 StoreMetaData meta(storeInfo); in RdbServiceImpl()
120 store->RegisterDetailProgressObserver(GetCallbacks(meta.tokenId, storeInfo.storeName)); in RdbServiceImpl()
218 CheckerManager::StoreInfo storeInfo; in CheckAccess() local
219 storeInfo.uid = IPCSkeleton::GetCallingUid(); in CheckAccess()
220 storeInfo.tokenId = IPCSkeleton::GetCallingTokenID(); in CheckAccess()
221 storeInfo.bundleName = bundleName; in CheckAccess()
222 storeInfo.storeId = RemoveSuffix(storeName); in CheckAccess()
223 return !CheckerManager::GetInstance().GetAppId(storeInfo).empty(); in CheckAccess()
508 StoreInfo storeInfo;
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | cloud_event.cpp | 19 CloudEvent::CloudEvent(int32_t evtId, StoreInfo storeInfo) in CloudEvent() argument
20 : Event(evtId), eventId_(evtId), storeInfo_(std::move(storeInfo)) in CloudEvent()
|
| H A D | cloud_lock_event.cpp | 19 CloudLockEvent::CloudLockEvent(int32_t evtId, StoreInfo storeInfo, Callback callback) in CloudLockEvent() argument
20 : CloudEvent(evtId, storeInfo), callback_(std::move(callback)) in CloudLockEvent()
|
| H A D | cloud_share_event.cpp | 19 CloudShareEvent::CloudShareEvent(StoreInfo storeInfo, std::shared_ptr<GenQuery> query, Callback callback) in CloudShareEvent() argument
20 : CloudEvent(CLOUD_SHARE, std::move(storeInfo)), query_(std::move(query)), callback_(std::move(callback)) in CloudShareEvent()
|
| H A D | sync_event.cpp | 53 SyncEvent::SyncEvent(StoreInfo storeInfo, EventInfo info) in SyncEvent() argument
54 : CloudEvent(CLOUD_SYNC, std::move(storeInfo)), info_(std::move(info)) in SyncEvent()
58 SyncEvent::SyncEvent(int32_t evtId, StoreInfo storeInfo, EventInfo info) in SyncEvent() argument
59 : CloudEvent(evtId, std::move(storeInfo)), info_(std::move(info)) in SyncEvent()
|
| H A D | make_query_event.cpp | 19 MakeQueryEvent::MakeQueryEvent(StoreInfo storeInfo, std::shared_ptr<DistributedRdb::PredicatesMemo> predicates, in MakeQueryEvent() argument
21 : CloudEvent(MAKE_QUERY, std::move(storeInfo)), predicates_(std::move(predicates)), columns_(columns), in MakeQueryEvent()
|
| H A D | sync_strategy.cpp | 18 int32_t SyncStrategy::CheckSyncAction(const StoreInfo &storeInfo) in CheckSyncAction() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | change_event.h | 23 ChangeEvent(StoreInfo storeInfo, EventInfo info) : SyncEvent(LOCAL_CHANGE, std::move(storeInfo), std::move(info)) in ChangeEvent() argument
|
| H A D | sync_event.h | 45 SyncEvent(StoreInfo storeInfo, EventInfo info);
58 SyncEvent(int32_t evtId, StoreInfo storeInfo, EventInfo info);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | object_asset_machine_test.cpp | 68 StoreInfo storeInfo { in SetUp()
75 storeInfo_ = storeInfo; in SetUp()
76 ChangedAssetInfo changedAssetInfo(asset, AssetBindInfo, storeInfo); in SetUp()
206 StoreInfo storeInfo { in HWTEST_F()
213 ChangedAssetInfo changedAssetInfo(asset, bindInfo, storeInfo); in HWTEST_F()
250 StoreInfo storeInfo { in HWTEST_F()
257 ChangedAssetInfo changedAssetInfo(asset, AssetBindInfo, storeInfo); in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/checker/ |
| H A D | system_checker.cpp | 120 bool SystemChecker::AddDynamicStore(const CheckerManager::StoreInfo &storeInfo) in AddDynamicStore() argument
122 dynamicStores_.push_back(storeInfo); in AddDynamicStore()
126 bool SystemChecker::AddStaticStore(const CheckerManager::StoreInfo &storeInfo) in AddStaticStore() argument
128 staticStores_.push_back(storeInfo); in AddStaticStore()
|
| H A D | bundle_checker.cpp | 178 bool BundleChecker::AddDynamicStore(const CheckerManager::StoreInfo &storeInfo) in AddDynamicStore() argument
180 dynamicStores_.push_back(storeInfo); in AddDynamicStore()
184 bool BundleChecker::AddStaticStore(const CheckerManager::StoreInfo &storeInfo) in AddStaticStore() argument
186 staticStores_.push_back(storeInfo); in AddStaticStore()
|
| H A D | bundle_checker.h | 33 bool AddDynamicStore(const CheckerManager::StoreInfo& storeInfo) override;
34 bool AddStaticStore(const CheckerManager::StoreInfo& storeInfo) override;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/commonevent/ |
| H A D | data_sync_event.h | 29 DataSyncEvent(StoreInfo storeInfo, uint32_t syncMode, int32_t status, uint32_t traceId, uint32_t count = 0)
in DataSyncEvent() argument
30 : CloudEvent(DATA_SYNC, std::move(storeInfo)), syncMode_(syncMode), status_(std::move(status)),
in DataSyncEvent()
|
| H A D | data_change_event.h | 33 DataChangeEvent(StoreInfo storeInfo, EventInfo evtInfo) in DataChangeEvent() argument
34 : CloudEvent(DATA_CHANGE, std::move(storeInfo)), info_(std::move(evtInfo)) in DataChangeEvent()
|
| H A D | set_searchable_event.h | 29 SetSearchableEvent(StoreInfo storeInfo, EventInfo evtInfo, int32_t evtId = SET_SEARCHABLE) in SetSearchableEvent() argument
30 : CloudEvent(evtId, std::move(storeInfo)), info_(std::move(evtInfo)) in SetSearchableEvent()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
| H A D | checker_mock.h | 37 bool AddDynamicStore(const CheckerManager::StoreInfo &storeInfo) override;
38 bool AddStaticStore(const CheckerManager::StoreInfo &storeInfo) override;
|
| H A D | checker_mock.cpp | 93 bool CheckerMock::AddDynamicStore(const CheckerManager::StoreInfo &storeInfo) in AddDynamicStore() argument
98 bool CheckerMock::AddStaticStore(const CheckerManager::StoreInfo &storeInfo) in AddStaticStore() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_asset_machine.h | 32 StoreInfo storeInfo; member
38 storeInfo = store; in ChangedAssetInfo()
|
| H A D | object_asset_machine.cpp | 167 ObjectAssetLoader::GetInstance()->TransferAssetsAsync(changedAsset.storeInfo.user, in DoTransfer()
168 changedAsset.storeInfo.bundleName, changedAsset.deviceId, assets, [&changedAsset](bool success) { in DoTransfer()
294 meta.bundleName = changedAsset.storeInfo.bundleName; in GetStore()
295 meta.user = std::to_string(changedAsset.storeInfo.user); in GetStore()
296 meta.instanceId = changedAsset.storeInfo.instanceId; in GetStore()
353 bindEventInfo.bundleName = changedAsset.storeInfo.bundleName; in MakeBindInfo()
354 bindEventInfo.user = changedAsset.storeInfo.user; in MakeBindInfo()
355 bindEventInfo.tokenId = changedAsset.storeInfo.tokenId; in MakeBindInfo()
356 bindEventInfo.instanceId = changedAsset.storeInfo.instanceId; in MakeBindInfo()
|
| H A D | object_service_impl.cpp | 262 DistributedData::CheckerManager::StoreInfo storeInfo; in IsBundleNameEqualTokenId() local
263 storeInfo.uid = IPCSkeleton::GetCallingUid(); in IsBundleNameEqualTokenId()
264 storeInfo.tokenId = tokenId; in IsBundleNameEqualTokenId()
265 storeInfo.bundleName = bundleName; in IsBundleNameEqualTokenId()
266 storeInfo.storeId = sessionId; in IsBundleNameEqualTokenId()
267 std::string appId = DistributedData::CheckerManager::GetInstance().GetAppId(storeInfo); in IsBundleNameEqualTokenId()
270 bundleName.c_str(), storeInfo.uid, Anonymous::Change(std::to_string(storeInfo.tokenId)).c_str()); in IsBundleNameEqualTokenId()
|