Searched refs:observerHandle (Results 1 – 7 of 7) sorted by relevance
95 auto observerHandle = new (std::nothrow) KvDBObserverHandle(mode); in RegisterObserver() local96 if (observerHandle == nullptr) { in RegisterObserver()111 delete observerHandle; in RegisterObserver()112 observerHandle = nullptr; in RegisterObserver()119 observerHandle->InsertListener(listener); in RegisterObserver()121 observerList_.push_back(observerHandle); in RegisterObserver()123 return observerHandle; in RegisterObserver()128 if (observerHandle == nullptr) { in UnRegisterObserver()137 int errCode = GetEventType(observerHandle->GetObserverMode(), eventTypes); in UnRegisterObserver()166 delete observerHandle; in UnRegisterObserver()[all …]
41 int UnRegisterObserver(const KvDBObserverHandle *observerHandle) override;
224 KvDBObserverHandle *observerHandle = conn_->RegisterObserver( in RegisterObserver() local233 if (errCode != E_OK || observerHandle == nullptr) { in RegisterObserver()238 …_.insert(std::pair<const KvStoreObserver *, const KvDBObserverHandle *>(observer, observerHandle)); in RegisterObserver()261 const KvDBObserverHandle *observerHandle = iter->second; in UnRegisterObserver() local262 int errCode = conn_->UnRegisterObserver(observerHandle); in UnRegisterObserver()
412 KvDBObserverHandle *observerHandle = conn_->RegisterObserver( in RegisterDeviceObserver() local421 if (errCode != E_OK || observerHandle == nullptr) { in RegisterDeviceObserver()426 …_.insert(std::pair<const KvStoreObserver *, const KvDBObserverHandle *>(observer, observerHandle)); in RegisterDeviceObserver()496 const KvDBObserverHandle *observerHandle = iter->second; in UnRegisterDeviceObserver() local497 int errCode = conn_->UnRegisterObserver(observerHandle); in UnRegisterDeviceObserver()
235 autoLaunchItemMap_[identifier][userId].observerHandle = autoLaunchItem.observerHandle; in GetKVConnectionInEnable()258 if (autoLaunchItem.observerHandle != nullptr) { in CloseConnectionStrict()259 errCode = kvConn->UnRegisterObserver(autoLaunchItem.observerHandle); in CloseConnectionStrict()264 autoLaunchItem.observerHandle = nullptr; in CloseConnectionStrict()423 autoLaunchItemMap_[identifier][userId].observerHandle = autoLaunchItem.observerHandle; in DisableKvStoreAutoLaunch()644 … autoLaunchItemMap_[items.first][iter.first].observerHandle = iter.second.observerHandle; in UpdateGlobalMap()686 autoLaunchItemMap_[identifier][userId].observerHandle = autoLaunchItem.observerHandle; in ReceiveUnknownIdentifierCallBackTask()1177 if (autoLaunchItem.observerHandle != nullptr) { in TryCloseKvConnection()1182 autoLaunchItem.observerHandle = nullptr; in TryCloseKvConnection()1267 KvDBObserverHandle *observerHandle = nullptr; in RegisterKvObserver() local[all …]
97 virtual int UnRegisterObserver(const KvDBObserverHandle *observerHandle) = 0;
56 KvDBObserverHandle *observerHandle = nullptr; member