Home
last modified time | relevance | path

Searched refs:CloudTaskInfo (Results 1 – 16 of 16) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h54 cloudTaskInfos_.insert(std::pair<TaskId, CloudTaskInfo>{taskId, CloudTaskInfo()}); in InitCloudSyncer()
82 CloudTaskInfo GetCurrentCloudTaskInfos() in GetCurrentCloudTaskInfos()
90 CloudTaskInfo taskInfo; in CreateCloudTaskInfoAndCallTryToAddSync()
124 int CallDoSyncInner(const CloudTaskInfo &taskInfo) in CallDoSyncInner()
187 CloudTaskInfo SetAndGetCloudTaskInfo(SyncMode mode, std::vector<std::string> table, in SetAndGetCloudTaskInfo()
190 CloudTaskInfo taskInfo; in SetAndGetCloudTaskInfo()
215 int CallTryToAddSyncTask(CloudTaskInfo &&taskInfo) in CallTryToAddSyncTask()
358 CloudTaskInfo taskInfo; in CallDoDownloadInNeed()
368 CloudTaskInfo taskInfo; in CallDoUploadInNeed()
375 CloudTaskInfo taskInfo_;
H A Dvirtual_cloud_syncer.cpp36 int VirtualCloudSyncer::DoDownloadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload, bool… in DoDownloadInNeed()
89 CloudTaskInfo taskInfo = cloudTaskInfos_[currentContext_.currentTaskId]; in Notify()
105 CloudTaskInfo taskInfo; in SetCurrentTaskInfo()
H A Dvirtual_cloud_syncer.h27 …int DoDownloadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload, bool isFirstDownload) o…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.h52 int Sync(const CloudTaskInfo &taskInfo);
73 void GenerateCompensatedSync(CloudTaskInfo &taskInfo);
145 int PrepareAndUpload(const CloudTaskInfo &taskInfo, size_t index);
147 int DoSyncInner(const CloudTaskInfo &taskInfo);
149 int DoUploadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload);
207 int TryToAddSyncTask(CloudTaskInfo &&taskInfo);
385 …int PrepareAndDownload(const std::string &table, const CloudTaskInfo &taskInfo, bool isFirstDownlo…
397 bool IsTaskCanMerge(const CloudTaskInfo &taskInfo);
418 std::vector<CloudTaskInfo> CopyAndClearTaskInfos();
436 int GenerateTaskIdIfNeed(CloudTaskInfo &taskInfo);
[all …]
H A Dcloud_sync_utils.h100 static CloudSyncer::CloudTaskInfo InitCompensatedSyncTaskInfo();
102 static CloudSyncer::CloudTaskInfo InitCompensatedSyncTaskInfo(const CloudSyncOption &option,
105 …static CloudSyncer::CloudTaskInfo InitCompensatedSyncTaskInfo(const CloudSyncer::CloudTaskInfo &or…
H A Dcloud_sync_utils.cpp610 CloudSyncer::CloudTaskInfo CloudSyncUtils::InitCompensatedSyncTaskInfo() in InitCompensatedSyncTaskInfo()
612 CloudSyncer::CloudTaskInfo taskInfo; in InitCompensatedSyncTaskInfo()
621 CloudSyncer::CloudTaskInfo CloudSyncUtils::InitCompensatedSyncTaskInfo(const CloudSyncOption &optio… in InitCompensatedSyncTaskInfo()
624 CloudSyncer::CloudTaskInfo taskInfo = InitCompensatedSyncTaskInfo(); in InitCompensatedSyncTaskInfo()
637 CloudSyncer::CloudTaskInfo CloudSyncUtils::InitCompensatedSyncTaskInfo(const CloudSyncer::CloudTask… in InitCompensatedSyncTaskInfo()
639 CloudSyncer::CloudTaskInfo taskInfo = InitCompensatedSyncTaskInfo(); in InitCompensatedSyncTaskInfo()
H A Dcloud_syncer.cpp56 CloudTaskInfo taskInfo; in Sync()
70 int CloudSyncer::Sync(const CloudTaskInfo &taskInfo) in Sync()
84 CloudTaskInfo info = taskInfo; in Sync()
228 CloudTaskInfo taskInfo; in DoSync()
355 CloudTaskInfo taskInfo; in SyncMachineDoDownload()
389 CloudTaskInfo taskInfo; in SyncMachineDoUpload()
444 CloudTaskInfo taskInfo; in SyncMachineDoFinished()
459 int CloudSyncer::DoSyncInner(const CloudTaskInfo &taskInfo) in DoSyncInner()
1105 CloudTaskInfo taskInfo; in NotifyInBatchUpload()
1897 CloudTaskInfo info; in ClearContextAndNotify()
[all …]
H A Dprocess_notifier.h30 …void NotifyProcess(const ICloudSyncer::CloudTaskInfo &taskInfo, const ICloudSyncer::InnerProcessIn…
H A Dcloud_syncer_extend.cpp455 void CloudSyncer::GenerateCompensatedSync(CloudTaskInfo &taskInfo) in GenerateCompensatedSync()
528 int CloudSyncer::PrepareAndDownload(const std::string &table, const CloudTaskInfo &taskInfo, bool i… in PrepareAndDownload()
687 int CloudSyncer::DoDownloadInNeed(const CloudTaskInfo &taskInfo, const bool needUpload, bool isFirs… in DoDownloadInNeed()
741 int CloudSyncer::TryToAddSyncTask(CloudTaskInfo &&taskInfo) in TryToAddSyncTask()
839 bool CloudSyncer::IsTaskCanMerge(const CloudTaskInfo &taskInfo) in IsTaskCanMerge()
868 CloudTaskInfo &taskInfo) in AdjustTableBasedOnSchema()
1206 int CloudSyncer::GenerateTaskIdIfNeed(CloudTaskInfo &taskInfo) in GenerateTaskIdIfNeed()
H A Dicloud_syncer.h29 struct CloudTaskInfo { struct
H A Dprocess_notifier.cpp74 void ProcessNotifier::NotifyProcess(const ICloudSyncer::CloudTaskInfo &taskInfo, in NotifyProcess()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store.h157 CloudSyncer::CloudTaskInfo &info);
180 …ReFillSyncInfoTable(const std::vector<std::string> &actualTable, CloudSyncer::CloudTaskInfo &info);
H A Dsqlite_relational_store.cpp1121 … CloudSyncer::CloudTaskInfo info = CloudSyncUtils::InitCompensatedSyncTaskInfo(option, onProcess); in Sync()
1126 CloudSyncer::CloudTaskInfo info; in Sync()
1250 CloudSyncer::CloudTaskInfo &info) in FillSyncInfo()
1419 CloudSyncer::CloudTaskInfo &info) in ReFillSyncInfoTable()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dsync_able_kvdb.h158 CloudSyncer::CloudTaskInfo &info);
H A Dsync_able_kvdb.cpp545 CloudSyncer::CloudTaskInfo &info) in FillSyncInfo()
610 CloudSyncer::CloudTaskInfo info; in Sync()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_check_sync_test.cpp2061 …CloudSyncer::CloudTaskInfo taskInfo = CloudSyncUtils::InitCompensatedSyncTaskInfo(option, onProces…