Home
last modified time | relevance | path

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

1234

/system/vold/
DBenchmarkGen.h42 int t3433f17 = TEMP_FAILURE_RETRY(open("file0", O_RDONLY|O_LARGEFILE)); in BenchmarkRun()
43 TEMP_FAILURE_RETRY(lseek(t3433f17, 0, SEEK_END)); in BenchmarkRun()
44 TEMP_FAILURE_RETRY(lseek(t3433f17, 38891199, SEEK_SET)); in BenchmarkRun()
45 TEMP_FAILURE_RETRY(read(t3433f17, buf, 65557)); in BenchmarkRun()
46 TEMP_FAILURE_RETRY(pread(t3433f17, buf, 769726, 38187008)); // mmap2 in BenchmarkRun()
47 TEMP_FAILURE_RETRY(pread(t3433f17, buf, 30, 278721)); in BenchmarkRun()
48 TEMP_FAILURE_RETRY(pread(t3433f17, buf, 19, 278751)); in BenchmarkRun()
49 TEMP_FAILURE_RETRY(pread(t3433f17, buf, 25119, 278528)); // mmap2 in BenchmarkRun()
50 TEMP_FAILURE_RETRY(pread(t3433f17, buf, 30, 37276895)); in BenchmarkRun()
51 TEMP_FAILURE_RETRY(pread(t3433f17, buf, 14, 37276925)); in BenchmarkRun()
[all …]
Dvdc.cpp103 if (TEMP_FAILURE_RETRY(write(sock, cmd.c_str(), cmd.length() + 1)) < 0) { in do_cmd()
122 int rc = TEMP_FAILURE_RETRY(poll(&poll_sock, 1, timeout)); in do_monitor()
137 rc = TEMP_FAILURE_RETRY(read(sock, buffer, sizeof(buffer))); in do_monitor()
/system/core/libcutils/
Dashmem-dev.c54 int fd = TEMP_FAILURE_RETRY(open(ASHMEM_DEVICE, O_RDWR)); in __ashmem_open_locked()
59 ret = TEMP_FAILURE_RETRY(fstat(fd, &st)); in __ashmem_open_locked()
93 if (TEMP_FAILURE_RETRY(fstat(fd, &st)) < 0) { in __ashmem_is_ashmem()
156 ret = TEMP_FAILURE_RETRY(ioctl(fd, ASHMEM_SET_NAME, buf)); in ashmem_create_region()
162 ret = TEMP_FAILURE_RETRY(ioctl(fd, ASHMEM_SET_SIZE, size)); in ashmem_create_region()
183 return TEMP_FAILURE_RETRY(ioctl(fd, ASHMEM_SET_PROT_MASK, prot)); in ashmem_set_prot_region()
195 return TEMP_FAILURE_RETRY(ioctl(fd, ASHMEM_PIN, &pin)); in ashmem_pin_region()
207 return TEMP_FAILURE_RETRY(ioctl(fd, ASHMEM_UNPIN, &pin)); in ashmem_unpin_region()
217 return TEMP_FAILURE_RETRY(ioctl(fd, ASHMEM_GET_SIZE, NULL)); in ashmem_get_size_region()
Dqtaguid.c50 resTrackFd = TEMP_FAILURE_RETRY(open("/dev/xt_qtaguid", O_RDONLY)); in qtaguid_resTrack()
52 TEMP_FAILURE_RETRY(fcntl(resTrackFd, F_SETFD, FD_CLOEXEC)); in qtaguid_resTrack()
66 fd = TEMP_FAILURE_RETRY(open(CTRL_PROCPATH, O_WRONLY)); in write_ctrl()
71 res = TEMP_FAILURE_RETRY(write(fd, cmd, strlen(cmd))); in write_ctrl()
89 param_fd = TEMP_FAILURE_RETRY(open(param_path, O_WRONLY)); in write_param()
93 res = TEMP_FAILURE_RETRY(write(param_fd, value, strlen(value))); in write_param()
Dfs.c45 if (TEMP_FAILURE_RETRY(lstat(path, &sb)) == -1) { in fs_prepare_path_impl()
81 ? TEMP_FAILURE_RETRY(mkdir(path, mode)) in fs_prepare_path_impl()
82 : TEMP_FAILURE_RETRY(open(path, O_CREAT | O_CLOEXEC | O_NOFOLLOW | O_RDONLY)); in fs_prepare_path_impl()
96 if (TEMP_FAILURE_RETRY(chmod(path, mode)) == -1) { in fs_prepare_path_impl()
100 if (TEMP_FAILURE_RETRY(chown(path, uid, gid)) == -1) { in fs_prepare_path_impl()
121 int fd = TEMP_FAILURE_RETRY(open(path, O_RDONLY)); in fs_read_atomic_int()
128 if (TEMP_FAILURE_RETRY(read(fd, buf, BUF_SIZE)) == -1) { in fs_read_atomic_int()
152 int fd = TEMP_FAILURE_RETRY(mkstemp(temp)); in fs_write_atomic_int()
164 if (TEMP_FAILURE_RETRY(write(fd, buf, len)) < len) { in fs_write_atomic_int()
Ddebugger.c34 if (TEMP_FAILURE_RETRY(write(sock_fd, msg_ptr, msg_len)) != (ssize_t) msg_len) { in send_request()
38 if (TEMP_FAILURE_RETRY(read(sock_fd, &ack, 1)) != 1) { in send_request()
92 while ((n = TEMP_FAILURE_RETRY(read(sock_fd, buffer, sizeof(buffer)))) > 0) { in dump_backtrace_to_file_timeout()
93 if (TEMP_FAILURE_RETRY(write(fd, buffer, n)) != n) { in dump_backtrace_to_file_timeout()
115 ssize_t n = TEMP_FAILURE_RETRY(read(sock_fd, buffer, sizeof(buffer) - 1)); in dump_tombstone_timeout()
/system/core/libsuspend/
Dautosuspend_earlysuspend.c52 int fd = TEMP_FAILURE_RETRY(open(EARLYSUSPEND_WAIT_FOR_FB_WAKE, O_RDONLY, 0)); in wait_for_fb_wake()
54 err = TEMP_FAILURE_RETRY(read(fd, &buf, 1)); in wait_for_fb_wake()
65 int fd = TEMP_FAILURE_RETRY(open(EARLYSUSPEND_WAIT_FOR_FB_SLEEP, O_RDONLY, 0)); in wait_for_fb_sleep()
67 err = TEMP_FAILURE_RETRY(read(fd, &buf, 1)); in wait_for_fb_sleep()
133 ret = TEMP_FAILURE_RETRY(write(sPowerStatefd, pwr_state_on, strlen(pwr_state_on))); in autosuspend_earlysuspend_disable()
194 sPowerStatefd = TEMP_FAILURE_RETRY(open(EARLYSUSPEND_SYS_POWER_STATE, O_RDWR)); in autosuspend_earlysuspend_init()
202 ret = TEMP_FAILURE_RETRY(write(sPowerStatefd, "on", 2)); in autosuspend_earlysuspend_init()
Dautosuspend_wakeup_count.c56 wakeup_count_len = TEMP_FAILURE_RETRY(read(wakeup_count_fd, wakeup_count, in suspend_thread_func()
79 ret = TEMP_FAILURE_RETRY(write(wakeup_count_fd, wakeup_count, wakeup_count_len)); in suspend_thread_func()
85 ret = TEMP_FAILURE_RETRY(write(state_fd, sleep_state, strlen(sleep_state))); in suspend_thread_func()
162 state_fd = TEMP_FAILURE_RETRY(open(SYS_POWER_STATE, O_RDWR)); in autosuspend_wakeup_count_init()
169 wakeup_count_fd = TEMP_FAILURE_RETRY(open(SYS_POWER_WAKEUP_COUNT, O_RDWR)); in autosuspend_wakeup_count_init()
Dautosuspend_autosleep.c43 ret = TEMP_FAILURE_RETRY(write(autosleep_fd, sleep_state, strlen(sleep_state))); in autosuspend_autosleep_enable()
65 ret = TEMP_FAILURE_RETRY(write(autosleep_fd, on_state, strlen(on_state))); in autosuspend_autosleep_disable()
89 autosleep_fd = TEMP_FAILURE_RETRY(open(SYS_POWER_AUTOSLEEP, O_WRONLY)); in autosuspend_autosleep_init()
/system/core/base/
Dfile.cpp43 while ((n = TEMP_FAILURE_RETRY(read(fd, &buf[0], sizeof(buf)))) > 0) { in ReadFdToString()
52 int fd = TEMP_FAILURE_RETRY(open(path.c_str(), O_RDONLY | O_CLOEXEC | O_NOFOLLOW | O_BINARY)); in ReadFileToString()
65 ssize_t n = TEMP_FAILURE_RETRY(write(fd, p, left)); in WriteStringToFd()
87 int fd = TEMP_FAILURE_RETRY(open(path.c_str(), flags, mode)); in WriteStringToFile()
114 int fd = TEMP_FAILURE_RETRY(open(path.c_str(), flags, DEFFILEMODE)); in WriteStringToFile()
128 ssize_t n = TEMP_FAILURE_RETRY(read(fd, p, remaining)); in ReadFully()
140 ssize_t n = TEMP_FAILURE_RETRY(write(fd, p, remaining)); in WriteFully()
/system/core/liblog/
Dlogd_writer.c70 i = TEMP_FAILURE_RETRY(socket(PF_UNIX, SOCK_DGRAM | SOCK_CLOEXEC, 0)); in logdOpen()
73 } else if (TEMP_FAILURE_RETRY(fcntl(i, F_SETFL, O_NONBLOCK)) < 0) { in logdOpen()
82 if (TEMP_FAILURE_RETRY(connect(i, (struct sockaddr *)&un, in logdOpen()
181 ret = TEMP_FAILURE_RETRY(writev(logdLoggerWrite.context.sock, newVec, 2)); in logdWrite()
201 ret = TEMP_FAILURE_RETRY(writev(logdLoggerWrite.context.sock, newVec, 2)); in logdWrite()
230 ret = TEMP_FAILURE_RETRY(writev(logdLoggerWrite.context.sock, newVec, i)); in logdWrite()
243 ret = TEMP_FAILURE_RETRY(writev(logdLoggerWrite.context.sock, newVec, i)); in logdWrite()
Dlog_portability.h72 #ifndef TEMP_FAILURE_RETRY
74 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
/system/extras/simpleperf/
Dworkload.cpp101 ssize_t nread = TEMP_FAILURE_RETRY(read(start_signal_fd, &start_signal, 1)); in ChildProcessFn()
109 TEMP_FAILURE_RETRY(write(exec_child_fd, &exec_child_failed, 1)); in ChildProcessFn()
121 ssize_t nwrite = TEMP_FAILURE_RETRY(write(start_signal_fd_, &start_signal, 1)); in Start()
127 ssize_t nread = TEMP_FAILURE_RETRY(read(exec_child_fd_, &exec_child_failed, 1)); in Start()
143 pid_t result = TEMP_FAILURE_RETRY(waitpid(work_pid_, &status, (wait_forever ? 0 : WNOHANG))); in WaitChildProcess()
/system/extras/memory_replay/tests/
DNativeInfoTest.cpp58 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
119 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
180 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
257 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
DLineBufferTest.cpp42 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
61 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
82 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
111 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
141 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
176 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
211 ASSERT_TRUE(TEMP_FAILURE_RETRY( in TEST_F()
/system/core/fastboot/
Dsocket.cpp99 int result = TEMP_FAILURE_RETRY(select(sock_ + 1, &read_set, nullptr, nullptr, &timeout)); in WaitForRecv()
136 return TEMP_FAILURE_RETRY(sendto(sock_, reinterpret_cast<const char*>(data), length, 0, in Send()
147 return TEMP_FAILURE_RETRY(socket_send_buffers_function_( in Send()
163 return TEMP_FAILURE_RETRY(recvfrom(sock_, reinterpret_cast<char*>(data), length, 0, in Receive()
185 TEMP_FAILURE_RETRY(send(sock_, reinterpret_cast<const char*>(data), length, 0)); in Send()
198 ssize_t sent = TEMP_FAILURE_RETRY( in Send()
235 return TEMP_FAILURE_RETRY(recv(sock_, reinterpret_cast<char*>(data), length, 0)); in Receive()
/system/core/debuggerd/
Dsignal_sender.cpp89 int rc = TEMP_FAILURE_RETRY(read(sfd[0], &msg, sizeof(msg))); in start_signal_sender()
110 if (TEMP_FAILURE_RETRY(write(sfd[0], &err, sizeof(err))) < 0) { in start_signal_sender()
156 if (TEMP_FAILURE_RETRY(write(signal_fd, &msg, sizeof(msg))) < 0) { in send_signal()
163 ssize_t rc = TEMP_FAILURE_RETRY(read(signal_fd, &response, sizeof(response))); in send_signal()
/system/netd/client/
DFwmarkClient.cpp53 if (TEMP_FAILURE_RETRY(connect(mChannel, reinterpret_cast<const sockaddr*>(&FWMARK_SERVER_PATH), in send()
86 if (TEMP_FAILURE_RETRY(sendmsg(mChannel, &message, 0)) == -1) { in send()
92 if (TEMP_FAILURE_RETRY(recv(mChannel, &error, sizeof(error), 0)) == -1) { in send()
/system/core/libmemunreachable/
DLeakPipe.h106 ssize_t ret = TEMP_FAILURE_RETRY(write(fd_, &value, sizeof(T))); in Send()
125 ssize_t ret = TEMP_FAILURE_RETRY(write(fd_, vector.data(), size)); in SendVector()
144 ssize_t ret = TEMP_FAILURE_RETRY(read(fd_, reinterpret_cast<void*>(value), sizeof(T))); in Receive()
167 ssize_t ret = TEMP_FAILURE_RETRY(read(fd_, ptr, size)); in ReceiveVector()
/system/core/include/cutils/
Dfs.h28 #ifndef TEMP_FAILURE_RETRY
30 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
/system/core/adb/
Dsysdeps.h42 #ifndef TEMP_FAILURE_RETRY
44 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
236 return TEMP_FAILURE_RETRY(unix_read_interruptible(fd, buf, len)); in unix_read()
527 return TEMP_FAILURE_RETRY( open(path, options) ); in unix_open()
536 return TEMP_FAILURE_RETRY( open( path, options, mode ) ); in unix_open()
544 return TEMP_FAILURE_RETRY( open( pathname, options, mode ) ); in adb_open_mode()
557 int fd = TEMP_FAILURE_RETRY( open( pathname, options ) ); in adb_open()
589 return TEMP_FAILURE_RETRY( read( fd, buf, len ) ); in adb_read()
602 return TEMP_FAILURE_RETRY( write( fd, buf, len ) ); in adb_write()
623 int fd = TEMP_FAILURE_RETRY( creat( path, mode ) ); in adb_creat()
[all …]
/system/core/include/utils/
DCompat.h72 #ifndef TEMP_FAILURE_RETRY
74 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
/system/core/libmemunreachable/tests/
DThreadCapture_test.cpp191 EXPECT_EQ(1, TEMP_FAILURE_RETRY(write(start_pipe.Sender(), "+", 1))) << strerror(errno); in Fork()
193 EXPECT_EQ(1, TEMP_FAILURE_RETRY(read(stop_pipe.Receiver(), &buf, 1))) << strerror(errno); in Fork()
200 ASSERT_EQ(1, TEMP_FAILURE_RETRY(read(start_pipe.Receiver(), &buf, 1))) << strerror(errno); in Fork()
204 ASSERT_EQ(1, TEMP_FAILURE_RETRY(write(stop_pipe.Sender(), "+", 1))) << strerror(errno); in Fork()
206 ASSERT_EQ(0, TEMP_FAILURE_RETRY(waitid(P_PID, pid, &info, WEXITED))) << strerror(errno); in Fork()
341 ASSERT_EQ(1, TEMP_FAILURE_RETRY(read(pipe.Receiver(), &buf, 1))); in TEST_F()
/system/extras/squashfs_utils/
Dsquashfs_utils.c66 data_device = TEMP_FAILURE_RETRY(open(blk_device, O_RDONLY | O_CLOEXEC)); in squashfs_parse_sb()
72 if (TEMP_FAILURE_RETRY(read(data_device, &sb, sizeof(sb))) in squashfs_parse_sb()
/system/core/base/include/android-base/
Dmacros.h24 #ifndef TEMP_FAILURE_RETRY
25 #define TEMP_FAILURE_RETRY(exp) \ macro

1234