| /foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/src/ |
| H A D | notify_handler.cpp | 29 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance(); in Handle() local
30 if (obsMgrClient == nullptr) { in Handle()
31 MEDIA_ERR_LOG("%{public}s obsMgrClient is nullptr", __func__); in Handle()
35 obsMgrClient->NotifyChangeExt({static_cast<ChangeType>(notifyInfo.first), notifyInfo.second}); in Handle()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/src/ |
| H A D | general_controller_service_impl.cpp | 170 auto obsMgrClient = OHOS::AAFwk::DataObsMgrClient::GetInstance(); in RegisterObserver() local
171 if (obsMgrClient == nullptr) { in RegisterObserver()
175 ErrCode ret = obsMgrClient->RegisterObserver(uri, dataObserver); in RegisterObserver()
183 auto obsMgrClient = OHOS::AAFwk::DataObsMgrClient::GetInstance(); in UnregisterObserver() local
184 if (obsMgrClient == nullptr) { in UnregisterObserver()
188 ErrCode ret = obsMgrClient->UnregisterObserver(uri, dataObserver); in UnregisterObserver()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
| H A D | datashare_helper.cpp | 218 auto obsMgrClient = OHOS::AAFwk::DataObsMgrClient::GetInstance(); in RegisterObserverExt() local
219 if (obsMgrClient == nullptr) { in RegisterObserverExt()
228 ErrCode ret = obsMgrClient->RegisterObserverExt(uri, obs, isDescendants); in RegisterObserverExt()
248 auto obsMgrClient = OHOS::AAFwk::DataObsMgrClient::GetInstance(); in UnregisterObserverExt() local
249 if (obsMgrClient == nullptr) { in UnregisterObserverExt()
264 ErrCode ret = obsMgrClient->UnregisterObserverExt(uri, obs); in UnregisterObserverExt()
280 auto obsMgrClient = OHOS::AAFwk::DataObsMgrClient::GetInstance(); in NotifyChangeExt() local
281 if (obsMgrClient == nullptr) { in NotifyChangeExt()
286 ErrCode ret = obsMgrClient->NotifyChangeExt(ObserverImpl::ConvertInfo(changeInfo)); in NotifyChangeExt()
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_notify.cpp | 88 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance(); in SendAlbumSub() local
109 MEDIA_DEBUG_LOG("obsMgrClient->NotifyChangeExt URI is %{public}s, NotifyType is %{public}d", in SendAlbumSub()
111 return obsMgrClient->NotifyChangeExt({changeType, {notifyUri}, uBuf, parcel.GetDataSize()}); in SendAlbumSub()
116 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance(); in SolveAlbumUri() local
117 MEDIA_DEBUG_LOG("obsMgrClient->NotifyChangeExt URI is %{public}s, NotifyType is %{public}d", in SolveAlbumUri()
122 return obsMgrClient->NotifyChangeExt({static_cast<ChangeType>(type), uris}); in SolveAlbumUri()
134 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance(); in PushNotifyDataMap() local
135 MEDIA_DEBUG_LOG("obsMgrClient->NotifyChangeExt URI is %{public}s, type is %{public}d", in PushNotifyDataMap()
137 ret = obsMgrClient->NotifyChangeExt({static_cast<ChangeType>(type), uris}); in PushNotifyDataMap()
|
| H A D | media_datashare_ext_ability.cpp | 948 auto obsMgrClient = DataObsMgrClient::GetInstance(); in RegisterObserver() local
949 if (obsMgrClient == nullptr) { in RegisterObserver()
950 MEDIA_ERR_LOG("%{public}s obsMgrClient is nullptr", __func__); in RegisterObserver()
954 ErrCode ret = obsMgrClient->RegisterObserver(uri, dataObserver); in RegisterObserver()
956 MEDIA_ERR_LOG("%{public}s obsMgrClient->RegisterObserver error return %{public}d", __func__, ret); in RegisterObserver()
966 auto obsMgrClient = DataObsMgrClient::GetInstance(); in UnregisterObserver() local
967 if (obsMgrClient == nullptr) { in UnregisterObserver()
968 MEDIA_ERR_LOG("%{public}s obsMgrClient is nullptr", __func__); in UnregisterObserver()
972 ErrCode ret = obsMgrClient->UnregisterObserver(uri, dataObserver); in UnregisterObserver()
974 MEDIA_ERR_LOG("%{public}s obsMgrClient in UnregisterObserver()
983 auto obsMgrClient = DataObsMgrClient::GetInstance(); NotifyChange() local
[all...] |
| /foundation/filemanagement/dfs_service/services/clouddisk_database/src/ |
| H A D | clouddisk_notify.cpp | 419 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance(); in AddNotify()
420 if (obsMgrClient == nullptr) { in AddNotify()
421 LOGE("obsMgrClient is null"); in AddNotify()
447 obsMgrClient->NotifyChangeExt(changeInfo); in AddNotify()
466 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance(); in NotifyChangeOuter() local
467 if (obsMgrClient == nullptr) { in NotifyChangeOuter()
468 LOGE("obsMgrClient is null"); in NotifyChangeOuter()
495 obsMgrClient->NotifyChangeExt(changeInfo); in NotifyChangeOuter()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/provider/src/ |
| H A D | js_datashare_ext_ability.cpp | 812 auto obsMgrClient = DataObsMgrClient::GetInstance(); in RegisterObserver() local
813 if (obsMgrClient == nullptr) { in RegisterObserver()
814 LOG_ERROR("obsMgrClient is nullptr"); in RegisterObserver()
818 ErrCode ret = obsMgrClient->RegisterObserver(uri, dataObserver); in RegisterObserver()
820 LOG_ERROR("obsMgrClient->RegisterObserver error return %{public}d", ret); in RegisterObserver()
829 auto obsMgrClient = DataObsMgrClient::GetInstance(); in UnregisterObserver() local
830 if (obsMgrClient == nullptr) { in UnregisterObserver()
831 LOG_ERROR("obsMgrClient is nullptr"); in UnregisterObserver()
835 ErrCode ret = obsMgrClient->UnregisterObserver(uri, dataObserver); in UnregisterObserver()
837 LOG_ERROR("obsMgrClient in UnregisterObserver()
846 auto obsMgrClient = DataObsMgrClient::GetInstance(); NotifyChange() local
[all...] |
| /foundation/filemanagement/dfs_service/interfaces/kits/js/cloudfilesync/ |
| H A D | cloud_sync_napi.cpp | 474 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance();
475 if (obsMgrClient == nullptr) {
484 ErrCode ret = obsMgrClient->RegisterObserverExt(uri, obs, registerParams.recursion);
538 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance();
539 if (obsMgrClient == nullptr) {
569 ErrCode ret = obsMgrClient->UnregisterObserverExt(Uri(uri), obs);
|
| /foundation/ability/ability_runtime/frameworks/native/ability/native/ |
| H A D | fa_ability_thread.cpp | 1192 auto obsMgrClient = DataObsMgrClient::GetInstance(); in CreateAbilityName() local
1193 if (obsMgrClient == nullptr) { in CreateAbilityName()
1194 TAG_LOGE(AAFwkTag::FA, "obsMgrClient is nullptr"); in CreateAbilityName()
1198 ErrCode ret = obsMgrClient->RegisterObserver(uri, dataObserver); in CreateAbilityName()
1208 auto obsMgrClient = DataObsMgrClient::GetInstance(); in CreateAbilityName() local
1209 if (obsMgrClient == nullptr) { in CreateAbilityName()
1210 TAG_LOGE(AAFwkTag::FA, "obsMgrClient is nullptr"); in CreateAbilityName()
1214 ErrCode ret = obsMgrClient->UnregisterObserver(uri, dataObserver); in CreateAbilityName()
1224 auto obsMgrClient = DataObsMgrClient::GetInstance(); in CreateAbilityName() local
1225 if (obsMgrClient in CreateAbilityName()
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
| H A D | data_share_service_impl.cpp | 123 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance(); in NotifyChange() local
124 if (obsMgrClient == nullptr) { in NotifyChange()
125 ZLOGE("obsMgrClient is nullptr"); in NotifyChange()
130 ErrCode ret = obsMgrClient->NotifyChange(Uri(uri)); in NotifyChange()
132 ZLOGE("obsMgrClient->NotifyChange error return %{public}d", ret); in NotifyChange()
885 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance();
886 if (obsMgrClient == nullptr) {
889 return obsMgrClient->RegisterObserver(Uri(uri), obServer);
914 auto obsMgrClient = AAFwk::DataObsMgrClient::GetInstance();
915 if (obsMgrClient
[all...] |