| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | rdb_subscriber_manager.cpp | 15 #define LOG_TAG "RdbSubscriberManager"
108 RdbSubscriberManager &RdbSubscriberManager::GetInstance()
in GetInstance()
110 static RdbSubscriberManager manager;
in GetInstance()
114 int RdbSubscriberManager::Add(const Key &key, const sptr<IDataProxyRdbObserver> observer,
in Add()
143 int RdbSubscriberManager::Delete(const Key &key, uint32_t firstCallerTokenId)
in Delete()
166 void RdbSubscriberManager::Delete(uint32_t callerTokenId)
in Delete()
186 int RdbSubscriberManager::Disable(const Key &key, uint32_t firstCallerTokenId)
in Disable()
202 int RdbSubscriberManager::Enable(const Key &key, std::shared_ptr<Context> context)
in Enable()
224 void RdbSubscriberManager
[all...] |
| H A D | rdb_subscriber_manager.h | 52 friend class RdbSubscriberManager;
55 class RdbSubscriberManager {
class
57 static RdbSubscriberManager &GetInstance();
82 RdbSubscriberManager() = default;
|
| /foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/ |
| H A D | rdb_subscriber_manager.cpp | 26 RdbSubscriberManager &RdbSubscriberManager::GetInstance() in GetInstance()
28 static RdbSubscriberManager manager; in GetInstance()
32 RdbSubscriberManager::RdbSubscriberManager() in RdbSubscriberManager() function in OHOS::DataShare::RdbSubscriberManager
37 std::vector<OperationResult> RdbSubscriberManager::AddObservers(void *subscriber, in AddObservers()
81 std::vector<OperationResult> RdbSubscriberManager::DelObservers(void *subscriber, in DelObservers()
112 std::vector<OperationResult> RdbSubscriberManager::DelObservers(void *subscriber, in DelObservers()
131 std::vector<OperationResult> RdbSubscriberManager::EnableObservers(void *subscriber,
170 std::vector<OperationResult> RdbSubscriberManager
[all...] |
| H A D | data_share_manager_impl.cpp | 134 RdbSubscriberManager::GetInstance().RecoverObservers(proxy); in DataShareManagerImpl()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | data_share_subscriber_managers_test.cpp | 145 RdbSubscriberManager::GetInstance().Delete(tokenId);
146 auto result = RdbSubscriberManager::GetInstance().Delete(key, tokenId);
164 auto result = RdbSubscriberManager::GetInstance().Disable(key, tokenId);
167 result = RdbSubscriberManager::GetInstance().Enable(key, context);
180 RdbSubscriberManager::GetInstance().Emit(DATA_SHARE_URI_TEST, context);
in HWTEST_F()
181 RdbSubscriberManager::GetInstance().Emit(DATA_SHARE_URI_TEST, TEST_SUB_ID, context);
in HWTEST_F()
186 RdbSubscriberManager::GetInstance().EmitByKey(key, USER_TEST, "rdbPath", 1);
in HWTEST_F()
188 auto result = RdbSubscriberManager::GetInstance().GetEnableObserverCount(keys);
in HWTEST_F()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/src/ |
| H A D | persistent_data_controller.cpp | 52 return RdbSubscriberManager::GetInstance().AddObservers(subscriber, proxy, uris, templateId, callback); in SubscribeRdbData()
65 return RdbSubscriberManager::GetInstance().DelObservers(subscriber, proxy); in UnSubscribeRdbData()
67 return RdbSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, templateId); in UnSubscribeRdbData()
78 return RdbSubscriberManager::GetInstance().EnableObservers(subscriber, proxy, uris, templateId); in EnableSubscribeRdbData()
89 return RdbSubscriberManager::GetInstance().DisableObservers(subscriber, proxy, uris, templateId); in DisableSubscribeRdbData()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/ |
| H A D | rdb_subscriber_manager.h | 76 class RdbSubscriberManager : public CallbacksManager<RdbObserverMapKey, RdbObserver> { class
81 static RdbSubscriberManager &GetInstance();
98 RdbSubscriberManager();
|
| /foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/ |
| H A D | abnormal_branch_test.cpp | 168 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().AddObservers(subscriber, proxy, uris, in HWTEST_F()
196 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, in HWTEST_F()
199 results = RdbSubscriberManager::GetInstance().DelObservers(subscriber, proxy); in HWTEST_F()
224 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().EnableObservers(subscriber, proxy, in HWTEST_F()
250 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().DisableObservers(subscriber, proxy, in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/ |
| H A D | scheduler_manager.cpp | 49 std::vector<Key> keys = RdbSubscriberManager::GetInstance().GetKeysByUri(uri); in Execute()
139 RdbSubscriberManager::GetInstance().EmitByKey(key, userId, dbPath, version); in SetTimer()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
| H A D | data_share_service_impl.cpp | 112 RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.currentUserId, metaData); in InsertEx()
153 RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.currentUserId, metaData); in UpdateEx()
173 RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.currentUserId, metaData); in DeleteEx()
218 RdbSubscriberManager::GetInstance().Emit(context->uri, tpltId.subscriberId_, context); in AddTemplate()
312 return RdbSubscriberManager::GetInstance().Add(
326 return RdbSubscriberManager::GetInstance().Delete(
340 return RdbSubscriberManager::GetInstance().Enable(
354 return RdbSubscriberManager::GetInstance().Disable(
684 RdbSubscriberManager::GetInstance().Delete(tokenId);
741 RdbSubscriberManager
[all...] |