| /foundation/multimodalinput/input/service/subscriber/src/ |
| H A D | key_subscriber_handler.cpp | 128 auto subscriber = std::make_shared<Subscriber>(subscribeId, sess, keyOption); in SubscribeKeyEvent() local
130 auto ret = AddKeyGestureSubscriber(subscriber, keyOption); in SubscribeKeyEvent()
136 auto ret = AddSubscriber(subscriber, keyOption, true); in SubscribeKeyEvent()
186 std::shared_ptr<Subscriber> subscriber, std::shared_ptr<KeyOption> keyOption) in AddKeyGestureSubscriber()
189 CHKPR(subscriber, RET_ERR); in AddKeyGestureSubscriber()
190 CHKPR(subscriber->sess_, RET_ERR); in AddKeyGestureSubscriber()
191 subscriber->timerId_ = keyGestureMgr_.AddKeyGesture(subscriber->sess_->GetPid(), keyOption, in AddKeyGestureSubscriber()
192 [this, subscriber](std::shared_ptr<KeyEvent> keyEvent) { in AddKeyGestureSubscriber()
193 NotifySubscriber(keyEvent, subscriber); in AddKeyGestureSubscriber()
185 AddKeyGestureSubscriber( std::shared_ptr<Subscriber> subscriber, std::shared_ptr<KeyOption> keyOption) AddKeyGestureSubscriber() argument
218 auto subscriber = *innerIter; RemoveKeyGestureSubscriber() local
275 DeleteShortcutId(std::shared_ptr<Subscriber> subscriber) DeleteShortcutId() argument
302 auto subscriber = std::make_shared<Subscriber>(subscribeId, sess, keyOption); SubscribeHotkey() local
323 AddSubscriber(std::shared_ptr<Subscriber> subscriber, std::shared_ptr<KeyOption> option, bool isSystem) AddSubscriber() argument
627 auto subscriber = *inner; OnSessionDelete() local
781 NotifySubscriber(std::shared_ptr<KeyEvent> keyEvent, const std::shared_ptr<Subscriber> &subscriber) NotifySubscriber() argument
826 AddTimer(const std::shared_ptr<Subscriber> &subscriber, const std::shared_ptr<KeyEvent> &keyEvent) AddTimer() argument
881 ClearTimer(const std::shared_ptr<Subscriber> &subscriber) ClearTimer() argument
899 OnTimer(const std::shared_ptr<Subscriber> subscriber) OnTimer() argument
969 SubscriberNotifyNap(const std::shared_ptr<Subscriber> subscriber) SubscriberNotifyNap() argument
1149 HandleKeyUpWithDelay(std::shared_ptr<KeyEvent> keyEvent, const std::shared_ptr<Subscriber> &subscriber) HandleKeyUpWithDelay() argument
1174 PrintKeyUpLog(const std::shared_ptr<Subscriber> &subscriber) PrintKeyUpLog() argument
[all...] |
| H A D | switch_subscriber_handler.cpp | 90 auto subscriber = std::make_shared<Subscriber>(subscribeId, sess, switchType); in SubscribeSwitchEvent() local
91 InsertSubScriber(std::move(subscriber)); in SubscribeSwitchEvent()
120 for (const auto &subscriber : subscribers_) { in OnSubscribeSwitchEvent()
121 if (subscriber->switchType_ == switchEvent->GetSwitchType() || in OnSubscribeSwitchEvent()
122 (subscriber->switchType_ == SwitchEvent::SwitchType::SWITCH_DEFAULT && in OnSubscribeSwitchEvent()
124 NotifySubscriber(switchEvent, subscriber); in OnSubscribeSwitchEvent()
169 const std::shared_ptr<Subscriber> &subscriber) in NotifySubscriber()
173 CHKPV(subscriber); in NotifySubscriber()
178 if (subscriber->sess_ == nullptr) { in NotifySubscriber()
182 int32_t fd = subscriber in NotifySubscriber()
168 NotifySubscriber(std::shared_ptr<SwitchEvent> switchEvent, const std::shared_ptr<Subscriber> &subscriber) NotifySubscriber() argument
217 std::shared_ptr<Subscriber> subscriber = item; Dump() local
[all...] |
| /foundation/resourceschedule/background_task_mgr/services/test/unittest/ |
| H A D | bg_transient_task_mgr_test.cpp | 49 auto subscriber = std::make_shared<TestBackgroundTaskSubscriber>(); in HWTEST_F() local
50 auto ret = DelayedSingleton<BgTransientTaskMgr>::GetInstance()->SubscribeBackgroundTask(subscriber->GetImpl()); in HWTEST_F()
74 auto subscriber = std::make_shared<TestBackgroundTaskSubscriber>(); in HWTEST_F() local
75 auto ret = DelayedSingleton<BgTransientTaskMgr>::GetInstance()->SubscribeBackgroundTask(subscriber->GetImpl()); in HWTEST_F()
78 ret = DelayedSingleton<BgTransientTaskMgr>::GetInstance()->SubscribeBackgroundTask(subscriber->GetImpl()); in HWTEST_F()
90 auto subscriber = std::make_shared<TestBackgroundTaskSubscriber>(); in HWTEST_F() local
91 auto ret = DelayedSingleton<BgTransientTaskMgr>::GetInstance()->SubscribeBackgroundTask(subscriber->GetImpl()); in HWTEST_F()
96 ret = DelayedSingleton<BgTransientTaskMgr>::GetInstance()->UnsubscribeBackgroundTask(subscriber->GetImpl()); in HWTEST_F()
108 auto subscriber = std::make_shared<TestBackgroundTaskSubscriber>(); in HWTEST_F() local
109 auto ret = DelayedSingleton<BgTransientTaskMgr>::GetInstance()->UnsubscribeBackgroundTask(subscriber in HWTEST_F()
[all...] |
| /foundation/resourceschedule/device_standby/interfaces/innerkits/test/unittest/ |
| H A D | standby_client_unit_test.cpp | 56 sptr<IStandbyServiceSubscriber> subscriber = new (std::nothrow) StandbyServiceSubscriberStub(); in HWTEST_F() local
57 EXPECT_NE(StandbyServiceClient::GetInstance().SubscribeStandbyCallback(subscriber), ERR_OK); in HWTEST_F()
58 StandbyServiceClient::GetInstance().SubscribeStandbyCallback(subscriber); in HWTEST_F()
59 EXPECT_NE(StandbyServiceClient::GetInstance().UnsubscribeStandbyCallback(subscriber), ERR_OK); in HWTEST_F()
60 EXPECT_NE(StandbyServiceClient::GetInstance().UnsubscribeStandbyCallback(subscriber), ERR_OK); in HWTEST_F()
153 sptr<StandbyServiceSubscriberStub> subscriber = new (std::nothrow) StandbyServiceSubscriberStub(); in HWTEST_F() local
157 subscriber->OnRemoteRequestInner( in HWTEST_F()
159 subscriber->OnRemoteRequestInner( in HWTEST_F()
161 EXPECT_NE(subscriber->HandleOnDeviceIdleMode(data), ERR_OK); in HWTEST_F()
162 subscriber in HWTEST_F()
[all...] |
| /foundation/resourceschedule/background_task_mgr/services/efficiency_resources/src/ |
| H A D | resources_subscriber_mgr.cpp | 32 ErrCode ResourcesSubscriberMgr::AddSubscriber(const sptr<IBackgroundTaskSubscriber>& subscriber) in AddSubscriber() argument
34 BGTASK_LOGD("ResourcesSubscriberMgr start subscriber"); in AddSubscriber()
35 if (subscriber == NULL) { in AddSubscriber()
36 BGTASK_LOGI("subscriber is null"); in AddSubscriber()
39 auto remote = subscriber->AsObject(); in AddSubscriber()
41 BGTASK_LOGE("remote in subscriber is null"); in AddSubscriber()
51 [&remote](const auto &subscriber) { return subscriber->AsObject() == remote; }); in AddSubscriber()
53 BGTASK_LOGE("subscriber has already exist"); in AddSubscriber()
57 subscriberList_.emplace_back(subscriber); in AddSubscriber()
65 RemoveSubscriber(const sptr<IBackgroundTaskSubscriber>& subscriber) RemoveSubscriber() argument
[all...] |
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/src/ |
| H A D | persistent_data_controller.cpp | 43 std::vector<OperationResult> PersistentDataController::SubscribeRdbData(void *subscriber, in SubscribeRdbData() argument
52 return RdbSubscriberManager::GetInstance().AddObservers(subscriber, proxy, uris, templateId, callback); in SubscribeRdbData()
55 std::vector<OperationResult> PersistentDataController::UnSubscribeRdbData(void *subscriber, in UnSubscribeRdbData() argument
65 return RdbSubscriberManager::GetInstance().DelObservers(subscriber, proxy); in UnSubscribeRdbData()
67 return RdbSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, templateId); in UnSubscribeRdbData()
70 std::vector<OperationResult> PersistentDataController::EnableSubscribeRdbData(void *subscriber, in EnableSubscribeRdbData() argument
78 return RdbSubscriberManager::GetInstance().EnableObservers(subscriber, proxy, uris, templateId); in EnableSubscribeRdbData()
81 std::vector<OperationResult> PersistentDataController::DisableSubscribeRdbData(void *subscriber, in DisableSubscribeRdbData() argument
89 return RdbSubscriberManager::GetInstance().DisableObservers(subscriber, proxy, uris, templateId); in DisableSubscribeRdbData()
|
| H A D | published_data_controller.cpp | 43 std::vector<OperationResult> PublishedDataController::SubscribePublishedData(void *subscriber, in SubscribePublishedData() argument
52 return PublishedDataSubscriberManager::GetInstance().AddObservers(subscriber, proxy, uris, subscriberId, callback); in SubscribePublishedData()
55 std::vector<OperationResult> PublishedDataController::UnSubscribePublishedData(void *subscriber, in UnSubscribePublishedData() argument
64 return PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, proxy); in UnSubscribePublishedData()
66 return PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, subscriberId); in UnSubscribePublishedData()
69 std::vector<OperationResult> PublishedDataController::EnableSubscribePublishedData(void *subscriber, in EnableSubscribePublishedData() argument
77 return PublishedDataSubscriberManager::GetInstance().EnableObservers(subscriber, proxy, uris, subscriberId); in EnableSubscribePublishedData()
80 std::vector<OperationResult> PublishedDataController::DisableSubscribePublishedData(void *subscriber, in DisableSubscribePublishedData() argument
88 return PublishedDataSubscriberManager::GetInstance().DisableObservers(subscriber, proxy, uris, subscriberId); in DisableSubscribePublishedData()
|
| /foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/ |
| H A D | abnormal_branch_test.cpp | 149 void *subscriber = nullptr; in HWTEST_F() local
154 std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().AddObservers(subscriber, in HWTEST_F()
163 void *subscriber = nullptr; in HWTEST_F() local
168 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().AddObservers(subscriber, proxy, uris, in HWTEST_F()
177 void *subscriber = nullptr; in HWTEST_F() local
181 std::vector<OperationResult> results = PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, in HWTEST_F()
184 results = PublishedDataSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, subscriberId); in HWTEST_F()
192 void *subscriber = nullptr; in HWTEST_F() local
196 std::vector<OperationResult> results = RdbSubscriberManager::GetInstance().DelObservers(subscriber, proxy, uris, in HWTEST_F()
199 results = RdbSubscriberManager::GetInstance().DelObservers(subscriber, prox in HWTEST_F()
207 void *subscriber = nullptr; HWTEST_F() local
220 void *subscriber = nullptr; HWTEST_F() local
233 void *subscriber = nullptr; HWTEST_F() local
246 void *subscriber = nullptr; HWTEST_F() local
[all...] |
| /foundation/ability/ability_runtime/test/unittest/ability_manager_event_subscriber_test/ |
| H A D | ability_manager_event_subscriber_test.cpp | 53 auto subscriber = std::make_shared<AbilityManagerEventSubscriber>( in HWTEST_F() local
57 subscriber->OnReceiveEvent(data); in HWTEST_F()
58 EXPECT_NE(subscriber->callback_, nullptr); in HWTEST_F()
60 subscriber->OnReceiveEvent(data); in HWTEST_F()
61 EXPECT_NE(subscriber->userScreenUnlockCallback_, nullptr); in HWTEST_F()
|
| /foundation/barrierfree/accessibility/services/test/mock/ |
| H A D | mock_common_event_manager.cpp | 41 const std::shared_ptr<CommonEventSubscriber>& subscriber) in PublishCommonEvent()
46 bool CommonEventManager::SubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber>& subscriber) in SubscribeCommonEvent() argument
49 subscriberMOCK_ = subscriber; in SubscribeCommonEvent()
53 bool CommonEventManager::UnSubscribeCommonEvent(const std::shared_ptr<CommonEventSubscriber>& subscriber) in UnSubscribeCommonEvent() argument
56 if (subscriberMOCK_ == subscriber) { in UnSubscribeCommonEvent()
40 PublishCommonEvent(const CommonEventData& data, const CommonEventPublishInfo& publishInfo, const std::shared_ptr<CommonEventSubscriber>& subscriber) PublishCommonEvent() argument
|
| /foundation/distributeddatamgr/data_share/frameworks/native/common/include/ |
| H A D | callbacks_manager.h | 37 std::vector<OperationResult> AddObservers(const std::vector<Key> &keys, void *subscriber,
43 std::vector<OperationResult> DelObservers(const std::vector<Key> &keys, void *subscriber,
47 std::vector<OperationResult> DelObservers(void *subscriber,
51 std::vector<OperationResult> EnableObservers(const std::vector<Key> &keys, void *subscriber,
55 std::vector<OperationResult> DisableObservers(const std::vector<Key> &keys, void *subscriber,
73 ObserverNode(const std::shared_ptr<Observer> &observer, void *subscriber) in ObserverNode()
74 : observer_(observer), subscriber_(subscriber) in ObserverNode()
80 void DelLocalObservers(const Key &key, void *subscriber, std::vector<Key> &lastDelKeys,
82 void DelLocalObservers(void *subscriber, std::vector<Key> &lastDelKeys, std::vector<OperationResult> &result);
89 void *subscriber, cons in AddObservers()
88 AddObservers(const std::vector<Key> &keys, void *subscriber, 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
132 DelLocalObservers(void *subscriber, std::vector<Key> &lastDelKeys, std::vector<OperationResult> &result) DelLocalObservers() argument
141 DelLocalObservers(const Key &key, void *subscriber, std::vector<Key> &lastDelKeys, std::vector<OperationResult> &result) DelLocalObservers() argument
166 DelObservers(void *subscriber, std::function<void(const std::vector<Key> &, std::vector<OperationResult> &)> processOnLastDel) DelObservers() argument
186 DelObservers(const std::vector<Key> &keys, void *subscriber, std::function<void(const std::vector<Key> &, std::vector<OperationResult> &)> processOnLastDel) DelObservers() argument
225 EnableObservers( const std::vector<Key> &keys, void *subscriber, std::function<void(std::map<Key, std::vector<ObserverNodeOnEnabled>> &)> enableLocalFunc, std::function<void(const std::vector<Key> &, std::vector<OperationResult> &)> enableServiceFunc) EnableObservers() argument
273 DisableObservers(const std::vector<Key> &keys, void *subscriber, std::function<void(const std::vector<Key> &, std::vector<OperationResult> &)> processOnLastDisable) DisableObservers() argument
[all...] |
| /foundation/arkui/ace_engine/advanced_ui_component/fullscreenlaunchcomponent/interfaces/ |
| H A D | fullscreenlaunchcomponent.js | 34 this.subscriber = null;
55 if (u.subscriber !== undefined) {
56 this.subscriber = u.subscriber;
87 hilog.error(0x3900, 'FullScreenLaunchComponent', 'Failed to create subscriber, err: %{public}s.', JSON.stringify(t));
91 hilog.error(0x3900, 'FullScreenLaunchComponent', 'Failed to create subscriber, data is null.');
94 this.subscriber = u;
95 commonEventManager.subscribe(this.subscriber, (w, x) => {
107 if (this.subscriber !== null) {
108 commonEventManager.unsubscribe(this.subscriber, (
[all...] |
| /foundation/arkui/ace_engine/advanced_ui_component/innerfullscreenlaunchcomponent/interfaces/ |
| H A D | innerfullscreenlaunchcomponent.js | 41 this.subscriber = null;
70 if (c1.subscriber !== undefined) {
71 this.subscriber = c1.subscriber;
99 hilog.error(0x3900, 'InnerFullScreenLaunchComponent', 'Failed to create subscriber, err: %{public}s.', u.message);
103 hilog.error(0x3900, 'InnerFullScreenLaunchComponent', 'Failed to create subscriber, data is null.');
106 this.subscriber = v;
107 commonEventManager.subscribe(this.subscriber, (x, y) => {
119 if (this.subscriber !== null) {
120 commonEventManager.unsubscribe(this.subscriber, (
[all...] |
| /foundation/arkui/advanced_ui_component/innerfullscreenlaunchcomponent/interfaces/ |
| H A D | innerfullscreenlaunchcomponent.js | 41 this.subscriber = null;
70 if (c1.subscriber !== undefined) {
71 this.subscriber = c1.subscriber;
99 hilog.error(0x3900, 'InnerFullScreenLaunchComponent', 'Failed to create subscriber, err: %{public}s.', u.message);
103 hilog.error(0x3900, 'InnerFullScreenLaunchComponent', 'Failed to create subscriber, data is null.');
106 this.subscriber = v;
107 commonEventManager.subscribe(this.subscriber, (x, y) => {
119 if (this.subscriber !== null) {
120 commonEventManager.unsubscribe(this.subscriber, (
[all...] |
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/controller/service/include/ |
| H A D | published_data_controller.h | 34 std::vector<OperationResult> SubscribePublishedData(void *subscriber, const std::vector<std::string> &uris,
37 std::vector<OperationResult> UnSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris,
40 std::vector<OperationResult> EnableSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris,
43 std::vector<OperationResult> DisableSubscribePublishedData(void *subscriber, const std::vector<std::string> &uris,
|
| H A D | persistent_data_controller.h | 34 std::vector<OperationResult> SubscribeRdbData(void *subscriber, const std::vector<std::string> &uris,
37 std::vector<OperationResult> UnSubscribeRdbData(void *subscriber, const std::vector<std::string> &uris,
40 std::vector<OperationResult> EnableSubscribeRdbData(void *subscriber, const std::vector<std::string> &uris,
43 std::vector<OperationResult> DisableSubscribeRdbData(void *subscriber, const std::vector<std::string> &uris,
|
| /foundation/filemanagement/dfs_service/test/unittests/cloudsync_sa/sync_rule/ |
| H A D | battery_status_listener_test.cpp | 117 auto subscriber = std::make_shared<BatteryStatusSubscriber>(EventFwk::CommonEventSubscribeInfo(), in HWTEST_F() local
119 subscriber->OnReceiveEvent(eventData); in HWTEST_F()
143 auto subscriber = std::make_shared<BatteryStatusSubscriber>(EventFwk::CommonEventSubscribeInfo(), in HWTEST_F() local
145 subscriber->OnReceiveEvent(eventData); in HWTEST_F()
169 auto subscriber = std::make_shared<BatteryStatusSubscriber>(EventFwk::CommonEventSubscribeInfo(), in HWTEST_F() local
171 subscriber->OnReceiveEvent(eventData); in HWTEST_F()
195 auto subscriber = std::make_shared<BatteryStatusSubscriber>(EventFwk::CommonEventSubscribeInfo(), in HWTEST_F() local
197 subscriber->OnReceiveEvent(eventData); in HWTEST_F()
|
| /foundation/multimodalinput/input/service/subscriber/test/ |
| H A D | key_subscriber_handler_test.cpp | 244 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); in HWTEST_F() local
245 ASSERT_NO_FATAL_FAILURE(handler.DumpSubscriber(fd, subscriber)); in HWTEST_F()
355 * @tc.desc: Test remove subscriber
468 * @tc.desc: Test notify key down subscriber
580 * @tc.desc: Test add subscriber
590 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); in HWTEST_F() local
592 handler.AddSubscriber(subscriber, option, true); in HWTEST_F()
594 ASSERT_NE(it->second.front(), subscriber); in HWTEST_F()
645 * @tc.desc: Test notify key up subscriber
756 * @tc.desc: Test clear subscriber time
786 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
804 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
842 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
905 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
1288 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1384 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1428 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1456 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1480 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1509 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1539 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1569 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1733 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
1754 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
1785 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
1828 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2129 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2147 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(3, sess, keyOption); HWTEST_F() local
2183 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(3, sess, keyOption); HWTEST_F() local
2238 auto subscriber = *innerIter; HWTEST_F() local
2281 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2302 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2360 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2387 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2409 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2436 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2467 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2489 auto subscriber = std::make_shared<OHOS::MMI::KeySubscriberHandler::Subscriber>(1, sess, keyOption); HWTEST_F() local
2552 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
2571 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
2593 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
2615 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
2637 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
2663 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
2684 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
2704 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
2724 std::shared_ptr<KeySubscriberHandler::Subscriber> subscriber = HWTEST_F() local
[all...] |
| H A D | switch_subscriber_handler_test.cpp | 135 auto subscriber = std::make_shared<SwitchSubscriberHandler::Subscriber>( in HWTEST_F() local
137 ASSERT_NE(subscriber, nullptr); in HWTEST_F()
139 switchSubscriberHandler->InsertSubScriber(subscriber); in HWTEST_F()
289 auto subscriber = std::make_shared<SwitchSubscriberHandler::Subscriber>( in HWTEST_F() local
291 ASSERT_NE(subscriber, nullptr); in HWTEST_F()
297 switchSubscriberHandler->InsertSubScriber(subscriber); in HWTEST_F()
346 auto subscriber = std::make_shared<SwitchSubscriberHandler::Subscriber>( in HWTEST_F() local
348 ASSERT_NE(subscriber, nullptr); in HWTEST_F()
352 switchSubscriberHandler->NotifySubscriber(nullptr, subscriber); in HWTEST_F()
354 switchSubscriberHandler->NotifySubscriber(switchEvent, subscriber); in HWTEST_F()
395 auto subscriber = std::make_shared<SwitchSubscriberHandler::Subscriber>( HWTEST_F() local
[all...] |
| /foundation/resourceschedule/device_standby/services/notification/src/ |
| H A D | standby_state_subscriber.cpp | 41 ErrCode StandbyStateSubscriber::AddSubscriber(const sptr<IStandbyServiceSubscriber>& subscriber) in AddSubscriber() argument
43 STANDBYSERVICE_LOGD("StandbyStateSubscriber start subscriber"); in AddSubscriber()
44 if (subscriber == NULL) { in AddSubscriber()
45 STANDBYSERVICE_LOGI("subscriber is null"); in AddSubscriber()
48 auto remote = subscriber->AsObject(); in AddSubscriber()
50 STANDBYSERVICE_LOGE("remote in subscriber is null"); in AddSubscriber()
60 STANDBYSERVICE_LOGE("subscriber has already exist"); in AddSubscriber()
64 subscriberList_.emplace_back(subscriber); in AddSubscriber()
71 ErrCode StandbyStateSubscriber::RemoveSubscriber(const sptr<IStandbyServiceSubscriber>& subscriber) in RemoveSubscriber() argument
73 if (subscriber in RemoveSubscriber()
[all...] |
| /foundation/multimodalinput/input/service/subscriber/include/ |
| H A D | key_subscriber_handler.h | 78 void DumpSubscriber(int32_t fd, std::shared_ptr<Subscriber> subscriber) const;
87 const std::shared_ptr<Subscriber> &subscriber);
88 bool AddTimer(const std::shared_ptr<Subscriber> &subscriber, const std::shared_ptr<KeyEvent> &keyEvent);
89 void ClearTimer(const std::shared_ptr<Subscriber> &subscriber);
90 void OnTimer(const std::shared_ptr<Subscriber> subscriber);
99 void HandleKeyUpWithDelay(std::shared_ptr<KeyEvent> keyEvent, const std::shared_ptr<Subscriber> &subscriber);
100 void PrintKeyUpLog(const std::shared_ptr<Subscriber> &subscriber);
101 void SubscriberNotifyNap(const std::shared_ptr<Subscriber> subscriber);
104 int32_t AddKeyGestureSubscriber(std::shared_ptr<Subscriber> subscriber, std::shared_ptr<KeyOption> option);
113 void DeleteShortcutId(std::shared_ptr<Subscriber> subscriber);
[all...] |
| /foundation/resourceschedule/background_task_mgr/interfaces/test/unittest/bgtask_manager_client_test/ |
| H A D | bgtask_client_unit_test.cpp | 373 auto subscriber = TestBackgroundTaskSubscriber(); in HWTEST_F() local
374 auto subscriberImpl = std::make_shared<BackgroundTaskSubscriber::BackgroundTaskSubscriberImpl>(subscriber); in HWTEST_F()
413 auto subscriber = BackgroundTaskSubscriber(); in HWTEST_F() local
414 subscriber.OnConnected(); in HWTEST_F()
415 subscriber.OnDisconnected(); in HWTEST_F()
416 subscriber.OnTransientTaskStart(nullptr); in HWTEST_F()
417 subscriber.OnTransientTaskEnd(nullptr); in HWTEST_F()
418 subscriber.OnTransientTaskErr(nullptr); in HWTEST_F()
419 subscriber.OnAppTransientTaskStart(nullptr); in HWTEST_F()
420 subscriber in HWTEST_F()
[all...] |
| /foundation/resourceschedule/memmgr/test/unittest/phone/ |
| H A D | purgeable_memory_manager_test.cpp | 186 auto subscriber = AppStateSubscriberTest();
in HWTEST_F() local
187 auto subscriberImpl = std::make_shared<AppStateSubscriber::AppStateSubscriberImpl>(subscriber);
in HWTEST_F()
191 EXPECT_EQ(subscriber.OnConnectedCallTimes, 1);
in HWTEST_F()
193 EXPECT_EQ(subscriber.OnDisconnectedCallTimes, 1);
in HWTEST_F()
196 EXPECT_EQ(subscriber.OnTrimCallTimes, 1);
in HWTEST_F()
201 EXPECT_EQ(subscriber.OnAppStateChangedCallTimes, 1);
in HWTEST_F()
203 EXPECT_EQ(subscriber.ForceReclaimCallTimes, 1);
in HWTEST_F()
205 EXPECT_EQ(subscriber.OnRemoteDiedCallTimes, 1);
in HWTEST_F()
|
| /foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/ |
| H A D | published_data_subscriber_manager.cpp | 26 std::vector<OperationResult> PublishedDataSubscriberManager::AddObservers(void *subscriber, in AddObservers() argument
39 keys, subscriber, std::make_shared<Observer>(callback), in AddObservers()
43 [&proxy, subscriber, &subscriberId, this](const std::vector<Key> &firstAddKeys, in AddObservers()
64 BaseCallbacks::DelObservers(failedKeys, subscriber); in AddObservers()
70 std::vector<OperationResult> PublishedDataSubscriberManager::DelObservers(void *subscriber, in DelObservers() argument
77 return BaseCallbacks::DelObservers(subscriber, in DelObservers()
79 // delete all obs by subscriber in DelObservers()
93 std::vector<OperationResult> PublishedDataSubscriberManager::DelObservers(void *subscriber, in DelObservers() argument
101 return DelObservers(subscriber, proxy); in DelObservers()
108 return BaseCallbacks::DelObservers(keys, subscriber, in DelObservers()
[all...] |
| H A D | rdb_subscriber_manager.cpp | 37 std::vector<OperationResult> RdbSubscriberManager::AddObservers(void *subscriber, in AddObservers() argument
50 keys, subscriber, std::make_shared<Observer>(callback), in AddObservers()
54 [&proxy, subscriber, &templateId, this](const std::vector<Key> &firstAddKeys, in AddObservers()
75 BaseCallbacks::DelObservers(failedKeys, subscriber); in AddObservers()
81 std::vector<OperationResult> RdbSubscriberManager::DelObservers(void *subscriber, in DelObservers() argument
89 return DelObservers(subscriber, proxy); in DelObservers()
96 return BaseCallbacks::DelObservers(keys, subscriber, in DelObservers()
112 std::vector<OperationResult> RdbSubscriberManager::DelObservers(void *subscriber, in DelObservers() argument
119 return BaseCallbacks::DelObservers(subscriber, in DelObservers()
121 // delete all obs by subscriber in DelObservers()
[all...] |