Home
last modified time | relevance | path

Searched refs:observer (Results 1 - 25 of 833) sorted by relevance

12345678910>>...34

/foundation/ability/ability_runtime/test/unittest/frameworks_kits_ability_native_test/
H A Dability_lifecycle_test.cpp96 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 Dlocal_subscribe_store_test.cpp171 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 Dlocal_subscribe_device_store_test.cpp161 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 Dsetting_datashare_test.cpp133 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 Dui_extension_stability_test.cpp90 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 Dtest_observer_test.cpp38 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 Daccount_delegate_test.cpp34 // 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 Dconnection_observer_client_impl.cpp26 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 Dability_first_frame_state_observer_manager.cpp29 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 Dsoftbus_client_event_manager.c48 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 Doh_pasteboard.cpp39 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 Dbluetooth_observer_map.h30 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 Dbluetooth_observer_list.h35 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 Dui_extension_connect_module_test.cpp90 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 Dbase_observer_list.h30 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 Ddistributeddb_kv_observer_test.cpp107 * @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 Dnapi_callbacks_manager.h29 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 Djs_inspector.cpp25 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 Dform_event_handler.cpp40 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 Dfree_install_observer_manager_test.cpp97 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 Dremote_observer_list.h33 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 Dcooperate_context.cpp128 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 Dnapi_datashare_inner_observer.cpp38 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 Daccount_delegate_impl.cpp78 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 Dnapi_observer.cpp33 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_, &param[0]); in CallbackFunc()
52 param[1] = innerWorker->getParam(observer->env_); in CallbackFunc()
53 napi_status callStatus = napi_call_function(observer in CallbackFunc()
[all...]

Completed in 14 milliseconds

12345678910>>...34