Home
last modified time | relevance | path

Searched refs:downloadData (Results 1 – 22 of 22) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_executor_utils.h39 static int PutCloudData(sqlite3 *db, bool isMemory, DownloadData &downloadData);
86 static int ExecutePutCloudData(sqlite3 *db, bool isMemory, DownloadData &downloadData,
90 DownloadData &downloadData);
101 DownloadData &downloadData);
125 …t OnlyUpdateLogTable(sqlite3 *db, bool isMemory, int index, OpType op, DownloadData &downloadData);
127 …lyUpdateSyncData(sqlite3 *db, bool isMemory, int index, OpType opType, DownloadData &downloadData);
129 …ndUpdateSyncDataStmt(sqlite3_stmt *dataStmt, int index, OpType opType, DownloadData &downloadData);
131 … static int BindUpdateTimestampStmt(sqlite3_stmt *dataStmt, int index, DownloadData &downloadData);
136 static std::pair<int, DataItem> GetDataItem(int index, DownloadData &downloadData);
H A Dsqlite_cloud_kv_executor_utils.cpp366 if (downloadData.data.size() != downloadData.opType.size()) { in PutCloudData()
368 downloadData.opType.size()); in PutCloudData()
386 DownloadData &downloadData, std::map<int, int> &statisticMap) in ExecutePutCloudData() argument
390 for (OpType op : downloadData.opType) { in ExecutePutCloudData()
425 DownloadData &downloadData) in OperateCloudData() argument
551 DownloadData &downloadData) in BindStmt() argument
553 auto [errCode, dataItem] = GetDataItem(index, downloadData); in BindStmt()
799 DownloadData &downloadData) in OnlyUpdateLogTable() argument
801 if (downloadData.existDataHashKey[index].empty()) { in OnlyUpdateLogTable()
896 DownloadData &downloadData) in OnlyUpdateSyncData() argument
[all …]
H A Dsqlite_cloud_kv_store.cpp252 …KvStore::PutCloudSyncData([[gnu::unused]] const std::string &tableName, DownloadData &downloadData)
259 downloadData.timeOffset = storageHandle_->GetLocalTimeOffsetForCloud();
260 return SqliteCloudKvExecutorUtils::PutCloudData(db, isMemory, downloadData);
H A Dsqlite_cloud_kv_store.h65 int PutCloudSyncData(const std::string &tableName, DownloadData &downloadData) override;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_save_cloud_data_test.cpp820 downloadData.data.push_back(vBucket); in ConstructDownloadData()
844 DownloadData downloadData; in SaveCloudDataTest() local
1038 downloadData.data.push_back(vBucket); in ConstructMultiDownloadData()
1068 DownloadData downloadData; variable
1101 DownloadData downloadData; variable
1153 DownloadData downloadData; variable
1158 downloadData.data.push_back(vBucket);
1159 downloadData.opType = { OpType::DELETE };
1187 DownloadData downloadData; variable
1247 DownloadData downloadData; in DeleteWithPkTest() local
[all …]
H A Ddistributeddb_cloud_meta_data_test.cpp277 DownloadData downloadData; variable
278 EXPECT_EQ(proxyObj.PutCloudSyncData(TABLE_NAME_1, downloadData), -E_INVALID_DB);
280 … EXPECT_EQ(proxyObj.MarkFlagAsConsistent(TABLE_NAME_1, downloadData, gidFilters), -E_INVALID_DB);
349 DownloadData downloadData; variable
350 EXPECT_EQ(obj.PutCloudSyncData(TABLE_NAME_1, downloadData), -E_INVALID_DB);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.cpp502 VBucket &datum = param.downloadData.data[j]; in UpdateChangedData()
745 param.downloadData.opType[idx] = strategyOpResult; in TagStatus()
760 OpType strategy = param.downloadData.opType[idx]; in TagDownloadAssets()
787 OpType strategy = param.downloadData.opType[idx]; in HandleTagAssets()
900 VBucket &lastData = param.downloadData.data.back(); in SaveData()
1080 param.downloadData.opType.resize(param.downloadData.data.size()); in SaveDataNotifyProcess()
1081 param.downloadData.existDataKey.resize(param.downloadData.data.size()); in SaveDataNotifyProcess()
1082 param.downloadData.existDataHashKey.resize(param.downloadData.data.size()); in SaveDataNotifyProcess()
1425 DownloadData &downloadData) in QueryCloudData() argument
2076 param.downloadData = {}; in DownloadDataFromCloud()
[all …]
H A Dcloud_sync_utils.cpp409 … param.downloadData.data[dataIndex], param.changedData, dataInfo.localInfo, ChangeType::OP_INSERT); in SaveChangedData()
413 …return CloudSyncUtils::SaveChangedDataByType(param.downloadData.data[dataIndex], param.changedData, in SaveChangedData()
419 …return CloudSyncUtils::SaveChangedDataByType(param.downloadData.data[dataIndex], param.changedData, in SaveChangedData()
582 OpType opType = param.downloadData.opType[dataIndex]; in CalOpType()
589 …int errCode = CloudSyncUtils::GetCloudPkVals(param.downloadData.data[dataIndex], param.changedData… in CalOpType()
H A Dicloud_syncer.h64 DownloadData downloadData; member
H A Dcloud_syncer.h201 DownloadData &downloadData);
H A Dcloud_syncer_extend.cpp576 return storageProxy_->MarkFlagAsConsistent(param.tableName, param.downloadData, gidFilters); in UpdateFlagForSavedRecord()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp262 downloadData.data.push_back(vBucket); in ConstructMultiDownloadData()
264 downloadData.opType = opTypes; in ConstructMultiDownloadData()
267 void AddVersionToDownloadData(DownloadData &downloadData) in AddVersionToDownloadData() argument
269 for (size_t i = 0; i < downloadData.data.size(); i++) { in AddVersionToDownloadData()
276 for (size_t i = 0; i < downloadData.data.size(); i++) { in AddCloudOwnerToDownloadData()
1046 DownloadData downloadData; variable
1425 DownloadData downloadData; variable
1437 AddVersionToDownloadData(downloadData);
1467 DownloadData downloadData; variable
1470 AddVersionToDownloadData(downloadData);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp256 for (OpType op : downloadData.opType) { in ExecutePutCloudData()
257 VBucket &vBucket = downloadData.data[index]; in ExecutePutCloudData()
278 GetLocalDataKey(index, downloadData), op) : errCode; in ExecutePutCloudData()
613 if (downloadData.data.size() != downloadData.opType.size()) { in PutCloudSyncData()
614 LOGE("put cloud data, data size = %zu, flag size = %zu.", downloadData.data.size(), in PutCloudSyncData()
615 downloadData.opType.size()); in PutCloudSyncData()
1335 const DownloadData &downloadData, const std::set<std::string> &gidFilters) in MarkFlagAsConsistent() argument
1337 if (downloadData.data.size() != downloadData.opType.size()) { in MarkFlagAsConsistent()
1338 …LOGE("The num of data:%zu an opType:%zu is not equal.", downloadData.data.size(), downloadData.opT… in MarkFlagAsConsistent()
1351 for (const auto &data: downloadData.data) { in MarkFlagAsConsistent()
[all …]
H A Dsqlite_single_ver_relational_storage_executor.h135 const TrackerTable &trackerTable, DownloadData &downloadData);
200 int MarkFlagAsConsistent(const std::string &tableName, const DownloadData &downloadData,
291 … const TrackerTable &trackerTable, DownloadData &downloadData, std::map<int, int> &statisticMap);
390 int64_t GetLocalDataKey(size_t index, const DownloadData &downloadData);
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp1051 const DownloadData &downloadData) in GetLocalDataKey() argument
1053 if (index >= downloadData.existDataKey.size()) { in GetLocalDataKey()
1057 return downloadData.existDataKey[index]; in GetLocalDataKey()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_db_proxy_test.cpp783 param.downloadData.opType.push_back(OpType::INSERT);
784 param.downloadData.opType.push_back(OpType::UPDATE);
789 param.downloadData.data.push_back(oneRow);
790 param.downloadData.data.push_back(oneRow);
795 for (size_t i = 0; i < param.downloadData.data.size(); ++i) {
803 param.downloadData.data.push_back(oneRow);
804 param.downloadData.opType.push_back(OpType::UPDATE);
806 EXPECT_EQ(CloudSyncUtils::CalOpType(param, param.downloadData.data.size() - 1), OpType::UPDATE);
H A Ddistributeddb_cloud_asset_compare_test.cpp1029 param.downloadData.opType.push_back(OpType::INSERT);
1030 param.downloadData.opType.push_back(OpType::UPDATE);
1035 param.downloadData.data.push_back(oneRow);
1036 param.downloadData.data.push_back(oneRow);
1047 for (size_t i = 0; i < param.downloadData.opType.size(); ++i) {
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dstorage_proxy.h83 int PutCloudSyncData(const std::string &tableName, DownloadData &downloadData);
133 int MarkFlagAsConsistent(const std::string &tableName, const DownloadData &downloadData,
H A Dicloud_sync_storage_interface.h131 virtual int PutCloudSyncData(const std::string &tableName, DownloadData &downloadData) = 0;
206 …[[gnu::unused]] const DownloadData &downloadData, [[gnu::unused]] const std::set<std::string> &gid…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp309 int StorageProxy::PutCloudSyncData(const std::string &tableName, DownloadData &downloadData) in PutCloudSyncData() argument
319 downloadData.user = user_; in PutCloudSyncData()
320 return store_->PutCloudSyncData(tableName, downloadData); in PutCloudSyncData()
599 … StorageProxy::MarkFlagAsConsistent(const std::string &tableName, const DownloadData &downloadData, in MarkFlagAsConsistent() argument
606 return store_->MarkFlagAsConsistent(tableName, downloadData, gidFilters); in MarkFlagAsConsistent()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp1270 …lationalSyncAbleStorage::PutCloudSyncData(const std::string &tableName, DownloadData &downloadData) in PutCloudSyncData() argument
1276 return PutCloudSyncDataInner(transactionHandle_, tableName, downloadData); in PutCloudSyncData()
1280 const std::string &tableName, DownloadData &downloadData) in PutCloudSyncDataInner() argument
1292 errCode = handle->PutCloudSyncData(tableName, tableSchema, trackerTable, downloadData); in PutCloudSyncDataInner()
1814 DownloadData downloadData; in UpsertDataInTransaction() local
1831 downloadData.opType.push_back(OpType::INSERT); in UpsertDataInTransaction()
1837 downloadData.opType.push_back(OpType::UPDATE); in UpsertDataInTransaction()
1844 downloadData.existDataKey.push_back(dataInfoWithLog.logInfo.dataKey); in UpsertDataInTransaction()
1845 downloadData.data.push_back(std::move(recordCopy)); in UpsertDataInTransaction()
1847 return PutCloudSyncDataInner(handle, tableName, downloadData); in UpsertDataInTransaction()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h172 int PutCloudSyncData(const std::string &tableName, DownloadData &downloadData) override;
218 int MarkFlagAsConsistent(const std::string &tableName, const DownloadData &downloadData,
237 DownloadData &downloadData);