| /base/notification/eventhandler/frameworks/test/moduletest/ |
| D | event_handler_send_event_module_test.cpp | 29 void SendAndCheck(int64_t delayTime, EventQueue::Priority priority) in SendAndCheck()
50 void SendEventWithPriority(EventQueue::Priority priority) in SendEventWithPriority()
60 if (priority == EventQueue::Priority::HIGH) { in SendEventWithPriority()
66 if (priority == EventQueue::Priority::IMMEDIATE) { in SendEventWithPriority()
83 void SendEventWithPriorityByEventId(EventQueue::Priority priority) in SendEventWithPriorityByEventId()
94 if (priority == EventQueue::Priority::LOW) { in SendEventWithPriorityByEventId()
97 if (priority == EventQueue::Priority::HIGH) { in SendEventWithPriorityByEventId()
100 if (priority == EventQueue::Priority::IMMEDIATE) { in SendEventWithPriorityByEventId()
122 const std::shared_ptr<MyEventHandler> &handler, EventQueue::Priority priority, const T &ptr) in SendEventWithSharedOrWeakPtr()
125 if (priority == EventQueue::Priority::LOW) { in SendEventWithSharedOrWeakPtr()
[all …]
|
| D | event_handler_send_sync_event_module_test.cpp | 148 bool result = handler->SendSyncEvent(nullPtr, EventQueue::Priority::LOW);
167 bool result = handler->SendSyncEvent(event, EventQueue::Priority::IDLE);
191 bool result = handler->SendSyncEvent(event, EventQueue::Priority::IMMEDIATE); in __anonc6b63c660402()
215 bool result = handler->SendSyncEvent(event, EventQueue::Priority::HIGH);
239 …bool rValueResult = handler->SendSyncEvent(InnerEvent::Get(RUN_EVENT_ID), EventQueue::Priority::LO… in __anonc6b63c660502()
384 bool result = handler->PostSyncTask(myTask, EventQueue::Priority::HIGH); in __anonc6b63c660a02()
|
| D | event_handler_post_task_module_test.cpp | 66 bool postResult = handler->PostTask(f, taskName, delayTime, EventQueue::Priority::LOW);
92 bool postResult = handler->PostTask(f, delayTime, EventQueue::Priority::HIGH);
|
| D | event_handler_send_timing_event_module_test.cpp | 154 bool result = handler->SendTimingEvent(nullPtr, nowTime + delayTime, EventQueue::Priority::LOW);
199 handler->SendTimingEvent(RUN_EVENT_ID, delayTime + nowTime, EventQueue::Priority::LOW);
|
| /base/notification/eventhandler/test/systemtest/ems_event_queue_system_test/ |
| D | ems_event_queue_system_test.cpp | 65 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>();
85 handler->SendEvent(event, DELAY_TIME, EventQueue::Priority::LOW);
86 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>();
101 handler->SendEvent(event, DELAY_TIME, EventQueue::Priority::IMMEDIATE);
102 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>();
114 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>();
128 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>();
|
| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| D | event_queue.cpp | 84 EventQueue::EventQueue() : ioWaiter_(std::make_shared<NoneIoWaiter>()) in EventQueue() function in OHOS::AppExecFwk::EventQueue
87 EventQueue::EventQueue(const std::shared_ptr<IoWaiter> &ioWaiter) in EventQueue() function in OHOS::AppExecFwk::EventQueue
93 …std::bind(&EventQueue::HandleFileDescriptorEvent, this, std::placeholders::_1, std::placeholders::… in EventQueue()
97 EventQueue::~EventQueue() in ~EventQueue()
103 void EventQueue::Insert(InnerEvent::Pointer &event, Priority priority) in Insert()
137 void EventQueue::RemoveOrphan() in RemoveOrphan()
160 void EventQueue::RemoveAll() in RemoveAll()
172 void EventQueue::Remove(const std::shared_ptr<EventHandler> &owner) in Remove()
184 void EventQueue::Remove(const std::shared_ptr<EventHandler> &owner, uint32_t innerEventId) in Remove()
198 void EventQueue::Remove(const std::shared_ptr<EventHandler> &owner, uint32_t innerEventId, int64_t … in Remove()
[all …]
|
| /base/notification/eventhandler/frameworks/eventhandler/test/unittest/ |
| D | lib_event_handler_event_queue_test.cpp | 100 static void GetEventAndCompare(uint32_t eventId, EventQueue &queue) in GetEventAndCompare()
125 EventQueue queue; in DelayTest()
154 static void InsertPriorityTest(const EventQueue::Priority priorities[], size_t priorityCount) in InsertPriorityTest()
158 EventQueue queue; in InsertPriorityTest()
180 if (priorities[0] == EventQueue::Priority::IDLE) { in InsertPriorityTest()
200 static void BreakQueueTest(EventQueue &queue, uint32_t eventId) in BreakQueueTest()
220 static void InsertAndGet(EventQueue &queue, InnerEvent::Pointer &event) in InsertAndGet()
238 static void InsertPriorityEvent(EventQueue &queue, size_t length) in InsertPriorityEvent()
246 queue.Insert(event, EventQueue::Priority::LOW); in InsertPriorityEvent()
258 queue.Insert(event, EventQueue::Priority::HIGH); in InsertPriorityEvent()
[all …]
|
| /base/notification/eventhandler/test/fuzztest/eventqueueinsert_fuzzer/ |
| D | eventqueueinsert_fuzzer.cpp | 28 AppExecFwk::EventQueue eventQueue(ioWaiter); in DoSomethingInterestingWithMyAPI()
31 AppExecFwk::EventQueue::Priority priority = AppExecFwk::EventQueue::Priority::LOW; in DoSomethingInterestingWithMyAPI()
|
| /base/notification/eventhandler/ |
| D | README_zh.md | 10 | EventRunner | 消息队列的循环分发器，每个线程只有一个EventRunner，主要用于管理消息队列EventQueue,不断地从队列中取出InnerEvent分发至对应的Event…
13 | EventQueue | 线程消息队列，管理InnerEvent，在初始化EventRunner对象时需要创建一个与之关联的EventQueue。 |
|
| /base/notification/eventhandler/interfaces/inner_api/ |
| D | event_queue.h | 49 class EventQueue final {
63 EventQueue();
64 explicit EventQueue(const std::shared_ptr<IoWaiter> &ioWaiter);
65 ~EventQueue();
66 DISALLOW_COPY_AND_MOVE(EventQueue);
|
| D | event_runner.h | 99 inline const std::shared_ptr<EventQueue> &GetEventQueue() const in GetEventQueue()
109 static std::shared_ptr<EventQueue> GetCurrentEventQueue();
222 std::shared_ptr<EventQueue> queue_;
|
| /base/notification/eventhandler/test/systemtest/ems_dumper_system_test/ |
| D | ems_dumper_system_test.cpp | 208 handler->PostTask(task, DELAY_TIME, EventQueue::Priority::LOW);
226 handler->SendEvent(event, DELAY_TIME, EventQueue::Priority::LOW);
244 handler->SendEvent(event, DELAY_TIME, EventQueue::Priority::LOW);
263 handler->SendEvent(event, DELAY_TIME, EventQueue::Priority::LOW);
264 handler->PostTask(task, DELAY_TIME * 2, EventQueue::Priority::LOW);
|
| /base/notification/eventhandler/frameworks/eventhandler/include/ |
| D | event_inner_runner.h | 38 const std::shared_ptr<EventQueue> &GetEventQueue() const in GetEventQueue()
64 std::shared_ptr<EventQueue> queue_;
|
| /base/hiviewdfx/hicollie/frameworks/native/ |
| D | handler_checker.cpp | 31 … if (!handler_->PostTask(fb, "IpcCheck Task", 0, AppExecFwk::EventQueue::Priority::IMMEDIATE)) { in ScheduleCheck()
40 …if (!handler_->PostTask(f, "XCollie Watchdog Task", 0, AppExecFwk::EventQueue::Priority::IMMEDIATE… in ScheduleCheck()
|
| /base/hiviewdfx/hiview/utility/smart_parser/test/resource/SmartParserTest001/ |
| D | trace.txt | 3 #02 pc 0000000000011db4 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::WaitUntilL…
4 #03 pc 0000000000011cf8 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::GetEvent()…
|
| D | cppcrash-com.ohos.launcher-20010025-19700324235211 | 26 #02 pc 0000000000011db4 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::WaitUntilL…
27 #03 pc 0000000000011cf8 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::GetEvent()…
68 #05 pc 0000000000011db4 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::WaitUntilL…
69 #06 pc 0000000000011cf8 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::GetEvent()…
|
| /base/hiviewdfx/hicollie/frameworks/native/test/unittest/common/ |
| D | watchdog_interface_test.cpp | 98 bool ret = handler->PostTask(blockFunc, "kickWatchdog", 0, EventQueue::Priority::LOW);
159 bool ret = handler->PostTask(blockFunc, "Block70s", 0, EventQueue::Priority::LOW);
199 bool ret = handler->PostTask(blockFunc, "Block30", 0, EventQueue::Priority::LOW);
241 bool ret = handler->PostTask(blockFunc, "Block10", 0, EventQueue::Priority::LOW);
|
| /base/notification/eventhandler/test/fuzztest/eventhandler_fuzzer/ |
| D | eventhandler_fuzzer.cpp | 76 AppExecFwk::EventQueue::Priority priority = AppExecFwk::EventQueue::Priority::LOW; in DoSomethingInterestingWithMyAPI()
|
| /base/hiviewdfx/hiview/utility/smart_parser/test/resource/SmartParserTest003/ |
| D | trace.txt | 6 #05 pc 0000000000011db4 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::WaitUntilL…
7 #06 pc 0000000000011cf8 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::GetEvent()…
|
| /base/hiviewdfx/hiview/utility/smart_parser/test/resource/SmartParserTest010/ |
| D | trace.txt | 6 #05 pc 0000000000011db4 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::WaitUntilL…
7 #06 pc 0000000000011cf8 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::GetEvent()…
|
| /base/hiviewdfx/hiview/utility/smart_parser/test/resource/SmartParserTest011/ |
| D | trace.txt | 6 #05 pc 0000000000011db4 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::WaitUntilL…
7 #06 pc 0000000000011cf8 /system/lib64/libeventhandler.z.so(OHOS::AppExecFwk::EventQueue::GetEvent()…
|
| /base/notification/eventhandler/test/fuzztest/eventqueue_fuzzer/ |
| D | eventqueue_fuzzer.cpp | 44 AppExecFwk::EventQueue eventQueue(ioWaiter); in DoSomethingInterestingWithMyAPI()
|
| /base/notification/eventhandler/frameworks/napi/include/ |
| D | events_emitter.h | 34 using Priority = EventQueue::Priority;
|
| /base/telephony/cellular_call/services/connection/src/ |
| D | supplement_request_cs.cpp | 190 bool ret = ccHandler->SendEvent(msgEvent, 0, AppExecFwk::EventQueue::Priority::IMMEDIATE); in AlterPinPassword()
213 bool ret = ccHandler->SendEvent(msgEvent, 0, AppExecFwk::EventQueue::Priority::IMMEDIATE); in UnlockPuk()
236 bool ret = ccHandler->SendEvent(msgEvent, 0, AppExecFwk::EventQueue::Priority::IMMEDIATE); in AlterPin2Password()
259 bool ret = ccHandler->SendEvent(msgEvent, 0, AppExecFwk::EventQueue::Priority::IMMEDIATE); in UnlockPuk2()
|
| /base/notification/eventhandler/test/fuzztest/eventqueueannex_fuzzer/ |
| D | eventqueueannex_fuzzer.cpp | 54 AppExecFwk::EventQueue eventQueue(ioWaiter); in DoSomethingInterestingWithMyAPI()
|