| /base/startup/init/services/loopevent/loop/ |
| D | le_loop.h | 46 } EventLoop; typedef
48 LE_STATUS CloseLoop(EventLoop *loop);
49 LE_STATUS AddTask(EventLoop *loop, BaseTask *task);
50 BaseTask *GetTaskByFd(EventLoop *loop, int fd);
51 void DelTask(EventLoop *loop, BaseTask *task);
52 LE_STATUS ProcessEvent(const EventLoop *loop, int fd, uint32_t oper);
|
| D | le_loop.c | 53 static LE_STATUS CreateLoop_(EventLoop **loop, uint32_t maxevents, uint32_t timeout) in CreateLoop_()
75 LE_STATUS CloseLoop(EventLoop *loop) in CloseLoop()
87 LE_STATUS ProcessEvent(const EventLoop *loop, int fd, uint32_t oper) in ProcessEvent()
89 BaseTask *task = GetTaskByFd((EventLoop *)loop, fd); in ProcessEvent()
101 LE_STATUS AddTask(EventLoop *loop, BaseTask *task) in AddTask()
114 BaseTask *GetTaskByFd(EventLoop *loop, int fd) in GetTaskByFd()
127 void DelTask(EventLoop *loop, BaseTask *task) in DelTask()
137 static EventLoop *g_defaultLoop = NULL;
148 EventLoop *loop = NULL; in LE_CreateLoop()
157 EventLoop *loop = (EventLoop *)handle; in LE_RunLoop()
[all …]
|
| D | le_epoll.h | 23 EventLoop loop;
28 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout);
|
| D | le_epoll.c | 36 static LE_STATUS Close_(const EventLoop *loop) in Close_()
46 static LE_STATUS AddEvent_(const EventLoop *loop, const BaseTask *task, int op) in AddEvent_()
62 static LE_STATUS ModEvent_(const EventLoop *loop, const BaseTask *task, int op) in ModEvent_()
78 static LE_STATUS DelEvent_(const EventLoop *loop, int fd, int op) in DelEvent_()
91 static LE_STATUS RunLoop_(const EventLoop *loop) in RunLoop_()
123 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout) in CreateEpollLoop()
132 *loop = (EventLoop *)epoll; in CreateEpollLoop()
|
| /base/hiviewdfx/hiview/plugins/eventlogger/test/unittest/common/ |
| D | event_logger_plugin_test.cpp | 68 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
82 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
98 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
115 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
134 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
164 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
190 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
216 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
242 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
|
| /base/hiviewdfx/hiview/base/ |
| D | event_loop.cpp | 52 EventLoop::EventLoop(const std::string &name) : name_(name), nextWakeupTime_(0), currentProcessingE… in EventLoop() function in OHOS::HiviewDFX::EventLoop
55 EventLoop::~EventLoop() in ~EventLoop()
60 bool EventLoop::InitEventQueueNotifier() in InitEventQueueNotifier()
101 void EventLoop::WakeUp() in WakeUp()
120 void EventLoop::StartLoop(bool createNewThread) in StartLoop()
132 thread_ = std::make_unique<std::thread>(&EventLoop::Run, this); in StartLoop()
139 void EventLoop::StopLoop() in StopLoop()
160 uint64_t EventLoop::AddEvent(std::shared_ptr<EventHandler> handler, std::shared_ptr<Event> event, c… in AddEvent()
183 std::future<bool> EventLoop::AddEventForResult(std::shared_ptr<EventHandler> handler, std::shared_p… in AddEventForResult()
214 uint64_t EventLoop::AddTimerEvent(std::shared_ptr<EventHandler> handler, std::shared_ptr<Event> eve… in AddTimerEvent()
[all …]
|
| D | plugin.cpp | 139 void Plugin::BindWorkLoop(std::shared_ptr<EventLoop> loop) in BindWorkLoop()
144 std::shared_ptr<EventLoop> Plugin::GetWorkLoop() in GetWorkLoop()
|
| /base/startup/init/services/loopevent/task/ |
| D | le_watchtask.c | 21 EventLoop *loop = (EventLoop *)loopHandle; in HandleWatcherEvent_()
29 watcher = (WatcherTask *)GetTaskByFd((EventLoop *)loopHandle, fd); in HandleWatcherEvent_()
49 DelTask((EventLoop *)loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
67 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartWatcher()
|
| D | le_streamtask.c | 27 EventLoop *loop = (EventLoop *)loopHandle; in HandleSendMsg_()
84 EventLoop *loop = (EventLoop *)loopHandle; in HandleStreamEvent_()
133 DelTask((EventLoop *)loopHandle, task); in HandleStreamTaskClose_()
152 EventLoop *loop = (EventLoop *)loopHandle; in HandleServerEvent_()
171 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateStreamServer()
207 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateStreamClient()
237 EventLoop *loop = (EventLoop *)loopHandle; in LE_AcceptStreamClient()
|
| D | le_asynctask.c | 69 EventLoop *loop = (EventLoop *)loopHandle; in HandleAsyncEvent_()
93 DelTask((EventLoop *)loopHandle, task); in HandleAsyncTaskClose_()
115 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateAsyncTask()
|
| /base/startup/init/services/loopevent/signal/ |
| D | le_signal.c | 46 DelTask((EventLoop *)loopHandle, task); in HandleSignalTaskClose_()
73 EventLoop *loop = (EventLoop *)loopHandle; in LE_AddSignal()
95 EventLoop *loop = (EventLoop *)loopHandle; in LE_RemoveSignal()
|
| /base/startup/init/services/loopevent/timer/ |
| D | le_timer.c | 54 timer = (TimerTask *)GetTaskByFd((EventLoop *)loop, fd); in HandleTimerEvent_()
70 DelTask((EventLoop *)loopHandle, task); in HandleTimerClose_()
101 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartTimer()
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/include/ |
| D | data_publisher.h | 47 void SetWorkLoop(std::shared_ptr<EventLoop> looper);
60 std::shared_ptr<EventLoop> looper_;
|
| /base/hiviewdfx/hiview/plugins/faultlogger/service/ |
| D | faultlog_manager.h | 35 explicit FaultLogManager(std::shared_ptr<EventLoop> looper) : looper_(looper) {}; in FaultLogManager()
51 std::shared_ptr<EventLoop> looper_ = nullptr;
|
| /base/hiviewdfx/hiview/plugins/event_store/include/ |
| D | sys_event_db_mgr.h | 32 void StartCheckStoreTask(std::shared_ptr<EventLoop> looper);
|
| /base/hiviewdfx/hiview/base/include/ |
| D | event_loop.h | 101 class DllExport EventLoop {
103 explicit EventLoop(const std::string &name);
104 virtual ~EventLoop();
|
| D | plugin.h | 111 void BindWorkLoop(std::shared_ptr<EventLoop> loop);
114 std::shared_ptr<EventLoop> GetWorkLoop();
182 std::shared_ptr<EventLoop> workLoop_;
232 virtual std::shared_ptr<EventLoop> GetSharedWorkLoop() in GetSharedWorkLoop()
|
| /base/hiviewdfx/hiview/base/test/unittest/common/ |
| D | plugin_example.cpp | 36 auto looper = std::make_shared<EventLoop>("PluginExample"); in OnLoad()
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/ |
| D | sys_event_service_adapter.h | 29 static void SetWorkLoop(std::shared_ptr<EventLoop> looper);
|
| /base/telephony/ril_adapter/services/hril/src/ |
| D | hril_timer_callback.cpp | 95 void HRilTimerCallback::EventLoop() in EventLoop() function in OHOS::Telephony::HRilTimerCallback
121 EventLoop(); in EventLoop()
|
| /base/hiviewdfx/hiview/plugins/event_store/store/ |
| D | sys_event_db_mgr.cpp | 38 void SysEventDbMgr::StartCheckStoreTask(std::shared_ptr<EventLoop> looper) in StartCheckStoreTask()
|
| /base/hiviewdfx/hiview/core/include/ |
| D | hiview_platform.h | 56 std::shared_ptr<EventLoop> GetSharedWorkLoop() override;
102 const std::map<std::string, std::shared_ptr<EventLoop>>& GetWorkLoopMap() in GetWorkLoopMap()
178 std::shared_ptr<EventLoop> GetAvaliableWorkLoop(const std::string& name);
204 std::shared_ptr<EventLoop> sharedWorkLoop_;
208 std::map<std::string, std::shared_ptr<EventLoop>> privateWorkLoopMap_;
|
| /base/hiviewdfx/hiview/plugins/freeze_detector/ |
| D | freeze_detector_plugin.h | 45 std::shared_ptr<EventLoop> threadLoop_ = nullptr;
|
| /base/telephony/ril_adapter/services/hril/include/ |
| D | hril_timer_callback.h | 38 void EventLoop();
|
| /base/hiviewdfx/hiview/plugins/sysevent_source/include/ |
| D | platform_monitor.h | 65 void StartMonitor(std::shared_ptr<EventLoop> looper);
135 std::shared_ptr<EventLoop> looper_;
|