Searched refs:rdbCache_ (Results 1 – 2 of 2) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | rdb_subscriber_manager.cpp | 118 rdbCache_.Compute(key, [&observer, &context, executorPool, this](const auto &key, auto &value) { in Add()
147 rdbCache_.ComputeIfPresent(key, [&firstCallerTokenId, this](const auto &key, in Delete()
169 …rdbCache_.EraseIf([&callerTokenId, &callerPid, this](const auto &key, std::vector<ObserverNode> &v… in Delete()
190 rdbCache_.ComputeIfPresent(key, [&firstCallerTokenId, this](const auto &key, in Disable()
234 rdbCache_.ForEach([&uri, &context, this](const Key &key, std::vector<ObserverNode> &val) { in Emit()
253 …rdbCache_.ForEach([&uri, &userId, &metaData, &hasObserver, this](const Key &key, std::vector<Obser… in Emit()
281 rdbCache_.ForEach([&uri, &results](const Key &key, std::vector<ObserverNode> &val) { in GetKeysByUri()
296 rdbCache_.ComputeIfPresent(key, [&rdbPath, &version, &userId, this](const Key &key, auto &val) { in EmitByKey()
305 auto pair = rdbCache_.Find(key); in GetEnableObserverCount()
360 rdbCache_.Clear(); in Clear()
[all …]
|
| H A D | rdb_subscriber_manager.h | 85 ConcurrentMap<Key, std::vector<ObserverNode>> rdbCache_; variable
|