Searched refs:publishedDataCache_ (Results 1 – 2 of 2) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | published_data_subscriber_manager.cpp | 38 publishedDataCache_.Compute( in Add()
52 publishedDataCache_.ComputeIfPresent(key, [&firstCallerTokenId](const auto &key, in Delete()
70 …publishedDataCache_.EraseIf([&callerTokenId, &callerPid](const auto &key, std::vector<ObserverNode… in Delete()
87 publishedDataCache_.ComputeIfPresent(key, [&firstCallerTokenId](const auto &key, in Disable()
103 publishedDataCache_.ComputeIfPresent(key, [&firstCallerTokenId](const auto &key, in Enable()
122 …publishedDataCache_.ForEach([&keys, &status, &observer, &publishedResult, &callbacks, &userId, thi… in Emit()
175 publishedDataCache_.Clear(); in Clear()
181 …publishedDataCache_.ComputeIfPresent(key, [&count](const auto &key, std::vector<ObserverNode> &val… in GetCount()
190 auto pair = publishedDataCache_.Find(key); in IsNotifyOnEnabled()
205 … publishedDataCache_.ComputeIfPresent(pkey, [](const auto &key, std::vector<ObserverNode> &value) { in SetObserversNotifiedOnEnabled()
|
| H A D | published_data_subscriber_manager.h | 73 ConcurrentMap<PublishedDataKey, std::vector<ObserverNode>> publishedDataCache_; variable
|