| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.h | 131 SyncParam syncParam;
230 int SaveData(CloudSyncer::TaskId taskId, SyncParam ¶m);
234 int SaveDataInTransaction(CloudSyncer::TaskId taskId, SyncParam ¶m);
239 int DoDownloadAssets(bool skipSave, SyncParam ¶m);
241 int SaveDataNotifyProcess(CloudSyncer::TaskId taskId, SyncParam ¶m);
289 int UpdateChangedData(SyncParam ¶m, DownloadList &assetsDownloadList);
291 void UpdateCloudWaterMark(TaskId taskId, const SyncParam ¶m);
298 int GetLocalInfo(size_t index, SyncParam ¶m, DataInfoWithLog &logInfo,
315 int DownloadOneBatch(TaskId taskId, SyncParam ¶m, bool isFirstDownload);
320 int GetSyncParamForDownload(TaskId taskId, SyncParam ¶m);
[all …]
|
| H A D | cloud_sync_utils.h | 81 …static int SaveChangedData(ICloudSyncer::SyncParam ¶m, size_t dataIndex, const ICloudSyncer::D…
84 static void ClearWithoutData(ICloudSyncer::SyncParam ¶m);
98 static OpType CalOpType(ICloudSyncer::SyncParam ¶m, size_t dataIndex);
|
| H A D | cloud_syncer.cpp | 495 int CloudSyncer::UpdateChangedData(SyncParam ¶m, DownloadList &assetsDownloadList) in UpdateChangedData()
853 int CloudSyncer::SaveData(CloudSyncer::TaskId taskId, SyncParam ¶m) in SaveData()
1004 int CloudSyncer::SaveDataInTransaction(CloudSyncer::TaskId taskId, SyncParam ¶m) in SaveDataInTransaction()
1037 int CloudSyncer::DoDownloadAssets(bool skipSave, SyncParam ¶m) in DoDownloadAssets()
1066 int CloudSyncer::SaveDataNotifyProcess(CloudSyncer::TaskId taskId, SyncParam ¶m) in SaveDataNotifyProcess()
1120 SyncParam param; in DoDownload()
1709 void CloudSyncer::UpdateCloudWaterMark(TaskId taskId, const SyncParam ¶m) in UpdateCloudWaterMark()
1767 int CloudSyncer::GetLocalInfo(size_t index, SyncParam ¶m, DataInfoWithLog &logInfo, in GetLocalInfo()
1934 int CloudSyncer::DownloadOneBatch(TaskId taskId, SyncParam ¶m, bool isFirstDownload) in DownloadOneBatch()
2006 int CloudSyncer::GetSyncParamForDownload(TaskId taskId, SyncParam ¶m) in GetSyncParamForDownload()
[all …]
|
| H A D | icloud_syncer.h | 63 struct SyncParam { struct
|
| H A D | cloud_sync_utils.cpp | 382 int CloudSyncUtils::SaveChangedData(ICloudSyncer::SyncParam ¶m, size_t dataIndex, in SaveChangedData()
426 void CloudSyncUtils::ClearWithoutData(ICloudSyncer::SyncParam ¶m) in ClearWithoutData()
580 OpType CloudSyncUtils::CalOpType(ICloudSyncer::SyncParam ¶m, size_t dataIndex) in CalOpType()
|
| H A D | cloud_syncer_extend.cpp | 565 int CloudSyncer::UpdateFlagForSavedRecord(const SyncParam ¶m) in UpdateFlagForSavedRecord()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_syncer_test.h | 313 void SetResumeSyncParam(TaskId taskId, const SyncParam &syncParam) in SetResumeSyncParam()
329 int CallGetSyncParamForDownload(TaskId taskId, SyncParam ¶m) in CallGetSyncParamForDownload()
344 …int CallHandleTagAssets(const Key &hashKey, const DataInfo &dataInfo, size_t idx, SyncParam ¶m, in CallHandleTagAssets()
|
| H A D | virtual_cloud_syncer.cpp | 113 SyncParam param; in CallTagStatusByStrategy()
|
| H A D | distributeddb_cloud_syncer_upload_test.cpp | 1081 ICloudSyncer::SyncParam param;
1088 ICloudSyncer::SyncParam actualParam;
1123 ICloudSyncer::SyncParam param;
1130 ICloudSyncer::SyncParam actualParam;
|
| H A D | distributeddb_cloud_syncer_download_test.cpp | 767 ICloudSyncer::SyncParam param;
772 ICloudSyncer::SyncParam actualParam;
|
| H A D | distributeddb_cloud_db_proxy_test.cpp | 782 ICloudSyncer::SyncParam param;
|
| H A D | distributeddb_cloud_asset_compare_test.cpp | 1028 ICloudSyncer::SyncParam param;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | sync_event.h | 27 …API_EXPORT EventInfo(const SyncParam &syncParam, bool retry, std::shared_ptr<GenQuery> query, GenA…
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | sync_event.cpp | 24 SyncEvent::EventInfo::EventInfo(const SyncParam &syncParam, bool retry, std::shared_ptr<GenQuery> q… in EventInfo()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
| H A D | general_store_mock.h | 41 const SyncParam &syncParm) override;
|
| H A D | general_store_mock.cpp | 73 const SyncParam &syncParm) in Sync()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/ |
| H A D | general_value.h | 95 struct SyncParam { struct
|
| H A D | general_store.h | 154 DetailAsync async, const SyncParam &syncParm) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_general_store.h | 64 const SyncParam &syncParm) override;
|
| H A D | kvdb_general_store.cpp | 379 const SyncParam &syncParam) in Sync()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.h | 75 const DistributedData::SyncParam &syncParam) override;
|
| H A D | rdb_service_impl.cpp | 441 SyncParam syncParam = { option.mode, 0, option.isCompensation }; in DoSync()
558 SyncParam syncParam = { mixMode, (option.isAsync ? 0 : WAIT_TIME), option.isCompensation }; in DoCloudSync()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | kvdb_general_store_test.cpp | 326 SyncParam syncParam{};
449 SyncParam syncParam{};
|
| H A D | rdb_general_store_test.cpp | 727 SyncParam syncParam;
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 312 … SyncParam syncParam = { info.mode_, info.wait_, info.isCompensation_, info.triggerMode_, in GetPostEventTask()
402 …SyncParam syncParam = { evt.GetMode(), evt.GetWait(), evt.IsCompensation(), MODE_DEFAULT, prepareT… in GetSyncHandler()
|