| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
| H A D | data_share_types_util.h | 33 using PublishedDataChangeNode = DataShare::PublishedDataChangeNode;
60 bool Marshalling(const PublishedDataChangeNode &changeNode, MessageParcel &parcel);
|
| H A D | data_proxy_observer.h | 33 virtual void OnChangeFromPublishedData(PublishedDataChangeNode &changeNode) = 0;
|
| H A D | data_share_obs_proxy.h | 39 void OnChangeFromPublishedData(PublishedDataChangeNode &changeNode) override;
|
| H A D | data_share_obs_proxy.cpp | 47 void PublishedDataObserverProxy::OnChangeFromPublishedData(PublishedDataChangeNode &changeNode) in OnChangeFromPublishedData()
|
| H A D | data_share_types_util.cpp | 92 bool Marshalling(const PublishedDataChangeNode &changeNode, MessageParcel &parcel) in Marshalling()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/ |
| H A D | data_proxy_observer_stub.h | 38 using PublishedDataCallback = std::function<void(PublishedDataChangeNode &changeNode)>;
44 void OnChangeFromPublishedData(PublishedDataChangeNode &changeNode);
|
| H A D | published_data_subscriber_manager.h | 68 void OnChange(PublishedDataChangeNode &changeNode);
93 void Emit(PublishedDataChangeNode &changeNode);
102 ConcurrentMap<Key, PublishedDataChangeNode> lastChangeNodeMap_;
|
| /foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/ |
| H A D | published_data_subscriber_manager.cpp | 213 void PublishedDataSubscriberManager::Emit(PublishedDataChangeNode &changeNode)
217 lastChangeNodeMap_.Compute(key, [](const Key &, PublishedDataChangeNode &value) {
222 std::map<std::shared_ptr<Observer>, PublishedDataChangeNode> results;
230 lastChangeNodeMap_.Compute(key, [&data, &changeNode](const Key &, PublishedDataChangeNode &value) {
248 PublishedDataChangeNode node;
250 lastChangeNodeMap_.ComputeIfPresent(key, [&node](const Key &, PublishedDataChangeNode &value) {
263 std::map<std::shared_ptr<Observer>, PublishedDataChangeNode> results;
267 PublishedDataChangeNode &value) {
294 serviceCallback_ = new PublishedDataObserverStub([this](PublishedDataChangeNode &changeNode) {
325 void PublishedDataObserver::OnChange(PublishedDataChangeNode
[all...] |
| H A D | data_proxy_observer_stub.cpp | 81 PublishedDataChangeNode changeNode; in OnRemoteRequest()
90 void PublishedDataObserverStub::OnChangeFromPublishedData(PublishedDataChangeNode &changeNode) in OnChangeFromPublishedData()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/common/include/ |
| H A D | datashare_itypes_utils.h | 34 using PublishedDataChangeNode = DataShare::PublishedDataChangeNode;
117 bool Marshalling(const PublishedDataChangeNode &changeNode, MessageParcel &parcel);
120 bool Unmarshalling(PublishedDataChangeNode &changeNode, MessageParcel &parcel);
|
| /foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/ |
| H A D | napi_observer.cpp | 123 void NapiPublishedObserver::OnChange(PublishedDataChangeNode &changeNode) in OnChange()
135 std::shared_ptr<PublishedDataChangeNode> node = std::make_shared<PublishedDataChangeNode>(std::move(changeNode)); in OnChange()
|
| H A D | napi_subscriber_manager.cpp | 145 [this](const PublishedDataChangeNode &changeNode) { in AddObservers()
190 void NapiPublishedSubscriberManager::Emit(const PublishedDataChangeNode &changeNode)
196 std::map<std::shared_ptr<Observer>, PublishedDataChangeNode> results;
218 PublishedDataChangeNode node;
|
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/include/ |
| H A D | published_data_controller.h | 35 int64_t subscriberId, const std::function<void(const PublishedDataChangeNode &changeNode)> &callback);
|
| /foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/include/ |
| H A D | napi_subscriber_manager.h | 112 void Emit(const PublishedDataChangeNode &changeNode);
117 std::map<Key, PublishedDataChangeNode> lastChangeNodeMap_;
|
| H A D | napi_observer.h | 51 void OnChange(PublishedDataChangeNode &changeNode);
|
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/src/ |
| H A D | published_data_controller.cpp | 45 const std::function<void(const PublishedDataChangeNode &changeNode)> &callback) in SubscribePublishedData()
|
| /foundation/distributeddatamgr/data_share/interfaces/inner_api/common/include/ |
| H A D | datashare_template.h | 133 struct PublishedDataChangeNode { struct
|
| /foundation/distributeddatamgr/data_share/frameworks/native/common/src/ |
| H A D | datashare_itypes_utils.cpp | 147 bool Marshalling(const PublishedDataChangeNode &changeNode, MessageParcel &parcel) in Marshalling()
153 bool Unmarshalling(PublishedDataChangeNode &changeNode, MessageParcel &parcel) in Unmarshalling()
|
| /foundation/ability/form_fwk/services/include/ |
| H A D | form_data_proxy_record.h | 83 void OnPublishedDataChange(const DataShare::PublishedDataChangeNode &changeNode);
|
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/include/ |
| H A D | datashare_helper_impl.h | 92 const std::function<void(const PublishedDataChangeNode &)> &callback) override;
|
| /foundation/distributeddatamgr/data_share/interfaces/inner_api/consumer/include/ |
| H A D | datashare_helper.h | 392 int64_t subscriberId, const std::function<void(const PublishedDataChangeNode &changeNode)> &callback) = 0;
|
| /foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/ |
| H A D | abnormal_branch_test.cpp | 153 const PublishedDataCallback callback = [](const PublishedDataChangeNode &changeNode){}; in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | published_data_subscriber_manager.cpp | 140 PublishedDataChangeNode result;
in Emit()
|
| /foundation/ability/form_fwk/services/src/ |
| H A D | form_data_proxy_record.cpp | 189 void FormDataProxyRecord::OnPublishedDataChange(const DataShare::PublishedDataChangeNode &changeNode) in OnPublishedDataChange()
306 auto publishedTask = [weak](const DataShare::PublishedDataChangeNode &changeNode) { in SubscribePublishFormData()
813 auto publishedTask = [weak](const DataShare::PublishedDataChangeNode &changeNode) { in RetryFailurePublishedSubscribes()
|
| /foundation/distributeddatamgr/data_share/test/native/unittest/datashareproxy_test/ |
| H A D | proxydatas_with_permission_test.cpp | 332 helper->SubscribePublishedData(uris, SUBSCRIBER_ID, [](const PublishedDataChangeNode &changeNode) { in HWTEST_F()
|