Home
last modified time | relevance | path

Searched refs:epollEvents (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/commonlibrary/c_utils/base/src/
H A Dio_event_epoll.cpp57 bool IOEventEpoll::OperateEpoll(int op, int fd, EPEventId epollEvents) in OperateEpoll() argument
61 event.events = epollEvents; in OperateEpoll()
108 struct epoll_event epollEvents[maxEvents_]; in Polling() local
109 int nfds = epoll_wait(epollFd_, &epollEvents[0], maxEvents_, timeout); in Polling()
118 …res.emplace_back(std::make_pair(epollEvents[idx].data.fd, Epoll2Reactor(epollEvents[idx].events))); in Polling()
127 REventId IOEventEpoll::Epoll2Reactor(EPEventId epollEvents) in Epoll2Reactor() argument
130 if ((epollEvents & EPOLLHUP) && !(epollEvents & EPOLLIN)) { in Epoll2Reactor()
134 if (epollEvents & EPOLLERR) { in Epoll2Reactor()
138 if (epollEvents & (EPOLLIN | EPOLLPRI | EPOLLRDHUP)) { in Epoll2Reactor()
142 if (epollEvents & EPOLLOUT) { in Epoll2Reactor()
H A Devent_demultiplexer.cpp106 std::vector<struct epoll_event> epollEvents(maxEvents_); in Polling() local
110 int nfds = epoll_wait(epollFd_, &epollEvents[0], static_cast<int>(epollEvents.size()), timeout); in Polling()
124 int targetFd = epollEvents[idx].data.fd; in Polling()
125 uint32_t events = epollEvents[idx].events; in Polling()
146 uint32_t EventDemultiplexer::Epoll2Reactor(uint32_t epollEvents) in Epoll2Reactor() argument
148 if (epollEvents & (EPOLLIN | EPOLLPRI | EPOLLRDHUP)) { in Epoll2Reactor()
H A Dio_event_epoll.h53 REventId Epoll2Reactor(EPEventId epollEvents);
54 bool OperateEpoll(int op, int fd, EPEventId epollEvents);
H A Devent_demultiplexer.h46 static uint32_t Epoll2Reactor(uint32_t epollEvents);
/ohos5.0/base/notification/eventhandler/frameworks/eventhandler/src/
H A Depoll_io_waiter.cpp38 .events = epollEvents, in EpollCtrl()
128 struct epoll_event epollEvents[MAX_EPOLL_EVENTS_SIZE]; in WaitFor() local
146 if (epollEvents[i].data.fd == awakenFd_) { in WaitFor()
154 if ((epollEvents[i].events & EPOLLIN) != 0) { in WaitFor()
158 if ((epollEvents[i].events & EPOLLOUT) != 0) { in WaitFor()
162 if ((epollEvents[i].events & (EPOLLHUP)) != 0) { in WaitFor()
166 if ((epollEvents[i].events & (EPOLLERR)) != 0) { in WaitFor()
227 uint32_t epollEvents = 0; in AddFileDescriptor() local
229 epollEvents |= EPOLLIN; in AddFileDescriptor()
233 epollEvents |= EPOLLOUT; in AddFileDescriptor()
[all …]
H A Ddeamon_io_waiter.cpp41 .events = epollEvents, in EpollCtrl()
196 if (epollEvents[i].data.fd == awakenFd_) { in HandleEpollEvents()
204 if ((epollEvents[i].events & EPOLLIN) != 0) { in HandleEpollEvents()
208 if ((epollEvents[i].events & EPOLLOUT) != 0) { in HandleEpollEvents()
212 if ((epollEvents[i].events & (EPOLLHUP)) != 0) { in HandleEpollEvents()
216 if ((epollEvents[i].events & (EPOLLERR)) != 0) { in HandleEpollEvents()
245 struct epoll_event epollEvents[MAX_EPOLL_EVENTS_SIZE]; in EpollWaitFor() local
260 HandleEpollEvents(epollEvents, retVal); in EpollWaitFor()
311 uint32_t epollEvents = 0; in AddFileDescriptor() local
313 epollEvents |= EPOLLIN; in AddFileDescriptor()
[all …]
H A Dffrt_descriptor_listener.cpp64 uint32_t epollEvents = 0; in ConvertEvents() local
66 epollEvents |= FILE_DESCRIPTOR_INPUT_EVENT; in ConvertEvents()
70 epollEvents |= FILE_DESCRIPTOR_OUTPUT_EVENT; in ConvertEvents()
72 return epollEvents; in ConvertEvents()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/
H A Devent_loop_epoll.cpp173 uint32_t epollEvents = 0; in CalEpollEvents() local
175 epollEvents |= EPOLLIN; in CalEpollEvents()
178 epollEvents |= EPOLLOUT; in CalEpollEvents()
181 epollEvents |= EPOLLERR; in CalEpollEvents()
183 return epollEvents; in CalEpollEvents()
186 EventsMask EventLoopEpoll::CalEventsMask(uint32_t epollEvents) in CalEventsMask() argument
189 if (epollEvents & EPOLLIN) { // LCOV_EXCL_BR_LINE in CalEventsMask()
192 if (epollEvents & EPOLLOUT) { // LCOV_EXCL_BR_LINE in CalEventsMask()
195 if (epollEvents & EPOLLERR) { // LCOV_EXCL_BR_LINE in CalEventsMask()
217 uint32_t epollEvents = CalEpollEvents(events); in EpollCtl() local
[all …]
H A Devent_loop_epoll.h44 EventsMask CalEventsMask(uint32_t epollEvents);
/ohos5.0/base/notification/eventhandler/frameworks/eventhandler/include/
H A Ddeamon_io_waiter.h67 LOCAL_API void HandleEpollEvents(struct epoll_event *epollEvents, int32_t eventsCount);