| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 222 size_t delRecordLen = uploadData.delData.record.size(); in CheckCloudSyncDataValid()
223 size_t delExtendLen = uploadData.delData.extend.size(); in CheckCloudSyncDataValid()
251 std::vector<VBucket>().swap(uploadData.delData.record); in ClearCloudSyncData()
252 std::vector<VBucket>().swap(uploadData.delData.extend); in ClearCloudSyncData()
289 uploadData.delData.extend.empty() && uploadData.delData.record.empty() && in CheckCloudSyncDataEmpty()
333 if (!uploadData.delData.extend.empty()) { in UpdateExtendTime()
334 if (uploadData.delData.record.size() != uploadData.delData.extend.size()) { in UpdateExtendTime()
338 ret = CloudSyncUtils::GetWaterMarkAndUpdateTime(uploadData.delData.extend, waterMark); in UpdateExtendTime()
563 AssetOperationUtils::UpdateAssetsFlag(uploadData.delData.record, uploadData.delData.assets); in UpdateAssetsFlag()
|
| H A D | cloud_syncer_extend.cpp | 581 int errCode = cloudDB_.BatchDelete(uploadData.tableName, uploadData.delData.record, in BatchDelete()
582 uploadData.delData.extend, deleteInfo); in BatchDelete()
|
| H A D | cloud_syncer.cpp | 1199 if (!uploadData.delData.record.empty() && !uploadData.delData.extend.empty()) { in SaveUploadData()
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/ |
| H A D | js_watcher.cpp | 239 EventHandler *delData = i; in Del() local
242 handlers_ = delData->next; in Del()
244 temp->next = delData->next; in Del()
246 napi_delete_reference(env, delData->callbackRef); in Del()
247 delete delData; in Del()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_types.h | 43 CloudSyncBatch delData; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_syncer_test.h | 211 uploadData.delData.record = std::vector<VBucket>(size, tmp); in initFullCloudSyncData()
212 uploadData.delData.extend = std::vector<VBucket>(size, tmp); in initFullCloudSyncData()
|
| H A D | distributeddb_cloud_syncer_upload_test.cpp | 126 uploadData.delData.record = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataForUploadModeCheck012()
127 uploadData.delData.extend = std::vector<VBucket>(COUNT, tmp); in PrepareUploadDataForUploadModeCheck012()
754 uploadData2.delData.record = std::vector<VBucket>(1000, tmp);
755 uploadData2.delData.extend = std::vector<VBucket>(1000, tmp);
934 extend = uploadData.delData.extend; in SetFuncs015()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 1302 cloudSyncData.delData.record.push_back(data); in IdentifyCloudTypeInner()
1303 cloudSyncData.delData.extend.push_back(log); in IdentifyCloudTypeInner()
1304 cloudSyncData.delData.hashKey.push_back(*hashKey); in IdentifyCloudTypeInner()
1305 cloudSyncData.delData.timestamp.push_back(*timeStamp); in IdentifyCloudTypeInner()
1306 cloudSyncData.delData.rowid.push_back(*rowid); in IdentifyCloudTypeInner()
|
| /ohos5.0/base/print/print_fwk/test/unittest/service_test/ |
| H A D | print_service_stub_test.cpp | 1050 MessageParcel delData; variable
1054 EXPECT_TRUE(delData.WriteInterfaceToken(IPrintCallback::GetDescriptor()));
1055 EXPECT_TRUE(delData.WriteString(printerName));
1058 EXPECT_TRUE(static_cast<bool>(stub->OnRemoteRequest(delCode, delData, delReply, option)));
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 1445 syncData.delData.rowid.push_back(3); // rowid is 3
1446 syncData.delData.extend.resize(1); // has 1 record
1450 CheckCloudBatchData(syncData.delData, false);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_executor_utils.cpp | 52 …data.insData.record.size(), data.updData.record.size(), data.delData.extend.size(), errCode, total… in GetCloudData()
77 maxTimeStamp = GetMaxTimeStamp(data.delData.extend); in UpdateBeginTimeForMemoryDB()
792 return FillCloudGid(param, data.delData, user, CloudWaterType::DELETE, recorder); in FillCloudLog()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 1377 syncData.delData.extend.push_back(extend1);
1388 syncData.delData.hashKey.push_back(hashKey);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1143 cloudDataResult.delData.extend.size(), cloudDataResult.lockData.extend.size()); in GetCloudDataNext()
1879 …errCode = UpdateRecordFlagAfterUpload(handle, data.tableName, data.delData, CloudWaterType::DELETE… in FillCloudLogAndAssetInner()
|