Searched refs:ProcessNotifier (Results 1 – 7 of 7) sorted by relevance
21 ProcessNotifier::ProcessNotifier(ICloudSyncer *syncer) in ProcessNotifier() function in DistributedDB::ProcessNotifier27 ProcessNotifier::~ProcessNotifier() in ~ProcessNotifier()32 void ProcessNotifier::Init(const std::vector<std::string> &tableName, in Init()56 void ProcessNotifier::UpdateProcess(const ICloudSyncer::InnerProcessInfo &process) in UpdateProcess()74 void ProcessNotifier::NotifyProcess(const ICloudSyncer::CloudTaskInfo &taskInfo, in NotifyProcess()126 std::vector<std::string> ProcessNotifier::GetDevices() const in GetDevices()131 uint32_t ProcessNotifier::GetUploadBatchIndex(const std::string &tableName) const in GetUploadBatchIndex()141 void ProcessNotifier::ResetUploadBatchIndex(const std::string &tableName) in ResetUploadBatchIndex()183 void ProcessNotifier::SetUser(const std::string &user) in SetUser()188 void ProcessNotifier::SetAllTableFinish() in SetAllTableFinish()[all …]
20 class ProcessNotifier {22 explicit ProcessNotifier(ICloudSyncer *syncer);23 ~ProcessNotifier();
94 std::shared_ptr<ProcessNotifier> notifier;
826 auto processNotifier = std::make_shared<ProcessNotifier>(this); in TryMergeTask()1193 std::shared_ptr<ProcessNotifier> notifier = nullptr; in GetCloudTaskStatus()
151 auto processNotifier = std::make_shared<ProcessNotifier>(this); in StopAllTasks()1516 currentContext_.notifier = std::make_shared<ProcessNotifier>(this); in PrepareSync()1896 std::shared_ptr<ProcessNotifier> notifier = nullptr; in ClearContextAndNotify()
104 currentContext_.notifier = std::make_shared<ProcessNotifier>(this); in SetCurrentTaskInfo()
60 currentContext_.notifier = std::make_shared<ProcessNotifier>(this); in InitCloudSyncer()