Home
last modified time | relevance | path

Searched refs:PublishedDataSubscriberManager (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/
H A Dpublished_data_subscriber_manager.cpp29 PublishedDataSubscriberManager &PublishedDataSubscriberManager::GetInstance() in GetInstance()
31 static PublishedDataSubscriberManager manager; in GetInstance()
35 int PublishedDataSubscriberManager::Add( in Add()
49 int PublishedDataSubscriberManager::Delete(const PublishedDataKey &key, uint32_t firstCallerTokenId) in Delete()
68 void PublishedDataSubscriberManager::Delete(uint32_t callerTokenId, uint32_t callerPid) in Delete()
84 int PublishedDataSubscriberManager::Disable(const PublishedDataKey &key, uint32_t firstCallerTokenI… in Disable()
100 int PublishedDataSubscriberManager::Enable(const PublishedDataKey &key, uint32_t firstCallerTokenId) in Enable()
115 void PublishedDataSubscriberManager::Emit(const std::vector<PublishedDataKey> &keys, int32_t userId, in Emit()
157 void PublishedDataSubscriberManager::PutInto( in PutInto()
173 void PublishedDataSubscriberManager::Clear() in Clear()
[all …]
H A Dpublished_data_subscriber_manager.h41 class PublishedDataSubscriberManager {
43 static PublishedDataSubscriberManager &GetInstance();
70 PublishedDataSubscriberManager() = default;
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Dpublished_data_subscriber_manager.cpp26 std::vector<OperationResult> PublishedDataSubscriberManager::AddObservers(void *subscriber, in AddObservers()
70 std::vector<OperationResult> PublishedDataSubscriberManager::DelObservers(void *subscriber, in DelObservers()
93 std::vector<OperationResult> PublishedDataSubscriberManager::DelObservers(void *subscriber, in DelObservers()
124 std::vector<OperationResult> PublishedDataSubscriberManager::EnableObservers(void *subscriber, in EnableObservers()
163 std::vector<OperationResult> PublishedDataSubscriberManager::DisableObservers(void *subscriber, in DisableObservers()
213 void PublishedDataSubscriberManager::Emit(PublishedDataChangeNode &changeNode) in Emit()
290 bool PublishedDataSubscriberManager::Init() in Init()
301 void PublishedDataSubscriberManager::Destroy() in Destroy()
312 PublishedDataSubscriberManager &PublishedDataSubscriberManager::GetInstance() in GetInstance()
314 static PublishedDataSubscriberManager manager; in GetInstance()
[all …]
H A Ddata_share_manager_impl.cpp139 PublishedDataSubscriberManager::GetInstance().RecoverObservers(proxy); in DataShareManagerImpl()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/src/
H A Dpublished_data_controller.cpp52 …return PublishedDataSubscriberManager::GetInstance().AddObservers(subscriber, proxy, uris, subscri… in SubscribePublishedData()
64 return PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, proxy); in UnSubscribePublishedData()
66 …return PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, subscri… in UnSubscribePublishedData()
77 …return PublishedDataSubscriberManager::GetInstance().EnableObservers(subscriber, proxy, uris, subs… in EnableSubscribePublishedData()
88 …return PublishedDataSubscriberManager::GetInstance().DisableObservers(subscriber, proxy, uris, sub… in DisableSubscribePublishedData()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/
H A Dpublished_data_subscriber_manager.h76 class PublishedDataSubscriberManager : public CallbacksManager<PublishedObserverMapKey, PublishedDa…
81 static PublishedDataSubscriberManager &GetInstance();
98 PublishedDataSubscriberManager();
/ohos5.0/foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/
H A Dabnormal_branch_test.cpp154 …std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().AddObservers(…
181 …std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().DelObservers(…
184 …results = PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, subs…
211 …std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().EnableObserve…
237 …std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().DisableObserv…
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Ddata_share_subscriber_managers_test.cpp207 std::vector<PublishedDataSubscriberManager::ObserverNode> val;
209 PublishedDataSubscriberManager::GetInstance().PutInto(callbacks, val, key, observer);
211 PublishedDataSubscriberManager::GetInstance().SetObserversNotifiedOnEnabled(publishedKeys);
214 auto result = PublishedDataSubscriberManager::GetInstance().IsNotifyOnEnabled(keys, tokenId);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_service_impl.cpp381 PublishedDataSubscriberManager::GetInstance().Emit(publishedData, userId, callerBundleName); in Publish()
382 PublishedDataSubscriberManager::GetInstance().SetObserversNotifiedOnEnabled(publishedData); in Publish()
474 return PublishedDataSubscriberManager::GetInstance().Add( in SubscribePublishedData()
491 …PublishedDataSubscriberManager::GetInstance().Emit(publishedKeys, userId, callerBundleName, observ… in SubscribePublishedData()
511 auto result = PublishedDataSubscriberManager::GetInstance().Delete( in UnsubscribePublishedData()
543 return PublishedDataSubscriberManager::GetInstance().Enable( in EnablePubSubs()
555 …if (PublishedDataSubscriberManager::GetInstance().IsNotifyOnEnabled(pKey, context->callerTokenId))… in EnablePubSubs()
562 PublishedDataSubscriberManager::GetInstance().Emit(publishedKeys, userId, callerBundleName); in EnablePubSubs()
582 auto result = PublishedDataSubscriberManager::GetInstance().Disable( in DisablePubSubs()
780 PublishedDataSubscriberManager::GetInstance().Delete(tokenId, pid); in OnAppExit()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/data/
H A Dpublished_data.cpp210 if (data.timestamp < lastValidTime && PublishedDataSubscriberManager::GetInstance() in ClearAging()