Home
last modified time | relevance | path

Searched refs:currentContext_ (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_syncer_test.h59 currentContext_.currentTaskId = taskId; in InitCloudSyncer()
62 …currentContext_.notifier->Init({currentContext_.tableName}, { "cloud" }, cloudTaskInfos_[taskId].u… in InitCloudSyncer()
100 currentContext_.currentTaskId = 0u; in CallClose()
101 currentContext_.strategy = nullptr; in CallClose()
102 currentContext_.notifier = nullptr; in CallClose()
136 return currentContext_.currentTaskId; in getCurrentTaskId()
154 return this->currentContext_.tableName; in GetCurrentContextTableName()
159 this->currentContext_.tableName = name; in SetCurrentContextTableName()
238 currentContext_.tableName = tableName; in SetAssetFields()
239 currentContext_.assetFields[currentContext_.tableName] = assetFields; in SetAssetFields()
[all …]
H A Dvirtual_cloud_syncer.cpp78 currentContext_.isNeedUpload = true; in SetTaskNeedUpload()
89 CloudTaskInfo taskInfo = cloudTaskInfos_[currentContext_.currentTaskId]; in Notify()
90 currentContext_.notifier->NotifyProcess(taskInfo, {}, notifyIfError); in Notify()
103 currentContext_.currentTaskId = taskId; in SetCurrentTaskInfo()
104 currentContext_.notifier = std::make_shared<ProcessNotifier>(this); in SetCurrentTaskInfo()
123 if (currentContext_.currentTaskId == INVALID_TASK_ID) { in PauseCurrentTask()
126 cloudTaskInfos_[currentContext_.currentTaskId].pause = true; in PauseCurrentTask()
127 LOGD("[CloudSyncer] Mark taskId %" PRIu64 " paused success", currentContext_.currentTaskId); in PauseCurrentTask()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.cpp181 currentContext_.currentUserIndex = currentContext_.currentUserIndex + 1; in SetProxyUser()
296 currentContext_.processRecorder->MarkDownloadFinish(currentContext_.currentUserIndex, in PrepareAndUpload()
554 …bool hasTable = (currentContext_.assetFields.find(currentContext_.tableName) != currentContext_.as… in IsDataContainAssets()
560 if (currentContext_.assetFields[currentContext_.tableName].empty()) { in IsDataContainAssets()
574 assetFields = currentContext_.assetFields[currentContext_.tableName]; in TagAssetsInSingleRecord()
721 fields = currentContext_.assetFields[currentContext_.tableName]; in GetAssetsFromVBucket()
1341 if (currentContext_.cloudWaterMarks.find(currentContext_.currentUserIndex) == in SaveCloudWaterMark()
1344 currentContext_.cloudWaterMarks[currentContext_.currentUserIndex].end()) { in SaveCloudWaterMark()
2037 currentContext_.assetFields[currentContext_.tableName] = assetFields; in GetSyncParamForDownload()
2117 return currentContext_.notifier->GetUploadBatchIndex(currentContext_.tableName); in GetCurrentTableUploadBatchIndex()
[all …]
H A Dcloud_syncer_extend.cpp46 …std::string cacheCloudWaterMark = currentContext_.cloudWaterMarks[currentContext_.currentUserIndex… in ReloadCloudWaterMarkIfNeed()
136 currentContext_.notifier->UpdateProcess(info); in UpdateProccessWhenUploadFailed()
694 if (currentContext_.processRecorder->IsDownloadFinish(currentContext_.currentUserIndex, in DoDownloadInNeed()
700 table = currentContext_.tableName; in DoDownloadInNeed()
1030 assetFields = currentContext_.assetFields[currentContext_.tableName]; in TagUploadAssets()
1087 currentContext_.repeatCount++; in SyncMachineDoRepeatCheck()
1095 currentContext_.repeatCount); in SyncMachineDoRepeatCheck()
1107 …currentContext_.processRecorder->MarkDownloadFinish(currentContext_.currentUserIndex, downloadTabl… in MarkDownloadFinishIfNeed()
1140 return currentContext_.processRecorder->IsUploadFinish(currentContext_.currentUserIndex, table); in IsTableFinishInUpload()
1150 … currentContext_.processRecorder->MarkUploadFinish(currentContext_.currentUserIndex, table, true); in MarkUploadFinishIfNeed()
[all …]
H A Dcloud_syncer.h445 TaskContext currentContext_; variable