Home
last modified time | relevance | path

Searched refs:EventLoop (Results 1 – 25 of 63) sorted by relevance

123

/ohos5.0/foundation/communication/wifi/wifi/base/cRPC/include/
H A Devloop.h29 typedef struct EventLoop EventLoop; typedef
30 struct EventLoop { struct
45 EventLoop *CreateEventLoop(int size);
52 void DestroyEventLoop(EventLoop *loop);
59 void StopEventLoop(EventLoop *loop);
69 int AddFdEvent(EventLoop *loop, int fd, unsigned int addMask);
79 int DelFdEvent(EventLoop *loop, int fd, unsigned int delMask);
/ohos5.0/base/startup/init/services/loopevent/loop/
H A Dle_loop.c80 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 *loop = (EventLoop *)handle; in LE_RunLoop()
166 CloseLoop((EventLoop *)loopHandle); in LE_CloseLoop()
[all …]
H A Dle_loop.h50 } 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 Dle_epoll.c38 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_()
132 CheckTimeoutOfTimer((EventLoop *)loop, GetCurrentTimespec(0)); in RunLoop_()
142 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout) in CreateEpollLoop()
151 *loop = (EventLoop *)epoll; in CreateEpollLoop()
H A Dle_epoll.h23 EventLoop loop;
28 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout);
/ohos5.0/base/hiviewdfx/hiview/base/
H A Devent_loop.cpp53 EventLoop::EventLoop(const std::string &name) : name_(name), nextWakeupTime_(0), currentProcessingE… in EventLoop() function in OHOS::HiviewDFX::EventLoop
56 EventLoop::~EventLoop() in ~EventLoop()
61 bool EventLoop::InitEventQueueNotifier() in InitEventQueueNotifier()
102 void EventLoop::WakeUp() in WakeUp()
140 void EventLoop::StopLoop() in StopLoop()
251 bool EventLoop::RemoveEvent(uint64_t seq) in RemoveEvent()
269 void EventLoop::ResetTimerIfNeedLocked() in ResetTimerIfNeedLocked()
355 void EventLoop::ModifyFdStatus() in ModifyFdStatus()
404 void EventLoop::Run() in Run()
425 void EventLoop::InitThreadName() in InitThreadName()
[all …]
/ohos5.0/base/hiviewdfx/hiview/plugins/eventlogger/test/unittest/common/
H A Devent_logger_plugin_test.cpp67 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
81 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
97 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
114 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
133 std::shared_ptr<EventLoop> loop = std::make_shared<EventLoop>("eventLoop");
/ohos5.0/foundation/communication/wifi/wifi/test/wifi_standard/ipc_framework/cRPC/unittest/
H A Dserver_test.cpp55 EventLoop loop;
65 EventLoop loop;
76 EventLoop loop;
88 EventLoop loop;
101 EventLoop loop;
117 EventLoop loop;
130 EventLoop loop;
142 EventLoop loop;
154 EventLoop loop;
172 EventLoop loop;
[all …]
/ohos5.0/foundation/communication/wifi/wifi/test/wifi_standard/wifi_base/
H A Dserver_test.cpp55 EventLoop loop;
65 EventLoop loop;
76 EventLoop loop;
88 EventLoop loop;
101 EventLoop loop;
117 EventLoop loop;
130 EventLoop loop;
142 EventLoop loop;
154 EventLoop loop;
172 EventLoop loop;
[all …]
/ohos5.0/foundation/communication/wifi/wifi/base/cRPC/src/
H A Devloop.c28 EventLoop *CreateEventLoop(int size) in CreateEventLoop()
32 EventLoop *evLoop = NULL; in CreateEventLoop()
34 evLoop = (EventLoop *)calloc(1, sizeof(EventLoop)); in CreateEventLoop()
76 void DestroyEventLoop(EventLoop *loop) in DestroyEventLoop()
96 void StopEventLoop(EventLoop *loop) in StopEventLoop()
106 int AddFdEvent(EventLoop *loop, int fd, unsigned int addMask) in AddFdEvent()
139 int DelFdEvent(EventLoop *loop, int fd, unsigned int delMask) in DelFdEvent()
/ohos5.0/base/startup/init/services/loopevent/task/
H A Dle_watchtask.c21 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 Dle_streamtask.c28 EventLoop *loop = (EventLoop *)loopHandle; in HandleSendMsg_()
139 DelTask((EventLoop *)loopHandle, task); in HandleStreamTaskClose_()
195 EventLoop *loop = (EventLoop *)loopHandle; in HandleServerEvent_()
218 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateStreamServer()
256 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateStreamClient()
288 EventLoop *loop = (EventLoop *)loopHandle; in LE_AcceptStreamClient()
H A Dle_asynctask.c71 EventLoop *loop = (EventLoop *)loopHandle; in HandleAsyncEvent_()
94 DelTask((EventLoop *)loopHandle, task); in HandleAsyncTaskClose_()
126 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateAsyncTask()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/
H A Dievent_loop.cpp21 using EventLoop = DistributedDB::EventLoopEpoll; typedef
24 using EventLoop = DistributedDB::EventLoopSelect; typedef
30 EventLoopImpl *loop = new (std::nothrow) EventLoop; in CreateEventLoop()
/ohos5.0/base/hiviewdfx/hiview/plugins/reliability/bbox_detectors/test/mock/
H A Dbbox_detectors_mock.h26 MOCK_METHOD0(GetSharedWorkLoop, std::shared_ptr<EventLoop>());
29 class MockEventLoop : public EventLoop {
31 MockEventLoop() : EventLoop("testEventLoop") {}; in MockEventLoop()
/ohos5.0/base/startup/init/services/loopevent/timer/
H A Dle_timer.c52 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()
H A Dle_timer.h47 void CheckTimeoutOfTimer(EventLoop *loop, uint64_t currTime);
48 void DestroyTimerList(EventLoop *loop);
49 uint64_t GetMinTimeoutPeriod(const EventLoop *loop);
/ohos5.0/base/startup/init/services/loopevent/signal/
H A Dle_signal.c46 DelTask((EventLoop *)loopHandle, task); in HandleSignalTaskClose_()
101 EventLoop *loop = (EventLoop *)loopHandle; in LE_AddSignal()
123 EventLoop *loop = (EventLoop *)loopHandle; in LE_RemoveSignal()
/ohos5.0/base/startup/init/services/loopevent/idle/
H A Dle_idle.c44 task->loop = (EventLoop *)loopHandle; in LE_AddIdle()
111 EventLoop *loop = (EventLoop *)loopHandle; in LE_RunIdle()
/ohos5.0/base/startup/init/test/unittest/loopevent/
H A Dlooptimer_unittest.cpp76 EventLoop *loop = reinterpret_cast<EventLoop *>(g_loop);
84 EventLoop *loop = reinterpret_cast<EventLoop *>(g_loop);
/ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/service/
H A Dfaultlog_database.h33 explicit FaultLogDatabase(const std::shared_ptr<EventLoop>& eventLoop);
39 std::shared_ptr<EventLoop> eventLoop_{nullptr};
/ohos5.0/base/hiviewdfx/hiview/core/include/
H A Dhiview_platform.h53 std::shared_ptr<EventLoop> GetSharedWorkLoop() override;
89 const std::map<std::string, std::shared_ptr<EventLoop>>& GetWorkLoopMap() in GetWorkLoopMap()
164 std::shared_ptr<EventLoop> GetAvailableWorkLoop(const std::string& name);
192 std::shared_ptr<EventLoop> sharedWorkLoop_;
195 std::map<std::string, std::shared_ptr<EventLoop>> privateWorkLoopMap_;
/ohos5.0/base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/include/
H A Ddata_publisher.h47 void SetWorkLoop(std::shared_ptr<EventLoop> looper);
61 std::shared_ptr<EventLoop> looper_;
/ohos5.0/base/hiviewdfx/hiview/plugins/unified_collector/test/unittest/common/mock/
H A Dmock_function_jumble.cpp61 uint64_t EventLoop::AddTimerEvent(std::shared_ptr<EventHandler> handler, std::shared_ptr<Event> eve… in AddTimerEvent()
96 bool EventLoop::RemoveEvent(uint64_t seq) in RemoveEvent()
/ohos5.0/base/hiviewdfx/hiview/base/include/
H A Devent_loop.h95 class DllExport EventLoop {
97 explicit EventLoop(const std::string &name);
98 virtual ~EventLoop();

123