Searched refs:cloudTaskInfos_ (Results 1 – 5 of 5) sorted by relevance
55 cloudTaskInfos_[taskId].mode = mode; in InitCloudSyncer()56 cloudTaskInfos_[taskId].taskId = taskId; in InitCloudSyncer()78 cloudTaskInfos_[currentContext_.currentTaskId].table = tables; in SetCurrentCloudTaskInfos()84 return cloudTaskInfos_[currentContext_.currentTaskId]; in GetCurrentCloudTaskInfos()107 this->cloudTaskInfos_[taskId].timeout = timeout; in SetTimeOut()113 this->cloudTaskInfos_[this->lastTaskId_].callback = [this]( in InitCloudSyncerForSync()131 return cloudTaskInfos_[taskId].callback; in getCallback()232 auto info = cloudTaskInfos_[currentContext_.currentTaskId]; in CallNotify()281 cloudTaskInfos_[currentContext_.currentTaskId].pause = true; in SetCurrentTaskPause()295 cloudTaskInfos_[taskId].queryList = queryList; in SetQuerySyncObject()[all …]
89 CloudTaskInfo taskInfo = cloudTaskInfos_[currentContext_.currentTaskId]; in Notify()107 cloudTaskInfos_[taskId] = taskInfo; in SetCurrentTaskInfo()126 cloudTaskInfos_[currentContext_.currentTaskId].pause = true; in PauseCurrentTask()
767 cloudTaskInfos_[taskId].storeId.c_str(), cloudTaskInfos_[taskId].taskId); in TryToAddSyncTask()827 processNotifier->Init(cloudTaskInfos_[beMergeTask].table, cloudTaskInfos_[beMergeTask].devices, in TryMergeTask()833 cloudTaskInfos_.erase(beMergeTask); in TryMergeTask()885 cloudTaskInfos_[source].table = cloudTaskInfos_[target].table; in SwapTwoTaskAndCopyTable()886 cloudTaskInfos_[source].queryList = cloudTaskInfos_[target].queryList; in SwapTwoTaskAndCopyTable()888 users.insert(cloudTaskInfos_[source].users.begin(), cloudTaskInfos_[source].users.end()); in SwapTwoTaskAndCopyTable()889 users.insert(cloudTaskInfos_[target].users.begin(), cloudTaskInfos_[target].users.end()); in SwapTwoTaskAndCopyTable()897 …return !std::any_of(cloudTaskInfos_[taskId].queryList.begin(), cloudTaskInfos_[taskId].queryList.e… in IsQueryListEmpty()1048 if (cloudTaskInfos_.find(currentContext_.currentTaskId) == cloudTaskInfos_.end()) { in IsLockInDownload()1185 if (iter == cloudTaskInfos_.end()) { in GetCloudTaskStatus()[all …]
919 if (cloudTaskInfos_.find(taskId) == cloudTaskInfos_.end()) { in PreCheck()1180 if (cloudTaskInfos_.find(taskId) == cloudTaskInfos_.end()) { in PreCheckUpload()1459 if (cloudTaskInfos_.find(taskId) == cloudTaskInfos_.end()) { in CheckTaskIdValid()1499 if (closed_ || cloudTaskInfos_.find(taskId) == cloudTaskInfos_.end()) { in PrepareSync()1508 cloudTaskInfos_[taskId].resume = cloudTaskInfos_[taskId].pause; in PrepareSync()1519 … currentContext_.notifier->Init(cloudTaskInfos_[taskId].table, cloudTaskInfos_[taskId].devices, in PrepareSync()1640 if (cloudTaskInfos_.find(taskId) == cloudTaskInfos_.end()) { in SetTaskFailed()1819 if (cloudTaskInfos_.find(currentContext_.currentTaskId) == cloudTaskInfos_.end()) { in MarkCurrentTaskPausedIfNeed()1903 if (cloudTaskInfos_.find(taskId) == cloudTaskInfos_.end()) { // should not happen in ClearContextAndNotify()1909 cloudTaskInfos_.erase(taskId); in ClearContextAndNotify()[all …]
442 std::map<TaskId, CloudTaskInfo> cloudTaskInfos_; variable