/ohos5.0/foundation/barrierfree/accessibility/frameworks/acfwk/src/ |
H A D | accessibility_config_impl.cpp | 467 observers = it->second; in OnAccessibleAbilityManagerCaptionPropertyChanged() 559 observers = it->second; in UpdateCaptionEnabled() 578 observers = it->second; in UpdateScreenMagnificationEnabled() 597 observers = it->second; in UpdateShortKeyEnabled() 616 observers = it->second; in UpdateMouseKeyEnabled() 635 observers = it->second; in UpdateAudioMonoEnabled() 654 observers = it->second; in UpdateAnimationOffEnabled() 674 observers = it->second; in UpdateInvertColorEnabled() 694 observers = it->second; in UpdateHighContrastTextEnabled() 714 observers = it->second; in UpdateDaltonizationStateEnabled() [all …]
|
/ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/connectionobs_manager/src/ |
H A D | connection_observer_client_impl.cpp | 88 auto observers = GetObservers(); in HandleExtensionConnected() local 89 for (auto it = observers.begin(); it != observers.end(); ++it) { in HandleExtensionConnected() 99 auto observers = GetObservers(); in HandleExtensionDisconnected() local 100 for (auto it = observers.begin(); it != observers.end(); ++it) { in HandleExtensionDisconnected() 111 auto observers = GetObservers(); in HandleDlpAbilityOpened() local 112 for (auto it = observers.begin(); it != observers.end(); ++it) { in HandleDlpAbilityOpened() 122 auto observers = GetObservers(); in HandleDlpAbilityClosed() local 123 for (auto it = observers.begin(); it != observers.end(); ++it) { in HandleDlpAbilityClosed() 266 auto observers = GetObservers(); in NotifyServiceDiedToObservers() local 268 for (auto it = observers.begin(); it != observers.end(); ++it) { in NotifyServiceDiedToObservers()
|
/ohos5.0/foundation/barrierfree/accessibility/frameworks/acfwk/include/ |
H A D | accessibility_config_impl.h | 238 …tifyCaptionStateChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 240 …id NotifyCaptionChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 244 …d NotifyShortKeyChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 246 …d NotifyMouseKeyChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 248 …fyShortkeyTargetChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 254 …tifyAudioBalanceChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 261 const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 263 … NotifyAudioMonoChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 265 …tifyAnimationOffChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, 267 …otifyInvertColorChanged(const std::vector<std::shared_ptr<AccessibilityConfigObserver>> &observers, [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
H A D | distributeddb_kv_observer_snap_test.cpp | 874 observers[0].Clear(); in ObserverSnapVerifyInsert() 878 observers[1].Clear(); in ObserverSnapVerifyInsert() 890 observers[0].Clear(); in ObserverSnapVerifyInsertBatch() 892 observers[1].Clear(); in ObserverSnapVerifyInsertBatch() 905 observers[0].Clear(); in ObserverSnapVerifyDelete() 910 observers[1].Clear(); in ObserverSnapVerifyDelete() 924 observers[0].Clear(); in ObserverSnapVerifyUpdate() 929 observers[1].Clear(); in ObserverSnapVerifyUpdate() 941 observers[0].Clear(); in ObserverSnapVerifyUpdate() 961 observers[0].Clear(); in ObserverSnapVerifyDeleteBatch() [all …]
|
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/cj/src/ |
H A D | relational_store_impl_rdbstore.cpp | 291 std::list<std::shared_ptr<RdbStoreObserverImpl>> &observers) in HasRegisteredObserver() argument 293 for (auto &it : observers) { in HasRegisteredObserver() 316 std::list<std::shared_ptr<RdbStoreObserverImpl>>> &observers, in RegisteredObserver() argument 319 observers.try_emplace(option.event); in RegisteredObserver() 326 observers[option.event].push_back(localObserver); in RegisteredObserver() 354 auto obs = observers.find(option.event); in UnRegisteredObserver() 355 if (obs == observers.end()) { in UnRegisteredObserver() 372 observers.erase(option.event); in UnRegisteredObserver() 393 auto obs = observers.find(option.event); in UnRegisteredAllObserver() 394 if (obs == observers.end()) { in UnRegisteredAllObserver() [all …]
|
/ohos5.0/foundation/arkui/ace_engine_lite/frameworks/packages/runtime-core/src/observer/ |
H A D | subject.js | 62 const observers = this._obsMap[key]; 63 if (!observers.has(observer)) { 64 observers.add(observer); 66 observers.delete(observer);
|
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/preferences/src/ |
H A D | napi_preferences.cpp | 495 for (auto &it : observers) { in HasRegisteredObserver() 530 observers.push_back(observer); in RegisteredObserver() 545 auto it = observers.begin(); in UnRegisteredObserver() 546 while (it != observers.end()) { in UnRegisteredObserver() 553 it = observers.erase(it); in UnRegisteredObserver() 576 for (auto &observer : observers) { in UnRegisteredAllObservers() 584 observers.clear(); in UnRegisteredAllObservers() 619 auto &observers = dataObservers_; in RegisteredDataObserver() local 671 auto &observers = dataObservers_; in UnRegisteredDataObserver() local 678 auto it = observers.begin(); in UnRegisteredDataObserver() [all …]
|
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
H A D | rdb_service_proxy.cpp | 312 void RdbServiceProxy::ImportObservers(Observers &observers) in ImportObservers() argument 314 observers.ForEach([this](const std::string &key, const std::list<ObserverParam> &value) { in ImportObservers() 392 …yncObservers_.Compute(name, [this, ¶m, &status, observer](const auto &store, auto &observers) { in RegisterAutoSyncCallback() argument 393 for (const auto &element : observers) { in RegisterAutoSyncCallback() 401 observers.push_back(observer); in RegisterAutoSyncCallback() 403 return !observers.empty(); in RegisterAutoSyncCallback() 431 for (auto it = observers.begin(); it != observers.end();) { in UnregisterAutoSyncCallback() 438 it = observers.erase(it); in UnregisterAutoSyncCallback() 441 return !observers.empty(); in UnregisterAutoSyncCallback() 490 syncObservers_.ComputeIfPresent(storeName, [&result](const auto &key, const auto &observers) { in OnSyncComplete() argument [all …]
|
H A D | rdb_manager_impl.cpp | 148 auto observers = proxy->ExportObservers(); in OnRemoteDied() local 160 proxy->ImportObservers(observers); in OnRemoteDied()
|
/ohos5.0/foundation/communication/bluetooth/frameworks/js/napi/src/ble/ |
H A D | napi_bluetooth_ble_central_manager_callback.cpp | 144 void SysOnScanCallBack(sysBLEMap &observers, const BleScanResult &result) in SysOnScanCallBack() argument 146 auto callbackInfos = observers[REGISTER_SYS_BLE_FIND_DEVICE_TYPE]; in SysOnScanCallBack() 288 auto observers = GetSysBLEObserver(); in OnStartOrStopScanEvent() local 289 if (observers.empty()) { in OnStartOrStopScanEvent() 293 if (observers.find(REGISTER_SYS_BLE_SCAN_TYPE) == observers.end()) { in OnStartOrStopScanEvent() 297 callbackInfos = observers[REGISTER_SYS_BLE_SCAN_TYPE]; in OnStartOrStopScanEvent()
|
/ohos5.0/foundation/ability/ability_runtime/test/fuzztest/abilityfirstframestateobservermanager_fuzzer/ |
H A D | abilityfirstframestateobservermanager_fuzzer.cpp | 54 sptr<IRemoteBroker> observers; in DoSomethingInterestingWithMyAPI() local 62 abilityFirstFrameStateObserverSet->AddObserverDeathRecipient(observers); in DoSomethingInterestingWithMyAPI() 63 abilityFirstFrameStateObserverSet->RemoveObserverDeathRecipient(observers); in DoSomethingInterestingWithMyAPI()
|
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/cj/src/ |
H A D | preferences_impl.cpp | 468 auto &observers = (ConvertToRegisterMode(mode) == RegisterMode::LOCAL_CHANGE) ? in RegisterObserver() local 470 observers.push_back(observer); in RegisterObserver() 477 auto &observers = (ConvertToRegisterMode(mode) == RegisterMode::LOCAL_CHANGE) ? in UnRegisterObserver() local 479 auto it = observers.begin(); in UnRegisterObserver() 484 while (it != observers.end()) { in UnRegisterObserver() 490 it = observers.erase(it); in UnRegisterObserver() 501 auto &observers = (ConvertToRegisterMode(mode) == RegisterMode::LOCAL_CHANGE) ? in UnRegisteredAllObservers() local 509 for (auto &observer : observers) { in UnRegisteredAllObservers() 515 observers.clear(); in UnRegisteredAllObservers()
|
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/cj/include/ |
H A D | relational_store_impl_rdbstore.h | 89 std::list<std::shared_ptr<RdbStoreObserverImpl>>> &observers, 92 std::list<std::shared_ptr<RdbStoreObserverImpl>> &observers); 96 std::list<std::shared_ptr<RdbStoreObserverImpl>>> &observers, 99 std::list<std::shared_ptr<RdbStoreObserverImpl>>> &observers);
|
/ohos5.0/foundation/distributeddatamgr/pasteboard/framework/framework/eventcenter/ |
H A D | event_center.cpp | 55 auto observers = observers_.Find(evt.GetEventId()); in Dispatch() local 56 if (!observers.first) { in Dispatch() 60 for (const auto &observer : observers.second) { in Dispatch()
|
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/eventcenter/ |
H A D | event_center.cpp | 56 auto observers = observers_.Find(evt.GetEventId()); in Dispatch() local 57 if (!observers.first) { in Dispatch() 61 for (const auto &observer : observers.second) { in Dispatch()
|
/ohos5.0/foundation/ability/form_fwk/services/src/ |
H A D | form_observer_record.cpp | 49 std::vector<sptr<IRemoteObject>> observers; in SetFormAddObserver() local 50 observers.emplace_back(callerToken); in SetFormAddObserver() 51 formAddObservers_.emplace(bundleName, observers); in SetFormAddObserver() 70 std::vector<sptr<IRemoteObject>> observers; in SetFormRemoveObserver() local 71 observers.emplace_back(callerToken); in SetFormRemoveObserver() 72 formRemoveObservers_.emplace(bundleName, observers); in SetFormRemoveObserver()
|
/ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/include/ |
H A D | connection_observer_controller.h | 88 auto observers = GetObservers(); in CallObservers() local 89 for (auto& observer : observers) { in CallObservers()
|
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
H A D | device_manager_adapter.cpp | 261 auto observers = GetObservers(); in Online() local 262 for (const auto &item : observers) { // notify db in Online() 271 for (const auto &item : observers) { // judge water version, get device security level in Online() 279 for (const auto &item : observers) { // set compatible identify, sync service meta in Online() 306 std::vector<const AppDeviceChangeListener *> observers; in GetObservers() local 307 observers.reserve(observers_.Size()); in GetObservers() 308 observers_.ForEach([&observers](const auto &key, auto &value) { in GetObservers() 309 observers.emplace_back(value); in GetObservers() 312 return observers; in GetObservers()
|
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/event_monitor/ |
H A D | events_monitor.cpp | 202 auto &observers = eventListenersVect[event]; in NotifyEventToObervers() local 203 for (auto it = observers.begin(); it != observers.end();) { in NotifyEventToObervers() 209 it = observers.erase(it); in NotifyEventToObervers()
|
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/js/napi/sendable_preferences/src/ |
H A D | napi_preferences.cpp | 561 auto &observers = observers_[mode]; in Subscribe() local 563 …observers.begin(), observers.end(), [env = env_, callback](std::shared_ptr<JSObserverImpl> observe… in Subscribe() 569 if (observerIt != observers.end()) { in Subscribe() 582 observers.push_back(jsObserver); in Subscribe() 594 auto &observers = observers_[mode]; in Unsubscribe() local 595 for (auto observer = observers.begin(); observer != observers.end();) { in Unsubscribe() 600 observer = observers.erase(observer); in Unsubscribe()
|
/ohos5.0/foundation/ability/ability_runtime/test/fuzztest/abilityappmgrrenderstateobservermanager_fuzzer/ |
H A D | abilityappmgrrenderstateobservermanager_fuzzer.cpp | 77 sptr<IRenderStateObserver> observers; in DoSomethingInterestingWithMyAPI() local 78 manager->UnregisterRenderStateObserver(observers); in DoSomethingInterestingWithMyAPI()
|
/ohos5.0/foundation/ability/ability_runtime/test/unittest/connection_observer_controller_test/ |
H A D | connection_observer_controller_test.cpp | 154 std::vector<sptr<AbilityRuntime::IConnectionObserver>> observers; variable 156 EXPECT_EQ(res, observers);
|
/ohos5.0/foundation/distributeddatamgr/pasteboard/services/core/src/ |
H A D | pasteboard_service.cpp | 1638 observers = it->second; in AddObserver() 1643 observers->insert(observer); in AddObserver() 1646 static_cast<unsigned int>(observers->size())); in AddObserver() 1661 auto observers = it->second; in RemoveSingleObserver() local 1663 static_cast<unsigned int>(observers->size())); in RemoveSingleObserver() 1664 auto eraseNum = observers->erase(observer); in RemoveSingleObserver() 1678 auto observers = it->second; in RemoveAllObserver() local 1680 static_cast<unsigned int>(observers->size())); in RemoveAllObserver() 1836 for (auto &observers : observerLocalChangedMap_) { in NotifyObservers() local 1843 for (auto &observers : observerEventMap_) { in NotifyObservers() local [all …]
|
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/server/src/ |
H A D | bluetooth_a2dp_sink_server.cpp | 41 void SetObserver(RemoteObserverList<IBluetoothA2dpSinkObserver> *observers) in SetObserver() argument 43 observers_ = observers; in SetObserver()
|
/ohos5.0/foundation/communication/bluetooth/frameworks/inner/src/ |
H A D | bluetooth_pan.cpp | 36 explicit PanInnerObserver(BluetoothObserverList<PanObserver> &observers) : observers_(observers) in PanInnerObserver() argument
|