| /base/notification/distributed_notification_service/services/test/moduletest/mock/ |
| D | mock_event_handler.cpp | 20 std::shared_ptr<EventHandler> EventHandler::Current() in Current()
22 … const std::weak_ptr<EventHandler> &wp = std::make_shared<EventHandler>(EventRunner::Create(true)); in Current()
26 EventHandler::EventHandler(const std::shared_ptr<EventRunner> &runner) : eventRunner_(runner) in EventHandler() function in OHOS::AppExecFwk::EventHandler
29 EventHandler::~EventHandler() in ~EventHandler()
32 bool EventHandler::SendEvent(InnerEvent::Pointer &event, int64_t delayTime, Priority priority) in SendEvent()
39 bool EventHandler::SendTimingEvent(InnerEvent::Pointer &event, int64_t taskTime, Priority priority) in SendTimingEvent()
44 bool EventHandler::SendSyncEvent(InnerEvent::Pointer &event, Priority priority) in SendSyncEvent()
51 void EventHandler::RemoveAllEvents() in RemoveAllEvents()
54 void EventHandler::RemoveEvent(uint32_t innerEventId) in RemoveEvent()
57 void EventHandler::RemoveEvent(uint32_t innerEventId, int64_t param) in RemoveEvent()
[all …]
|
| /base/notification/distributed_notification_service/frameworks/test/moduletest/mock/ |
| D | mock_event_handler.cpp | 20 std::shared_ptr<EventHandler> EventHandler::Current() in Current()
22 … const std::weak_ptr<EventHandler> &wp = std::make_shared<EventHandler>(EventRunner::Create(true)); in Current()
26 EventHandler::EventHandler(const std::shared_ptr<EventRunner> &runner) : eventRunner_(runner) in EventHandler() function in OHOS::AppExecFwk::EventHandler
29 EventHandler::~EventHandler() in ~EventHandler()
32 bool EventHandler::SendEvent(InnerEvent::Pointer &event, int64_t delayTime, Priority priority) in SendEvent()
39 bool EventHandler::SendTimingEvent(InnerEvent::Pointer &event, int64_t taskTime, Priority priority) in SendTimingEvent()
44 bool EventHandler::SendSyncEvent(InnerEvent::Pointer &event, Priority priority) in SendSyncEvent()
51 void EventHandler::RemoveAllEvents() in RemoveAllEvents()
54 void EventHandler::RemoveEvent(uint32_t innerEventId) in RemoveEvent()
57 void EventHandler::RemoveEvent(uint32_t innerEventId, int64_t param) in RemoveEvent()
[all …]
|
| /base/notification/distributed_notification_service/services/distributed/test/unittest/mock/ |
| D | mock_event_handler.cpp | 20 std::shared_ptr<EventHandler> EventHandler::Current() in Current()
22 … const std::weak_ptr<EventHandler> &wp = std::make_shared<EventHandler>(EventRunner::Create(true)); in Current()
26 EventHandler::EventHandler(const std::shared_ptr<EventRunner> &runner) : eventRunner_(runner) in EventHandler() function in OHOS::AppExecFwk::EventHandler
29 EventHandler::~EventHandler() in ~EventHandler()
32 bool EventHandler::SendEvent(InnerEvent::Pointer &event, int64_t delayTime, Priority priority) in SendEvent()
39 bool EventHandler::SendTimingEvent(InnerEvent::Pointer &event, int64_t taskTime, Priority priority) in SendTimingEvent()
44 bool EventHandler::SendSyncEvent(InnerEvent::Pointer &event, Priority priority) in SendSyncEvent()
51 void EventHandler::RemoveAllEvents() in RemoveAllEvents()
54 void EventHandler::RemoveEvent(uint32_t innerEventId) in RemoveEvent()
57 void EventHandler::RemoveEvent(uint32_t innerEventId, int64_t param) in RemoveEvent()
[all …]
|
| /base/notification/distributed_notification_service/services/ans/test/unittest/mock/ |
| D | mock_event_handler.cpp | 20 std::shared_ptr<EventHandler> EventHandler::Current() in Current()
22 … const std::weak_ptr<EventHandler> &wp = std::make_shared<EventHandler>(EventRunner::Create(true)); in Current()
26 EventHandler::EventHandler(const std::shared_ptr<EventRunner> &runner) : eventRunner_(runner) in EventHandler() function in OHOS::AppExecFwk::EventHandler
29 EventHandler::~EventHandler() in ~EventHandler()
32 bool EventHandler::SendEvent(InnerEvent::Pointer &event, int64_t delayTime, Priority priority) in SendEvent()
39 bool EventHandler::SendTimingEvent(InnerEvent::Pointer &event, int64_t taskTime, Priority priority) in SendTimingEvent()
44 bool EventHandler::SendSyncEvent(InnerEvent::Pointer &event, Priority priority) in SendSyncEvent()
51 void EventHandler::RemoveAllEvents() in RemoveAllEvents()
54 void EventHandler::RemoveEvent(uint32_t innerEventId) in RemoveEvent()
57 void EventHandler::RemoveEvent(uint32_t innerEventId, int64_t param) in RemoveEvent()
[all …]
|
| /base/telephony/core_service/services/tel_ril/test/ |
| D | tel_ril_test.h | 190 … void OnInitForRegister(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler);
192 …ocessInput(int32_t slotId, int32_t what, const std::shared_ptr<AppExecFwk::EventHandler> &handler);
195 int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler);
197 …questSimGetSimStatusTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler);
199 …void OnRequestSimIccIoTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handle…
201 …void OnRequestOpenLGSimIOTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &han…
204 const std::shared_ptr<AppExecFwk::EventHandler> &handler);
207 const std::shared_ptr<AppExecFwk::EventHandler> &handler);
209 …estSimAuthenticationTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler);
211 …void OnRequestCloseLGSimIOTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &ha…
[all …]
|
| D | tel_ril_test.cpp | 186 void TelRilTest::OnInitForRegister(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> … in OnInitForRegister()
228 …rocessInput(int32_t slotId, int32_t what, const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnProcessInput()
240 int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnRequestCallGetCurrentCallsStatusTest()
251 …equestSimGetSimStatusTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnRequestSimGetSimStatusTest()
262 …st::OnRequestSimIccIoTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnRequestSimIccIoTest()
282 …:OnRequestOpenLGSimIOTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnRequestOpenLGSimIOTest()
300 const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnRequestTransmitApduLogicalChannelTest()
319 const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnRequestTransmitApduBasicChannelTest()
338 const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnRequestSimAuthenticationTest()
375 …OnRequestCloseLGSimIOTest(int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler) in OnRequestCloseLGSimIOTest()
[all …]
|
| /base/telephony/core_service/test/unittest/tel_ril_gtest/ |
| D | tel_ril_test_util.h | 145 …void ProcessTest(int32_t index, int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler);
148 class DemoHandler : public AppExecFwk::EventHandler {
151 : AppExecFwk::EventHandler(runner) in DemoHandler()
181 …void CallGetCurrentCallsStatusTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handl…
182 void SimGetSimStatusTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler);
183 void SimIccIoTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler);
184 void SimGetImsiTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler);
185 void GetSimLockStatusTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler);
186 void SetSimLockTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler);
187 void UnSetSimLockTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler);
[all …]
|
| D | tel_ril_test_util.cpp | 131 …Test::ProcessTest(int32_t index, int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler) in ProcessTest()
297 …t::CallGetCurrentCallsStatusTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler) in CallGetCurrentCallsStatusTest()
317 void TelRilTest::SimGetSimStatusTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> hand… in SimGetSimStatusTest()
336 void TelRilTest::SimIccIoTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler) in SimIccIoTest()
364 void TelRilTest::SimGetImsiTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler) in SimGetImsiTest()
383 void TelRilTest::GetSimLockStatusTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> han… in GetSimLockStatusTest()
403 void TelRilTest::SetSimLockTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler) in SetSimLockTest()
426 void TelRilTest::UnSetSimLockTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler) in UnSetSimLockTest()
449 void TelRilTest::ChangeSimPasswordTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> ha… in ChangeSimPasswordTest()
473 void TelRilTest::RadioRestartTest(int32_t slotId, std::shared_ptr<AppExecFwk::EventHandler> handler) in RadioRestartTest()
[all …]
|
| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| D | event_handler.cpp | 32 thread_local std::weak_ptr<EventHandler> EventHandler::currentEventHandler;
34 std::shared_ptr<EventHandler> EventHandler::Current() in Current()
39 EventHandler::EventHandler(const std::shared_ptr<EventRunner> &runner) : eventRunner_(runner) in EventHandler() function in OHOS::AppExecFwk::EventHandler
42 EventHandler::~EventHandler() in ~EventHandler()
54 bool EventHandler::SendEvent(InnerEvent::Pointer &event, int64_t delayTime, Priority priority) in SendEvent()
88 bool EventHandler::SendTimingEvent(InnerEvent::Pointer &event, int64_t taskTime, Priority priority) in SendTimingEvent()
102 bool EventHandler::SendSyncEvent(InnerEvent::Pointer &event, Priority priority) in SendSyncEvent()
139 void EventHandler::RemoveAllEvents() in RemoveAllEvents()
149 void EventHandler::RemoveEvent(uint32_t innerEventId) in RemoveEvent()
159 void EventHandler::RemoveEvent(uint32_t innerEventId, int64_t param) in RemoveEvent()
[all …]
|
| /base/telephony/core_service/interfaces/innerkits/include/ |
| D | core_manager_inner.h | 40 … int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &handler, int what, int32_t *obj);
42 … int32_t slotId, const std::shared_ptr<AppExecFwk::EventHandler> &observerCallBack, int what);
56 …otId, int32_t eventId, int fun, int rst, const std::shared_ptr<AppExecFwk::EventHandler> &handler);
58 … int32_t slotId, int32_t eventId, const std::shared_ptr<AppExecFwk::EventHandler> &handler) const;
59 …hutDown(int32_t slotId, int32_t eventId, const std::shared_ptr<AppExecFwk::EventHandler> &handler);
61 const std::shared_ptr<AppExecFwk::EventHandler> &handler);
62 …int32_t Reject(int32_t slotId, int32_t eventId, const std::shared_ptr<AppExecFwk::EventHandler> &h…
64 …otId, int32_t eventId, int32_t gsmIndex, const std::shared_ptr<AppExecFwk::EventHandler> &handler);
65 …int32_t Answer(int32_t slotId, int32_t eventId, const std::shared_ptr<AppExecFwk::EventHandler> &h…
67 … int32_t slotId, int32_t eventId, const std::shared_ptr<AppExecFwk::EventHandler> &handler) const;
[all …]
|
| /base/notification/eventhandler/test/systemtest/ems_event_runner_system_test/ |
| D | ems_event_runner_system_test.cpp | 179 F const &f, const std::shared_ptr<EventHandler> &handler, const std::atomic<bool> &taskCalled) in WaitUntilTaskCalled()
203 static void CreateRunnerWithName(const std::shared_ptr<EventHandler> &handler, const std::string &t… in CreateRunnerWithName()
237 auto handler = std::make_shared<EventHandler>(runner);
256 auto handler = std::make_shared<EventHandler>(runner);
274 auto handler = std::make_shared<EventHandler>(runner);
292 auto handler = std::make_shared<EventHandler>(runner);
310 auto handler = std::make_shared<EventHandler>(runner);
328 auto handler = std::make_shared<EventHandler>(runner);
334 handler->PostTask(task, EventHandler::Priority::HIGH);
347 auto handler = std::make_shared<EventHandler>(runner);
[all …]
|
| /base/notification/eventhandler/test/systemtest/ems_event_handler_system_test/ |
| D | ems_event_handler_test.cpp | 166 class MyEventHandler : public EventHandler {
168 explicit MyEventHandler(const std::shared_ptr<EventRunner> &runner) : EventHandler(runner) in MyEventHandler()
208 class TestEventHandler : public EventHandler {
210 explicit TestEventHandler(const std::shared_ptr<EventRunner> &runner) : EventHandler(runner) in TestEventHandler()
274 auto handler = std::make_shared<EventHandler>(runner);
289 auto handler = std::make_shared<EventHandler>(runner);
304 auto handler = std::make_shared<EventHandler>(runner);
320 auto handler = std::make_shared<EventHandler>(runner);
336 auto handler = std::make_shared<EventHandler>(runner);
352 auto handler = std::make_shared<EventHandler>(runner);
[all …]
|
| /base/notification/eventhandler/ |
| D | README_zh.md | 4 EventHandler提供了OpenHarmony线程间通信的基本能力，可以通过EventRunner创建新线程，将耗时的操作抛到新线程上执行，从而实现在不阻塞原来的线程的基础上…
6 EventHandler主要包括如下核心类：
10 …r | 消息队列的循环分发器，每个线程只有一个EventRunner，主要用于管理消息队列EventQueue,不断地从队列中取出InnerEvent分发至对应的EventHandler处理。 |
11 | InnerEvent | 线程之间消息传递的实体封装，EventHandler接收与处理的消息对象。EventHandler待处理的InnerEvent的优先级可在IMMEDIATE、HIG…
12 | EventHandler | 发送和处理消息的核心类，通过绑定一个EventRunner实现对消息队列进行循环分发的功能。 |
|
| /base/msdp/device_status/services/interaction/coordination/src/ |
| D | coordination_event_handler.cpp | 28 : AppExecFwk::EventHandler(runner) {} in CoordinationEventHandler()
33 return AppExecFwk::EventHandler::PostTask(callback, delayTime); in ProxyPostTask()
40 return AppExecFwk::EventHandler::PostTask(callback, name, delayTime); in ProxyPostTask()
46 AppExecFwk::EventHandler::RemoveTask(name); in ProxyRemoveTask()
|
| /base/notification/eventhandler/interfaces/inner_api/ |
| D | file_descriptor_listener.h | 34 class EventHandler; variable
73 inline std::shared_ptr<EventHandler> GetOwner() const in GetOwner()
83 inline void SetOwner(const std::shared_ptr<EventHandler> &owner) in SetOwner()
93 std::weak_ptr<EventHandler> owner_;
|
| D | event_queue.h | 33 class EventHandler; variable
37 std::weak_ptr<EventHandler> owner_;
94 void Remove(const std::shared_ptr<EventHandler> &owner);
102 void Remove(const std::shared_ptr<EventHandler> &owner, uint32_t innerEventId);
111 void Remove(const std::shared_ptr<EventHandler> &owner, uint32_t innerEventId, int64_t param);
119 void Remove(const std::shared_ptr<EventHandler> &owner, const std::string &name);
137 void RemoveFileDescriptorListener(const std::shared_ptr<EventHandler> &owner);
215 bool HasInnerEvent(const std::shared_ptr<EventHandler> &owner, uint32_t innerEventId);
224 bool HasInnerEvent(const std::shared_ptr<EventHandler> &owner, int64_t param);
|
| /base/security/access_token/services/tokensyncmanager/src/service/ |
| D | token_sync_event_handler.cpp | 29 : AppExecFwk::EventHandler(runner) in TokenSyncEventHandler()
38 return AppExecFwk::EventHandler::PostTask(callback, delayTime); in ProxyPostTask()
45 return AppExecFwk::EventHandler::PostTask(callback, name, delayTime); in ProxyPostTask()
50 AppExecFwk::EventHandler::RemoveTask(name); in ProxyRemoveTask()
|
| /base/notification/eventhandler/frameworks/eventhandler/test/unittest/ |
| D | lib_event_handler_event_runner_test.cpp | 43 static void WaitUntilTaskCalled(F const &f, const std::shared_ptr<EventHandler> &handler, const std… in WaitUntilTaskCalled()
67 static void CreateRunnerWithName(const std::shared_ptr<EventHandler> &handler, const std::string &t… in CreateRunnerWithName()
138 auto handler = std::make_shared<EventHandler>(EventRunner::Create());
162 auto handler = std::make_shared<EventHandler>(runner);
188 auto handler = std::make_shared<EventHandler>(EventRunner::Create(threadName));
208 auto handler = std::make_shared<EventHandler>(EventRunner::Create("threadName"));
229 auto handler = std::make_shared<EventHandler>(runner);
258 auto handler = std::make_shared<EventHandler>(runner);
307 auto handler = std::make_shared<EventHandler>(runner);
332 auto handler = std::make_shared<EventHandler>(runner);
[all …]
|
| /base/security/security_component_manager/services/security_component_service/sa/sa_main/ |
| D | sec_event_handler.cpp | 24 : AppExecFwk::EventHandler(runner) {} in SecEventHandler()
31 return AppExecFwk::EventHandler::PostTask(callback, name, delayTime); in ProxyPostTask()
36 AppExecFwk::EventHandler::RemoveTask(name); in ProxyRemoveTask()
|
| /base/telephony/core_service/services/tel_ril/include/ |
| D | observer_handler.h | 32 void RegObserver(int32_t what, const std::shared_ptr<AppExecFwk::EventHandler> handler);
34 void RegUniqueObserver(int32_t what, const std::shared_ptr<AppExecFwk::EventHandler> handler);
36 void Remove(int32_t what, const std::shared_ptr<AppExecFwk::EventHandler> handler);
69 …std::unordered_map<int32_t, std::list<std::shared_ptr<AppExecFwk::EventHandler>>> observerHandlerM…
|
| /base/notification/common_event_service/services/include/ |
| D | ordered_event_handler.h | 23 using EventHandler = OHOS::AppExecFwk::EventHandler; variable
29 class OrderedEventHandler : public EventHandler {
|
| /base/update/updater/utils/include/ |
| D | updater_event.h | 28 using EventHandler = std::function<void()>; variable
30 static void Subscribe(enum EventId id, EventHandler handler) in Subscribe()
46 static inline std::map<enum EventId, std::vector<EventHandler>> eventMap_ {};
|
| /base/telephony/core_service/services/sim/include/ |
| D | multi_sim_monitor.h | 36 class MultiSimMonitor : public AppExecFwk::EventHandler {
45 void RegisterCoreNotify(const std::shared_ptr<AppExecFwk::EventHandler> &handler, int what);
56 …const CommonEventSubscribeInfo &info, std::shared_ptr<AppExecFwk::EventHandler> multiSimMonitorHan… in UserSwitchEventSubscriber()
63 std::shared_ptr<AppExecFwk::EventHandler> multiSimMonitorHandler_ = nullptr;
68 …SystemAbilityStatusChangeListener(std::shared_ptr<AppExecFwk::EventHandler> multiSimMonitorHandler…
74 std::weak_ptr<AppExecFwk::EventHandler> multiSimMonitorHandler_;
|
| /base/telephony/core_service/services/tel_ril/src/ |
| D | observer_handler.cpp | 26 void ObserverHandler::RegObserver(int32_t what, const std::shared_ptr<AppExecFwk::EventHandler> han… in RegObserver()
31 std::list<std::shared_ptr<OHOS::AppExecFwk::EventHandler>> &handlers = iter->second; in RegObserver()
40 std::list<std::shared_ptr<AppExecFwk::EventHandler>> handlers; in RegObserver()
52 void ObserverHandler::Remove(int32_t what, const std::shared_ptr<AppExecFwk::EventHandler> handler) in Remove()
62 std::list<std::shared_ptr<OHOS::AppExecFwk::EventHandler>> &handlers = iter->second; in Remove()
|
| /base/notification/common_event_service/frameworks/core/include/ |
| D | common_event_listener.h | 29 using EventHandler = OHOS::AppExecFwk::EventHandler;
72 std::shared_ptr<EventHandler> handler_;
|