| /ohos5.0/foundation/ability/ability_runtime/services/dataobsmgr/src/ |
| H A D | dataobs_mgr_inner.cpp | 49 obsPair->second.push_back(dataObserver); in HandleRegisterObserver()
51 AddObsDeathRecipient(dataObserver); in HandleRegisterObserver()
85 if (!HaveRegistered(dataObserver)) { in HandleUnregisterObserver()
119 if ((dataObserver == nullptr) || dataObserver->AsObject() == nullptr) { in AddObsDeathRecipient()
145 if (dataObserver == nullptr) { in RemoveObsDeathRecipient()
149 auto it = obsRecipient_.find(dataObserver); in RemoveObsDeathRecipient()
159 auto dataObserver = remote.promote(); in OnCallBackDied() local
160 if (dataObserver == nullptr) { in OnCallBackDied()
165 if (dataObserver == nullptr) { in OnCallBackDied()
170 RemoveObs(dataObserver); in OnCallBackDied()
[all …]
|
| H A D | dataobs_mgr_inner_ext.cpp | 31 if (dataObserver->AsObject() == nullptr) { in HandleRegisterObserver()
54 if (dataObserver->AsObject() == nullptr) { in HandleUnregisterObserver()
71 if (dataObserver->AsObject() == nullptr) { in HandleUnregisterObserver()
77 root_->RemoveObserver(dataObserver); in HandleUnregisterObserver()
115 const sptr<IRemoteObject> &dataObserver) in AddObsDeathRecipient() argument
159 auto dataObserver = remote.promote(); in OnCallBackDied() local
160 if (dataObserver == nullptr) { in OnCallBackDied()
165 root_->RemoveObserver(dataObserver); in OnCallBackDied()
167 RemoveObsDeathRecipient(dataObserver, true); in OnCallBackDied()
211 sptr<IDataAbilityObserver> dataObserver) in RemoveObserver() argument
[all …]
|
| H A D | dataobs_mgr_inner_pref.cpp | 49 obsPair->second.push_back(dataObserver); in HandleRegisterObserver()
51 AddObsDeathRecipient(dataObserver); in HandleRegisterObserver()
84 if (!HaveRegistered(dataObserver)) { in HandleUnregisterObserver()
125 if ((dataObserver == nullptr) || dataObserver->AsObject() == nullptr) { in AddObsDeathRecipient()
151 if (dataObserver == nullptr) { in RemoveObsDeathRecipient()
155 auto it = obsRecipient_.find(dataObserver); in RemoveObsDeathRecipient()
165 auto dataObserver = remote.promote(); in OnCallBackDied() local
166 if (dataObserver == nullptr) { in OnCallBackDied()
171 if (dataObserver == nullptr) { in OnCallBackDied()
176 RemoveObs(dataObserver); in OnCallBackDied()
[all …]
|
| H A D | dataobs_mgr_client.cpp | 86 auto status = dataObsManger->RegisterObserver(uri, dataObserver); in RegisterObserver()
90 observers_.Compute(dataObserver, [&uri](const auto &key, auto &value) { in RegisterObserver()
111 auto status = dataObsManger->UnregisterObserver(uri, dataObserver); in UnregisterObserver()
115 observers_.Compute(dataObserver, [&uri](const auto &key, auto &value) { in UnregisterObserver()
182 auto status = dataObsManger->RegisterObserverExt(uri, dataObserver, isDescendants); in RegisterObserverExt()
186 observerExts_.Compute(dataObserver, [&uri, isDescendants](const auto &key, auto &value) { in RegisterObserverExt()
199 auto status = dataObsManger->UnregisterObserverExt(uri, dataObserver); in UnregisterObserverExt()
203 observerExts_.Compute(dataObserver, [&uri](const auto &key, auto &value) { in UnregisterObserverExt()
212 Status DataObsMgrClient::UnregisterObserverExt(sptr<IDataAbilityObserver> dataObserver) in UnregisterObserverExt() argument
218 auto status = dataObsManger->UnregisterObserverExt(dataObserver); in UnregisterObserverExt()
[all …]
|
| H A D | dataobs_mgr_service.cpp | 90 if (dataObserver == nullptr) { in RegisterObserver()
104 status = dataObsMgrInnerPref_->HandleRegisterObserver(uri, dataObserver); in RegisterObserver()
106 status = dataObsMgrInner_->HandleRegisterObserver(uri, dataObserver); in RegisterObserver()
119 if (dataObserver == nullptr) { in UnregisterObserver()
133 status = dataObsMgrInnerPref_->HandleUnregisterObserver(uri, dataObserver); in UnregisterObserver()
135 status = dataObsMgrInner_->HandleUnregisterObserver(uri, dataObserver); in UnregisterObserver()
188 if (dataObserver == nullptr) { in RegisterObserverExt()
206 if (dataObserver == nullptr) { in UnregisterObserverExt()
219 return dataObsMgrInnerExt_->HandleUnregisterObserver(innerUri, dataObserver); in UnregisterObserverExt()
224 if (dataObserver == nullptr) { in UnregisterObserverExt()
[all …]
|
| H A D | dataobs_mgr_proxy.cpp | 41 if (dataObserver == nullptr) { in WriteParam()
46 if (!data.WriteRemoteObject(dataObserver->AsObject())) { in WriteParam()
53 …32_t DataObsManagerProxy::RegisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) in RegisterObserver() argument
63 if (!WriteParam(data, uri, dataObserver)) { in RegisterObserver()
78 …_t DataObsManagerProxy::UnregisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) in UnregisterObserver() argument
88 if (!WriteParam(data, uri, dataObserver)) { in UnregisterObserver()
138 if (!WriteParam(data, uri, dataObserver)) { in RegisterObserverExt()
169 if (!WriteParam(data, uri, dataObserver)) { in UnregisterObserverExt()
183 Status DataObsManagerProxy::UnregisterObserverExt(sptr<IDataAbilityObserver> dataObserver) in UnregisterObserverExt() argument
193 if (dataObserver == nullptr) { in UnregisterObserverExt()
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/services/dataobsmgr/include/ |
| H A D | dataobs_mgr_inner_ext.h | 40 …Status HandleRegisterObserver(Uri &uri, sptr<IDataAbilityObserver> dataObserver, bool isDescendant…
41 Status HandleUnregisterObserver(Uri &uri, sptr<IDataAbilityObserver> dataObserver);
42 Status HandleUnregisterObserver(sptr<IDataAbilityObserver> dataObserver);
72 sptr<IDataAbilityObserver> dataObserver);
73 inline bool RemoveObserver(sptr<IDataAbilityObserver> dataObserver);
74 bool RemoveObserver(sptr<IRemoteObject> dataObserver);
82 … std::shared_ptr<DeathRecipientRef> AddObsDeathRecipient(const sptr<IRemoteObject> &dataObserver);
83 void RemoveObsDeathRecipient(const sptr<IRemoteObject> &dataObserver, bool isForce = false);
|
| H A D | dataobs_mgr_inner.h | 39 int HandleRegisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver);
40 int HandleUnregisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver);
45 void AddObsDeathRecipient(sptr<IDataAbilityObserver> dataObserver);
46 void RemoveObsDeathRecipient(sptr<IRemoteObject> dataObserver);
47 void RemoveObs(sptr<IRemoteObject> dataObserver);
48 bool HaveRegistered(sptr<IDataAbilityObserver> dataObserver);
|
| H A D | dataobs_mgr_inner_pref.h | 38 int HandleRegisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver);
39 int HandleUnregisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver);
44 void AddObsDeathRecipient(sptr<IDataAbilityObserver> dataObserver);
45 void RemoveObsDeathRecipient(sptr<IRemoteObject> dataObserver);
46 void RemoveObs(sptr<IRemoteObject> dataObserver);
47 bool HaveRegistered(sptr<IDataAbilityObserver> dataObserver);
|
| H A D | dataobs_mgr_proxy.h | 46 virtual int RegisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) override;
56 … virtual int UnregisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) override;
76 virtual Status RegisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver,
87 …virtual Status UnregisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) over…
96 virtual Status UnregisterObserverExt(sptr<IDataAbilityObserver> dataObserver) override;
109 bool WriteParam(MessageParcel &data, const Uri &uri, sptr<IDataAbilityObserver> dataObserver);
|
| H A D | dataobs_mgr_service.h | 52 virtual int RegisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) override;
53 … virtual int UnregisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) override;
55 virtual Status RegisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver,
57 …virtual Status UnregisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) over…
58 virtual Status UnregisterObserverExt(sptr<IDataAbilityObserver> dataObserver) override;
|
| /ohos5.0/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_proxy_test/ |
| H A D | dataobs_mgr_proxy_test.cpp | 66 … sptr<AAFwk::IDataAbilityObserver> dataObserver(new (std::nothrow) MockDataAbilityObserverStub());
68 int32_t retVal = dataObsManagerProxy->RegisterObserver(*uri, dataObserver);
92 … sptr<AAFwk::IDataAbilityObserver> dataObserver(new (std::nothrow) MockDataAbilityObserverStub());
94 int32_t retVal = dataObsManagerProxy->UnregisterObserver(*uri, dataObserver);
141 … sptr<AAFwk::IDataAbilityObserver> dataObserver(new (std::nothrow) MockDataAbilityObserverStub());
143 int32_t retVal = dataObsManagerProxy->RegisterObserverExt(*uri, dataObserver, true);
166 … sptr<AAFwk::IDataAbilityObserver> dataObserver(new (std::nothrow) MockDataAbilityObserverStub());
168 int32_t retVal = dataObsManagerProxy->UnregisterObserverExt(*uri, dataObserver);
170 retVal = dataObsManagerProxy->UnregisterObserverExt(dataObserver);
|
| /ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/dataobs_manager/include/ |
| H A D | dataobs_mgr_interface.h | 59 virtual int RegisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) = 0;
69 virtual int UnregisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) = 0;
89 …virtual Status RegisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver, bool i…
99 … virtual Status UnregisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) = 0;
108 virtual Status UnregisterObserverExt(sptr<IDataAbilityObserver> dataObserver) = 0;
|
| H A D | dataobs_mgr_client.h | 49 ErrCode RegisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver);
59 ErrCode UnregisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver);
78 …Status RegisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver, bool isDescend…
88 Status UnregisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver);
97 Status UnregisterObserverExt(sptr<IDataAbilityObserver> dataObserver);
|
| /ohos5.0/foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/ |
| H A D | slientaccess_test.cpp | 407 dataObserver->SetName("zhangsan");
408 helper->RegisterObserver(uri, dataObserver);
417 dataObserver->data.Wait();
419 dataObserver->Clear();
425 helper->UnregisterObserver(uri, dataObserver);
435 dataObserver->SetName("zhangsan");
462 dataObserver->SetName("zhangsan");
477 helper->UnregisterObserver(uri, dataObserver);
487 dataObserver->SetName("zhangsan");
488 helper->RegisterObserver(uri, dataObserver);
[all …]
|
| H A D | mediadatashare_unit_test.cpp | 1203 dataObserver->data.Wait();
1205 dataObserver->Clear();
1215 dataObserver->Clear();
1227 dataObserver->Clear();
1251 dataObserver->Clear();
1258 dataObserver->Clear();
1520 dataObserver->Clear();
1548 dataObserver->Clear();
1576 dataObserver->Clear();
1603 dataObserver->Clear();
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_client_test/ |
| H A D | mock_dataobs_mgr_service.h | 32 int RegisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) override in RegisterObserver() argument
37 int UnregisterObserver(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) override in UnregisterObserver() argument
48 …Status RegisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver, bool isDe) ove… in RegisterObserverExt() argument
54 Status UnregisterObserverExt(const Uri &uri, sptr<IDataAbilityObserver> dataObserver) override in UnregisterObserverExt() argument
60 Status UnregisterObserverExt(sptr<IDataAbilityObserver> dataObserver) override in UnregisterObserverExt() argument
|
| /ohos5.0/foundation/ability/ability_runtime/frameworks/native/ability/native/ |
| H A D | data_ability_helper_impl.cpp | 634 if (!CheckUriAndDataObserver(uri, dataObserver)) { in RegisterObserver()
644 auto dataability = registerMap_.find(dataObserver); in RegisterObserver()
650 auto path = uriMap_.find(dataObserver); in RegisterObserver()
666 registerMap_.erase(dataObserver); in RegisterObserver()
667 uriMap_.erase(dataObserver); in RegisterObserver()
681 if (!CheckUriAndDataObserver(uri, dataObserver)) { in UnregisterObserver()
694 auto path = uriMap_.find(dataObserver); in UnregisterObserver()
717 registerMap_.erase(dataObserver); in UnregisterObserver()
718 uriMap_.erase(dataObserver); in UnregisterObserver()
861 const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in CheckUriAndDataObserver() argument
[all …]
|
| /ohos5.0/base/telephony/core_service/services/network_search/src/ |
| H A D | setting_utils.cpp | 97 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in UnRegisterSettingsObserver() argument
102 if (it->first == uri && it->second == dataObserver) { in UnRegisterSettingsObserver()
113 settingHelper->UnregisterObserver(uri, dataObserver); in UnRegisterSettingsObserver()
120 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in RegisterSettingsObserver() argument
125 if (it->first == uri && it->second == dataObserver) { in RegisterSettingsObserver()
130 registerInfos_.emplace_back(std::make_pair(uri, dataObserver)); in RegisterSettingsObserver()
132 return RegisterToDataShare(uri, dataObserver); in RegisterSettingsObserver()
150 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in RegisterToDataShare() argument
157 settingHelper->RegisterObserver(uri, dataObserver); in RegisterToDataShare()
|
| /ohos5.0/base/telephony/cellular_data/services/src/utils/ |
| H A D | cellular_data_rdb_helper.cpp | 276 void CellularDataRdbHelper::RegisterObserver(const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in RegisterObserver() argument
286 dataShareHelper->RegisterObserver(resetApnUri, dataObserver); in RegisterObserver()
287 dataShareHelper->RegisterObserver(preferApnUri, dataObserver); in RegisterObserver()
288 dataShareHelper->RegisterObserver(initApnUri, dataObserver); in RegisterObserver()
289 dataShareHelper->RegisterObserver(cellularDataUri_, dataObserver); in RegisterObserver()
294 …id CellularDataRdbHelper::UnRegisterObserver(const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in UnRegisterObserver() argument
304 dataShareHelper->UnregisterObserver(resetApnUri, dataObserver); in UnRegisterObserver()
305 dataShareHelper->UnregisterObserver(preferApnUri, dataObserver); in UnRegisterObserver()
306 dataShareHelper->UnregisterObserver(initApnUri, dataObserver); in UnRegisterObserver()
307 dataShareHelper->UnregisterObserver(cellularDataUri_, dataObserver); in UnRegisterObserver()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/js/src/ |
| H A D | userfile_client.cpp | 231 …FileClient::RegisterObserver(const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in RegisterObserver() argument
237 sDataShareHelper_->RegisterObserver(uri, dataObserver); in RegisterObserver()
240 …leClient::UnregisterObserver(const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in UnregisterObserver() argument
246 sDataShareHelper_->UnregisterObserver(uri, dataObserver); in UnregisterObserver()
269 shared_ptr<DataShare::DataShareObserver> dataObserver, bool isDescendants) in RegisterObserverExt() argument
275 sDataShareHelper_->RegisterObserverExt(uri, std::move(dataObserver), isDescendants); in RegisterObserverExt()
278 …::UnregisterObserverExt(const Uri &uri, std::shared_ptr<DataShare::DataShareObserver> dataObserver) in UnregisterObserverExt() argument
284 sDataShareHelper_->UnregisterObserverExt(uri, std::move(dataObserver)); in UnregisterObserverExt()
|
| /ohos5.0/base/notification/distributed_notification_service/services/ans/src/ |
| H A D | advanced_datashare_observer.cpp | 57 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in UnRegisterSettingsObserver() argument
64 settingHelper->UnregisterObserver(uri, dataObserver); in UnRegisterSettingsObserver()
68 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in RegisterSettingsObserver() argument
76 settingHelper->RegisterObserver(uri, dataObserver); in RegisterSettingsObserver()
|
| /ohos5.0/foundation/communication/nfc/interfaces/inner_api/controller/ |
| H A D | nfc_data_share_impl.cpp | 53 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in RegisterDataObserver() argument
63 dataShareHelper_->RegisterObserver(uri, dataObserver); in RegisterDataObserver()
68 const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver) in UnregisterDataObserver() argument
78 dataShareHelper_->UnregisterObserver(uri, dataObserver); in UnregisterDataObserver()
|
| /ohos5.0/foundation/multimedia/media_library/interfaces/kits/js/include/ |
| H A D | userfile_client.h | 50 …tatic void RegisterObserver(const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver);
51 …tic void UnregisterObserver(const Uri &uri, const sptr<AAFwk::IDataAbilityObserver> &dataObserver);
56 std::shared_ptr<DataShare::DataShareObserver> dataObserver, bool isDescendants);
58 std::shared_ptr<DataShare::DataShareObserver> dataObserver);
|
| /ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
| H A D | datashare_helper.cpp | 216 …taShareHelper::RegisterObserverExt(const Uri &uri, std::shared_ptr<DataShareObserver> dataObserver, in RegisterObserverExt() argument
219 if (dataObserver == nullptr) { in RegisterObserverExt()
228 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(uri, dataObserver); in RegisterObserverExt()
235 ObserverImpl::DeleteObserver(uri, dataObserver); in RegisterObserverExt()
247 …ShareHelper::UnregisterObserverExt(const Uri &uri, std::shared_ptr<DataShareObserver> dataObserver) in UnregisterObserverExt() argument
249 if (dataObserver == nullptr) { in UnregisterObserverExt()
259 if (!ObserverImpl::FindObserver(uri, dataObserver)) { in UnregisterObserverExt()
264 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(uri, dataObserver); in UnregisterObserverExt()
275 ObserverImpl::DeleteObserver(uri, dataObserver); in UnregisterObserverExt()
|