Home
last modified time | relevance | path

Searched refs:cloudInfo (Results 1 - 25 of 27) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_strategy_test.cpp102 LogInfo cloudInfo; in HWTEST_F() local
107 EXPECT_EQ(strategy->TagSyncDataStatus(false, false, localInfo, cloudInfo), OpType::INSERT); in HWTEST_F()
114 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::ONLY_UPDATE_GID); in HWTEST_F()
120 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::NOT_HANDLE); in HWTEST_F()
125 cloudInfo.timestamp = 2u; // mark 2 means cloud is new in HWTEST_F()
126 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::UPDATE); in HWTEST_F()
131 cloudInfo.flag = 0x01; // it means delete in HWTEST_F()
132 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::DELETE); in HWTEST_F()
137 cloudInfo.flag = 0; // it means no delete in HWTEST_F()
139 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpTyp in HWTEST_F()
197 LogInfo cloudInfo; HWTEST_F() local
247 LogInfo cloudInfo; HWTEST_F() local
303 LogInfo cloudInfo; HWTEST_F() local
327 LogInfo cloudInfo; HWTEST_F() local
356 LogInfo cloudInfo; HWTEST_F() local
[all...]
H A Dvirtual_cloud_syncer.cpp111 const LogInfo &cloudInfo, OpType &strategyOpResult) in CallTagStatusByStrategy()
116 dataInfo.cloudLogInfo = cloudInfo; in CallTagStatusByStrategy()
110 CallTagStatusByStrategy(bool isExist, const DataInfoWithLog &localInfo, const LogInfo &cloudInfo, OpType &strategyOpResult) CallTagStatusByStrategy() argument
H A Dvirtual_cloud_syncer.h47 int CallTagStatusByStrategy(bool isExist, const DataInfoWithLog &localInfo, const LogInfo &cloudInfo,
H A Ddistributeddb_cloud_db_proxy_test.cpp756 LogInfo cloudInfo; in HWTEST_F() local
759 cloudInfo.cloudGid = "gid"; in HWTEST_F()
764 CloudSyncUtils::UpdateLocalCache(OpType::INSERT, cloudInfo, localInfo, localLogInfoCache); in HWTEST_F()
766 EXPECT_EQ(localLogInfoCache[hashKey].cloudGid, cloudInfo.cloudGid); in HWTEST_F()
771 CloudSyncUtils::UpdateLocalCache(OpType::DELETE, cloudInfo, localInfo, localLogInfoCache); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_merge_strategy.cpp21 const LogInfo &cloudInfo) in TagSyncDataStatus()
23 bool isCloudDelete = IsDelete(cloudInfo); in TagSyncDataStatus()
26 return TagCloudUpdateLocal(localInfo, cloudInfo, isCloudDelete, isLocalDelete); in TagSyncDataStatus()
38 localInfo.timestamp > cloudInfo.timestamp) { in TagSyncDataStatus()
39 return TagLocallyNewer(localInfo, cloudInfo, isCloudDelete, isLocalDelete); in TagSyncDataStatus()
49 bool isTimeSame = (localInfo.timestamp == cloudInfo.timestamp) && (localInfo.wTimestamp == cloudInfo.wTimestamp); in TagSyncDataStatus()
50 if (isTimeSame && (localInfo.cloudGid.empty() || cloudInfo.sharingResource != localInfo.sharingResource)) { in TagSyncDataStatus()
53 if (!localInfo.isNeedUpdateAsset && IsSameRecord(cloudInfo, localInfo)) { in TagSyncDataStatus()
56 return TagUpdateLocal(cloudInfo, localInf in TagSyncDataStatus()
20 TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo, const LogInfo &cloudInfo) TagSyncDataStatus() argument
69 TagLocallyNewer(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete, bool isLocalDelete) TagLocallyNewer() argument
85 TagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete, bool isLocalDelete) TagCloudUpdateLocal() argument
[all...]
H A Dcloud_sync_strategy.cpp34 [[gnu::unused]] const LogInfo &localInfo, [[gnu::unused]] const LogInfo &cloudInfo) in TagSyncDataStatus()
60 bool CloudSyncStrategy::IsLogNeedUpdate(const LogInfo &cloudInfo, const LogInfo &localInfo) in IsLogNeedUpdate() argument
62 return (cloudInfo.sharingResource != localInfo.sharingResource) || (cloudInfo.version != localInfo.version); in IsLogNeedUpdate()
65 bool CloudSyncStrategy::IsSameVersion(const LogInfo &cloudInfo, const LogInfo &localInfo) in IsSameVersion() argument
67 if (cloudInfo.version.empty() || localInfo.version.empty()) { in IsSameVersion()
70 return (cloudInfo.version == localInfo.version); in IsSameVersion()
89 OpType CloudSyncStrategy::TagUpdateLocal(const LogInfo &cloudInfo, const LogInfo &localInfo) const in TagUpdateLocal() argument
94 bool CloudSyncStrategy::IsSameRecord(const LogInfo &cloudInfo, const LogInfo &localInfo) in IsSameRecord() argument
99 !localInfo.version.empty() && localInfo.version == cloudInfo in IsSameRecord()
33 TagSyncDataStatus([[gnu::unused]] bool existInLocal, [[gnu::unused]] bool isCloudWin, [[gnu::unused]] const LogInfo &localInfo, [[gnu::unused]] const LogInfo &cloudInfo) TagSyncDataStatus() argument
[all...]
H A Dcloud_force_pull_strategy.cpp21 const LogInfo &localInfo, const LogInfo &cloudInfo) in TagSyncDataStatus()
30 if (!IsDelete(localInfo) && IsDelete(cloudInfo)) { in TagSyncDataStatus()
32 } else if (IsDelete(cloudInfo)) { in TagSyncDataStatus()
38 return TagUpdateLocal(cloudInfo, localInfo); in TagSyncDataStatus()
41 if (IsDelete(cloudInfo)) { in TagSyncDataStatus()
47 return TagUpdateLocal(cloudInfo, localInfo); in TagSyncDataStatus()
20 TagSyncDataStatus(bool existInLocal, [[gnu::unused]] bool isCloudWin, const LogInfo &localInfo, const LogInfo &cloudInfo) TagSyncDataStatus() argument
H A Dcloud_sync_strategy.h35 const LogInfo &cloudInfo);
45 static bool IsLogNeedUpdate(const LogInfo &cloudInfo, const LogInfo &localInfo);
47 OpType TagUpdateLocal(const LogInfo &cloudInfo, const LogInfo &localInfo) const;
49 static bool IsSameVersion(const LogInfo &cloudInfo, const LogInfo &localInfo);
53 static bool IsSameRecord(const LogInfo &cloudInfo, const LogInfo &localInfo);
H A Dcloud_force_push_strategy.cpp21 const LogInfo &localInfo, const LogInfo &cloudInfo) in TagSyncDataStatus()
26 bool isCloudDelete = IsDelete(cloudInfo); in TagSyncDataStatus()
41 if (localInfo.timestamp == cloudInfo.timestamp) { in TagSyncDataStatus()
47 if (IsLogNeedUpdate(cloudInfo, localInfo)) { in TagSyncDataStatus()
20 TagSyncDataStatus(bool existInLocal, [[gnu::unused]] bool isCloudWin, const LogInfo &localInfo, const LogInfo &cloudInfo) TagSyncDataStatus() argument
H A Dcloud_merge_strategy.h27 const LogInfo &cloudInfo) override;
33 OpType TagLocallyNewer(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete, bool isLocalDelete);
35 OpType TagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete,
H A Dcloud_force_pull_strategy.h23 const LogInfo &cloudInfo) override;
H A Dcloud_force_push_strategy.h23 const LogInfo &cloudInfo) override;
H A Dcloud_sync_utils.h78 static void UpdateLocalCache(OpType opType, const LogInfo &cloudInfo,
H A Dcloud_sync_utils.cpp346 void CloudSyncUtils::UpdateLocalCache(OpType opType, const LogInfo &cloudInfo, const LogInfo &localInfo, in UpdateLocalCache() argument
356 updateLogInfo = cloudInfo; in UpdateLocalCache()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dcloud_service_impl.cpp109 auto [status, cloudInfo] = GetCloudInfo(user); in EnableCloud()
113 cloudInfo.enableCloud = true; in EnableCloud()
115 if (!cloudInfo.Exist(bundle)) { in EnableCloud()
118 cloudInfo.apps[bundle].cloudSwitch = (value == SWITCH_ON); in EnableCloud()
121 if (!MetaDataManager::GetInstance().SaveMeta(cloudInfo.GetKey(), cloudInfo, true)) { in EnableCloud()
124 Execute(GenTask(0, cloudInfo.user, { WORK_CLOUD_INFO_UPDATE, WORK_SCHEMA_UPDATE, WORK_DO_CLOUD_SYNC, WORK_SUB })); in EnableCloud()
135 auto [status, cloudInfo] = GetCloudInfo(user); in DisableCloud()
139 if (cloudInfo.id != id) { in DisableCloud()
141 Anonymous::Change(cloudInfo in DisableCloud()
194 DoClean(const CloudInfo &cloudInfo, const std::map<std::string, int32_t> &actions) DoClean() argument
288 CheckNotifyConditions(const std::string &id, const std::string &bundleName, CloudInfo &cloudInfo) CheckNotifyConditions() argument
442 ExecuteStatistics(const std::string &storeId, const CloudInfo &cloudInfo, const SchemaMeta &schemaMeta) ExecuteStatistics() argument
721 CloudInfo cloudInfo; GetCloudInfoFromMeta() local
733 CloudInfo cloudInfo; GetCloudInfoFromServer() local
950 CloudInfo cloudInfo; OnAppUninstall() local
1057 CloudInfo cloudInfo; DoSubscribe() local
[all...]
H A Dcloud_service_impl.h138 const std::string &storeId, const CloudInfo &cloudInfo, const SchemaMeta &schemaMeta);
151 int32_t DoClean(const CloudInfo &cloudInfo, const std::map<std::string, int32_t> &actions);
156 int32_t CheckNotifyConditions(const std::string &id, const std::string &bundleName, CloudInfo &cloudInfo);
H A Dsync_manager.cpp265 ZLOGE("cloudInfo invalid:%{public}d, <syncId:%{public}s, metaId:%{public}s>", cloud.IsValid(), in IsValid()
783 CloudInfo cloudInfo;
784 cloudInfo.user = user;
785 if (!MetaDataManager::GetInstance().LoadMeta(cloudInfo.GetKey(), cloudInfo, true)) {
786 ZLOGE("not exist meta, user:%{public}d.", cloudInfo.user);
789 return cloudInfo.id;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/
H A Dcloud_test.cpp113 CloudInfo cloudInfo; in HWTEST_F() local
114 auto result = cloudInfo.GetSchemaPrefix("ohos.test.demo"); in HWTEST_F()
117 result = cloudInfo.GetSchemaPrefix(""); in HWTEST_F()
130 CloudInfo cloudInfo; in HWTEST_F() local
131 auto result = cloudInfo.IsValid(); in HWTEST_F()
156 CloudInfo cloudInfo; in HWTEST_F() local
157 auto result = cloudInfo.Exist("", 1); in HWTEST_F()
167 cloudInfo.user = 111; in HWTEST_F()
168 cloudInfo.id = "test_cloud_id"; in HWTEST_F()
169 cloudInfo in HWTEST_F()
189 CloudInfo cloudInfo; HWTEST_F() local
318 CloudInfo cloudInfo; HWTEST_F() local
347 CloudInfo cloudInfo; HWTEST_F() local
364 CloudInfo cloudInfo; HWTEST_F() local
381 CloudInfo cloudInfo; HWTEST_F() local
395 CloudInfo cloudInfo; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dcloud_service_impl_test.cpp149 * @tc.desc: Test the EnableCloud function in case it doesn't get cloudInfo.
169 CloudInfo cloudInfo; in HWTEST_F() local
172 cloudInfo.apps[TEST_CLOUD_BUNDLE] = std::move(appInfo); in HWTEST_F()
179 auto result = cloudServiceImpl_->ExecuteStatistics("", cloudInfo, schemaMeta); in HWTEST_F()
467 CloudInfo cloudInfo; in HWTEST_F() local
468 cloudInfo.enableCloud = false; in HWTEST_F()
469 cloudInfo.id = TEST_CLOUD_APPID; in HWTEST_F()
471 auto status = cloudServiceImpl_->CheckNotifyConditions(TEST_CLOUD_APPID, TEST_CLOUD_BUNDLE, cloudInfo); in HWTEST_F()
473 cloudInfo.enableCloud = true; in HWTEST_F()
477 cloudInfo in HWTEST_F()
[all...]
H A Dcloud_data_test.cpp146 CloudInfo cloudInfo; in GetServerInfo() local
147 cloudInfo.user = userId; in GetServerInfo()
148 cloudInfo.id = TEST_CLOUD_ID; in GetServerInfo()
149 cloudInfo.remainSpace = REMAINSPACE; in GetServerInfo()
150 cloudInfo.totalSpace = TATALSPACE; in GetServerInfo()
151 cloudInfo.enableCloud = true; in GetServerInfo()
159 cloudInfo.apps[TEST_CLOUD_BUNDLE] = std::move(appInfo); in GetServerInfo()
160 return cloudInfo; in GetServerInfo()
307 auto cloudInfo = cloudServerMock->GetServerInfo(user, true); in HWTEST_F() local
308 ASSERT_TRUE(MetaDataManager::GetInstance().DelMeta(cloudInfo in HWTEST_F()
1797 CloudInfo cloudInfo; HWTEST_F() local
1872 CloudInfo cloudInfo; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dcloud_server_impl.h51 void GetAppInfo(std::shared_ptr<OhCloudExtHashMap> briefInfo, DBCloudInfo &cloudInfo);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_store.h102 bool IsTagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dicloud_sync_storage_interface.h233 virtual bool IsTagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo, in IsTagCloudUpdateLocal() argument
H A Dstorage_proxy.h156 bool IsTagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp684 bool StorageProxy::IsTagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo, in IsTagCloudUpdateLocal() argument
690 return store_->IsTagCloudUpdateLocal(localInfo, cloudInfo, policy); in IsTagCloudUpdateLocal()

Completed in 17 milliseconds

12