| /frameworks/native/libs/vr/libpdx_uds/private/uds/ |
| D | channel_event_set.h | 22 BorrowedHandle event_fd() const { return epoll_fd_.Borrow(); } in event_fd()
24 explicit operator bool() const { return !!epoll_fd_ && !!event_fd_; }
30 LocalHandle epoll_fd_;
44 ChannelEventReceiver(LocalHandle epoll_fd) : epoll_fd_{std::move(epoll_fd)} {} in ChannelEventReceiver()
48 BorrowedHandle event_fd() const { return epoll_fd_.Borrow(); } in event_fd()
52 LocalHandle epoll_fd_;
|
| D | service_dispatcher.h | 45 LocalHandle epoll_fd_; variable
|
| D | service_endpoint.h | 108 int epoll_fd() const { return epoll_fd_.Get(); } in epoll_fd()
152 LocalHandle epoll_fd_; variable
|
| /frameworks/native/libs/vr/libpdx_uds/ |
| D | service_dispatcher.cpp | 19 if (!dispatcher->epoll_fd_ || !dispatcher->event_fd_) { in Create()
33 epoll_fd_.Reset(epoll_create1(EPOLL_CLOEXEC)); in ServiceDispatcher()
34 if (!epoll_fd_) { in ServiceDispatcher()
45 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, event_fd_.Get(), &event) < 0) { in ServiceDispatcher()
50 epoll_fd_.Close(); in ServiceDispatcher()
83 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, endpoint->epoll_fd(), &event) < in AddService()
106 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_DEL, endpoint->epoll_fd(), &dummy) < in RemoveService()
126 int count = epoll_wait(epoll_fd_.Get(), events, kMaxEventsPerLoop, timeout); in ReceiveAndDispatch()
159 int count = epoll_wait(epoll_fd_.Get(), events, kMaxEventsPerLoop, -1); in EnterDispatchLoop()
|
| D | channel_event_set.cpp | 30 epoll_fd_ = std::move(epoll_fd); in ChannelEventSet()
38 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, data_fd.Get(), &event) < 0) { in AddDataFd()
63 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_MOD, event_fd_.Get(), &event) < in ModifyEvents()
95 RETRY_EINTR(epoll_wait(epoll_fd_.Get(), &event, 1, kTimeoutMs)); in GetPendingEvents()
|
| D | service_endpoint.cpp | 179 epoll_fd_.Reset(epoll_create1(EPOLL_CLOEXEC)); in Init()
180 CHECK(epoll_fd_.IsValid()) in Init()
187 int ret = epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, socket_fd.Get(), in Init()
198 int ret = epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, cancel_event_fd_.Get(), in Init()
283 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, channel_fd.Get(), &event) < 0) { in OnNewChannelLocked()
311 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_MOD, fd.Get(), &event) < 0) { in ReenableEpollEvent()
336 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_DEL, channel_fd, &dummy) < 0) { in CloseChannelLocked()
575 epoll_wait(epoll_fd_.Get(), &event, 1, is_blocking_ ? -1 : 0)); in MessageReceive()
|
| /frameworks/native/libs/vr/libvrflinger/ |
| D | epoll_event_dispatcher.cpp | 14 epoll_fd_.Reset(epoll_create(64)); in EpollEventDispatcher()
15 if (!epoll_fd_) { in EpollEventDispatcher()
30 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, event_fd_.Get(), &event) < 0) { in EpollEventDispatcher()
58 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, fd, &event) < 0) { in AddEventHandler()
72 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_DEL, fd, &dummy) < 0) { in RemoveEventHandler()
100 const int num_events = epoll_wait(epoll_fd_.Get(), events, kMaxNumEvents, -1); in EventThread()
|
| D | epoll_event_dispatcher.h | 56 pdx::LocalHandle epoll_fd_; variable
|
| /frameworks/native/libs/vr/libbufferhubqueue/ |
| D | buffer_hub_queue_client.cpp | 58 int ret = epoll_fd_.Create(); in Initialize()
68 ret = epoll_fd_.Control(EPOLL_CTL_ADD, event_fd(), &event); in Initialize()
132 const int ret = epoll_fd_.Wait(events.data(), events.size(), in WaitForBuffers()
274 const int ret = epoll_fd_.Control(EPOLL_CTL_ADD, buf->event_fd(), &event); in AddBuffer()
293 const int ret = epoll_fd_.Control(EPOLL_CTL_DEL, buf->event_fd(), nullptr); in DetachBuffer()
|
| /frameworks/native/libs/vr/libbufferhubqueue/include/private/dvr/ |
| D | buffer_hub_queue_client.h | 65 explicit operator bool() const { return epoll_fd_.IsValid(); }
82 int queue_fd() const { return epoll_fd_.Get(); } in queue_fd()
267 EpollFileDescriptor epoll_fd_; variable
|