Home
last modified time | relevance | path

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

12

/system/core/libcutils/
Ddebugger.c61 if (TEMP_FAILURE_RETRY(write(sock_fd, msg_ptr, msg_len)) != (ssize_t) msg_len) { in send_request()
65 if (TEMP_FAILURE_RETRY(read(sock_fd, &ack, 1)) != 1) { in send_request()
120 TEMP_FAILURE_RETRY(close(sock_fd)); in make_dump_request()
141 while ((n = TEMP_FAILURE_RETRY(read(sock_fd, buffer, sizeof(buffer)))) > 0) { in dump_backtrace_to_file_timeout()
142 if (TEMP_FAILURE_RETRY(write(fd, buffer, n)) != n) { in dump_backtrace_to_file_timeout()
147 TEMP_FAILURE_RETRY(close(sock_fd)); in dump_backtrace_to_file_timeout()
164 ssize_t n = TEMP_FAILURE_RETRY(read(sock_fd, buffer, sizeof(buffer) - 1)); in dump_tombstone_timeout()
176 TEMP_FAILURE_RETRY(close(sock_fd)); in dump_tombstone_timeout()
Dfs.c43 if (TEMP_FAILURE_RETRY(lstat(path, &sb)) == -1) { in fs_prepare_dir()
64 if (TEMP_FAILURE_RETRY(mkdir(path, mode)) == -1) { in fs_prepare_dir()
72 if (TEMP_FAILURE_RETRY(chmod(path, mode)) == -1) { in fs_prepare_dir()
76 if (TEMP_FAILURE_RETRY(chown(path, uid, gid)) == -1) { in fs_prepare_dir()
85 int fd = TEMP_FAILURE_RETRY(open(path, O_RDONLY)); in fs_read_atomic_int()
92 if (TEMP_FAILURE_RETRY(read(fd, buf, BUF_SIZE)) == -1) { in fs_read_atomic_int()
116 int fd = TEMP_FAILURE_RETRY(mkstemp(temp)); in fs_write_atomic_int()
128 if (TEMP_FAILURE_RETRY(write(fd, buf, len)) < len) { in fs_write_atomic_int()
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()
88 param_fd = TEMP_FAILURE_RETRY(open(param_path, O_WRONLY)); in write_param()
92 res = TEMP_FAILURE_RETRY(write(param_fd, value, strlen(value))); in write_param()
/system/core/fs_mgr/
Dfs_mgr_verity.c125 data_device = TEMP_FAILURE_RETRY(open(blk_device, O_RDONLY | O_CLOEXEC)); in get_target_device_size()
131 if (TEMP_FAILURE_RETRY(lseek64(data_device, 1024, SEEK_SET)) < 0) { in get_target_device_size()
133 TEMP_FAILURE_RETRY(close(data_device)); in get_target_device_size()
137 if (TEMP_FAILURE_RETRY(read(data_device, &sb, sizeof(sb))) != sizeof(sb)) { in get_target_device_size()
139 TEMP_FAILURE_RETRY(close(data_device)); in get_target_device_size()
146 TEMP_FAILURE_RETRY(close(data_device)); in get_target_device_size()
161 device = TEMP_FAILURE_RETRY(open(block_device, O_RDONLY | O_CLOEXEC)); in read_verity_metadata()
172 if (TEMP_FAILURE_RETRY(lseek64(device, device_length, SEEK_SET)) < 0) { in read_verity_metadata()
178 if (TEMP_FAILURE_RETRY(read(device, &magic_number, sizeof(magic_number))) != in read_verity_metadata()
199 if (TEMP_FAILURE_RETRY(read(device, &protocol_version, in read_verity_metadata()
[all …]
/system/netd/client/
DFwmarkClient.cpp49 if (TEMP_FAILURE_RETRY(connect(mChannel, reinterpret_cast<const sockaddr*>(&FWMARK_SERVER_PATH), in send()
80 if (TEMP_FAILURE_RETRY(sendmsg(mChannel, &message, 0)) == -1) { in send()
86 if (TEMP_FAILURE_RETRY(recv(mChannel, &error, sizeof(error), 0)) == -1) { in send()
/system/core/include/cutils/
Dfs.h28 #ifndef TEMP_FAILURE_RETRY
30 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
/system/core/adb/
Dsysdeps.h287 #ifndef TEMP_FAILURE_RETRY
289 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
331 return TEMP_FAILURE_RETRY( open(path, options) ); in unix_open()
340 return TEMP_FAILURE_RETRY( open( path, options, mode ) ); in unix_open()
346 return TEMP_FAILURE_RETRY( open( pathname, options, mode ) ); in adb_open_mode()
352 int fd = TEMP_FAILURE_RETRY( open( pathname, options ) ); in adb_open()
378 return TEMP_FAILURE_RETRY( read( fd, buf, len ) ); in adb_read()
386 return TEMP_FAILURE_RETRY( write( fd, buf, len ) ); in adb_write()
407 int fd = TEMP_FAILURE_RETRY( creat( path, mode ) ); in adb_creat()
422 fd = TEMP_FAILURE_RETRY( accept( serverfd, addr, addrlen ) ); in adb_socket_accept()
/system/core/include/utils/
DCompat.h55 #ifndef TEMP_FAILURE_RETRY
57 #define TEMP_FAILURE_RETRY(exp) ({ \ macro
/system/core/libziparchive/
Dzip_archive_test.cc181 ASSERT_EQ(file_size, TEMP_FAILURE_RETRY(write(fd, kEmptyEntriesZip, file_size))); in TEST()
214 ASSERT_EQ(file_size, TEMP_FAILURE_RETRY(write(fd, kEmptyEntriesZip, file_size))); in TEST()
215 ASSERT_EQ(trailer_size, TEMP_FAILURE_RETRY(write(fd, trailer, trailer_size))); in TEST()
228 ASSERT_EQ(data_size, TEMP_FAILURE_RETRY(write(fd, data, data_size))); in TEST()
241 ASSERT_EQ(data_size, TEMP_FAILURE_RETRY(read(fd, read_buffer, data_size))); in TEST()
247 TEMP_FAILURE_RETRY( in TEST()
Dzip_archive.cc354 ssize_t actual = TEMP_FAILURE_RETRY(read(fd, buf, get_size)); in CopyFileToFile()
459 ssize_t actual = TEMP_FAILURE_RETRY( in MapCentralDirectory0()
718 ssize_t actual = TEMP_FAILURE_RETRY(read(fd, ddBuf, sizeof(ddBuf))); in UpdateEntryFromDataDescriptor()
743 return TEMP_FAILURE_RETRY(pread64(fd, buf, len, off)); in ReadAtOffset()
753 return TEMP_FAILURE_RETRY(read(fd, buf, len)); in ReadAtOffset()
1020 const ZD_TYPE actual = TEMP_FAILURE_RETRY(read(fd, read_buf, getSize)); in InflateToFile()
1127 int result = TEMP_FAILURE_RETRY(ftruncate(fd, declared_length + current_offset)); in ExtractEntryToFile()
/system/core/debuggerd/
Dutility.cpp37 int written = TEMP_FAILURE_RETRY(write(fd, buf + len - to_write, to_write)); in write_to_am()
79 TEMP_FAILURE_RETRY(write(log->tfd, buf, len)); in _LOG()
98 pid_t n = TEMP_FAILURE_RETRY(waitpid(tid, &status, __WALL | WNOHANG)); in wait_for_sigstop()
Ddebuggerd.cpp143 status = TEMP_FAILURE_RETRY(poll(pollfds, 1, 3000)); in read_request()
151 status = TEMP_FAILURE_RETRY(read(fd, &msg, sizeof(msg))); in read_request()
232 if (TEMP_FAILURE_RETRY(write(fd, "\0", 1)) != 1) { in handle_request()
Dtombstone.cpp613 TEMP_FAILURE_RETRY( write(log->amfd, &datum, 4) ); in dump_crash()
615 TEMP_FAILURE_RETRY( write(log->amfd, &datum, 4) ); in dump_crash()
651 TEMP_FAILURE_RETRY( write(log->amfd, &eodMarker, 1) ); in dump_crash()
653 TEMP_FAILURE_RETRY( read(log->amfd, &eodMarker, 1) ); in dump_crash()
717 err = TEMP_FAILURE_RETRY(connect( in activity_manager_connect()
/system/core/fastbootd/commands/
Dflash.h57 … while ((len = TEMP_FAILURE_RETRY(read(fd, (void *) &buffer[readcount], size - readcount))) > 0) { in read_data_once()
/system/core/libsysutils/src/
DNetlinkListener.cpp50 count = TEMP_FAILURE_RETRY(uevent_kernel_multicast_uid_recv( in onDataAvailable()
DFrameworkClient.cpp24 ret = TEMP_FAILURE_RETRY(write(mSocket, msg, strlen(msg) +1)); in sendMsg()
DSocketListener.cpp114 rc = TEMP_FAILURE_RETRY(write(mCtrlPipe[1], &c, 1)); in stopListener()
194 TEMP_FAILURE_RETRY(read(mCtrlPipe[0], &c, 1)); in runListener()
270 TEMP_FAILURE_RETRY(write(mCtrlPipe[1], &b, 1)); in release()
DFrameworkListener.cpp58 len = TEMP_FAILURE_RETRY(read(c->getSocket(), buffer, sizeof(buffer))); in onDataAvailable()
/system/core/logd/
Dlibaudit.c136 rc = TEMP_FAILURE_RETRY(sendto(fd, &req, req.nlh.nlmsg_len, 0, in audit_send()
231 len = TEMP_FAILURE_RETRY(recvfrom(fd, rep, sizeof(*rep), flags, in audit_get_reply()
/system/core/run-as/
Dpackage.c98 fd = TEMP_FAILURE_RETRY(open(filename, O_RDONLY)); in map_file()
109 ret = TEMP_FAILURE_RETRY(fstat(fd, &st)); in map_file()
156 TEMP_FAILURE_RETRY(munmap(address, size)); in unmap_file()
/system/core/fastbootd/
Dutils.c170 ret = TEMP_FAILURE_RETRY(write(bulk_in, buf + count, length - count)); in bulk_write()
191 ret = TEMP_FAILURE_RETRY(read(bulk_out, buf + n, to_read)); in bulk_read()
/system/core/liblog/
Dlog_read.c293 ret = TEMP_FAILURE_RETRY(write(sock, buf, len)); in send_log_msg()
300 while ((ret = TEMP_FAILURE_RETRY(read(sock, cp, len))) > 0) { in send_log_msg()
315 ret = TEMP_FAILURE_RETRY(poll(&p, 1, 20)); in send_log_msg()
/system/netd/server/
DFwmarkServer.cpp69 int messageLength = TEMP_FAILURE_RETRY(recvmsg(client->getSocket(), &message, 0)); in processClient()
/system/core/init/
Dinit.c611 hwrandom_fd = TEMP_FAILURE_RETRY( in mix_hwrng_into_linux_rng_action()
624 urandom_fd = TEMP_FAILURE_RETRY( in mix_hwrng_into_linux_rng_action()
632 chunk_size = TEMP_FAILURE_RETRY( in mix_hwrng_into_linux_rng_action()
642 chunk_size = TEMP_FAILURE_RETRY(write(urandom_fd, buf, chunk_size)); in mix_hwrng_into_linux_rng_action()
Dproperty_service.c288 nr = TEMP_FAILURE_RETRY(poll(ufds, 1, timeout_ms)); in handle_property_set_fd()
299 r = TEMP_FAILURE_RETRY(recv(s, &msg, sizeof(msg), MSG_DONTWAIT)); in handle_property_set_fd()

12