| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/notify_test/src/ |
| H A D | notify_test.cpp | 89 unique_lock<mutex> lock(obs->mutex_); in CheckFileNotify()
107 …std::copy(static_cast<const char*>(obs->changeInfo_.data_), static_cast<const char*>(obs->changeIn… in SolveAlbumNotify()
108 obs->changeInfo_.size_, data.begin()); in SolveAlbumNotify()
141 unique_lock<mutex> lock(obs->mutex_); in CheckAlbumNotify()
143 if (obs->changeInfo_.size_ > 0) { in CheckAlbumNotify()
144 SolveAlbumNotify(obs, assetStr); in CheckAlbumNotify()
178 unique_lock<mutex> lock(obs->mutex_); in CheckCloseAssetNotify()
198 unique_lock<mutex> lock(obs->mutex_); in CheckInfo()
200 obs->bChange_.load()) { in CheckInfo()
202 EXPECT_EQ(obs->changeInfo_.changeType_, in CheckInfo()
[all …]
|
| /ohos5.0/foundation/multimedia/player_framework/services/engine/histreamer/player/ |
| H A D | hiplayer_callback_looper.cpp | 68 obs_ = obs; in StartWithPlayerEngineObs()
128 auto obs = obs_.lock(); in DoReportCompletedTime() local
129 if (obs) { in DoReportCompletedTime()
153 auto obs = obs_.lock(); in DoReportMediaProgress() local
177 auto obs = obs_.lock(); in DoCollectAmplitude() local
178 if (obs) { in DoCollectAmplitude()
203 if (obs != nullptr) { in ReportRemainedMaxAmplitude()
221 obs = obs_.lock(); in DoReportSystemOperation()
223 if (obs) { in DoReportSystemOperation()
245 if (obs != nullptr) { in DoReportError()
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/services/dataobsmgr/src/ |
| H A D | dataobs_mgr_inner.cpp | 41 for (auto obs = obsPair->second.begin(); obs != obsPair->second.end(); obs++) { in HandleRegisterObserver() local
42 if ((*obs)->AsObject() == dataObserver->AsObject()) { in HandleRegisterObserver()
69 auto obs = obsPair->second.begin(); in HandleUnregisterObserver() local
70 for (; obs != obsPair->second.end(); obs++) { in HandleUnregisterObserver()
71 if ((*obs)->AsObject() == dataObserver->AsObject()) { in HandleUnregisterObserver()
75 if (obs == obsPair->second.end()) { in HandleUnregisterObserver()
80 obsPair->second.remove(*obs); in HandleUnregisterObserver()
106 for (auto &obs : obsList) { in HandleNotifyChange() local
107 if (obs != nullptr) { in HandleNotifyChange()
108 obs->OnChange(); in HandleNotifyChange()
[all …]
|
| H A D | dataobs_mgr_inner_pref.cpp | 41 for (auto obs = obsPair->second.begin(); obs != obsPair->second.end(); obs++) { in HandleRegisterObserver() local
42 if ((*obs)->AsObject() == dataObserver->AsObject()) { in HandleRegisterObserver()
68 auto obs = obsPair->second.begin(); in HandleUnregisterObserver() local
69 for (; obs != obsPair->second.end(); obs++) { in HandleUnregisterObserver()
70 if ((*obs)->AsObject() == dataObserver->AsObject()) { in HandleUnregisterObserver()
74 if (obs == obsPair->second.end()) { in HandleUnregisterObserver()
79 obsPair->second.remove(*obs); in HandleUnregisterObserver()
112 for (auto &obs : obsList) { in HandleNotifyChange() local
113 if (obs != nullptr) { in HandleNotifyChange()
114 obs->OnChangePreferences(const_cast<Uri &>(uri).GetQuery()); in HandleNotifyChange()
[all …]
|
| H A D | dataobs_mgr_inner_ext.cpp | 104 for (const auto &[obs, value] : changeRes) { in HandleNotifyChange()
105 if (obs != nullptr && !value.empty()) { in HandleNotifyChange()
106 obs->OnChangeExt( in HandleNotifyChange()
251 auto obs = dataObserver->AsObject(); in RemoveObserver() local
252 return obs != nullptr && RemoveObserver(obs); in RemoveObserver()
|
| /ohos5.0/foundation/multimedia/player_framework/services/engine/histreamer/transcoder/ |
| H A D | hitranscoder_callback_looper.cpp | 64 obs_ = obs; in StartWithTransCoderEngineObs()
100 auto obs = obs_.lock(); in DoReportCompletedTime() local
101 if (obs) { in DoReportCompletedTime()
119 auto obs = obs_.lock(); in DoReportMediaProgress() local
120 if (obs && !isDropMediaProgress_) { in DoReportMediaProgress()
148 auto obs = obs_.lock(); in DoReportError() local
149 FALSE_RETURN(obs != nullptr); in DoReportError()
157 obs->OnError(ptr->first, ptr->second); in DoReportError()
168 auto obs = obs_.lock(); in DoReportInfo() local
169 FALSE_RETURN(obs != nullptr); in DoReportInfo()
[all …]
|
| H A D | hitranscoder_callback_looper.h | 36 void StartWithTransCoderEngineObs(const std::weak_ptr<ITransCoderEngineObs>& obs);
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/scene/player/standard/ |
| H A D | hiplayer_callback_looper.cpp | 56 void HiPlayerCallbackLooper::StartWithPlayerEngineObs(const std::weak_ptr<IPlayerEngineObs>& obs) in StartWithPlayerEngineObs() argument
58 obs_ = obs; in StartWithPlayerEngineObs()
92 auto obs = obs_.lock(); in DoReportMediaProgress() local
93 if (obs) { in DoReportMediaProgress()
98 obs->OnInfo(INFO_TYPE_POSITION_UPDATE, currentPositionMs, format); in DoReportMediaProgress()
117 auto obs = obs_.lock(); in DoReportError() local
118 if (obs != nullptr) { in DoReportError()
122 obs->OnError(ptr->first, ptr->second); in DoReportError()
134 auto obs = obs_.lock(); in DoReportInfo() local
135 if (obs != nullptr) { in DoReportInfo()
[all …]
|
| H A D | hiplayer_callback_looper.h | 36 void StartWithPlayerEngineObs(const std::weak_ptr<IPlayerEngineObs>& obs);
|
| /ohos5.0/commonlibrary/c_utils/base/src/ |
| H A D | observer.cpp | 29 if (obs.count(o) > 0) { in AddObserver()
33 obs.insert(o); in AddObserver()
39 obs.erase(o); in RemoveObserver()
45 obs.clear(); in RemoveAllObservers()
56 return (int)obs.size(); in GetObserversCount()
73 arrLocal = obs; in NotifyObservers()
|
| /ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/ |
| H A D | rdb_subscriber_manager.cpp | 223 for (auto &obs : callbacks) { in Emit() local
224 if (obs != nullptr) { in Emit()
227 obs->OnChange(changeNode); in Emit()
250 for (auto &obs : obsVector) { in EmitOnEnable() local
251 if (obs.isNotifyOnEnabled_) { in EmitOnEnable()
252 obs.observer_->OnChange(it->second); in EmitOnEnable()
|
| H A D | published_data_subscriber_manager.cpp | 235 for (auto const &obs : callbacks) { in Emit() local
236 results[obs].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData()); in Emit()
270 for (auto &obs : obsVector) { in EmitOnEnable() local
271 if (obs.isNotifyOnEnabled_) { in EmitOnEnable()
273 … results[obs.observer_].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData()); in EmitOnEnable()
274 results[obs.observer_].ownerBundleName_ = value.ownerBundleName_; in EmitOnEnable()
|
| /ohos5.0/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/ |
| H A D | napi_subscriber_manager.cpp | 100 for (auto &obs : callbacks) { in Emit() local
101 if (obs != nullptr) { in Emit()
102 obs->OnChange(changeNode); in Emit()
206 for (auto const &obs : callbacks) { in Emit() local
207 results[obs].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData()); in Emit()
|
| /ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
| H A D | datashare_helper.cpp | 228 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(uri, dataObserver); in RegisterObserverExt() local
229 if (obs == nullptr) { in RegisterObserverExt()
233 ErrCode ret = obsMgrClient->RegisterObserverExt(uri, obs, isDescendants); in RegisterObserverExt()
264 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(uri, dataObserver); in UnregisterObserverExt() local
265 if (obs == nullptr) { in UnregisterObserverExt()
269 ErrCode ret = obsMgrClient->UnregisterObserverExt(uri, obs); in UnregisterObserverExt()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/scrollable/ |
| H A D | scroller_observer_manager.cpp | 19 void ScrollerObserverManager::AddObserver(const ScrollerObserver& obs, int32_t id) in AddObserver() argument
21 observers_.emplace(id, obs); in AddObserver()
|
| H A D | scroller_observer_manager.h | 31 void AddObserver(const ScrollerObserver& obs, int32_t id);
|
| /ohos5.0/foundation/ability/ability_runtime/services/dataobsmgr/include/ |
| H A D | dataobs_mgr_inner_ext.h | 54 … Entry(sptr<IDataAbilityObserver> obs, std::shared_ptr<DeathRecipientRef> deathRef, bool isDes) in Entry()
55 : observer(obs), deathRecipientRef(deathRef), isDescendants(isDes) in Entry()
|
| /ohos5.0/foundation/multimedia/media_foundation/test/scenetest/helper/ |
| H A D | std_audio_recorder.cpp | 66 auto obs = std::make_shared<RecorderEngineObs>(); in CreateAudioRecorder() local
67 recorder->SetObs(obs); in CreateAudioRecorder()
|
| /ohos5.0/foundation/filemanagement/dfs_service/interfaces/kits/js/cloudfilesync/ |
| H A D | cloud_sync_napi.cpp | 383 shared_ptr<CloudNotifyObserver> obs; in CheckRef() local
479 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(uri, observer); in RegisterToObs() local
480 if (obs == nullptr) { in RegisterToObs()
484 ErrCode ret = obsMgrClient->RegisterObserverExt(uri, obs, registerParams.recursion); in RegisterToObs()
563 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(Uri(uri), observer); in UnregisterFromObs() local
564 if (obs == nullptr) { in UnregisterFromObs()
569 ErrCode ret = obsMgrClient->UnregisterObserverExt(Uri(uri), obs); in UnregisterFromObs()
|
| /ohos5.0/base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | event_queue_base.cpp | 428 ObserverTrace obs; in TryExecuteObserverCallback() local
429 obs.source = GetObserverTypeName(observer_.observer); in TryExecuteObserverCallback()
433 obs.stage = STAGE_BEFORE_WAITING.data(); in TryExecuteObserverCallback()
434 consumer = ExecuteObserverCallback(obs, stage, info); in TryExecuteObserverCallback()
441 obs.stage = STAGE_AFTER_WAITING.data(); in TryExecuteObserverCallback()
442 consumer = ExecuteObserverCallback(obs, stage, info); in TryExecuteObserverCallback()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/cj/src/ |
| H A D | relational_store_impl_rdbstore.cpp | 354 auto obs = observers.find(option.event); in UnRegisteredObserver() local
355 if (obs == observers.end()) { in UnRegisteredObserver()
360 auto &list = obs->second; in UnRegisteredObserver()
393 auto obs = observers.find(option.event); in UnRegisteredAllObserver() local
394 if (obs == observers.end()) { in UnRegisteredAllObserver()
|
| /ohos5.0/commonlibrary/c_utils/base/include/ |
| H A D | observer.h | 108 std::set<std::shared_ptr<Observer>> obs; // A collection of observers.
|
| /ohos5.0/foundation/multimedia/player_framework/services/services/engine_intf/ |
| H A D | i_transcoder_engine.h | 81 virtual int32_t SetObs(const std::weak_ptr<ITransCoderEngineObs> &obs) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_store_impl.cpp | 506 auto obs = localObservers_.find(option.event); in UnSubscribeLocal() local
507 if (obs == localObservers_.end()) { in UnSubscribeLocal()
511 auto &list = obs->second; in UnSubscribeLocal()
529 if (obs == localObservers_.end()) { in UnSubscribeLocalAll()
541 if (obs == localSharedObservers_.end()) { in UnSubscribeLocalShared()
551 auto &list = obs->second; in UnSubscribeLocalShared()
573 if (obs == localSharedObservers_.end()) { in UnSubscribeLocalSharedAll()
583 auto &list = obs->second; in UnSubscribeLocalSharedAll()
671 auto obs = localObservers_.find(event); in Notify() local
672 if (obs != localObservers_.end()) { in Notify()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| H A D | napi_rdb_store.cpp | 81 for (auto &obs : observers_[mode]) { in ~RdbStoreProxy() local
82 if (obs == nullptr) { in ~RdbStoreProxy()
89 for (const auto &obs : observers) { in ~RdbStoreProxy() local
90 if (obs == nullptr) { in ~RdbStoreProxy()
97 for (const auto &obs : observers) { in ~RdbStoreProxy() local
98 if (obs == nullptr) { in ~RdbStoreProxy()
104 for (const auto &obs : syncObservers_) { in ~RdbStoreProxy() local
1684 auto obs = observers.find(option.event); in UnRegisteredObserver() local
1685 if (obs == observers.end()) { in UnRegisteredObserver()
1691 auto &list = obs->second; in UnRegisteredObserver()
[all …]
|