| /system/core/adb/ |
| D | sysdeps_test.cpp | 96 adb_pollfd pfd[2] = {}; in TEST_F() local
97 pfd[0].fd = fds[0]; in TEST_F()
98 pfd[0].events = POLLRDNORM; in TEST_F()
99 pfd[1].fd = fds[1]; in TEST_F()
100 pfd[1].events = POLLWRNORM; in TEST_F()
102 pfd[0].revents = -1; in TEST_F()
103 pfd[1].revents = -1; in TEST_F()
104 EXPECT_EQ(1, adb_poll(pfd, 2, 0)); in TEST_F()
105 EXPECT_EQ(0, pfd[0].revents); in TEST_F()
106 EXPECT_EQ(POLLWRNORM, pfd[1].revents); in TEST_F()
[all …]
|
| D | services.cpp | 230 adb_pollfd pfd = {.fd = fd.get(), .events = POLLIN}; in wait_service() local
231 if (adb_poll(&pfd, 1, 100) != 0) { in wait_service()
|
| /system/core/adb/fdevent/ |
| D | fdevent_poll.cpp | 117 adb_pollfd pfd; in Loop() local
118 pfd.fd = fd; in Loop()
119 pfd.events = 0; in Loop()
121 pfd.events |= POLLIN; in Loop()
124 pfd.events |= POLLOUT; in Loop()
127 pfd.events |= POLLERR; in Loop()
130 pfd.events |= POLLRDHUP; in Loop()
132 pfd.revents = 0; in Loop()
133 pollfds.push_back(pfd); in Loop()
|
| /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/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/update_engine/binder_bindings/android/os/ |
| D | IUpdateEngine.aidl | 30 void applyPayloadFd(in ParcelFileDescriptor pfd, in applyPayloadFd() argument
|
| /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/update_engine/ |
| D | binder_service_android.h | 57 const ::android::os::ParcelFileDescriptor& pfd,
|
| D | binder_service_android.cc | 133 const ParcelFileDescriptor& pfd, in applyPayloadFd() argument
141 pfd.get(), payload_offset, payload_size, str_headers, &error)) { in applyPayloadFd()
|
| /system/core/debuggerd/handler/ |
| D | debuggerd_fallback.cpp | 139 struct pollfd pfd = { in forward_output() local
144 if (poll(&pfd, 1, 1000) != 1) { in forward_output()
|
| /system/testing/gtest_extras/ |
| D | Isolate.cpp | 271 pollfd* pfd = &running_pollfds_[i]; in ReadTestsOutput() local
272 if (pfd->revents & POLLIN) { in ReadTestsOutput()
276 pfd->fd = 0; in ReadTestsOutput()
277 pfd->events = 0; in ReadTestsOutput()
280 pfd->revents = 0; in ReadTestsOutput()
|
| /system/core/debuggerd/client/ |
| D | debuggerd_client.cpp | 265 struct pollfd pfd = { in debuggerd_trigger_dump() local
269 rc = poll(&pfd, 1, remaining_ms); in debuggerd_trigger_dump()
|
| /system/core/adb/daemon/ |
| D | usb.cpp | 294 adb_pollfd pfd[2] = { in StartMonitor() local
302 int rc = TEMP_FAILURE_RETRY(adb_poll(pfd, 2, timeout_ms)); in StartMonitor()
310 if (pfd[1].revents) { in StartMonitor()
|
| D | shell_service.cpp | 572 auto it = std::find_if(pfds.begin(), pfds.end(), [=](const adb_pollfd& pfd) { in PassDataStreams() argument
573 return pfd.fd == dead_sfd->get(); in PassDataStreams()
|
| /system/incremental_delivery/incfs/ |
| D | MountRegistry.cpp | 263 pollfd pfd = {.fd = mMountInfo.get(), .events = POLLERR | POLLPRI}; in ensureUpToDate() local
264 const auto res = TEMP_FAILURE_RETRY(poll(&pfd, 1, 0)); in ensureUpToDate()
|
| D | incfs.cpp | 950 pollfd pfd = {fd, POLLIN, 0}; in waitForReads() local
952 ::poll(&pfd, 1, duration_cast<std::chrono::milliseconds>(hrTimeout).count()); in waitForReads()
|
| /system/incremental_delivery/libdataloader/ |
| D | DataLoaderConnector.cpp | 503 static int createFdFromManaged(JNIEnv* env, jobject pfd) { in createFdFromManaged() argument
504 if (!pfd) { in createFdFromManaged()
509 auto managedFd = env->CallObjectMethod(pfd, jni.parcelFileDescriptorGetFileDescriptor); in createFdFromManaged()
|
| /system/core/adb/client/ |
| D | incremental_server.cpp | 299 adb_pollfd pfd = {adb_fd_.get(), POLLIN, 0}; in SkipToRequest() local
300 auto res = adb_poll(&pfd, 1, blocking ? kPollTimeoutMillis : 0); in SkipToRequest()
|
| D | file_sync_client.cpp | 800 adb_pollfd pfd = {.fd = fd.get(), .events = POLLIN}; in ReadAcknowledgements() local
804 ssize_t rc = adb_poll(&pfd, 1, should_block ? -1 : 0); in ReadAcknowledgements()
|
| /system/hardware/interfaces/suspend/1.0/default/ |
| D | SystemSuspendUnitTest.cpp | 74 struct pollfd pfd { in isReadBlocked() struct
77 return poll(&pfd, 1, timeout_ms) == 0; in isReadBlocked()
|