/foundation/distributeddatamgr/data_share/frameworks/native/common/include/ |
H A D | callbacks_manager.h | 37 std::vector<OperationResult> AddObservers(const std::vector<Key> &keys, void *subscriber, 41 std::vector<OperationResult> &)>); 43 std::vector<OperationResult> DelObservers(const std::vector<Key> &keys, void *subscriber, 44 std::function<void(const std::vector<Key> &, std::vector<OperationResult> &)> processOnLastDel = 47 std::vector<OperationResult> DelObservers(void *subscriber, 48 std::function<void(const std::vector<Key> &, std::vector<OperationResult> &)> processOnLastDel = 51 std::vector<OperationResult> EnableObservers(const std::vector<Key> &keys, void *subscriber, 53 std::function<void(const std::vector<Key> &, std::vector<OperationResult> &)>); 55 std::vector<OperationResult> DisableObservers(const std::vector<Key> &keys, void *subscriber, 56 std::function<void(const std::vector<Key> &, std::vector<OperationResult> [all...] |
H A D | idata_share_service.h | 52 virtual std::vector<OperationResult> Publish(const Data &data, const std::string &bundleName) = 0; 56 virtual std::vector<OperationResult> SubscribeRdbData(const std::vector<std::string> &uris, 59 virtual std::vector<OperationResult> UnSubscribeRdbData(const std::vector<std::string> &uris, 62 virtual std::vector<OperationResult> EnableSubscribeRdbData(const std::vector<std::string> &uris, 65 virtual std::vector<OperationResult> DisableSubscribeRdbData(const std::vector<std::string> &uris, 68 virtual std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, 71 virtual std::vector<OperationResult> UnSubscribePublishedData(const std::vector<std::string> &uris, 74 virtual std::vector<OperationResult> EnableSubscribePublishedData(const std::vector<std::string> &uris, 77 virtual std::vector<OperationResult> DisableSubscribePublishedData(const std::vector<std::string> &uris,
|
H A D | datashare_itypes_utils.h | 35 using OperationResult = DataShare::OperationResult; 123 bool Marshalling(const OperationResult &operationResult, MessageParcel &parcel); 126 bool Unmarshalling(OperationResult &predicateTemplateNode, MessageParcel &parcel);
|
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/src/ |
H A D | published_data_controller.cpp | 23 std::vector<OperationResult> PublishedDataController::Publish(const Data &data, const std::string &bundleName) in Publish() 28 return std::vector<OperationResult>(); in Publish() 43 std::vector<OperationResult> PublishedDataController::SubscribePublishedData(void *subscriber, in SubscribePublishedData() 50 return std::vector<OperationResult>(); in SubscribePublishedData() 55 std::vector<OperationResult> PublishedDataController::UnSubscribePublishedData(void *subscriber, in UnSubscribePublishedData() 61 return std::vector<OperationResult>(); in UnSubscribePublishedData() 69 std::vector<OperationResult> PublishedDataController::EnableSubscribePublishedData(void *subscriber, in EnableSubscribePublishedData() 75 return std::vector<OperationResult>(); in EnableSubscribePublishedData() 80 std::vector<OperationResult> PublishedDataController::DisableSubscribePublishedData(void *subscriber, in DisableSubscribePublishedData() 86 return std::vector<OperationResult>(); in DisableSubscribePublishedData() [all...] |
H A D | persistent_data_controller.cpp | 43 std::vector<OperationResult> PersistentDataController::SubscribeRdbData(void *subscriber, in SubscribeRdbData() 50 return std::vector<OperationResult>(); in SubscribeRdbData() 55 std::vector<OperationResult> PersistentDataController::UnSubscribeRdbData(void *subscriber, in UnSubscribeRdbData() 61 return std::vector<OperationResult>(); in UnSubscribeRdbData() 70 std::vector<OperationResult> PersistentDataController::EnableSubscribeRdbData(void *subscriber, in EnableSubscribeRdbData() 76 return std::vector<OperationResult>(); in EnableSubscribeRdbData() 81 std::vector<OperationResult> PersistentDataController::DisableSubscribeRdbData(void *subscriber, in DisableSubscribeRdbData() 87 return std::vector<OperationResult>(); in DisableSubscribeRdbData()
|
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/include/ |
H A D | published_data_controller.h | 30 std::vector<OperationResult> Publish(const Data &data, const std::string &bundleName); 34 std::vector<OperationResult> SubscribePublishedData(void *subscriber, const std::vector<std::string> &uris, 37 std::vector<OperationResult> UnSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris, 40 std::vector<OperationResult> EnableSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris, 43 std::vector<OperationResult> DisableSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris,
|
H A D | persistent_data_controller.h | 34 std::vector<OperationResult> SubscribeRdbData(void *subscriber, const std::vector<std::string> &uris, 37 std::vector<OperationResult> UnSubscribeRdbData(void *subscriber, const std::vector<std::string> &uris, 40 std::vector<OperationResult> EnableSubscribeRdbData(void *subscriber, const std::vector<std::string> &uris, 43 std::vector<OperationResult> DisableSubscribeRdbData(void *subscriber, const std::vector<std::string> &uris,
|
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/ |
H A D | data_share_service_proxy.h | 43 std::vector<OperationResult> Publish(const Data &data, const std::string &bundleName) override; 47 std::vector<OperationResult> SubscribeRdbData(const std::vector<std::string> &uris, const TemplateId &templateId, 50 std::vector<OperationResult> UnSubscribeRdbData( 53 std::vector<OperationResult> EnableSubscribeRdbData( 56 std::vector<OperationResult> DisableSubscribeRdbData( 59 std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, int64_t subscriberId, 62 std::vector<OperationResult> UnSubscribePublishedData( 65 std::vector<OperationResult> EnableSubscribePublishedData( 68 std::vector<OperationResult> DisableSubscribePublishedData(
|
H A D | published_data_subscriber_manager.h | 83 std::vector<OperationResult> AddObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy, 85 std::vector<OperationResult> DelObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy, 87 std::vector<OperationResult> DelObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy); 88 std::vector<OperationResult> EnableObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy, 90 std::vector<OperationResult> DisableObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy,
|
H A D | rdb_subscriber_manager.h | 83 std::vector<OperationResult> AddObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy, 85 std::vector<OperationResult> DelObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy, 87 std::vector<OperationResult> DelObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy); 88 std::vector<OperationResult> EnableObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy, 90 std::vector<OperationResult> DisableObservers(void *subscriber, std::shared_ptr<DataShareServiceProxy> proxy,
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
H A D | idata_share_service.h | 65 virtual std::vector<OperationResult> Publish(const Data &data, const std::string &bundleNameOfProvider) = 0; 67 virtual std::vector<OperationResult> SubscribeRdbData( 69 virtual std::vector<OperationResult> UnsubscribeRdbData( 71 virtual std::vector<OperationResult> EnableRdbSubs( 73 virtual std::vector<OperationResult> DisableRdbSubs( 75 virtual std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, 77 virtual std::vector<OperationResult> UnsubscribePublishedData(const std::vector<std::string> &uris, 79 virtual std::vector<OperationResult> EnablePubSubs(const std::vector<std::string> &uris, 81 virtual std::vector<OperationResult> DisablePubSubs(const std::vector<std::string> &uris,
|
H A D | data_share_types_util.h | 34 using OperationResult = DataShare::OperationResult; 63 bool Marshalling(const OperationResult &operationResult, MessageParcel &parcel);
|
H A D | data_share_service_impl.h | 56 std::vector<OperationResult> Publish(const Data &data, const std::string &bundleNameOfProvider) override; 58 std::vector<OperationResult> SubscribeRdbData(const std::vector<std::string> &uris, 60 std::vector<OperationResult> UnsubscribeRdbData( 62 std::vector<OperationResult> EnableRdbSubs( 64 std::vector<OperationResult> DisableRdbSubs( 66 std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, 68 std::vector<OperationResult> UnsubscribePublishedData(const std::vector<std::string> &uris, 70 std::vector<OperationResult> EnablePubSubs(const std::vector<std::string> &uris, 72 std::vector<OperationResult> DisablePubSubs(const std::vector<std::string> &uris,
|
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
H A D | datashare_helper_impl.cpp | 337 std::vector<OperationResult> DataShareHelperImpl::Publish(const Data &data, const std::string &bundleName) in Publish() 343 return std::vector<OperationResult>(); in Publish() 359 std::vector<OperationResult> DataShareHelperImpl::SubscribeRdbData(const std::vector<std::string> &uris, in SubscribeRdbData() 369 return std::vector<OperationResult>(); in SubscribeRdbData() 374 __attribute__((no_sanitize("cfi"))) std::vector<OperationResult> DataShareHelperImpl::UnsubscribeRdbData( in UnsubscribeRdbData() 384 return std::vector<OperationResult>(); in UnsubscribeRdbData() 389 std::vector<OperationResult> DataShareHelperImpl::EnableRdbSubs(const std::vector<std::string> &uris, in EnableRdbSubs() 396 return std::vector<OperationResult>(); in EnableRdbSubs() 401 std::vector<OperationResult> DataShareHelperImpl::DisableRdbSubs(const std::vector<std::string> &uris, in DisableRdbSubs() 408 return std::vector<OperationResult>(); in DisableRdbSubs() [all...] |
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/include/ |
H A D | datashare_helper_impl.h | 75 std::vector<OperationResult> Publish(const Data &data, const string &bundleName) override; 79 std::vector<OperationResult> SubscribeRdbData(const std::vector<std::string> &uris, const TemplateId &templateId, 82 std::vector<OperationResult> UnsubscribeRdbData(const std::vector<std::string> &uris, 85 std::vector<OperationResult> EnableRdbSubs(const std::vector<std::string> &uris, 88 std::vector<OperationResult> DisableRdbSubs(const std::vector<std::string> &uris, 91 std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, int64_t subscriberId, 94 std::vector<OperationResult> UnsubscribePublishedData(const std::vector<std::string> &uris, 97 std::vector<OperationResult> EnablePubSubs(const std::vector<std::string> &uris, int64_t subscriberId) override; 99 std::vector<OperationResult> DisablePubSubs(const std::vector<std::string> &uris, int64_t subscriberId) override;
|
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/ |
H A D | napi_subscriber_manager.cpp | 22 std::vector<OperationResult> NapiRdbSubscriberManager::AddObservers(napi_env env, napi_value callback, in AddObservers() 28 return std::vector<OperationResult>(); in AddObservers() 41 const std::shared_ptr<Observer> observer, std::vector<OperationResult> &opResult) { in AddObservers() 67 std::vector<OperationResult> NapiRdbSubscriberManager::DelObservers(napi_env env, napi_value callback, in DelObservers() 73 return std::vector<OperationResult>(); in DelObservers() 81 const std::shared_ptr<Observer> &observer, std::vector<OperationResult> &opResult) { in DelObservers() 117 std::vector<OperationResult> NapiPublishedSubscriberManager::AddObservers(napi_env env, napi_value callback, in AddObservers() 123 return std::vector<OperationResult>(); in AddObservers() 136 const std::shared_ptr<Observer> observer, std::vector<OperationResult> &opResult) { in AddObservers() 162 std::vector<OperationResult> NapiPublishedSubscriberManage [all...] |
/foundation/distributeddatamgr/data_share/frameworks/js/napi/common/include/ |
H A D | napi_callbacks_manager.h | 29 std::vector<OperationResult> AddObservers(const std::vector<Key> &keys, const std::shared_ptr<Observer> observer, 32 std::vector<OperationResult> &)>); 34 std::vector<OperationResult> DelObservers(const std::vector<Key> &keys, 37 std::vector<OperationResult> &)> processOnLastDel = NapiCallbacksManager::DefaultProcess); 45 std::vector<OperationResult> &){}; in DefaultProcess() 62 std::vector<OperationResult> NapiCallbacksManager<Key, Observer>::AddObservers( in AddObservers() 66 std::vector<OperationResult> &)> processOnFirstAdd) in AddObservers() 68 std::vector<OperationResult> result; in AddObservers() 109 std::vector<OperationResult> NapiCallbacksManager<Key, Observer>::DelObservers( in DelObservers() 111 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &, std::vector<OperationResult> in DelObservers() [all...] |
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/ |
H A D | published_data_subscriber_manager.cpp | 26 std::vector<OperationResult> PublishedDataSubscriberManager::AddObservers(void *subscriber, in AddObservers() 32 return std::vector<OperationResult>(); in AddObservers() 44 const std::shared_ptr<Observer> observer, std::vector<OperationResult> &opResult) { in AddObservers() 70 std::vector<OperationResult> PublishedDataSubscriberManager::DelObservers(void *subscriber, in DelObservers() 75 return std::vector<OperationResult>(); in DelObservers() 78 [&proxy, this](const std::vector<Key> &lastDelKeys, std::vector<OperationResult> &opResult) { in DelObservers() 93 std::vector<OperationResult> PublishedDataSubscriberManager::DelObservers(void *subscriber, in DelObservers() 98 return std::vector<OperationResult>(); in DelObservers() 109 [&proxy, &subscriberId, this](const std::vector<Key> &lastDelKeys, std::vector<OperationResult> &opResult) { in DelObservers() 124 std::vector<OperationResult> PublishedDataSubscriberManage [all...] |
H A D | rdb_subscriber_manager.cpp | 37 std::vector<OperationResult> RdbSubscriberManager::AddObservers(void *subscriber, in AddObservers() 43 return std::vector<OperationResult>(); in AddObservers() 55 const std::shared_ptr<Observer> observer, std::vector<OperationResult> &opResult) { in AddObservers() 81 std::vector<OperationResult> RdbSubscriberManager::DelObservers(void *subscriber, in DelObservers() 86 return std::vector<OperationResult>(); in DelObservers() 97 [&proxy, &templateId, this](const std::vector<Key> &lastDelKeys, std::vector<OperationResult> &opResult) { in DelObservers() 112 std::vector<OperationResult> RdbSubscriberManager::DelObservers(void *subscriber, in DelObservers() 117 return std::vector<OperationResult>(); in DelObservers() 120 [&proxy, this](const std::vector<Key> &lastDelKeys, std::vector<OperationResult> &opResult) { in DelObservers() 131 std::vector<OperationResult> RdbSubscriberManage [all...] |
H A D | data_share_service_proxy.cpp | 244 std::vector<OperationResult> DataShareServiceProxy::Publish(const Data &data, const std::string &bundleName) in Publish() 246 std::vector<OperationResult> results; in Publish() 295 std::vector<OperationResult> DataShareServiceProxy::SubscribeRdbData(const std::vector<std::string> &uris, in SubscribeRdbData() 298 std::vector<OperationResult> results; in SubscribeRdbData() 330 std::vector<OperationResult> DataShareServiceProxy::UnSubscribeRdbData( in UnSubscribeRdbData() 333 std::vector<OperationResult> results; in UnSubscribeRdbData() 357 std::vector<OperationResult> DataShareServiceProxy::EnableSubscribeRdbData( in EnableSubscribeRdbData() 360 std::vector<OperationResult> results; in EnableSubscribeRdbData() 384 std::vector<OperationResult> DataShareServiceProxy::DisableSubscribeRdbData( in DisableSubscribeRdbData() 387 std::vector<OperationResult> result in DisableSubscribeRdbData() [all...] |
/foundation/distributeddatamgr/data_share/interfaces/inner_api/consumer/include/ |
H A D | datashare_helper.h | 337 virtual std::vector<OperationResult> Publish(const Data &data, const std::string &bundleName) = 0; 354 virtual std::vector<OperationResult> SubscribeRdbData(const std::vector<std::string> &uris, 363 virtual std::vector<OperationResult> UnsubscribeRdbData(const std::vector<std::string> &uris, 372 virtual std::vector<OperationResult> EnableRdbSubs(const std::vector<std::string> &uris, 381 virtual std::vector<OperationResult> DisableRdbSubs(const std::vector<std::string> &uris, 391 virtual std::vector<OperationResult> SubscribePublishedData(const std::vector<std::string> &uris, 400 virtual std::vector<OperationResult> UnsubscribePublishedData(const std::vector<std::string> &uris, 409 virtual std::vector<OperationResult> EnablePubSubs(const std::vector<std::string> &uris, int64_t subscriberId) = 0; 417 virtual std::vector<OperationResult> DisablePubSubs(const std::vector<std::string> &uris, int64_t subscriberId) = 0;
|
/foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/ |
H A D | abnormal_branch_test.cpp | 154 std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().AddObservers(subscriber, in HWTEST_F() 168 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().AddObservers(subscriber, proxy, uris, in HWTEST_F() 181 std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, in HWTEST_F() 196 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, in HWTEST_F() 211 std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().EnableObservers(subscriber, in HWTEST_F() 224 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().EnableObservers(subscriber, proxy, in HWTEST_F() 237 std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().DisableObservers(subscriber, in HWTEST_F() 250 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().DisableObservers(subscriber, proxy, in HWTEST_F()
|
/foundation/distributeddatamgr/data_share/test/native/unittest/datashareproxy_test/ |
H A D | proxydatas_with_permission_test.cpp | 206 std::vector<OperationResult> results = helper->Publish(data, bundleName); in HWTEST_F() 234 std::vector<OperationResult> results = helper->Publish(data, bundleName); in HWTEST_F() 254 std::vector<OperationResult> results = helper->Publish(data, bundleName); in HWTEST_F() 289 std::vector<OperationResult> results1 = in HWTEST_F() 301 std::vector<OperationResult> results3 = helper->EnableRdbSubs(uris, tplId); in HWTEST_F() 313 std::vector<OperationResult> results4 = helper->UnsubscribeRdbData(uris, tplId); in HWTEST_F() 331 std::vector<OperationResult> results = in HWTEST_F() 348 std::vector<OperationResult> results = helper->DisablePubSubs(uris, SUBSCRIBER_ID); in HWTEST_F() 361 std::vector<OperationResult> results = helper->EnablePubSubs(uris, SUBSCRIBER_ID); in HWTEST_F() 374 std::vector<OperationResult> result in HWTEST_F() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | data_share_service_impl_test.cpp | 218 std::vector<OperationResult> result = dataShareServiceImpl.Publish(data, bundleName);
in HWTEST_F() 242 std::vector<OperationResult> result = dataShareServiceImpl.Publish(data, bundleName);
in HWTEST_F() 275 std::vector<OperationResult> result2 = dataShareServiceImpl.SubscribeRdbData(uris, tplId, observer);
in HWTEST_F() 281 std::vector<OperationResult> result3 = dataShareServiceImpl.EnableRdbSubs(uris, tplId);
in HWTEST_F() 293 std::vector<OperationResult> result5 = dataShareServiceImpl.UnsubscribeRdbData(uris, tplId);
in HWTEST_F() 304 std::vector<OperationResult> result7 = dataShareServiceImpl.DisableRdbSubs(uris, tplId);
in HWTEST_F() 326 std::vector<OperationResult> result = dataShareServiceImpl.SubscribePublishedData(uris, subscriberId, observer);
in HWTEST_F() 352 std::vector<OperationResult> result = dataShareServiceImpl.SubscribePublishedData(uris, subscriberId, observer);
in HWTEST_F() 381 std::vector<OperationResult> result = dataShareServiceImpl.EnablePubSubs(uris, subscriberId);
in HWTEST_F() 404 std::vector<OperationResult> resul in HWTEST_F() [all...] |
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/include/ |
H A D | napi_subscriber_manager.h | 63 std::vector<OperationResult> AddObservers(napi_env env, napi_value callback, const std::vector<std::string> &uris, 65 std::vector<OperationResult> DelObservers(napi_env env, napi_value callback, 108 std::vector<OperationResult> AddObservers(napi_env env, napi_value callback, const std::vector<std::string> &uris, 110 std::vector<OperationResult> DelObservers(napi_env env, napi_value callback,
|