Home
last modified time | relevance | path

Searched refs:Event_Write (Results 1 – 9 of 9) sorted by relevance

/base/startup/init/test/unittest/loopevent/
Dloopsignal_unittest.cpp59 ((BaseTask *)g_sigHandler)->handleEvent(loopClient, (TaskHandle)&g_sigHandler, Event_Write);
Dloopevent_unittest.cpp95 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()
Dloopserver_unittest.cpp308 info.events = Event_Read | Event_Write; in CreateWatcherTask()
/base/startup/init/services/loopevent/loop/
Dle_epoll.c31 if (LE_TEST_FLAGS(op, Event_Write)) { in GetEpollEvent_()
105 ProcessEvent(loop, epoll->waitEvents[index].data.fd, Event_Write); in RunLoop_()
Dle_loop.c130 Event_Read | Event_Write | Event_Error | Event_Free | Event_Timeout | Event_Signal); in DelTask()
/base/startup/init/services/loopevent/task/
Dle_streamtask.c89 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_()
Dle_asynctask.c77 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Write); in HandleAsyncEvent_()
Dle_task.c184 loop->modEvent(loop, (BaseTask *)taskHandle, Event_Write); in LE_Send()
/base/startup/init/services/loopevent/include/
Dloop_event.h39 Event_Write = (0x0002), enumerator