Searched refs:Event_Write (Results 1 – 9 of 9) sorted by relevance
/base/startup/init/test/unittest/loopevent/ |
D | loopsignal_unittest.cpp | 59 ((BaseTask *)g_sigHandler)->handleEvent(loopClient, (TaskHandle)&g_sigHandler, Event_Write);
|
D | loopevent_unittest.cpp | 95 CheckTaskFlags(nullptr, Event_Write); in CreateServerTask() 162 …ectTask *)client)->stream.base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)(client), Event_Write); in LeTaskTest() 196 …syncEventTask *)asynHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), asynHandle, Event_Write); in ProcessasynEvent()
|
D | loopserver_unittest.cpp | 308 info.events = Event_Read | Event_Write; in CreateWatcherTask()
|
/base/startup/init/services/loopevent/loop/ |
D | le_epoll.c | 31 if (LE_TEST_FLAGS(op, Event_Write)) { in GetEpollEvent_() 105 ProcessEvent(loop, epoll->waitEvents[index].data.fd, Event_Write); 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/task/ |
D | le_streamtask.c | 89 if (LE_TEST_FLAGS(oper, Event_Write)) { in HandleStreamEvent_() 96 loop->delEvent(loop, GetSocketFd(handle), Event_Read | Event_Write); in HandleStreamEvent_() 111 if (LE_TEST_FLAGS(oper, Event_Write)) { in HandleClientEvent_()
|
D | le_asynctask.c | 77 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Write); in HandleAsyncEvent_()
|
D | le_task.c | 184 loop->modEvent(loop, (BaseTask *)taskHandle, Event_Write); in LE_Send()
|
/base/startup/init/services/loopevent/include/ |
D | loop_event.h | 39 Event_Write = (0x0002), enumerator
|