Searched refs:currentTaskId (Results 1 – 5 of 5) sorted by relevance
89 CloudTaskInfo taskInfo = cloudTaskInfos_[currentContext_.currentTaskId]; in Notify()103 currentContext_.currentTaskId = taskId; 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()
59 currentContext_.currentTaskId = taskId; in InitCloudSyncer()78 cloudTaskInfos_[currentContext_.currentTaskId].table = tables; in SetCurrentCloudTaskInfos()79 cloudTaskInfos_[currentContext_.currentTaskId].callback = onProcess; in SetCurrentCloudTaskInfos()84 return cloudTaskInfos_[currentContext_.currentTaskId]; in GetCurrentCloudTaskInfos()100 currentContext_.currentTaskId = 0u; in CallClose()136 return currentContext_.currentTaskId; in getCurrentTaskId()232 auto info = cloudTaskInfos_[currentContext_.currentTaskId]; in CallNotify()271 currentContext_.currentTaskId = taskId; in SetCurrentContext()281 cloudTaskInfos_[currentContext_.currentTaskId].pause = true; in SetCurrentTaskPause()361 taskInfo = cloudTaskInfos_[currentContext_.currentTaskId]; in CallDoDownloadInNeed()[all …]
120 currentTask = currentContext_.currentTaskId; in Close()141 currentTask = currentContext_.currentTaskId; in StopAllTasks()432 taskId = currentContext_.currentTaskId; in SyncMachineDoFinished()705 taskId = currentContext_.currentTaskId; in DownloadAssets()941 taskId = currentContext_.currentTaskId; in NeedNotifyChangedData()1507 currentContext_.currentTaskId = taskId; in PrepareSync()1592 if (currentContext_.currentTaskId != taskId) { in HeartBeat()1613 if (currentContext_.currentTaskId != taskId) { in HeartBeat()1816 if (currentContext_.currentTaskId == INVALID_TASK_ID) { in MarkCurrentTaskPausedIfNeed()1878 heartbeatCount_.erase(currentContext_.currentTaskId); in ClearCurrentContextWithoutLock()[all …]
121 for (const auto &item : cloudTaskInfos_[currentContext_.currentTaskId].queryList) { in GetQuerySyncObject()798 TaskId runningTask = currentContext_.currentTaskId; in TryMergeTask()1048 if (cloudTaskInfos_.find(currentContext_.currentTaskId) == cloudTaskInfos_.end()) { in IsLockInDownload()1051 …auto currentLockAction = static_cast<uint32_t>(cloudTaskInfos_[currentContext_.currentTaskId].lock… in IsLockInDownload()1058 cloudTaskInfos_[currentContext_.currentTaskId].errCode = errCode; in SetCurrentTaskFailedInMachine()1094 … LOGD("[CloudSyncer] Repeat taskId %" PRIu64 " download current %d", currentContext_.currentTaskId, in SyncMachineDoRepeatCheck()1194 if (currentContext_.currentTaskId == taskId) { in GetCloudTaskStatus()
92 TaskId currentTaskId = 0u; member