Searched refs:subManager_ (Results 1 – 8 of 8) sorted by relevance
65 subManager_ = nullptr; in ~SyncEngine()98 if (subManager_ == nullptr) { in Initialize()99 subManager_ = std::make_shared<SubscribeManager>(); in Initialize()143 if (subManager_ != nullptr) { in Close()144 subManager_->ClearAllRemoteQuery(); in Close()830 subManager_->ClearRemoteSubscribeQuery(deviceId); in OfflineHandleByDevice()832 if (!subManager_->IsQueryExistSubscribe(queryId)) { in OfflineHandleByDevice()853 subManager_->ClearLocalSubscribeQuery(deviceId); in OfflineHandleByDevice()884 subManager_->GetAllUnFinishSubQueries(allSyncQueries); in GetAllUnFinishSubQueries()1003 return subManager_->LocalSubscribeLimitCheck(devices, query); in SubscribeLimitCheck()[all …]
150 std::shared_ptr<SubscribeManager> subManager_; variable
32 subManager_(nullptr), in GenericVirtualDevice()97 subManager_ = std::make_shared<SubscribeManager>(); in Initialize()98 static_cast<SingleVerSyncTaskContext *>(context_)->SetSubscribeManager(subManager_); in Initialize()
29 subManager_ = std::make_shared<SubscribeManager>(); in InitSubscribeManager()
59 std::shared_ptr<SubscribeManager> subManager_; variable
39 subManager_ = nullptr; in ~SingleVerSyncTaskContext()480 subManager_ = subManager; in SetSubscribeManager()485 return subManager_; in GetSubscribeManager()
46 context->SetSubscribeManager(subManager_); in CreateSyncTaskContext()
178 std::shared_ptr<SubscribeManager> subManager_; variable