Home
last modified time | relevance | path

Searched refs:TEMP_FAILURE_RETRY (Results 1 – 25 of 28) sorted by relevance

12

/packages/modules/Virtualization/tests/benchmark/src/native/
Dio_vsock.cpp29 int server_fd(TEMP_FAILURE_RETRY(socket(AF_VSOCK, SOCK_STREAM | SOCK_CLOEXEC, 0))); in init_vsock_server()
39 int ret = TEMP_FAILURE_RETRY(bind(server_fd, (struct sockaddr *)&server_sa, sizeof(server_sa))); in init_vsock_server()
43 ret = TEMP_FAILURE_RETRY(listen(server_fd, /*backlog=*/1)); in init_vsock_server()
55 unique_fd client_fd(TEMP_FAILURE_RETRY( in run_vsock_server_and_receive_data()
66 ssize_t n = TEMP_FAILURE_RETRY(read(client_fd.get(), buf, sizeof(buf))); in run_vsock_server_and_receive_data()
/packages/modules/StatsD/lib/libstatssocket/
Dstatsd_writer.cpp43 #ifndef TEMP_FAILURE_RETRY
44 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
106 int sock = TEMP_FAILURE_RETRY(socket(PF_UNIX, flags, 0)); in statsdOpen()
120 if (TEMP_FAILURE_RETRY( in statsdOpen()
243 ret = TEMP_FAILURE_RETRY(writev(sock, newVec, 2)); in statsdWrite()
280 ret = TEMP_FAILURE_RETRY(writev(sock, newVec, i)); in statsdWrite()
301 ret = TEMP_FAILURE_RETRY(writev(atomic_load(&statsdLoggerWrite.sock), newVec, i)); in statsdWrite()
/packages/modules/adb/
Dsysdeps.h128 return TEMP_FAILURE_RETRY(unix_read_interruptible(fd, buf, len)); in unix_read()
453 return TEMP_FAILURE_RETRY(open(zero_terminated.c_str(), options)); in unix_open()
460 return TEMP_FAILURE_RETRY(open(zero_terminated.c_str(), options, mode)); in unix_open()
467 return TEMP_FAILURE_RETRY(open(pathname, options, mode)); in adb_open_mode()
478 int fd = TEMP_FAILURE_RETRY(open(pathname, options)); in adb_open()
518 return TEMP_FAILURE_RETRY(read(fd.get(), buf, len)); in adb_read()
523 return TEMP_FAILURE_RETRY(pread(fd.get(), buf, len, offset)); in adb_pread()
525 return TEMP_FAILURE_RETRY(pread64(fd.get(), buf, len, offset)); in adb_pread()
540 return TEMP_FAILURE_RETRY(write(fd.get(), buf, len)); in adb_write()
545 return TEMP_FAILURE_RETRY(pwrite(fd, buf, len, offset)); in adb_pwrite()
[all …]
Dtransport_fd.cpp165 if (TEMP_FAILURE_RETRY(adb_write(wake_fd_write_.get(), &buf, sizeof(buf))) != sizeof(buf)) { in WakeThread()
Dadb_utils.cpp63 if (TEMP_FAILURE_RETRY(dup2(fd, STDIN_FILENO)) == -1) { in close_stdin()
/packages/modules/StatsD/statsd/tests/storage/
DStorageManager_test.cpp114 android::base::unique_fd fd(TEMP_FAILURE_RETRY( in prepareLocalHistoryTestFiles()
122 android::base::unique_fd fd2(TEMP_FAILURE_RETRY( in prepareLocalHistoryTestFiles()
133 TEMP_FAILURE_RETRY(remove(file1.c_str())); in clearLocalHistoryTestFiles()
134 TEMP_FAILURE_RETRY(remove(file2.c_str())); in clearLocalHistoryTestFiles()
135 TEMP_FAILURE_RETRY(remove(file1_history.c_str())); in clearLocalHistoryTestFiles()
136 TEMP_FAILURE_RETRY(remove(file2_history.c_str())); in clearLocalHistoryTestFiles()
140 android::base::unique_fd fd(TEMP_FAILURE_RETRY(open(name.c_str(), O_RDONLY | O_CLOEXEC))); in fileExist()
/packages/modules/adb/libs/adbconnection/
Dadbconnection_server.cpp39 ssize_t rc = TEMP_FAILURE_RETRY(recv(socket, proto.data(), proto.length(), MSG_PEEK)); in readProcessInfoFromSocket()
53 rc = TEMP_FAILURE_RETRY(recv(socket, proto.data(), message_size, 0)); in readProcessInfoFromSocket()
105 int epoll_rc = TEMP_FAILURE_RETRY(epoll_wait(epfd.get(), events.data(), events.size(), -1)); in adbconnection_listen()
114 TEMP_FAILURE_RETRY(accept4(s.get(), nullptr, nullptr, SOCK_NONBLOCK | SOCK_CLOEXEC))); in adbconnection_listen()
Dadbconnection_client.cpp104 ssize_t rc = TEMP_FAILURE_RETRY( in send_app_info()
/packages/services/Car/cpp/bugreport/
Dmain.cpp137 TEMP_FAILURE_RETRY(open(filepath.c_str(), O_RDONLY | O_NOFOLLOW))); in zipFilesToFd()
144 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(fd, buffer, sizeof(buffer))); in zipFilesToFd()
178 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(fd_in, buffer, buffer_len)); in copyTo()
200 android::base::unique_fd fd(TEMP_FAILURE_RETRY(open(zip_path.c_str(), O_RDONLY | O_NOFOLLOW))); in copyFile()
290 int ret = TEMP_FAILURE_RETRY(sigtimedwait(&child_mask, nullptr, &ts)); in waitpid_with_timeout()
426 if (TEMP_FAILURE_RETRY(stat(dir, &sb)) == 0) { in createTempDir()
434 if (TEMP_FAILURE_RETRY(mkdir(dir, 0700)) == -1) { in createTempDir()
/packages/modules/Bluetooth/system/log/src/
Dvlog_android.cc69 TEMP_FAILURE_RETRY(write(2, buf, strlen(buf))); in vlog()
70 TEMP_FAILURE_RETRY(write(2, "\n", 1)); in vlog()
/packages/modules/Bluetooth/tools/rootcanal/model/setup/
Dasync_manager.cc31 #ifndef TEMP_FAILURE_RETRY
33 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
200 if (TEMP_FAILURE_RETRY(write(notification_write_fd_, &buffer, 1)) < 0) { in notifyThread()
227 while (TEMP_FAILURE_RETRY(read(notification_listen_fd_, buffer, in consumeThreadNotifications()
/packages/modules/adb/client/pairing/tests/
Dpairing_server.cpp247 int rc = TEMP_FAILURE_RETRY(epoll_wait(epoll_fd_.get(), events, 2, -1)); in serverWorker()
264 int rc = TEMP_FAILURE_RETRY(read(event_fd_.get(), &dummy, sizeof(dummy))); in serverWorker()
371 unique_fd ufd(TEMP_FAILURE_RETRY(accept4(fd, nullptr, nullptr, SOCK_CLOEXEC))); in handleNewClientConnection()
/packages/modules/Virtualization/tests/testapk/src/native/
Dtestbinary.cpp119 unique_fd server_fd{TEMP_FAILURE_RETRY(socket(AF_VSOCK, SOCK_STREAM | SOCK_CLOEXEC, 0))}; in start_echo_reverse_server()
128 int ret = TEMP_FAILURE_RETRY(bind(server_fd, (struct sockaddr*)&server_sa, sizeof(server_sa))); in start_echo_reverse_server()
132 ret = TEMP_FAILURE_RETRY(listen(server_fd, /*backlog=*/1)); in start_echo_reverse_server()
/packages/services/Car/cpp/security/vehicle_binding_util/src/
DVehicleBindingUtil.cpp122 int fd = TEMP_FAILURE_RETRY(open("/dev/urandom", O_RDONLY | O_CLOEXEC | O_NOFOLLOW)); in fill()
130 while ((bytes_read = TEMP_FAILURE_RETRY(read(fd, bufptr, size))) > 0) { in fill()
/packages/modules/adb/fdevent/
Dfdevent_epoll.cpp35 ssize_t rc = TEMP_FAILURE_RETRY(adb_read(fd, &buf, sizeof(buf))); in fdevent_interrupt()
203 ssize_t rc = TEMP_FAILURE_RETRY(adb_write(this->interrupt_fd_, &i, sizeof(i))); in Interrupt()
Dfdevent_poll.cpp55 ssize_t rc = TEMP_FAILURE_RETRY(adb_read(fd, buf, sizeof(buf))); in fdevent_interrupt()
/packages/modules/DnsResolver/
DDnsTlsSocket.cpp60 return TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in waitForReading()
65 return TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in waitForWriting()
341 int n = TEMP_FAILURE_RETRY(poll(fds, std::size(fds), mConnectTimeoutMs)); in sslConnectV2()
442 const int s = TEMP_FAILURE_RETRY(poll(fds, std::size(fds), timeout_msecs)); in loop()
DDnsTlsTransport.cpp124 const int n = TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in sendUdpQuery()
/packages/modules/adb/pairing_connection/
Dpairing_server.cpp267 int rc = TEMP_FAILURE_RETRY(epoll_wait(epoll_fd_.get(), events, 2, -1)); in ServerWorker()
284 int rc = TEMP_FAILURE_RETRY(read(event_fd_.get(), &dummy, sizeof(dummy))); in ServerWorker()
402 unique_fd ufd(TEMP_FAILURE_RETRY(accept4(fd, nullptr, nullptr, SOCK_CLOEXEC))); in HandleNewClientConnection()
/packages/modules/Bluetooth/system/btif/src/
Dbtif_bqr.cc172 TEMP_FAILURE_RETRY(write(fd, ss_log.str().c_str(), ss_log.str().size())); in WriteLmpLlTraceLogFile()
173 TEMP_FAILURE_RETRY( in WriteLmpLlTraceLogFile()
194 TEMP_FAILURE_RETRY(write(fd, ss_log.str().c_str(), ss_log.str().size())); in WriteBtSchedulingTraceLogFile()
195 TEMP_FAILURE_RETRY( in WriteBtSchedulingTraceLogFile()
/packages/modules/StatsD/statsd/src/
Dmain.cpp75 if (TEMP_FAILURE_RETRY( in initSeedRandom()
/packages/modules/adb/daemon/
Dframebuffer_service.cpp186 TEMP_FAILURE_RETRY(waitpid(pid, nullptr, 0)); in framebuffer_service()
Dusb.cpp273 int rc = TEMP_FAILURE_RETRY(adb_poll(pfd, 2, timeout_ms)); in StartMonitor()
287 rc = TEMP_FAILURE_RETRY(adb_read(control_fd_.get(), &event, sizeof(event))); in StartMonitor()
/packages/modules/adb/client/
Dusb_linux.cpp332 if (TEMP_FAILURE_RETRY(ioctl(h->fd, USBDEVFS_SUBMITURB, urb)) == -1) { in usb_bulk_write()
371 if (TEMP_FAILURE_RETRY(ioctl(h->fd, USBDEVFS_SUBMITURB, urb)) == -1) { in usb_bulk_read()
/packages/modules/DnsResolver/tests/
Dresolv_test_utils.cpp164 const pid_t got_pid = TEMP_FAILURE_RETRY(waitpid(pid, &status, 0)); in WaitChild()

12