/system/core/fastboot/ |
H A D | socket.cpp | 99 int result = TEMP_FAILURE_RETRY(select(sock_ + 1, &read_set, nullptr, nullptr, &timeout)); 136 return TEMP_FAILURE_RETRY(sendto(sock_, reinterpret_cast<const char*>(data), length, 0, 147 return TEMP_FAILURE_RETRY(socket_send_buffers_function_( 163 return TEMP_FAILURE_RETRY(recvfrom(sock_, reinterpret_cast<char*>(data), length, 0, 185 TEMP_FAILURE_RETRY(send(sock_, reinterpret_cast<const char*>(data), length, 0)); 198 ssize_t sent = TEMP_FAILURE_RETRY( 235 return TEMP_FAILURE_RETRY(recv(sock_, reinterpret_cast<char*>(data), length, 0));
|
/system/extras/memory_replay/tests/ |
H A D | LineBufferTest.cpp | 42 ASSERT_TRUE(TEMP_FAILURE_RETRY( 61 ASSERT_TRUE(TEMP_FAILURE_RETRY( 82 ASSERT_TRUE(TEMP_FAILURE_RETRY( 111 ASSERT_TRUE(TEMP_FAILURE_RETRY( 141 ASSERT_TRUE(TEMP_FAILURE_RETRY( 176 ASSERT_TRUE(TEMP_FAILURE_RETRY( 211 ASSERT_TRUE(TEMP_FAILURE_RETRY(
|
/system/nvram/hal/ |
H A D | fake_nvram_storage.cpp | 66 if (TEMP_FAILURE_RETRY(unlinkat(g_data_dir_fd, name, 0))) { 80 TEMP_FAILURE_RETRY(openat(g_data_dir_fd, name, O_RDONLY))); 90 if (TEMP_FAILURE_RETRY(fstat(data_file_fd.get(), &data_file_stat))) { 116 android::base::unique_fd data_file_fd(TEMP_FAILURE_RETRY( 135 if (TEMP_FAILURE_RETRY(fdatasync(data_file_fd.get()))) { 144 if (TEMP_FAILURE_RETRY( 152 if (TEMP_FAILURE_RETRY(fsync(g_data_dir_fd))) {
|
H A D | fake_nvram.cpp | 118 TEMP_FAILURE_RETRY(read(socket, command_buffer, sizeof(command_buffer))); 142 if (TEMP_FAILURE_RETRY(write(socket, command_buffer, response_size)) < 0) { 159 while (TEMP_FAILURE_RETRY(poll(poll_fds, poll_fds_count, -1)) >= 0) { 230 TEMP_FAILURE_RETRY(open(g_data_directory_path, O_RDONLY | O_DIRECTORY));
|
H A D | testing_nvram_implementation.cpp | 106 ssize_t rc = TEMP_FAILURE_RETRY( 113 rc = TEMP_FAILURE_RETRY(
|
/system/core/adb/ |
H A D | sysdeps.h | 42 * TEMP_FAILURE_RETRY is defined by some, but not all, versions of 46 #ifndef TEMP_FAILURE_RETRY 48 #define TEMP_FAILURE_RETRY(exp) ({ \ macro 150 return TEMP_FAILURE_RETRY(unix_read_interruptible(fd, buf, len)); 397 return TEMP_FAILURE_RETRY( open(path, options) ); 406 return TEMP_FAILURE_RETRY( open( path, options, mode ) ); 414 return TEMP_FAILURE_RETRY( open( pathname, options, mode ) ); 427 int fd = TEMP_FAILURE_RETRY( open( pathname, options ) ); 465 return TEMP_FAILURE_RETRY( read( fd, buf, len ) ); 478 return TEMP_FAILURE_RETRY( writ [all...] |
/system/security/keystore/ |
H A D | keystore_utils.cpp | 35 ssize_t n = TEMP_FAILURE_RETRY(read(fd, data, remaining)); 48 ssize_t n = TEMP_FAILURE_RETRY(write(fd, data, remaining)); 56 if (TEMP_FAILURE_RETRY(fsync(fd)) == -1) {
|
/system/core/init/ |
H A D | signal_handler.cpp | 43 if (TEMP_FAILURE_RETRY(write(signal_write_fd, "1", 1)) == -1) {
|
/system/core/libmemunreachable/ |
H A D | LeakPipe.h | 102 ssize_t ret = TEMP_FAILURE_RETRY(write(fd_, &value, sizeof(T))); 121 ssize_t ret = TEMP_FAILURE_RETRY(write(fd_, vector.data(), size)); 140 ssize_t ret = TEMP_FAILURE_RETRY(read(fd_, reinterpret_cast<void*>(value), sizeof(T))); 163 ssize_t ret = TEMP_FAILURE_RETRY(read(fd_, ptr, size));
|
H A D | LineBuffer.cpp | 49 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1));
|
/system/core/libsysutils/src/ |
H A D | FrameworkClient.cpp | 40 ret = TEMP_FAILURE_RETRY(write(mSocket, msg, strlen(msg) +1));
|
H A D | NetlinkListener.cpp | 57 count = TEMP_FAILURE_RETRY(uevent_kernel_recv(socket,
|
/system/extras/memory_replay/ |
H A D | LineBuffer.cpp | 44 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1));
|
/system/bt/vendor_libs/linux/interface/ |
H A D | hci_packetizer.cc | 58 size_t bytes_read = TEMP_FAILURE_RETRY( 76 size_t bytes_read = TEMP_FAILURE_RETRY(read(
|
H A D | async_fd_watcher.cc | 110 if (TEMP_FAILURE_RETRY(write(notification_write_fd_, &buffer, 1)) < 0) { 168 TEMP_FAILURE_RETRY(read(notification_listen_fd_, buffer, 1));
|
/system/core/debuggerd/ |
H A D | util.cpp | 42 return TEMP_FAILURE_RETRY(sendmsg(sockfd, &msg, 0)); 61 ssize_t result = TEMP_FAILURE_RETRY(recvmsg(sockfd, &msg, 0));
|
/system/core/liblog/ |
H A D | logd_writer.c | 67 int sock = TEMP_FAILURE_RETRY( 77 if (TEMP_FAILURE_RETRY(connect(sock, (struct sockaddr*)&un, 197 ret = TEMP_FAILURE_RETRY(writev(sock, newVec, 2)); 217 ret = TEMP_FAILURE_RETRY(writev(sock, newVec, 2)); 250 ret = TEMP_FAILURE_RETRY(writev(sock, newVec, i)); 270 ret = TEMP_FAILURE_RETRY(
|
/system/core/libappfuse/ |
H A D | FuseBuffer.cc | 53 const ssize_t result = sockflag ? TEMP_FAILURE_RETRY(recv(fd, buf, sizeof(T), sockflag)) 54 : TEMP_FAILURE_RETRY(read(fd, buf, sizeof(T))); 100 result = TEMP_FAILURE_RETRY(send(fd, buf, header.len, sockflag)); 104 result = TEMP_FAILURE_RETRY(writev(fd, vec, arraysize(vec))); 106 result = TEMP_FAILURE_RETRY(write(fd, buf, header.len));
|
H A D | EpollController.cc | 29 const int result = TEMP_FAILURE_RETRY(epoll_wait(poll_fd_, events_.data(), event_count, -1));
|
/system/extras/simpleperf/ |
H A D | workload.cpp | 128 ssize_t nread = TEMP_FAILURE_RETRY(read(start_signal_fd, &start_signal, 1)); 145 TEMP_FAILURE_RETRY(write(exec_child_fd, &exec_child_failed, 1)); 158 ssize_t nwrite = TEMP_FAILURE_RETRY(write(start_signal_fd_, &start_signal, 1)); 164 ssize_t nread = TEMP_FAILURE_RETRY(read(exec_child_fd_, &exec_child_failed, 1)); 187 pid_t result = TEMP_FAILURE_RETRY(waitpid(work_pid_, &status, (wait_forever ? 0 : WNOHANG)));
|
/system/vold/ |
H A D | vdc.cpp | 111 if (TEMP_FAILURE_RETRY(write(sock, cmd.c_str(), cmd.length() + 1)) < 0) { 130 int rc = TEMP_FAILURE_RETRY(poll(&poll_sock, 1, timeout)); 145 rc = TEMP_FAILURE_RETRY(read(sock, buffer, sizeof(buffer)));
|
H A D | EmulatedVolume.cpp | 108 TEMP_FAILURE_RETRY(waitpid(mFusePid, nullptr, WNOHANG)); 125 TEMP_FAILURE_RETRY(waitpid(mFusePid, nullptr, 0));
|
/system/core/debuggerd/handler/ |
H A D | debuggerd_handler.cpp | 299 int devnull = TEMP_FAILURE_RETRY(open("/dev/null", O_RDWR)); 302 TEMP_FAILURE_RETRY(dup2(devnull, STDOUT_FILENO)); 303 TEMP_FAILURE_RETRY(dup2(devnull, STDERR_FILENO)); 316 TEMP_FAILURE_RETRY(dup2(pipefds[1], STDOUT_FILENO)); 338 ssize_t rc = TEMP_FAILURE_RETRY(read(pipefds[0], &buf, sizeof(buf))); 358 if (TEMP_FAILURE_RETRY(waitpid(forkpid, &status, 0)) == -1) {
|
/system/core/libmemunreachable/tests/ |
H A D | ThreadCapture_test.cpp | 187 EXPECT_EQ(1, TEMP_FAILURE_RETRY(write(start_pipe.Sender(), "+", 1))) << strerror(errno); 189 EXPECT_EQ(1, TEMP_FAILURE_RETRY(read(stop_pipe.Receiver(), &buf, 1))) << strerror(errno); 196 ASSERT_EQ(1, TEMP_FAILURE_RETRY(read(start_pipe.Receiver(), &buf, 1))) << strerror(errno); 200 ASSERT_EQ(1, TEMP_FAILURE_RETRY(write(stop_pipe.Sender(), "+", 1))) << strerror(errno); 202 ASSERT_EQ(0, TEMP_FAILURE_RETRY(waitid(P_PID, pid, &info, WEXITED))) << strerror(errno); 339 ASSERT_EQ(1, TEMP_FAILURE_RETRY(read(pipe.Receiver(), &buf, 1)));
|
/system/core/debuggerd/tombstoned/ |
H A D | intercept_manager.cpp | 123 TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response))); 137 TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response))); 146 if (TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response))) == -1) { 215 TEMP_FAILURE_RETRY(write(intercept->sockfd, &response, sizeof(response)));
|