Home
last modified time | relevance | path

Searched refs:changeNode (Results 1 – 25 of 31) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Ddata_proxy_observer_stub.cpp36 RdbChangeNode changeNode; in OnRemoteRequest() local
37 if (!ITypesUtil::Unmarshal(data, changeNode)) { in OnRemoteRequest()
41 OnChangeFromRdb(changeNode); in OnRemoteRequest()
45 void RdbObserverStub::OnChangeFromRdb(const RdbChangeNode &changeNode) in OnChangeFromRdb() argument
49 callback_(changeNode); in OnChangeFromRdb()
81 PublishedDataChangeNode changeNode; in OnRemoteRequest() local
82 if (!ITypesUtil::Unmarshal(data, changeNode)) { in OnRemoteRequest()
86 OnChangeFromPublishedData(changeNode); in OnRemoteRequest()
90 void PublishedDataObserverStub::OnChangeFromPublishedData(PublishedDataChangeNode &changeNode) in OnChangeFromPublishedData() argument
94 callback_(changeNode); in OnChangeFromPublishedData()
H A Drdb_subscriber_manager.cpp218 void RdbSubscriberManager::Emit(const RdbChangeNode &changeNode) in Emit() argument
220 RdbObserverMapKey key(changeNode.uri_, changeNode.templateId_); in Emit()
221 lastChangeNodeMap_[key] = changeNode; in Emit()
227 obs->OnChange(changeNode); in Emit()
262 serviceCallback_ = new RdbObserverStub([this](const RdbChangeNode &changeNode) { in Init() argument
263 Emit(changeNode); in Init()
282 void RdbObserver::OnChange(const RdbChangeNode &changeNode) in OnChange() argument
284 callback_(changeNode); in OnChange()
H A Dpublished_data_subscriber_manager.cpp213 void PublishedDataSubscriberManager::Emit(PublishedDataChangeNode &changeNode) in Emit() argument
215 for (auto &data : changeNode.datas_) { in Emit()
223 for (auto &data : changeNode.datas_) { in Emit()
230 …lastChangeNodeMap_.Compute(key, [&data, &changeNode](const Key &, PublishedDataChangeNode &value) { in Emit()
232 value.ownerBundleName_ = changeNode.ownerBundleName_; in Emit()
241 node.ownerBundleName_ = changeNode.ownerBundleName_; in Emit()
294 … serviceCallback_ = new PublishedDataObserverStub([this](PublishedDataChangeNode &changeNode) { in Init() argument
295 Emit(changeNode); in Init()
325 void PublishedDataObserver::OnChange(PublishedDataChangeNode &changeNode) in OnChange() argument
327 callback_(changeNode); in OnChange()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/common/src/
H A Ddatashare_itypes_utils.cpp135 bool Marshalling(const RdbChangeNode &changeNode, MessageParcel &parcel) in Marshalling() argument
137 return ITypesUtil::Marshal(parcel, changeNode.uri_, changeNode.templateId_, changeNode.data_); in Marshalling()
141 bool Unmarshalling(RdbChangeNode &changeNode, MessageParcel &parcel) in Unmarshalling() argument
143 return ITypesUtil::Unmarshal(parcel, changeNode.uri_, changeNode.templateId_, changeNode.data_); in Unmarshalling()
147 bool Marshalling(const PublishedDataChangeNode &changeNode, MessageParcel &parcel) in Marshalling() argument
149 return ITypesUtil::Marshal(parcel, changeNode.ownerBundleName_, changeNode.datas_); in Marshalling()
153 bool Unmarshalling(PublishedDataChangeNode &changeNode, MessageParcel &parcel) in Unmarshalling() argument
155 return ITypesUtil::Unmarshal(parcel, changeNode.ownerBundleName_, changeNode.datas_); in Unmarshalling()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/
H A Dnapi_subscriber_manager.cpp51 Emit(changeNode); in AddObservers()
95 void NapiRdbSubscriberManager::Emit(const RdbChangeNode &changeNode) in Emit() argument
97 Key key(changeNode.uri_, changeNode.templateId_); in Emit()
98 lastChangeNodeMap_[key] = changeNode; in Emit()
102 obs->OnChange(changeNode); in Emit()
145 [this](const PublishedDataChangeNode &changeNode) { in AddObservers() argument
146 Emit(changeNode); in AddObservers()
192 for (auto &data : changeNode.datas_) { in Emit()
197 for (auto &data : changeNode.datas_) { in Emit()
205 lastChangeNodeMap_[key].ownerBundleName_ = changeNode.ownerBundleName_; in Emit()
[all …]
H A Dnapi_observer.cpp91 void NapiRdbObserver::OnChange(const RdbChangeNode &changeNode) in OnChange() argument
103 observerWorker->getParam = [changeNode](napi_env env) { in OnChange()
104 return DataShareJSUtils::Convert2JSValue(env, changeNode); in OnChange()
123 void NapiPublishedObserver::OnChange(PublishedDataChangeNode &changeNode) in OnChange() argument
135 …r<PublishedDataChangeNode> node = std::make_shared<PublishedDataChangeNode>(std::move(changeNode)); in OnChange()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_types_util.cpp86 bool Marshalling(const RdbChangeNode &changeNode, MessageParcel &parcel) in Marshalling() argument
88 return ITypesUtil::Marshal(parcel, changeNode.uri_, changeNode.templateId_, changeNode.data_); in Marshalling()
92 bool Marshalling(const PublishedDataChangeNode &changeNode, MessageParcel &parcel) in Marshalling() argument
94 return ITypesUtil::Marshal(parcel, changeNode.ownerBundleName_, changeNode.datas_); in Marshalling()
H A Ddata_share_obs_proxy.cpp25 void RdbObserverProxy::OnChangeFromRdb(RdbChangeNode &changeNode) in OnChangeFromRdb() argument
32 if (!ITypesUtil::Marshal(parcel, changeNode)) { in OnChangeFromRdb()
47 void PublishedDataObserverProxy::OnChangeFromPublishedData(PublishedDataChangeNode &changeNode) in OnChangeFromPublishedData() argument
54 if (!ITypesUtil::Marshal(parcel, changeNode)) { in OnChangeFromPublishedData()
H A Ddata_proxy_observer.h27 virtual void OnChangeFromRdb(RdbChangeNode &changeNode) = 0;
33 virtual void OnChangeFromPublishedData(PublishedDataChangeNode &changeNode) = 0;
H A Ddata_share_obs_proxy.h28 void OnChangeFromRdb(RdbChangeNode &changeNode) override;
39 void OnChangeFromPublishedData(PublishedDataChangeNode &changeNode) override;
H A Ddata_share_types_util.h57 bool Marshalling(const RdbChangeNode &changeNode, MessageParcel &parcel);
60 bool Marshalling(const PublishedDataChangeNode &changeNode, MessageParcel &parcel);
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/
H A Ddata_proxy_observer_stub.h25 using RdbCallback = std::function<void(const RdbChangeNode &changeNode)>;
31 void OnChangeFromRdb(const RdbChangeNode &changeNode);
38 using PublishedDataCallback = std::function<void(PublishedDataChangeNode &changeNode)>;
44 void OnChangeFromPublishedData(PublishedDataChangeNode &changeNode);
H A Dpublished_data_subscriber_manager.h68 void OnChange(PublishedDataChangeNode &changeNode);
93 void Emit(PublishedDataChangeNode &changeNode);
H A Drdb_subscriber_manager.h68 void OnChange(const RdbChangeNode &changeNode);
93 void Emit(const RdbChangeNode &changeNode);
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/common/include/
H A Ddatashare_itypes_utils.h111 bool Marshalling(const RdbChangeNode &changeNode, MessageParcel &parcel);
114 bool Unmarshalling(RdbChangeNode &changeNode, MessageParcel &parcel);
117 bool Marshalling(const PublishedDataChangeNode &changeNode, MessageParcel &parcel);
120 bool Unmarshalling(PublishedDataChangeNode &changeNode, MessageParcel &parcel);
129 bool Marshalling(const TemplateId &changeNode, MessageParcel &parcel);
/ohos5.0/foundation/ability/form_fwk/services/src/
H A Dform_data_proxy_record.cpp180 void FormDataProxyRecord::OnRdbDataChange(const DataShare::RdbChangeNode &changeNode) in OnRdbDataChange() argument
182 HILOG_INFO("rdb change. data size is %{public}zu", changeNode.data_.size()); in OnRdbDataChange()
183 if (changeNode.data_.size() == 0) { in OnRdbDataChange()
186 UpdateRdbDataForm(changeNode.data_); in OnRdbDataChange()
192 UpdatePublishedDataForm(changeNode.datas_); in OnPublishedDataChange()
259 auto rdbTask = [weak](const DataShare::RdbChangeNode &changeNode) { in SubscribeRdbFormData() argument
265 formDataRecord->OnRdbDataChange(changeNode); in SubscribeRdbFormData()
312 formDataRecord->OnPublishedDataChange(changeNode); in SubscribePublishFormData()
778 auto rdbTask = [weak](const DataShare::RdbChangeNode &changeNode) { in RetryFailureRdbSubscribes() argument
784 formDataRecord->OnRdbDataChange(changeNode); in RetryFailureRdbSubscribes()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/
H A Drdb_subscriber_manager.cpp336 RdbChangeNode changeNode; in Notify() local
337 changeNode.uri_ = key.uri; in Notify()
338 changeNode.templateId_.subscriberId_ = key.subscriberId; in Notify()
339 changeNode.templateId_.bundleName_ = key.bundleName; in Notify()
345 changeNode.data_.emplace_back("{\"" + predicate.key_ + "\":" + result + "}"); in Notify()
349 … val.size(), changeNode.data_.size(), DistributedData::Anonymous::Change(changeNode.uri_).c_str()); in Notify()
352 callback.observer->OnChangeFromRdb(changeNode); in Notify()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/include/
H A Dnapi_observer.h45 void OnChange(const RdbChangeNode &changeNode);
51 void OnChange(PublishedDataChangeNode &changeNode);
H A Dnapi_subscriber_manager.h67 void Emit(const RdbChangeNode &changeNode);
112 void Emit(const PublishedDataChangeNode &changeNode);
/ohos5.0/foundation/distributeddatamgr/data_share/test/native/unittest/datashareproxy_test/
H A Dproxydatas_with_permission_test.cpp290 helper->SubscribeRdbData(uris, tplId, [&tplId](const RdbChangeNode &changeNode) { in __anon83ff92070102() argument
291 EXPECT_EQ(changeNode.uri_, DATA_SHARE_PROXY_URI); in __anon83ff92070102()
292 EXPECT_EQ(changeNode.templateId_.bundleName_, tplId.bundleName_); in __anon83ff92070102()
293 EXPECT_EQ(changeNode.templateId_.subscriberId_, tplId.subscriberId_); in __anon83ff92070102()
332 …helper->SubscribePublishedData(uris, SUBSCRIBER_ID, [](const PublishedDataChangeNode &changeNode) { in __anon83ff92070202() argument
333 EXPECT_EQ(changeNode.ownerBundleName_, "ohos.datashareproxyclienttest.demo"); in __anon83ff92070202()
/ohos5.0/foundation/ability/form_fwk/services/include/
H A Dform_data_proxy_record.h82 void OnRdbDataChange(const DataShare::RdbChangeNode &changeNode);
83 void OnPublishedDataChange(const DataShare::PublishedDataChangeNode &changeNode);
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/js/napi/common/src/
H A Ddatashare_js_utils.cpp375 napi_value DataShareJSUtils::Convert2JSValue(napi_env env, const RdbChangeNode &changeNode) in Convert2JSValue() argument
381 uri = Convert2JSValue(env, changeNode.uri_); in Convert2JSValue()
386 templateId = Convert2JSValue(env, changeNode.templateId_); in Convert2JSValue()
390 napi_value data = Convert2JSValue(env, changeNode.data_); in Convert2JSValue()
446 napi_value DataShareJSUtils::Convert2JSValue(napi_env env, PublishedDataChangeNode &changeNode) in Convert2JSValue() argument
452 bundleName = Convert2JSValue(env, changeNode.ownerBundleName_); in Convert2JSValue()
457 data = Convert2JSValue(env, changeNode.datas_); in Convert2JSValue()
/ohos5.0/base/startup/init/services/param/watcher/agent/
H A Dwatcher_manager_kits.cpp245 std::shared_ptr<ParameterChangeListener> changeNode = in AddParameterListener() local
247 WATCHER_CHECK(changeNode != nullptr, return -1, "Failed to create listener"); in AddParameterListener()
248 parameterChangeListeners[listenerId_] = changeNode; in AddParameterListener()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/include/
H A Dpublished_data_controller.h35 …int64_t subscriberId, const std::function<void(const PublishedDataChangeNode &changeNode)> &callba…
/ohos5.0/foundation/distributeddatamgr/data_share/interfaces/inner_api/consumer/include/
H A Ddatashare_helper.h361 …const TemplateId &templateId, const std::function<void(const RdbChangeNode &changeNode)> &callback…
398 …int64_t subscriberId, const std::function<void(const PublishedDataChangeNode &changeNode)> &callba…

12