Home
last modified time | relevance | path

Searched refs:TEMP_FAILURE_RETRY (Results 1 - 25 of 29) sorted by relevance

12

/base/hiviewdfx/hilog/frameworks/libhilog/socket/
H A Dsocket.cpp50 int tmpFd = TEMP_FAILURE_RETRY(socket(AF_UNIX, socketType, 0)); in GenerateFD()
53 res = TEMP_FAILURE_RETRY(socket(AF_UNIX, socketType, 0)); in GenerateFD()
65 int fd = TEMP_FAILURE_RETRY(socket(AF_UNIX, socketType, 0)); in Create()
88 return TEMP_FAILURE_RETRY(write(socketHandler, data, len)); in Write()
116 return TEMP_FAILURE_RETRY(writev(socketHandler, vec, len)); in WriteV()
121 return TEMP_FAILURE_RETRY(read(socketHandler, buffer, len)); in Read()
126 return TEMP_FAILURE_RETRY(recv(socketHandler, buffer, bufferLen, flags)); in Recv()
H A Dsocket_server.cpp57 socketHandler = TEMP_FAILURE_RETRY(socket(AF_UNIX, socketType, 0)); in Init()
70 return TEMP_FAILURE_RETRY(bind(socketHandler, (struct sockaddr *)&serverAddr, sizeof(sockaddr_un))); in Init()
75 return TEMP_FAILURE_RETRY(recv(socketHandler, buffer, bufferLen, flags)); in Recv()
80 return TEMP_FAILURE_RETRY(recvmsg(socketHandler, hdr, flags)); in RecvMsg()
85 return TEMP_FAILURE_RETRY(listen(socketHandler, backlog)); in Listen()
91 int result = TEMP_FAILURE_RETRY(poll(&info, 1, timeout.count())); in Poll()
99 return TEMP_FAILURE_RETRY(accept(socketHandler, (struct sockaddr*)&serverAddr, &addressSize)); in Accept()
H A Dsocket_client.cpp43 return TEMP_FAILURE_RETRY(connect(socketHandler, reinterpret_cast<sockaddr*>(&serverAddr), sizeof(serverAddr))); in Connect()
/base/hiviewdfx/hidumper/frameworks/native/
H A Ddump_utils.h22 #ifndef TEMP_FAILURE_RETRY
23 #define TEMP_FAILURE_RETRY macro
H A Ddump_utils.cpp297 int fd = TEMP_FAILURE_RETRY(open(path, O_RDONLY | O_CLOEXEC | O_NONBLOCK)); in FdToRead()
325 fd = TEMP_FAILURE_RETRY(open(fileName.c_str(), O_WRONLY | O_CREAT | O_CLOEXEC | O_NOFOLLOW, in FdToWrite()
/base/powermgr/power_manager/services/native/src/actions/default/suspend/
H A Drunning_lock_hub.cpp66 lockFd_ = UniqueFd(TEMP_FAILURE_RETRY(open(LOCK_PATH, O_RDWR | O_CLOEXEC))); in InitFd()
67 unlockFd_ = UniqueFd(TEMP_FAILURE_RETRY(open(UNLOCK_PATH, O_RDWR | O_CLOEXEC))); in InitFd()
H A Dsuspend_controller.cpp99 static UniqueFd suspendStateFd(TEMP_FAILURE_RETRY(open(SUSPEND_STATE_PATH, O_RDWR | O_CLOEXEC))); in SuspendEnter()
119 wakeupCountFd = UniqueFd(TEMP_FAILURE_RETRY(open(WAKEUP_COUNT_PATH, O_RDWR | O_CLOEXEC))); in WaitWakeupCount()
/base/hiviewdfx/hilog/frameworks/libhilog/base/
H A Dhilog_base.c39 int socketFd = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCKET_TYPE, 0)); in SendMessage()
46 TEMP_FAILURE_RETRY(connect(socketFd, (const struct sockaddr *)(&SOCKET_ADDR), sizeof(SOCKET_ADDR))); in SendMessage()
72 int ret = TEMP_FAILURE_RETRY(writev(socketFd, vec, LOG_LEN)); in SendMessage()
/base/startup/init/services/modules/init_context/
H A Dinit_context.c144 ssize_t rLen = TEMP_FAILURE_RETRY(read(subInfo->recvFd, buffer, sizeof(buffer))); in SubInitExecuteCmd()
146 rLen = TEMP_FAILURE_RETRY(read(subInfo->recvFd, buffer, sizeof(buffer))); in SubInitExecuteCmd()
196 ssize_t rLen = TEMP_FAILURE_RETRY(read(subInfo->recvFd, buffer, size)); in HandleRecvMessage_()
198 rLen = TEMP_FAILURE_RETRY(read(subInfo->recvFd, buffer, size)); in HandleRecvMessage_()
/base/hiviewdfx/hiview/plugins/faultlogger/service/idl/
H A Dfaultlog_query_result_ohos.cpp48 ret->fd = TEMP_FAILURE_RETRY(open(realPath.c_str(), O_RDONLY)); in GetNext()
/base/hiviewdfx/hisysevent/interfaces/native/innerkits/hisysevent_easy/
H A Deasy_socket_writer.c67 int socketId = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCK_DGRAM | SOCK_NONBLOCK | SOCK_CLOEXEC, 0)); in Write()
/base/powermgr/power_manager/test/unittest/src/
H A Drunning_lock_hub_native_test.cpp81 UniqueFd(TEMP_FAILURE_RETRY(open(Suspend::RunningLockHub::LOCK_PATH, O_RDWR | O_CLOEXEC))); in HWTEST_F()
/base/startup/init/services/modules/trace/
H A Dinit_trace.c356 zs.avail_in = (uInt)TEMP_FAILURE_RETRY(read(traceFd, inBuffer, CHUNK_SIZE)); in DumpCompressedTrace()
366 size_t bytesWritten = (size_t)TEMP_FAILURE_RETRY(write(outFd, outBuffer, have)); in DumpCompressedTrace()
394 bytesRead = TEMP_FAILURE_RETRY(read(traceFd, buffer, BLOCK_SIZE)); in DumpTrace()
398 bytesWritten = TEMP_FAILURE_RETRY(write(outFd, buffer, bytesRead)); in DumpTrace()
/base/hiviewdfx/hisysevent/interfaces/native/innerkits/hisysevent/
H A Dtransport.cpp90 auto socketId = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCK_DGRAM | SOCK_NONBLOCK | SOCK_CLOEXEC, 0)); in SendToHiSysEventDataSource()
/base/hiviewdfx/hiview/plugins/faultlogger/interfaces/cj/
H A Dfaultlogger_ffi.cpp64 int nread = TEMP_FAILURE_RETRY(read((fd), buf, BUF_SIZE_512 - 1)); in ConvertInform()
/base/hiviewdfx/hitrace/cmd/src/
H A Dhitrace_cmd.cpp520 bytesRead = TEMP_FAILURE_RETRY(read(traceFd, in.get(), CHUNK_SIZE)); in DumpCompressedTrace()
532 bytesWritten = TEMP_FAILURE_RETRY(write(outFd, out.get(), CHUNK_SIZE)); in DumpCompressedTrace()
543 bytesWritten = TEMP_FAILURE_RETRY(write(outFd, out.get(), have)); in DumpCompressedTrace()
594 bytesRead = TEMP_FAILURE_RETRY(read(traceFd, buffer, blockSize)); in DumpTrace()
598 bytesWritten = TEMP_FAILURE_RETRY(write(outFd, buffer, bytesRead)); in DumpTrace()
/base/startup/init/interfaces/innerkits/fd_holder/
H A Dfd_holder.c105 if (TEMP_FAILURE_RETRY(sendmsg(sock, &msghdr, MSG_NOSIGNAL)) < 0) { in ServiceSendFds()
H A Dfd_holder_internal.c137 ssize_t rc = TEMP_FAILURE_RETRY(recvmsg(sock, &msghdr, flags)); in ReceiveFds()
/base/startup/init/services/init/standard/
H A Dfd_holder_service.c86 if (TEMP_FAILURE_RETRY(sendmsg(sock, &msghdr, MSG_NOSIGNAL)) < 0) { in SendErrorInfo()
/base/hiviewdfx/hiview/plugins/sysevent_source/
H A Devent_server.cpp157 socketId = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCK_DGRAM | SOCK_NONBLOCK | SOCK_CLOEXEC, 0)); in InitSocket()
164 if (TEMP_FAILURE_RETRY(bind(socketId, reinterpret_cast<sockaddr*>(&serverAddr), sizeof(serverAddr))) < 0) { in InitSocket()
/base/hiviewdfx/hiview/plugins/faultlogger/service/
H A Dfaultlogger.cpp604 int fd = TEMP_FAILURE_RETRY(open(outputFilePath.c_str(), O_CREAT | O_RDWR | O_APPEND, DEFAULT_LOG_FILE_MODE)); in ReportJsErrorToAppEvent()
868 nread = TEMP_FAILURE_RETRY(read(*info.pipeFd, buffer, MAX_PIPE_SIZE)); in GetStackInfo()
943 ssize_t nread = TEMP_FAILURE_RETRY(read(fds[0], buffer, sizeof(buffer) - 1)); in GetHilog()
952 if (TEMP_FAILURE_RETRY(waitpid(childPid, nullptr, 0)) != childPid) { in GetHilog()
/base/hiviewdfx/hiview/plugins/faultlogger/test/common/unittest/
H A Dfaultlogger_unittest.cpp247 int fd = TEMP_FAILURE_RETRY(open("/data/test/testFile", O_CREAT | O_WRONLY | O_TRUNC, 770)); in HWTEST_F()
296 int fd = TEMP_FAILURE_RETRY(open("/data/test/testFile", O_CREAT | O_WRONLY | O_TRUNC, 770)); in HWTEST_F()
337 int fd = TEMP_FAILURE_RETRY(open("/data/test/testFile", O_CREAT | O_WRONLY | O_TRUNC, 770)); in HWTEST_F()
397 TEMP_FAILURE_RETRY(write(pipeFd[1], jsonInfo.c_str(), jsonInfo.size())); in GenCppCrashLogTestCommon()
727 TEMP_FAILURE_RETRY(write(fd, content.data(), content.length())); in HWTEST_F()
1003 auto fd = TEMP_FAILURE_RETRY(open("/data/test/testFile2", O_CREAT | O_WRONLY | O_TRUNC, 770)); in HWTEST_F()
/base/hiviewdfx/hilog/frameworks/libhilog/
H A Dhilog_printf.cpp209 return TEMP_FAILURE_RETRY(write(fd, logInfo, strlen(logInfo))); in LogToKmsg()
/base/hiviewdfx/hiview/base/utility/
H A Dfile_util.cpp263 if (writeSize != TEMP_FAILURE_RETRY(write(fd, buffer, size))) { in WriteBufferToFd()
/base/hiviewdfx/hiview/plugins/faultlogger/interfaces/js/napi/
H A Dnapi_faultlogger.cpp60 int nread = TEMP_FAILURE_RETRY(read((fd), buf, BUF_SIZE_512 - 1)); in ConversionInform()

Completed in 15 milliseconds

12