Searched refs:dbMgr_ (Results 1 – 5 of 5) sorted by relevance
102 dbMgr_ = std::make_shared<ExportDbManager>(dbStoreDir); in Init()145 …if (dbMgr_->IsUnrecordedModule(config->moduleName)) { // first time to export event for current mo… in RegistSettingObserver()150 dbMgr_->HandleExportSwitchChanged(config->moduleName, 0); in RegistSettingObserver()165 auto expireTask = std::make_shared<EventExpireTask>(config, dbMgr_); in InitAndRunTask()166 auto exportTask = std::make_shared<EventExportTask>(config, dbMgr_); in InitAndRunTask()177 int64_t enabledSeq = dbMgr_->GetExportEnabledSeq(moduleName); in HandleExportSwitchOn()184 dbMgr_->HandleExportSwitchChanged(moduleName, curEventSeq); in HandleExportSwitchOn()189 dbMgr_->HandleExportSwitchChanged(moduleName, INVALID_SEQ_VAL); in HandleExportSwitchOff()
65 if (config_ == nullptr || dbMgr_ == nullptr) { in OnTaskRun()69 if (IsExportSwitchOff(config_, dbMgr_)) { in OnTaskRun()90 dbMgr_->HandleExportTaskFinished(config_->moduleName, endSeq); in OnTaskRun()129 readReq->beginSeq = dbMgr_->GetExportBeginSeq(config_->moduleName); in InitReadRequest()
30 : config_(config), dbMgr_(dbMgr) {} in ExportBaseTask()43 std::shared_ptr<ExportDbManager> dbMgr_ = nullptr; variable
52 std::shared_ptr<ExportDbManager> dbMgr_ = nullptr; variable
41 if (config_ == nullptr || dbMgr_ == nullptr) { in OnTaskRun()