Home
last modified time | relevance | path

Searched refs:InnerProcessInfo (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.h166 void NotifyInEmptyDownload(CloudSyncer::TaskId taskId, InnerProcessInfo &info);
173 InnerProcessInfo &innerProcessInfo);
177 int PreProcessBatchUpload(UploadParam &uploadParam, const InnerProcessInfo &innerProcessInfo,
275 int DownloadAssets(InnerProcessInfo &info, const std::vector<std::string> &pKColNames,
295 int CommitDownloadResult(const DownloadItem &downloadItem, InnerProcessInfo &info,
318 DownloadItem &downloadItem, InnerProcessInfo &info, ChangedData &changedAssets);
350 void NotifyUploadFailed(int errCode, InnerProcessInfo &info);
352 void UpdateProccessWhenUploadFailed(InnerProcessInfo &info);
360 int DownloadAssetsOneByOne(const InnerProcessInfo &info, DownloadItem &downloadItem,
363 std::pair<int, uint32_t> GetDBAssets(bool isSharedTable, const InnerProcessInfo &info,
[all …]
H A Dprocess_notifier.h28 void UpdateProcess(const ICloudSyncer::InnerProcessInfo &process);
30 …Process(const ICloudSyncer::CloudTaskInfo &taskInfo, const ICloudSyncer::InnerProcessInfo &process,
41 void GetDownloadInfoByTableName(ICloudSyncer::InnerProcessInfo &process);
H A Dcloud_syncer_extend.cpp50 void CloudSyncer::ReloadUploadInfoIfNeed(TaskId taskId, const UploadParam &param, InnerProcessInfo … in ReloadUploadInfoIfNeed()
132 void CloudSyncer::UpdateProccessWhenUploadFailed(InnerProcessInfo &info) in UpdateProccessWhenUploadFailed()
139 void CloudSyncer::NotifyUploadFailed(int errCode, InnerProcessInfo &info) in NotifyUploadFailed()
239 int CloudSyncer::DownloadAssetsOneByOne(const InnerProcessInfo &info, DownloadItem &downloadItem, in DownloadAssetsOneByOne()
267 std::pair<int, uint32_t> CloudSyncer::GetDBAssets(bool isSharedTable, const InnerProcessInfo &info, in GetDBAssets()
332 int CloudSyncer::IsNeedSkipDownload(bool isSharedTable, int &errCode, const InnerProcessInfo &info, in IsNeedSkipDownload()
368 int CloudSyncer::DownloadAssetsOneByOneInner(bool isSharedTable, const InnerProcessInfo &info, in DownloadAssetsOneByOneInner()
673 InnerProcessInfo innerProcessInfo; in UpdateProcessInfoWithoutUpload()
918 int CloudSyncer::HandleBatchUpload(UploadParam &uploadParam, InnerProcessInfo &info, in HandleBatchUpload()
965 InnerProcessInfo info = GetInnerProcessInfo(tableName, uploadParam); in DoUploadInner()
[all …]
H A Dicloud_syncer.h50 struct InnerProcessInfo { struct
66 InnerProcessInfo info; argument
H A Dprocess_notifier.cpp56 void ProcessNotifier::UpdateProcess(const ICloudSyncer::InnerProcessInfo &process) in UpdateProcess()
75 const ICloudSyncer::InnerProcessInfo &process, bool notifyWhenError) in NotifyProcess()
165 void ProcessNotifier::GetDownloadInfoByTableName(ICloudSyncer::InnerProcessInfo &process) in GetDownloadInfoByTableName()
H A Dcloud_syncer.cpp640 int CloudSyncer::CloudDbDownloadAssets(TaskId taskId, InnerProcessInfo &info, const DownloadList &d… in CloudDbDownloadAssets()
684 int CloudSyncer::DownloadAssets(InnerProcessInfo &info, const std::vector<std::string> &pKColNames, in DownloadAssets()
1102 void CloudSyncer::NotifyInBatchUpload(const UploadParam &uploadParam, const InnerProcessInfo &inner… in NotifyInBatchUpload()
1157 void CloudSyncer::NotifyInEmptyDownload(CloudSyncer::TaskId taskId, InnerProcessInfo &info) in NotifyInEmptyDownload()
1196 InnerProcessInfo &innerProcessInfo) in SaveUploadData()
1226 …:DoBatchUpload(CloudSyncData &uploadData, UploadParam &uploadParam, InnerProcessInfo &innerProcess… in DoBatchUpload()
1310 int CloudSyncer::PreProcessBatchUpload(UploadParam &uploadParam, const InnerProcessInfo &innerProce… in PreProcessBatchUpload()
1717 int CloudSyncer::CommitDownloadResult(const DownloadItem &downloadItem, InnerProcessInfo &info, in CommitDownloadResult()
1961 DownloadItem &downloadItem, InnerProcessInfo &info, ChangedData &changedAssets) in DownloadOneAssetRecord()
2138 CloudSyncer::InnerProcessInfo CloudSyncer::GetInnerProcessInfo(const std::string &tableName, Upload… in GetInnerProcessInfo()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h262 InnerProcessInfo info; in CallDownloadAssets()