Home
last modified time | relevance | path

Searched refs:syncAgents_ (Results 1 - 4 of 4) sorted by relevance

/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()
234 auto [success, agent] = syncAgents_.Find(tokenId); in OnAsyncComplete()
340 syncAgents_.Compute(tokenId, [&appId, notifier](const auto &, SyncAgent &value) { in RegServiceNotifier()
352 syncAgents_.ComputeIfPresent(IPCSkeleton::GetCallingTokenID(), [&appId](const auto &key, SyncAgent &value) { in UnregServiceNotifier()
368 syncAgents_.Compute(tokenId, [&appId, &notifier](const auto &, SyncAgent &value) { in SubscribeSwitchData()
407 syncAgents_.ComputeIfPresent(tokenId, [&destroyed](auto &key, SyncAgent &value) { in UnsubscribeSwitchData()
451 syncAgents_.Compute(tokenId, [&appId, &storeId, &syncParam](auto &key, SyncAgent &value) { in SetSyncParam()
465 syncAgents_.ComputeIfPresent(tokenId, [&appId, &storeId, &syncParam](auto &key, SyncAgent &value) { in GetSyncParam()
549 syncAgents_.Compute(tokenId, [&appId, &storeId, &observer, &isCreate](auto &key, SyncAgent &agent) { in Subscribe()
571 syncAgents_ in Unsubscribe()
[all...]
H A Dkvdb_service_impl.h154 ConcurrentMap<uint32_t, SyncAgent> syncAgents_; member in OHOS::DistributedKv::final
/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()
252 syncAgents_.Compute(tokenId, [bundleName = param.bundleName_, notifierProxy, pid](auto, SyncAgents &agents) { in InitNotifier()
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()
577 syncAgents_.Compute(tokenId, [pid, &param, &isCreate](auto &key, SyncAgents &agents) {
606 syncAgents_.ComputeIfPresent(tokenId, [pid, &destroyed](auto, SyncAgents &agents) {
631 syncAgents_.Compute(tokenId, [pid, &param, &storeName](auto, SyncAgents &agents) {
651 syncAgents_.ComputeIfPresent(tokenId, [pid, &storeName](auto, SyncAgents &agents) {
H A Drdb_service_impl.h212 ConcurrentMap<uint32_t, SyncAgents> syncAgents_; member in OHOS::DistributedRdb::RdbServiceImpl

Completed in 5 milliseconds