| /base/request/request/frameworks/native/src/ |
| H A D | request_running_task_count.cpp | 72 observers_.push_back(pNewFwkOb); in AttachObserver()
74 static_cast<int32_t>(observers_.size())); in AttachObserver()
81 auto it = observers_.begin(); in DetachObserver()
82 while (it != observers_.end()) { in DetachObserver()
85 it = observers_.erase(it); in DetachObserver()
100 return !observers_.empty(); in HasObserver()
115 REQUEST_HILOGD("Notify runcount to %{public}d observers.", static_cast<int32_t>(observers_.size())); in NotifyAllObservers()
117 auto it = observers_.begin(); in NotifyAllObservers()
118 while (it != observers_.end()) { in NotifyAllObservers()
|
| /base/msdp/device_status/intention/adapters/ddm_adapter/src/ |
| H A D | ddm_adapter_impl.cpp | 101 observers_.erase(Observer()); in AddBoardObserver()
102 observers_.emplace(observer); in AddBoardObserver()
110 observers_.erase(Observer()); in RemoveBoardObserver()
111 if (auto iter = observers_.find(Observer(observer)); iter != observers_.end()) { in RemoveBoardObserver()
112 observers_.erase(iter); in RemoveBoardObserver()
164 std::for_each(observers_.cbegin(), observers_.cend(), in OnBoardOnline()
177 std::for_each(observers_.cbegin(), observers_ in OnBoardOffline()
[all...] |
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/observer/ |
| H A D | app_event_observer_mgr.cpp | 215 observers_[observerSeq] = observer;
in RegisterObserver()
245 if (observers_.find(observerSeq) == observers_.cend()) {
in UnregisterObserver()
253 observers_.erase(observerSeq);
in UnregisterObserver()
294 if (observers_.empty() || events.empty()) {
in HandleEvents()
299 for (auto it = observers_.cbegin(); it != observers_.cend(); ++it) {
in HandleEvents()
303 for (auto it = observers_.cbegin(); it != observers_.cend(); ++it) {
in HandleEvents()
318 for (auto it = observers_ in HandleTimeout()
[all...] |
| /base/msdp/device_status/intention/cooperate/plugin/src/ |
| H A D | cooperate_context.cpp | 118 observers_.insert(observer); in AddObserver()
123 observers_.erase(observer); in RemoveObserver()
257 return std::all_of(observers_.cbegin(), observers_.cend(), [](const auto &observer) { in IsAllowCooperate()
264 std::for_each(observers_.cbegin(), observers_.cend(), [&data](const auto &observer) { in OnStartCooperate()
271 std::for_each(observers_.cbegin(), observers_.cend(), [&data](const auto &observer) { in OnRemoteStartCooperate()
280 for (const auto &observer : observers_) { in OnTransitionOut()
294 for (const auto &observer : observers_) { in OnTransitionIn()
[all...] |
| /base/hiviewdfx/hiview/base/utility/ |
| H A D | setting_observer_manager.cpp | 86 observers_[paramKey] = observer; in RegisterObserver()
107 observers_.erase(paramKey); in UnregisterObserver()
159 auto iter = observers_.find(paramKey); in GetSettingObserver()
160 if (iter != observers_.end()) { in GetSettingObserver()
|
| /base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/ |
| H A D | dsoftbus_adapter_impl.cpp | 101 observers_.erase(Observer()); in AddObserver()
102 observers_.emplace(observer); in AddObserver()
109 if (auto iter = observers_.find(Observer(observer)); iter != observers_.end()) { in RemoveObserver()
110 observers_.erase(iter); in RemoveObserver()
112 observers_.erase(Observer()); in RemoveObserver()
305 for (const auto &item : observers_) { in OnBind()
330 for (const auto &item : observers_) { in OnShutdown()
486 for (const auto &item : observers_) { in OnConnectedLocked()
579 for (const auto &item : observers_) { in HandlePacket()
[all...] |
| /base/hiviewdfx/hiview/base/utility/include/ |
| H A D | setting_observer_manager.h | 55 std::unordered_map<std::string, sptr<SettingObserver>> observers_; member in OHOS::HiviewDFX::SettingObserverManager
|
| /base/request/request/frameworks/native/include/ |
| H A D | request_running_task_count.h | 69 std::vector<std::shared_ptr<FwkIRunningTaskObserver>> observers_; member in OHOS::Request::FwkRunningTaskCountManager
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/observer/include/ |
| H A D | app_event_observer_mgr.h | 72 std::unique_ptr<ModuleLoader> moduleLoader_; // moduleLoader_ must declared before observers_, or lead to crash
73 std::unordered_map<int64_t, std::shared_ptr<AppEventObserver>> observers_;
member in OHOS::HiviewDFX::AppEventObserverMgr
|
| /base/msdp/device_status/intention/services/device_manager/src/ |
| H A D | device_manager.cpp | 258 for (const auto &observer : observers_) { in OnDeviceAdded()
267 for (const auto &observer : observers_) { in OnDeviceRemoved()
374 auto ret = observers_.insert(observer); in OnAddDeviceObserver()
397 observers_.erase(observer); in OnRemoveDeviceObserver()
|
| /base/msdp/device_status/intention/adapters/dsoftbus_adapter/include/ |
| H A D | dsoftbus_adapter_impl.h | 119 std::set<Observer> observers_; member in OHOS::Msdp::DeviceStatus::final
|
| /base/msdp/device_status/intention/adapters/ddm_adapter/include/ |
| H A D | ddm_adapter_impl.h | 114 std::set<Observer> observers_; member in OHOS::Msdp::DeviceStatus::final
|
| /base/msdp/device_status/intention/services/device_manager/include/ |
| H A D | device_manager.h | 94 std::set<std::weak_ptr<IDeviceObserver>> observers_; member in OHOS::Msdp::DeviceStatus::final
|
| /base/msdp/device_status/intention/cooperate/plugin/include/ |
| H A D | cooperate_context.h | 124 std::set<std::shared_ptr<ICooperateObserver>> observers_; member in OHOS::Msdp::DeviceStatus::Cooperate::final
|
| /base/request/request/test/unittest/cpp_test/fwkTest/src/ |
| H A D | request_manager_impl_test.cpp | 761 FwkRunningTaskCountManager::GetInstance()->observers_.push_back(pNewFwkOb); in HWTEST_F()
767 FwkRunningTaskCountManager::GetInstance()->observers_.clear(); in HWTEST_F()
|
| /base/msdp/device_status/test/unittest/intention/cooperate/src/ |
| H A D | cooperate_plugin_test.cpp | 643 g_context->observers_.clear(); in HWTEST_F()
|