/foundation/ability/ability_runtime/test/unittest/frameworks_kits_ability_native_test/ |
H A D | ability_lifecycle_test.cpp | 96 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); in HWTEST_F() local 97 ASSERT_NE(observer, nullptr); in HWTEST_F() 98 lifeCycle_->AddObserver(observer); in HWTEST_F() 113 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); in HWTEST_F() local 114 ASSERT_NE(observer, nullptr); in HWTEST_F() 115 lifeCycle_->AddObserver(observer); in HWTEST_F() 131 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); in HWTEST_F() local 132 ASSERT_NE(observer, nullptr); in HWTEST_F() 133 lifeCycle_->AddObserver(observer); in HWTEST_F() 135 lifeCycle_->RemoveObserver(observer); in HWTEST_F() 150 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 168 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 186 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 204 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 222 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 240 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 258 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 276 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 293 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 310 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 327 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 344 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 361 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local 378 std::shared_ptr<MockLifecycleObserver> observer = std::make_shared<MockLifecycleObserver>(); HWTEST_F() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
H A D | local_subscribe_store_test.cpp | 171 auto observer = std::make_shared<KvStoreObserverUnitTest>(); in HWTEST_F() local 172 observer->ResetToZero(); in HWTEST_F() 174 Status status = kvStore->SubscribeKvStore(subscribeType, observer); in HWTEST_F() 176 EXPECT_EQ(static_cast<int>(observer->GetCallCount()), 0); in HWTEST_F() 178 status = kvStore->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F() 180 observer = nullptr; in HWTEST_F() 185 * @tc.desc: Subscribe fail, observer is null 194 std::shared_ptr<KvStoreObserverUnitTest> observer = nullptr; in HWTEST_F() local 195 Status status = kvStore->SubscribeKvStore(subscribeType, observer); in HWTEST_F() 209 auto observer in HWTEST_F() local 236 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 302 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 345 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 380 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 414 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 461 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 508 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 545 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 582 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 617 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 637 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 679 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 721 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 742 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 772 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 852 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 904 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 950 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 996 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1051 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1086 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1129 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1172 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1213 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1274 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1336 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1397 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1459 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1492 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1532 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1570 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1615 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1662 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1706 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1758 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1814 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1866 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local 1922 auto observer = std::make_shared<KvStoreObserverUnitTest>(); HWTEST_F() local [all...] |
H A D | local_subscribe_device_store_test.cpp | 161 auto observer = std::make_shared<DeviceObserverTest>(); in HWTEST_F() local 162 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in HWTEST_F() 164 EXPECT_EQ(static_cast<int>(observer->GetCallCount()), 0); in HWTEST_F() 166 status = kvStore_->UnSubscribeKvStore(subscribeType, observer); in HWTEST_F() 168 observer = nullptr; in HWTEST_F() 173 * @tc.desc: Subscribe fail, observer is null 182 std::shared_ptr<DeviceObserverTest> observer = nullptr; in HWTEST_F() local 183 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in HWTEST_F() 197 auto observer = std::make_shared<DeviceObserverTest>(); in HWTEST_F() local 199 Status status = kvStore_->SubscribeKvStore(subscribeType, observer); in HWTEST_F() 223 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 289 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 332 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 367 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 402 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 449 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 496 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 533 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 570 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 605 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 625 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 667 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 709 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 730 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 760 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 840 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 892 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 938 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 984 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1038 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1073 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1116 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1159 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1200 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1261 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1323 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1384 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1446 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1479 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1519 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1557 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1602 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1649 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1693 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1745 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1801 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1853 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local 1909 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local [all...] |
/foundation/multimodalinput/input/service/key_command/test/ |
H A D | setting_datashare_test.cpp | 133 sptr<SettingObserver> observer = nullptr;
in HWTEST_F() local 134 ASSERT_NO_FATAL_FAILURE(settingDataShare.ExecRegisterCb(observer));
in HWTEST_F() 148 sptr<SettingObserver> observer = nullptr;
in HWTEST_F() local 149 ASSERT_EQ(settingDataShare.RegisterObserver(observer), RET_ERR);
in HWTEST_F() 163 sptr<SettingObserver> observer = nullptr;
in HWTEST_F() local 164 ASSERT_EQ(settingDataShare.UnregisterObserver(observer), RET_ERR);
in HWTEST_F() 166 observer = new (std::nothrow) SettingObserver;
in HWTEST_F() 167 ASSERT_EQ(settingDataShare.UnregisterObserver(observer), RET_ERR);
in HWTEST_F() 195 SettingObserver observer;
in HWTEST_F() local 197 observer in HWTEST_F() 211 SettingDataShare observer; HWTEST_F() local 233 SettingDataShare observer; HWTEST_F() local 252 SettingDataShare observer; HWTEST_F() local [all...] |
/foundation/ability/ability_runtime/test/moduletest/ui_extension_ability_test/ui_extension_stability_test/ |
H A D | ui_extension_stability_test.cpp | 90 void WaitUntilProcessCreated(const sptr<UIExtensionConnectModuleTestObserver> &observer);
91 void WaitUntilProcessDied(const sptr<UIExtensionConnectModuleTestObserver> &observer);
92 void CheckProcessNotDied(const sptr<UIExtensionConnectModuleTestObserver> &observer);
93 void WaitUntilAbilityForeground(const sptr<UIExtensionConnectModuleTestObserver> &observer);
94 void WaitUntilAbilityBackground(const sptr<UIExtensionConnectModuleTestObserver> &observer);
96 void RegisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer);
97 void UnregisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer);
135 void UIExtensionStabilityTest::RegisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer)
in RegisterApplicationStateObserver() argument 140 auto ret = appMgr_->RegisterApplicationStateObserver(observer, bundleNameList);
in RegisterApplicationStateObserver() 146 void UIExtensionStabilityTest::UnregisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer)
in UnregisterApplicationStateObserver() argument 154 WaitUntilProcessCreated(const sptr<UIExtensionConnectModuleTestObserver> &observer) WaitUntilProcessCreated() argument 165 WaitUntilProcessDied(const sptr<UIExtensionConnectModuleTestObserver> &observer) WaitUntilProcessDied() argument 176 CheckProcessNotDied(const sptr<UIExtensionConnectModuleTestObserver> &observer) CheckProcessNotDied() argument 187 WaitUntilAbilityForeground( const sptr<UIExtensionConnectModuleTestObserver> &observer) WaitUntilAbilityForeground() argument 199 WaitUntilAbilityBackground( const sptr<UIExtensionConnectModuleTestObserver> &observer) WaitUntilAbilityBackground() argument 222 auto observer = sptr<UIExtensionConnectModuleTestObserver>::MakeSptr(); HWTEST_F() local 254 auto observer = sptr<UIExtensionConnectModuleTestObserver>::MakeSptr(); HWTEST_F() local [all...] |
/foundation/ability/ability_runtime/tools/test/unittest/ability_delegator/ |
H A D | test_observer_test.cpp | 38 const std::string MSG = "observer msg"; 51 static void thfunc(TestObserver& observer); 66 void TestObserverTest::thfunc(TestObserver& observer) in thfunc() argument 71 observer.isFinished_ = true; in thfunc() 82 TestObserver observer; in HWTEST_F() local 83 observer.TestFinished(MSG.c_str(), RESULT_CODE); in HWTEST_F() 84 EXPECT_TRUE(observer.isFinished_); in HWTEST_F() 95 TestObserver observer; in HWTEST_F() local 96 EXPECT_EQ(observer.ExecuteShellCommand(CMD.c_str(), TIMEOUT).stdResult.size(), 0); in HWTEST_F() 107 TestObserver observer; in HWTEST_F() local 122 TestObserver observer; HWTEST_F() local 136 std::shared_ptr<TestObserver> observer = std::make_shared<TestObserver>(); HWTEST_F() local [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/test/ |
H A D | account_delegate_test.cpp | 34 // must specify unique name for observer 73 * @tc.desc: subscribe user change, the observer is invalid 84 auto observer = std::make_shared<AccountObserver>(); in HWTEST_F() local 85 observer->SetName(""); in HWTEST_F() 86 status = account->Subscribe(observer); in HWTEST_F() 101 auto observer = std::make_shared<AccountObserver>(); in HWTEST_F() local 102 auto status = account->Subscribe(observer); in HWTEST_F() 104 observer->SetName("Subscribe002Observer"); in HWTEST_F() 105 status = account->Subscribe(observer); in HWTEST_F() 111 * @tc.desc: subscribe user change, the observer i 119 auto observer = std::make_shared<AccountObserver>(); HWTEST_F() local 143 auto observer = std::make_shared<AccountObserver>(); HWTEST_F() local 163 auto observer = std::make_shared<AccountObserver>(); HWTEST_F() local 243 auto observer = std::make_shared<AccountObserver>(); HWTEST_F() local [all...] |
/foundation/ability/ability_runtime/interfaces/inner_api/connectionobs_manager/src/ |
H A D | connection_observer_client_impl.cpp | 26 int32_t ConnectionObserverClientImpl::RegisterObserver(const std::shared_ptr<ConnectionObserver> &observer) in RegisterObserver() argument 28 if (!observer) { in RegisterObserver() 29 TAG_LOGE(AAFwkTag::CONNECTION, "invalid observer"); in RegisterObserver() 41 return AddObserversLocked(observer); in RegisterObserver() 44 int32_t ConnectionObserverClientImpl::UnregisterObserver(const std::shared_ptr<ConnectionObserver> &observer) in UnregisterObserver() argument 46 if (!observer) { in UnregisterObserver() 47 TAG_LOGE(AAFwkTag::CONNECTION, "invalid observer"); in UnregisterObserver() 54 auto ret = RemoveObserversLocked(observer); in UnregisterObserver() 67 TAG_LOGE(AAFwkTag::CONNECTION, "invalid observer"); in GetDlpConnectionInfos() 79 TAG_LOGE(AAFwkTag::CONNECTION, "invalid observer"); in GetConnectionData() 90 auto observer = *it; HandleExtensionConnected() local 101 auto observer = *it; HandleExtensionDisconnected() local 113 auto observer = *it; HandleDlpAbilityOpened() local 124 auto observer = *it; HandleDlpAbilityClosed() local 172 AddObserversLocked(const std::shared_ptr<ConnectionObserver> &observer) AddObserversLocked() argument 182 RemoveObserversLocked(const std::shared_ptr<ConnectionObserver> &observer) RemoveObserversLocked() argument 269 auto observer = *it; NotifyServiceDiedToObservers() local [all...] |
/foundation/ability/ability_runtime/services/abilitymgr/src/ |
H A D | ability_first_frame_state_observer_manager.cpp | 29 const sptr<IAbilityFirstFrameStateObserver> &observer, const std::string &targetBundleName) in AddAbilityFirstFrameStateObserver() 31 if (observer == nullptr || observer->AsObject() == nullptr) { in AddAbilityFirstFrameStateObserver() 32 TAG_LOGE(AAFwkTag::ABILITYMGR, "observer or observer->AsObject is null"); in AddAbilityFirstFrameStateObserver() 38 if (it.first->AsObject() == observer->AsObject()) { in AddAbilityFirstFrameStateObserver() 43 observerMap_.emplace(observer, targetBundleName); in AddAbilityFirstFrameStateObserver() 45 AddObserverDeathRecipient(observer); in AddAbilityFirstFrameStateObserver() 50 void AbilityFirstFrameStateObserverSet::AddObserverDeathRecipient(const sptr<IRemoteBroker> &observer) in AddObserverDeathRecipient() argument 53 if (observer in AddObserverDeathRecipient() 28 AddAbilityFirstFrameStateObserver( const sptr<IAbilityFirstFrameStateObserver> &observer, const std::string &targetBundleName) AddAbilityFirstFrameStateObserver() argument 84 RemoveAbilityFirstFrameStateObserver( const sptr<IAbilityFirstFrameStateObserver> &observer) RemoveAbilityFirstFrameStateObserver() argument 100 RemoveObserverDeathRecipient(const sptr<IRemoteBroker> &observer) RemoveObserverDeathRecipient() argument 155 RegisterAbilityFirstFrameStateObserver( const sptr<IAbilityFirstFrameStateObserver> &observer, const std::string &targetBundleName) RegisterAbilityFirstFrameStateObserver() argument 175 UnregisterAbilityFirstFrameStateObserver( const sptr<IAbilityFirstFrameStateObserver> &observer) UnregisterAbilityFirstFrameStateObserver() argument [all...] |
/foundation/communication/dsoftbus/sdk/frame/common/src/ |
H A D | softbus_client_event_manager.c | 48 COMM_LOGE(COMM_SDK, "create observer list failed"); in EventClientInit() 96 COMM_LOGE(COMM_SDK, "observer count over limit"); in RegisterEventCallback() 101 Observer *observer = (Observer *)SoftBusCalloc(sizeof(Observer)); in RegisterEventCallback() local 102 if (observer == NULL) { in RegisterEventCallback() 103 COMM_LOGE(COMM_SDK, "malloc observer failed"); in RegisterEventCallback() 108 observer->event = event; in RegisterEventCallback() 109 observer->callback = cb; in RegisterEventCallback() 110 observer->userData = (char *)userData; in RegisterEventCallback() 112 ListInit(&observer->node); in RegisterEventCallback() 113 ListAdd(&g_observerList->list, &observer in RegisterEventCallback() 131 Observer *observer = NULL; CLIENT_NotifyObserver() local [all...] |
/foundation/distributeddatamgr/pasteboard/interfaces/ndk/src/ |
H A D | oh_pasteboard.cpp | 39 static bool IsSubscriberValid(OH_PasteboardObserver *observer) in IsSubscriberValid() argument 41 return observer != nullptr && observer->cid == SUBSCRIBER_STRUCT_ID; in IsSubscriberValid() 55 OH_PasteboardObserver *observer = new (std::nothrow) OH_PasteboardObserver(); in OH_PasteboardObserver_Create() local 56 if (observer == nullptr) { in OH_PasteboardObserver_Create() 60 return observer; in OH_PasteboardObserver_Create() 63 int OH_PasteboardObserver_Destroy(OH_PasteboardObserver *observer) in OH_PasteboardObserver_Destroy() argument 65 if (!IsSubscriberValid(observer)) { in OH_PasteboardObserver_Destroy() 68 if (observer->finalize != nullptr) { in OH_PasteboardObserver_Destroy() 69 (observer in OH_PasteboardObserver_Destroy() 76 OH_PasteboardObserver_SetData(OH_PasteboardObserver *observer, void *context, const Pasteboard_Notify callback, const Pasteboard_Finalize finalize) OH_PasteboardObserver_SetData() argument 118 OH_Pasteboard_Subscribe(OH_Pasteboard *pasteboard, int type, const OH_PasteboardObserver *observer) OH_Pasteboard_Subscribe() argument 141 OH_Pasteboard_Unsubscribe(OH_Pasteboard *pasteboard, int type, const OH_PasteboardObserver *observer) OH_Pasteboard_Unsubscribe() argument [all...] |
/foundation/communication/bluetooth/frameworks/inner/include/ |
H A D | bluetooth_observer_map.h | 30 bool Register(int handle, T observer); 31 bool Deregister(T observer); 33 void ForEach(const std::function<void(uint8_t, T)> &observer, int handle); 35 uint8_t GetAdvertiserHandle(T observer); 38 bool IsExistAdvertiserCallback(T observer, int &handle); 63 bool BluetoothObserverMap<T>::Register(int handle, T observer) in Register() argument 71 observers_.insert(std::make_pair(handle, observer)); in Register() 78 observers_.insert(std::make_pair(handle, observer)); in Register() 84 bool BluetoothObserverMap<T>::Deregister(T observer) in Deregister() argument 89 if (it->second == observer) { in Deregister() 101 ForEach(const std::function<void(uint8_t, T)> &observer, int handle) ForEach() argument 112 GetAdvertiserHandle(T observer) GetAdvertiserHandle() argument 162 IsExistAdvertiserCallback(T observer, int &handle) IsExistAdvertiserCallback() argument [all...] |
H A D | bluetooth_observer_list.h | 35 bool Register(std::shared_ptr<T> &observer); 36 bool Deregister(std::shared_ptr<T> &observer); 38 void ForEach(const std::function<void(std::shared_ptr<T>)> &observer); 55 bool BluetoothObserverList<T>::Register(std::shared_ptr<T> &observer) in Register() argument 59 if (*it == observer) { in Register() 63 observers_.push_back(observer); in Register() 68 bool BluetoothObserverList<T>::Deregister(std::shared_ptr<T> &observer) in Deregister() argument 72 if (*it == observer) { in Deregister() 82 void BluetoothObserverList<T>::ForEach(const std::function<void(std::shared_ptr<T>)> &observer) in ForEach() argument 87 observer(i in ForEach() [all...] |
/foundation/ability/ability_runtime/test/moduletest/ui_extension_ability_test/ui_extension_connect_module_test/ |
H A D | ui_extension_connect_module_test.cpp | 90 void WaitUntilProcessCreated(const sptr<UIExtensionConnectModuleTestObserver> &observer); 91 void WaitUntilProcessDied(const sptr<UIExtensionConnectModuleTestObserver> &observer); 92 void CheckProcessNotDied(const sptr<UIExtensionConnectModuleTestObserver> &observer); 93 void WaitUntilAbilityForeground(const sptr<UIExtensionConnectModuleTestObserver> &observer); 94 void WaitUntilAbilityBackground(const sptr<UIExtensionConnectModuleTestObserver> &observer); 96 void RegisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer); 97 void UnregisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer); 135 void UIExtensionConnectModuleTest::RegisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer) in RegisterApplicationStateObserver() argument 140 auto ret = appMgr_->RegisterApplicationStateObserver(observer, bundleNameList); in RegisterApplicationStateObserver() 146 void UIExtensionConnectModuleTest::UnregisterApplicationStateObserver(const sptr<IApplicationStateObserver> &observer) in UnregisterApplicationStateObserver() argument 177 WaitUntilProcessCreated(const sptr<UIExtensionConnectModuleTestObserver> &observer) WaitUntilProcessCreated() argument 188 WaitUntilProcessDied(const sptr<UIExtensionConnectModuleTestObserver> &observer) WaitUntilProcessDied() argument 199 CheckProcessNotDied(const sptr<UIExtensionConnectModuleTestObserver> &observer) CheckProcessNotDied() argument 210 WaitUntilAbilityForeground( const sptr<UIExtensionConnectModuleTestObserver> &observer) WaitUntilAbilityForeground() argument 222 WaitUntilAbilityBackground( const sptr<UIExtensionConnectModuleTestObserver> &observer) WaitUntilAbilityBackground() argument [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/service/src/base/ |
H A D | base_observer_list.h | 30 bool Register(T &observer); 31 bool Deregister(T &observer); 33 void ForEach(const std::function<void(T &)> &observer); 50 bool BaseObserverList<T>::Register(T &observer) in Register() argument 54 if (*it == &observer) { in Register() 59 observers_.push_back(&observer); in Register() 64 bool BaseObserverList<T>::Deregister(T &observer) in Deregister() argument 68 if (*it == &observer) { in Deregister() 78 void BaseObserverList<T>::ForEach(const std::function<void(T &)> &observer) in ForEach() argument 82 observer(*i in ForEach() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
H A D | distributeddb_kv_observer_test.cpp | 107 * @tc.desc: Verify that can register a fresh observer base on kv db. 116 KvStoreObserverImpl observer; in HWTEST_F() local 119 * @tc.steps: step1. Register observer base on kv db. in HWTEST_F() 122 DBStatus status = DistributedTestTools::RegisterObserver(g_observerDelegate, &observer); in HWTEST_F() 125 DBStatus statusRelease = DistributedTestTools::UnRegisterObserver(g_observerDelegate, &observer); in HWTEST_F() 131 * @tc.desc: Verify that can register a null observer on kv db. 141 * @tc.steps: step1. Register a null observer base on kv db. in HWTEST_F() 153 * @tc.desc: Verify that can register only once with the same observer. 162 KvStoreObserverImpl observer; in HWTEST_F() local 165 * @tc.steps: step1. Register observer in HWTEST_F() 279 KvStoreObserverImpl observer; HWTEST_F() local 330 KvStoreObserverImpl observer; HWTEST_F() local 385 KvStoreObserverImpl observer; HWTEST_F() local 519 KvStoreObserverImpl observer; HWTEST_F() local 560 KvStoreObserverImpl observer; HWTEST_F() local 601 KvStoreObserverImpl observer; HWTEST_F() local 637 KvStoreObserverImpl observer; HWTEST_F() local 678 KvStoreObserverImpl observer; HWTEST_F() local 719 KvStoreObserverImpl observer; HWTEST_F() local 761 KvStoreObserverImpl observer; HWTEST_F() local 795 KvStoreObserverImpl observer; HWTEST_F() local 829 KvStoreObserverImpl observer; HWTEST_F() local 1239 KvStoreObserverImpl observer; HWTEST_F() local 1273 KvStoreObserverImpl observer; HWTEST_F() local 1312 KvStoreObserverImpl observer; HWTEST_F() local 1372 KvObserverBatchPerformance(KvStoreObserverImpl &observer, vector<Entry> &entriesBatch) KvObserverBatchPerformance() argument 1398 KvStoreObserverImpl observer; HWTEST_F() local 1446 KvObserverTransactionPerformance(KvStoreObserverImpl &observer, vector<Entry> &entriesBatch) KvObserverTransactionPerformance() argument 1477 KvStoreObserverImpl observer; HWTEST_F() local 1548 KvStoreObserverImpl observer; HWTEST_F() local 1580 KvStoreObserverImpl observer; HWTEST_F() local 1607 KvStoreObserverImpl observer; HWTEST_F() local 1640 KvStoreObserverImpl observer; HWTEST_F() local [all...] |
/foundation/distributeddatamgr/data_share/frameworks/js/napi/common/include/ |
H A D | napi_callbacks_manager.h | 29 std::vector<OperationResult> AddObservers(const std::vector<Key> &keys, const std::shared_ptr<Observer> observer, 30 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer)>, 31 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, 35 const std::shared_ptr<Observer> observer = nullptr, 36 std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, 44 static void DefaultProcess(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, in DefaultProcess() argument 49 ObserverNode(const std::shared_ptr<Observer> &observer) : observer_(observer) in ObserverNode() 53 ObserverNode(const std::shared_ptr<Observer> &observer, bool enabled) in ObserverNode() 54 : observer_(observer), enabled in ObserverNode() 62 AddObservers( const std::vector<Key> &keys, const std::shared_ptr<Observer> observer, std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer)> processOnLocalAdd, std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, std::vector<OperationResult> &)> processOnFirstAdd) AddObservers() argument 97 IsRegistered(const Observer &observer, const std::vector<ObserverNode> &observers) IsRegistered() argument 109 DelObservers( const std::vector<Key> &keys, const std::shared_ptr<Observer> observer, std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &, std::vector<OperationResult> &)> processOnLastDel) DelObservers() argument [all...] |
/foundation/arkui/ace_engine/interfaces/napi/kits/inspector/ |
H A D | js_inspector.cpp | 25 ComponentObserver* observer = nullptr; in GetObserver() local 26 napi_unwrap(env, thisVar, (void**)&observer); in GetObserver() 27 if (!observer) { in GetObserver() 30 observer->Initialize(env, thisVar); in GetObserver() 32 return observer; in GetObserver() 165 ComponentObserver* observer = GetObserver(env, thisVar); 166 if (!observer) { 172 observer->AddCallbackToList(cb, observer->cbLayoutList_, calloutType, env, scope); 174 observer [all...] |
/foundation/ability/form_fwk/services/src/ |
H A D | form_event_handler.cpp | 40 for (auto &observer : sharedThis->observers_) { in ProcessEvent() 41 if (observer == nullptr) { in ProcessEvent() 42 HILOG_ERROR("null observer"); in ProcessEvent() 45 observer->OnEventTimeoutResponse(msg, eventId); in ProcessEvent() 57 void FormEventHandler::RegisterEventTimeoutObserver(const std::shared_ptr<FormEventTimeoutObserver> &observer) in RegisterEventTimeoutObserver() argument 61 auto iter = observers_.find(observer); in RegisterEventTimeoutObserver() 63 HILOG_ERROR("observer repeat attach"); in RegisterEventTimeoutObserver() 66 observers_.emplace(observer); in RegisterEventTimeoutObserver() 69 void FormEventHandler::UnregisterEventTimeoutObserver(const std::shared_ptr<FormEventTimeoutObserver> &observer) in UnregisterEventTimeoutObserver() argument 73 auto iter = observers_.find(observer); in UnregisterEventTimeoutObserver() [all...] |
/foundation/ability/ability_runtime/test/unittest/free_install_observer_manager_test/ |
H A D | free_install_observer_manager_test.cpp | 97 sptr<AbilityRuntime::IFreeInstallObserver> observer; in HWTEST_F() local 98 int32_t res = info->AddObserver(recordId, observer); in HWTEST_F() 113 sptr<AbilityRuntime::IFreeInstallObserver> observer = new IFreeInstallObserverMock(); in HWTEST_F() local 114 int32_t res = freeInstallObserverManager_->AddObserver(recordId, observer); in HWTEST_F() 129 sptr<AbilityRuntime::IFreeInstallObserver> observer; in HWTEST_F() local 130 int32_t res = freeInstallObserverManager_->RemoveObserver(observer); in HWTEST_F() 144 sptr<AbilityRuntime::IFreeInstallObserver> observer = new IFreeInstallObserverMock(); in HWTEST_F() local 145 int32_t res = freeInstallObserverManager_->RemoveObserver(observer); in HWTEST_F() 159 sptr<AbilityRuntime::IFreeInstallObserver> observer = new IFreeInstallObserverMock(); in HWTEST_F() local 160 freeInstallObserverManager_->observerMap_[0] = observer; in HWTEST_F() 212 sptr<AbilityRuntime::IFreeInstallObserver> observer = new IFreeInstallObserverMock(); HWTEST_F() local 230 sptr<AbilityRuntime::IFreeInstallObserver> observer = new IFreeInstallObserverMock(); HWTEST_F() local 261 sptr<AbilityRuntime::IFreeInstallObserver> observer = new IFreeInstallObserverMock(); HWTEST_F() local [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/server/include/ |
H A D | remote_observer_list.h | 33 using DrCallbackFunc = std::function<void(const sptr<T> &observer, Args... args)>; 37 bool Register(const sptr<T> &observer, DrCallbackFunc func, Args... args); 38 bool Deregister(const sptr<T> &observer); 39 void ForEach(const std::function<void(sptr<T>)> &observer); 43 ObserverDeathRecipient(const sptr<T> &observer, RemoteObserverList<T, Args...> *owner); 80 HILOGE("Failed to unlink death recipient from observer"); in ~RemoteObserverList() 88 bool RemoteObserverList<T, Args...>::Register(const sptr<T> &observer, DrCallbackFunc func, Args... args) in Register() argument 94 if (it.first != nullptr && it.first->AsObject() == observer->AsObject()) { in Register() 95 HILOGW("Observer list already contains given observer"); in Register() 101 sptr<ObserverDeathRecipient> dr(new ObserverDeathRecipient(observer, thi in Register() 127 Deregister(const sptr<T> &observer) Deregister() argument 142 ForEach(const std::function<void(sptr<T>)> &observer) ForEach() argument 153 ObserverDeathRecipient( const sptr<T> &observer, RemoteObserverList<T, Args...> *owner) ObserverDeathRecipient() argument [all...] |
/foundation/multimodalinput/input/intention/cooperate/plugin/src/ |
H A D | cooperate_context.cpp | 128 void Context::AddObserver(std::shared_ptr<ICooperateObserver> observer) in AddObserver() argument 130 CHKPV(observer); in AddObserver() 131 observers_.insert(observer); in AddObserver() 134 void Context::RemoveObserver(std::shared_ptr<ICooperateObserver> observer) in RemoveObserver() argument 136 observers_.erase(observer); in RemoveObserver() 272 return std::all_of(observers_.cbegin(), observers_.cend(), [](const auto &observer) { in IsAllowCooperate() 273 return observer->IsAllowCooperate(); in IsAllowCooperate() 279 std::for_each(observers_.cbegin(), observers_.cend(), [&data](const auto &observer) { in OnStartCooperate() 280 return observer->OnStartCooperate(data); in OnStartCooperate() 286 std::for_each(observers_.cbegin(), observers_.cend(), [&data](const auto &observer) { in OnRemoteStartCooperate() [all...] |
/foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/src/ |
H A D | napi_datashare_inner_observer.cpp | 38 auto observer = innerWorker->observer_.lock();
in OnComplete() local 39 if (observer == nullptr || observer->ref_ == nullptr) {
in OnComplete() 45 napi_open_handle_scope(observer->env_, &scope);
in OnComplete() 53 napi_get_reference_value(observer->env_, observer->ref_, &callback);
in OnComplete() 54 napi_get_global(observer->env_, &global);
in OnComplete() 55 napi_get_undefined(observer->env_, &args[0]);
in OnComplete() 57 args[1] = DataShareJSUtils::Convert2JSValue(observer->env_, innerWorker->result_);
in OnComplete() 59 napi_status callStatus = napi_call_function(observer in OnComplete() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
H A D | account_delegate_impl.cpp | 78 Status AccountDelegateImpl::Subscribe(std::shared_ptr<Observer> observer) in Subscribe() argument 81 if (observer == nullptr || observer->Name().empty()) { in Subscribe() 84 if (observerMap_.Contains(observer->Name())) { in Subscribe() 88 auto ret = observerMap_.Insert(observer->Name(), observer); in Subscribe() 97 Status AccountDelegateImpl::Unsubscribe(std::shared_ptr<Observer> observer) in Unsubscribe() argument 100 if (observer == nullptr || observer->Name().empty()) { in Unsubscribe() 103 if (!observerMap_.Contains(observer in Unsubscribe() [all...] |
/foundation/distributeddatamgr/data_share/frameworks/js/napi/observer/src/ |
H A D | napi_observer.cpp | 33 std::shared_ptr<NapiObserver> observer = innerWorker->observer_.lock(); in CallbackFunc() local 34 if (observer == nullptr || observer->ref_ == nullptr) { in CallbackFunc() 40 napi_open_handle_scope(observer->env_, &scope); in CallbackFunc() 49 napi_get_reference_value(observer->env_, observer->ref_, &callback); in CallbackFunc() 50 napi_get_global(observer->env_, &global); in CallbackFunc() 51 napi_get_undefined(observer->env_, ¶m[0]); in CallbackFunc() 52 param[1] = innerWorker->getParam(observer->env_); in CallbackFunc() 53 napi_status callStatus = napi_call_function(observer in CallbackFunc() [all...] |