Searched refs:TEMP_FAILURE_RETRY (Results 26 - 50 of 155) sorted by relevance

1234567

/system/core/fastboot/
H A Dsocket.cpp99 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 DLineBufferTest.cpp42 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 Dfake_nvram_storage.cpp66 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 Dfake_nvram.cpp118 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 Dtesting_nvram_implementation.cpp106 ssize_t rc = TEMP_FAILURE_RETRY(
113 rc = TEMP_FAILURE_RETRY(
/system/core/adb/
H A Dsysdeps.h42 * 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 Dkeystore_utils.cpp35 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 Dsignal_handler.cpp43 if (TEMP_FAILURE_RETRY(write(signal_write_fd, "1", 1)) == -1) {
/system/core/libmemunreachable/
H A DLeakPipe.h102 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 DLineBuffer.cpp49 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1));
/system/core/libsysutils/src/
H A DFrameworkClient.cpp40 ret = TEMP_FAILURE_RETRY(write(mSocket, msg, strlen(msg) +1));
H A DNetlinkListener.cpp57 count = TEMP_FAILURE_RETRY(uevent_kernel_recv(socket,
/system/extras/memory_replay/
H A DLineBuffer.cpp44 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1));
/system/bt/vendor_libs/linux/interface/
H A Dhci_packetizer.cc58 size_t bytes_read = TEMP_FAILURE_RETRY(
76 size_t bytes_read = TEMP_FAILURE_RETRY(read(
H A Dasync_fd_watcher.cc110 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 Dutil.cpp42 return TEMP_FAILURE_RETRY(sendmsg(sockfd, &msg, 0));
61 ssize_t result = TEMP_FAILURE_RETRY(recvmsg(sockfd, &msg, 0));
/system/core/liblog/
H A Dlogd_writer.c67 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 DFuseBuffer.cc53 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 DEpollController.cc29 const int result = TEMP_FAILURE_RETRY(epoll_wait(poll_fd_, events_.data(), event_count, -1));
/system/extras/simpleperf/
H A Dworkload.cpp128 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 Dvdc.cpp111 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 DEmulatedVolume.cpp108 TEMP_FAILURE_RETRY(waitpid(mFusePid, nullptr, WNOHANG));
125 TEMP_FAILURE_RETRY(waitpid(mFusePid, nullptr, 0));
/system/core/debuggerd/handler/
H A Ddebuggerd_handler.cpp299 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 DThreadCapture_test.cpp187 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 Dintercept_manager.cpp123 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)));

Completed in 413 milliseconds

1234567