| /foundation/ability/ability_runtime/services/dataobsmgr/src/ |
| H A D | dataobs_mgr_client.cpp | 84 observers_.Compute(dataObserver, [&uri](const auto &key, auto &value) { in RegisterObserver()
109 observers_.Compute(dataObserver, [&uri](const auto &key, auto &value) { in UnregisterObserver()
180 observerExts_.Compute(dataObserver, [&uri, isDescendants](const auto &key, auto &value) { in RegisterObserverExt()
197 observerExts_.Compute(dataObserver, [&uri](const auto &key, auto &value) { in UnregisterObserverExt()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/communication/ |
| H A D | connect_manager.cpp | 71 sessionCloseListener_.Compute(name, [&success, &listener](const auto &key, auto &value) { in RegisterSessionCloseListener()
99 sessionOpenListener_.Compute(name, [&success, &listener](const auto &key, auto &value) { in RegisterSessionOpenListener()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | user_delegate.cpp | 55 deviceUser_.Compute(deviceId, [&users](const auto &key, auto &value) { in GetLocalUsers()
83 deviceUser_.Compute(deviceId, [&userStatus](const auto &key, auto &users) { in GetUsers()
110 deviceUser_.Compute(deviceId, [&userStatus](const auto &key, std::map<int, bool> &users) { in UpdateUsers()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/common/src/ |
| H A D | call_reporter.cpp | 28 callCounts.Compute(funcName, [&overCount, &firstCallTime](auto &key, CallInfo &callInfo) { in Count()
|
| /foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | store_factory.cpp | 43 stores_.Compute(appId, [&](auto &, auto &stores) { in GetOrOpenStore()
113 dbManagers_.Compute(path, [&dbManager, &appId](const auto &path, std::shared_ptr<DBManager> &manager) { in GetDBManager()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
| H A D | data_share_silent_config.cpp | 63 enableSilentUris_.Compute(callerTokenId, [&enable, &uri](const uint32_t &key, in EnableSilentProxy()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/dump/ |
| H A D | dump_manager.cpp | 51 handlers_.Compute(infoName, [ptr, &handler](const auto &key, auto &value) { in AddHandler()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
| H A D | store_cache.cpp | 45 stores_.Compute(key, [&store, intention](const auto &key, std::shared_ptr<Store> &storePtr) -> bool {
in GetStore()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | auto_sync_timer_mock.cpp | 52 stores_.Compute(appId, [&storeIds](const auto &key, std::vector<StoreId> &value) { in AddSyncStores()
|
| H A D | auto_sync_timer.cpp | 54 stores_.Compute(appId, [&storeIds](const auto &key, std::vector<StoreId> &value) { in AddSyncStores()
|
| H A D | store_factory.cpp | 65 stores_.Compute(appId, [&](auto &, auto &stores) { in GetOrOpenStore()
156 dbManagers_.Compute(path, [&dbManager, &appId](const auto &path, std::shared_ptr<DBManager> &manager) { in GetDBManager()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/eventcenter/ |
| H A D | event_center.cpp | 29 return observers_.Compute(evtId, [&observer](const auto &id, auto &list) -> bool { in Subscribe()
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/eventcenter/ |
| H A D | event_center.cpp | 28 return observers_.Compute(evtId, [&observer](const auto &id, auto &list) -> bool { in Subscribe()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | kvdb_notifier_client.cpp | 71 remotes_.Compute(clientUuid, [isChange = changed, type](const auto &key, auto &value) -> bool { in OnRemoteChange()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/ |
| H A D | published_data_subscriber_manager.cpp | 217 lastChangeNodeMap_.Compute(key, [](const Key &, PublishedDataChangeNode &value) {
230 lastChangeNodeMap_.Compute(key, [&data, &changeNode](const Key &, PublishedDataChangeNode &value) {
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/ |
| H A D | auto_cache.cpp | 72 stores_.Compute( in GetStore()
242 disables_.Compute(tokenId, [&storeId](auto key, std::set<std::string> &stores) { in Disable()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/ |
| H A D | db_delegate.cpp | 33 stores_.Compute(metaData.tokenId,
in Create()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/permission/src/ |
| H A D | permit_delegate.cpp | 92 appId2BundleNameMap_.Compute(param.appId, [&data, ¶m](const auto &key, std::string &value) { in VerifyPermission()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_manager.cpp | 362 callbacks_.Compute(tokenId, ([pid, &proxy, &prefix](const uint32_t key, CallbackInfo &value) {
in RegisterRemoteCallback()
378 callbacks_.Compute(tokenId, ([pid, &sessionId, &bundleName](const uint32_t key, CallbackInfo &value) {
in UnregisterRemoteCallback()
465 restoreStatus_.Compute(objectKey, [this, &data, saveInfo] (const auto &key, auto &value) {
in ComputeStatus()
541 restoreStatus_.Compute(objectKey, [this, &bundleName] (const auto &key, auto &value) {
in NotifyAssetsReady()
1169 bindSnapshots_.Compute(storeKey, [this, &asset, snapshots] (const auto &key, auto &value) {
in BindAsset()
1187 snapshots_.Compute(snapshotKey, [this, &asset, &bindInfo, &storeInfo] (const auto &key, auto &value) {
in BindAsset()
|
| /foundation/ability/ability_runtime/services/dataobsmgr/include/ |
| H A D | concurrent_map.h | 211 bool Compute(const key_type &key, const std::function<bool(const key_type &, mapped_type &)> &action) in Compute() function in OHOS::ConcurrentMap
|
| /foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | concurrent_map.h | 224 bool Compute(const key_type &key, const std::function<bool(const key_type &, mapped_type &)> &action) in Compute() function in OHOS::ConcurrentMap
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | published_data_subscriber_manager.cpp | 38 publishedDataCache_.Compute(
in Add()
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/include/common/ |
| H A D | concurrent_map.h | 187 bool Compute(const key_type &key, const std::function<bool(const key_type &, mapped_type &)> &action) in Compute() function in OHOS::ConcurrentMap
|
| /foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/ |
| H A D | concurrent_map.h | 211 bool Compute(const key_type &key, const std::function<bool(const key_type &, mapped_type &)> &action) in Compute() function in OHOS::ConcurrentMap
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 239 actives_.Compute(syncId, [this, &ref, &syncInfo](const uint64_t &key, TaskId &taskId) mutable { in DoCloudSync()
483 actives_.Compute(syncId, [this, times, interval, &ref, &info](const uint64_t &key, TaskId &value) mutable {
712 lastSyncInfos_.Compute(queryKey, [id = syncId, startTime](auto &, std::map<SyncId, CloudSyncInfo> &val) {
|