Searched refs:delayNotifier_ (Results 1 – 4 of 4) sorted by relevance
184 PauseDelayNotify::PauseDelayNotify(std::shared_ptr<DelayNotify> delayNotifier) : delayNotifier_(del… in PauseDelayNotify()186 if (delayNotifier_ != nullptr) { in PauseDelayNotify()187 delayNotifier_->Pause(); in PauseDelayNotify()188 delayNotifier_->SetAutoSyncInterval(AUTO_SYNC_MAX_INTERVAL); in PauseDelayNotify()194 if (delayNotifier_ != nullptr) { in ~PauseDelayNotify()195 delayNotifier_->Resume(); in ~PauseDelayNotify()
283 if (delayNotifier_ != nullptr) { in NotifyDataChange()284 delayNotifier_->UpdateNotify(rdbChangedData, true); in NotifyDataChange()717 if (delayNotifier_ != nullptr) { in InitDelayNotifier()720 delayNotifier_ = std::make_shared<DelayNotify>(); in InitDelayNotifier()721 if (delayNotifier_ == nullptr) { in InitDelayNotifier()725 delayNotifier_->SetExecutorPool(TaskExecutor::GetInstance().GetExecutor()); in InitDelayNotifier()726 delayNotifier_->SetTask([param = syncerParam_] in InitDelayNotifier()750 auto callBack = [delayNotifier = delayNotifier_](const std::set<std::string> &tables) { in RegisterDataChangeCallback()1018 PauseDelayNotify pauseDelayNotify(delayNotifier_); in BatchInsert()
66 std::shared_ptr<DelayNotify> delayNotifier_; variable
243 std::shared_ptr<DelayNotify> delayNotifier_ = nullptr; variable