Home
last modified time | relevance | path

Searched refs:EVENT_READ (Results 1 – 19 of 19) sorted by relevance

/ohos5.0/base/startup/init/test/unittest/loopevent/
H A Dloopevent_unittest.cpp118 (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()
286 info.events = EVENT_READ;
H A Dloopserver_unittest.cpp308 info.events = EVENT_READ | EVENT_WRITE; in CreateWatcherTask()
/ohos5.0/base/startup/init/services/loopevent/task/
H A Dle_streamtask.c47 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ); in HandleSendMsg_()
100 if (LE_TEST_FLAGS(oper, EVENT_READ)) { in HandleStreamEvent_()
123 if (LE_TEST_FLAGS(oper, EVENT_READ)) { in HandleClientEvent_()
185 if (!LE_TEST_FLAGS(oper, EVENT_READ)) { in HandleServerEvent_()
196 loop->modEvent(loop, (const BaseTask *)serverTask, EVENT_READ); in HandleServerEvent_()
227 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_CreateStreamServer()
257 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_CreateStreamClient()
289 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_AcceptStreamClient()
H A Dle_asynctask.c73 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()
/ohos5.0/base/startup/init/services/loopevent/signal/
H A Dle_signal.c30 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()
/ohos5.0/commonlibrary/c_utils/base/src/
H A Dio_event_epoll.cpp139 res |= Events::EVENT_READ; in Epoll2Reactor()
153 if (reactorEvent & Events::EVENT_READ) { in Reactor2Epoll()
H A Dio_event_handler.cpp86 events_ |= Events::EVENT_READ; in EnableRead()
/ohos5.0/base/startup/init/interfaces/innerkits/control_fd/
H A Dcontrol_fd_client.c46 *events = EVENT_READ; in ProcessPtyWrite()
72 *events = EVENT_READ; in ProcessPtyRead()
186 info.events = EVENT_READ; in InitPtyInterface()
/ohos5.0/base/startup/init/services/init/standard/
H A Dfd_holder_service.c169 *events = EVENT_READ; in ProcessFdHoldEvent()
183 info.events = EVENT_READ; in RegisterFdHoldWatcher()
/ohos5.0/base/startup/init/services/loopevent/loop/
H A Dle_epoll.c30 if (LE_TEST_FLAGS(op, EVENT_READ)) { in GetEpollEvent_()
120 ProcessEvent(loop, epoll->waitEvents[index].data.fd, EVENT_READ); in RunLoop_()
H A Dle_loop.c98 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()
/ohos5.0/commonlibrary/c_utils/base/include/
H A Dio_event_common.h37 static constexpr EventId EVENT_READ = 1u; variable
/ohos5.0/commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/
H A Devent_benchmark_test.cpp132 handler->SetEvents(Events::EVENT_READ | Events::EVENT_WRITE); in BENCHMARK_F()
133 AssertEqual(handler->GetEvents(), (Events::EVENT_READ | Events::EVENT_WRITE), in BENCHMARK_F()
149 AssertEqual(handler->GetEvents(), (Events::EVENT_READ | Events::EVENT_WRITE), in BENCHMARK_F()
154 AssertEqual(handler->GetEvents(), Events::EVENT_READ, in BENCHMARK_F()
177 AssertEqual(handler->GetEvents(), Events::EVENT_READ, in BENCHMARK_F()
1403 EventId events = Events::EVENT_READ; in BENCHMARK_F()
1428 EventId events = Events::EVENT_READ; in BENCHMARK_F()
/ohos5.0/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_event_test.cpp98 handler->SetEvents(Events::EVENT_READ | Events::EVENT_WRITE);
99 EXPECT_EQ(handler->GetEvents(), Events::EVENT_READ | Events::EVENT_WRITE);
113 EXPECT_EQ(handler->GetEvents(), Events::EVENT_READ | Events::EVENT_WRITE);
117 EXPECT_EQ(handler->GetEvents(), Events::EVENT_READ);
142 EXPECT_EQ(handler->GetEvents(), Events::EVENT_READ);
/ohos5.0/base/startup/init/interfaces/innerkits/include/
H A Dloop_event.h38 EVENT_READ = (0x0001), enumerator
/ohos5.0/base/startup/init/services/init/
H A Dinit_service_socket.c186 info.events = EVENT_READ; in AddSocketWatcher()
H A Dinit_service_manager.c1054 info.events = EVENT_READ; in AddFileDescriptorToWatcher()
/ohos5.0/commonlibrary/c_utils/docs/zh-cn/
H A Dc_utils_guide_event.md114 | constexpr EventId | **EVENT_READ** <br>可读事件。表明当前事件监听“可读”事件。 |
/ohos5.0/base/startup/appspawn/standard/
H A Dappspawn_service.c597 watchInfo.events = EVENT_READ; in WatchChildProcessFd()
630 watchInfo.events = EVENT_READ; in AddChildWatcher()