Home
last modified time | relevance | path

Searched refs:ComputeIfPresent (Results 1 - 25 of 31) sorted by relevance

12

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/
H A Dpublished_data_subscriber_manager.cpp51 publishedDataCache_.ComputeIfPresent(key, [&firstCallerTokenId](const auto &key, in Delete()
86 publishedDataCache_.ComputeIfPresent(key, [&firstCallerTokenId](const auto &key, in Disable()
102 publishedDataCache_.ComputeIfPresent(key, [&firstCallerTokenId](const auto &key, in Enable()
180 publishedDataCache_.ComputeIfPresent(key, [&count](const auto &key, std::vector<ObserverNode> &value) { in GetCount()
204 publishedDataCache_.ComputeIfPresent(pkey, [](const auto &key, std::vector<ObserverNode> &value) { in SetObserversNotifiedOnEnabled()
H A Drdb_subscriber_manager.cpp146 rdbCache_.ComputeIfPresent(key, [&firstCallerTokenId, this](const auto &key, in Delete()
189 rdbCache_.ComputeIfPresent(key, [&firstCallerTokenId, this](const auto &key, in Disable()
204 auto result = rdbCache_.ComputeIfPresent(key, [&context, this](const auto &key, std::vector<ObserverNode> &value) { in Enable()
295 rdbCache_.ComputeIfPresent(key, [&rdbPath, &version, &userId, this](const Key &key, auto &val) { in EmitByKey()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/
H A Dauto_cache.cpp106 stores_.ComputeIfPresent( in GetStoresIfPresent()
151 stores_.ComputeIfPresent(tokenId, in CloseStore()
168 stores_.ComputeIfPresent(tokenId, [this, &storeIds](auto &key, auto &delegates) { in CloseStore()
203 stores_.ComputeIfPresent(tokenId, [&storeId, &watchers](auto &key, auto &stores) { in SetObserver()
234 disables_.ComputeIfPresent(tokenId, [&storeId](auto key, std::set<std::string> &stores) { in Enable()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Dapp_connect_manager.cpp55 blockCache_.ComputeIfPresent(bundleName, [&bundleName](const std::string &key, BlockData<bool> *value) { in Notify()
H A Dextension_ability_manager.cpp67 connectCallbackCache_.ComputeIfPresent(bundleName, in Disconnect()
H A Drdb_delegate.cpp245 resultSetCallingPids.ComputeIfPresent(callingPid, [](const uint32_t &, int32_t &value) { in Query()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_silent_config.cpp75 enableSilentUris_.ComputeIfPresent(callerTokenId, [&isEnable, &status, &uri](const uint32_t &key, in CheckExistEnableSilentUris()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/dump/
H A Ddump_manager.cpp76 handlers_.ComputeIfPresent(infoName, [ptr](const auto &key, auto &value) { in RemoveHandler()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_service_proxy.cpp262 observers_.ComputeIfPresent(name, [observer](const auto &key, std::list<ObserverParam> &value) { in UnSubscribe()
430 syncObservers_.ComputeIfPresent(name, [this, &param, &status, observer](const auto &storeName, auto &observers) { in UnregisterAutoSyncCallback()
466 observers_.ComputeIfPresent(name, [&origin, &primaries, info = std::move(changeInfo)]( in OnDataChange()
478 syncCallbacks_.ComputeIfPresent(seqNum, [&result] (const auto& key, const AsyncDetail& callback) { in OnSyncComplete()
490 syncObservers_.ComputeIfPresent(storeName, [&result](const auto &key, const auto &observers) { in OnSyncComplete()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Dkvdb_notifier_client.cpp49 cloudSyncCallbacks_.ComputeIfPresent(seqNum, [&detail](const auto &key, const AsyncDetail &callback) { in SyncCompleted()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_adapter_standard.cpp329 connects_.ComputeIfPresent(deviceId.deviceId, [&mtuSize](auto, auto &connects) { in GetMtuSize()
350 connects_.ComputeIfPresent(deviceId.deviceId, [&interval](auto, auto &connects) { in GetTimeout()
437 auto ret = dataChangeListeners_.ComputeIfPresent(pipeInfo.pipeId, in NotifyDataListeners()
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/
H A Djs_distributedobjectstore.cpp101 return callbacks.ComputeIfPresent(sessionId, execute); in DelCallback()
351 watchResult = g_changeCallBacks.ComputeIfPresent(objectId, [&](const std::string &key, std::list<napi_ref> &lists) { in RestoreWatchers()
365 watchResult = g_statusCallBacks.ComputeIfPresent(objectId, [&](const std::string &key, std::list<napi_ref> &lists) { in RestoreWatchers()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_service_impl.cpp183 syncAgents_.ComputeIfPresent(tokenId, [&appId, &storeId](auto &key, SyncAgent &syncAgent) { in Delete()
352 syncAgents_.ComputeIfPresent(IPCSkeleton::GetCallingTokenID(), [&appId](const auto &key, SyncAgent &value) { in UnregServiceNotifier()
407 syncAgents_.ComputeIfPresent(tokenId, [&destroyed](auto &key, SyncAgent &value) { in UnsubscribeSwitchData()
465 syncAgents_.ComputeIfPresent(tokenId, [&appId, &storeId, &syncParam](auto &key, SyncAgent &value) { in GetSyncParam()
571 syncAgents_.ComputeIfPresent(tokenId, [&appId, &storeId, &observer, &destroyed](auto &key, SyncAgent &agent) { in Unsubscribe()
1137 syncAgents_.ComputeIfPresent(meta.tokenId, [&notifier](auto &key, SyncAgent &agent) { in DoComplete()
1159 syncAgents_.ComputeIfPresent(IPCSkeleton::GetCallingTokenID(), [&delay, &storeId](auto &, SyncAgent &agent) { in GetSyncDelayTime()
1330 syncAgents_.ComputeIfPresent(tokenId, [&storeId, &watchers](auto &, SyncAgent &agent) { in GetWatchers()
H A Duser_delegate.cpp135 deviceUser_.ComputeIfPresent(userMetaData.deviceId, [&userMetaData](const auto &, std::map<int, bool> &users) { in InitLocalUserMeta()
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Dpublished_data_subscriber_manager.cpp250 lastChangeNodeMap_.ComputeIfPresent(key, [&node](const Key &, PublishedDataChangeNode &value) {
266 lastChangeNodeMap_.ComputeIfPresent(key, [obsVector = obsVector, &results, &num](const Key &,
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/
H A Dstore_factory.cpp90 stores_.ComputeIfPresent(appId, [&storeId, &status, isForce](auto &, auto &values) { in Close()
/foundation/distributeddatamgr/pasteboard/services/core/src/
H A Dpasteboard_service.cpp359 clips_.ComputeIfPresent(appInfo.userId, [dataId, recordId, value](auto, auto &data) { in GetRecordValueByType()
838 clips_.ComputeIfPresent(appInfo.userId, [&data, &isNotify, &isDelayRecordPadding](auto &key, auto &value) { in GetLocalData()
857 delayGetters_.ComputeIfPresent(appInfo.userId, [this, &data](auto, auto &delayGetter) { in GetDelayPasteData()
1004 p2pMap_.ComputeIfPresent(deviceId, [pasteId, deviceId, this](const auto &key, auto &value) { in PasteComplete()
1005 value.ComputeIfPresent(pasteId, [deviceId](const auto &key, auto &value) { in PasteComplete()
1450 clips_.ComputeIfPresent(appInfo.userId, [this](auto, auto &clip) { in RemovePasteData()
1454 delayGetters_.ComputeIfPresent(appInfo.userId, [](auto, auto &delayGetter) { in RemovePasteData()
1461 entryGetters_.ComputeIfPresent(appInfo.userId, [](auto, auto &entryGetter) { in RemovePasteData()
1674 globalShareOptions_.ComputeIfPresent(tokenId, [&count](const uint32_t &key, ShareOption &value) { in RemoveGlobalShareOption()
1698 globalShareOptions_.ComputeIfPresent(tokenI in GetGlobalShareOption()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_service_impl.cpp191 syncAgents_.ComputeIfPresent(tokenId, [pid, &destroyed](auto &key, SyncAgents &agents) { in OnAppExit()
327 syncAgents_.ComputeIfPresent(tokenId, [&notifier, pid](auto, SyncAgents &syncAgents) { in OnAsyncComplete()
357 syncAgents_.ComputeIfPresent(tokenId, [&watchers](auto, SyncAgents &syncAgents) { in GetWatchers()
371 syncAgents_.ComputeIfPresent(tokenId, [&storeName, &notifiers](auto, SyncAgents &syncAgents) { in GetCallbacks()
606 syncAgents_.ComputeIfPresent(tokenId, [pid, &destroyed](auto, SyncAgents &agents) {
651 syncAgents_.ComputeIfPresent(tokenId, [pid, &storeName](auto, SyncAgents &agents) {
H A Drdb_general_store.cpp543 tasks_->ComputeIfPresent(syncId, [executor = executor_](SyncId syncId, const FinishTask &task) { in Sync()
1108 task->ComputeIfPresent(syncId, [executor = executor_, this](SyncId syncId, FinishTask &task) {
1115 task->ComputeIfPresent(syncId, [&cb, executor = executor_](SyncId syncId, const FinishTask &task) {
1173 task->ComputeIfPresent(syncId, [&cb, &progress, executor](SyncId syncId, FinishTask &finishTask) {
/foundation/ability/ability_runtime/services/dataobsmgr/include/
H A Dconcurrent_map.h232 bool ComputeIfPresent(const key_type &key, const std::function<bool(const key_type &, mapped_type &)> &action) in ComputeIfPresent() function in OHOS::ConcurrentMap
/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dconcurrent_map.h245 bool ComputeIfPresent(const key_type &key, const std::function<bool(const key_type &, mapped_type &)> &action) in ComputeIfPresent() function in OHOS::ConcurrentMap
/foundation/distributeddatamgr/pasteboard/framework/framework/include/common/
H A Dconcurrent_map.h208 bool ComputeIfPresent(const key_type &key, const std::function<bool(const key_type &, mapped_type &)> &action) in ComputeIfPresent() function in OHOS::ConcurrentMap
/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/
H A Dconcurrent_map.h232 bool ComputeIfPresent(const key_type &key, const std::function<bool(const key_type &, mapped_type &)> &action) in ComputeIfPresent() function in OHOS::ConcurrentMap
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/
H A Ddatashare_helper.cpp354 return observers_.ComputeIfPresent(observer.get(), [&uri](auto &key, auto &value) { in DeleteObserver()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dstore_factory.cpp132 stores_.ComputeIfPresent(appId, [&storeId, &status, isForce](auto &, auto &values) { in Close()

Completed in 23 milliseconds

12