Searched refs:Event_Read (Results 1 – 14 of 14) sorted by relevance
| /base/startup/init/test/unittest/loopevent/ |
| D | loopevent_unittest.cpp | 118 (TaskHandle)clientTaskHandle, Event_Read); in StreamTaskTest()
146 … ((StreamServerTask *)serverTask_)->base.handleEvent(LE_GetDefaultLoop(), serverTask_, Event_Read); in LeTaskTest()
179 ProcessEvent((EventLoop *)LE_GetDefaultLoop(), 1, Event_Read); in ProcessEventTest()
185 ProcessEvent((EventLoop *)LE_GetDefaultLoop(), testfd, Event_Read); in ProcessEventTest()
195 …AsyncEventTask *)asynHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), asynHandle, Event_Read); in ProcessasynEvent()
205 info.events = Event_Read; in ProcessWatcherTask()
211 … ((WatcherTask *)handle)->base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)handle, Event_Read); in ProcessWatcherTask()
214 … ((WatcherTask *)handle)->base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)handle, Event_Read); in ProcessWatcherTask()
315 info.events = Event_Read;
|
| D | loopserver_unittest.cpp | 308 info.events = Event_Read | Event_Write; in CreateWatcherTask()
|
| /base/startup/init/services/loopevent/task/ |
| D | le_streamtask.c | 42 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Read); in HandleSendMsg_()
92 if (LE_TEST_FLAGS(oper, Event_Read)) { in HandleStreamEvent_()
96 loop->delEvent(loop, GetSocketFd(handle), Event_Read | Event_Write); in HandleStreamEvent_()
116 if (LE_TEST_FLAGS(oper, Event_Read)) { in HandleClientEvent_()
142 if (!LE_TEST_FLAGS(oper, Event_Read)) { in HandleServerEvent_()
153 loop->modEvent(loop, (const BaseTask *)serverTask, Event_Read); in HandleServerEvent_()
179 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateStreamServer()
208 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateStreamClient()
238 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_AcceptStreamClient()
|
| D | le_asynctask.c | 71 if (LE_TEST_FLAGS(oper, Event_Read)) { in HandleAsyncEvent_()
83 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Read); in HandleAsyncEvent_()
116 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateAsyncTask()
|
| /base/startup/init/services/loopevent/signal/ |
| D | le_signal.c | 29 if (!LE_TEST_FLAGS(oper, Event_Read)) { in HandleSignalEvent_()
84 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_AddSignal()
86 loop->modEvent(loop, (const BaseTask *)task, Event_Read); in LE_AddSignal()
106 loop->delEvent(loop, GetSocketFd(signalHandle), Event_Read); in LE_RemoveSignal()
|
| /base/startup/init/services/loopevent/timer/ |
| D | le_timer.c | 43 if (!LE_TEST_FLAGS(oper, Event_Read)) { in HandleTimerEvent_()
107 ret = loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_StartTimer()
|
| /base/startup/init/services/init/standard/ |
| D | fd_holder_service.c | 166 *events = Event_Read; in ProcessFdHoldEvent()
180 info.events = Event_Read; in RegisterFdHoldWatcher()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd_client.c | 44 *events = Event_Read; in ProcessPtyWrite()
64 *events = Event_Read; in ProcessPtyRead()
177 info.events = Event_Read; in InitPtyInterface()
|
| /base/startup/init/services/loopevent/loop/ |
| D | le_epoll.c | 28 if (LE_TEST_FLAGS(op, Event_Read)) { in GetEpollEvent_()
102 ProcessEvent(loop, epoll->waitEvents[index].data.fd, Event_Read); in RunLoop_()
|
| D | le_loop.c | 130 Event_Read | Event_Write | Event_Error | Event_Free | Event_Timeout | Event_Signal); in DelTask()
|
| /base/startup/init/services/loopevent/include/ |
| D | loop_event.h | 38 Event_Read = (0x0001), enumerator
|
| /base/startup/init/services/init/ |
| D | init_service_socket.c | 192 info.events = Event_Read; in AddSocketWatcher()
|
| D | init_service_manager.c | 953 info.events = Event_Read; in AddFileDescriptorToWatcher()
|
| /base/startup/init/test/unittest/init/ |
| D | group_unittest.cpp | 234 …k *)service->timer)->base.handleEvent(LE_GetDefaultLoop(), (LoopBase *)service->timer, Event_Read);
|