Home
last modified time | relevance | path

Searched refs:obs (Results 1 - 25 of 46) sorted by relevance

12

/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/notify_test/src/
H A Dnotify_test.cpp88 shared_ptr<TestObserver> obs = make_shared<TestObserver>(); in CheckFileNotify() local
92 sDataShareHelper_->RegisterObserverExt(uri, obs, true); in CheckFileNotify()
95 unique_lock<mutex> lock(obs->mutex_); in CheckFileNotify()
96 if (obs->condition_.wait_for(lock, 2s) == cv_status::no_timeout) { in CheckFileNotify()
97 EXPECT_EQ(obs->changeInfo_.changeType_, static_cast<DataShareObserver::ChangeType>(notifyType)); in CheckFileNotify()
98 EXPECT_EQ(obs->changeInfo_.uris_.size(), 1); in CheckFileNotify()
99 EXPECT_EQ(obs->changeInfo_.uris_.begin()->ToString(), uriStr); in CheckFileNotify()
106 void SolveAlbumNotify(std::shared_ptr<TestObserver> obs, const std::string& assetStr) in SolveAlbumNotify() argument
108 std::vector<uint8_t> data(obs->changeInfo_.size_); in SolveAlbumNotify()
113 std::copy(static_cast<const char*>(obs in SolveAlbumNotify()
140 shared_ptr<TestObserver> obs = make_shared<TestObserver>(); CheckAlbumNotify() local
167 shared_ptr<TestObserver> obs = make_shared<TestObserver>(); CheckCloseAssetNotify() local
201 CheckInfo(shared_ptr<TestObserver> obs, const std::string &uriPrefix, const std::string &uriPostfix, const DataShareObserver::ChangeType &changeType) CheckInfo() argument
256 shared_ptr<TestObserver> obs = make_shared<TestObserver>(); CheckCloudSyncNotify() local
[all...]
/foundation/multimedia/player_framework/services/engine/histreamer/player/
H A Dhiplayer_callback_looper.cpp65 void HiPlayerCallbackLooper::StartWithPlayerEngineObs(const std::weak_ptr<IPlayerEngineObs>& obs) in StartWithPlayerEngineObs() argument
68 obs_ = obs; in StartWithPlayerEngineObs()
129 auto obs = obs_.lock(); in DoReportCompletedTime() local
130 if (obs) { in DoReportCompletedTime()
135 obs->OnInfo(INFO_TYPE_POSITION_UPDATE, playRangeEndTime, format); in DoReportCompletedTime()
140 obs->OnInfo(INFO_TYPE_POSITION_UPDATE, currentPositionMs, format); in DoReportCompletedTime()
154 auto obs = obs_.lock(); in DoReportMediaProgress() local
155 if (obs && !isDropMediaProgress_) { in DoReportMediaProgress()
160 obs->OnInfo(INFO_TYPE_POSITION_UPDATE, currentPositionMs, format); in DoReportMediaProgress()
178 auto obs in DoCollectAmplitude() local
203 auto obs = obs_.lock(); ReportRemainedMaxAmplitude() local
220 auto obs = obs_.lock(); DoReportSystemOperation() local
242 auto obs = obs_.lock(); DoReportError() local
269 auto obs = obs_.lock(); DoReportInfo() local
[all...]
H A Dhiplayer_callback_looper.h39 void StartWithPlayerEngineObs(const std::weak_ptr<IPlayerEngineObs>& obs);
/foundation/ability/ability_runtime/services/dataobsmgr/src/
H A Ddataobs_mgr_inner_pref.cpp41 for (auto obs = obsPair->second.begin(); obs != obsPair->second.end(); obs++) { in HandleRegisterObserver()
42 if ((*obs)->AsObject() == dataObserver->AsObject()) { in HandleRegisterObserver()
43 TAG_LOGE(AAFwkTag::DBOBSMGR, "registered obs:%{public}s", in HandleRegisterObserver()
62 AAFwkTag::DBOBSMGR, "uris no obs:%{public}s", CommonUtils::Anonymous(uri.ToString()).c_str()); in HandleUnregisterObserver()
66 TAG_LOGD(AAFwkTag::DBOBSMGR, "obs num:%{public}zu:%{public}s", obsPair->second.size(), in HandleUnregisterObserver()
68 auto obs = obsPair->second.begin(); in HandleUnregisterObserver() local
69 for (; obs != obsPair->second.end(); obs in HandleUnregisterObserver()
202 auto obs = std::find(value.begin(), value.end(), dataObserver); HaveRegistered() local
[all...]
H A Ddataobs_mgr_inner.cpp41 for (auto obs = obsPair->second.begin(); obs != obsPair->second.end(); obs++) { in HandleRegisterObserver()
42 if ((*obs)->AsObject() == dataObserver->AsObject()) { in HandleRegisterObserver()
43 TAG_LOGE(AAFwkTag::DBOBSMGR, "obs registered:%{public}s", in HandleRegisterObserver()
63 AAFwkTag::DBOBSMGR, "uri no obs:%{public}s", CommonUtils::Anonymous(uri.ToString()).c_str()); in HandleUnregisterObserver()
67 TAG_LOGD(AAFwkTag::DBOBSMGR, "obs num:%{public}zu:%{public}s", obsPair->second.size(), in HandleUnregisterObserver()
69 auto obs = obsPair->second.begin(); in HandleUnregisterObserver() local
70 for (; obs != obsPair->second.end(); obs in HandleUnregisterObserver()
196 auto obs = std::find(value.begin(), value.end(), dataObserver); HaveRegistered() local
[all...]
H A Ddataobs_mgr_inner_ext.cpp99 "uris no obs, changeType:%{public}ud, uris num:%{public}zu," in HandleNotifyChange()
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()
/foundation/multimedia/player_framework/services/engine/histreamer/transcoder/
H A Dhitranscoder_callback_looper.cpp60 void HiTransCoderCallbackLooper::StartWithTransCoderEngineObs(const std::weak_ptr<ITransCoderEngineObs>& obs) in StartWithTransCoderEngineObs() argument
64 obs_ = obs; in StartWithTransCoderEngineObs()
100 auto obs = obs_.lock(); in DoReportCompletedTime() local
101 if (obs) { in DoReportCompletedTime()
106 obs->OnInfo(TransCoderOnInfoType::INFO_TYPE_PROGRESS_UPDATE, currentPositionMs); in DoReportCompletedTime()
119 auto obs = obs_.lock(); in DoReportMediaProgress() local
120 if (obs && !isDropMediaProgress_) { in DoReportMediaProgress()
128 obs->OnInfo(TransCoderOnInfoType::INFO_TYPE_PROGRESS_UPDATE, progress); in DoReportMediaProgress()
148 auto obs = obs_.lock(); in DoReportError() local
149 FALSE_RETURN(obs ! in DoReportError()
168 auto obs = obs_.lock(); DoReportInfo() local
[all...]
H A Dhitranscoder_callback_looper.h36 void StartWithTransCoderEngineObs(const std::weak_ptr<ITransCoderEngineObs>& obs);
/foundation/multimedia/media_foundation/engine/scene/player/standard/
H A Dhiplayer_callback_looper.cpp56 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 ! in DoReportInfo()
[all...]
H A Dhiplayer_callback_looper.h36 void StartWithPlayerEngineObs(const std::weak_ptr<IPlayerEngineObs>& obs);
/foundation/graphic/graphic_3d/lume/metaobject/test/src/interface/
H A DIntfObjectHierarchyObserverTest.cpp383 ObjectHierarchyObserver obs; in HWTEST_F() local
386 obs.Target(interface_pointer_cast<IObject>(meta->GetPropertyContainer()), in HWTEST_F()
388 obs.OnHierarchyChanged([&info](const HierarchyChangedInfo& i) { info = i; }); in HWTEST_F()
408 ObjectHierarchyObserver obs; in HWTEST_F() local
409 EXPECT_THAT(obs.GetAllObserved(), IsEmpty()); in HWTEST_F()
417 EXPECT_TRUE(obs.Target(containerObject)); in HWTEST_F()
418 EXPECT_THAT(obs.GetAllObserved(), UnorderedElementsAre(containerObject, childObject)); in HWTEST_F()
419 EXPECT_THAT(obs.GetAllObserved<IContainer>(), UnorderedElementsAre(container)); in HWTEST_F()
422 EXPECT_THAT(obs.GetAllObserved(), UnorderedElementsAre(containerObject)); in HWTEST_F()
434 ObjectHierarchyObserver obs; in HWTEST_F() local
470 ObjectHierarchyObserver obs; HWTEST_F() local
523 ObjectHierarchyObserver obs; HWTEST_F() local
556 ObjectHierarchyObserver obs; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/
H A Dnapi_subscriber_manager.cpp100 for (auto &obs : callbacks) { in Emit()
101 if (obs != nullptr) { in Emit()
102 obs->OnChange(changeNode); in Emit()
206 for (auto const &obs : callbacks) {
207 results[obs].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Dpublished_data_subscriber_manager.cpp79 // delete all obs by subscriber in DelObservers()
235 for (auto const &obs : callbacks) {
236 results[obs].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
270 for (auto &obs : obsVector) {
271 if (obs.isNotifyOnEnabled_) {
273 results[obs.observer_].datas_.emplace_back(data.key_, data.subscriberId_, data.GetData());
274 results[obs.observer_].ownerBundleName_ = value.ownerBundleName_;
H A Drdb_subscriber_manager.cpp121 // delete all obs by subscriber in DelObservers()
223 for (auto &obs : callbacks) {
224 if (obs != nullptr) {
227 obs->OnChange(changeNode);
250 for (auto &obs : obsVector) {
251 if (obs.isNotifyOnEnabled_) {
252 obs.observer_->OnChange(it->second);
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/
H A Ddatashare_helper.cpp223 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(uri, dataObserver); in RegisterObserverExt() local
224 if (obs == nullptr) { in RegisterObserverExt()
228 ErrCode ret = obsMgrClient->RegisterObserverExt(uri, obs, isDescendants); in RegisterObserverExt()
259 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(uri, dataObserver); in UnregisterObserverExt() local
260 if (obs == nullptr) { in UnregisterObserverExt()
264 ErrCode ret = obsMgrClient->UnregisterObserverExt(uri, obs); in UnregisterObserverExt()
/foundation/ability/ability_runtime/services/dataobsmgr/include/
H A Ddataobs_mgr_inner_ext.h54 Entry(sptr<IDataAbilityObserver> obs, std::shared_ptr<DeathRecipientRef> deathRef, bool isDes) in Entry()
55 : observer(obs), deathRecipientRef(deathRef), isDescendants(isDes) in Entry()
/foundation/multimedia/media_foundation/test/scenetest/helper/
H A Dstd_audio_recorder.cpp66 auto obs = std::make_shared<RecorderEngineObs>(); in CreateAudioRecorder() local
67 recorder->SetObs(obs); in CreateAudioRecorder()
/foundation/multimedia/player_framework/services/services/engine_intf/
H A Di_transcoder_engine.h81 virtual int32_t SetObs(const std::weak_ptr<ITransCoderEngineObs> &obs) = 0;
H A Di_avcodec_engine.h63 virtual int32_t SetObs(const std::weak_ptr<IAVCodecEngineObs> &obs) = 0;
H A Di_recorder_engine.h128 virtual int32_t SetObs(const std::weak_ptr<IRecorderEngineObs> &obs) = 0;
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_store_impl.cpp505 auto obs = localObservers_.find(option.event); in UnSubscribeLocal() local
506 if (obs == localObservers_.end()) { in UnSubscribeLocal()
510 auto &list = obs->second; in UnSubscribeLocal()
527 auto obs = localObservers_.find(option.event); in UnSubscribeLocalAll() local
528 if (obs == localObservers_.end()) { in UnSubscribeLocalAll()
539 auto obs = localSharedObservers_.find(option.event); in UnSubscribeLocalShared() local
540 if (obs == localSharedObservers_.end()) { in UnSubscribeLocalShared()
550 auto &list = obs->second; in UnSubscribeLocalShared()
571 auto obs = localSharedObservers_.find(option.event); in UnSubscribeLocalSharedAll() local
572 if (obs in UnSubscribeLocalSharedAll()
670 auto obs = localObservers_.find(event); Notify() local
[all...]
/foundation/filemanagement/dfs_service/interfaces/kits/js/cloudfilesync/
H A Dcloud_sync_napi.cpp383 shared_ptr<CloudNotifyObserver> obs;
479 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(uri, observer);
480 if (obs == nullptr) {
484 ErrCode ret = obsMgrClient->RegisterObserverExt(uri, obs, registerParams.recursion);
563 sptr<ObserverImpl> obs = ObserverImpl::GetObserver(Uri(uri), observer);
564 if (obs == nullptr) {
569 ErrCode ret = obsMgrClient->UnregisterObserverExt(Uri(uri), obs);
571 LOGE("call obs unregister fail");
594 LOGI("no obs to unregister");
/foundation/filemanagement/user_file_service/services/native/file_access_service/include/
H A Dfile_access_service.h43 ObserverContext(sptr<IFileAccessObserver> obs): obs_(obs) {} in ObserverContext() argument
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/
H A Dnapi_rdb_store.cpp82 for (auto &obs : observers_[mode]) { in ~RdbStoreProxy()
83 if (obs == nullptr) { in ~RdbStoreProxy()
86 rdbStore->UnSubscribe({ static_cast<SubscribeMode>(mode) }, obs.get()); in ~RdbStoreProxy()
90 for (const auto &obs : observers) { in ~RdbStoreProxy()
91 if (obs == nullptr) { in ~RdbStoreProxy()
94 rdbStore->UnSubscribe({ static_cast<SubscribeMode>(DistributedRdb::LOCAL), event }, obs.get()); in ~RdbStoreProxy()
98 for (const auto &obs : observers) { in ~RdbStoreProxy()
99 if (obs == nullptr) { in ~RdbStoreProxy()
102 rdbStore->UnSubscribe({ static_cast<SubscribeMode>(DistributedRdb::LOCAL_SHARED), event }, obs.get()); in ~RdbStoreProxy()
105 for (const auto &obs in ~RdbStoreProxy()
1693 auto obs = observers.find(option.event); UnRegisteredObserver() local
[all...]
/foundation/multimedia/media_foundation/engine/scene/recorder/standard/
H A Dhirecorder_impl.h59 int32_t SetObs(const std::weak_ptr<IRecorderEngineObs>& obs) override;

Completed in 17 milliseconds

12