/hardware/interfaces/bluetooth/1.0/default/test/ |
async_fd_watcher_unittest.cc | 84 int n = TEMP_FAILURE_RETRY(read(fd, server_buffer_, kBufferSize - 1)); 286 int n = TEMP_FAILURE_RETRY(read(fd, read_buf, sizeof(read_buf))); 294 int n = TEMP_FAILURE_RETRY(read(fd, read_buf, sizeof(read_buf))); 310 TEMP_FAILURE_RETRY(write(sockfd[1], one_buf, sizeof(one_buf))); 318 TEMP_FAILURE_RETRY(write(sockfd[0], two_buf, sizeof(two_buf)));
|
/art/adbconnection/ |
adbconnection.cc | 113 TEMP_FAILURE_RETRY(read(fd_, &data_, sizeof(data_))); 117 TEMP_FAILURE_RETRY(write(fd_, &data_, sizeof(data_))); 385 ssize_t res = TEMP_FAILURE_RETRY(writev(adb_connection_socket_, iovs, kIovSize)); 440 int res = TEMP_FAILURE_RETRY(sendmsg(local_agent_control_sock_, &msg, MSG_EOR)); 476 int rc = TEMP_FAILURE_RETRY(recvmsg(control_sock_, &msg, 0)); 530 ret = TEMP_FAILURE_RETRY(send(sock, &pid, sizeof(pid), 0)); 584 int res = TEMP_FAILURE_RETRY(poll(pollfds, 4, -1)); 597 res = TEMP_FAILURE_RETRY(recv(local_agent_control_sock_, buf, sizeof(buf) - 1, 0)); 698 ssize_t res = TEMP_FAILURE_RETRY(recv(adb_connection_socket_.get(), 728 res = TEMP_FAILURE_RETRY(ioctl(adb_connection_socket_.get(), FIONREAD, &avail)) [all...] |
/art/dt_fd_forward/ |
dt_fd_forward.cc | 105 TEMP_FAILURE_RETRY(send(fd, kListenStartMessage, sizeof(kListenStartMessage), MSG_EOR)); 121 TEMP_FAILURE_RETRY(send(fd, kListenEndMessage, sizeof(kListenEndMessage), MSG_EOR)); 149 int res = TEMP_FAILURE_RETRY(read(read_fd_, bdata + nbytes, ndata - nbytes)); 165 int res = TEMP_FAILURE_RETRY(ioctl(read_fd_, FIONREAD, &avail)); 175 res = TEMP_FAILURE_RETRY(poll(&pollfd, /*nfds*/1, /*timeout*/0)); 217 int poll_res = TEMP_FAILURE_RETRY(poll(pollfds, 2, -1)); 223 int unused = TEMP_FAILURE_RETRY(read(wakeup_fd_, &val, sizeof(val))); 237 TEMP_FAILURE_RETRY(read(fd_, &data_, sizeof(data_))); 241 TEMP_FAILURE_RETRY(write(fd_, &data_, sizeof(data_))); 254 int res = TEMP_FAILURE_RETRY(write(write_fd_, bdata + nbytes, ndata - nbytes)) [all...] |
/bionic/libc/async_safe/ |
async_safe_log.cpp | 107 ssize_t bytes = TEMP_FAILURE_RETRY(write(fd_, data, len)); 440 int result = TEMP_FAILURE_RETRY(writev(STDERR_FILENO, vec, 4)); 451 int log_fd = TEMP_FAILURE_RETRY(socket(PF_UNIX, SOCK_DGRAM | SOCK_CLOEXEC | SOCK_NONBLOCK, 0)); 464 if (TEMP_FAILURE_RETRY(connect(log_fd, &u.addr, sizeof(u.addrUn))) != 0) { 506 int result = TEMP_FAILURE_RETRY(writev(main_log_fd, vec, sizeof(vec) / sizeof(vec[0]))); 542 TEMP_FAILURE_RETRY(writev(2, iov, 2));
|
/frameworks/native/cmds/dumpstate/ |
utils.cpp | 287 if ((fd = TEMP_FAILURE_RETRY(open(cmdpath, O_RDONLY | O_CLOEXEC))) >= 0) { 288 TEMP_FAILURE_RETRY(read(fd, cmdline, sizeof(cmdline) - 2)); 298 if ((fd = TEMP_FAILURE_RETRY(open(cmdpath, O_RDONLY | O_CLOEXEC))) >= 0) { 299 TEMP_FAILURE_RETRY(read(fd, cmdline + 1, sizeof(cmdline) - 4)); 361 if ((fd = TEMP_FAILURE_RETRY(open(commpath, O_RDONLY | O_CLOEXEC))) < 0) { 365 TEMP_FAILURE_RETRY(read(fd, comm, sizeof(comm) - 2)); 400 if ((fd = TEMP_FAILURE_RETRY(open(path, O_RDONLY | O_CLOEXEC))) < 0) { 405 ret = TEMP_FAILURE_RETRY(read(fd, buffer, sizeof(buffer))); 466 if ((fd = TEMP_FAILURE_RETRY(open(path, O_RDONLY | O_CLOEXEC))) < 0) { 471 ret = TEMP_FAILURE_RETRY(read(fd, buffer, sizeof(buffer))) [all...] |
DumpstateUtil.cpp | 59 int ret = TEMP_FAILURE_RETRY(sigtimedwait(&child_mask, NULL, &ts)); 195 android::base::unique_fd fd(TEMP_FAILURE_RETRY(open(path.c_str(), O_RDONLY | O_NONBLOCK | O_CLOEXEC))); 299 TEMP_FAILURE_RETRY(dup2(STDERR_FILENO, STDOUT_FILENO)); 302 TEMP_FAILURE_RETRY(dup2(fd, STDOUT_FILENO));
|
/frameworks/base/cmds/incidentd/src/ |
incidentd_util.cpp | 72 if (input != NULL && (TEMP_FAILURE_RETRY(dup2(input->readFd().get(), STDIN_FILENO)) < 0 || 77 if (TEMP_FAILURE_RETRY(dup2(output->writeFd().get(), STDOUT_FILENO)) < 0 ||
|
/hardware/interfaces/bluetooth/1.0/default/ |
async_fd_watcher.cc | 116 if (TEMP_FAILURE_RETRY(write(notification_write_fd_, &buffer, 1)) < 0) { 173 TEMP_FAILURE_RETRY(read(notification_listen_fd_, buffer, 1));
|
/libnativehelper/include/nativehelper/ |
JNIHelp.h | 208 * TEMP_FAILURE_RETRY is defined by some, but not all, versions of 212 #ifndef TEMP_FAILURE_RETRY 214 #define TEMP_FAILURE_RETRY(exp) ({ \
|
/system/core/fs_mgr/ |
fs_mgr_avb_ops.cpp | 150 android::base::unique_fd fd(TEMP_FAILURE_RETRY(open(path.c_str(), O_RDONLY | O_CLOEXEC))); 174 ssize_t num_read = TEMP_FAILURE_RETRY(pread64(fd, buffer, num_bytes, offset));
|
/system/core/libsuspend/ |
autosuspend_wakeup_count.cpp | 120 int fd = TEMP_FAILURE_RETRY(open(sys_power_state, O_CLOEXEC | O_RDWR)); 141 wakeup_count_fd = TEMP_FAILURE_RETRY(open(sys_power_wakeup_count, O_CLOEXEC | O_RDWR));
|
/system/core/libunwindstack/tests/ |
ElfTestUtils.cpp | 111 int fd = TEMP_FAILURE_RETRY(open(name.c_str(), O_RDONLY)); 115 bytes = TEMP_FAILURE_RETRY(read(fd, buf.data(), buf.size()));
|
/system/core/run-as/ |
run-as.cpp | 70 if (TEMP_FAILURE_RETRY(lstat(path, &st)) == -1) return false; 205 if (TEMP_FAILURE_RETRY(chdir(info.data_dir)) == -1) {
|
/system/hwservicemanager/ |
TokenManager.cpp | 18 int fd = TEMP_FAILURE_RETRY(open("/dev/urandom", O_RDONLY | O_CLOEXEC | O_NOFOLLOW)); 25 while ((n = TEMP_FAILURE_RETRY(read(fd, buf, len))) > 0) {
|
/art/runtime/ |
exec_utils.cc | 76 pid_t got_pid = TEMP_FAILURE_RETRY(waitpid(pid, &status, 0));
|
/bootable/recovery/ |
fuse_sdcard_provider.cpp | 44 if (TEMP_FAILURE_RETRY(lseek64(fd.fd, offset, SEEK_SET)) == -1) {
|
/system/core/debuggerd/ |
debuggerd.cpp | 46 ssize_t rc = TEMP_FAILURE_RETRY(read(fd.get(), buf, sizeof(buf)));
|
/art/runtime/jdwp/ |
jdwp_adb.cc | 192 int rc = TEMP_FAILURE_RETRY(recvmsg(ControlSock(), &msg, 0)); 277 ret = TEMP_FAILURE_RETRY(send(control_sock, &pid, sizeof(pid), 0)); 466 int cc = TEMP_FAILURE_RETRY(write(clientSock, input_buffer_, kMagicHandshakeLen));
|
/device/google/wahoo/dumpstate/ |
DumpstateDevice.cpp | 167 android::base::unique_fd fdLog(TEMP_FAILURE_RETRY(open(modemLogCombined.c_str(), O_RDONLY | O_CLOEXEC | O_NONBLOCK))); 171 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(fdLog, buffer.data(), buffer.size())); 180 ssize_t result = TEMP_FAILURE_RETRY(write(fdModem, buffer.data(), bytes_read));
|
/frameworks/av/media/mtp/ |
MtpDescriptors.cpp | 264 ssize_t ret = TEMP_FAILURE_RETRY(write(fd, 268 ret = TEMP_FAILURE_RETRY(write(fd, 275 ret = TEMP_FAILURE_RETRY(write(fd, &mtp_strings, sizeof(mtp_strings)));
|
/system/core/debuggerd/client/ |
debuggerd_client.cpp | 144 TEMP_FAILURE_RETRY(recv(set_timeout(sockfd.get()), &response, sizeof(response), MSG_TRUNC)); 165 rc = TEMP_FAILURE_RETRY(recv(set_timeout(sockfd.get()), &response, sizeof(response), MSG_TRUNC)); 210 rc = TEMP_FAILURE_RETRY(read(pipe_read.get(), buf, sizeof(buf)));
|
/system/core/debuggerd/handler/ |
debuggerd_fallback.cpp | 140 if (TEMP_FAILURE_RETRY(read(src_fd, &tid, sizeof(tid))) != sizeof(tid)) { 153 ssize_t rc = TEMP_FAILURE_RETRY(read(src_fd, buf, sizeof(buf))); 209 if (TEMP_FAILURE_RETRY(write(fd, &tid, sizeof(tid))) == sizeof(tid)) {
|
/system/extras/tests/timetest/ |
rtc_test.cpp | 39 ret = TEMP_FAILURE_RETRY(stat(rtc, &st)); 48 ret = TEMP_FAILURE_RETRY(open(rtc, flag)); 61 ret = TEMP_FAILURE_RETRY(ioctl(fd.get(), request, tm));
|
/system/security/keystore/ |
user_state.cpp | 107 int in = TEMP_FAILURE_RETRY(open(src->getMasterKeyFileName(), O_RDONLY)); 117 TEMP_FAILURE_RETRY(open(mMasterKeyFile, O_WRONLY | O_TRUNC | O_CREAT, S_IRUSR | S_IWUSR)); 141 int in = TEMP_FAILURE_RETRY(open(mMasterKeyFile, O_RDONLY));
|
/system/vold/model/ |
PublicVolume.cpp | 76 if (TEMP_FAILURE_RETRY(mkdir(securePath.c_str(), 0700))) { 214 if (TEMP_FAILURE_RETRY(waitpid(mFusePid, nullptr, WNOHANG)) == mFusePid) 236 TEMP_FAILURE_RETRY(waitpid(mFusePid, nullptr, 0));
|