Home
last modified time | relevance | path

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

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_service_impl.h113 struct SyncAgent { struct in OHOS::DistributedRdb::RdbServiceImpl
114 SyncAgent() = default;
115 explicit SyncAgent(const std::string &bundleName);
124 using SyncAgents = std::map<int32_t, SyncAgent>;
H A Drdb_service_impl.cpp253 auto [it, success] = agents.try_emplace(pid, SyncAgent(bundleName)); in InitNotifier()
956 void RdbServiceImpl::SyncAgent::SetNotifier(sptr<RdbNotifierProxy> notifier)
964 void RdbServiceImpl::SyncAgent::SetWatcher(std::shared_ptr<RdbWatcher> watcher)
974 RdbServiceImpl::SyncAgent::SyncAgent(const std::string &bundleName) : bundleName_(bundleName)
/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()
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_.ComputeIfPresent(tokenId, [&appId, &storeId, &observer, &destroyed](auto &key, SyncAgent &agent) { in Unsubscribe()
737 syncAgents_.EraseIf([pid, &info](auto &key, SyncAgent in OnAppExit()
[all...]
H A Dkvdb_service_impl.h97 struct SyncAgent { struct in OHOS::DistributedKv::final
154 ConcurrentMap<uint32_t, SyncAgent> syncAgents_;

Completed in 6 milliseconds