| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_strategy_test.cpp | 119 localInfo.cloudGid = "gid";
162 localInfo.cloudGid = "";
215 localInfo.cloudGid = "gid";
217 localInfo.cloudGid = "";
228 localInfo.cloudGid = "gid";
259 localInfo.cloudGid = "";
267 localInfo.cloudGid = "gid";
275 localInfo.cloudGid = "";
284 localInfo.cloudGid = "gid";
307 localInfo.cloudGid = "";
[all …]
|
| H A D | distributeddb_cloud_db_proxy_test.cpp | 754 cloudInfo.cloudGid = "gid";
761 EXPECT_EQ(localLogInfoCache[hashKey].cloudGid, cloudInfo.cloudGid);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_strategy.cpp | 79 LOGW("[CloudSyncStrategy] dont ignore %.6s", localInfo.cloudGid.c_str()); in IsIgnoreUpdate()
83 LOGW("[CloudSyncStrategy] %.6s was ignored override", localInfo.cloudGid.c_str()); in IsIgnoreUpdate()
|
| H A D | cloud_merge_strategy.cpp | 49 …if (isTimeSame && (localInfo.cloudGid.empty() || cloudInfo.sharingResource != localInfo.sharingRes… in TagSyncDataStatus()
71 if (localInfo.cloudGid.empty()) { in TagLocallyNewer()
|
| H A D | cloud_force_pull_strategy.cpp | 40 bool gidEmpty = localInfo.cloudGid.empty(); in TagSyncDataStatus()
|
| H A D | cloud_force_push_strategy.cpp | 31 if (localInfo.cloudGid.empty()) { in TagSyncDataStatus()
|
| H A D | cloud_sync_utils.cpp | 151 localLogInfo.cloudGid == cloudLogInfo.cloudGid && in NeedSaveData()
188 cloudLogInfo.cloudGid = std::get<std::string>(datum[CloudDbConstant::GID_FIELD]); in GetCloudLogInfo()
369 updateLogInfo.cloudGid.clear(); in UpdateLocalCache()
|
| H A D | cloud_syncer_extend.cpp | 106 std::vector<std::string> cloudGid; in GetCloudGid() local
108 …t errCode = storageProxy_->GetCloudGid(obj, isCloudForcePush, IsCompensatedTask(taskId), cloudGid); in GetCloudGid()
111 } else if (!cloudGid.empty()) { in GetCloudGid()
112 obj.SetCloudGid(cloudGid); in GetCloudGid()
114 LOGI("[CloudSyncer] get cloud gid size:%zu", cloudGid.size()); in GetCloudGid()
435 logInfo.cloudGid = gid; in CommitDownloadAssets()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | query_sync_object.cpp | 246 void QuerySyncObject::SetCloudGid(const std::vector<std::string> &cloudGid) in SetCloudGid() argument
248 for (size_t i = 0; i < cloudGid.size(); i+= MAX_VALUE_SIZE) { in SetCloudGid()
249 size_t end = std::min(i + MAX_VALUE_SIZE, cloudGid.size()); in SetCloudGid()
259 std::vector<std::string> subCloudGid(cloudGid.begin() + i, cloudGid.begin() + end); in SetCloudGid()
|
| H A D | query_sync_object.h | 48 void SetCloudGid(const std::vector<std::string> &cloudGid);
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 151 std::string cloudGid = reinterpret_cast<const std::string::value_type *>( in GetCloudLog() local
153 if (!cloudGid.empty()) { in GetCloudLog()
154 logInfo.insert_or_assign(CloudDbConstant::GID_FIELD, cloudGid); in GetCloudLog()
155 totalSize += cloudGid.size(); in GetCloudLog()
353 dataInfoWithLog.logInfo.cloudGid = gid; in FillLogInfoWithStmt()
1379 QuerySyncObject &querySyncObject, std::vector<std::string> &cloudGid) in QueryCloudGid() argument
1403 cloudGid.push_back(gid); in QueryCloudGid()
|
| H A D | sqlite_cloud_kv_store.h | 58 bool isCompensatedTask, std::vector<std::string> &cloudGid) override;
|
| H A D | sqlite_cloud_kv_store.cpp | 349 bool isCloudForcePush, bool isCompensatedTask, std::vector<std::string> &cloudGid) in GetCloudGid() argument
359 …rrCode = SqliteCloudKvExecutorUtils::QueryCloudGid(db, handle->IsMemory(), user_, query, cloudGid); in GetCloudGid()
|
| H A D | sqlite_cloud_kv_executor_utils.h | 63 std::vector<std::string> &cloudGid);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 103 (void)SQLiteUtils::GetColumnTextValue(statement, index++, logInfo.cloudGid); // 7 is cloud_gid in GetLogInfoByStatement()
196 std::string cloudGid; in GetQueryLogStatement() local
198 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in GetQueryLogStatement()
206 if (!cloudGid.empty()) { in GetQueryLogStatement()
208 errCode = SQLiteUtils::BindTextToStatement(selectStmt, index, cloudGid); in GetQueryLogStatement()
228 std::string cloudGid; in GetQueryLogSql() local
229 …nt errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in GetQueryLogSql()
235 if (pkSet.empty() && cloudGid.empty()) { in GetQueryLogSql()
241 if (!cloudGid.empty()) { in GetQueryLogSql()
786 std::string cloudGid; in BindHashKeyAndGidToInsertLogStatement() local
[all …]
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 99 std::string cloudGid; in FillCloudAssetForDownload() local
100 …nt errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in FillCloudAssetForDownload()
116 …std::tie(errCode, std::ignore) = GetAssetsByGidOrHashKey(tableSchema, cloudGid, hashKey, dbAssets); in FillCloudAssetForDownload()
127 errCode = IncreaseCursorOnAssetData(tableSchema.name, cloudGid); in FillCloudAssetForDownload()
141 errCode = ExecuteFillDownloadAssetStatement(stmt, assetsField.size() + 1, cloudGid); in FillCloudAssetForDownload()
291 std::string cloudGid; in InitFillUploadAssetStatement() local
293 …CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in InitFillUploadAssetStatement()
294 …std::tie(errCode, std::ignore) = GetAssetsByGidOrHashKey(tableSchema, cloudGid, data.hashKey.at(in… in InitFillUploadAssetStatement()
1414 int beginIndex, const std::string &cloudGid) in ExecuteFillDownloadAssetStatement() argument
1416 int errCode = SQLiteUtils::BindTextToStatement(stmt, beginIndex, cloudGid); in ExecuteFillDownloadAssetStatement()
[all …]
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 612 std::string cloudGid = reinterpret_cast<const std::string::value_type *>( in GetCloudLog() local
614 if (!cloudGid.empty()) { in GetCloudLog()
615 logInfo.insert_or_assign(CloudDbConstant::GID_FIELD, cloudGid); in GetCloudLog()
616 totalSize += cloudGid.size(); in GetCloudLog()
640 void GetCloudGid(sqlite3_stmt *logStatement, std::vector<std::string> &cloudGid) in GetCloudGid() argument
651 cloudGid.emplace_back(gid); in GetCloudGid()
1607 bool isCompensatedTask, std::vector<std::string> &cloudGid) in GetSyncCloudGid() argument
1627 GetCloudGid(queryStmt, cloudGid); in GetSyncCloudGid()
|
| H A D | sqlite_single_ver_relational_storage_executor.h | 127 bool isCompensatedTask, std::vector<std::string> &cloudGid);
414 …xecuteFillDownloadAssetStatement(sqlite3_stmt *&stmt, int beginIndex, const std::string &cloudGid);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | data_transformer.h | 38 std::string cloudGid; // use for sync with cloud member
|
| H A D | storage_proxy.cpp | 263 bool isCompensatedTask, std::vector<std::string> &cloudGid) in GetCloudGid() argument
274 …n store_->GetCloudGid(tableSchema, querySyncObject, isCloudForcePush, isCompensatedTask, cloudGid); in GetCloudGid()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 147 std::string cloudGid; in InitLogData() local
152 cloudGid = "''"; in InitLogData()
155 cloudGid = "'" + g_storeID + index + "'"; in InitLogData()
158 cloudGid = "'" + g_storeID + index + "'"; in InitLogData()
161 cloudGid = "''"; in InitLogData()
167 std::to_string(g_startTime + i) + "','" + flag + "', ? , " + cloudGid + ");"; in InitLogData()
995 ASSERT_EQ(dataInfo.logInfo.cloudGid, std::to_string(i));
1033 ASSERT_EQ(dataInfo.logInfo.cloudGid, std::to_string(i));
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_meta_data_test.cpp | 340 std::vector<std::string> cloudGid; variable
341 EXPECT_EQ(obj.GetCloudGid(tableSchema, querySync, true, true, cloudGid), -E_INVALID_DB);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | storage_proxy.h | 78 bool isCompensatedTask, std::vector<std::string> &cloudGid);
|
| H A D | icloud_sync_storage_interface.h | 124 bool isCloudForcePush, bool isCompensatedTask, std::vector<std::string> &cloudGid) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1157 bool isCloudForcePush, bool isCompensatedTask, std::vector<std::string> &cloudGid) in GetCloudGid() argument
1169 …ode = handle->GetSyncCloudGid(query, syncTimeRange, isCloudForcePush, isCompensatedTask, cloudGid); in GetCloudGid()
1838 recordCopy[CloudDbConstant::GID_FIELD] = dataInfoWithLog.logInfo.cloudGid; in UpsertDataInTransaction()
1910 std::string cloudGid; in UpdateRecordFlagAfterUpload() local
1911 (void)CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, record, cloudGid); in UpdateRecordFlagAfterUpload()
1913 logInfo.cloudGid = cloudGid; in UpdateRecordFlagAfterUpload()
|