Home
last modified time | relevance | path

Searched refs:lastChangeNodeMap_ (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/
H A Dnapi_subscriber_manager.cpp84 lastChangeNodeMap_.erase(result); in DelObservers()
98 lastChangeNodeMap_[key] = changeNode; in Emit()
110 auto it = lastChangeNodeMap_.find(key); in Emit()
111 if (it != lastChangeNodeMap_.end()) { in Emit()
179 lastChangeNodeMap_.erase(result); in DelObservers()
194 lastChangeNodeMap_[key].datas_.clear(); in Emit()
204 lastChangeNodeMap_[key].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData()); in Emit()
205 lastChangeNodeMap_[key].ownerBundleName_ = changeNode.ownerBundleName_; in Emit()
220 auto it = lastChangeNodeMap_.find(key); in Emit()
221 if (it == lastChangeNodeMap_.end()) { in Emit()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Drdb_subscriber_manager.cpp101 lastChangeNodeMap_.erase(result); in DelObservers()
123 lastChangeNodeMap_.erase(key); in DelObservers()
221 lastChangeNodeMap_[key] = changeNode; in Emit()
236 auto it = lastChangeNodeMap_.find(key); in Emit()
237 if (it != lastChangeNodeMap_.end()) { in Emit()
246 auto it = lastChangeNodeMap_.find(key); in EmitOnEnable()
247 if (it == lastChangeNodeMap_.end()) { in EmitOnEnable()
H A Dpublished_data_subscriber_manager.cpp82 lastChangeNodeMap_.Erase(key); in DelObservers()
112 lastChangeNodeMap_.Erase(result); in DelObservers()
217 lastChangeNodeMap_.Compute(key, [](const Key &, PublishedDataChangeNode &value) { in Emit()
230 …lastChangeNodeMap_.Compute(key, [&data, &changeNode](const Key &, PublishedDataChangeNode &value) { in Emit()
250 … lastChangeNodeMap_.ComputeIfPresent(key, [&node](const Key &, PublishedDataChangeNode &value) { in Emit()
266 … lastChangeNodeMap_.ComputeIfPresent(key, [obsVector = obsVector, &results, &num](const Key &, in EmitOnEnable()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/include/
H A Dnapi_subscriber_manager.h72 std::map<Key, RdbChangeNode> lastChangeNodeMap_; variable
117 std::map<Key, PublishedDataChangeNode> lastChangeNodeMap_; variable
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/
H A Dpublished_data_subscriber_manager.h102 ConcurrentMap<Key, PublishedDataChangeNode> lastChangeNodeMap_; variable
H A Drdb_subscriber_manager.h102 std::map<Key, RdbChangeNode> lastChangeNodeMap_; variable