| /base/startup/init/services/loopevent/loop/ |
| H A D | le_loop.h | 50 } EventLoop;
typedef
52 LE_STATUS CloseLoop(EventLoop *loop);
53 LE_STATUS AddTask(EventLoop *loop, BaseTask *task);
54 BaseTask *GetTaskByFd(EventLoop *loop, int fd);
55 void DelTask(EventLoop *loop, BaseTask *task);
56 LE_STATUS ProcessEvent(const EventLoop *loop, int fd, uint32_t oper);
|
| H A D | le_loop.c | 53 static LE_STATUS CreateLoop_(EventLoop **loop, uint32_t maxevents, uint32_t timeout)
in CreateLoop_()
80 LE_STATUS CloseLoop(EventLoop *loop)
in CloseLoop()
92 LE_STATUS ProcessEvent(const EventLoop *loop, int fd, uint32_t oper)
in ProcessEvent()
94 BaseTask *task = GetTaskByFd((EventLoop *)loop, fd);
in ProcessEvent()
103 LE_STATUS AddTask(EventLoop *loop, BaseTask *task)
in AddTask()
116 BaseTask *GetTaskByFd(EventLoop *loop, int fd)
in GetTaskByFd()
129 void DelTask(EventLoop *loop, BaseTask *task)
in DelTask()
139 static EventLoop *g_defaultLoop = NULL;
150 EventLoop *loop = NULL;
in LE_CreateLoop()
159 EventLoop *loo in LE_RunLoop()
[all...] |
| H A D | le_epoll.h | 23 EventLoop loop;
28 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout);
|
| H A D | le_epoll.c | 38 static LE_STATUS Close_(const EventLoop *loop) in Close_()
48 static LE_STATUS AddEvent_(const EventLoop *loop, const BaseTask *task, int op) in AddEvent_()
64 static LE_STATUS ModEvent_(const EventLoop *loop, const BaseTask *task, int op) in ModEvent_()
80 static LE_STATUS DelEvent_(const EventLoop *loop, int fd, int op) in DelEvent_()
95 static LE_STATUS RunLoop_(const EventLoop *loop) in RunLoop_()
135 CheckTimeoutOfTimer((EventLoop *)loop, GetCurrentTimespec(0)); in RunLoop_()
145 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout) in CreateEpollLoop()
154 *loop = (EventLoop *)epoll; in CreateEpollLoop()
|
| /base/hiviewdfx/hiview/plugins/eventlogger/test/unittest/common/ |
| H A D | event_logger_plugin_test.cpp | 67 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); in HWTEST_F()
81 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); in HWTEST_F()
97 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); in HWTEST_F()
114 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop"); in HWTEST_F()
133 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoo in HWTEST_F()
[all...] |
| /base/hiviewdfx/hiview/base/ |
| H A D | event_loop.cpp | 51 DEFINE_LOG_TAG("HiView-EventLoop");
53 EventLoop::EventLoop(const std::string &name) : name_(name), nextWakeupTime_(0), currentProcessingEvent_(nullptr)
in EventLoop() function in OHOS::HiviewDFX::EventLoop
56 EventLoop::~EventLoop()
in ~EventLoop()
61 bool EventLoop::InitEventQueueNotifier()
in InitEventQueueNotifier()
102 void EventLoop::WakeUp()
in WakeUp()
121 void EventLoop::StartLoop(bool createNewThread)
in StartLoop()
133 thread_ = std::make_unique<std::thread>(&EventLoop::Run, this);
in StartLoop()
140 void EventLoop
[all...] |
| /base/hiviewdfx/hiview/plugins/reliability/bbox_detectors/test/mock/ |
| H A D | bbox_detectors_mock.h | 26 MOCK_METHOD0(GetSharedWorkLoop, std::shared_ptr<EventLoop>());
29 class MockEventLoop : public EventLoop {
31 MockEventLoop() : EventLoop("testEventLoop") {}; in MockEventLoop()
|
| H A D | bbox_detectors_mock.cpp | 23 return EventLoop::AddTimerEvent(handler, event, task, GetMockInterval(), repeat); in AddTimerEvent()
|
| /base/startup/init/services/loopevent/timer/ |
| H A D | le_timer.h | 47 void CheckTimeoutOfTimer(EventLoop *loop, uint64_t currTime);
48 void DestroyTimerList(EventLoop *loop);
49 uint64_t GetMinTimeoutPeriod(const EventLoop *loop);
|
| H A D | le_timer.c | 52 static void InsertTimerNode(EventLoop *loop, TimerNode *timer)
in InsertTimerNode()
63 void CheckTimeoutOfTimer(EventLoop *loop, uint64_t currTime)
in CheckTimeoutOfTimer()
137 EventLoop *loop = (EventLoop *)loopHandle;
in LE_StartTimer()
147 uint64_t GetMinTimeoutPeriod(const EventLoop *loop)
in GetMinTimeoutPeriod()
166 void DestroyTimerList(EventLoop *loop)
in DestroyTimerList()
|
| /base/startup/init/services/loopevent/task/ |
| H A D | le_watchtask.c | 21 DelTask((EventLoop *)loopHandle, (BaseTask *)taskHandle);
in HandleWatcherTaskClose_()
28 EventLoop *loop = (EventLoop *)loopHandle;
in HandleWatcherEvent_()
36 watcher = (WatcherTask *)GetTaskByFd((EventLoop *)loopHandle, fd);
in HandleWatcherEvent_()
79 EventLoop *loop = (EventLoop *)loopHandle;
in LE_StartWatcher()
|
| H A D | le_streamtask.c | 28 EventLoop *loop = (EventLoop *)loopHandle;
in HandleSendMsg_()
140 DelTask((EventLoop *)loopHandle, task);
in HandleStreamTaskClose_()
196 EventLoop *loop = (EventLoop *)loopHandle;
in HandleServerEvent_()
219 EventLoop *loop = (EventLoop *)loopHandle;
in LE_CreateStreamServer()
257 EventLoop *loop = (EventLoop *)loopHandle;
in LE_CreateStreamClient()
289 EventLoop *loo in LE_AcceptStreamClient()
[all...] |
| H A D | le_asynctask.c | 71 EventLoop *loop = (EventLoop *)loopHandle;
in HandleAsyncEvent_()
94 DelTask((EventLoop *)loopHandle, task);
in HandleAsyncTaskClose_()
126 EventLoop *loop = (EventLoop *)loopHandle;
in LE_CreateAsyncTask()
|
| /base/hiviewdfx/hiview/plugins/faultlogger/service/ |
| H A D | faultlog_database.h | 33 explicit FaultLogDatabase(const std::shared_ptr<EventLoop>& eventLoop);
39 std::shared_ptr<EventLoop> eventLoop_{nullptr};
|
| H A D | faultlog_manager.h | 35 explicit FaultLogManager(const std::shared_ptr<EventLoop>& looper) : looper_(looper) {}; in FaultLogManager()
51 std::shared_ptr<EventLoop> looper_ = nullptr;
|
| /base/startup/init/test/systest/ |
| H A D | client_systest.cpp | 52 EventLoop *loop = (EventLoop *)LE_GetDefaultLoop(); in main()
|
| /base/startup/init/services/loopevent/signal/ |
| H A D | le_signal.c | 46 DelTask((EventLoop *)loopHandle, task);
in HandleSignalTaskClose_()
101 EventLoop *loop = (EventLoop *)loopHandle;
in LE_AddSignal()
123 EventLoop *loop = (EventLoop *)loopHandle;
in LE_RemoveSignal()
|
| /base/startup/init/services/loopevent/idle/ |
| H A D | le_idle.c | 44 task->loop = (EventLoop *)loopHandle;
in LE_AddIdle()
111 EventLoop *loop = (EventLoop *)loopHandle;
in LE_RunIdle()
|
| H A D | le_idle.h | 30 EventLoop *loop;
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/include/ |
| H A D | data_publisher.h | 47 void SetWorkLoop(std::shared_ptr<EventLoop> looper);
61 std::shared_ptr<EventLoop> looper_;
|
| /base/hiviewdfx/hiview/plugins/unified_collector/test/unittest/common/mock/ |
| H A D | mock_function_jumble.cpp | 61 uint64_t EventLoop::AddTimerEvent(std::shared_ptr<EventHandler> handler, std::shared_ptr<Event> event, in AddTimerEvent()
96 bool EventLoop::RemoveEvent(uint64_t seq) in RemoveEvent()
|
| /base/startup/init/test/unittest/loopevent/ |
| H A D | looptimer_unittest.cpp | 76 EventLoop *loop = reinterpret_cast<EventLoop *>(g_loop); in HWTEST_F()
84 EventLoop *loop = reinterpret_cast<EventLoop *>(g_loop); in HWTEST_F()
|
| /base/hiviewdfx/hiview/plugins/event_store/include/ |
| H A D | sys_event_db_mgr.h | 32 void StartCheckStoreTask(std::shared_ptr<EventLoop> looper);
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/ |
| H A D | sys_event_service_adapter.h | 29 static void SetWorkLoop(std::shared_ptr<EventLoop> looper);
|
| /base/hiviewdfx/hiview/base/test/unittest/common/ |
| H A D | plugin_example.cpp | 36 auto looper = std::make_shared<EventLoop>("PluginExample");
in OnLoad()
|