Searched refs:EVENT_READ (Results 1 - 13 of 13) sorted by relevance
| /base/startup/init/test/unittest/loopevent/ |
| H A D | loopevent_unittest.cpp | 118 (TaskHandle)clientTaskHandle, EVENT_READ);
146 ((StreamServerTask *)serverTask_)->base.handleEvent(LE_GetDefaultLoop(), serverTask_, EVENT_READ);
179 ProcessEvent((EventLoop *)LE_GetDefaultLoop(), 1, EVENT_READ);
185 ProcessEvent((EventLoop *)LE_GetDefaultLoop(), testfd, EVENT_READ);
195 ((AsyncEventTask *)asynHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), asynHandle, EVENT_READ);
205 info.events = EVENT_READ;
211 ((WatcherTask *)handle)->base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)handle, EVENT_READ);
214 ((WatcherTask *)handle)->base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)handle, EVENT_READ);
286 info.events = EVENT_READ;
|
| H A D | loopserver_unittest.cpp | 308 info.events = EVENT_READ | EVENT_WRITE; in CreateWatcherTask()
|
| /base/startup/init/services/loopevent/signal/ |
| H A D | le_signal.c | 30 if (!LE_TEST_FLAGS(oper, EVENT_READ)) {
in HandleSignalEvent_()
112 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_AddSignal()
114 loop->modEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_AddSignal()
134 loop->delEvent(loop, GetSocketFd(signalHandle), EVENT_READ);
in LE_RemoveSignal()
|
| /base/startup/init/services/loopevent/task/ |
| H A D | le_streamtask.c | 47 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ);
in HandleSendMsg_()
101 if (LE_TEST_FLAGS(oper, EVENT_READ)) {
in HandleStreamEvent_()
124 if (LE_TEST_FLAGS(oper, EVENT_READ)) {
in HandleClientEvent_()
186 if (!LE_TEST_FLAGS(oper, EVENT_READ)) {
in HandleServerEvent_()
197 loop->modEvent(loop, (const BaseTask *)serverTask, EVENT_READ);
in HandleServerEvent_()
228 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_CreateStreamServer()
258 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_CreateStreamClient()
290 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_AcceptStreamClient()
|
| H A D | le_asynctask.c | 73 if (LE_TEST_FLAGS(oper, EVENT_READ)) {
in HandleAsyncEvent_()
85 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ);
in HandleAsyncEvent_()
127 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_CreateAsyncTask()
|
| /base/startup/init/services/loopevent/loop/ |
| H A D | le_loop.c | 98 loop->delEvent(loop, fd, EVENT_READ | EVENT_WRITE);
in ProcessEvent()
132 EVENT_READ | EVENT_WRITE | EVENT_ERROR | EVENT_FREE | EVENT_TIMEOUT | EVENT_SIGNAL);
in DelTask()
|
| H A D | le_epoll.c | 30 if (LE_TEST_FLAGS(op, EVENT_READ)) { in GetEpollEvent_()
123 ProcessEvent(loop, epoll->waitEvents[index].data.fd, EVENT_READ); in RunLoop_()
|
| /base/startup/init/services/init/standard/ |
| H A D | fd_holder_service.c | 169 *events = EVENT_READ; in ProcessFdHoldEvent()
183 info.events = EVENT_READ; in RegisterFdHoldWatcher()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| H A D | control_fd_client.c | 46 *events = EVENT_READ; in ProcessPtyWrite()
72 *events = EVENT_READ; in ProcessPtyRead()
186 info.events = EVENT_READ; in InitPtyInterface()
|
| /base/startup/init/interfaces/innerkits/include/ |
| H A D | loop_event.h | 38 EVENT_READ = (0x0001),
enumerator
|
| /base/startup/init/services/init/ |
| H A D | init_service_socket.c | 186 info.events = EVENT_READ; in AddSocketWatcher()
|
| H A D | init_service_manager.c | 1054 info.events = EVENT_READ; in AddFileDescriptorToWatcher()
|
| /base/startup/appspawn/standard/ |
| H A D | appspawn_service.c | 605 watchInfo.events = EVENT_READ; in WatchChildProcessFd()
637 watchInfo.events = EVENT_READ; in AddChildWatcher()
|
Completed in 11 milliseconds