| /system/core/adb/ |
| D | sysdeps_test.cpp | 81 adb_pollfd pfd[2] = {}; in TEST_F() local
82 pfd[0].fd = fds[0]; in TEST_F()
83 pfd[0].events = POLLRDNORM; in TEST_F()
84 pfd[1].fd = fds[1]; in TEST_F()
85 pfd[1].events = POLLWRNORM; in TEST_F()
87 pfd[0].revents = -1; in TEST_F()
88 pfd[1].revents = -1; in TEST_F()
89 EXPECT_EQ(1, adb_poll(pfd, 2, 0)); in TEST_F()
90 EXPECT_EQ(0, pfd[0].revents); in TEST_F()
91 EXPECT_EQ(POLLWRNORM, pfd[1].revents); in TEST_F()
[all …]
|
| D | services.cpp | 125 adb_pollfd pfd = {.fd = fd, .events = POLLIN}; in wait_for_state() local
126 int rc = adb_poll(&pfd, 1, 100); in wait_for_state()
130 } else if (rc > 0 && (pfd.revents & POLLHUP) != 0) { in wait_for_state()
|
| /system/bt/udrv/ulinux/ |
| D | uipc.cc | 137 struct pollfd pfd; in accept_server_socket() local
144 pfd.fd = sfd; in accept_server_socket()
145 pfd.events = POLLIN; in accept_server_socket()
148 OSI_NO_INTR(poll_ret = poll(&pfd, 1, 0)); in accept_server_socket()
335 struct pollfd pfd; in uipc_flush_ch_locked() local
337 pfd.events = POLLIN; in uipc_flush_ch_locked()
338 pfd.fd = uipc.ch[ch_id].fd; in uipc_flush_ch_locked()
347 OSI_NO_INTR(ret = poll(&pfd, 1, 1)); in uipc_flush_ch_locked()
360 pfd.fd, pfd.revents, ret); in uipc_flush_ch_locked()
361 if (pfd.revents & (POLLERR | POLLHUP)) { in uipc_flush_ch_locked()
[all …]
|
| /system/ashmemd/tests/ |
| D | ashmemd_test.cpp | 69 ParcelFileDescriptor pfd; in TEST_F() local
70 openFd(&pfd); in TEST_F()
71 int fd = pfd.get(); in TEST_F()
|
| /system/bt/btif/src/ |
| D | btif_sock_thread.cc | 80 struct pollfd pfd; member
349 ts[h].ps[i].pfd.fd = -1; in init_poll()
364 ps->pfd.fd = fd; in set_poll()
372 ps->pfd.events = flags2pevents(flags); in set_poll()
373 ps->pfd.revents = 0; in set_poll()
383 if (ps[i].pfd.fd == fd) { in add_poll()
388 } else if (empty < 0 && ps[i].pfd.fd == -1) in add_poll()
404 ps->pfd.fd = -1; in remove_poll()
409 ps->pfd.events = flags2pevents(ps->flags); in remove_poll()
431 if (poll_slot->pfd.fd == cmd.fd) { in process_cmd_sock()
[all …]
|
| /system/media/audio_utils/include/audio_utils/ |
| D | FdToString.h | 100 struct pollfd pfd = { in reader() local
107 const int retval = poll(&pfd, 1 /* nfds*/, waitMs); in reader()
108 if (retval <= 0 || (pfd.revents & POLLIN) != POLLIN) break; // error or timeout in reader()
|
| /system/core/libnetutils/ |
| D | dhcpclient.c | 398 struct pollfd pfd; in dhcp_init_ifc() local
420 pfd.fd = s; in dhcp_init_ifc()
421 pfd.events = POLLIN; in dhcp_init_ifc()
422 pfd.revents = 0; in dhcp_init_ifc()
423 r = poll(&pfd, 1, timeout); in dhcp_init_ifc()
|
| /system/core/debuggerd/client/ |
| D | debuggerd_client.cpp | 216 struct pollfd pfd = { in debuggerd_trigger_dump() local
220 rc = poll(&pfd, 1, remaining_ms); in debuggerd_trigger_dump()
|
| /system/testing/gtest_extras/ |
| D | Isolate.cpp | 239 pollfd* pfd = &running_pollfds_[i]; in ReadTestsOutput() local
240 if (pfd->revents & POLLIN) { in ReadTestsOutput()
244 pfd->fd = 0; in ReadTestsOutput()
245 pfd->events = 0; in ReadTestsOutput()
248 pfd->revents = 0; in ReadTestsOutput()
|
| /system/core/debuggerd/handler/ |
| D | debuggerd_fallback.cpp | 138 struct pollfd pfd = { in forward_output() local
143 if (poll(&pfd, 1, 1000) != 1) { in forward_output()
|
| /system/hardware/interfaces/suspend/1.0/default/ |
| D | SystemSuspendUnitTest.cpp | 69 struct pollfd pfd { in isReadBlocked() struct
72 return poll(&pfd, 1, timeout_ms) == 0; in isReadBlocked()
|
| /system/core/adb/daemon/ |
| D | usb.cpp | 278 adb_pollfd pfd[2] = { in StartMonitor() local
286 int rc = TEMP_FAILURE_RETRY(adb_poll(pfd, 2, timeout_ms)); in StartMonitor()
294 if (pfd[1].revents) { in StartMonitor()
|
| /system/core/adb/client/ |
| D | file_sync_client.cpp | 241 adb_pollfd pfd = {.fd = fd.get(), .events = POLLIN}; in ReceivedError() local
242 int rc = adb_poll(&pfd, 1, 0); in ReceivedError()
|