| /system/core/adb/ |
| D | sysdeps_test.cpp | 87 pfd[0].revents = -1; in TEST_F()
88 pfd[1].revents = -1; in TEST_F()
90 EXPECT_EQ(0, pfd[0].revents); in TEST_F()
91 EXPECT_EQ(POLLWRNORM, pfd[1].revents); in TEST_F()
96 pfd[0].revents = -1; in TEST_F()
98 EXPECT_EQ(POLLRDNORM, pfd[0].revents); in TEST_F()
99 pfd[0].revents = -1; in TEST_F()
100 pfd[1].revents = -1; in TEST_F()
102 EXPECT_EQ(POLLRDNORM, pfd[0].revents); in TEST_F()
103 EXPECT_EQ(POLLWRNORM, pfd[1].revents); in TEST_F()
[all …]
|
| D | transport_fd.cpp | 85 if (pfds[0].revents) { in Run()
86 if ((pfds[0].revents & POLLOUT)) { in Run()
94 if (pfds[0].revents & POLLIN) { in Run()
129 if (pfds[1].revents) { in Run()
|
| D | fdevent.cpp | 311 if (pollfd.revents != 0) { in fdevent_process()
312 D("for fd %d, revents = %x", pollfd.fd, pollfd.revents); in fdevent_process()
315 if (pollfd.revents & POLLIN) { in fdevent_process()
318 if (pollfd.revents & POLLOUT) { in fdevent_process()
321 if (pollfd.revents & (POLLERR | POLLHUP | POLLNVAL)) { in fdevent_process()
327 if (pollfd.revents & POLLRDHUP) { in fdevent_process()
|
| D | services.cpp | 130 } else if (rc > 0 && (pfd.revents & POLLHUP) != 0) { in wait_for_state()
|
| /system/nvram/hal/ |
| D | fake_nvram.cpp | 157 poll_fds[0].revents = 0; in ProcessMessages()
160 if (poll_fds[0].revents & POLLIN) { in ProcessMessages()
172 poll_fds[poll_fds_count].revents = 0; in ProcessMessages()
187 if (poll_fds[i].revents & POLLIN) { in ProcessMessages()
197 poll_fds[i].revents = 0; in ProcessMessages()
|
| /system/netd/server/ |
| D | NetlinkListener.cpp | 130 ASSIGN_OR_RETURN(auto revents, sys.ppoll(fds, events, timeout)); in run()
132 if (revents[0] & POLLIN) { in run()
135 if (revents[1] & (POLLIN|POLLERR)) { in run()
|
| D | IptablesRestoreController.cpp | 69 return (ret == 1) && !(pollfd.revents & POLLERR); in outputReady()
295 if (pollfd.revents & POLLIN) { in drainAndWaitForAck()
327 if (pollfd.revents & POLLHUP) { in drainAndWaitForAck()
|
| D | MDnsSdListener.cpp | 603 if (mPollFds[i].revents != 0) { in run()
606 i, mPollFds[i].revents); in run()
610 mPollFds[i].revents = 0; in run()
613 if (VDBG) ALOGD("controlSocket shows revent= %d", mPollFds[0].revents); in run()
614 switch (mPollFds[0].revents) { in run()
624 mPollFds[0].revents = 0; in run()
|
| /system/bt/btif/src/ |
| D | btif_sock_thread.cc | 373 ps->pfd.revents = 0; in set_poll()
470 if (pfds[i].revents) { in process_data_sock()
476 print_events(pfds[i].revents); in process_data_sock()
477 if (IS_READ(pfds[i].revents)) { in process_data_sock()
480 if (IS_WRITE(pfds[i].revents)) { in process_data_sock()
483 if (IS_EXCEPTION(pfds[i].revents)) { in process_data_sock()
533 if (pfds[0].revents) // cmd fd always is the first one in sock_poll_thread()
|
| /system/core/libsysutils/src/ |
| D | SocketListener.cpp | 175 if (fds[0].revents & (POLLIN | POLLERR)) { in runListener()
183 if (mListen && (fds[1].revents & (POLLIN | POLLERR))) { in runListener()
202 if (p.revents & (POLLIN | POLLERR)) { in runListener()
|
| /system/netd/client/ |
| D | NetdClientTest.cpp | 42 if (fds[SERVERFD].revents & POLLIN) { in serverLoop()
|
| /system/core/init/ |
| D | uevent_listener.cpp | 193 ufd.revents = 0; in Poll()
211 if (ufd.revents & POLLIN) { in Poll()
|
| /system/chre/host/common/ |
| D | socket_server.cc | 275 if (mPollFds[kListenIndex].revents & POLLIN) { in serviceSocket()
284 if (mPollFds[i].revents & POLLIN) { in serviceSocket()
|
| /system/media/audio_utils/include/audio_utils/ |
| D | FdToString.h | 108 if (retval <= 0 || (pfd.revents & POLLIN) != POLLIN) break; // error or timeout in reader()
|
| /system/netd/libnetdutils/include/netdutils/ |
| D | Syscalls.h | 151 tmp[i].revents = 0; in ppoll()
156 out[i] = tmp[i].revents; in ppoll()
|
| /system/netd/resolv/ |
| D | DnsTlsSocket.cpp | 369 if (fds[SSLFD].revents & (POLLIN | POLLERR | POLLHUP)) { in loop()
375 if (fds[EVENTFD].revents & (POLLIN | POLLERR)) { in loop()
393 } else if (fds[SSLFD].revents & POLLOUT) { in loop()
|
| /system/connectivity/wificond/tests/ |
| D | shell_utils.cpp | 105 if (shell_output.revents & POLLHUP) { in RunShellCommand()
|
| /system/bt/udrv/ulinux/ |
| D | uipc.cc | 360 pfd.fd, pfd.revents, ret); in uipc_flush_ch_locked()
361 if (pfd.revents & (POLLERR | POLLHUP)) { in uipc_flush_ch_locked()
660 if (pfd.revents & (POLLHUP | POLLNVAL)) { in UIPC_Read()
|
| /system/bt/service/ipc/ |
| D | linux_ipc_host.cc | 89 if (pfds_[kFdIpc].revents && !OnMessage()) { in EventLoop()
93 if (pfds_.size() == kPossibleFds && pfds_[kFdGatt].revents && in EventLoop()
|
| /system/netd/resolv/dns_responder/ |
| D | dns_tls_frontend.cpp | 283 if (fds[EVENT_FD].revents & (POLLIN | POLLERR)) { in requestHandler()
287 if (fds[LISTEN_FD].revents & (POLLIN | POLLERR)) { in requestHandler()
|
| /system/core/toolbox/ |
| D | getevent.c | 660 if(ufds[0].revents & POLLIN) { in getevent_main()
664 if(ufds[i].revents) { in getevent_main()
665 if(ufds[i].revents & POLLIN) { in getevent_main()
|
| /system/core/libusbhost/ |
| D | usbhost.c | 746 struct pollfd p = {.fd = dev->fd, .events = POLLOUT, .revents = 0}; in usb_request_wait()
750 if (res != 1 || p.revents != POLLOUT) { in usb_request_wait()
751 D("[ poll - event %d, error %d]\n", p.revents, errno); in usb_request_wait()
|
| /system/core/adb/daemon/ |
| D | usb.cpp | 279 { .fd = control_fd_.get(), .events = POLLIN, .revents = 0 }, in StartMonitor()
280 { .fd = monitor_event_fd_.get(), .events = POLLIN, .revents = 0 }, in StartMonitor()
294 if (pfd[1].revents) { in StartMonitor()
|
| /system/core/logwrapper/ |
| D | logwrap.c | 356 if (poll_fds[0].revents & POLLIN) { in parent()
399 if (poll_fds[0].revents & POLLHUP) { in parent()
|
| /system/core/liblog/ |
| D | logd_reader.cpp | 172 if (!(p.revents & POLLIN)) { in send_log_msg()
504 if ((ret > 0) && !(p.revents & POLLIN)) { in logdPoll()
|